dockeracquisition

package
v1.7.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 3, 2025 License: MIT Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ReadTailScanner 

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

Types

type BackOffFactory added in v1.7.1 

type BackOffFactory func() backoff.BackOff

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 DockerConfiguration 

type DockerConfiguration 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 DockerSource 

type DockerSource struct {
	Config DockerConfiguration

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

func (*DockerSource) CanRun 

func (*DockerSource) CanRun() error

func (*DockerSource) Configure 

func (d *DockerSource) Configure(ctx context.Context, yamlConfig []byte, logger *log.Entry, metricsLevel metrics.AcquisitionMetricsLevel) error

func (*DockerSource) ConfigureByDSN 

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

func (*DockerSource) ContainerManager added in v1.7.0 

func (d *DockerSource) ContainerManager(ctx context.Context, in chan *ContainerConfig, deleteChan chan *ContainerConfig, outChan chan pipeline.Event) error

func (*DockerSource) Dump 

func (d *DockerSource) Dump() any

func (*DockerSource) EvalContainer 

func (d *DockerSource) EvalContainer(ctx context.Context, container dockerContainer.Summary) *ContainerConfig

func (*DockerSource) EvalService added in v1.7.0 

func (d *DockerSource) EvalService(_ context.Context, service dockerTypesSwarm.Service) *ContainerConfig

func (*DockerSource) GetAggregMetrics 

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

func (*DockerSource) GetMetrics 

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

func (*DockerSource) GetMode 

func (d *DockerSource) GetMode() string

func (*DockerSource) GetName 

func (*DockerSource) GetName() string

func (*DockerSource) GetUuid added in v1.5.0 

func (d *DockerSource) GetUuid() string

func (*DockerSource) OneShotAcquisition 

func (d *DockerSource) OneShotAcquisition(ctx context.Context, out chan pipeline.Event, t *tomb.Tomb) error

OneShotAcquisition reads a set of file and returns when done

func (*DockerSource) ServiceManager added in v1.7.0 

func (d *DockerSource) ServiceManager(ctx context.Context, in chan *ContainerConfig, deleteChan chan *ContainerConfig, outChan chan pipeline.Event) error

func (*DockerSource) StreamingAcquisition 

func (d *DockerSource) StreamingAcquisition(ctx context.Context, out chan pipeline.Event, t *tomb.Tomb) error

func (*DockerSource) SupportedModes 

func (*DockerSource) SupportedModes() []string

SupportedModes returns the supported modes by the acquisition module

func (*DockerSource) TailContainer added in v1.7.0 

func (d *DockerSource) TailContainer(ctx context.Context, container *ContainerConfig, outChan chan pipeline.Event, deleteChan chan *ContainerConfig) error

func (*DockerSource) TailService added in v1.7.0 

func (d *DockerSource) TailService(ctx context.Context, service *ContainerConfig, outChan chan pipeline.Event, deleteChan chan *ContainerConfig) error

func (*DockerSource) UnmarshalConfig added in v1.5.0 

func (d *DockerSource) UnmarshalConfig(yamlConfig []byte) error

func (*DockerSource) Watch added in v1.7.0 

func (d *DockerSource) Watch(ctx context.Context, containerChan chan *ContainerConfig, containerDeleteChan chan *ContainerConfig, serviceChan chan *ContainerConfig, serviceDeleteChan chan *ContainerConfig) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.