aggregation

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Dec 29, 2020 License: Apache-2.0 Imports: 10 Imported by: 37

Documentation

Index

Constants

View Source 
const (
	// IDLen is the length of the ID.
	// The IDLen will be 1 when maxTypeID <= 63.
	IDLen = (maxTypeID)/64 + 1
)

Variables

This section is empty.

Functions

func EmptyTransform 

func EmptyTransform(b []byte) []byte

EmptyTransform transforms the input byte slice to an empty byte slice.

func NoOpTransform 

func NoOpTransform(b []byte) []byte

NoOpTransform returns the input byte slice as is.

func SuffixTransform 

func SuffixTransform(b []byte) []byte

SuffixTransform transforms the input byte slice to a suffix by prepending a dot at the beginning.

Types

type ID 

type ID [IDLen]uint64

ID represents a compressed view of Types. 

var (
	// DefaultID is a default ID.
	DefaultID ID
)

func CompressTypes 

func CompressTypes(aggTypes ...Type) (ID, error)

CompressTypes compresses a list of aggregation types to an ID.

func MustCompressTypes 

func MustCompressTypes(aggTypes ...Type) ID

MustCompressTypes compresses a list of aggregation types to an ID, it panics if an error was encountered.

func NewIDFromProto 

func NewIDFromProto(input []aggregationpb.AggregationType) (ID, error)

NewIDFromProto creates an ID from proto.

func (ID) Contains 

func (id ID) Contains(aggType Type) bool

Contains checks if the given aggregation type is contained in the aggregation id.

func (ID) Equal 

func (id ID) Equal(other ID) bool

Equal checks whether two IDs are considered equal.

func (*ID) FromProto 

func (id *ID) FromProto(pb aggregationpb.AggregationID) error

FromProto converts the protobuf message to an aggregation id in place.

func (ID) IsDefault 

func (id ID) IsDefault() bool

IsDefault checks if the ID is the default aggregation type.

func (ID) MarshalJSON 

func (id ID) MarshalJSON() ([]byte, error)

MarshalJSON returns the JSON encoding of an ID.

func (ID) MarshalYAML added in v0.12.0 

func (id ID) MarshalYAML() (interface{}, error)

func (ID) String 

func (id ID) String() string

String is a string representation of the ID.

func (ID) ToProto 

func (id ID) ToProto(pb *aggregationpb.AggregationID) error

ToProto converts the aggregation id to a protobuf message in place.

func (ID) Types 

func (id ID) Types() (Types, error)

Types returns the aggregation types defined by the id.

func (*ID) UnmarshalJSON 

func (id *ID) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshals JSON-encoded data into an ID.

func (*ID) UnmarshalYAML 

func (id *ID) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML unmarshals YAML-encoded data into an ID.

type IDCompressor 

type IDCompressor interface {
	// Compress compresses a set of aggregation types into an aggregation id.
	Compress(aggTypes Types) (ID, error)

	// MustCompress compresses a set of aggregation types into an aggregation id,
	// and panics if an error is encountered.
	MustCompress(aggTypes Types) ID
}

IDCompressor can compress Types into an ID.

func NewIDCompressor 

func NewIDCompressor() IDCompressor

NewIDCompressor returns a new IDCompressor.

type IDDecompressor 

type IDDecompressor interface {
	// Decompress decompresses an aggregation id into a set of aggregation types.
	Decompress(id ID) (Types, error)

	// MustDecompress decompresses an aggregation id into a set of aggregation types,
	// and panics if an error is encountered.
	MustDecompress(id ID) Types
}

IDDecompressor can decompress ID.

func NewIDDecompressor 

func NewIDDecompressor() IDDecompressor

NewIDDecompressor returns a new IDDecompressor.

func NewPooledIDDecompressor 

func NewPooledIDDecompressor(pool TypesPool) IDDecompressor

NewPooledIDDecompressor returns a new pooled TypeDecompressor.

type QuantileTypeStringFn 

type QuantileTypeStringFn func(quantile float64) []byte

QuantileTypeStringFn returns the type string for a quantile value.

type Type 

type Type int

Type defines an aggregation function. 

const (
	UnknownType Type = iota
	Last
	Min
	Max
	Mean
	Median
	Count
	Sum
	SumSq
	Stdev
	P10
	P20
	P30
	P40
	P50
	P60
	P70
	P80
	P90
	P95
	P99
	P999
	P9999
)

Supported aggregation types.

func NewTypeFromProto 

func NewTypeFromProto(input aggregationpb.AggregationType) (Type, error)

NewTypeFromProto creates an aggregation type from a proto.

func ParseType 

func ParseType(str string) (Type, error)

ParseType parses an aggregation type.

func (Type) Bytes added in v0.15.11 

func (i Type) Bytes() []byte

func (Type) ID 

func (a Type) ID() int

ID returns the id of the Type.

func (Type) IsValid 

func (a Type) IsValid() bool

IsValid checks if an Type is valid.

func (Type) IsValidForCounter 

func (a Type) IsValidForCounter() bool

IsValidForCounter if an Type is valid for Counter.

func (Type) IsValidForGauge 

func (a Type) IsValidForGauge() bool

IsValidForGauge if an Type is valid for Gauge.

func (Type) IsValidForTimer 

func (a Type) IsValidForTimer() bool

IsValidForTimer if an Type is valid for Timer.

func (Type) MarshalText added in v0.12.0 

func (a Type) MarshalText() ([]byte, error)

MarshalText returns the text encoding of an aggregation type.

func (Type) Name added in v1.0.1 

func (a Type) Name() []byte

Name returns the name of the Type.

func (Type) Proto 

func (a Type) Proto() (aggregationpb.AggregationType, error)

Proto returns the proto of the aggregation type.

func (Type) Quantile 

func (a Type) Quantile() (float64, bool)

Quantile returns the quantile represented by the Type.

func (Type) String 

func (i Type) String() string

func (*Type) UnmarshalText added in v0.12.0 

func (a *Type) UnmarshalText(data []byte) error

UnmarshalText unmarshals text-encoded data into an aggregation type.

func (*Type) UnmarshalYAML 

func (a *Type) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML unmarshals text-encoded data into an aggregation type.

type TypeStringTransformFn 

type TypeStringTransformFn func(typeString []byte) []byte

TypeStringTransformFn transforms the type string.

type Types 

type Types []Type

Types is a list of Types. 

var (

	// DefaultTypes is a default list of aggregation types.
	DefaultTypes Types

	// ValidTypes is the list of all the valid aggregation types.
	ValidTypes = map[Type]struct{}{
		Last:   emptyStruct,
		Min:    emptyStruct,
		Max:    emptyStruct,
		Mean:   emptyStruct,
		Median: emptyStruct,
		Count:  emptyStruct,
		Sum:    emptyStruct,
		SumSq:  emptyStruct,
		Stdev:  emptyStruct,
		P10:    emptyStruct,
		P20:    emptyStruct,
		P30:    emptyStruct,
		P40:    emptyStruct,
		P50:    emptyStruct,
		P60:    emptyStruct,
		P70:    emptyStruct,
		P80:    emptyStruct,
		P90:    emptyStruct,
		P95:    emptyStruct,
		P99:    emptyStruct,
		P999:   emptyStruct,
		P9999:  emptyStruct,
	}
)

func NewTypesFromProto 

func NewTypesFromProto(input []aggregationpb.AggregationType) (Types, error)

NewTypesFromProto creates a list of aggregation types from a proto.

func ParseTypes 

func ParseTypes(str string) (Types, error)

ParseTypes parses a list of aggregation types in the form of type1,type2,type3.

func (Types) Contains 

func (aggTypes Types) Contains(aggType Type) bool

Contains checks if the given type is contained in the aggregation types.

func (Types) IsDefault 

func (aggTypes Types) IsDefault() bool

IsDefault checks if the Types is the default aggregation type.

func (Types) IsValidForCounter 

func (aggTypes Types) IsValidForCounter() bool

IsValidForCounter checks if the list of aggregation types is valid for Counter.

func (Types) IsValidForGauge 

func (aggTypes Types) IsValidForGauge() bool

IsValidForGauge checks if the list of aggregation types is valid for Gauge.

func (Types) IsValidForTimer 

func (aggTypes Types) IsValidForTimer() bool

IsValidForTimer checks if the list of aggregation types is valid for Timer.

func (Types) PooledQuantiles 

func (aggTypes Types) PooledQuantiles(p pool.FloatsPool) ([]float64, bool)

PooledQuantiles returns all the quantiles found in the list of aggregation types. Using a floats pool if available.

A boolean will also be returned to indicate whether the returned float slice is from the pool.

func (Types) Proto 

func (aggTypes Types) Proto() ([]aggregationpb.AggregationType, error)

Proto returns the proto of the aggregation types.

func (Types) String 

func (aggTypes Types) String() string

String returns the string representation of the list of aggregation types.

type TypesAlloc 

type TypesAlloc func() Types

TypesAlloc allocates new aggregation types.

type TypesConfiguration 

type TypesConfiguration struct {
	// Default aggregation types for counter metrics.
	DefaultCounterAggregationTypes *Types `yaml:"defaultCounterAggregationTypes"`

	// Default aggregation types for timer metrics.
	DefaultTimerAggregationTypes *Types `yaml:"defaultTimerAggregationTypes"`

	// Default aggregation types for gauge metrics.
	DefaultGaugeAggregationTypes *Types `yaml:"defaultGaugeAggregationTypes"`

	// CounterTransformFnType configures the type string transformation function for counters.
	CounterTransformFnType *transformFnType `yaml:"counterTransformFnType"`

	// TimerTransformFnType configures the type string transformation function for timers.
	TimerTransformFnType *transformFnType `yaml:"timerTransformFnType"`

	// GaugeTransformFnType configures the type string transformation function for gauges.
	GaugeTransformFnType *transformFnType `yaml:"gaugeTransformFnType"`

	// Pool of aggregation types.
	AggregationTypesPool pool.ObjectPoolConfiguration `yaml:"aggregationTypesPool"`

	// Pool of quantile slices.
	QuantilesPool pool.BucketizedPoolConfiguration `yaml:"quantilesPool"`
}

TypesConfiguration contains configuration for aggregation types.

func (TypesConfiguration) NewOptions 

func (c TypesConfiguration) NewOptions(instrumentOpts instrument.Options) (TypesOptions, error)

NewOptions creates a new Option.

type TypesOptions 

type TypesOptions interface {

	// SetDefaultCounterAggregationTypes sets the default aggregation types for counters.
	SetDefaultCounterAggregationTypes(value Types) TypesOptions

	// DefaultCounterAggregationTypes returns the default aggregation types for counters.
	DefaultCounterAggregationTypes() Types

	// SetDefaultTimerAggregationTypes sets the default aggregation types for timers.
	SetDefaultTimerAggregationTypes(value Types) TypesOptions

	// DefaultTimerAggregationTypes returns the default aggregation types for timers.
	DefaultTimerAggregationTypes() Types

	// SetDefaultGaugeAggregationTypes sets the default aggregation types for gauges.
	SetDefaultGaugeAggregationTypes(value Types) TypesOptions

	// DefaultGaugeAggregationTypes returns the default aggregation types for gauges.
	DefaultGaugeAggregationTypes() Types

	// SetQuantileTypeStringFn sets the quantile type string function for timers.
	SetQuantileTypeStringFn(value QuantileTypeStringFn) TypesOptions

	// QuantileTypeStringFn returns the quantile type string function for timers.
	QuantileTypeStringFn() QuantileTypeStringFn

	// SetCounterTypeStringTransformFn sets the transformation function for counter type strings.
	SetCounterTypeStringTransformFn(value TypeStringTransformFn) TypesOptions

	// CounterTypeStringTransformFn returns the transformation function for counter type strings.
	CounterTypeStringTransformFn() TypeStringTransformFn

	// SetTimerTypeStringTransformFn sets the transformation function for timer type strings.
	SetTimerTypeStringTransformFn(value TypeStringTransformFn) TypesOptions

	// TimerTypeStringTransformFn returns the transformation function for timer type strings.
	TimerTypeStringTransformFn() TypeStringTransformFn

	// SetGaugeTypeStringTransformFn sets the transformation function for gauge type strings.
	SetGaugeTypeStringTransformFn(value TypeStringTransformFn) TypesOptions

	// GaugeTypeStringTransformFn returns the transformation function for gauge type strings.
	GaugeTypeStringTransformFn() TypeStringTransformFn

	// SetTypesPool sets the aggregation types pool.
	SetTypesPool(pool TypesPool) TypesOptions

	// TypesPool returns the aggregation types pool.
	TypesPool() TypesPool

	// SetQuantilesPool sets the timer quantiles pool.
	SetQuantilesPool(pool pool.FloatsPool) TypesOptions

	// QuantilesPool returns the timer quantiles pool.
	QuantilesPool() pool.FloatsPool

	// TypeStringForCounter returns the type string for the aggregation type for counters.
	TypeStringForCounter(value Type) []byte

	// TypeStringForTimer returns the type string for the aggregation type for timers.
	TypeStringForTimer(value Type) []byte

	// TypeStringForGauge returns the type string for the aggregation type for gauges.
	TypeStringForGauge(value Type) []byte

	// TypeForCounter returns the aggregation type for given counter type string.
	TypeForCounter(value []byte) Type

	// TypeForTimer returns the aggregation type for given timer type string.
	TypeForTimer(value []byte) Type

	// TypeForGauge returns the aggregation type for given gauge type string.
	TypeForGauge(value []byte) Type

	// Quantiles returns the quantiles for timers.
	Quantiles() []float64

	// IsContainedInDefaultAggregationTypes checks if the given aggregation type is
	// contained in the default aggregation types for the metric type.
	IsContainedInDefaultAggregationTypes(at Type, mt metric.Type) bool
}

TypesOptions provides a set of options for aggregation types.

func NewTypesOptions 

func NewTypesOptions() TypesOptions

NewTypesOptions returns a default TypesOptions.

type TypesPool 

type TypesPool interface {
	// Init initializes the aggregation types pool.
	Init(alloc TypesAlloc)

	// Get gets an empty list of aggregation types from the pool.
	Get() Types

	// Put returns aggregation types to the pool.
	Put(value Types)
}

TypesPool provides a pool of aggregation types.

func NewTypesPool 

func NewTypesPool(opts pool.ObjectPoolOptions) TypesPool

NewTypesPool creates a new pool for aggregation types.

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.