logs

type LogAgent ¶

type LogAgent struct {
	Config *config.Config
	// contains filtered or unexported fields
}

LogAgent is the agent handles pure log pipelines

func NewLogAgent(c *config.Config) *LogAgent

func (l *LogAgent) Run(ctx context.Context)

type LogBackend ¶

type LogBackend interface {
	CreateDest(string, string, int, string, LogSrc) LogDest
}

A LogBackend is able to return a LogDest of a given name. The same name should always return the same LogDest.

type LogCollection ¶

type LogCollection interface {
	FindLogSrc() []LogSrc
	Start(acc telegraf.Accumulator) error
}

A LogCollection is a collection of LogSrc, a plugin which can provide many LogSrc

type LogDest ¶

type LogDest interface {
	Publish(events []LogEvent) error
	NotifySourceStopped()
}

A LogDest represents a final endpoint where log events are published to. e.g. a particular log stream in cloudwatchlogs.

type LogEntityProvider ¶ added in v1.300052.0

type LogEntityProvider interface {
	Entity() *cloudwatchlogs.Entity
}

type LogEvent ¶

type LogEvent interface {
	Message() string
	Time() time.Time
	Done()
}

type LogSrc ¶

type LogSrc interface {
	LogEntityProvider
	SetOutput(func(LogEvent))
	Group() string
	Stream() string
	Destination() string
	Description() string
	Retention() int
	Class() string
	Stop()
}

A LogSrc is a single source where log events are generated e.g. a single log file

type StatefulLogEvent ¶ added in v1.300057.0

type StatefulLogEvent interface {
	LogEvent
	Range() state.Range
	RangeQueue() state.FileRangeQueue
}