aboutsummaryrefslogtreecommitdiffstats
path: root/core/test/interface.go
diff options
context:
space:
mode:
authorJimmy Hu <jimmy.hu@dexon.org>2019-01-09 15:32:08 +0800
committerWei-Ning Huang <w@dexon.org>2019-01-09 15:32:08 +0800
commit25018527ec18ec2830801983d19e63a0ebf7b263 (patch)
tree6c6f1bc251b24da1fd9d6df7375f931fbae35a00 /core/test/interface.go
parentc62ce07468cea07035ddcad3c89b0a5c0b25746a (diff)
downloadtangerine-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.tar
tangerine-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.tar.gz
tangerine-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.tar.bz2
tangerine-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.tar.lz
tangerine-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.tar.xz
tangerine-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.tar.zst
tangerine-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.zip
simulation: fix k8s dmoment issue (#416)
* Handshake with server dmoment * Start simulation from dMoment * Update k8s config
Diffstat (limited to 'core/test/interface.go')
-rw-r--r--core/test/interface.go8
1 files changed, 8 insertions, 0 deletions
diff --git a/core/test/interface.go b/core/test/interface.go
index d9578de..000b835 100644
--- a/core/test/interface.go
+++ b/core/test/interface.go
@@ -18,6 +18,8 @@
package test
import (
+ "time"
+
"github.com/dexon-foundation/dexon-consensus/core/crypto"
"github.com/dexon-foundation/dexon-consensus/core/db"
"github.com/dexon-foundation/dexon-consensus/core/types"
@@ -77,6 +79,9 @@ type TransportServer interface {
Host() (chan *TransportEnvelope, error)
// WaitForPeers waits for all peers to join the network.
WaitForPeers(numPeers uint32) error
+
+ // SetDMoment
+ SetDMoment(time.Time)
}
// TransportClient defines those peers in the network.
@@ -86,6 +91,9 @@ type TransportClient interface {
Report(msg interface{}) error
// Join the network, should block until joined.
Join(serverEndpoint interface{}) (<-chan *TransportEnvelope, error)
+
+ // DMoment returns the DMoment of the network.
+ DMoment() time.Time
}
// Transport defines the interface for basic transportation capabilities.