log

type Aggregator interface {
	// Listen causes an aggregator to begin consuming messages via its underlying transport
	// mechanism. Implementations of this must be non-blocking. Stop() can be called to stop the
	// aggregator.
	Listen() error
	// Stop stops the consumer and blocks until it stops or the configured duration passes. In the
	// latter case, returns an error of type ErrStopTimedOut
	Stop() error
	// Stopped returns a channel that will receive when the consumer has stopped. The error received
	// may be nil, which means it was stopped cleanly. A non-nil error means it stopped because it
	// errored.
	Stopped() <-chan error
}

type Docker struct {
	ContainerID string `json:"container_id"`
}

type ErrStopTimedOut struct {
	Timeout time.Duration
}

type Kubernetes struct {
	Namespace     string            `json:"namespace_name"`
	PodID         string            `json:"pod_id"`
	PodName       string            `json:"pod_name"`
	ContainerName string            `json:"container_name"`
	Labels        map[string]string `json:"labels"`
	Host          string            `json:"host"`
}

type Message struct {
	Log        string     `json:"log"`
	Stream     string     `json:"stream"`
	Kubernetes Kubernetes `json:"kubernetes"`
	Docker     Docker     `json:"docker"`
	Time       time.Time  `json:"time"`
}