stdout

Documentation

Index

• type FlusherStdout
  • func (*FlusherStdout) Description() string
  • func (p *FlusherStdout) Export(in []*models.PipelineGroupEvents, context pipeline.PipelineContext) error
  • func (p *FlusherStdout) Flush(projectName string, logstoreName string, configName string, ...) error
  • func (p *FlusherStdout) Init(context pipeline.Context) error
  • func (*FlusherStdout) IsReady(projectName string, logstoreName string, logstoreKey int64) bool
  • func (p *FlusherStdout) SetUrgent(flag bool)
  • func (p *FlusherStdout) Stop() error

Types

type FlusherStdout

type FlusherStdout struct {
	FileName      string
	MaxSize       int
	MaxRolls      int
	KeyValuePairs bool
	Tags          bool
	OnlyStdout    bool
	// contains filtered or unexported fields
}

FlusherStdout is a flusher plugin in plugin system. It has two usages: 1. flusher the logGroup to the stdout 2. flusher the logGroup to the file. If the specified file name is not configured, the logGroups would append to the global log file.

func (*FlusherStdout) Description

func (*FlusherStdout) Description() string

func (*FlusherStdout) Export

func (p *FlusherStdout) Export(in []*models.PipelineGroupEvents, context pipeline.PipelineContext) error

func (*FlusherStdout) Flush

func (p *FlusherStdout) Flush(projectName string, logstoreName string, configName string, logGroupList []*protocol.LogGroup) error

Flush the logGroup list to stdout or files.

func (*FlusherStdout) Init

func (p *FlusherStdout) Init(context pipeline.Context) error

Init method would be trigger before working. For the plugin, init method choose the log output channel.

func (*FlusherStdout) IsReady

func (*FlusherStdout) IsReady(projectName string, logstoreName string, logstoreKey int64) bool

IsReady is ready to flush

func (*FlusherStdout) SetUrgent

func (p *FlusherStdout) SetUrgent(flag bool)

func (*FlusherStdout) Stop

func (p *FlusherStdout) Stop() error

Stop ...