watcher

package

v3.3.2 Latest Latest Go to latest Published: Sep 24, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewWatcher(agentConfig *config.Config) *Watcher

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

error is always nil

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

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

error is always nil

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

func (*Watcher) Subscriptions() []string

Path	Synopsis
credentials
file
health
healthfakes Code generated by counterfeiter.	Code generated by counterfeiter.
instance
instancefakes Code generated by counterfeiter.	Code generated by counterfeiter.
process
processfakes Code generated by counterfeiter.	Code generated by counterfeiter.
watcherfakes Code generated by counterfeiter.	Code generated by counterfeiter.