Versions in this module Expand all Collapse all v1 v1.1.0 Mar 2, 2017 Changes in this version + var VERSION = "dirty" + func NewSocket(addr *net.UDPAddr, recvBuf int, reuseport bool) (net.PacketConn, error) + type Config struct + APIHostname string + Aggregates []string + AwsAccessKeyID string + AwsRegion string + AwsS3Bucket string + AwsSecretAccessKey string + Debug bool + EnableProfiling bool + FlushMaxPerBody int + ForwardAddress string + HTTPAddress string + Hostname string + InfluxAddress string + InfluxConsistency string + InfluxDBName string + Interval string + Key string + MetricMaxLength int + NumReaders int + NumWorkers int + OmitEmptyHostname bool + Percentiles []float64 + ReadBufferSizeBytes int + SentryDsn string + StatsAddress string + TLSAuthorityCertificate string + TLSCertificate string + TLSKey string + Tags []string + TcpAddress string + TraceAPIAddress string + TraceAddress string + TraceMaxLengthBytes int + UdpAddress string + func ReadConfig(path string) (c Config, err error) + func (c Config) ParseInterval() (time.Duration, error) + type DatadogTraceSpan struct + Duration int64 + Error int64 + Meta map[string]string + Metrics map[string]float64 + Name string + ParentID int64 + Resource string + Service string + SpanID int64 + Start int64 + TraceID int64 + Type string + type EventWorker struct + EventChan chan samplers.UDPEvent + ServiceCheckChan chan samplers.UDPServiceCheck + func NewEventWorker(stats *statsd.Client) *EventWorker + func (ew *EventWorker) Flush() ([]samplers.UDPEvent, []samplers.UDPServiceCheck) + func (ew *EventWorker) Work() + type Server struct + DDAPIKey string + DDHostname string + DDTraceAddress string + EventWorker *EventWorker + FlushMaxPerBody int + ForwardAddr string + HTTPAddr string + HTTPClient *http.Client + HistogramAggregates samplers.HistogramAggregates + HistogramPercentiles []float64 + Hostname string + RcvbufBytes int + TCPAddr *net.TCPAddr + Tags []string + TraceAddr *net.UDPAddr + TraceWorker *TraceWorker + UDPAddr *net.UDPAddr + Workers []*Worker + func NewFromConfig(conf Config) (ret Server, err error) + func (s *Server) ConsumePanic(err interface{}) + func (s *Server) Flush() + func (s *Server) FlushGlobal(ctx context.Context) + func (s *Server) FlushLocal(ctx context.Context) + func (s *Server) HTTPServe() + func (s *Server) HandleMetricPacket(packet []byte) error + func (s *Server) HandleTracePacket(packet []byte) + func (s *Server) Handler() http.Handler + func (s *Server) ImportMetrics(ctx context.Context, jsonMetrics []samplers.JSONMetric) + func (s *Server) IsLocal() bool + func (s *Server) ReadMetricSocket(packetPool *sync.Pool, reuseport bool) + func (s *Server) ReadTCPSocket() + func (s *Server) ReadTraceSocket(packetPool *sync.Pool, reuseport bool) + func (s *Server) Shutdown() + func (s *Server) Start() + func (s *Server) TracingEnabled() bool + type TraceWorker struct + TraceChan chan ssf.SSFSample + func NewTraceWorker(stats *statsd.Client) *TraceWorker + func (tw *TraceWorker) Flush() *ring.Ring + func (tw *TraceWorker) Work() + type Worker struct + ImportChan chan []samplers.JSONMetric + PacketChan chan samplers.UDPMetric + QuitChan chan struct{} + func NewWorker(id int, stats *statsd.Client, logger *logrus.Logger) *Worker + func (w *Worker) Flush() WorkerMetrics + func (w *Worker) ImportMetric(other samplers.JSONMetric) + func (w *Worker) ProcessMetric(m *samplers.UDPMetric) + func (w *Worker) Stop() + func (w *Worker) Work() + type WorkerMetrics struct + func NewWorkerMetrics() WorkerMetrics + func (wm WorkerMetrics) Upsert(mk samplers.MetricKey, Scope samplers.MetricScope, tags []string) bool