monitor

package

v1.19.1 Latest Latest Go to latest Published: Feb 17, 2026 License: Apache-2.0 Imports: 18 Imported by: 2

Details

This section is empty.

This section is empty.

func NewConsumer(observer Observer, lostEventSendInterval time.Duration) *consumer

NewConsumer returns a new consumer that sends events to the provided Observer.

func NewMonitorFilter(logger *slog.Logger, monitorEventFilters []string) (*monitorFilter, error)

NewMonitorFilter creates a new monitor filter. If monitorEventFilters is empty, no events are allowed.

type Observer interface {
	GetEventsChannel() chan *observerTypes.MonitorEvent
	GetLogger() *slog.Logger
}

Observer is the receiver of MonitorEvents