log

Documentation

Index

• Constants
• type EsLogsConsumer
  • func NewEsLogsConsumer(client sarama.Client, rs repository.SearchRepository, l *zap.Logger) *EsLogsConsumer
  • func (es *EsLogsConsumer) BatchHandleLogs(_ []*sarama.ConsumerMessage, events []Event) error
  • func (es *EsLogsConsumer) Start(ctx context.Context) error
• type Event

Constants

const TopicZapLogs = "linkme_elk_events"

Types

type EsLogsConsumer

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

func NewEsLogsConsumer

func NewEsLogsConsumer(client sarama.Client, rs repository.SearchRepository, l *zap.Logger) *EsLogsConsumer

func (*EsLogsConsumer) BatchHandleLogs

func (es *EsLogsConsumer) BatchHandleLogs(_ []*sarama.ConsumerMessage, events []Event) error

func (*EsLogsConsumer) Start

func (es *EsLogsConsumer) Start(ctx context.Context) error

type Event

type Event struct {
	Timestamp int64  `json:"timestamp"`
	Level     string `json:"level"`
	Message   string `json:"message"`
}