Documentation
¶
Index ¶
- type DockerFileSyner
- type DockerJSONLog
- type DockerStdoutProcessor
- type ServiceDockerStdout
- func (sds *ServiceDockerStdout) ClearUselessCheckpoint()
- func (sds *ServiceDockerStdout) Collect(ilogtail.Collector) error
- func (sds *ServiceDockerStdout) Description() string
- func (sds *ServiceDockerStdout) FlushAll(c ilogtail.Collector, firstStart bool) error
- func (sds *ServiceDockerStdout) Init(context ilogtail.Context) (int, error)
- func (sds *ServiceDockerStdout) LoadCheckPoint()
- func (sds *ServiceDockerStdout) SaveCheckPoint(force bool) error
- func (sds *ServiceDockerStdout) Start(c ilogtail.Collector) error
- func (sds *ServiceDockerStdout) Stop() error
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 NewDockerFileSyner ¶
func NewDockerFileSyner(sds *ServiceDockerStdout, info *helper.DockerInfoDetail, checkpointMap map[string]helper.LogFileReaderCheckPoint) *DockerFileSyner
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 (*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 (sds *ServiceDockerStdout) Collect(ilogtail.Collector) error
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 ¶
func (sds *ServiceDockerStdout) Start(c ilogtail.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
Click to show internal directories.
Click to hide internal directories.