checker

Documentation

Index

• type FlusherChecker
  • func (p *FlusherChecker) CheckEveryKeyValue(checker func(string, string) error) error
  • func (p *FlusherChecker) CheckEveryLog(checker func(*protocol.Log) error) error
  • func (p *FlusherChecker) CheckKeyValue(key, value string) error
  • func (p *FlusherChecker) CheckKeyValueAny(key, value string) error
  • func (p *FlusherChecker) CheckKeyValueRegex(key, valueRegex string) error
  • func (*FlusherChecker) Description() string
  • func (p *FlusherChecker) Flush(projectName string, logstoreName string, configName string, ...) error
  • func (p *FlusherChecker) GetLogCount() int
  • func (p *FlusherChecker) Init(context pipeline.Context) error
  • func (p *FlusherChecker) IsReady(projectName string, logstoreName string, logstoreKey int64) bool
  • func (p *FlusherChecker) SetUrgent(flag bool)
  • func (p *FlusherChecker) Stop() error

Types

type FlusherChecker

type FlusherChecker struct {
	LogGroup protocol.LogGroup
	Lock     sync.RWMutex
	Block    bool
	// contains filtered or unexported fields
}

func (*FlusherChecker) CheckEveryKeyValue

func (p *FlusherChecker) CheckEveryKeyValue(checker func(string, string) error) error

func (*FlusherChecker) CheckEveryLog

func (p *FlusherChecker) CheckEveryLog(checker func(*protocol.Log) error) error

func (*FlusherChecker) CheckKeyValue

func (p *FlusherChecker) CheckKeyValue(key, value string) error

func (*FlusherChecker) CheckKeyValueAny

func (p *FlusherChecker) CheckKeyValueAny(key, value string) error

func (*FlusherChecker) CheckKeyValueRegex

func (p *FlusherChecker) CheckKeyValueRegex(key, valueRegex string) error

func (*FlusherChecker) Description

func (*FlusherChecker) Description() string

func (*FlusherChecker) Flush

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

func (*FlusherChecker) GetLogCount

func (p *FlusherChecker) GetLogCount() int

func (*FlusherChecker) Init

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

func (*FlusherChecker) IsReady

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

IsReady is ready to flush

func (*FlusherChecker) SetUrgent

func (p *FlusherChecker) SetUrgent(flag bool)

func (*FlusherChecker) Stop

func (p *FlusherChecker) Stop() error

Stop ...