eventmonitor

type CWSStatusProvider interface {
	GetStatus(ctx context.Context) (*api.Status, error)
}

type EventConsumer interface {
	// IDer implements the ID method to return unique ID of the event consumer
	probe.IDer
	// Start starts the event consumer
	Start() error
	// Stop stops the event consumer
	Stop()
}

type EventConsumerHandler interface {
	probe.EventConsumerHandler
}

type EventConsumerPostProbeStartHandler interface {
	// PostProbeStart is called after the event stream (the probe) is started
	PostProbeStart() error
}

type EventMonitor struct {
	sync.RWMutex
	Probe *probe.Probe

	Config       *config.Config
	StatsdClient statsd.ClientInterface
	// contains filtered or unexported fields
}

type Opts struct {
	ProbeOpts    probe.Opts
	StatsdClient statsd.ClientInterface
}