rawstdout

package
v1.8.8 Latest Latest
Warning

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

Go to latest
Published: Mar 27, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ServiceDockerStdout

type ServiceDockerStdout struct {
	IncludeLabel          map[string]string // Deprecated: use IncludeContainerLabel and IncludeK8sLabel instead.
	ExcludeLabel          map[string]string // Deprecated: use ExcludeContainerLabel and ExcludeK8sLabel instead.
	IncludeEnv            map[string]string
	ExcludeEnv            map[string]string
	IncludeContainerLabel map[string]string
	ExcludeContainerLabel map[string]string
	IncludeK8sLabel       map[string]string
	ExcludeK8sLabel       map[string]string
	ExternalEnvTag        map[string]string
	ExternalK8sLabelTag   map[string]string
	FlushIntervalMs       int
	TimeoutMs             int
	BeginLineRegex        string
	BeginLineTimeoutMs    int
	BeginLineCheckLength  int
	MaxLogSize            int
	Stdout                bool
	Stderr                bool
	K8sNamespaceRegex     string
	K8sPodRegex           string
	K8sContainerRegex     string

	// export from ilogtail-trace component
	IncludeLabelRegex map[string]*regexp.Regexp
	ExcludeLabelRegex map[string]*regexp.Regexp
	IncludeEnvRegex   map[string]*regexp.Regexp
	ExcludeEnvRegex   map[string]*regexp.Regexp
	K8sFilter         *helper.K8SFilter
	// contains filtered or unexported fields
}

func (*ServiceDockerStdout) Collect

Collect takes in an accumulator and adds the metrics that the Input gathers. This is called every "interval"

func (*ServiceDockerStdout) Description

func (sds *ServiceDockerStdout) Description() string

func (*ServiceDockerStdout) FlushAll

func (sds *ServiceDockerStdout) FlushAll(c pipeline.Collector, firstStart bool) error

func (*ServiceDockerStdout) GetCheckPoint

func (sds *ServiceDockerStdout) GetCheckPoint() *StdoutCheckPoint

func (*ServiceDockerStdout) Init

func (sds *ServiceDockerStdout) Init(context pipeline.Context) (int, error)

func (*ServiceDockerStdout) SaveCheckPoint

func (sds *ServiceDockerStdout) SaveCheckPoint() error

func (*ServiceDockerStdout) Start

Start starts the ServiceInput's service, whatever that may be

func (*ServiceDockerStdout) Stop

func (sds *ServiceDockerStdout) Stop() error

Stop stops the services and closes any necessary channels and connections

type StdoutCheckPoint

type StdoutCheckPoint struct {
	// contains filtered or unexported fields
}

func (*StdoutCheckPoint) DeleteCheckPoint

func (sc *StdoutCheckPoint) DeleteCheckPoint(id string)

func (*StdoutCheckPoint) GetAllCheckPoint

func (sc *StdoutCheckPoint) GetAllCheckPoint() map[string]string

func (*StdoutCheckPoint) GetCheckPoint

func (sc *StdoutCheckPoint) GetCheckPoint(id string) string

func (*StdoutCheckPoint) SaveCheckPoint

func (sc *StdoutCheckPoint) SaveCheckPoint(id, checkpoint string)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL