kafka

package
v1.8.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 27, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FlusherFunc added in v1.0.28

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 added in v1.0.28

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 added in v1.0.28

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 ...

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL