opencensus_proto_stats_v1

package
v0.0.0-...-e88dc8b Latest Latest
Warning

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

 Go to latest Published: Jun 14, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package opencensus_proto_stats_v1 is a generated protocol buffer package.

It is generated from these files: 

opencensus/proto/stats/v1/stats.proto

It has these top-level messages: 

Tag
Measure
View
CountAggregation
SumAggregation
LastValueAggregation
DistributionAggregation
Measurement

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthStats = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStats   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Measure_Type_name = map[int32]string{
	0: "TYPE_UNSPECIFIED",
	1: "INT64",
	2: "DOUBLE",
}
View Source 
var Measure_Type_value = map[string]int32{
	"TYPE_UNSPECIFIED": 0,
	"INT64":            1,
	"DOUBLE":           2,
}

Functions

This section is empty.

Types

type CountAggregation 

type CountAggregation struct {
}

func (*CountAggregation) Descriptor 

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

func (*CountAggregation) Marshal 

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

func (*CountAggregation) MarshalTo 

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

func (*CountAggregation) ProtoMessage 

func (*CountAggregation) ProtoMessage()

func (*CountAggregation) Reset 

func (m *CountAggregation) Reset()

func (*CountAggregation) Size 

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

func (*CountAggregation) String 

func (m *CountAggregation) String() string

func (*CountAggregation) Unmarshal 

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

type DistributionAggregation 

type DistributionAggregation struct {
	// A Distribution may optionally contain a histogram of the values in the
	// population. The bucket boundaries for that histogram are described by
	// `bucket_bounds`. This defines `size(bucket_bounds) + 1` (= N)
	// buckets. The boundaries for bucket index i are:
	//
	// (-infinity, bucket_bounds[i]) for i == 0
	// [bucket_bounds[i-1], bucket_bounds[i]) for 0 < i < N-2
	// [bucket_bounds[i-1], +infinity) for i == N-1
	//
	// i.e. an underflow bucket (number 0), zero or more finite buckets (1
	// through N - 2, and an overflow bucket (N - 1), with inclusive lower
	// bounds and exclusive upper bounds.
	//
	// If `bucket_bounds` has no elements (zero size), then there is no
	// histogram associated with the Distribution. If `bucket_bounds` has only
	// one element, there are no finite buckets, and that single element is the
	// common boundary of the overflow and underflow buckets. The values must
	// be monotonically increasing.
	BucketBounds []float64 `protobuf:"fixed64,1,rep,packed,name=bucket_bounds,json=bucketBounds" json:"bucket_bounds,omitempty"`
}

func (*DistributionAggregation) Descriptor 

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

func (*DistributionAggregation) GetBucketBounds 

func (m *DistributionAggregation) GetBucketBounds() []float64

func (*DistributionAggregation) Marshal 

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

func (*DistributionAggregation) MarshalTo 

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

func (*DistributionAggregation) ProtoMessage 

func (*DistributionAggregation) ProtoMessage()

func (*DistributionAggregation) Reset 

func (m *DistributionAggregation) Reset()

func (*DistributionAggregation) Size 

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

func (*DistributionAggregation) String 

func (m *DistributionAggregation) String() string

func (*DistributionAggregation) Unmarshal 

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

type LastValueAggregation 

type LastValueAggregation struct {
}

func (*LastValueAggregation) Descriptor 

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

func (*LastValueAggregation) Marshal 

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

func (*LastValueAggregation) MarshalTo 

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

func (*LastValueAggregation) ProtoMessage 

func (*LastValueAggregation) ProtoMessage()

func (*LastValueAggregation) Reset 

func (m *LastValueAggregation) Reset()

func (*LastValueAggregation) Size 

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

func (*LastValueAggregation) String 

func (m *LastValueAggregation) String() string

func (*LastValueAggregation) Unmarshal 

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

type Measure 

type Measure struct {
	// A string by which the measure will be referred to, e.g. "rpc_server_latency". Names MUST be
	// unique within the library.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Describes the measure, e.g. "RPC latency in seconds".
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Describes the unit used for the Measure. Follows the format described by
	// http://unitsofmeasure.org/ucum.html.
	Unit string `protobuf:"bytes,3,opt,name=unit,proto3" json:"unit,omitempty"`
	// The type used for this Measure.
	Type Measure_Type `protobuf:"varint,4,opt,name=type,proto3,enum=opencensus.proto.stats.v1.Measure_Type" json:"type,omitempty"`
}

Measure .

func (*Measure) Descriptor 

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

func (*Measure) GetDescription 

func (m *Measure) GetDescription() string

func (*Measure) GetName 

func (m *Measure) GetName() string

func (*Measure) GetType 

func (m *Measure) GetType() Measure_Type

func (*Measure) GetUnit 

func (m *Measure) GetUnit() string

func (*Measure) Marshal 

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

func (*Measure) MarshalTo 

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

func (*Measure) ProtoMessage 

func (*Measure) ProtoMessage()

func (*Measure) Reset 

func (m *Measure) Reset()

func (*Measure) Size 

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

func (*Measure) String 

func (m *Measure) String() string

func (*Measure) Unmarshal 

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

type Measure_Type 

type Measure_Type int32
const (
	// Unknown type.
	Measure_TYPE_UNSPECIFIED Measure_Type = 0
	// Indicates an int64 Measure.
	Measure_INT64 Measure_Type = 1
	// Indicates a double Measure.
	Measure_DOUBLE Measure_Type = 2
)

func (Measure_Type) EnumDescriptor 

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

func (Measure_Type) String 

func (x Measure_Type) String() string

type Measurement 

type Measurement struct {
	Tags []*Tag `protobuf:"bytes,1,rep,name=tags" json:"tags,omitempty"`
	// The name of the measure to which the value is applied.
	MeasureName string `protobuf:"bytes,2,opt,name=measure_name,json=measureName,proto3" json:"measure_name,omitempty"`
	// The recorded value, MUST have the appropriate type to match the Measure.
	//
	// Types that are valid to be assigned to Value:
	//	*Measurement_DoubleValue
	//	*Measurement_IntValue
	Value isMeasurement_Value `protobuf_oneof:"value"`
	// The time when this measurement was recorded. If the implementation uses a async buffer to
	// record measurements this may be the time when the measurement was read from the buffer.
	Time *google_protobuf.Timestamp `protobuf:"bytes,5,opt,name=time" json:"time,omitempty"`
}

Describes a data point to be collected for a Measure.

func (*Measurement) Descriptor 

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

func (*Measurement) GetDoubleValue 

func (m *Measurement) GetDoubleValue() float64

func (*Measurement) GetIntValue 

func (m *Measurement) GetIntValue() int64

func (*Measurement) GetMeasureName 

func (m *Measurement) GetMeasureName() string

func (*Measurement) GetTags 

func (m *Measurement) GetTags() []*Tag

func (*Measurement) GetTime 

func (m *Measurement) GetTime() *google_protobuf.Timestamp

func (*Measurement) GetValue 

func (m *Measurement) GetValue() isMeasurement_Value

func (*Measurement) Marshal 

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

func (*Measurement) MarshalTo 

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

func (*Measurement) ProtoMessage 

func (*Measurement) ProtoMessage()

func (*Measurement) Reset 

func (m *Measurement) Reset()

func (*Measurement) Size 

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

func (*Measurement) String 

func (m *Measurement) String() string

func (*Measurement) Unmarshal 

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

func (*Measurement) XXX_OneofFuncs 

func (*Measurement) 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 Measurement_DoubleValue 

type Measurement_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

func (*Measurement_DoubleValue) MarshalTo 

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

func (*Measurement_DoubleValue) Size 

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

type Measurement_IntValue 

type Measurement_IntValue struct {
	IntValue int64 `protobuf:"varint,4,opt,name=int_value,json=intValue,proto3,oneof"`
}

func (*Measurement_IntValue) MarshalTo 

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

func (*Measurement_IntValue) Size 

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

type SumAggregation 

type SumAggregation struct {
}

func (*SumAggregation) Descriptor 

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

func (*SumAggregation) Marshal 

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

func (*SumAggregation) MarshalTo 

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

func (*SumAggregation) ProtoMessage 

func (*SumAggregation) ProtoMessage()

func (*SumAggregation) Reset 

func (m *SumAggregation) Reset()

func (*SumAggregation) Size 

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

func (*SumAggregation) String 

func (m *SumAggregation) String() string

func (*SumAggregation) Unmarshal 

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

type Tag 

type Tag struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

TODO(bdrutu): Consider if this should be moved to a "tags" directory to match the API structure.

func (*Tag) Descriptor 

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

func (*Tag) GetKey 

func (m *Tag) GetKey() string

func (*Tag) GetValue 

func (m *Tag) GetValue() string

func (*Tag) Marshal 

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

func (*Tag) MarshalTo 

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

func (*Tag) ProtoMessage 

func (*Tag) ProtoMessage()

func (*Tag) Reset 

func (m *Tag) Reset()

func (*Tag) Size 

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

func (*Tag) String 

func (m *Tag) String() string

func (*Tag) Unmarshal 

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

type View 

type View struct {
	// A string by which the View will be referred to, e.g. "rpc_latency". Names MUST be unique
	// within the library.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Describes the view, e.g. "RPC latency distribution"
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// The Measure to which this view is applied.
	Measure *Measure `protobuf:"bytes,3,opt,name=measure" json:"measure,omitempty"`
	// An array of tag keys. These values associated with tags of this name form the basis by which
	// individual stats will be aggregated (one aggregation per unique tag value). If none are
	// provided, then all data is recorded in a single aggregation.
	Columns []string `protobuf:"bytes,4,rep,name=columns" json:"columns,omitempty"`
	// The description of the aggregation used for this view which describes how data collected are
	// aggregated.
	//
	// Types that are valid to be assigned to Aggregation:
	//	*View_CountAggregation
	//	*View_SumAggregation
	//	*View_LastValueAggregation
	//	*View_DistributionAggregation
	Aggregation isView_Aggregation `protobuf_oneof:"aggregation"`
}

func (*View) Descriptor 

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

func (*View) GetAggregation 

func (m *View) GetAggregation() isView_Aggregation

func (*View) GetColumns 

func (m *View) GetColumns() []string

func (*View) GetCountAggregation 

func (m *View) GetCountAggregation() *CountAggregation

func (*View) GetDescription 

func (m *View) GetDescription() string

func (*View) GetDistributionAggregation 

func (m *View) GetDistributionAggregation() *DistributionAggregation

func (*View) GetLastValueAggregation 

func (m *View) GetLastValueAggregation() *LastValueAggregation

func (*View) GetMeasure 

func (m *View) GetMeasure() *Measure

func (*View) GetName 

func (m *View) GetName() string

func (*View) GetSumAggregation 

func (m *View) GetSumAggregation() *SumAggregation

func (*View) Marshal 

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

func (*View) MarshalTo 

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

func (*View) ProtoMessage 

func (*View) ProtoMessage()

func (*View) Reset 

func (m *View) Reset()

func (*View) Size 

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

func (*View) String 

func (m *View) String() string

func (*View) Unmarshal 

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

func (*View) XXX_OneofFuncs 

func (*View) 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 View_CountAggregation 

type View_CountAggregation struct {
	CountAggregation *CountAggregation `protobuf:"bytes,5,opt,name=count_aggregation,json=countAggregation,oneof"`
}

func (*View_CountAggregation) MarshalTo 

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

func (*View_CountAggregation) Size 

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

type View_DistributionAggregation 

type View_DistributionAggregation struct {
	DistributionAggregation *DistributionAggregation `protobuf:"bytes,8,opt,name=distribution_aggregation,json=distributionAggregation,oneof"`
}

func (*View_DistributionAggregation) MarshalTo 

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

func (*View_DistributionAggregation) Size 

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

type View_LastValueAggregation 

type View_LastValueAggregation struct {
	LastValueAggregation *LastValueAggregation `protobuf:"bytes,7,opt,name=last_value_aggregation,json=lastValueAggregation,oneof"`
}

func (*View_LastValueAggregation) MarshalTo 

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

func (*View_LastValueAggregation) Size 

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

type View_SumAggregation 

type View_SumAggregation struct {
	SumAggregation *SumAggregation `protobuf:"bytes,6,opt,name=sum_aggregation,json=sumAggregation,oneof"`
}

func (*View_SumAggregation) MarshalTo 

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

func (*View_SumAggregation) Size 

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

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.