tally: github.com/uber-go/tally/m3/thrift Index | Files

package m3

import "github.com/uber-go/tally/m3/thrift"

Index

Package Files

constants.go m3.go ttypes.go

Variables

var CountValue_I64Value_DEFAULT int64
var GaugeValue_DValue_DEFAULT float64
var GaugeValue_I64Value_DEFAULT int64
var GoUnusedProtection__ int
var MetricBatch_CommonTags_DEFAULT map[*MetricTag]bool
var MetricTag_TagValue_DEFAULT string
var Metric_Tags_DEFAULT map[*MetricTag]bool
var Metric_Timestamp_DEFAULT int64
var TimerValue_DValue_DEFAULT float64
var TimerValue_I64Value_DEFAULT int64

type CountValue Uses

type CountValue struct {
    I64Value *int64 `thrift:"i64Value,1" json:"i64Value"`
}
var MetricValue_Count_DEFAULT CountValue

func NewCountValue Uses

func NewCountValue() *CountValue

func (*CountValue) GetI64Value Uses

func (p *CountValue) GetI64Value() int64

func (*CountValue) IsSetI64Value Uses

func (p *CountValue) IsSetI64Value() bool

func (*CountValue) Read Uses

func (p *CountValue) Read(iprot thrift.TProtocol) error

func (*CountValue) ReadField1 Uses

func (p *CountValue) ReadField1(iprot thrift.TProtocol) error

func (*CountValue) String Uses

func (p *CountValue) String() string

func (*CountValue) Write Uses

func (p *CountValue) Write(oprot thrift.TProtocol) error

type EmitMetricBatchArgs Uses

type EmitMetricBatchArgs struct {
    Batch *MetricBatch `thrift:"batch,1" json:"batch"`
}

func NewEmitMetricBatchArgs Uses

func NewEmitMetricBatchArgs() *EmitMetricBatchArgs

func (*EmitMetricBatchArgs) GetBatch Uses

func (p *EmitMetricBatchArgs) GetBatch() *MetricBatch

func (*EmitMetricBatchArgs) IsSetBatch Uses

func (p *EmitMetricBatchArgs) IsSetBatch() bool

func (*EmitMetricBatchArgs) Read Uses

func (p *EmitMetricBatchArgs) Read(iprot thrift.TProtocol) error

func (*EmitMetricBatchArgs) ReadField1 Uses

func (p *EmitMetricBatchArgs) ReadField1(iprot thrift.TProtocol) error

func (*EmitMetricBatchArgs) String Uses

func (p *EmitMetricBatchArgs) String() string

func (*EmitMetricBatchArgs) Write Uses

func (p *EmitMetricBatchArgs) Write(oprot thrift.TProtocol) error

type GaugeValue Uses

type GaugeValue struct {
    I64Value *int64   `thrift:"i64Value,1" json:"i64Value"`
    DValue   *float64 `thrift:"dValue,2" json:"dValue"`
}
var MetricValue_Gauge_DEFAULT GaugeValue

func NewGaugeValue Uses

func NewGaugeValue() *GaugeValue

func (*GaugeValue) GetDValue Uses

func (p *GaugeValue) GetDValue() float64

func (*GaugeValue) GetI64Value Uses

func (p *GaugeValue) GetI64Value() int64

func (*GaugeValue) IsSetDValue Uses

func (p *GaugeValue) IsSetDValue() bool

func (*GaugeValue) IsSetI64Value Uses

func (p *GaugeValue) IsSetI64Value() bool

func (*GaugeValue) Read Uses

func (p *GaugeValue) Read(iprot thrift.TProtocol) error

func (*GaugeValue) ReadField1 Uses

func (p *GaugeValue) ReadField1(iprot thrift.TProtocol) error

func (*GaugeValue) ReadField2 Uses

func (p *GaugeValue) ReadField2(iprot thrift.TProtocol) error

func (*GaugeValue) String Uses

func (p *GaugeValue) String() string

func (*GaugeValue) Write Uses

func (p *GaugeValue) Write(oprot thrift.TProtocol) error

type M3 Uses

type M3 interface {

    // Emits a batch of metrics.
    //
    // Parameters:
    //  - Batch
    EmitMetricBatch(batch *MetricBatch) (err error)
}

type M3Client Uses

type M3Client struct {
    Transport       thrift.TTransport
    ProtocolFactory thrift.TProtocolFactory
    InputProtocol   thrift.TProtocol
    OutputProtocol  thrift.TProtocol
    SeqId           int32
}

M3 Metrics Service

func NewM3ClientFactory Uses

func NewM3ClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *M3Client

func NewM3ClientProtocol Uses

func NewM3ClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *M3Client

func (*M3Client) EmitMetricBatch Uses

func (p *M3Client) EmitMetricBatch(batch *MetricBatch) (err error)

Emits a batch of metrics.

Parameters:

- Batch

type M3Processor Uses

type M3Processor struct {
    // contains filtered or unexported fields
}

func NewM3Processor Uses

func NewM3Processor(handler M3) *M3Processor

func (*M3Processor) AddToProcessorMap Uses

func (p *M3Processor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*M3Processor) GetProcessorFunction Uses

func (p *M3Processor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*M3Processor) Process Uses

func (p *M3Processor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*M3Processor) ProcessorMap Uses

func (p *M3Processor) ProcessorMap() map[string]thrift.TProcessorFunction

type Metric Uses

type Metric struct {
    Name        string              `thrift:"name,1" json:"name"`
    MetricValue *MetricValue        `thrift:"metricValue,2" json:"metricValue"`
    Timestamp   *int64              `thrift:"timestamp,3" json:"timestamp"`
    Tags        map[*MetricTag]bool `thrift:"tags,4" json:"tags"`
}

func NewMetric Uses

func NewMetric() *Metric

func (*Metric) GetMetricValue Uses

func (p *Metric) GetMetricValue() *MetricValue

func (*Metric) GetName Uses

func (p *Metric) GetName() string

func (*Metric) GetTags Uses

func (p *Metric) GetTags() map[*MetricTag]bool

func (*Metric) GetTimestamp Uses

func (p *Metric) GetTimestamp() int64

func (*Metric) IsSetMetricValue Uses

func (p *Metric) IsSetMetricValue() bool

func (*Metric) IsSetTags Uses

func (p *Metric) IsSetTags() bool

func (*Metric) IsSetTimestamp Uses

func (p *Metric) IsSetTimestamp() bool

func (*Metric) Read Uses

func (p *Metric) Read(iprot thrift.TProtocol) error

func (*Metric) ReadField1 Uses

func (p *Metric) ReadField1(iprot thrift.TProtocol) error

func (*Metric) ReadField2 Uses

func (p *Metric) ReadField2(iprot thrift.TProtocol) error

func (*Metric) ReadField3 Uses

func (p *Metric) ReadField3(iprot thrift.TProtocol) error

func (*Metric) ReadField4 Uses

func (p *Metric) ReadField4(iprot thrift.TProtocol) error

func (*Metric) String Uses

func (p *Metric) String() string

func (*Metric) Write Uses

func (p *Metric) Write(oprot thrift.TProtocol) error

type MetricBatch Uses

type MetricBatch struct {
    Metrics    []*Metric           `thrift:"metrics,1" json:"metrics"`
    CommonTags map[*MetricTag]bool `thrift:"commonTags,2" json:"commonTags"`
}
var EmitMetricBatchArgs_Batch_DEFAULT *MetricBatch

func NewMetricBatch Uses

func NewMetricBatch() *MetricBatch

func (*MetricBatch) GetCommonTags Uses

func (p *MetricBatch) GetCommonTags() map[*MetricTag]bool

func (*MetricBatch) GetMetrics Uses

func (p *MetricBatch) GetMetrics() []*Metric

func (*MetricBatch) IsSetCommonTags Uses

func (p *MetricBatch) IsSetCommonTags() bool

func (*MetricBatch) Read Uses

func (p *MetricBatch) Read(iprot thrift.TProtocol) error

func (*MetricBatch) ReadField1 Uses

func (p *MetricBatch) ReadField1(iprot thrift.TProtocol) error

func (*MetricBatch) ReadField2 Uses

func (p *MetricBatch) ReadField2(iprot thrift.TProtocol) error

func (*MetricBatch) String Uses

func (p *MetricBatch) String() string

func (*MetricBatch) Write Uses

func (p *MetricBatch) Write(oprot thrift.TProtocol) error

type MetricTag Uses

type MetricTag struct {
    TagName  string  `thrift:"tagName,1" json:"tagName"`
    TagValue *string `thrift:"tagValue,2" json:"tagValue"`
}

func NewMetricTag Uses

func NewMetricTag() *MetricTag

func (*MetricTag) GetTagName Uses

func (p *MetricTag) GetTagName() string

func (*MetricTag) GetTagValue Uses

func (p *MetricTag) GetTagValue() string

func (*MetricTag) IsSetTagValue Uses

func (p *MetricTag) IsSetTagValue() bool

func (*MetricTag) Read Uses

func (p *MetricTag) Read(iprot thrift.TProtocol) error

func (*MetricTag) ReadField1 Uses

func (p *MetricTag) ReadField1(iprot thrift.TProtocol) error

func (*MetricTag) ReadField2 Uses

func (p *MetricTag) ReadField2(iprot thrift.TProtocol) error

func (*MetricTag) String Uses

func (p *MetricTag) String() string

func (*MetricTag) Write Uses

func (p *MetricTag) Write(oprot thrift.TProtocol) error

type MetricValue Uses

type MetricValue struct {
    Count *CountValue `thrift:"count,1" json:"count"`
    Gauge *GaugeValue `thrift:"gauge,2" json:"gauge"`
    Timer *TimerValue `thrift:"timer,3" json:"timer"`
}
var Metric_MetricValue_DEFAULT *MetricValue

func NewMetricValue Uses

func NewMetricValue() *MetricValue

func (*MetricValue) GetCount Uses

func (p *MetricValue) GetCount() CountValue

func (*MetricValue) GetGauge Uses

func (p *MetricValue) GetGauge() GaugeValue

func (*MetricValue) GetTimer Uses

func (p *MetricValue) GetTimer() TimerValue

func (*MetricValue) IsSetCount Uses

func (p *MetricValue) IsSetCount() bool

func (*MetricValue) IsSetGauge Uses

func (p *MetricValue) IsSetGauge() bool

func (*MetricValue) IsSetTimer Uses

func (p *MetricValue) IsSetTimer() bool

func (*MetricValue) Read Uses

func (p *MetricValue) Read(iprot thrift.TProtocol) error

func (*MetricValue) ReadField1 Uses

func (p *MetricValue) ReadField1(iprot thrift.TProtocol) error

func (*MetricValue) ReadField2 Uses

func (p *MetricValue) ReadField2(iprot thrift.TProtocol) error

func (*MetricValue) ReadField3 Uses

func (p *MetricValue) ReadField3(iprot thrift.TProtocol) error

func (*MetricValue) String Uses

func (p *MetricValue) String() string

func (*MetricValue) Write Uses

func (p *MetricValue) Write(oprot thrift.TProtocol) error

type TimerValue Uses

type TimerValue struct {
    I64Value *int64   `thrift:"i64Value,1" json:"i64Value"`
    DValue   *float64 `thrift:"dValue,2" json:"dValue"`
}
var MetricValue_Timer_DEFAULT TimerValue

func NewTimerValue Uses

func NewTimerValue() *TimerValue

func (*TimerValue) GetDValue Uses

func (p *TimerValue) GetDValue() float64

func (*TimerValue) GetI64Value Uses

func (p *TimerValue) GetI64Value() int64

func (*TimerValue) IsSetDValue Uses

func (p *TimerValue) IsSetDValue() bool

func (*TimerValue) IsSetI64Value Uses

func (p *TimerValue) IsSetI64Value() bool

func (*TimerValue) Read Uses

func (p *TimerValue) Read(iprot thrift.TProtocol) error

func (*TimerValue) ReadField1 Uses

func (p *TimerValue) ReadField1(iprot thrift.TProtocol) error

func (*TimerValue) ReadField2 Uses

func (p *TimerValue) ReadField2(iprot thrift.TProtocol) error

func (*TimerValue) String Uses

func (p *TimerValue) String() string

func (*TimerValue) Write Uses

func (p *TimerValue) Write(oprot thrift.TProtocol) error

Package m3 imports 3 packages (graph) and is imported by 4 packages. Updated 2019-06-25. Refresh now. Tools for package owners.