servicelog

Documentation

Index

• func Extend(in <-chan Entry, extenders ...Extender) <-chan Entry
• type Entry
• type Extender
• type StaticDataExtender
  • func (e StaticDataExtender) Extend(entry Entry) Entry
• type SystemDataExtender
  • func (e SystemDataExtender) Extend(entry Entry) Entry

Functions

func Extend

func Extend(in <-chan Entry, extenders ...Extender) <-chan Entry

Extend returns a channel that will return log entries extended with passed extenders list. Original log entries are not modified, but duplicate keys are overwritten in returned ones.

Types

type Entry

type Entry map[string]interface{}

Entry represents one scraped log line in flat key-value store.

type Extender

type Extender interface {
	// Extend returns a new log entry, based on the passed one, with additional
	// data. Original entry is not modified but duplicate keys are overwritten in
	// returned entry.
	Extend(Entry) Entry
}

Extender is type used to extend log data with additional data.

type StaticDataExtender

type StaticDataExtender struct {
	Data map[string]interface{}
}

StaticDataExtender adds data specified in the Data field to passed log entry.

func (StaticDataExtender) Extend

func (e StaticDataExtender) Extend(entry Entry) Entry

Extend returns a new log entry, based on the passed entry, with Data map added to it.

type SystemDataExtender

type SystemDataExtender struct {
}

SystemDataExtender adds system specific data to passed log entry. It only adds data that is able to get.

func (SystemDataExtender) Extend

func (e SystemDataExtender) Extend(entry Entry) Entry

Extend returns a new log entry, based on the passed entry, with hostname, region and availability zone added to it. Data is added only when it is possible to retrieve it from the system.