formatter

package
v0.0.0-...-8a44fb0 Latest Latest
Warning

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

Go to latest
Published: Jul 24, 2022 License: MIT, MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewUnifytlogcFormatter

func NewUnifytlogcFormatter(config *config.TaskConfig) (*unifytlogcFormatter, error)

NewUnifytlogcFormatter: 兼容unifytlogc输出格式

func NewV1Formatter

func NewV1Formatter(config *config.TaskConfig) (*v1Formatter, error)

NewV1Formatter: 兼容bklogbeat输出格式

func NewV2Formatter

func NewV2Formatter(config *config.TaskConfig) (*v2Formatter, error)

NewV2Formatter: bkunifylogbeat日志采集输出格式

Types

type ContainerStdoutFields

type ContainerStdoutFields struct {
	Log    string `json:"log"`
	Stream string `json:"stream"`
	Time   string `json:"time"`
}

type LogConfig

type LogConfig struct {
	HarvesterLimit int `config:"harvester_limit"`
}

如果未配置close_inactive则直接默认为5分钟

type TQOSFormatter

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

func NewTQOSFormatter

func NewTQOSFormatter(config *config.TaskConfig) (*TQOSFormatter, error)

NewTQOSFormatter: 兼容TQOS输出格式

func (TQOSFormatter) Format

func (f TQOSFormatter) Format(events []*util.Data) beat.MapStr

Format: TQOS输出格式兼容

type TQOSLogConfig

type TQOSLogConfig struct {
	HarvesterLimit int `config:"harvester_limit"`
}

如果未配置close_inactive则直接默认为5分钟

Jump to

Keyboard shortcuts

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