writer

Documentation

Index

• type SampledSpans
  • func (ss *SampledSpans) Empty() bool
• type StatsWriter
  • func NewStatsWriter(cfg *config.AgentConfig, in <-chan []stats.Bucket) *StatsWriter
  • func (w *StatsWriter) Run()
  • func (w *StatsWriter) Stop()
• type TraceWriter
  • func NewTraceWriter(cfg *config.AgentConfig, in <-chan *SampledSpans) *TraceWriter
  • func (w *TraceWriter) Run()
  • func (w *TraceWriter) Stop()

Types

type SampledSpans

type SampledSpans struct {
	// Trace will contain a trace if it was sampled or be empty if it wasn't.
	Trace pb.Trace
	// Events contains all APM events extracted from a trace. If no events were extracted, it will be empty.
	Events []*pb.Span
}

SampledSpans represents the result of a trace sampling operation.

func (*SampledSpans) Empty

func (ss *SampledSpans) Empty() bool

Empty returns true if this TracePackage has no data.

type StatsWriter

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

StatsWriter ingests stats buckets and flushes them to the API.

func NewStatsWriter

func NewStatsWriter(cfg *config.AgentConfig, in <-chan []stats.Bucket) *StatsWriter

NewStatsWriter returns a new StatsWriter. It must be started using Run.

func (*StatsWriter) Run

func (w *StatsWriter) Run()

Run starts the StatsWriter, making it ready to receive stats and report metrics.

func (*StatsWriter) Stop

func (w *StatsWriter) Stop()

Stop stops a running StatsWriter.

type TraceWriter

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

TraceWriter buffers traces and APM events, flushing them to the Datadog API.

func NewTraceWriter

func NewTraceWriter(cfg *config.AgentConfig, in <-chan *SampledSpans) *TraceWriter

NewTraceWriter returns a new TraceWriter. It is created for the given agent configuration and will accept incoming spans via the in channel.

func (*TraceWriter) Run

func (w *TraceWriter) Run()

Run starts the TraceWriter.

func (*TraceWriter) Stop

func (w *TraceWriter) Stop()

Stop stops the TraceWriter and attempts to flush whatever is left in the senders buffers.