messages

Documentation

Index

• type DogStatsDMessage
  • func ParseDogStatsDMessage(buf []byte) (DogStatsDMessage, error)
• type DogStatsDMessageType
  • func (d DogStatsDMessageType) String() string
• type DogStatsDMetric
  • func (d DogStatsDMetric) Data() []byte
  • func (d DogStatsDMetric) Type() DogStatsDMessageType
• type DogStatsDMetricType
  • func (d DogStatsDMetricType) String() string
• type DogStatsDServiceCheck
  • func (d DogStatsDServiceCheck) Data() []byte
  • func (DogStatsDServiceCheck) Type() DogStatsDMessageType
• type Handler
  • func (h *Handler) Handle(msg []byte) error
  • func (h *Handler) New() *Handler
  • func (h *Handler) Stop()
• type OutputHandler

Types

type DogStatsDMessage

type DogStatsDMessage interface {
	Type() DogStatsDMessageType
	Data() []byte
}

func ParseDogStatsDMessage

func ParseDogStatsDMessage(buf []byte) (DogStatsDMessage, error)

ParseDogStatsDMessage parses a DogStatsDMessage, returning the correct message back

type DogStatsDMessageType

type DogStatsDMessageType int

const (
	MetricMessageType DogStatsDMessageType = iota
	ServiceCheckMessageType
	EventMessageType
)

func (DogStatsDMessageType) String

func (d DogStatsDMessageType) String() string

type DogStatsDMetric

type DogStatsDMetric struct {
	Namespace     string
	Name          string
	MetricData    []byte
	Timestamp     time.Time
	MetricType    DogStatsDMetricType
	RawValue      string
	FloatValue    float64
	DurationValue time.Duration
	Extras        []string
	Tags          []string
	SampleRate    float64
}

func (DogStatsDMetric) Data

func (d DogStatsDMetric) Data() []byte

func (DogStatsDMetric) Type

func (d DogStatsDMetric) Type() DogStatsDMessageType

type DogStatsDMetricType

type DogStatsDMetricType int

const (
	GaugeMetricType DogStatsDMetricType = iota
	CounterMetricType
	SetMetricType
	TimerMetricType
	HistogramMetricType
)

func (DogStatsDMetricType) String

func (d DogStatsDMetricType) String() string

type DogStatsDServiceCheck

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

func (DogStatsDServiceCheck) Data

func (d DogStatsDServiceCheck) Data() []byte

func (DogStatsDServiceCheck) Type

func (DogStatsDServiceCheck) Type() DogStatsDMessageType

type Handler

type Handler struct {
	Logger     *log.Logger
	Out        OutputHandler
	PoolSize   int
	BufferSize int
	// contains filtered or unexported fields
}

func (*Handler) Handle

func (h *Handler) Handle(msg []byte) error

Handle submits to the pool

func (*Handler) New

func (h *Handler) New() *Handler

func (*Handler) Stop

func (h *Handler) Stop()

type OutputHandler

type OutputHandler func([]byte) error