adapters

Documentation

Index

• func NewEsLog(index, id string, opt goes.Config) *golog.Logger
• func NewFileLog(opts ...FileOption) *golog.Logger
• func NewKafkaLog(topic string, opt gokafka.Config) *golog.Logger
• type EsAdapter
  • func NewEsAdapter(index, id string, opt goes.Config) *EsAdapter
  • func (fa *EsAdapter) Write(msg *golog.Message)
• type FileAdapter
  • func NewFileAdapter(opt ...FileOption) *FileAdapter
  • func (fa *FileAdapter) Write(msg *golog.Message)
• type FileOption
  • func FileMaxSizeOption(maxSize int64) FileOption
  • func FilePathOption(filepath string) FileOption
• type KafkaAdapter
  • func NewKafkaAdapter(topic string, opt gokafka.Config) *KafkaAdapter
  • func (fa *KafkaAdapter) CloseKafka()
  • func (fa *KafkaAdapter) Write(msg *golog.Message)

Functions

func NewEsLog

func NewEsLog(index, id string, opt goes.Config) *golog.Logger

func NewFileLog

func NewFileLog(opts ...FileOption) *golog.Logger

func NewKafkaLog

func NewKafkaLog(topic string, opt gokafka.Config) *golog.Logger

Types

type EsAdapter

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

func NewEsAdapter

func NewEsAdapter(index, id string, opt goes.Config) *EsAdapter

func (*EsAdapter) Write

func (fa *EsAdapter) Write(msg *golog.Message)

type FileAdapter

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

func NewFileAdapter

func NewFileAdapter(opt ...FileOption) *FileAdapter

func (*FileAdapter) Write

func (fa *FileAdapter) Write(msg *golog.Message)

type FileOption

type FileOption interface {
	// contains filtered or unexported methods
}

func FileMaxSizeOption

func FileMaxSizeOption(maxSize int64) FileOption

func FilePathOption

func FilePathOption(filepath string) FileOption

type KafkaAdapter

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

func NewKafkaAdapter

func NewKafkaAdapter(topic string, opt gokafka.Config) *KafkaAdapter

func (*KafkaAdapter) CloseKafka

func (fa *KafkaAdapter) CloseKafka()

func (*KafkaAdapter) Write

func (fa *KafkaAdapter) Write(msg *golog.Message)