v1

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2018 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CountAggregation) Descriptor 

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

func (*CountAggregation) ProtoMessage 

func (*CountAggregation) ProtoMessage()

func (*CountAggregation) Reset 

func (m *CountAggregation) Reset()

func (*CountAggregation) String 

func (m *CountAggregation) String() string

func (*CountAggregation) XXX_DiscardUnknown 

func (m *CountAggregation) XXX_DiscardUnknown()

func (*CountAggregation) XXX_Marshal 

func (m *CountAggregation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CountAggregation) XXX_Merge 

func (m *CountAggregation) XXX_Merge(src proto.Message)

func (*CountAggregation) XXX_Size 

func (m *CountAggregation) XXX_Size() int

func (*CountAggregation) XXX_Unmarshal 

func (m *CountAggregation) XXX_Unmarshal(b []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,proto3" json:"bucket_bounds,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DistributionAggregation) Descriptor 

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

func (*DistributionAggregation) GetBucketBounds 

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

func (*DistributionAggregation) ProtoMessage 

func (*DistributionAggregation) ProtoMessage()

func (*DistributionAggregation) Reset 

func (m *DistributionAggregation) Reset()

func (*DistributionAggregation) String 

func (m *DistributionAggregation) String() string

func (*DistributionAggregation) XXX_DiscardUnknown 

func (m *DistributionAggregation) XXX_DiscardUnknown()

func (*DistributionAggregation) XXX_Marshal 

func (m *DistributionAggregation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DistributionAggregation) XXX_Merge 

func (m *DistributionAggregation) XXX_Merge(src proto.Message)

func (*DistributionAggregation) XXX_Size 

func (m *DistributionAggregation) XXX_Size() int

func (*DistributionAggregation) XXX_Unmarshal 

func (m *DistributionAggregation) XXX_Unmarshal(b []byte) error

type LastValueAggregation 

type LastValueAggregation struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LastValueAggregation) Descriptor 

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

func (*LastValueAggregation) ProtoMessage 

func (*LastValueAggregation) ProtoMessage()

func (*LastValueAggregation) Reset 

func (m *LastValueAggregation) Reset()

func (*LastValueAggregation) String 

func (m *LastValueAggregation) String() string

func (*LastValueAggregation) XXX_DiscardUnknown 

func (m *LastValueAggregation) XXX_DiscardUnknown()

func (*LastValueAggregation) XXX_Marshal 

func (m *LastValueAggregation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LastValueAggregation) XXX_Merge 

func (m *LastValueAggregation) XXX_Merge(src proto.Message)

func (*LastValueAggregation) XXX_Size 

func (m *LastValueAggregation) XXX_Size() int

func (*LastValueAggregation) XXX_Unmarshal 

func (m *LastValueAggregation) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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) ProtoMessage 

func (*Measure) ProtoMessage()

func (*Measure) Reset 

func (m *Measure) Reset()

func (*Measure) String 

func (m *Measure) String() string

func (*Measure) XXX_DiscardUnknown 

func (m *Measure) XXX_DiscardUnknown()

func (*Measure) XXX_Marshal 

func (m *Measure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Measure) XXX_Merge 

func (m *Measure) XXX_Merge(src proto.Message)

func (*Measure) XXX_Size 

func (m *Measure) XXX_Size() int

func (*Measure) XXX_Unmarshal 

func (m *Measure) XXX_Unmarshal(b []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,proto3" 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                 *timestamp.Timestamp `protobuf:"bytes,5,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

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() *timestamp.Timestamp

func (*Measurement) GetValue 

func (m *Measurement) GetValue() isMeasurement_Value

func (*Measurement) ProtoMessage 

func (*Measurement) ProtoMessage()

func (*Measurement) Reset 

func (m *Measurement) Reset()

func (*Measurement) String 

func (m *Measurement) String() string

func (*Measurement) XXX_DiscardUnknown 

func (m *Measurement) XXX_DiscardUnknown()

func (*Measurement) XXX_Marshal 

func (m *Measurement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Measurement) XXX_Merge 

func (m *Measurement) XXX_Merge(src proto.Message)

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.

func (*Measurement) XXX_Size 

func (m *Measurement) XXX_Size() int

func (*Measurement) XXX_Unmarshal 

func (m *Measurement) XXX_Unmarshal(b []byte) error

type Measurement_DoubleValue 

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

type Measurement_IntValue 

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

type SumAggregation 

type SumAggregation struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SumAggregation) Descriptor 

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

func (*SumAggregation) ProtoMessage 

func (*SumAggregation) ProtoMessage()

func (*SumAggregation) Reset 

func (m *SumAggregation) Reset()

func (*SumAggregation) String 

func (m *SumAggregation) String() string

func (*SumAggregation) XXX_DiscardUnknown 

func (m *SumAggregation) XXX_DiscardUnknown()

func (*SumAggregation) XXX_Marshal 

func (m *SumAggregation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SumAggregation) XXX_Merge 

func (m *SumAggregation) XXX_Merge(src proto.Message)

func (*SumAggregation) XXX_Size 

func (m *SumAggregation) XXX_Size() int

func (*SumAggregation) XXX_Unmarshal 

func (m *SumAggregation) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) ProtoMessage 

func (*Tag) ProtoMessage()

func (*Tag) Reset 

func (m *Tag) Reset()

func (*Tag) String 

func (m *Tag) String() string

func (*Tag) XXX_DiscardUnknown 

func (m *Tag) XXX_DiscardUnknown()

func (*Tag) XXX_Marshal 

func (m *Tag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Tag) XXX_Merge 

func (m *Tag) XXX_Merge(src proto.Message)

func (*Tag) XXX_Size 

func (m *Tag) XXX_Size() int

func (*Tag) XXX_Unmarshal 

func (m *Tag) XXX_Unmarshal(b []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,proto3" 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,proto3" 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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

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) ProtoMessage 

func (*View) ProtoMessage()

func (*View) Reset 

func (m *View) Reset()

func (*View) String 

func (m *View) String() string

func (*View) XXX_DiscardUnknown 

func (m *View) XXX_DiscardUnknown()

func (*View) XXX_Marshal 

func (m *View) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*View) XXX_Merge 

func (m *View) XXX_Merge(src proto.Message)

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.

func (*View) XXX_Size 

func (m *View) XXX_Size() int

func (*View) XXX_Unmarshal 

func (m *View) XXX_Unmarshal(b []byte) error

type View_CountAggregation 

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

type View_DistributionAggregation 

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

type View_LastValueAggregation 

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

type View_SumAggregation 

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

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.