metricpb

package
v0.15.13 Latest Latest
Warning

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

Go to latest
Published: Aug 31, 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 (*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 (*ForwardedMetricWithMetadata) GetMetric

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 (*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 (*TimedMetricWithStoragePolicy) Unmarshal added in v0.5.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL