invocationlifecycle

type ExecutionStartInfo struct {
	TraceID uint64
	SpanID  uint64

	SamplingPriority sampler.SamplingPriority
	// contains filtered or unexported fields
}

type InvocationEndDetails struct {
	EndTime            time.Time
	IsError            bool
	IsTimeout          bool
	RequestID          string
	ResponseRawPayload []byte
	ColdStart          bool
	ProactiveInit      bool
	Runtime            string
	ErrorMsg           string
	ErrorType          string
	ErrorStack         string
}

type InvocationProcessor interface {
	// OnInvokeStart is the hook triggered when an invocation has started
	OnInvokeStart(startDetails *InvocationStartDetails)
	// OnInvokeEnd is the hook triggered when an invocation has ended
	OnInvokeEnd(endDetails *InvocationEndDetails)
	// GetExecutionInfo returns the current execution start information
	GetExecutionInfo() *ExecutionStartInfo
}

type InvocationStartDetails struct {
	StartTime             time.Time
	InvokeEventRawPayload []byte
	InvokeEventHeaders    http.Header
	InvokedFunctionARN    string
	InferredSpan          inferredspan.InferredSpan
}

type InvocationSubProcessor interface {
	// OnInvokeStart is the hook triggered when an invocation has started and the request handler context was created,
	OnInvokeStart(startDetails *InvocationStartDetails, ctx *RequestHandler)
	// OnInvokeEnd is the hook triggered when an invocation has ended
	OnInvokeEnd(endDetails *InvocationEndDetails, ctx *RequestHandler)
}

type LifecycleProcessor struct {
	ExtraTags            *serverlessLog.Tags
	ProcessTrace         func(p *api.Payload)
	Demux                aggregator.Demultiplexer
	DetectLambdaLibrary  func() bool
	InferredSpansEnabled bool
	SubProcessor         InvocationSubProcessor
	Extractor            propagation.Extractor
	// contains filtered or unexported fields
}

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