notifier

Documentation

Index

• func RecordIsOpen(ctx context.Context) (bool, error)
• func RecordPathFromContext(ctx context.Context) (string, error)
• type ChangeStore
• type Hook
• type Notifier
  • func NewNotifier(changeStore ChangeStore, hooks []Hook) *Notifier
  • func (n *Notifier) SetLogger(logger *log.Logger)
  • func (n *Notifier) Start(ctx context.Context)

Functions

func RecordIsOpen

func RecordIsOpen(ctx context.Context) (bool, error)

func RecordPathFromContext

func RecordPathFromContext(ctx context.Context) (string, error)

Types

type ChangeStore

type ChangeStore interface {
	AwaitNextChangeBatch(ctx context.Context) (state.ChangeBatch, error)
}

type Hook

type Hook func(ctx context.Context, changes state.Changes) error

type Notifier

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

func NewNotifier

func NewNotifier(changeStore ChangeStore, hooks []Hook) *Notifier

func (*Notifier) SetLogger

func (n *Notifier) SetLogger(logger *log.Logger)

func (*Notifier) Start

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