metricpb

package
v0.15.0-rc.6 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 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

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 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.