subscriptions

Documentation

Index

• func New(id string, logger *zap.Logger) *server
• func TenantTopicIndexer() *topicIndexer
• type Store
  • func NewMemDBStore() Store

Functions

func New

func New(id string, logger *zap.Logger) *server

func TenantTopicIndexer

func TenantTopicIndexer() *topicIndexer

Types

type Store

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

func NewMemDBStore

func NewMemDBStore() Store