Versions in this module Expand all Collapse all v0 v0.9.0 Apr 22, 2026 Changes in this version + func DockerEventsArgs(clusterName string) []string + func SystemdMonitorArgs(container docker.ContainerName) []string + type DockerMonitor struct + func NewDockerMonitor(containerPrefix string) *DockerMonitor + func (m *DockerMonitor) Run(ctx context.Context, r io.Reader, ch chan<- Event) error + type Event struct + Container docker.ContainerName + Detail string + Err error + Kind EventKind + Node string + Time time.Time + Unit string + type EventKind string + const EventContainerDie + const EventContainerOOM + const EventContainerPause + const EventContainerStart + const EventContainerUnpause + const EventMonitorError + const EventUnitActive + const EventUnitFailed + type NodeTarget struct + Container docker.ContainerName + ShortName string + type SystemdMonitor struct + func NewSystemdMonitor(node string, container docker.ContainerName) *SystemdMonitor + func (m *SystemdMonitor) Run(ctx context.Context, r io.Reader, ch chan<- Event) error + type Watcher struct + func NewWatcher(executor cmdexec.Executor, containerPrefix, clusterName string) *Watcher + func (w *Watcher) AddNodes(ctx context.Context, nodes []NodeTarget) + func (w *Watcher) Start(ctx context.Context, nodes []NodeTarget) error + func (w *Watcher) Subscribe() <-chan Event + func (w *Watcher) Unsubscribe(ch <-chan Event) + func (w *Watcher) Wait()
Go to main page