subscription

May 2, 2023

Changes in this version

type Service

+ HasSubscribers func() bool

type Subscription

+ HasSubscribers func(channel string) bool

May 2, 2023

Changes in this version

+ type NodeService interface

+ Subscribe func(ctx context.Context) (_ <-chan model.NodeChangedEvent, err error)

+ func NewNodeService(subscription Subscription) NodeService

+ type Service interface

+ Notify func(category T) error

+ Subscribe func(ctx context.Context) (<-chan T, error)

+ func NewPeerService(subscription Subscription) Service[*model.PeerChangedEvent]

+ func NewServerService(subscription Subscription) Service[*model.ServerChangedEvent]

+ func NewUserService(subscription Subscription) Service[*model.UserChangedEvent]

+ type Subscription interface

+ Notify func(bytes []byte, channel string) error

+ Subscribe func(ctx context.Context, channel string) (<-chan []byte, error)

+ func NewInMemorySubscription() Subscription