logkafka

package module

v0.1.3 Latest Latest Go to latest Published: Mar 6, 2024 License: MIT Imports: 5 Imported by: 3

Details

This section is empty.

This section is empty.

func NewKafkaClient(addrs []string, kafkaOpts ...KafkaOptionFunc) (sarama.Client, error)

type DynamicTopicsFunc func(entry *logrus.Entry) []string

type HookFilter func(entry *logrus.Entry) bool

type KafkaOptionFunc func(*sarama.Config)

func WithKafkaSASLEnable(enable bool) KafkaOptionFunc

func WithKafkaSASLHandshake(enable bool) KafkaOptionFunc

func WithKafkaSASLMechanism(mechanism sarama.SASLMechanism) KafkaOptionFunc

func WithKafkaSASLPassword(password string) KafkaOptionFunc

func WithKafkaSASLUser(user string) KafkaOptionFunc

func WithKafkaTLSConfig(config *tls.Config) KafkaOptionFunc

func WithKafkaTLSEnable(enable bool) KafkaOptionFunc

type LogKafkaHook struct {
	// contains filtered or unexported fields
}

func NewLogKafkaHook(addrs, topics []string, kafkaOpts []KafkaOptionFunc, opts ...LogKafkaHookOptionFunc) (*LogKafkaHook, error)

func NewLogKafkaHookFromClient(client sarama.Client, topics []string, opts ...LogKafkaHookOptionFunc) (*LogKafkaHook, error)

func (l *LogKafkaHook) Fire(entry *logrus.Entry) error

func (l *LogKafkaHook) Levels() []logrus.Level

type LogKafkaHookOptionFunc func(*LogKafkaHook)

func WithDynamicTopicsFunc(f DynamicTopicsFunc) LogKafkaHookOptionFunc

func WithHookFilters(filters ...HookFilter) LogKafkaHookOptionFunc

func WithHookKeyFormatter(formatter logrus.Formatter) LogKafkaHookOptionFunc

func WithHookLevels(levels []logrus.Level) LogKafkaHookOptionFunc

func WithHookMustHasFields(fields []string) LogKafkaHookOptionFunc

func WithHookMustNotHasFields(fields []string) LogKafkaHookOptionFunc

func WithHookValueFormatter(formatter logrus.Formatter) LogKafkaHookOptionFunc