watcher

Documentation

Index

• type Watcher
  • func NewWatcher(agentConfig *config.Config) *Watcher
  • func (w *Watcher) Close(ctx context.Context) error
  • func (*Watcher) Info() *bus.Info
  • func (w *Watcher) Init(ctx context.Context, messagePipe bus.MessagePipeInterface) error
  • func (w *Watcher) Process(ctx context.Context, msg *bus.Message)
  • func (*Watcher) Subscriptions() []string

Types

type Watcher

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

nolint

func NewWatcher

func NewWatcher(agentConfig *config.Config) *Watcher

func (*Watcher) Close

func (w *Watcher) Close(ctx context.Context) error

nolint: unparam error is always nil

func (*Watcher) Info

func (*Watcher) Info() *bus.Info

func (*Watcher) Init

func (w *Watcher) Init(ctx context.Context, messagePipe bus.MessagePipeInterface) error

nolint: unparam error is always nil

func (*Watcher) Process

func (w *Watcher) Process(ctx context.Context, msg *bus.Message)

func (*Watcher) Subscriptions

func (*Watcher) Subscriptions() []string