clientcfg

package
Version: v2.5.2-0...-f3a5e34 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 8, 2019 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DefaultDimensions

func DefaultDimensions(conf *ClientConfig) (map[string]string, error)

DefaultDimensions extracts default sfxclient dimensions that identify the host

func WatchSinkChanges

func WatchSinkChanges(sink sfxclient.Sink, conf *ClientConfig, logger log.Logger) sfxclient.Sink

WatchSinkChanges returns a new ClientConfigChangerSink that wraps a sink with auth/endpoint changes from distconf

Types

type ClientConfig

type ClientConfig struct {
	SourceName               *distconf.Str
	AuthToken                *distconf.Str
	Endpoint                 *distconf.Str
	ReportingInterval        *distconf.Duration
	ReportingTimeoutInterval *distconf.Duration
	TimeKeeper               timekeeper.TimeKeeper
	OsHostname               func() (name string, err error)
	DisableCompression       *distconf.Bool
	DebugCollectDatapoints   *distconf.Bool
}

ClientConfig configures a SfxClient

func (*ClientConfig) Load

func (c *ClientConfig) Load(d *distconf.Distconf)

Load the client config values from distconf

type ClientConfigChangerSink

type ClientConfigChangerSink struct {
	Destination *sfxclient.HTTPSink
	// contains filtered or unexported fields
}

ClientConfigChangerSink is a sink that can update auth and endpoint values

func WatchHTTPSinkChange

func WatchHTTPSinkChange(httpSink *sfxclient.HTTPSink, conf *ClientConfig, logger log.Logger) *ClientConfigChangerSink

WatchHTTPSinkChange returns anew ClientConfigChangerSink that takes an http sink, instead of a regular sinc

func (*ClientConfigChangerSink) AddDatapoints

func (s *ClientConfigChangerSink) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) error

AddDatapoints forwards the call to Destination

func (*ClientConfigChangerSink) AddEvents

func (s *ClientConfigChangerSink) AddEvents(ctx context.Context, events []*event.Event) error

AddEvents forwards the call to Destination

func (*ClientConfigChangerSink) AddSpans

func (s *ClientConfigChangerSink) AddSpans(ctx context.Context, spans []*trace.Span) error

AddSpans forwards the call to Destination

Source Files

Jump to

Keyboard shortcuts

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