agent

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

type ContainerStreamerParams struct {
	ID          string
	Name        string
	LogWriter   io.WriteCloser
	ErrWriter   io.WriteCloser
	LogsEmitter LogsEmitter
}

type DemoEmitter struct {
	Duration time.Duration
}

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

type DockerClient interface {
	ListContainers(opts docker.ListContainersOptions) ([]docker.APIContainers, error)
	AddEventListener(listener chan<- *docker.APIEvents) error
}

type Event struct {
	ContainerID   string
	ContainerName string
	Group         string // group is the "path" part of the image tag, i.e. for umputun/system/logger:latest it will be "system"
	TS            time.Time
	Status        bool
}

type EventLoop struct {
	MixOuts       bool
	WriterFactory func(ctx context.Context, containerName, group string) (logWriter, errWriter io.WriteCloser, err error)

	LogEmitter LogEmitter
	Events     Eventer
	// contains filtered or unexported fields
}

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

type Eventer interface {
	Channel() <-chan Event
}

type LogEmitter interface {
	Logs(opts docker.LogsOptions) error
}

type LogStreamer interface {
	Run() error
	Close(ctx context.Context) error
	Name() string
}

type LogsEmitter interface {
	Logs(docker.LogsOptions) error // runs endless loop publishing logs to writers from LogsOptions
}

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