notifier

Documentation

Index

• func ModuleFromContext(ctx context.Context) (*state.Module, error)
• func ModuleIsOpen(ctx context.Context) (bool, error)
• type Hook
• type ModuleStore
• type Notifier
  • func NewNotifier(modStore ModuleStore, hooks []Hook) *Notifier
  • func (n *Notifier) SetLogger(logger *log.Logger)
  • func (n *Notifier) Start(ctx context.Context)

Functions

func ModuleFromContext

func ModuleFromContext(ctx context.Context) (*state.Module, error)

func ModuleIsOpen

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

Types

type Hook

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

type ModuleStore

type ModuleStore interface {
	AwaitNextChangeBatch(ctx context.Context) (state.ModuleChangeBatch, error)
	ModuleByPath(path string) (*state.Module, error)
}

type Notifier

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

func NewNotifier

func NewNotifier(modStore ModuleStore, hooks []Hook) *Notifier

func (*Notifier) SetLogger

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

func (*Notifier) Start

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