trace

Documentation

Index

• type ColdStartSpanCreator
  • func (c *ColdStartSpanCreator) Run()
  • func (c *ColdStartSpanCreator) Stop()
• type Load
• type LoadConfig
  • func (l *LoadConfig) Load() (*config.AgentConfig, error)
• type ServerlessTraceAgent
  • func StartServerlessTraceAgent(enabled bool, loadConfig Load, lambdaSpanChan chan<- *pb.Span, ...) ServerlessTraceAgent

Types

type ColdStartSpanCreator

type ColdStartSpanCreator struct {
	TraceAgent ServerlessTraceAgent

	LambdaSpanChan       <-chan *pb.Span
	LambdaInitMetricChan <-chan *serverlessLog.LambdaInitMetric

	ColdStartSpanId uint64

	StopChan chan struct{}

	ColdStartRequestID string
	// contains filtered or unexported fields
}

func (*ColdStartSpanCreator) Run

func (c *ColdStartSpanCreator) Run()

func (*ColdStartSpanCreator) Stop

func (c *ColdStartSpanCreator) Stop()

type Load

type Load interface {
	Load() (*config.AgentConfig, error)
}

Load abstracts the file configuration loading

type LoadConfig

type LoadConfig struct {
	Path string
}

LoadConfig is implementing Load to retrieve the config

func (*LoadConfig) Load

func (l *LoadConfig) Load() (*config.AgentConfig, error)

Load loads the config from a file path

type ServerlessTraceAgent

type ServerlessTraceAgent interface {
	Stop()
	Flush()
	Process(p *api.Payload)
	SetTags(map[string]string)
	SetTargetTPS(float64)
	SetSpanModifier(agent.SpanModifier)
	GetSpanModifier() agent.SpanModifier
}

ServerlessTraceAgent represents a trace agent in a serverless context

func StartServerlessTraceAgent

func StartServerlessTraceAgent(enabled bool, loadConfig Load, lambdaSpanChan chan<- *pb.Span, coldStartSpanId uint64) ServerlessTraceAgent

Start starts the agent