veneur

package module

Go to main page

Versions in this module

v1

v1.9.0

Nov 8, 2018

Changes in this version

+ func SetLogger(logger *logrus.Logger)

type Config

+ BlockProfileRate int

+ DatadogFlushMaxPerBody int

+ DatadogSpanBufferSize int

+ DebugFlushedMetrics bool

+ DebugIngestedSpans bool

+ FalconerAddress string

+ ForwardUseGrpc bool

+ GrpcAddress string

+ IndicatorSpanTimerName string

+ KafkaBroker string

+ KafkaCheckTopic string

+ KafkaEventTopic string

+ KafkaMetricBufferBytes int

+ KafkaMetricBufferFrequency string

+ KafkaMetricBufferMessages int

+ KafkaMetricRequireAcks string

+ KafkaMetricTopic string

+ KafkaPartitioner string

+ KafkaRetryMax int

+ KafkaSpanBufferBytes int

+ KafkaSpanBufferFrequency string

+ KafkaSpanBufferMesages int

+ KafkaSpanRequireAcks string

+ KafkaSpanSampleRatePercent int

+ KafkaSpanSampleTag string

+ KafkaSpanSerializationFormat string

+ KafkaSpanTopic string

+ LightstepAccessToken string

+ LightstepCollectorHost string

+ LightstepMaximumSpans int

+ LightstepNumClients int

+ LightstepReconnectPeriod string

+ MutexProfileFraction int

+ NumSpanWorkers int

+ SignalfxAPIKey string

+ SignalfxEndpointBase string

+ SignalfxHostnameTag string

+ SignalfxMetricNamePrefixDrops []string

+ SignalfxMetricTagPrefixDrops []string

+ SignalfxPerTagAPIKeys []struct{ ... }

+ SignalfxVaryKeyBy string

+ SpanChannelCapacity int

+ SplunkHecAddress string

+ SplunkHecBatchSize int

+ SplunkHecConnectionLifetimeJitter string

+ SplunkHecIngestTimeout string

+ SplunkHecMaxConnectionLifetime string

+ SplunkHecSendTimeout string

+ SplunkHecSubmissionWorkers int

+ SplunkHecTLSValidateHostname string

+ SplunkHecToken string

+ SplunkSpanSampleRate int

+ TagsExclude []string

+ type KubernetesDiscoverer struct

+ func NewKubernetesDiscoverer() (*KubernetesDiscoverer, error)

+ func (kd *KubernetesDiscoverer) GetDestinationsForService(serviceName string) ([]string, error)

type Proxy

+ AcceptingGRPCForwards bool

+ ConsulForwardGRPCService string

+ ForwardGRPCDestinations *consistent.Consistent

+ ForwardGRPCDestinationsMtx sync.Mutex

+ ForwardTimeout time.Duration

+ MetricsInterval time.Duration

+ TraceClient *trace.Client

+ func (p *Proxy) ReportRuntimeMetrics()

+ func (p *Proxy) Serve()

type ProxyConfig

+ ConsulForwardGrpcServiceName string

+ ForwardTimeout string

+ GrpcAddress string

+ GrpcForwardAddress string

+ IdleConnectionTimeout string

+ MaxIdleConns int

+ MaxIdleConnsPerHost int

+ RuntimeMetricsInterval string

+ SsfDestinationAddress string

+ TracingClientCapacity int

+ TracingClientFlushInterval string

+ TracingClientMetricsInterval string

type Server

+ SpanChan chan *ssf.SSFSpan

+ SpanWorkerGoroutines int

+ func (s *Server) Serve()

+ type UnknownConfigKeys struct

+ func (e *UnknownConfigKeys) Error() string

type Worker

+ ImportMetricChan chan []*metricpb.Metric

+ func (w *Worker) ImportMetricGRPC(other *metricpb.Metric) (err error)

+ func (w *Worker) IngestMetrics(ms []*metricpb.Metric)

+ func (w *Worker) IngestUDP(metric samplers.UDPMetric)

type WorkerMetrics

+ func (wm WorkerMetrics) ForwardableMetrics(cl *trace.Client) []*metricpb.Metric

v1.8.1

Dec 6, 2017

v1.8.0

Dec 1, 2017

Changes in this version

+ var ErrNoSpanWorker = fmt.Errorf("Can not submit traces to an unstarted server")

+ func CalculateTickDelay(interval time.Duration, t time.Time) time.Duration

+ func NewBlackholeMetricSink() (*blackholeMetricSink, error)

+ func NewBlackholeSpanSink() (*blackholeSpanSink, error)

type Config

+ SynchronizeWithInterval bool

+ TraceLightstepNumClients int

type Server

+ TraceClient *trace.Client

v1.7.0

Oct 19, 2017

Changes in this version

+ var BUILD_DATE = defaultLinkValue

+ func NewDatadogMetricSink(config *Config, interval float64, httpClient *http.Client, ...) (*datadogMetricSink, error)

+ func StartSSF(s *Server, a net.Addr, tracePool *sync.Pool)

+ func StartStatsd(s *Server, a net.Addr, packetPool *sync.Pool)

type Config

+ SsfListenAddresses []string

+ StatsdListenAddresses []string

+ type DDMetric struct

+ DeviceName string

+ Hostname string

+ Interval int32

+ MetricType string

+ Name string

+ Tags []string

+ Value [1][2]float64

type Server

+ SSFListenAddrs []net.Addr

+ StatsdListenAddrs []net.Addr

+ func (s *Server) ReadSSFPacketSocket(serverConn net.PacketConn, packetPool *sync.Pool)

+ func (s *Server) ReadSSFStreamSocket(serverConn net.Conn)

v1.6.0

Aug 29, 2017

Changes in this version

+ const DatadogResourceKey

+ func NewDatadogSpanSink(config *Config, stats *statsd.Client, httpClient *http.Client, ...) (*datadogSpanSink, error)

+ func NewLightStepSpanSink(config *Config, stats *statsd.Client, commonTags map[string]string) (*lightStepSpanSink, error)

type Server

+ SpanWorker *SpanWorker

+ TagsAsMap map[string]string

+ type SpanWorker struct

+ SpanChan chan ssf.SSFSpan

+ func NewSpanWorker(sinks []spanSink, stats *statsd.Client) *SpanWorker

+ func (tw *SpanWorker) Flush()

+ func (tw *SpanWorker) Work()

v1.5.2

Aug 15, 2017

Changes in this version

type Config

+ TraceLightstepMaximumSpans int

+ TraceLightstepReconnectPeriod string

v1.5.1

Jul 18, 2017

v1.5.0

Jul 13, 2017

Changes in this version

+ func ValidTrace(sample ssf.SSFSpan) bool

type Config

+ DatadogAPIHostname string

+ DatadogAPIKey string

+ DatadogTraceAPIAddress string

+ SsfAddress string

+ SsfBufferSize int

+ TraceLightstepAccessToken string

+ TraceLightstepCollectorHost string

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

type Config

+ OmitEmptyHostname bool

+ TLSAuthorityCertificate string

+ TLSCertificate string

+ TLSKey string

+ TcpAddress string

type Server

+ FlushMaxPerBody int

+ TCPAddr *net.TCPAddr

+ func (s *Server) ReadTCPSocket()

+ func (s *Server) Start()

v0

v0.7.0

Jan 20, 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

+ Percentiles []float64

+ ReadBufferSizeBytes int

+ SentryDsn string

+ StatsAddress string

+ Tags []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

+ ForwardAddr string

+ HTTPAddr string

+ HTTPClient *http.Client

+ HistogramAggregates samplers.HistogramAggregates

+ HistogramPercentiles []float64

+ Hostname string

+ RcvbufBytes int

+ 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(interval time.Duration, metricLimit int)

+ func (s *Server) FlushGlobal(ctx context.Context, interval time.Duration, metricLimit int)

+ func (s *Server) FlushLocal(ctx context.Context, interval time.Duration, metricLimit int)

+ func (s *Server) HTTPServe()

+ func (s *Server) HandleMetricPacket(packet []byte)

+ 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) ReadTraceSocket(packetPool *sync.Pool, reuseport bool)

+ func (s *Server) Shutdown()

+ 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

Incompatible versions in this module

v13.2.0+incompatible

Sep 1, 2020

v13.1.0+incompatible

Jan 7, 2020

v13.0.0+incompatible

Jan 3, 2020

v12.0.0+incompatible

Mar 6, 2019

v11.0.0+incompatible

Jan 22, 2019

v10.0.0+incompatible

Dec 19, 2018

v9.0.0+incompatible

Nov 12, 2018

v9.0.0-candidate+incompatible

Nov 12, 2018

v8.0.0+incompatible

Sep 21, 2018

v7.0.0+incompatible

Aug 8, 2018

v6.0.0+incompatible

Jun 28, 2018

v5.0.0+incompatible

May 16, 2018

v4.0.0+incompatible

Apr 13, 2018

v3.0.0+incompatible

Feb 27, 2018

v2.0.0+incompatible

Jan 9, 2018

Other modules containing this package

github.com/stripe/veneur/v14

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL