config

package
v0.0.0-...-bb0e5b5 Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package config is a generated protocol buffer package.

The `wavefront` adapter collects metrics and makes them available to [Wavefront by VMware](https://www.wavefront.com/).

This adapter supports the [metric template](https://istio.io/docs/reference/config/policy-and-telemetry/templates/metric/).

It is generated from these files: 

mixer/adapter/wavefront/config/config.proto

It has these top-level messages: 

Params

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthConfig = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowConfig   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	// InvalidDirectCredsError is returned when invalid direct credentials are found in the configuration.
	InvalidDirectCredsError = errors.New("invalid server or token found in configuration")
	// InvalidProxyCredsError is returned when invalid proxy credentials are found in the configuration.
	InvalidProxyCredsError = errors.New("invalid proxy address found in configuration")
	// NoCredentialsError is returned when no valid credentials are found in the configuration.
	NoCredentialsError = errors.New("no credentials were found in the configuration")
	// NoInstanceNameError is returned when an instance name isn't supplied for a metric.
	NoInstanceNameError = errors.New("metric instance name must be supplied")
)
View Source 
var Params_MetricInfo_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "GAUGE",
	2: "COUNTER",
	3: "DELTA_COUNTER",
	4: "HISTOGRAM",
}
View Source 
var Params_MetricInfo_Type_value = map[string]int32{
	"UNKNOWN":       0,
	"GAUGE":         1,
	"COUNTER":       2,
	"DELTA_COUNTER": 3,
	"HISTOGRAM":     4,
}

Functions

func MetricName 

func MetricName(m *Params_MetricInfo) string

MetricName returns the name for the given metric instance.

func ValidateCredentials 

func ValidateCredentials(cfg *Params) error

ValidateCredentials validates the credentials given a Params instance.

func ValidateMetrics 

func ValidateMetrics(cfg *Params) error

ValidateMetrics validates the metrics configuration given a Params instance.

Types

type Params 

type Params struct {
	// One of the Wavefront service credentials must be supplied.
	//
	// Types that are valid to be assigned to Credentials:
	//	*Params_Direct
	//	*Params_Proxy
	Credentials isParams_Credentials `protobuf_oneof:"credentials"`
	// The metrics flush interval.
	FlushInterval time.Duration `protobuf:"bytes,3,opt,name=flush_interval,json=flushInterval,stdduration" json:"flush_interval"`
	// The source tag for all metrics handled by this adapter.
	Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	// The prefix to prepend all metrics handled by the adapter.
	Prefix string `protobuf:"bytes,5,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// The set of metrics to publish to Wavefront.
	Metrics []*Params_MetricInfo `protobuf:"bytes,6,rep,name=metrics" json:"metrics,omitempty"`
	// The log configuration.
	Logs *Params_Logs `protobuf:"bytes,7,opt,name=logs" json:"logs,omitempty"`
}

Configuration format for the `wavefront` adapter.

func (*Params) Descriptor 

func (*Params) Descriptor() ([]byte, []int)

func (*Params) Equal 

func (this *Params) Equal(that interface{}) bool

func (*Params) GetCredentials 

func (m *Params) GetCredentials() isParams_Credentials

func (*Params) GetDirect 

func (m *Params) GetDirect() *Params_WavefrontDirect

func (*Params) GetFlushInterval 

func (m *Params) GetFlushInterval() time.Duration

func (*Params) GetLogs 

func (m *Params) GetLogs() *Params_Logs

func (*Params) GetMetrics 

func (m *Params) GetMetrics() []*Params_MetricInfo

func (*Params) GetPrefix 

func (m *Params) GetPrefix() string

func (*Params) GetProxy 

func (m *Params) GetProxy() *Params_WavefrontProxy

func (*Params) GetSource 

func (m *Params) GetSource() string

func (*Params) GoString 

func (this *Params) GoString() string

func (*Params) Marshal 

func (m *Params) Marshal() (dAtA []byte, err error)

func (*Params) MarshalTo 

func (m *Params) MarshalTo(dAtA []byte) (int, error)

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

func (m *Params) Size() (n int)

func (*Params) String 

func (this *Params) String() string

func (*Params) Unmarshal 

func (m *Params) Unmarshal(dAtA []byte) error

func (*Params) XXX_OneofFuncs 

func (*Params) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Params_Direct 

type Params_Direct struct {
	Direct *Params_WavefrontDirect `protobuf:"bytes,1,opt,name=direct,oneof"`
}

func (*Params_Direct) Equal 

func (this *Params_Direct) Equal(that interface{}) bool

func (*Params_Direct) GoString 

func (this *Params_Direct) GoString() string

func (*Params_Direct) MarshalTo 

func (m *Params_Direct) MarshalTo(dAtA []byte) (int, error)

func (*Params_Direct) Size 

func (m *Params_Direct) Size() (n int)

func (*Params_Direct) String 

func (this *Params_Direct) String() string

type Params_Logs 

type Params_Logs struct {
	// The log level (one of error, warn, info, debug, or none). Ex: info
	Level string `protobuf:"bytes,1,opt,name=level,proto3" json:"level,omitempty"`
}

Describes the logging configuration.

func (*Params_Logs) Descriptor 

func (*Params_Logs) Descriptor() ([]byte, []int)

func (*Params_Logs) Equal 

func (this *Params_Logs) Equal(that interface{}) bool

func (*Params_Logs) GetLevel 

func (m *Params_Logs) GetLevel() string

func (*Params_Logs) GoString 

func (this *Params_Logs) GoString() string

func (*Params_Logs) Marshal 

func (m *Params_Logs) Marshal() (dAtA []byte, err error)

func (*Params_Logs) MarshalTo 

func (m *Params_Logs) MarshalTo(dAtA []byte) (int, error)

func (*Params_Logs) ProtoMessage 

func (*Params_Logs) ProtoMessage()

func (*Params_Logs) Reset 

func (m *Params_Logs) Reset()

func (*Params_Logs) Size 

func (m *Params_Logs) Size() (n int)

func (*Params_Logs) String 

func (this *Params_Logs) String() string

func (*Params_Logs) Unmarshal 

func (m *Params_Logs) Unmarshal(dAtA []byte) error

type Params_MetricInfo 

type Params_MetricInfo struct {
	// The metric name. (Optional)
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The fully qualified Istio metric instance name.
	InstanceName string `protobuf:"bytes,4,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	// The metric type.
	Type Params_MetricInfo_Type `protobuf:"varint,2,opt,name=type,proto3,enum=wavefront.config.Params_MetricInfo_Type" json:"type,omitempty"`
	// For metrics with type HISTOGRAM, this describes the sample definition.
	Sample *Params_MetricInfo_Sample `protobuf:"bytes,3,opt,name=sample" json:"sample,omitempty"`
}

Describes how a metric should be represented on Wavefront.

func (*Params_MetricInfo) Descriptor 

func (*Params_MetricInfo) Descriptor() ([]byte, []int)

func (*Params_MetricInfo) Equal 

func (this *Params_MetricInfo) Equal(that interface{}) bool

func (*Params_MetricInfo) GetInstanceName 

func (m *Params_MetricInfo) GetInstanceName() string

func (*Params_MetricInfo) GetName 

func (m *Params_MetricInfo) GetName() string

func (*Params_MetricInfo) GetSample 

func (m *Params_MetricInfo) GetSample() *Params_MetricInfo_Sample

func (*Params_MetricInfo) GetType 

func (m *Params_MetricInfo) GetType() Params_MetricInfo_Type

func (*Params_MetricInfo) GoString 

func (this *Params_MetricInfo) GoString() string

func (*Params_MetricInfo) Marshal 

func (m *Params_MetricInfo) Marshal() (dAtA []byte, err error)

func (*Params_MetricInfo) MarshalTo 

func (m *Params_MetricInfo) MarshalTo(dAtA []byte) (int, error)

func (*Params_MetricInfo) ProtoMessage 

func (*Params_MetricInfo) ProtoMessage()

func (*Params_MetricInfo) Reset 

func (m *Params_MetricInfo) Reset()

func (*Params_MetricInfo) Size 

func (m *Params_MetricInfo) Size() (n int)

func (*Params_MetricInfo) String 

func (this *Params_MetricInfo) String() string

func (*Params_MetricInfo) Unmarshal 

func (m *Params_MetricInfo) Unmarshal(dAtA []byte) error

type Params_MetricInfo_Sample 

type Params_MetricInfo_Sample struct {
	// One of the sample definition must be supplied.
	//
	// Types that are valid to be assigned to Definition:
	//	*Params_MetricInfo_Sample_ExpDecay_
	//	*Params_MetricInfo_Sample_Uniform_
	Definition isParams_MetricInfo_Sample_Definition `protobuf_oneof:"definition"`
}

Describes a sample as in the rcrowley/go-metrics(https://github.com/rcrowley/go-metrics) library.

func (*Params_MetricInfo_Sample) Descriptor 

func (*Params_MetricInfo_Sample) Descriptor() ([]byte, []int)

func (*Params_MetricInfo_Sample) Equal 

func (this *Params_MetricInfo_Sample) Equal(that interface{}) bool

func (*Params_MetricInfo_Sample) GetDefinition 

func (m *Params_MetricInfo_Sample) GetDefinition() isParams_MetricInfo_Sample_Definition

func (*Params_MetricInfo_Sample) GetExpDecay 

func (m *Params_MetricInfo_Sample) GetExpDecay() *Params_MetricInfo_Sample_ExpDecay

func (*Params_MetricInfo_Sample) GetUniform 

func (m *Params_MetricInfo_Sample) GetUniform() *Params_MetricInfo_Sample_Uniform

func (*Params_MetricInfo_Sample) GoString 

func (this *Params_MetricInfo_Sample) GoString() string

func (*Params_MetricInfo_Sample) Marshal 

func (m *Params_MetricInfo_Sample) Marshal() (dAtA []byte, err error)

func (*Params_MetricInfo_Sample) MarshalTo 

func (m *Params_MetricInfo_Sample) MarshalTo(dAtA []byte) (int, error)

func (*Params_MetricInfo_Sample) ProtoMessage 

func (*Params_MetricInfo_Sample) ProtoMessage()

func (*Params_MetricInfo_Sample) Reset 

func (m *Params_MetricInfo_Sample) Reset()

func (*Params_MetricInfo_Sample) Size 

func (m *Params_MetricInfo_Sample) Size() (n int)

func (*Params_MetricInfo_Sample) String 

func (this *Params_MetricInfo_Sample) String() string

func (*Params_MetricInfo_Sample) Unmarshal 

func (m *Params_MetricInfo_Sample) Unmarshal(dAtA []byte) error

func (*Params_MetricInfo_Sample) XXX_OneofFuncs 

func (*Params_MetricInfo_Sample) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Params_MetricInfo_Sample_ExpDecay 

type Params_MetricInfo_Sample_ExpDecay struct {
	// The reservoir size.
	ReservoirSize int32 `protobuf:"varint,1,opt,name=reservoir_size,json=reservoirSize,proto3" json:"reservoir_size,omitempty"`
	// The alpha.
	Alpha float64 `protobuf:"fixed64,2,opt,name=alpha,proto3" json:"alpha,omitempty"`
}

Describes an exponentially decaying sample.

func (*Params_MetricInfo_Sample_ExpDecay) Descriptor 

func (*Params_MetricInfo_Sample_ExpDecay) Descriptor() ([]byte, []int)

func (*Params_MetricInfo_Sample_ExpDecay) Equal 

func (this *Params_MetricInfo_Sample_ExpDecay) Equal(that interface{}) bool

func (*Params_MetricInfo_Sample_ExpDecay) GetAlpha 

func (m *Params_MetricInfo_Sample_ExpDecay) GetAlpha() float64

func (*Params_MetricInfo_Sample_ExpDecay) GetReservoirSize 

func (m *Params_MetricInfo_Sample_ExpDecay) GetReservoirSize() int32

func (*Params_MetricInfo_Sample_ExpDecay) GoString 

func (this *Params_MetricInfo_Sample_ExpDecay) GoString() string

func (*Params_MetricInfo_Sample_ExpDecay) Marshal 

func (m *Params_MetricInfo_Sample_ExpDecay) Marshal() (dAtA []byte, err error)

func (*Params_MetricInfo_Sample_ExpDecay) MarshalTo 

func (m *Params_MetricInfo_Sample_ExpDecay) MarshalTo(dAtA []byte) (int, error)

func (*Params_MetricInfo_Sample_ExpDecay) ProtoMessage 

func (*Params_MetricInfo_Sample_ExpDecay) ProtoMessage()

func (*Params_MetricInfo_Sample_ExpDecay) Reset 

func (m *Params_MetricInfo_Sample_ExpDecay) Reset()

func (*Params_MetricInfo_Sample_ExpDecay) Size 

func (m *Params_MetricInfo_Sample_ExpDecay) Size() (n int)

func (*Params_MetricInfo_Sample_ExpDecay) String 

func (this *Params_MetricInfo_Sample_ExpDecay) String() string

func (*Params_MetricInfo_Sample_ExpDecay) Unmarshal 

func (m *Params_MetricInfo_Sample_ExpDecay) Unmarshal(dAtA []byte) error

type Params_MetricInfo_Sample_ExpDecay_ 

type Params_MetricInfo_Sample_ExpDecay_ struct {
	ExpDecay *Params_MetricInfo_Sample_ExpDecay `protobuf:"bytes,1,opt,name=exp_decay,json=expDecay,oneof"`
}

func (*Params_MetricInfo_Sample_ExpDecay_) Equal 

func (this *Params_MetricInfo_Sample_ExpDecay_) Equal(that interface{}) bool

func (*Params_MetricInfo_Sample_ExpDecay_) GoString 

func (this *Params_MetricInfo_Sample_ExpDecay_) GoString() string

func (*Params_MetricInfo_Sample_ExpDecay_) MarshalTo 

func (m *Params_MetricInfo_Sample_ExpDecay_) MarshalTo(dAtA []byte) (int, error)

func (*Params_MetricInfo_Sample_ExpDecay_) Size 

func (m *Params_MetricInfo_Sample_ExpDecay_) Size() (n int)

func (*Params_MetricInfo_Sample_ExpDecay_) String 

func (this *Params_MetricInfo_Sample_ExpDecay_) String() string

type Params_MetricInfo_Sample_Uniform 

type Params_MetricInfo_Sample_Uniform struct {
	// The reservoir size.
	ReservoirSize int32 `protobuf:"varint,1,opt,name=reservoir_size,json=reservoirSize,proto3" json:"reservoir_size,omitempty"`
}

Describes a uniform sample.

func (*Params_MetricInfo_Sample_Uniform) Descriptor 

func (*Params_MetricInfo_Sample_Uniform) Descriptor() ([]byte, []int)

func (*Params_MetricInfo_Sample_Uniform) Equal 

func (this *Params_MetricInfo_Sample_Uniform) Equal(that interface{}) bool

func (*Params_MetricInfo_Sample_Uniform) GetReservoirSize 

func (m *Params_MetricInfo_Sample_Uniform) GetReservoirSize() int32

func (*Params_MetricInfo_Sample_Uniform) GoString 

func (this *Params_MetricInfo_Sample_Uniform) GoString() string

func (*Params_MetricInfo_Sample_Uniform) Marshal 

func (m *Params_MetricInfo_Sample_Uniform) Marshal() (dAtA []byte, err error)

func (*Params_MetricInfo_Sample_Uniform) MarshalTo 

func (m *Params_MetricInfo_Sample_Uniform) MarshalTo(dAtA []byte) (int, error)

func (*Params_MetricInfo_Sample_Uniform) ProtoMessage 

func (*Params_MetricInfo_Sample_Uniform) ProtoMessage()

func (*Params_MetricInfo_Sample_Uniform) Reset 

func (m *Params_MetricInfo_Sample_Uniform) Reset()

func (*Params_MetricInfo_Sample_Uniform) Size 

func (m *Params_MetricInfo_Sample_Uniform) Size() (n int)

func (*Params_MetricInfo_Sample_Uniform) String 

func (this *Params_MetricInfo_Sample_Uniform) String() string

func (*Params_MetricInfo_Sample_Uniform) Unmarshal 

func (m *Params_MetricInfo_Sample_Uniform) Unmarshal(dAtA []byte) error

type Params_MetricInfo_Sample_Uniform_ 

type Params_MetricInfo_Sample_Uniform_ struct {
	Uniform *Params_MetricInfo_Sample_Uniform `protobuf:"bytes,2,opt,name=uniform,oneof"`
}

func (*Params_MetricInfo_Sample_Uniform_) Equal 

func (this *Params_MetricInfo_Sample_Uniform_) Equal(that interface{}) bool

func (*Params_MetricInfo_Sample_Uniform_) GoString 

func (this *Params_MetricInfo_Sample_Uniform_) GoString() string

func (*Params_MetricInfo_Sample_Uniform_) MarshalTo 

func (m *Params_MetricInfo_Sample_Uniform_) MarshalTo(dAtA []byte) (int, error)

func (*Params_MetricInfo_Sample_Uniform_) Size 

func (m *Params_MetricInfo_Sample_Uniform_) Size() (n int)

func (*Params_MetricInfo_Sample_Uniform_) String 

func (this *Params_MetricInfo_Sample_Uniform_) String() string

type Params_MetricInfo_Type 

type Params_MetricInfo_Type int32

Describes metric types as in [Wavefront](https://docs.wavefront.com/metric_types.html). 

const (
	// Reserved for unknown metric types.
	UNKNOWN Params_MetricInfo_Type = 0
	// Represents a gauge metric type.
	GAUGE Params_MetricInfo_Type = 1
	// Represents a counter metric type.
	COUNTER Params_MetricInfo_Type = 2
	// Represents a delta counter metric type.
	DELTA_COUNTER Params_MetricInfo_Type = 3
	// Represents a histogram metric type.
	HISTOGRAM Params_MetricInfo_Type = 4
)

func (Params_MetricInfo_Type) EnumDescriptor 

func (Params_MetricInfo_Type) EnumDescriptor() ([]byte, []int)

func (Params_MetricInfo_Type) String 

func (x Params_MetricInfo_Type) String() string

type Params_Proxy 

type Params_Proxy struct {
	Proxy *Params_WavefrontProxy `protobuf:"bytes,2,opt,name=proxy,oneof"`
}

func (*Params_Proxy) Equal 

func (this *Params_Proxy) Equal(that interface{}) bool

func (*Params_Proxy) GoString 

func (this *Params_Proxy) GoString() string

func (*Params_Proxy) MarshalTo 

func (m *Params_Proxy) MarshalTo(dAtA []byte) (int, error)

func (*Params_Proxy) Size 

func (m *Params_Proxy) Size() (n int)

func (*Params_Proxy) String 

func (this *Params_Proxy) String() string

type Params_WavefrontDirect 

type Params_WavefrontDirect struct {
	// The Wavefront server URL. Ex: https://mydomain.wavefront.com
	Server string `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	// The Wavefront API token.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
}

Describes Wavefront Server credentials.

func (*Params_WavefrontDirect) Descriptor 

func (*Params_WavefrontDirect) Descriptor() ([]byte, []int)

func (*Params_WavefrontDirect) Equal 

func (this *Params_WavefrontDirect) Equal(that interface{}) bool

func (*Params_WavefrontDirect) GetServer 

func (m *Params_WavefrontDirect) GetServer() string

func (*Params_WavefrontDirect) GetToken 

func (m *Params_WavefrontDirect) GetToken() string

func (*Params_WavefrontDirect) GoString 

func (this *Params_WavefrontDirect) GoString() string

func (*Params_WavefrontDirect) Marshal 

func (m *Params_WavefrontDirect) Marshal() (dAtA []byte, err error)

func (*Params_WavefrontDirect) MarshalTo 

func (m *Params_WavefrontDirect) MarshalTo(dAtA []byte) (int, error)

func (*Params_WavefrontDirect) ProtoMessage 

func (*Params_WavefrontDirect) ProtoMessage()

func (*Params_WavefrontDirect) Reset 

func (m *Params_WavefrontDirect) Reset()

func (*Params_WavefrontDirect) Size 

func (m *Params_WavefrontDirect) Size() (n int)

func (*Params_WavefrontDirect) String 

func (this *Params_WavefrontDirect) String() string

func (*Params_WavefrontDirect) Unmarshal 

func (m *Params_WavefrontDirect) Unmarshal(dAtA []byte) error

type Params_WavefrontProxy 

type Params_WavefrontProxy struct {
	// The wavefront proxy address. Ex: 192.168.99.100:2878
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

Describes Wavefront Proxy credentials.

func (*Params_WavefrontProxy) Descriptor 

func (*Params_WavefrontProxy) Descriptor() ([]byte, []int)

func (*Params_WavefrontProxy) Equal 

func (this *Params_WavefrontProxy) Equal(that interface{}) bool

func (*Params_WavefrontProxy) GetAddress 

func (m *Params_WavefrontProxy) GetAddress() string

func (*Params_WavefrontProxy) GoString 

func (this *Params_WavefrontProxy) GoString() string

func (*Params_WavefrontProxy) Marshal 

func (m *Params_WavefrontProxy) Marshal() (dAtA []byte, err error)

func (*Params_WavefrontProxy) MarshalTo 

func (m *Params_WavefrontProxy) MarshalTo(dAtA []byte) (int, error)

func (*Params_WavefrontProxy) ProtoMessage 

func (*Params_WavefrontProxy) ProtoMessage()

func (*Params_WavefrontProxy) Reset 

func (m *Params_WavefrontProxy) Reset()

func (*Params_WavefrontProxy) Size 

func (m *Params_WavefrontProxy) Size() (n int)

func (*Params_WavefrontProxy) String 

func (this *Params_WavefrontProxy) String() string

func (*Params_WavefrontProxy) Unmarshal 

func (m *Params_WavefrontProxy) Unmarshal(dAtA []byte) error

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.