veneur

package module

Go to main page

Versions in this module

v14

v14.2.0

May 9, 2022

Changes in this version

+ const CounterTypeName

+ const GaugeTypeName

+ const HistogramTypeName

+ const SetTypeName

+ const StatusTypeName

+ const TimerTypeName

+ func ForwardGrpcSingle(ctx context.Context, client forwardrpc.ForwardClient, ...) error

+ func ForwardGrpcStream(ctx context.Context, client forwardrpc.ForwardClient, ...) error

type Config

+ ExtendTags []string

+ Features struct{ ... }

+ FlushOnShutdown bool

+ HTTP HttpConfig

+ MetricSinkRouting []SinkRoutingConfig

+ MetricSinks []SinkConfig

+ SignalfxVaryKeyByFavorCommonDimensions bool

+ Sources []SourceConfig

+ SpanSinks []SinkConfig

+ type GlobalListeningPerProtocolMetrics struct

+ type GrpcMetricsSource struct

+ func (source *GrpcMetricsSource) StartGRPC(s *Server, a net.Addr) net.Addr

+ type HttpConfig struct

+ Config bool

+ type MetricSinkConfig interface

+ type MetricSinkTypes = map[string]struct

+ type ParsedSourceConfig interface

+ type ProtocolType int

+ const DOGSTATSD_GRPC

+ const DOGSTATSD_TCP

+ const DOGSTATSD_UDP

+ const DOGSTATSD_UNIX

+ const SSF_GRPC

+ const SSF_UDP

+ const SSF_UNIX

+ func (p ProtocolType) String() string

type Proxy

+ func (p *Proxy) IsListeningHTTP() bool

type ProxyConfig

+ IgnoreTags []matcher.TagMatcher

+ type ProxyProtocol int64

+ const ProxyProtocolGrpcSingle

+ const ProxyProtocolGrpcStream

+ const ProxyProtocolRest

+ const ProxyProtocolUnknown

+ type SentryHook struct

+ Level []logrus.Level

+ func (s SentryHook) Fire(e *logrus.Entry) error

+ func (s SentryHook) Levels() []logrus.Level

type Server

+ Config Config

+ FlushOnShutdown bool

+ Interval time.Duration

+ func (s *Server) IsListeningHTTP() bool

+ type ServerConfig struct

+ Config Config

+ Logger *logrus.Logger

+ MetricSinkTypes MetricSinkTypes

+ SourceTypes SourceTypes

+ SpanSinkTypes SpanSinkTypes

+ type SinkConfig struct

+ Config interface{}

+ Kind string

+ Name string

+ StripTags []matcher.TagMatcher

+ type SinkRoutingConfig struct

+ Match []matcher.Matcher

+ Name string

+ Sinks SinkRoutingSinks

+ type SinkRoutingSinks struct

+ Matched []string

+ NotMatched []string

+ type SourceConfig struct

+ Config interface{}

+ Kind string

+ Name string

+ Tags []string

+ type SourceTypes = map[string]struct

+ type SpanSinkConfig interface

+ type SpanSinkTypes = map[string]struct

+ type SsfMetricsSource struct

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

+ type UdpMetricsSource struct

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

v14.1.0

Mar 17, 2021

Changes in this version

+ func StartGRPC(s *Server, a net.Addr) net.Addr

type Config

+ GrpcListenAddresses []string

type Server

+ GRPCListenAddrs []net.Addr

v14.0.0

Jan 14, 2021

Changes in this version

+ const REDACTED

+ const SentryFlushTimeout

+ var BUILD_DATE = defaultLinkValue

+ var VERSION = defaultLinkValue

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

+ func ConsumePanic(cl *trace.Client, hostname string, err interface{})

+ func NewSocket(addr *net.UDPAddr, recvBuf int, reuseport bool) (net.PacketConn, error)

+ func SetLogger(logger *logrus.Logger)

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

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

+ type Config struct

+ Aggregates []string

+ AwsAccessKeyID string

+ AwsRegion string

+ AwsS3Bucket string

+ AwsSecretAccessKey string

+ BlockProfileRate int

+ CountUniqueTimeseries bool

+ DatadogAPIHostname string

+ DatadogAPIKey string

+ DatadogExcludeTagsPrefixByPrefixMetric []struct{ ... }

+ DatadogFlushMaxPerBody int

+ DatadogMetricNamePrefixDrops []string

+ DatadogSpanBufferSize int

+ DatadogTraceAPIAddress string

+ Debug bool

+ DebugFlushedMetrics bool

+ DebugIngestedSpans bool

+ EnableProfiling bool

+ FalconerAddress string

+ FlushFile string

+ FlushMaxPerBody int

+ FlushWatchdogMissedFlushes int

+ ForwardAddress string

+ ForwardUseGrpc bool

+ GrpcAddress string

+ HTTPAddress string

+ HTTPQuit bool

+ Hostname string

+ IndicatorSpanTimerName string

+ Interval 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 float64

+ KafkaSpanSampleTag string

+ KafkaSpanSerializationFormat string

+ KafkaSpanTopic string

+ LightstepAccessToken string

+ LightstepCollectorHost string

+ LightstepMaximumSpans int

+ LightstepNumClients int

+ LightstepReconnectPeriod string

+ MetricMaxLength int

+ MutexProfileFraction int

+ NewrelicAccountID int

+ NewrelicCommonTags []string

+ NewrelicEventType string

+ NewrelicInsertKey string

+ NewrelicRegion string

+ NewrelicServiceCheckEventType string

+ NewrelicTraceObserverURL string

+ NumReaders int

+ NumSpanWorkers int

+ NumWorkers int

+ ObjectiveSpanTimerName string

+ OmitEmptyHostname bool

+ Percentiles []float64

+ PrometheusNetworkType string

+ PrometheusRepeaterAddress string

+ ReadBufferSizeBytes int

+ SentryDsn string

+ SignalfxAPIKey string

+ SignalfxDynamicPerTagAPIKeysEnable bool

+ SignalfxDynamicPerTagAPIKeysRefreshPeriod string

+ SignalfxEndpointAPI string

+ SignalfxEndpointBase string

+ SignalfxFlushMaxPerBody int

+ 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

+ SsfBufferSize int

+ SsfListenAddresses []string

+ StatsAddress string

+ StatsdListenAddresses []string

+ SynchronizeWithInterval bool

+ TLSAuthorityCertificate string

+ TLSCertificate string

+ TLSKey string

+ Tags []string

+ TagsExclude []string

+ TraceLightstepAccessToken string

+ TraceLightstepCollectorHost string

+ TraceLightstepMaximumSpans int

+ TraceLightstepNumClients int

+ TraceLightstepReconnectPeriod string

+ TraceMaxLengthBytes int

+ VeneurMetricsAdditionalTags []string

+ VeneurMetricsScopes struct{ ... }

+ XrayAddress string

+ XrayAnnotationTags []string

+ XraySamplePercentage float64

+ func ReadConfig(path string) (c Config, err error)

+ func (c Config) ParseInterval() (time.Duration, error)

+ type Consul struct

+ ConsulHealth *api.Health

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

+ func (c *Consul) GetDestinationsForService(serviceName string) ([]string, 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 Discoverer interface

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

+ type EventWorker struct

+ func NewEventWorker(cl *trace.Client, stats scopedstatsd.Client) *EventWorker

+ func (ew *EventWorker) Flush() []ssf.SSFSample

+ func (ew *EventWorker) Work()

+ type KubernetesDiscoverer struct

+ func NewKubernetesDiscoverer() (*KubernetesDiscoverer, error)

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

+ type Proxy struct

+ AcceptingForwards bool

+ AcceptingGRPCForwards bool

+ AcceptingTraces bool

+ ConsulForwardGRPCService string

+ ConsulForwardService string

+ ConsulInterval time.Duration

+ ConsulTraceService string

+ Discoverer Discoverer

+ ForwardDestinations *consistent.Consistent

+ ForwardDestinationsMtx sync.Mutex

+ ForwardGRPCDestinations *consistent.Consistent

+ ForwardGRPCDestinationsMtx sync.Mutex

+ ForwardTimeout time.Duration

+ HTTPAddr string

+ HTTPClient *http.Client

+ Hostname string

+ MetricsInterval time.Duration

+ TraceClient *trace.Client

+ TraceDestinations *consistent.Consistent

+ TraceDestinationsMtx sync.Mutex

+ func NewProxyFromConfig(logger *logrus.Logger, 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, origin string)

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

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

+ func (p *Proxy) ReportRuntimeMetrics()

+ func (p *Proxy) Serve()

+ func (p *Proxy) Shutdown()

+ func (p *Proxy) Start()

+ type ProxyConfig struct

+ ConsulForwardGrpcServiceName string

+ ConsulForwardServiceName string

+ ConsulRefreshInterval string

+ ConsulTraceServiceName string

+ Debug bool

+ EnableProfiling bool

+ ForwardAddress string

+ ForwardTimeout string

+ GrpcAddress string

+ GrpcForwardAddress string

+ HTTPAddress string

+ IdleConnectionTimeout string

+ MaxIdleConns int

+ MaxIdleConnsPerHost int

+ RuntimeMetricsInterval string

+ SentryDsn string

+ SsfDestinationAddress string

+ StatsAddress string

+ TraceAPIAddress string

+ TraceAddress string

+ TracingClientCapacity int

+ TracingClientFlushInterval string

+ TracingClientMetricsInterval string

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

+ type Server struct

+ CountUniqueTimeseries bool

+ EventWorker *EventWorker

+ ForwardAddr string

+ HTTPAddr string

+ HTTPClient *http.Client

+ HistogramAggregates samplers.HistogramAggregates

+ HistogramPercentiles []float64

+ Hostname string

+ RcvbufBytes int

+ SSFListenAddrs []net.Addr

+ SpanChan chan *ssf.SSFSpan

+ SpanWorker *SpanWorker

+ SpanWorkerGoroutines int

+ Statsd *scopedstatsd.ScopedClient

+ StatsdListenAddrs []net.Addr

+ Tags []string

+ TagsAsMap map[string]string

+ TraceClient *trace.Client

+ Workers []*Worker

+ func NewFromConfig(logger *logrus.Logger, conf Config) (*Server, error)

+ func (s *Server) Flush(ctx context.Context)

+ func (s *Server) FlushWatchdog()

+ 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(serverConn net.PacketConn, packetPool *sync.Pool)

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

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

+ func (s *Server) ReadStatsdDatagramSocket(serverConn *net.UnixConn, packetPool *sync.Pool)

+ func (s *Server) ReadTCPSocket(listener net.Listener)

+ func (s *Server) Serve()

+ func (s *Server) Shutdown()

+ func (s *Server) Start()

+ type SpanWorker struct

+ SpanChan <-chan *ssf.SSFSpan

+ func NewSpanWorker(sinks []sinks.SpanSink, cl *trace.Client, statsd scopedstatsd.Client, ...) *SpanWorker

+ func (tw *SpanWorker) Flush()

+ func (tw *SpanWorker) Work()

+ type UnknownConfigKeys struct

+ func (e *UnknownConfigKeys) Error() string

+ type Worker struct

+ ImportChan chan []samplers.JSONMetric

+ ImportMetricChan chan []*metricpb.Metric

+ PacketChan chan samplers.UDPMetric

+ QuitChan chan struct{}

+ func NewWorker(id int, isLocal bool, countUniqueTimeseries bool, cl *trace.Client, ...) *Worker

+ func (w *Worker) Flush() WorkerMetrics

+ func (w *Worker) ImportMetric(other samplers.JSONMetric)

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

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

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

+ func (w *Worker) MetricsProcessedCount() int64

+ func (w *Worker) ProcessMetric(m *samplers.UDPMetric)

+ func (w *Worker) SampleTimeseries(m *samplers.UDPMetric)

+ func (w *Worker) Stop()

+ func (w *Worker) Work()

+ type WorkerMetrics struct

+ func NewWorkerMetrics() WorkerMetrics

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

+ func (wm WorkerMetrics) Upsert(mk samplers.MetricKey, Scope samplers.MetricScope, tags []string) bool

v14.0.0-pre.0

Jan 6, 2021

Other modules containing this package

github.com/stripe/veneur

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