diff options
| author | Jimmy Hu <jimmy.hu@dexon.org> | 2019-01-09 15:32:08 +0800 |
|---|---|---|
| committer | Wei-Ning Huang <w@dexon.org> | 2019-01-09 15:32:08 +0800 |
| commit | 25018527ec18ec2830801983d19e63a0ebf7b263 (patch) | |
| tree | 6c6f1bc251b24da1fd9d6df7375f931fbae35a00 /core/test/interface.go | |
| parent | c62ce07468cea07035ddcad3c89b0a5c0b25746a (diff) | |
| download | dexon-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.tar.gz dexon-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.tar.zst dexon-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.go | 8 |
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. |