clientcfg

Documentation

Index

• func DefaultDimensions(conf *ClientConfig) (map[string]string, error)
• func WatchSinkChanges(sink sfxclient.Sink, Conf *ClientConfig, logger log.Logger) sfxclient.Sink
• type ClientConfig
  • func (c *ClientConfig) Load(d *distconf.Distconf)
• type ClientConfigChangerSink
  • func (s *ClientConfigChangerSink) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) (err error)

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
	TimeKeeper         timekeeper.TimeKeeper
	OsHostname         func() (name string, err error)
	DisableCompression *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 (*ClientConfigChangerSink) AddDatapoints

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

AddDatapoints forwards the call to Destination