Documentation
¶
Index ¶
- type FlusherStatistics
- func (*FlusherStatistics) Description() string
- func (p *FlusherStatistics) Flush(projectName string, logstoreName string, configName string, ...) error
- func (p *FlusherStatistics) Init(context pipeline.Context) error
- func (*FlusherStatistics) IsReady(projectName string, logstoreName string, logstoreKey int64) bool
- func (*FlusherStatistics) SetUrgent(flag bool)
- func (*FlusherStatistics) Stop() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FlusherStatistics ¶
type FlusherStatistics struct {
SleepMsPerLogGroup int
RateIntervalMs int
GeneratePB bool
// contains filtered or unexported fields
}
FlusherStatistics only does statistics for data to flush instead of flushing really. It maintains three rates: 1. loggroupRateCounter: the rate of the number of log groups to flush. 2. logRateCounter: the rate of the total number of logs in log groups to flush. 3. byteRateCounter: the rate of the total (serialized) bytes of logs in log groups to flush.
func (*FlusherStatistics) Description ¶
func (*FlusherStatistics) Description() string
func (*FlusherStatistics) Flush ¶
func (p *FlusherStatistics) Flush(projectName string, logstoreName string, configName string, logGroupList []*protocol.LogGroup) error
Flush flushes @logGroupList but it only do statistics. It returns any error it encountered.
func (*FlusherStatistics) IsReady ¶
func (*FlusherStatistics) IsReady(projectName string, logstoreName string, logstoreKey int64) bool
IsReady is ready to flush
func (*FlusherStatistics) SetUrgent ¶
func (*FlusherStatistics) SetUrgent(flag bool)
Source Files
Click to show internal directories.
Click to hide internal directories.