types

type Channel interface {
	Broadcast(b []byte)
	BroadcastFullState(b []byte)
}

type GossipServiceLayer interface {
	ServiceLayer
	Leave()
	Members() []*memberlist.Node
	UpdateMeta([]byte)
	Join([]string) error
	AddState(key string, state GossipState) (Channel, error)
}

type GossipState interface {
	Merge(inc []byte, full bool) error
	MarshalBinary() []byte
}

type RaftServiceLayer interface {
	ServiceLayer
	Start(name string, state RaftState) error
	ApplyEvent(event []byte) error
	Shutdown() error
	IsLeader() bool
}

type RaftState interface {
	Apply(event []byte) error
	Snapshot() io.ReadCloser
	Restore(io.Reader) error
}

type ServiceLayer interface {
	pb.LayerServer
	Health() string
}