rawstdout

Documentation

Index

• type ServiceDockerStdout
  • func (sds *ServiceDockerStdout) Collect(pipeline.Collector) error
  • func (sds *ServiceDockerStdout) Description() string
  • func (sds *ServiceDockerStdout) FlushAll(c pipeline.Collector, firstStart bool) error
  • func (sds *ServiceDockerStdout) GetCheckPoint() *StdoutCheckPoint
  • func (sds *ServiceDockerStdout) Init(context pipeline.Context) (int, error)
  • func (sds *ServiceDockerStdout) SaveCheckPoint() error
  • func (sds *ServiceDockerStdout) Start(c pipeline.Collector) error
  • func (sds *ServiceDockerStdout) Stop() error
• type StdoutCheckPoint
  • func (sc *StdoutCheckPoint) DeleteCheckPoint(id string)
  • func (sc *StdoutCheckPoint) GetAllCheckPoint() map[string]string
  • func (sc *StdoutCheckPoint) GetCheckPoint(id string) string
  • func (sc *StdoutCheckPoint) SaveCheckPoint(id, checkpoint string)

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

func (sds *ServiceDockerStdout) Collect(pipeline.Collector) error

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

func (sds *ServiceDockerStdout) Start(c pipeline.Collector) error

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)