clientcfg

Documentation

Overview

Deprecated: this package is no longer supported.

Index

• func DefaultDimensions(conf *ClientConfig) (map[string]string, error)
• func SetupSinkClientChanger(sink sfxclient.Sink, conf *ClientConfig, authToken func() string, ...) sfxclient.Sink
• func WatchSinkChanges(sink sfxclient.Sink, conf *ClientConfig, logger log.Logger) sfxclient.Sink
• type ClientConfig
  • func (c *ClientConfig) Load(d *distconf.Distconf)
• type ClientConfigChangerSink
  • func WatchHTTPSinkChange(httpSink *sfxclient.HTTPSink, conf *ClientConfig, logger log.Logger) *ClientConfigChangerSink
  • func (s *ClientConfigChangerSink) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) error
  • func (s *ClientConfigChangerSink) AddEvents(ctx context.Context, events []*event.Event) error
  • func (s *ClientConfigChangerSink) AddSpans(ctx context.Context, spans []*trace.Span) error
  • func (s *ClientConfigChangerSink) AuthUpdate() func(string)

Functions

func DefaultDimensions

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

DefaultDimensions extracts default sfxclient dimensions that identify the host

func SetupSinkClientChanger

func SetupSinkClientChanger(sink sfxclient.Sink, conf *ClientConfig, authToken func() string, logger log.Logger) sfxclient.Sink

SetupSinkClientChanger returns a new ClientConfigChangerSink that wraps a sink with endpoint changes from distconf This API should be used if you do not want to have distconf auth watcher

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 sink

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

func (*ClientConfigChangerSink) AuthUpdate

func (s *ClientConfigChangerSink) AuthUpdate() func(string)

AuthUpdate will return a func which can be used for updating auth token if default watcher is not used for token update