dockeracquisition

Documentation

Index

• func ReadTailScanner(scanner *bufio.Scanner, out chan string, t *tomb.Tomb) error
• type ContainerConfig
• type DockerConfiguration
• type DockerSource
  • func (d *DockerSource) CanRun() error
  • func (d *DockerSource) Configure(Config []byte, logger *log.Entry) error
  • func (d *DockerSource) ConfigureByDSN(dsn string, labels map[string]string, logger *log.Entry) error
  • func (d *DockerSource) DockerManager(in chan *ContainerConfig, deleteChan chan *ContainerConfig, ...) error
  • func (d *DockerSource) Dump() interface{}
  • func (d *DockerSource) EvalContainer(container dockerTypes.Container) (*ContainerConfig, bool)
  • func (d *DockerSource) GetAggregMetrics() []prometheus.Collector
  • func (d *DockerSource) GetMetrics() []prometheus.Collector
  • func (d *DockerSource) GetMode() string
  • func (d *DockerSource) GetName() string
  • func (d *DockerSource) OneShotAcquisition(out chan types.Event, t *tomb.Tomb) error
  • func (d *DockerSource) StreamingAcquisition(out chan types.Event, t *tomb.Tomb) error
  • func (d *DockerSource) SupportedModes() []string
  • func (d *DockerSource) TailDocker(container *ContainerConfig, outChan chan types.Event) error
  • func (d *DockerSource) WatchContainer(monitChan chan *ContainerConfig, deleteChan chan *ContainerConfig) error

Functions

func ReadTailScanner

func ReadTailScanner(scanner *bufio.Scanner, out chan string, t *tomb.Tomb) error

Types

type ContainerConfig

type ContainerConfig struct {
	Name string
	ID   string

	Labels map[string]string
	// contains filtered or unexported fields
}

type DockerConfiguration

type DockerConfiguration struct {
	CheckInterval                     string   `yaml:"check_interval"`
	FollowStdout                      bool     `yaml:"follow_stdout"`
	FollowStdErr                      bool     `yaml:"follow_stderr"`
	Until                             string   `yaml:"until"`
	Since                             string   `yaml:"since"`
	DockerHost                        string   `yaml:"docker_host"`
	ContainerName                     []string `yaml:"container_name"`
	ContainerID                       []string `yaml:"container_id"`
	ContainerNameRegexp               []string `yaml:"container_name_regexp"`
	ContainerIDRegexp                 []string `yaml:"container_id_regexp"`
	ForceInotify                      bool     `yaml:"force_inotify"`
	configuration.DataSourceCommonCfg `yaml:",inline"`
}

type DockerSource

type DockerSource struct {
	Config DockerConfiguration

	CheckIntervalDuration time.Duration

	Client client.CommonAPIClient
	// contains filtered or unexported fields
}

func (*DockerSource) CanRun

func (d *DockerSource) CanRun() error

func (*DockerSource) Configure

func (d *DockerSource) Configure(Config []byte, logger *log.Entry) error

func (*DockerSource) ConfigureByDSN

func (d *DockerSource) ConfigureByDSN(dsn string, labels map[string]string, logger *log.Entry) error

func (*DockerSource) DockerManager

func (d *DockerSource) DockerManager(in chan *ContainerConfig, deleteChan chan *ContainerConfig, outChan chan types.Event) error

func (*DockerSource) Dump

func (d *DockerSource) Dump() interface{}

func (*DockerSource) EvalContainer

func (d *DockerSource) EvalContainer(container dockerTypes.Container) (*ContainerConfig, bool)

func (*DockerSource) GetAggregMetrics

func (d *DockerSource) GetAggregMetrics() []prometheus.Collector

func (*DockerSource) GetMetrics

func (d *DockerSource) GetMetrics() []prometheus.Collector

func (*DockerSource) GetMode

func (d *DockerSource) GetMode() string

func (*DockerSource) GetName

func (d *DockerSource) GetName() string

func (*DockerSource) OneShotAcquisition

func (d *DockerSource) OneShotAcquisition(out chan types.Event, t *tomb.Tomb) error

OneShotAcquisition reads a set of file and returns when done

func (*DockerSource) StreamingAcquisition

func (d *DockerSource) StreamingAcquisition(out chan types.Event, t *tomb.Tomb) error

func (*DockerSource) SupportedModes

func (d *DockerSource) SupportedModes() []string

SupportedModes returns the supported modes by the acquisition module

func (*DockerSource) TailDocker

func (d *DockerSource) TailDocker(container *ContainerConfig, outChan chan types.Event) error

func (*DockerSource) WatchContainer

func (d *DockerSource) WatchContainer(monitChan chan *ContainerConfig, deleteChan chan *ContainerConfig) error