Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

veneur

package module

Go to main page

Versions in this module

v1

v1.3.1

Jun 6, 2017

Changes in this version

+ func ConsumePanic(sentry *raven.Client, stats *statsd.Client, hostname string, err interface{})

+ type Consul struct

+ ConsulHealth *api.Health

+ func NewConsul(config *api.Config) (*Consul, error)

+ func (c *Consul) GetDestinationsForService(serviceName string) ([]string, error)

+ type Discoverer interface

+ GetDestinationsForService func(string) ([]string, error)

+ type Proxy struct

+ AcceptingForwards bool

+ AcceptingTraces bool

+ ConsulForwardService string

+ ConsulInterval time.Duration

+ ConsulTraceService string

+ Discoverer Discoverer

+ ForwardDestinations *consistent.Consistent

+ ForwardDestinationsMtx sync.Mutex

+ HTTPAddr string

+ HTTPClient *http.Client

+ Hostname string

+ Sentry *raven.Client

+ Statsd *statsd.Client

+ TraceDestinations *consistent.Consistent

+ TraceDestinationsMtx sync.Mutex

+ func NewProxyFromConfig(conf ProxyConfig) (p Proxy, err error)

+ func (p *Proxy) HTTPServe()

+ func (p *Proxy) Handler() http.Handler

+ func (p *Proxy) ProxyMetrics(ctx context.Context, jsonMetrics []samplers.JSONMetric)

+ func (p *Proxy) ProxyTraces(ctx context.Context, traces []DatadogTraceSpan)

+ func (p *Proxy) RefreshDestinations(serviceName string, ring *consistent.Consistent, mtx *sync.Mutex)

+ func (p *Proxy) Shutdown()

+ func (p *Proxy) Start()

+ type ProxyConfig struct

+ ConsulForwardServiceName string

+ ConsulRefreshInterval string

+ ConsulTraceServiceName string

+ Debug bool

+ EnableProfiling bool

+ ForwardAddress string

+ HTTPAddress string

+ SentryDsn string

+ StatsAddress string

+ TraceAPIAddress string

+ TraceAddress string

+ func ReadProxyConfig(path string) (c ProxyConfig, err error)

type Server

+ Sentry *raven.Client

+ Statsd *statsd.Client

v1.2.0

Apr 24, 2017

Changes in this version

+ const REDACTED

type Config

+ FlushFile string

type Worker

+ func (w *Worker) MetricsProcessedCount() int64

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