subscriptions

type Channel interface {
	Broadcast([]byte)
}

type SessionStore interface {
	ByID(ctx context.Context, id string) (*sessions.Session, error)
}

type Store interface {
	ByTopic(tenant string, pattern []byte) (*pb.SubscriptionMetadataList, error)
	ByID(id string) (*pb.Subscription, error)
	All() (*pb.SubscriptionMetadataList, error)
	BySession(id string) (*pb.SubscriptionMetadataList, error)
	Create(message *pb.Subscription) error
	Delete(id string) error
}