stdout

package
v1.0.28 Latest Latest
Warning

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

Go to latest
Published: Dec 15, 2021 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DockerFileSyner

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

func NewDockerFileSynerByFile

func NewDockerFileSynerByFile(sds *ServiceDockerStdout, filePath string) *DockerFileSyner

type DockerJSONLog

type DockerJSONLog struct {
	LogContent string `json:"log"`
	StreamType string `json:"stream"`
	Time       string `json:"time"`
}

func (DockerJSONLog) MarshalEasyJSON

func (v DockerJSONLog) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (DockerJSONLog) MarshalJSON

func (v DockerJSONLog) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*DockerJSONLog) UnmarshalEasyJSON

func (v *DockerJSONLog) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*DockerJSONLog) UnmarshalJSON

func (v *DockerJSONLog) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type DockerStdoutProcessor

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

func NewDockerStdoutProcessor

func NewDockerStdoutProcessor(beginLineReg *regexp.Regexp, beginLineTimeout time.Duration, beginLineCheckLength int,
	maxLogSize int, stdout bool, stderr bool, context ilogtail.Context, collector ilogtail.Collector, tags map[string]string) *DockerStdoutProcessor

func (*DockerStdoutProcessor) ParseDockerLogLine

func (p *DockerStdoutProcessor) ParseDockerLogLine(line []byte) *DockerJSONLog

func (*DockerStdoutProcessor) Process

func (p *DockerStdoutProcessor) Process(fileBlock []byte, noChangeInterval time.Duration) int

func (*DockerStdoutProcessor) StreamAllowed

func (p *DockerStdoutProcessor) StreamAllowed(log *DockerJSONLog) bool

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
	ReadIntervalMs        int
	SaveCheckPointSec     int
	TimeoutMs             int
	BeginLineRegex        string
	BeginLineTimeoutMs    int
	BeginLineCheckLength  int
	MaxLogSize            int
	CloseUnChangedSec     int
	StartLogMaxOffset     int64
	Stdout                bool
	Stderr                bool
	LogtailInDocker       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) ClearUselessCheckpoint

func (sds *ServiceDockerStdout) ClearUselessCheckpoint()

func (*ServiceDockerStdout) Collect

func (*ServiceDockerStdout) Description

func (sds *ServiceDockerStdout) Description() string

func (*ServiceDockerStdout) FlushAll

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

func (*ServiceDockerStdout) Init

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

func (*ServiceDockerStdout) LoadCheckPoint

func (sds *ServiceDockerStdout) LoadCheckPoint()

func (*ServiceDockerStdout) SaveCheckPoint

func (sds *ServiceDockerStdout) SaveCheckPoint(force bool) 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

Jump to

Keyboard shortcuts

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