notifier

Documentation

Index

• type NotificationTopic
• type Notifier
  • func New(archetype *baseservice.Archetype, connConfig *pgx.ConnConfig, ...) *Notifier
  • func (n *Notifier) Listen(topic NotificationTopic, notifyFunc NotifyFunc) *Subscription
  • func (n *Notifier) Run(ctx context.Context)
• type NotifyFunc
• type Subscription
  • func (s *Subscription) Unlisten()

Types

type NotificationTopic

type NotificationTopic string

const (
	NotificationTopicInsert     NotificationTopic = "river_insert"
	NotificationTopicLeadership NotificationTopic = "river_leadership"
	NotificationTopicJobControl NotificationTopic = "river_job_control"
)

type Notifier

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

func New

func New(archetype *baseservice.Archetype, connConfig *pgx.ConnConfig, statusChangeFunc func(componentstatus.Status), logger *slog.Logger) *Notifier

func (*Notifier) Listen

func (n *Notifier) Listen(topic NotificationTopic, notifyFunc NotifyFunc) *Subscription

func (*Notifier) Run

func (n *Notifier) Run(ctx context.Context)

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()