stat

Documentation

Index

• Constants
• func NewSubscriber() counter.Provider
• func SubscriberEnd(operation *gmetric.Operation, recentCounter *counter.Operation, ...)
• type Values
  • func NewValues() *Values
  • func SubscriberBegin(operation *gmetric.Operation) (*counter.Operation, counter.OnDone, *Values)
  • func (v *Values) Append(item interface{})
  • func (v *Values) Values() []interface{}

Constants

const (
	ErrorKey             = "error"
	DataCorruption       = "data_corruption"
	Pending              = "pending"
	Retry                = "retry"
	Timeout              = "timeout"
	Acknowledged         = "ack"
	NegativeAcknowledged = "nack"
	SubscriberMetricName = "subscriber"
)

Functions

func NewSubscriber

func NewSubscriber() counter.Provider

func SubscriberEnd

func SubscriberEnd(operation *gmetric.Operation, recentCounter *counter.Operation, onDone counter.OnDone, stats *Values)

Types

type Values

type Values []interface{}

func NewValues

func NewValues() *Values

NewValues creates a values slice

func SubscriberBegin

func SubscriberBegin(operation *gmetric.Operation) (*counter.Operation, counter.OnDone, *Values)

func (*Values) Append

func (v *Values) Append(item interface{})

func (*Values) Values

func (v *Values) Values() []interface{}