logs

package
v0.0.0-...-45a9bcf Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 3, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL