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(yamlConfig []byte, logger *log.Entry) error
- func (d *DockerSource) ConfigureByDSN(dsn string, labels map[string]string, logger *log.Entry, uuid string) 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) GetUuid() 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) UnmarshalConfig(yamlConfig []byte) error
- func (d *DockerSource) WatchContainer(monitChan chan *ContainerConfig, deleteChan chan *ContainerConfig) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ContainerConfig ¶
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(yamlConfig []byte, logger *log.Entry) error
func (*DockerSource) ConfigureByDSN ¶
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) GetUuid ¶ added in v1.5.0
func (d *DockerSource) GetUuid() 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, deleteChan chan *ContainerConfig) error
func (*DockerSource) UnmarshalConfig ¶ added in v1.5.0
func (d *DockerSource) UnmarshalConfig(yamlConfig []byte) error
func (*DockerSource) WatchContainer ¶
func (d *DockerSource) WatchContainer(monitChan chan *ContainerConfig, deleteChan chan *ContainerConfig) error
Click to show internal directories.
Click to hide internal directories.