logexporter

Documentation

Index

• type LogEntry
• type LogExporter
  • func NewLogExporter(logger *logrus.Logger, sender LogSender) *LogExporter
  • func (e *LogExporter) Fire(entry *logrus.Entry) error
  • func (e *LogExporter) Levels() []logrus.Level
  • func (e *LogExporter) Wait()
• type LogSender

Types

type LogEntry

type LogEntry struct {
	Level   string        `json:"level"`
	Time    time.Time     `json:"time"`
	Message string        `json:"message"`
	Fields  logrus.Fields `json:"fields"`
}

type LogExporter

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

LogExporter hooks into logrus and sends logs to Mothership.

func NewLogExporter

func NewLogExporter(logger *logrus.Logger, sender LogSender) *LogExporter

NewLogExporter returns new exporter that can be hooked into logrus to inject logs into Cast AI.

func (*LogExporter) Fire

func (e *LogExporter) Fire(entry *logrus.Entry) error

Fire called by logrus with log entry that LogExporter sends out.

func (*LogExporter) Levels

func (e *LogExporter) Levels() []logrus.Level

Levels lists levels that tell logrus to trigger log injection.

func (*LogExporter) Wait

func (e *LogExporter) Wait()

Wait lets all pending log sends to finish.

type LogSender

type LogSender interface {
	SendLog(ctx context.Context, e *LogEntry) error
}