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(args StartServerlessTraceAgentArgs) ServerlessTraceAgent
• type StartServerlessTraceAgentArgs

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
	Tagger tagger.Component
}

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(args StartServerlessTraceAgentArgs) ServerlessTraceAgent

Start starts the agent

type StartServerlessTraceAgentArgs

type StartServerlessTraceAgentArgs struct {
	Enabled               bool
	LoadConfig            Load
	LambdaSpanChan        chan<- *pb.Span
	ColdStartSpanID       uint64
	AzureContainerAppTags string
}

StartServerlessTraceAgentArgs are the arguments for the StartServerlessTraceAgent method