distributed

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

type SessionMetadatasState interface {
	Create(id string, clientID string, connectedAt int64, lwt *packet.Publish, mountpoint string) error
	Get(id string) (api.SessionMetadatas, error)
	ByClientID(clientID string) (api.SessionMetadatas, error)
	ByPeer(peer uint64) []api.SessionMetadatas
	All() []api.SessionMetadatas
	Delete(id string) error
	DeletePeer(peer uint64) error
}

type State interface {
	Subscriptions() SubscriptionsState
	SessionMetadatas() SessionMetadatasState
	Topics() TopicsState
	Distributor() memberlist.Delegate
}

type SubscriptionsState interface {
	Create(sessionID string, pattern []byte, qos int32) error
	CreateFrom(sessionID string, peer uint64, pattern []byte, qos int32) error
	All() []api.Subscription
	ByPattern(pattern []byte) []api.Subscription
	ByPeer(peer uint64) []api.Subscription
	Delete(sessionID string, pattern []byte) error
	DeletePeer(peer uint64)
	DeleteSession(sessionID string)
}

type TopicsState interface {
	Set(message *packet.Publish) error
	Delete(topic []byte) error
	Get(pattern []byte) ([]api.RetainedMessage, error)
}