subscription

Documentation

Index

• type NodeService
  • func NewNodeService(subscription Subscription) NodeService
• type Service
  • func NewPeerService(subscription Subscription) Service[*model.PeerChangedEvent]
  • func NewServerService(subscription Subscription) Service[*model.ServerChangedEvent]
  • func NewUserService(subscription Subscription) Service[*model.UserChangedEvent]
• type Subscription
  • func NewInMemorySubscription() Subscription

Types

type NodeService

type NodeService interface {
	Subscribe(ctx context.Context) (_ <-chan model.NodeChangedEvent, err error)
}

func NewNodeService

func NewNodeService(subscription Subscription) NodeService

type Service

type Service[T model.NodeChangedEvent] interface {
	Notify(event T) error
	Subscribe(ctx context.Context) (<-chan T, error)
	HasSubscribers() bool
}

func NewPeerService

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

func NewServerService

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

func NewUserService

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

type Subscription

type Subscription interface {
	Notify(bytes []byte, channel string) error
	Subscribe(ctx context.Context, channel string) (<-chan []byte, error)
	HasSubscribers(channel string) bool
}

func NewInMemorySubscription

func NewInMemorySubscription() Subscription