metricpb

package
v1.0.0-rc.1 Latest Latest
Warning

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

 Go to latest Published: Nov 10, 2020 License: Apache-2.0 Imports: 9 Imported by: 10

Documentation

Overview

Package metricpb is a generated protocol buffer package.

It is generated from these files: 

github.com/m3db/m3/src/metrics/generated/proto/metricpb/composite.proto
github.com/m3db/m3/src/metrics/generated/proto/metricpb/metadata.proto
github.com/m3db/m3/src/metrics/generated/proto/metricpb/metric.proto

It has these top-level messages: 

CounterWithMetadatas
BatchTimerWithMetadatas
GaugeWithMetadatas
ForwardedMetricWithMetadata
TimedMetricWithMetadata
TimedMetricWithMetadatas
TimedMetricWithStoragePolicy
AggregatedMetric
MetricWithMetadatas
PipelineMetadata
Metadata
StagedMetadata
StagedMetadatas
ForwardMetadata
TimedMetadata
Counter
BatchTimer
Gauge
TimedMetric
ForwardedMetric
Tag

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthComposite = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowComposite   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthMetadata = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetadata   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthMetric = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetric   = fmt.Errorf("proto: integer overflow")
)
View Source 
var MetricType_name = map[int32]string{
	0: "UNKNOWN",
	1: "COUNTER",
	2: "TIMER",
	3: "GAUGE",
}
View Source 
var MetricType_value = map[string]int32{
	"UNKNOWN": 0,
	"COUNTER": 1,
	"TIMER":   2,
	"GAUGE":   3,
}
View Source 
var MetricWithMetadatas_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "COUNTER_WITH_METADATAS",
	2: "BATCH_TIMER_WITH_METADATAS",
	3: "GAUGE_WITH_METADATAS",
	4: "FORWARDED_METRIC_WITH_METADATA",
	5: "TIMED_METRIC_WITH_METADATA",
	6: "TIMED_METRIC_WITH_METADATAS",
	7: "TIMED_METRIC_WITH_STORAGE_POLICY",
}
View Source 
var MetricWithMetadatas_Type_value = map[string]int32{
	"UNKNOWN":                          0,
	"COUNTER_WITH_METADATAS":           1,
	"BATCH_TIMER_WITH_METADATAS":       2,
	"GAUGE_WITH_METADATAS":             3,
	"FORWARDED_METRIC_WITH_METADATA":   4,
	"TIMED_METRIC_WITH_METADATA":       5,
	"TIMED_METRIC_WITH_METADATAS":      6,
	"TIMED_METRIC_WITH_STORAGE_POLICY": 7,
}

Functions

This section is empty.

Types

type AggregatedMetric added in v0.5.0 

type AggregatedMetric struct {
	Metric      TimedMetricWithStoragePolicy `protobuf:"bytes,1,opt,name=metric" json:"metric"`
	EncodeNanos int64                        `protobuf:"varint,2,opt,name=encode_nanos,json=encodeNanos,proto3" json:"encode_nanos,omitempty"`
}

func (*AggregatedMetric) Descriptor added in v0.5.0 

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

func (*AggregatedMetric) GetEncodeNanos added in v0.5.0 

func (m *AggregatedMetric) GetEncodeNanos() int64

func (*AggregatedMetric) GetMetric added in v0.5.0 

func (m *AggregatedMetric) GetMetric() TimedMetricWithStoragePolicy

func (*AggregatedMetric) Marshal added in v0.5.0 

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

func (*AggregatedMetric) MarshalTo added in v0.5.0 

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

func (*AggregatedMetric) ProtoMessage added in v0.5.0 

func (*AggregatedMetric) ProtoMessage()

func (*AggregatedMetric) Reset added in v0.5.0 

func (m *AggregatedMetric) Reset()

func (*AggregatedMetric) Size added in v0.5.0 

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

func (*AggregatedMetric) String added in v0.5.0 

func (m *AggregatedMetric) String() string

func (*AggregatedMetric) Unmarshal added in v0.5.0 

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

type BatchTimer 

type BatchTimer struct {
	Id     []byte    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Values []float64 `protobuf:"fixed64,2,rep,packed,name=values" json:"values,omitempty"`
}

func (*BatchTimer) Descriptor 

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

func (*BatchTimer) GetId 

func (m *BatchTimer) GetId() []byte

func (*BatchTimer) GetValues 

func (m *BatchTimer) GetValues() []float64

func (*BatchTimer) Marshal 

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

func (*BatchTimer) MarshalTo 

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

func (*BatchTimer) ProtoMessage 

func (*BatchTimer) ProtoMessage()

func (*BatchTimer) Reset 

func (m *BatchTimer) Reset()

func (*BatchTimer) Size 

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

func (*BatchTimer) String 

func (m *BatchTimer) String() string

func (*BatchTimer) Unmarshal 

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

type BatchTimerWithMetadatas 

type BatchTimerWithMetadatas struct {
	BatchTimer BatchTimer      `protobuf:"bytes,1,opt,name=batch_timer,json=batchTimer" json:"batch_timer"`
	Metadatas  StagedMetadatas `protobuf:"bytes,2,opt,name=metadatas" json:"metadatas"`
}

func (*BatchTimerWithMetadatas) Descriptor 

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

func (*BatchTimerWithMetadatas) GetBatchTimer 

func (m *BatchTimerWithMetadatas) GetBatchTimer() BatchTimer

func (*BatchTimerWithMetadatas) GetMetadatas 

func (m *BatchTimerWithMetadatas) GetMetadatas() StagedMetadatas

func (*BatchTimerWithMetadatas) Marshal 

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

func (*BatchTimerWithMetadatas) MarshalTo 

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

func (*BatchTimerWithMetadatas) ProtoMessage 

func (*BatchTimerWithMetadatas) ProtoMessage()

func (*BatchTimerWithMetadatas) Reset 

func (m *BatchTimerWithMetadatas) Reset()

func (*BatchTimerWithMetadatas) Size 

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

func (*BatchTimerWithMetadatas) String 

func (m *BatchTimerWithMetadatas) String() string

func (*BatchTimerWithMetadatas) Unmarshal 

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

type Counter 

type Counter struct {
	Id    []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Value int64  `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Counter) Descriptor 

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

func (*Counter) GetId 

func (m *Counter) GetId() []byte

func (*Counter) GetValue 

func (m *Counter) GetValue() int64

func (*Counter) Marshal 

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

func (*Counter) MarshalTo 

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

func (*Counter) ProtoMessage 

func (*Counter) ProtoMessage()

func (*Counter) Reset 

func (m *Counter) Reset()

func (*Counter) Size 

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

func (*Counter) String 

func (m *Counter) String() string

func (*Counter) Unmarshal 

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

type CounterWithMetadatas 

type CounterWithMetadatas struct {
	Counter   Counter         `protobuf:"bytes,1,opt,name=counter" json:"counter"`
	Metadatas StagedMetadatas `protobuf:"bytes,2,opt,name=metadatas" json:"metadatas"`
}

func (*CounterWithMetadatas) Descriptor 

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

func (*CounterWithMetadatas) GetCounter 

func (m *CounterWithMetadatas) GetCounter() Counter

func (*CounterWithMetadatas) GetMetadatas 

func (m *CounterWithMetadatas) GetMetadatas() StagedMetadatas

func (*CounterWithMetadatas) Marshal 

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

func (*CounterWithMetadatas) MarshalTo 

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

func (*CounterWithMetadatas) ProtoMessage 

func (*CounterWithMetadatas) ProtoMessage()

func (*CounterWithMetadatas) Reset 

func (m *CounterWithMetadatas) Reset()

func (*CounterWithMetadatas) Size 

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

func (*CounterWithMetadatas) String 

func (m *CounterWithMetadatas) String() string

func (*CounterWithMetadatas) Unmarshal 

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

type ForwardMetadata 

type ForwardMetadata struct {
	AggregationId     aggregationpb.AggregationID `protobuf:"bytes,1,opt,name=aggregation_id,json=aggregationId" json:"aggregation_id"`
	StoragePolicy     policypb.StoragePolicy      `protobuf:"bytes,2,opt,name=storage_policy,json=storagePolicy" json:"storage_policy"`
	Pipeline          pipelinepb.AppliedPipeline  `protobuf:"bytes,3,opt,name=pipeline" json:"pipeline"`
	SourceId          uint32                      `protobuf:"varint,4,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	NumForwardedTimes int32                       `protobuf:"varint,5,opt,name=num_forwarded_times,json=numForwardedTimes,proto3" json:"num_forwarded_times,omitempty"`
}

func (*ForwardMetadata) Descriptor 

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

func (*ForwardMetadata) GetAggregationId 

func (m *ForwardMetadata) GetAggregationId() aggregationpb.AggregationID

func (*ForwardMetadata) GetNumForwardedTimes 

func (m *ForwardMetadata) GetNumForwardedTimes() int32

func (*ForwardMetadata) GetPipeline 

func (m *ForwardMetadata) GetPipeline() pipelinepb.AppliedPipeline

func (*ForwardMetadata) GetSourceId 

func (m *ForwardMetadata) GetSourceId() uint32

func (*ForwardMetadata) GetStoragePolicy 

func (m *ForwardMetadata) GetStoragePolicy() policypb.StoragePolicy

func (*ForwardMetadata) Marshal 

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

func (*ForwardMetadata) MarshalTo 

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

func (*ForwardMetadata) ProtoMessage 

func (*ForwardMetadata) ProtoMessage()

func (*ForwardMetadata) Reset 

func (m *ForwardMetadata) Reset()

func (*ForwardMetadata) Size 

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

func (*ForwardMetadata) String 

func (m *ForwardMetadata) String() string

func (*ForwardMetadata) Unmarshal 

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

type ForwardedMetric 

type ForwardedMetric struct {
	Type      MetricType `protobuf:"varint,1,opt,name=type,proto3,enum=metricpb.MetricType" json:"type,omitempty"`
	Id        []byte     `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	TimeNanos int64      `protobuf:"varint,3,opt,name=time_nanos,json=timeNanos,proto3" json:"time_nanos,omitempty"`
	Values    []float64  `protobuf:"fixed64,4,rep,packed,name=values" json:"values,omitempty"`
}

func (*ForwardedMetric) Descriptor 

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

func (*ForwardedMetric) GetId 

func (m *ForwardedMetric) GetId() []byte

func (*ForwardedMetric) GetTimeNanos 

func (m *ForwardedMetric) GetTimeNanos() int64

func (*ForwardedMetric) GetType 

func (m *ForwardedMetric) GetType() MetricType

func (*ForwardedMetric) GetValues 

func (m *ForwardedMetric) GetValues() []float64

func (*ForwardedMetric) Marshal 

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

func (*ForwardedMetric) MarshalTo 

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

func (*ForwardedMetric) ProtoMessage 

func (*ForwardedMetric) ProtoMessage()

func (*ForwardedMetric) Reset 

func (m *ForwardedMetric) Reset()

func (*ForwardedMetric) Size 

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

func (*ForwardedMetric) String 

func (m *ForwardedMetric) String() string

func (*ForwardedMetric) Unmarshal 

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

type ForwardedMetricWithMetadata 

type ForwardedMetricWithMetadata struct {
	Metric   ForwardedMetric `protobuf:"bytes,1,opt,name=metric" json:"metric"`
	Metadata ForwardMetadata `protobuf:"bytes,2,opt,name=metadata" json:"metadata"`
}

func (*ForwardedMetricWithMetadata) Descriptor 

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

func (*ForwardedMetricWithMetadata) GetMetadata 

func (m *ForwardedMetricWithMetadata) GetMetadata() ForwardMetadata

func (*ForwardedMetricWithMetadata) GetMetric 

func (m *ForwardedMetricWithMetadata) GetMetric() ForwardedMetric

func (*ForwardedMetricWithMetadata) Marshal 

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

func (*ForwardedMetricWithMetadata) MarshalTo 

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

func (*ForwardedMetricWithMetadata) ProtoMessage 

func (*ForwardedMetricWithMetadata) ProtoMessage()

func (*ForwardedMetricWithMetadata) Reset 

func (m *ForwardedMetricWithMetadata) Reset()

func (*ForwardedMetricWithMetadata) Size 

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

func (*ForwardedMetricWithMetadata) String 

func (m *ForwardedMetricWithMetadata) String() string

func (*ForwardedMetricWithMetadata) Unmarshal 

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

type Gauge 

type Gauge struct {
	Id    []byte  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Gauge) Descriptor 

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

func (*Gauge) GetId 

func (m *Gauge) GetId() []byte

func (*Gauge) GetValue 

func (m *Gauge) GetValue() float64

func (*Gauge) Marshal 

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

func (*Gauge) MarshalTo 

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

func (*Gauge) ProtoMessage 

func (*Gauge) ProtoMessage()

func (*Gauge) Reset 

func (m *Gauge) Reset()

func (*Gauge) Size 

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

func (*Gauge) String 

func (m *Gauge) String() string

func (*Gauge) Unmarshal 

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

type GaugeWithMetadatas 

type GaugeWithMetadatas struct {
	Gauge     Gauge           `protobuf:"bytes,1,opt,name=gauge" json:"gauge"`
	Metadatas StagedMetadatas `protobuf:"bytes,2,opt,name=metadatas" json:"metadatas"`
}

func (*GaugeWithMetadatas) Descriptor 

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

func (*GaugeWithMetadatas) GetGauge 

func (m *GaugeWithMetadatas) GetGauge() Gauge

func (*GaugeWithMetadatas) GetMetadatas 

func (m *GaugeWithMetadatas) GetMetadatas() StagedMetadatas

func (*GaugeWithMetadatas) Marshal 

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

func (*GaugeWithMetadatas) MarshalTo 

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

func (*GaugeWithMetadatas) ProtoMessage 

func (*GaugeWithMetadatas) ProtoMessage()

func (*GaugeWithMetadatas) Reset 

func (m *GaugeWithMetadatas) Reset()

func (*GaugeWithMetadatas) Size 

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

func (*GaugeWithMetadatas) String 

func (m *GaugeWithMetadatas) String() string

func (*GaugeWithMetadatas) Unmarshal 

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

type Metadata 

type Metadata struct {
	Pipelines []PipelineMetadata `protobuf:"bytes,1,rep,name=pipelines" json:"pipelines"`
}

func (*Metadata) Descriptor 

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

func (*Metadata) GetPipelines 

func (m *Metadata) GetPipelines() []PipelineMetadata

func (*Metadata) Marshal 

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

func (*Metadata) MarshalTo 

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

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) Size 

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

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) Unmarshal 

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

type MetricType 

type MetricType int32
const (
	MetricType_UNKNOWN MetricType = 0
	MetricType_COUNTER MetricType = 1
	MetricType_TIMER   MetricType = 2
	MetricType_GAUGE   MetricType = 3
)

func (MetricType) EnumDescriptor 

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

func (MetricType) String 

func (x MetricType) String() string

type MetricWithMetadatas 

type MetricWithMetadatas struct {
	Type                         MetricWithMetadatas_Type      `protobuf:"varint,1,opt,name=type,proto3,enum=metricpb.MetricWithMetadatas_Type" json:"type,omitempty"`
	CounterWithMetadatas         *CounterWithMetadatas         `protobuf:"bytes,2,opt,name=counter_with_metadatas,json=counterWithMetadatas" json:"counter_with_metadatas,omitempty"`
	BatchTimerWithMetadatas      *BatchTimerWithMetadatas      `` /* 127-byte string literal not displayed */
	GaugeWithMetadatas           *GaugeWithMetadatas           `protobuf:"bytes,4,opt,name=gauge_with_metadatas,json=gaugeWithMetadatas" json:"gauge_with_metadatas,omitempty"`
	ForwardedMetricWithMetadata  *ForwardedMetricWithMetadata  `` /* 139-byte string literal not displayed */
	TimedMetricWithMetadata      *TimedMetricWithMetadata      `` /* 127-byte string literal not displayed */
	TimedMetricWithMetadatas     *TimedMetricWithMetadatas     `` /* 130-byte string literal not displayed */
	TimedMetricWithStoragePolicy *TimedMetricWithStoragePolicy `` /* 144-byte string literal not displayed */
}

NB: we intentionally choose to explicitly define the message type as well as the corresponding payload as opposed to use `oneof` protobuf type here. This is because the generated `Unmarshal` method of `oneof` types doesn't permit reusing existing protobuf messages for decoding, thus incurring a significant performance hit when such message type is used for encoding and decoding high volume traffic.

func (*MetricWithMetadatas) Descriptor 

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

func (*MetricWithMetadatas) GetBatchTimerWithMetadatas 

func (m *MetricWithMetadatas) GetBatchTimerWithMetadatas() *BatchTimerWithMetadatas

func (*MetricWithMetadatas) GetCounterWithMetadatas 

func (m *MetricWithMetadatas) GetCounterWithMetadatas() *CounterWithMetadatas

func (*MetricWithMetadatas) GetForwardedMetricWithMetadata 

func (m *MetricWithMetadatas) GetForwardedMetricWithMetadata() *ForwardedMetricWithMetadata

func (*MetricWithMetadatas) GetGaugeWithMetadatas 

func (m *MetricWithMetadatas) GetGaugeWithMetadatas() *GaugeWithMetadatas

func (*MetricWithMetadatas) GetTimedMetricWithMetadata 

func (m *MetricWithMetadatas) GetTimedMetricWithMetadata() *TimedMetricWithMetadata

func (*MetricWithMetadatas) GetTimedMetricWithMetadatas added in v0.15.0 

func (m *MetricWithMetadatas) GetTimedMetricWithMetadatas() *TimedMetricWithMetadatas

func (*MetricWithMetadatas) GetTimedMetricWithStoragePolicy added in v0.15.0 

func (m *MetricWithMetadatas) GetTimedMetricWithStoragePolicy() *TimedMetricWithStoragePolicy

func (*MetricWithMetadatas) GetType 

func (m *MetricWithMetadatas) GetType() MetricWithMetadatas_Type

func (*MetricWithMetadatas) Marshal 

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

func (*MetricWithMetadatas) MarshalTo 

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

func (*MetricWithMetadatas) ProtoMessage 

func (*MetricWithMetadatas) ProtoMessage()

func (*MetricWithMetadatas) Reset 

func (m *MetricWithMetadatas) Reset()

func (*MetricWithMetadatas) Size 

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

func (*MetricWithMetadatas) String 

func (m *MetricWithMetadatas) String() string

func (*MetricWithMetadatas) Unmarshal 

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

type MetricWithMetadatas_Type 

type MetricWithMetadatas_Type int32
const (
	MetricWithMetadatas_UNKNOWN                          MetricWithMetadatas_Type = 0
	MetricWithMetadatas_COUNTER_WITH_METADATAS           MetricWithMetadatas_Type = 1
	MetricWithMetadatas_BATCH_TIMER_WITH_METADATAS       MetricWithMetadatas_Type = 2
	MetricWithMetadatas_GAUGE_WITH_METADATAS             MetricWithMetadatas_Type = 3
	MetricWithMetadatas_FORWARDED_METRIC_WITH_METADATA   MetricWithMetadatas_Type = 4
	MetricWithMetadatas_TIMED_METRIC_WITH_METADATA       MetricWithMetadatas_Type = 5
	MetricWithMetadatas_TIMED_METRIC_WITH_METADATAS      MetricWithMetadatas_Type = 6
	MetricWithMetadatas_TIMED_METRIC_WITH_STORAGE_POLICY MetricWithMetadatas_Type = 7
)

func (MetricWithMetadatas_Type) EnumDescriptor 

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

func (MetricWithMetadatas_Type) String 

func (x MetricWithMetadatas_Type) String() string

type PipelineMetadata 

type PipelineMetadata struct {
	AggregationId   aggregationpb.AggregationID `protobuf:"bytes,1,opt,name=aggregation_id,json=aggregationId" json:"aggregation_id"`
	StoragePolicies []policypb.StoragePolicy    `protobuf:"bytes,2,rep,name=storage_policies,json=storagePolicies" json:"storage_policies"`
	Pipeline        pipelinepb.AppliedPipeline  `protobuf:"bytes,3,opt,name=pipeline" json:"pipeline"`
	DropPolicy      policypb.DropPolicy         `protobuf:"varint,4,opt,name=drop_policy,json=dropPolicy,proto3,enum=policypb.DropPolicy" json:"drop_policy,omitempty"`
}

func (*PipelineMetadata) Descriptor 

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

func (*PipelineMetadata) GetAggregationId 

func (m *PipelineMetadata) GetAggregationId() aggregationpb.AggregationID

func (*PipelineMetadata) GetDropPolicy 

func (m *PipelineMetadata) GetDropPolicy() policypb.DropPolicy

func (*PipelineMetadata) GetPipeline 

func (m *PipelineMetadata) GetPipeline() pipelinepb.AppliedPipeline

func (*PipelineMetadata) GetStoragePolicies 

func (m *PipelineMetadata) GetStoragePolicies() []policypb.StoragePolicy

func (*PipelineMetadata) Marshal 

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

func (*PipelineMetadata) MarshalTo 

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

func (*PipelineMetadata) ProtoMessage 

func (*PipelineMetadata) ProtoMessage()

func (*PipelineMetadata) Reset 

func (m *PipelineMetadata) Reset()

func (*PipelineMetadata) Size 

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

func (*PipelineMetadata) String 

func (m *PipelineMetadata) String() string

func (*PipelineMetadata) Unmarshal 

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

type StagedMetadata 

type StagedMetadata struct {
	CutoverNanos int64    `protobuf:"varint,1,opt,name=cutover_nanos,json=cutoverNanos,proto3" json:"cutover_nanos,omitempty"`
	Tombstoned   bool     `protobuf:"varint,2,opt,name=tombstoned,proto3" json:"tombstoned,omitempty"`
	Metadata     Metadata `protobuf:"bytes,3,opt,name=metadata" json:"metadata"`
}

func (*StagedMetadata) Descriptor 

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

func (*StagedMetadata) GetCutoverNanos 

func (m *StagedMetadata) GetCutoverNanos() int64

func (*StagedMetadata) GetMetadata 

func (m *StagedMetadata) GetMetadata() Metadata

func (*StagedMetadata) GetTombstoned 

func (m *StagedMetadata) GetTombstoned() bool

func (*StagedMetadata) Marshal 

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

func (*StagedMetadata) MarshalTo 

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

func (*StagedMetadata) ProtoMessage 

func (*StagedMetadata) ProtoMessage()

func (*StagedMetadata) Reset 

func (m *StagedMetadata) Reset()

func (*StagedMetadata) Size 

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

func (*StagedMetadata) String 

func (m *StagedMetadata) String() string

func (*StagedMetadata) Unmarshal 

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

type StagedMetadatas 

type StagedMetadatas struct {
	Metadatas []StagedMetadata `protobuf:"bytes,1,rep,name=metadatas" json:"metadatas"`
}

func (*StagedMetadatas) Descriptor 

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

func (*StagedMetadatas) GetMetadatas 

func (m *StagedMetadatas) GetMetadatas() []StagedMetadata

func (*StagedMetadatas) Marshal 

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

func (*StagedMetadatas) MarshalTo 

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

func (*StagedMetadatas) ProtoMessage 

func (*StagedMetadatas) ProtoMessage()

func (*StagedMetadatas) Reset 

func (m *StagedMetadatas) Reset()

func (*StagedMetadatas) Size 

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

func (*StagedMetadatas) String 

func (m *StagedMetadatas) String() string

func (*StagedMetadatas) Unmarshal 

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

type Tag added in v0.15.11 

type Tag struct {
	Name  []byte `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Tag) Descriptor added in v0.15.11 

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

func (*Tag) GetName added in v0.15.11 

func (m *Tag) GetName() []byte

func (*Tag) GetValue added in v0.15.11 

func (m *Tag) GetValue() []byte

func (*Tag) Marshal added in v0.15.11 

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

func (*Tag) MarshalTo added in v0.15.11 

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

func (*Tag) ProtoMessage added in v0.15.11 

func (*Tag) ProtoMessage()

func (*Tag) Reset added in v0.15.11 

func (m *Tag) Reset()

func (*Tag) Size added in v0.15.11 

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

func (*Tag) String added in v0.15.11 

func (m *Tag) String() string

func (*Tag) Unmarshal added in v0.15.11 

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

type TimedMetadata 

type TimedMetadata struct {
	AggregationId aggregationpb.AggregationID `protobuf:"bytes,1,opt,name=aggregation_id,json=aggregationId" json:"aggregation_id"`
	StoragePolicy policypb.StoragePolicy      `protobuf:"bytes,2,opt,name=storage_policy,json=storagePolicy" json:"storage_policy"`
}

func (*TimedMetadata) Descriptor 

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

func (*TimedMetadata) GetAggregationId 

func (m *TimedMetadata) GetAggregationId() aggregationpb.AggregationID

func (*TimedMetadata) GetStoragePolicy 

func (m *TimedMetadata) GetStoragePolicy() policypb.StoragePolicy

func (*TimedMetadata) Marshal 

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

func (*TimedMetadata) MarshalTo 

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

func (*TimedMetadata) ProtoMessage 

func (*TimedMetadata) ProtoMessage()

func (*TimedMetadata) Reset 

func (m *TimedMetadata) Reset()

func (*TimedMetadata) Size 

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

func (*TimedMetadata) String 

func (m *TimedMetadata) String() string

func (*TimedMetadata) Unmarshal 

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

type TimedMetric 

type TimedMetric struct {
	Type      MetricType `protobuf:"varint,1,opt,name=type,proto3,enum=metricpb.MetricType" json:"type,omitempty"`
	Id        []byte     `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	TimeNanos int64      `protobuf:"varint,3,opt,name=time_nanos,json=timeNanos,proto3" json:"time_nanos,omitempty"`
	Value     float64    `protobuf:"fixed64,4,opt,name=value,proto3" json:"value,omitempty"`
}

func (*TimedMetric) Descriptor 

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

func (*TimedMetric) GetId 

func (m *TimedMetric) GetId() []byte

func (*TimedMetric) GetTimeNanos 

func (m *TimedMetric) GetTimeNanos() int64

func (*TimedMetric) GetType 

func (m *TimedMetric) GetType() MetricType

func (*TimedMetric) GetValue 

func (m *TimedMetric) GetValue() float64

func (*TimedMetric) Marshal 

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

func (*TimedMetric) MarshalTo 

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

func (*TimedMetric) ProtoMessage 

func (*TimedMetric) ProtoMessage()

func (*TimedMetric) Reset 

func (m *TimedMetric) Reset()

func (*TimedMetric) Size 

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

func (*TimedMetric) String 

func (m *TimedMetric) String() string

func (*TimedMetric) Unmarshal 

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

type TimedMetricWithMetadata 

type TimedMetricWithMetadata struct {
	Metric   TimedMetric   `protobuf:"bytes,1,opt,name=metric" json:"metric"`
	Metadata TimedMetadata `protobuf:"bytes,2,opt,name=metadata" json:"metadata"`
}

func (*TimedMetricWithMetadata) Descriptor 

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

func (*TimedMetricWithMetadata) GetMetadata 

func (m *TimedMetricWithMetadata) GetMetadata() TimedMetadata

func (*TimedMetricWithMetadata) GetMetric 

func (m *TimedMetricWithMetadata) GetMetric() TimedMetric

func (*TimedMetricWithMetadata) Marshal 

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

func (*TimedMetricWithMetadata) MarshalTo 

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

func (*TimedMetricWithMetadata) ProtoMessage 

func (*TimedMetricWithMetadata) ProtoMessage()

func (*TimedMetricWithMetadata) Reset 

func (m *TimedMetricWithMetadata) Reset()

func (*TimedMetricWithMetadata) Size 

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

func (*TimedMetricWithMetadata) String 

func (m *TimedMetricWithMetadata) String() string

func (*TimedMetricWithMetadata) Unmarshal 

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

type TimedMetricWithMetadatas added in v0.15.0 

type TimedMetricWithMetadatas struct {
	Metric    TimedMetric     `protobuf:"bytes,1,opt,name=metric" json:"metric"`
	Metadatas StagedMetadatas `protobuf:"bytes,2,opt,name=metadatas" json:"metadatas"`
}

func (*TimedMetricWithMetadatas) Descriptor added in v0.15.0 

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

func (*TimedMetricWithMetadatas) GetMetadatas added in v0.15.0 

func (m *TimedMetricWithMetadatas) GetMetadatas() StagedMetadatas

func (*TimedMetricWithMetadatas) GetMetric added in v0.15.0 

func (m *TimedMetricWithMetadatas) GetMetric() TimedMetric

func (*TimedMetricWithMetadatas) Marshal added in v0.15.0 

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

func (*TimedMetricWithMetadatas) MarshalTo added in v0.15.0 

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

func (*TimedMetricWithMetadatas) ProtoMessage added in v0.15.0 

func (*TimedMetricWithMetadatas) ProtoMessage()

func (*TimedMetricWithMetadatas) Reset added in v0.15.0 

func (m *TimedMetricWithMetadatas) Reset()

func (*TimedMetricWithMetadatas) Size added in v0.15.0 

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

func (*TimedMetricWithMetadatas) String added in v0.15.0 

func (m *TimedMetricWithMetadatas) String() string

func (*TimedMetricWithMetadatas) Unmarshal added in v0.15.0 

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

type TimedMetricWithStoragePolicy added in v0.5.0 

type TimedMetricWithStoragePolicy struct {
	TimedMetric   TimedMetric            `protobuf:"bytes,1,opt,name=timed_metric,json=timedMetric" json:"timed_metric"`
	StoragePolicy policypb.StoragePolicy `protobuf:"bytes,2,opt,name=storage_policy,json=storagePolicy" json:"storage_policy"`
}

func (*TimedMetricWithStoragePolicy) Descriptor added in v0.5.0 

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

func (*TimedMetricWithStoragePolicy) GetStoragePolicy added in v0.5.0 

func (m *TimedMetricWithStoragePolicy) GetStoragePolicy() policypb.StoragePolicy

func (*TimedMetricWithStoragePolicy) GetTimedMetric added in v0.5.0 

func (m *TimedMetricWithStoragePolicy) GetTimedMetric() TimedMetric

func (*TimedMetricWithStoragePolicy) Marshal added in v0.5.0 

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

func (*TimedMetricWithStoragePolicy) MarshalTo added in v0.5.0 

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

func (*TimedMetricWithStoragePolicy) ProtoMessage added in v0.5.0 

func (*TimedMetricWithStoragePolicy) ProtoMessage()

func (*TimedMetricWithStoragePolicy) Reset added in v0.5.0 

func (m *TimedMetricWithStoragePolicy) Reset()

func (*TimedMetricWithStoragePolicy) Size added in v0.5.0 

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

func (*TimedMetricWithStoragePolicy) String added in v0.5.0 

func (m *TimedMetricWithStoragePolicy) String() string

func (*TimedMetricWithStoragePolicy) Unmarshal added in v0.5.0 

func (m *TimedMetricWithStoragePolicy) 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.