collectd

Jan 30, 2020

Changes in this version

+ func GetDimensionsFromName(val *string) (instanceName string, toAddDims map[string]string)

+ func NewDatapoint(point *JSONWriteFormat, index uint, defaultDimensions map[string]string) *datapoint.Datapoint

+ func NewEvent(e *JSONWriteFormat, defaultDimensions map[string]string) *event.Event

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

+ type JSONDecoder struct

+ Logger log.Logger

+ SendTo dpsink.Sink

+ TotalBlankDims int64

+ TotalErrors int64

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

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

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

+ type JSONWriteBody collectdformat.JSONWriteBody

+ type JSONWriteFormat collectdformat.JSONWriteFormat

+ type ListenerConfig struct

+ DebugContext *web.HeaderCtxFlag

+ HTTPChain web.NextConstructor

+ HealthCheck *string

+ ListenAddr *string

+ ListenPath *string

+ Logger log.Logger

+ StartingContext context.Context

+ Timeout *time.Duration

+ type ListenerServer struct

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

+ func (s *ListenerServer) Close() error

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

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

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