add_docker_metadata

type Client interface {
	ContainerList(ctx context.Context, options types.ContainerListOptions) ([]types.Container, error)
	Events(ctx context.Context, options types.EventsOptions) (<-chan events.Message, <-chan error)
}

type Config struct {
	Host        string     `config:"host"`
	TLS         *TLSConfig `config:"ssl"`
	Fields      []string   `config:"match_fields"`
	MatchSource bool       `config:"match_source"`
	SourceIndex int        `config:"match_source_index"`

	// Annotations are kept after container is killled, until they haven't been accessed
	// for a full `cleanup_timeout`:
	CleanupTimeout time.Duration `config:"cleanup_timeout"`
}

type Container struct {
	ID     string
	Name   string
	Image  string
	Labels map[string]string
}

type TLSConfig struct {
	CA          string `config:"certificate_authority"`
	Certificate string `config:"certificate"`
	Key         string `config:"key"`
}

type Watcher interface {
	// Start watching docker API for new containers
	Start() error

	// Stop watching docker API for new containers
	Stop()

	// Container returns the running container with the given ID or nil if unknown
	Container(ID string) *Container

	// Containers returns the list of known containers
	Containers() map[string]*Container
}

type WatcherConstructor func(host string, tls *TLSConfig) (Watcher, error)