Documentation ¶
Index ¶
Constants ¶
View Source
const (
// MaxTypeLen the maximum length a span type can have
MaxTypeLen = 100
)
Variables ¶
Functions ¶
Types ¶
type Agent ¶
type Agent struct { Receiver *api.HTTPReceiver Concentrator *stats.Concentrator Blacklister *filters.Blacklister Replacer *filters.Replacer PrioritySampler *sampler.PrioritySampler ErrorsSampler *sampler.ErrorsSampler ExceptionSampler *sampler.ExceptionSampler NoPrioritySampler *sampler.NoPrioritySampler EventProcessor *event.Processor TraceWriter *writer.TraceWriter StatsWriter *writer.StatsWriter // In takes incoming payloads to be processed by the agent. In chan *api.Payload // contains filtered or unexported fields }
Agent struct holds all the sub-routines structs and make the data flow between them
func NewAgent ¶
func NewAgent(ctx context.Context, conf *config.AgentConfig) *Agent
NewAgent returns a new Agent object, ready to be started. It takes a context which may be cancelled in order to gracefully stop the agent.
func (*Agent) FlushSync ¶
func (a *Agent) FlushSync()
FlushSync flushes traces sychronously. This method only works when the agent is configured in synchronous flushing mode via the apm_config.sync_flush option.
func (*Agent) Process ¶
Process is the default work unit that receives a trace, transforms it and passes it downstream.
func (*Agent) ProcessStats ¶
func (a *Agent) ProcessStats(in pb.ClientStatsPayload, lang, tracerVersion string)
ProcessStats processes incoming client stats in from the given tracer.
type ProcessedTrace ¶
type ProcessedTrace struct { Trace pb.Trace WeightedTrace stats.WeightedTrace Root *pb.Span Env string ClientDroppedP0s bool }
ProcessedTrace represents a trace being processed in the agent.
Click to show internal directories.
Click to hide internal directories.