Documentation
¶
Index ¶
- Constants
- func ReadTailScanner(scanner *bufio.Scanner, out chan string, t *tomb.Tomb) error
- type BackOffFactory
- type Configuration
- type ContainerConfig
- type Source
- func (*Source) CanRun() error
- func (d *Source) Configure(ctx context.Context, yamlConfig []byte, logger *log.Entry, ...) error
- func (d *Source) ConfigureByDSN(_ context.Context, dsn string, labels map[string]string, logger *log.Entry, ...) error
- func (d *Source) ContainerManager(ctx context.Context, in chan *ContainerConfig, ...) error
- func (d *Source) Dump() any
- func (d *Source) EvalContainer(ctx context.Context, container dockerContainer.Summary) *ContainerConfig
- func (d *Source) EvalService(_ context.Context, service dockerTypesSwarm.Service) *ContainerConfig
- func (*Source) GetAggregMetrics() []prometheus.Collector
- func (*Source) GetMetrics() []prometheus.Collector
- func (d *Source) GetMode() string
- func (*Source) GetName() string
- func (d *Source) GetUuid() string
- func (d *Source) OneShotAcquisition(ctx context.Context, out chan pipeline.Event, t *tomb.Tomb) error
- func (d *Source) ServiceManager(ctx context.Context, in chan *ContainerConfig, ...) error
- func (d *Source) StreamingAcquisition(ctx context.Context, out chan pipeline.Event, t *tomb.Tomb) error
- func (d *Source) TailContainer(ctx context.Context, container *ContainerConfig, outChan chan pipeline.Event, ...) error
- func (d *Source) TailService(ctx context.Context, service *ContainerConfig, outChan chan pipeline.Event, ...) error
- func (d *Source) UnmarshalConfig(yamlConfig []byte) error
- func (d *Source) Watch(ctx context.Context, containerChan chan *ContainerConfig, ...) error
Constants ¶
View Source
const ModuleName = "docker"
Variables ¶
This section is empty.
Functions ¶
Types ¶
type BackOffFactory ¶ added in v1.7.1
type Configuration ¶
type Configuration struct {
configuration.DataSourceCommonCfg `yaml:",inline"`
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"`
ServiceName []string `yaml:"service_name"`
ServiceID []string `yaml:"service_id"`
ServiceNameRegexp []string `yaml:"service_name_regexp"`
ServiceIDRegexp []string `yaml:"service_id_regexp"`
UseServiceLabels bool `yaml:"use_service_labels"`
UseContainerLabels bool `yaml:"use_container_labels"`
}
type ContainerConfig ¶
type ContainerConfig struct {
Name string
ID string
Labels map[string]string
Tty bool
// contains filtered or unexported fields
}
func NewContainerConfig ¶ added in v1.7.1
func NewContainerConfig(baseOpts *client.ContainerLogsOptions, id string, name string, labels map[string]string, tty bool) *ContainerConfig
NewContainerConfig creates per-container log options by copying the base options
type Source ¶
type Source struct {
Config Configuration
Client client.APIClient
// contains filtered or unexported fields
}
func (*Source) ConfigureByDSN ¶
func (*Source) ContainerManager ¶
func (d *Source) ContainerManager(ctx context.Context, in chan *ContainerConfig, deleteChan chan *ContainerConfig, outChan chan pipeline.Event) error
func (*Source) EvalContainer ¶
func (d *Source) EvalContainer(ctx context.Context, container dockerContainer.Summary) *ContainerConfig
func (*Source) EvalService ¶
func (d *Source) EvalService(_ context.Context, service dockerTypesSwarm.Service) *ContainerConfig
func (*Source) GetAggregMetrics ¶
func (*Source) GetAggregMetrics() []prometheus.Collector
func (*Source) GetMetrics ¶
func (*Source) GetMetrics() []prometheus.Collector
func (*Source) OneShotAcquisition ¶
func (d *Source) OneShotAcquisition(ctx context.Context, out chan pipeline.Event, t *tomb.Tomb) error
OneShotAcquisition reads a set of file and returns when done
func (*Source) ServiceManager ¶
func (d *Source) ServiceManager(ctx context.Context, in chan *ContainerConfig, deleteChan chan *ContainerConfig, outChan chan pipeline.Event) error
func (*Source) StreamingAcquisition ¶
func (*Source) TailContainer ¶
func (d *Source) TailContainer(ctx context.Context, container *ContainerConfig, outChan chan pipeline.Event, deleteChan chan *ContainerConfig) error
func (*Source) TailService ¶
func (d *Source) TailService(ctx context.Context, service *ContainerConfig, outChan chan pipeline.Event, deleteChan chan *ContainerConfig) error
func (*Source) UnmarshalConfig ¶
func (*Source) Watch ¶
func (d *Source) Watch(ctx context.Context, containerChan chan *ContainerConfig, containerDeleteChan chan *ContainerConfig, serviceChan chan *ContainerConfig, serviceDeleteChan chan *ContainerConfig) error
Click to show internal directories.
Click to hide internal directories.