net

type ClientMsgWrapper struct {
	Msg       interface{}
	Timestamp hlc.Timestamp
	C         chan interface{} // reply channel created by request receiver
}

type Codec interface {
	Scheme() string
	Encode(interface{})
	Decode(interface{})
}

type Communication interface {
	AddAddress(id idservice.ID, addr string)

	GetAddresses() map[idservice.ID]string

	GetKnownIDs() []idservice.ID

	// Send put message to outbound queue
	Send(to idservice.ID, m interface{}) error

	// MulticastZone send msg to all nodes in the same site
	MulticastZone(zone int, m interface{})

	// MulticastQuorum sends msg to random number of nodes
	MulticastQuorum(quorum int, m interface{})

	// Broadcast send to all peers
	Broadcast(m interface{})

	// BroadcastOneDifferent sends m1 to one random peer, and m2 to the rest
	BroadcastOneDifferent(m1 interface{}, m2 interface{})

	// Recv receives a message
	Recv() interface{}

	Close()

	// Fault injection
	Drop(id idservice.ID, t int)             // drops every message send to NodeId last for t seconds
	Slow(id idservice.ID, d int, t int)      // delays every message send to NodeId for d ms and last for t seconds
	Flaky(id idservice.ID, p float64, t int) // drop message by chance p for t seconds
	Crash(t int)                             // node crash for t seconds
}

type HandshakeMsg struct {
	IsClient bool // whether this is a client connecting, if not we should have a NodeId
	NodeId   idservice.ID
}

type ProtocolMsg struct {
	HlcTime int64
	MsgId   int64
	Msg     interface{}
}

type Read struct {
	CommandID int
	Key       db.Key
}

type ReadReply struct {
	CommandID int
	Value     db.Value
}

type Reply struct {
	Command    db.Command
	Value      db.Value
	NodeID     idservice.ID
	Properties map[string]string
	Timestamp  int64
	HasErr     bool
	ErrStr     string
}

type Request struct {
	Command    db.Command        // Commands for the request
	Properties map[string]string // any additional metadata
	Timestamp  int64
	NodeID     idservice.ID // forward by node. This means the request is not directly from client and is forwarded
}

type TransportLink interface {
	// Scheme returns transportLink scheme
	Scheme() string

	// Mode returns whether this transportLink is a listener of a dialer
	Mode() TransportMode

	// Send sends message into t.send chan
	Send(interface{})

	// Recv waits for message from t.recv chan
	Recv() interface{}

	// Dial connects to remote server non-blocking once connected
	Dial() error

	// StartOutgoing starts sending any messages in outbound channel on an existing connection
	StartOutgoing(conn net.Conn)

	// Starts handling incoming messages from the remote endpoint
	StartIncoming(conn net.Conn, tm TransportLinkManager)

	// Listen waits for connections, non-blocking once listener starts
	Listen(tm TransportLinkManager)

	// Close closes send channel and stops listener
	Close()
}

type TransportLinkManager interface {
	// Adds transportLink to an existing pool of all transports
	AddTransportLink(t TransportLink, to idservice.ID)
}

type TransportMode int