sender

Documentation

Index

• Constants
• Variables
• func MakeCounterValue(endpoint, metric, tags string, val interface{}, step_and_ts ...int64) *model.JsonMetaData
• func MakeGaugeValue(endpoint, metric, tags string, val interface{}, step_and_ts ...int64) *model.JsonMetaData
• func MakeMetaData(endpoint, metric, tags string, val interface{}, counterType string, ...) *model.JsonMetaData
• func PostPush(L []*model.JsonMetaData) error
• func Push(endpoint, metric, tags string, val interface{}, counterType string, ...)
• func PushCounter(endpoint, metric, tags string, val interface{}, step_and_ts ...int64)
• func PushGauge(endpoint, metric, tags string, val interface{}, step_and_ts ...int64)
• func StartSender()
• type SafeLinkedList
  • func NewSafeLinkedList() *SafeLinkedList
  • func (this *SafeLinkedList) Front() *list.Element
  • func (this *SafeLinkedList) Len() int
  • func (this *SafeLinkedList) PopBack(limit int) []*model.JsonMetaData
  • func (this *SafeLinkedList) PushFront(v interface{}) *list.Element

Constants

const LIMIT = 200

Variables

var Debug bool

var MetaDataQueue = NewSafeLinkedList()

var PostPushUrl string

Functions

func MakeCounterValue

func MakeCounterValue(endpoint, metric, tags string, val interface{}, step_and_ts ...int64) *model.JsonMetaData

func MakeGaugeValue

func MakeGaugeValue(endpoint, metric, tags string, val interface{}, step_and_ts ...int64) *model.JsonMetaData

func MakeMetaData

func MakeMetaData(endpoint, metric, tags string, val interface{}, counterType string, step_and_ts ...int64) *model.JsonMetaData

func PostPush

func PostPush(L []*model.JsonMetaData) error

func Push

func Push(endpoint, metric, tags string, val interface{}, counterType string, step_and_ts ...int64)

func PushCounter

func PushCounter(endpoint, metric, tags string, val interface{}, step_and_ts ...int64)

func PushGauge

func PushGauge(endpoint, metric, tags string, val interface{}, step_and_ts ...int64)

func StartSender

func StartSender()

Types

type SafeLinkedList

type SafeLinkedList struct {
	sync.RWMutex
	L *list.List
}

func NewSafeLinkedList

func NewSafeLinkedList() *SafeLinkedList

func (*SafeLinkedList) Front

func (this *SafeLinkedList) Front() *list.Element

func (*SafeLinkedList) Len

func (this *SafeLinkedList) Len() int

func (*SafeLinkedList) PopBack

func (this *SafeLinkedList) PopBack(limit int) []*model.JsonMetaData

func (*SafeLinkedList) PushFront

func (this *SafeLinkedList) PushFront(v interface{}) *list.Element