veneur: github.com/stripe/veneur/samplers/metricpb Index | Files | Directories

package metricpb

import "github.com/stripe/veneur/samplers/metricpb"

Index

Package Files

metric.pb.go

Variables

var (
    ErrInvalidLengthMetric = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowMetric   = fmt.Errorf("proto: integer overflow")
)
var Scope_name = map[int32]string{
    0:  "Mixed",
    1:  "Local",
    2:  "Global",
}
var Scope_value = map[string]int32{
    "Mixed":  0,
    "Local":  1,
    "Global": 2,
}
var Type_name = map[int32]string{
    0:  "Counter",
    1:  "Gauge",
    2:  "Histogram",
    3:  "Set",
    4:  "Timer",
}
var Type_value = map[string]int32{
    "Counter":   0,
    "Gauge":     1,
    "Histogram": 2,
    "Set":       3,
    "Timer":     4,
}

type CounterValue Uses

type CounterValue struct {
    Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
}

CounterValue wraps the value of a counter

func (*CounterValue) Descriptor Uses

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

func (*CounterValue) GetValue Uses

func (m *CounterValue) GetValue() int64

func (*CounterValue) Marshal Uses

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

func (*CounterValue) MarshalTo Uses

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

func (*CounterValue) ProtoMessage Uses

func (*CounterValue) ProtoMessage()

func (*CounterValue) Reset Uses

func (m *CounterValue) Reset()

func (*CounterValue) Size Uses

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

func (*CounterValue) String Uses

func (m *CounterValue) String() string

func (*CounterValue) Unmarshal Uses

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

func (*CounterValue) XXX_DiscardUnknown Uses

func (m *CounterValue) XXX_DiscardUnknown()

func (*CounterValue) XXX_Marshal Uses

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

func (*CounterValue) XXX_Merge Uses

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

func (*CounterValue) XXX_Size Uses

func (m *CounterValue) XXX_Size() int

func (*CounterValue) XXX_Unmarshal Uses

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

type GaugeValue Uses

type GaugeValue struct {
    Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
}

GaugeValue wraps the value of a gauge

func (*GaugeValue) Descriptor Uses

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

func (*GaugeValue) GetValue Uses

func (m *GaugeValue) GetValue() float64

func (*GaugeValue) Marshal Uses

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

func (*GaugeValue) MarshalTo Uses

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

func (*GaugeValue) ProtoMessage Uses

func (*GaugeValue) ProtoMessage()

func (*GaugeValue) Reset Uses

func (m *GaugeValue) Reset()

func (*GaugeValue) Size Uses

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

func (*GaugeValue) String Uses

func (m *GaugeValue) String() string

func (*GaugeValue) Unmarshal Uses

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

func (*GaugeValue) XXX_DiscardUnknown Uses

func (m *GaugeValue) XXX_DiscardUnknown()

func (*GaugeValue) XXX_Marshal Uses

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

func (*GaugeValue) XXX_Merge Uses

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

func (*GaugeValue) XXX_Size Uses

func (m *GaugeValue) XXX_Size() int

func (*GaugeValue) XXX_Unmarshal Uses

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

type HistogramValue Uses

type HistogramValue struct {
    TDigest *tdigest.MergingDigestData `protobuf:"bytes,1,opt,name=t_digest,json=tDigest,proto3" json:"t_digest,omitempty"`
}

HistogramValue for now just includes the t-digest. This can be expanded to include the other values such as the sum, average, etc.

func (*HistogramValue) Descriptor Uses

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

func (*HistogramValue) GetTDigest Uses

func (m *HistogramValue) GetTDigest() *tdigest.MergingDigestData

func (*HistogramValue) Marshal Uses

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

func (*HistogramValue) MarshalTo Uses

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

func (*HistogramValue) ProtoMessage Uses

func (*HistogramValue) ProtoMessage()

func (*HistogramValue) Reset Uses

func (m *HistogramValue) Reset()

func (*HistogramValue) Size Uses

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

func (*HistogramValue) String Uses

func (m *HistogramValue) String() string

func (*HistogramValue) Unmarshal Uses

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

func (*HistogramValue) XXX_DiscardUnknown Uses

func (m *HistogramValue) XXX_DiscardUnknown()

func (*HistogramValue) XXX_Marshal Uses

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

func (*HistogramValue) XXX_Merge Uses

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

func (*HistogramValue) XXX_Size Uses

func (m *HistogramValue) XXX_Size() int

func (*HistogramValue) XXX_Unmarshal Uses

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

type Metric Uses

type Metric struct {
    Name string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    Tags []string `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
    Type Type     `protobuf:"varint,3,opt,name=type,proto3,enum=metricpb.Type" json:"type,omitempty"`
    // Types that are valid to be assigned to Value:
    //	*Metric_Counter
    //	*Metric_Gauge
    //	*Metric_Histogram
    //	*Metric_Set
    Value isMetric_Value `protobuf_oneof:"value"`
    Scope Scope          `protobuf:"varint,9,opt,name=scope,proto3,enum=metricpb.Scope" json:"scope,omitempty"`
}

Metric is a common container for any metric type. Common fields such as Name, Tags, and Type are all present for all types, while the value can vary.

func (*Metric) Descriptor Uses

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

func (*Metric) GetCounter Uses

func (m *Metric) GetCounter() *CounterValue

func (*Metric) GetGauge Uses

func (m *Metric) GetGauge() *GaugeValue

func (*Metric) GetHistogram Uses

func (m *Metric) GetHistogram() *HistogramValue

func (*Metric) GetName Uses

func (m *Metric) GetName() string

func (*Metric) GetScope Uses

func (m *Metric) GetScope() Scope

func (*Metric) GetSet Uses

func (m *Metric) GetSet() *SetValue

func (*Metric) GetTags Uses

func (m *Metric) GetTags() []string

func (*Metric) GetType Uses

func (m *Metric) GetType() Type

func (*Metric) GetValue Uses

func (m *Metric) GetValue() isMetric_Value

func (*Metric) Marshal Uses

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

func (*Metric) MarshalTo Uses

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

func (*Metric) ProtoMessage Uses

func (*Metric) ProtoMessage()

func (*Metric) Reset Uses

func (m *Metric) Reset()

func (*Metric) Size Uses

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

func (*Metric) String Uses

func (m *Metric) String() string

func (*Metric) Unmarshal Uses

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

func (*Metric) XXX_DiscardUnknown Uses

func (m *Metric) XXX_DiscardUnknown()

func (*Metric) XXX_Marshal Uses

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

func (*Metric) XXX_Merge Uses

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

func (*Metric) XXX_OneofFuncs Uses

func (*Metric) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Metric) XXX_Size Uses

func (m *Metric) XXX_Size() int

func (*Metric) XXX_Unmarshal Uses

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

type Metric_Counter Uses

type Metric_Counter struct {
    Counter *CounterValue `protobuf:"bytes,5,opt,name=counter,proto3,oneof"`
}

func (*Metric_Counter) MarshalTo Uses

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

func (*Metric_Counter) Size Uses

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

type Metric_Gauge Uses

type Metric_Gauge struct {
    Gauge *GaugeValue `protobuf:"bytes,6,opt,name=gauge,proto3,oneof"`
}

func (*Metric_Gauge) MarshalTo Uses

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

func (*Metric_Gauge) Size Uses

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

type Metric_Histogram Uses

type Metric_Histogram struct {
    Histogram *HistogramValue `protobuf:"bytes,7,opt,name=histogram,proto3,oneof"`
}

func (*Metric_Histogram) MarshalTo Uses

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

func (*Metric_Histogram) Size Uses

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

type Metric_Set Uses

type Metric_Set struct {
    Set *SetValue `protobuf:"bytes,8,opt,name=set,proto3,oneof"`
}

func (*Metric_Set) MarshalTo Uses

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

func (*Metric_Set) Size Uses

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

type Scope Uses

type Scope int32

Scope describes at which level the metric will be emitted.

const (
    Scope_Mixed  Scope = 0
    Scope_Local  Scope = 1
    Scope_Global Scope = 2
)

func (Scope) EnumDescriptor Uses

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

func (Scope) String Uses

func (x Scope) String() string

type SetValue Uses

type SetValue struct {
    HyperLogLog []byte `protobuf:"bytes,1,opt,name=hyper_log_log,json=hyperLogLog,proto3" json:"hyper_log_log,omitempty"`
}

SetValue contains a binary-encoded HyperLogLog

func (*SetValue) Descriptor Uses

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

func (*SetValue) GetHyperLogLog Uses

func (m *SetValue) GetHyperLogLog() []byte

func (*SetValue) Marshal Uses

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

func (*SetValue) MarshalTo Uses

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

func (*SetValue) ProtoMessage Uses

func (*SetValue) ProtoMessage()

func (*SetValue) Reset Uses

func (m *SetValue) Reset()

func (*SetValue) Size Uses

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

func (*SetValue) String Uses

func (m *SetValue) String() string

func (*SetValue) Unmarshal Uses

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

func (*SetValue) XXX_DiscardUnknown Uses

func (m *SetValue) XXX_DiscardUnknown()

func (*SetValue) XXX_Marshal Uses

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

func (*SetValue) XXX_Merge Uses

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

func (*SetValue) XXX_Size Uses

func (m *SetValue) XXX_Size() int

func (*SetValue) XXX_Unmarshal Uses

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

type Type Uses

type Type int32

Type can be any of the valid metric types recognized by Veneur.

const (
    Type_Counter   Type = 0
    Type_Gauge     Type = 1
    Type_Histogram Type = 2
    Type_Set       Type = 3
    Type_Timer     Type = 4
)

func (Type) EnumDescriptor Uses

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

func (Type) String Uses

func (x Type) String() string

Directories

PathSynopsis
testutils

Package metricpb imports 6 packages (graph) and is imported by 7 packages. Updated 2019-04-12. Refresh now. Tools for package owners.