notifier

Documentation

Index

• type NotificationTopic
• type Notifier
  • func New(archetype *baseservice.Archetype, listener riverdriver.Listener, ...) *Notifier
  • func (n *Notifier) Listen(ctx context.Context, topic NotificationTopic, notifyFunc NotifyFunc) (*Subscription, error)
  • func (n *Notifier) Start(ctx context.Context) error
• type NotifyFunc
• type Subscription
  • func (s *Subscription) Unlisten(ctx context.Context)

Types

type NotificationTopic

type NotificationTopic string

const (
	NotificationTopicControl    NotificationTopic = "river_control"
	NotificationTopicInsert     NotificationTopic = "river_insert"
	NotificationTopicLeadership NotificationTopic = "river_leadership"
)

type Notifier

type Notifier struct {
	baseservice.BaseService
	startstop.BaseStartStop
	// contains filtered or unexported fields
}

func New

func New(archetype *baseservice.Archetype, listener riverdriver.Listener, statusChangeFunc func(componentstatus.Status)) *Notifier

func (*Notifier) Listen

func (n *Notifier) Listen(ctx context.Context, topic NotificationTopic, notifyFunc NotifyFunc) (*Subscription, error)

func (*Notifier) Start

func (n *Notifier) Start(ctx context.Context) error

type NotifyFunc

type NotifyFunc func(topic NotificationTopic, payload string)

type Subscription

type Subscription struct {
	// contains filtered or unexported fields
}

func (*Subscription) Unlisten

func (s *Subscription) Unlisten(ctx context.Context)