statistics

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

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) Init

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

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)

func (*FlusherStatistics) Stop

func (*FlusherStatistics) Stop() error

Stop ...