kafka

Documentation

Index

• type FlusherFunc
• type FlusherKafka
  • func (k *FlusherKafka) Description() string
  • func (k *FlusherKafka) Flush(projectName string, logstoreName string, configName string, ...) error
  • func (k *FlusherKafka) HashFlush(projectName string, logstoreName string, configName string, ...) error
  • func (k *FlusherKafka) Init(context pipeline.Context) error
  • func (k *FlusherKafka) IsReady(projectName string, logstoreName string, logstoreKey int64) bool
  • func (k *FlusherKafka) NormalFlush(projectName string, logstoreName string, configName string, ...) error
  • func (*FlusherKafka) SetUrgent(flag bool)
  • func (k *FlusherKafka) Stop() error

Types

type FlusherFunc

type FlusherFunc func(projectName string, logstoreName string, configName string, logGroupList []*protocol.LogGroup) error

type FlusherKafka

type FlusherKafka struct {
	Brokers         []string
	SASLUsername    string
	SASLPassword    string
	Topic           string
	PartitionerType string
	HashKeys        []string
	HashOnce        bool
	ClientID        string
	// contains filtered or unexported fields
}

func (*FlusherKafka) Description

func (k *FlusherKafka) Description() string

func (*FlusherKafka) Flush

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

func (*FlusherKafka) HashFlush

func (k *FlusherKafka) HashFlush(projectName string, logstoreName string, configName string, logGroupList []*protocol.LogGroup) error

func (*FlusherKafka) Init

func (k *FlusherKafka) Init(context pipeline.Context) error

func (*FlusherKafka) IsReady

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

IsReady is ready to flush

func (*FlusherKafka) NormalFlush

func (k *FlusherKafka) NormalFlush(projectName string, logstoreName string, configName string, logGroupList []*protocol.LogGroup) error

func (*FlusherKafka) SetUrgent

func (*FlusherKafka) SetUrgent(flag bool)

func (*FlusherKafka) Stop

func (k *FlusherKafka) Stop() error

Stop ...