signalfx

Mar 11, 2020

Changes in this version

+ const Distributed

Nov 25, 2019

Changes in this version

+ const ZipkinTracePathV1

+ const ZipkinTracePathV2

+ func SetupJSONByPathsN(r *mux.Router, handler http.Handler, endpoints ...string)

Sep 10, 2019

Changes in this version

type Forwarder

+ func (connector *Forwarder) DebugDatapoints() []*datapoint.Datapoint

+ func (connector *Forwarder) DefaultDatapoints() []*datapoint.Datapoint

type ListenerServer

+ func (streamer *ListenerServer) DebugDatapoints() []*datapoint.Datapoint

+ func (streamer *ListenerServer) DefaultDatapoints() []*datapoint.Datapoint

Jul 31, 2019

Changes in this version

type ListenerConfig

+ Counter *dpsink.Counter

Apr 3, 2019

Changes in this version

type ListenerConfig

+ ObfuscateSpanTags []*spanobfuscation.TagMatchRuleConfig

Apr 3, 2019

Changes in this version

type ListenerConfig

+ RemoveSpanTags []*spanobfuscation.TagRemovalRuleConfig

Mar 4, 2019

Changes in this version

type ListenerConfig

+ AdditionalSpanTags map[string]string

Jan 31, 2019

Changes in this version

type ListenerConfig

+ SpanNameReplacementBreakAfterMatch *bool

Jan 29, 2019

Changes in this version

type Forwarder

+ func (connector *Forwarder) DebugEndpoints() map[string]http.Handler

Jan 17, 2019

Changes in this version

type ListenerConfig

+ SpanNameReplacementRules []string

Jan 4, 2019

Changes in this version

type ForwarderConfig

+ GatewayVersion *string

Dec 12, 2018

Changes in this version

type Forwarder

+ func (connector *Forwarder) StartupFinished() error

Oct 23, 2018

Changes in this version

+ func SetupChain(ctx context.Context, sink Sink, chainType string, ...) (http.Handler, sfxclient.Collector)

type ForwarderConfig

+ TraceSample *sampling.SmartSampleConfig

Aug 3, 2018

Changes in this version

+ const JaegerV1

+ func SetupThriftByPaths(r *mux.Router, handler http.Handler, endpoint string)

+ type JaegerThriftTraceDecoderV1 struct

+ Logger log.Logger

+ Sink trace.Sink

+ func NewJaegerThriftTraceDecoderV1(logger log.Logger, sink trace.Sink) *JaegerThriftTraceDecoderV1

+ func (decoder *JaegerThriftTraceDecoderV1) Read(ctx context.Context, req *http.Request) error

Jul 11, 2018

Changes in this version

+ var ClientKind = "CLIENT"

+ var ConsumerKind = "CONSUMER"

+ var ProducerKind = "PRODUCER"

+ var ServerKind = "SERVER"

+ type InputSpan signalfxformat.InputSpan

May 21, 2018

Changes in this version

+ const DefaultTracePathV1

+ const ZipkinV1

+ type Dataformat []*trace.Span

type Forwarder

+ func (connector *Forwarder) AddSpans(ctx context.Context, traces []*trace.Span) error

type ForwarderConfig

+ DisableCompression *bool

+ TraceURL *string

+ type JSONTraceDecoderV1 struct

+ Logger log.Logger

+ Sink trace.Sink

+ func (decoder *JSONTraceDecoderV1) Read(ctx context.Context, req *http.Request) error

+ type MiddlewareConstructor func(sendTo Sink) Sink

+ func NextWrap(wrapping NextSink) MiddlewareConstructor

+ type NextSink interface

+ AddDatapoints func(ctx context.Context, points []*datapoint.Datapoint, next Sink) error

+ AddEvents func(ctx context.Context, events []*event.Event, next Sink) error

+ AddSpans func(ctx context.Context, spans []*trace.Span, next Sink) error

+ func UnifyNextSinkWrap(s almostNextSink) NextSink

+ type Sink interface

+ func FromChain(endSink Sink, sinks ...MiddlewareConstructor) Sink

+ func IncludingDimensions(dims map[string]string, sink Sink) Sink

+ type WithDimensions struct

+ Dimensions map[string]string

+ func (w *WithDimensions) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint, next Sink) error

+ func (w *WithDimensions) AddEvents(ctx context.Context, events []*event.Event, next Sink) error

+ func (w *WithDimensions) AddSpans(ctx context.Context, spans []*trace.Span, next Sink) error

Dec 5, 2016

Changes in this version

type JSONDecoderV2

+ func (decoder *JSONDecoderV2) Datapoints() []*datapoint.Datapoint

May 17, 2016

Changes in this version

+ func PropertyAsRawType(p *com_signalfx_metrics_protobuf.PropertyValue) interface

type BodySendFormatV2

+ Properties map[string]ValueToSend

type Forwarder

+ func (connector *Forwarder) Pipeline() int64

type ForwarderConfig

+ Filters *filtering.FilterObj

Mar 11, 2016

Changes in this version

type ErrorTrackerHandler

+ Logger log.Logger

type Forwarder

+ Logger log.Logger

type ListenerConfig

+ HTTPChain web.NextConstructor

type ListenerServer

+ func (streamer *ListenerServer) Addr() net.Addr

Mar 3, 2016

Changes in this version

type ListenerConfig

+ HealthCheck *string

Mar 2, 2016

Changes in this version

type ListenerConfig

+ DebugContext *web.HeaderCtxFlag

Jan 6, 2016

Changes in this version

type ErrorTrackerHandler

+ func (e *ErrorTrackerHandler) Datapoints() []*datapoint.Datapoint

type Forwarder

+ func NewForwarder(conf *ForwarderConfig) *Forwarder

+ func (connector *Forwarder) Close() error

+ func (connector *Forwarder) Datapoints() []*datapoint.Datapoint

+ type ForwarderConfig struct

+ AuthToken *string

+ DatapointURL *string

+ EventURL *string

+ JSONMarshal func(v interface{}) ([]byte, error)

+ Logger log.Logger

+ MaxIdleConns *int64

+ ProtoMarshal func(pb proto.Message) ([]byte, error)

+ ProxyVersion *string

+ SourceDimensions *string

+ Timeout *time.Duration

+ type ListenerConfig struct

+ JSONMarshal func(v interface{}) ([]byte, error)

+ ListenAddr *string

+ Logger log.Logger

+ RootContext context.Context

+ Timeout *time.Duration

type ListenerServer

+ func NewListener(sink dpsink.Sink, conf *ListenerConfig) (*ListenerServer, error)

+ func (streamer *ListenerServer) Datapoints() []*datapoint.Datapoint

Dec 28, 2015

Changes in this version

type JSONDecoderV1

+ Logger log.Logger

type JSONDecoderV2

+ Logger log.Logger

type JSONEventDecoderV2

+ Logger log.Logger

type ProtobufDecoderV1

+ Logger log.Logger

type ProtobufDecoderV2

+ Logger log.Logger

type ProtobufEventDecoderV2

+ Logger log.Logger

Dec 16, 2015

Changes in this version

+ func NewProtobufEvent(e *com_signalfx_metrics_protobuf.Event) (*event.Event, error)

+ func SetupJSONByPaths(r *mux.Router, handler http.Handler, endpoint string)

+ func SetupJSONV2DatapointPaths(r *mux.Router, handler http.Handler)

+ func SetupJSONV2EventPaths(r *mux.Router, handler http.Handler)

+ func SetupProtobufV2ByPaths(r *mux.Router, handler http.Handler, path string)

+ func SetupProtobufV2DatapointPaths(r *mux.Router, handler http.Handler)

+ func SetupProtobufV2EventPaths(r *mux.Router, handler http.Handler)

+ type EventSendFormatV2 struct

+ Category *string

+ Dimensions map[string]string

+ EventType string

+ Properties map[string]interface{}

+ Timestamp *int64

+ type JSONEventDecoderV2 struct

+ Sink dpsink.ESink

+ func (decoder *JSONEventDecoderV2) Read(ctx context.Context, req *http.Request) error

+ type JSONEventV2 []*EventSendFormatV2

+ type ProtobufEventDecoderV2 struct

+ Sink dpsink.ESink

+ func (decoder *ProtobufEventDecoderV2) Read(ctx context.Context, req *http.Request) error

Nov 14, 2015

Changes in this version

type Forwarder

+ func NewSignalfxJSONForwarder(url string, timeout time.Duration, defaultAuthToken string, ...) *Forwarder

+ func (connector *Forwarder) AddEvents(ctx context.Context, events []*event.Event) error

+ func (connector *Forwarder) EventEndpoint(endpoint string)

+ type JSONEvent struct

+ Category string

+ Dimensions map[string]string

+ EventType string

+ Meta map[string]interface{}

+ Timestamp int64

May 1, 2015

Changes in this version

+ const TokenHeaderName

+ func ForwarderLoader(ctx context.Context, forwardTo *config.ForwardTo) (protocol.Forwarder, error)

+ func NewDatumValue(val *com_signalfx_metrics_protobuf.Datum) datapoint.Value

+ func NewProtobufDataPointWithType(dp *com_signalfx_metrics_protobuf.DataPoint, ...) *datapoint.Datapoint

+ func SetupCollectdPaths(r *mux.Router, handler http.Handler)

+ func SetupJSONV1Paths(r *mux.Router, handler http.Handler)

+ func SetupJSONV2Paths(r *mux.Router, handler http.Handler)

+ func SetupProtobufV1Paths(r *mux.Router, handler http.Handler)

+ func SetupProtobufV2Paths(r *mux.Router, handler http.Handler)

+ func ValueToValue(v ValueToSend) (datapoint.Value, error)

+ type BodySendFormatV2 struct

+ Dimensions map[string]string

+ Metric string

+ Timestamp int64

+ Value ValueToSend

+ func (bodySendFormat *BodySendFormatV2) String() string

+ type ConstTypeGetter com_signalfx_metrics_protobuf.MetricType

+ func (c ConstTypeGetter) GetMetricTypeFromMap(metricName string) com_signalfx_metrics_protobuf.MetricType

+ type ErrorReader interface

+ Read func(ctx context.Context, req *http.Request) error

+ type ErrorTrackerHandler struct

+ TotalErrors int64

+ func (e *ErrorTrackerHandler) ServeHTTPC(ctx context.Context, rw http.ResponseWriter, req *http.Request)

+ func (e *ErrorTrackerHandler) Stats(dimensions map[string]string) []*datapoint.Datapoint

+ type Forwarder struct

+ func ForwarderLoader1(ctx context.Context, forwardTo *config.ForwardTo) (protocol.Forwarder, *Forwarder, error)

+ func NewSignalfxJSONForwarer(url string, timeout time.Duration, defaultAuthToken string, ...) *Forwarder

+ func (connector *Forwarder) AddDatapoints(ctx context.Context, datapoints []*datapoint.Datapoint) error

+ func (connector *Forwarder) AuthToken(authToken string)

+ func (connector *Forwarder) Endpoint(endpoint string)

+ func (connector *Forwarder) UserAgent(ua string)

+ type JSONDatapointV1 struct

+ Metric string

+ Source string

+ Value float64

+ type JSONDatapointV2 map[string][]*BodySendFormatV2

+ type JSONDecoderV1 struct

+ Sink dpsink.Sink

+ TypeGetter MericTypeGetter

+ func (decoder *JSONDecoderV1) Read(ctx context.Context, req *http.Request) error

+ type JSONDecoderV2 struct

+ Sink dpsink.Sink

+ func (decoder *JSONDecoderV2) Read(ctx context.Context, req *http.Request) error

+ type ListenerServer struct

+ func ListenerLoader(ctx context.Context, sink dpsink.Sink, listenFrom *config.ListenFrom) (*ListenerServer, error)

+ func StartServingHTTPOnPort(ctx context.Context, sink dpsink.Sink, listenAddr string, ...) (*ListenerServer, error)

+ func (streamer *ListenerServer) Close() error

+ type MericTypeGetter interface

+ GetMetricTypeFromMap func(metricName string) com_signalfx_metrics_protobuf.MetricType

+ type MetricCreationResponse struct

+ Code int

+ Error bool

+ Message string

+ type MetricCreationStruct struct

+ MetricName string

+ MetricType string

+ type ProtobufDecoderV1 struct

+ Sink dpsink.Sink

+ TypeGetter MericTypeGetter

+ func (decoder *ProtobufDecoderV1) Read(ctx context.Context, req *http.Request) error

+ type ProtobufDecoderV2 struct

+ Sink dpsink.Sink

+ func (decoder *ProtobufDecoderV2) Read(ctx context.Context, req *http.Request) error

+ type ValueToSend interface