config

package
v1.0.15 Latest Latest
Warning

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

 Go to latest Published: Feb 26, 2019 License: Apache-2.0 Imports: 26 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DefaultGatewayConfig = &GatewayConfig{
	PidFilename:                   pointer.String("gateway.pid"),
	LogDir:                        pointer.String(os.TempDir()),
	LogMaxSize:                    pointer.Int(100),
	LogMaxBackups:                 pointer.Int(10),
	LogFormat:                     pointer.String(""),
	ServerName:                    pointer.String(getDefaultName(os.Hostname)),
	MaxGracefulWaitTimeDuration:   pointer.Duration(time.Second),
	GracefulCheckIntervalDuration: pointer.Duration(time.Second),
	SilentGracefulTimeDuration:    pointer.Duration(2 * time.Second),
	ListenOnPeerAddress:           pointer.String("0.0.0.0:2380"),
	AdvertisePeerAddress:          pointer.String("127.0.0.1:2380"),
	ListenOnClientAddress:         pointer.String("0.0.0.0:2379"),
	AdvertiseClientAddress:        pointer.String("127.0.0.1:2379"),
	ETCDMetricsAddress:            pointer.String("127.0.0.1:2381"),
	UnhealthyMemberTTL:            pointer.Duration(time.Second * 5),
	RemoveMemberTimeout:           pointer.Duration(time.Second),
	ClusterDataDir:                pointer.String("./etcd-data"),
	ClusterOperation:              pointer.String(""),
	TargetClusterAddresses:        []string{},
	AdditionalDimensions:          map[string]string{},
	ClusterName:                   pointer.String("gateway"),
}

DefaultGatewayConfig is default values for the gateway config

Functions

This section is empty.

Types

type ForwardTo 

type ForwardTo struct {
	URL                  *string `json:",omitempty"`
	EventURL             *string `json:",omitempty"`
	TraceURL             *string `json:",omitempty"`
	Host                 *string `json:",omitempty"`
	Port                 *uint16 `json:",omitempty"`
	Type                 string
	TimeoutDuration      *time.Duration              `json:"-"`
	Timeout              *string                     `json:",omitempty"`
	DefaultSource        *string                     `json:",omitempty"`
	DefaultAuthToken     *string                     `json:",omitempty"`
	AuthTokenEnvVar      *string                     `json:",omitempty"`
	BufferSize           *int64                      `json:",omitempty"`
	Name                 *string                     `json:",omitempty"`
	DrainingThreads      *int64                      `json:",omitempty"`
	MetricCreationURL    *string                     `json:",omitempty"`
	MaxDrainSize         *int64                      `json:",omitempty"`
	Filename             *string                     `json:",omitempty"`
	SourceDimensions     *string                     `json:",omitempty"`
	FormatVersion        *uint32                     `json:",omitempty"`
	DimensionsOrder      []string                    `json:",omitempty"`
	Filters              *filtering.FilterObj        `json:",omitempty"`
	TraceSample          *sampling.SmartSampleConfig `json:",omitempty"`
	AdditionalDimensions map[string]string           `json:",omitempty"`
	DisableCompression   *bool                       `json:",omitempty"`
	Server               etcdIntf.Server             `json:"-"`
	Client               etcdIntf.Client             `json:"-"`
	ClusterName          *string                     `json:"-"`
}

ForwardTo configures where we forward datapoints to

func (*ForwardTo) String 

func (forwardTo *ForwardTo) String() string

type GatewayConfig added in v1.0.1 

type GatewayConfig struct {
	ForwardTo                      []*ForwardTo      `json:",omitempty"`
	ListenFrom                     []*ListenFrom     `json:",omitempty"`
	StatsDelay                     *string           `json:",omitempty"`
	StatsDelayDuration             *time.Duration    `json:"-"`
	NumProcs                       *int              `json:",omitempty"`
	LocalDebugServer               *string           `json:",omitempty"`
	PidFilename                    *string           `json:",omitempty"`
	LogDir                         *string           `json:",omitempty"`
	LogMaxSize                     *int              `json:",omitempty"`
	LogMaxBackups                  *int              `json:",omitempty"`
	LogFormat                      *string           `json:",omitempty"`
	PprofAddr                      *string           `json:",omitempty"`
	DebugFlag                      *string           `json:",omitempty"`
	ServerName                     *string           `json:",omitempty"`
	MaxGracefulWaitTime            *string           `json:",omitempty"`
	GracefulCheckInterval          *string           `json:",omitempty"`
	SilentGracefulTime             *string           `json:",omitempty"`
	MaxGracefulWaitTimeDuration    *time.Duration    `json:"-"`
	GracefulCheckIntervalDuration  *time.Duration    `json:"-"`
	SilentGracefulTimeDuration     *time.Duration    `json:"-"`
	LateThreshold                  *string           `json:",omitempty"`
	FutureThreshold                *string           `json:",omitempty"`
	LateThresholdDuration          *time.Duration    `json:"-"`
	FutureThresholdDuration        *time.Duration    `json:"-"`
	ClusterOperation               *string           `json:",omitempty"`
	ClusterDataDir                 *string           `json:",omitempty"`
	TargetClusterAddresses         []string          `json:",omitempty"`
	AdvertisePeerAddress           *string           `json:",omitempty"`
	ListenOnPeerAddress            *string           `json:",omitempty"`
	AdvertiseClientAddress         *string           `json:",omitempty"`
	ListenOnClientAddress          *string           `json:",omitempty"`
	ETCDMetricsAddress             *string           `json:",omitempty"`
	UnhealthyMemberTTL             *time.Duration    `json:"-"`
	RemoveMemberTimeout            *time.Duration    `json:"-"`
	AdditionalDimensions           map[string]string `json:",omitempty"`
	InternalMetricsListenerAddress *string           `json:",omitempty"`
	ClusterName                    *string           `json:",omitempty"`
}

GatewayConfig is the full config as presented inside the gateway config file

func Load 

func Load(configFile string, logger log.Logger) (*GatewayConfig, error)

Load loads gateway configuration from a filename that is in an xdg configuration location

func (*GatewayConfig) String added in v1.0.1 

func (p *GatewayConfig) String() string

func (*GatewayConfig) Var added in v1.0.1 

func (p *GatewayConfig) Var() expvar.Var

Var returns the gateway config itself as an expvar

type ListenFrom 

type ListenFrom struct {
	Type                               string
	ListenAddr                         *string                `json:",omitempty"`
	Dimensions                         map[string]string      `json:",omitempty"`
	MetricDeconstructor                *string                `json:",omitempty"`
	MetricDeconstructorOptions         *string                `json:",omitempty"`
	MetricDeconstructorOptionsJSON     map[string]interface{} `json:",omitempty"`
	Timeout                            *string                `json:",omitempty"`
	Name                               *string                `json:",omitempty"`
	ListenPath                         *string                `json:",omitempty"`
	JSONEngine                         *string                `json:",omitempty"`
	Encrypted                          *bool                  `json:",omitempty"`
	Protocol                           *string                `json:",omitempty"`
	TimeoutDuration                    *time.Duration         `json:"-"`
	ServerAcceptDeadline               *time.Duration         `json:"-"`
	SpanNameReplacementRules           []string               `json:",omitempty"`
	SpanNameReplacementBreakAfterMatch *bool                  `json:",omitempty"`
}

ListenFrom configures how we listen for datapoints to forward

func (*ListenFrom) String 

func (listenFrom *ListenFrom) String() string

type Loader added in v0.9.0 

type Loader struct {
	// contains filtered or unexported fields
}

Loader is able to load forwarders and listeners from config type strings

func NewLoader added in v0.9.0 

func NewLoader(ctx context.Context, logger log.Logger, version string, debugContext *web.HeaderCtxFlag, itemFlagger *dpsink.ItemFlagger, ctxdims *log.CtxDimensions, next web.NextConstructor) *Loader

NewLoader creates the default loader for gateway protocols

func (*Loader) Forwarder added in v0.9.0 

func (l *Loader) Forwarder(conf *ForwardTo) (protocol.Forwarder, error)

Forwarder loads a forwarder based upon config, finding the right forwarder first

func (*Loader) Listener added in v0.9.0 

func (l *Loader) Listener(sink signalfx.Sink, conf *ListenFrom) (protocol.Listener, error)

Listener loads a listener based upon config, finding the right listener first

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.