metricpb

package
v0.0.0-...-9649366 Latest Latest
Warning

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

Go to latest
Published: Nov 21, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

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
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",
}
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,
}

Functions

This section is empty.

Types

type AggregatedMetric

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

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

func (*AggregatedMetric) GetEncodeNanos

func (m *AggregatedMetric) GetEncodeNanos() int64

func (*AggregatedMetric) GetMetric

func (*AggregatedMetric) Marshal

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

func (*AggregatedMetric) MarshalTo

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

func (*AggregatedMetric) ProtoMessage

func (*AggregatedMetric) ProtoMessage()

func (*AggregatedMetric) Reset

func (m *AggregatedMetric) Reset()

func (*AggregatedMetric) Size

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

func (*AggregatedMetric) String

func (m *AggregatedMetric) String() string

func (*AggregatedMetric) Unmarshal

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 */
}

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

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 TimedMetricWithStoragePolicy

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

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

func (*TimedMetricWithStoragePolicy) GetStoragePolicy

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

func (*TimedMetricWithStoragePolicy) GetTimedMetric

func (m *TimedMetricWithStoragePolicy) GetTimedMetric() TimedMetric

func (*TimedMetricWithStoragePolicy) Marshal

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

func (*TimedMetricWithStoragePolicy) MarshalTo

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

func (*TimedMetricWithStoragePolicy) ProtoMessage

func (*TimedMetricWithStoragePolicy) ProtoMessage()

func (*TimedMetricWithStoragePolicy) Reset

func (m *TimedMetricWithStoragePolicy) Reset()

func (*TimedMetricWithStoragePolicy) Size

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

func (*TimedMetricWithStoragePolicy) String

func (*TimedMetricWithStoragePolicy) Unmarshal

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