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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶ added in v1.4.0
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)
Source Files
Click to show internal directories.
Click to hide internal directories.