logs

Documentation

Index

• func GetLogsTags() []string
• func SetLogsTags(tags []string)
• func SetupLogAgent(logChannel chan *config.ChannelMessage, sourceName string, source string, ...) (logsAgent.ServerlessLogsAgent, error)
• type LambdaInitMetric
• type LambdaLogAPIMessage
  • func (l *LambdaLogAPIMessage) UnmarshalJSON(data []byte) error
• type LambdaLogsAPIServer
  • func NewLambdaLogsAPIServer(out chan<- []LambdaLogAPIMessage) LambdaLogsAPIServer
  • func (l *LambdaLogsAPIServer) Close()
  • func (c *LambdaLogsAPIServer) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type LambdaLogsCollector
  • func NewLambdaLogCollector(out chan<- *logConfig.ChannelMessage, demux aggregator.Demultiplexer, ...) *LambdaLogsCollector
  • func (lc *LambdaLogsCollector) Shutdown()
  • func (lc *LambdaLogsCollector) Start()
• type Tags

Functions

func GetLogsTags

func GetLogsTags() []string

func SetLogsTags

func SetLogsTags(tags []string)

SetLogsTags updates the tags attached to logs messages.

This function retains the given tags slice, which must not be modified after this call.

func SetupLogAgent

func SetupLogAgent(logChannel chan *config.ChannelMessage, sourceName string, source string, tagger tagger.Component) (logsAgent.ServerlessLogsAgent, error)

SetupLogAgent sets up the logs agent to handle messages on the given channel.

Types

type LambdaInitMetric

type LambdaInitMetric struct {
	InitDurationTelemetry float64
	InitStartTime         time.Time
}

type LambdaLogAPIMessage

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

LambdaLogAPIMessage is a log message sent by the AWS API.

func (*LambdaLogAPIMessage) UnmarshalJSON

func (l *LambdaLogAPIMessage) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshals the given bytes in a LogMessage object.

type LambdaLogsAPIServer

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

LambdaLogsAPI implements the AWS Lambda Logs API callback

func NewLambdaLogsAPIServer

func NewLambdaLogsAPIServer(out chan<- []LambdaLogAPIMessage) LambdaLogsAPIServer

func (*LambdaLogsAPIServer) Close

func (l *LambdaLogsAPIServer) Close()

func (*LambdaLogsAPIServer) ServeHTTP

func (c *LambdaLogsAPIServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP - see type LambdaLogsCollector comment.

type LambdaLogsCollector

type LambdaLogsCollector struct {
	In chan []LambdaLogAPIMessage
	// contains filtered or unexported fields
}

LambdaLogsCollector is the route to which the AWS environment is sending the logs for the extension to collect them.

func NewLambdaLogCollector

func NewLambdaLogCollector(out chan<- *logConfig.ChannelMessage, demux aggregator.Demultiplexer, extraTags *Tags, logsEnabled bool, enhancedMetricsEnabled bool, executionContext *executioncontext.ExecutionContext, handleRuntimeDone func(), lambdaInitMetricChan chan<- *LambdaInitMetric) *LambdaLogsCollector

func (*LambdaLogsCollector) Shutdown

func (lc *LambdaLogsCollector) Shutdown()

Shutdown the log collector

func (*LambdaLogsCollector) Start

func (lc *LambdaLogsCollector) Start()

Start processing logs. Can be called multiple times, but only the first invocation will be effective.

type Tags

type Tags struct {
	Tags []string
}

Tags contains the actual array of Tags (useful for passing it via reference)