sleep

Documentation

Index

• type FlusherSleep
  • func (*FlusherSleep) Description() string
  • func (p *FlusherSleep) Flush(projectName string, logstoreName string, configName string, ...) error
  • func (p *FlusherSleep) Init(context pipeline.Context) error
  • func (*FlusherSleep) IsReady(projectName string, logstoreName string, logstoreKey int64) bool
  • func (*FlusherSleep) SetUrgent(flag bool)
  • func (*FlusherSleep) Stop() error

Types

type FlusherSleep

type FlusherSleep struct {
	SleepMS int
	// contains filtered or unexported fields
}

func (*FlusherSleep) Description

func (*FlusherSleep) Description() string

func (*FlusherSleep) Flush

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

func (*FlusherSleep) Init

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

func (*FlusherSleep) IsReady

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

IsReady is ready to flush

func (*FlusherSleep) SetUrgent

func (*FlusherSleep) SetUrgent(flag bool)

func (*FlusherSleep) Stop

func (*FlusherSleep) Stop() error

Stop ...