peer

type ExecCallback struct {
	Cmd    commandpb.Command
	Result []byte
}

type ExecPacket struct {
	Cmd      commandpb.Command
	IsSpec   bool
	Meta     []byte
	Callback bool
	NoExec   bool
}

type LocalConfig struct {
	*pb.PeerConfig
	Peers      []pb.PeerID
	PeerAddrs  map[pb.PeerID]string
	ListenAddr string
	ID         pb.PeerID
	Logger     logger.Logger
	RandSeed   int64
}

type Peer struct {
	// contains filtered or unexported fields
}

type Protocol interface {
	Step(peerpb.Message)
	Tick()
	Request(*commandpb.Command)
	Callback(ExecCallback)

	MakeReady() Ready
	ClearMsgs()
	ClearExecutedCommands()

	AsyncCallback()
}

type Ready struct {
	Messages        []pb.Message
	OrderedCommands []ExecPacket
}

type TickingTimer interface {
	Tick()
	Reset()
	Stop()
	Instrument(func())
	IsSet() bool
}