receiver

Documentation

Index

• Constants
• type Config
• type GraphiteLineReceiver
  • func NewGraphiteLineReceiver(config Config, router routers.Router, exitChan <-chan struct{}, ...) (*GraphiteLineReceiver, error)
  • func (l *GraphiteLineReceiver) Parse(line []byte) (*carbon.Metric, error)
  • func (l *GraphiteLineReceiver) Start()
• type Metrics
• type Receiver

Constants

const (
	GraphiteLineReceiverMaxLineSize = 32 * 1024
)

Types

type Config

type Config struct {
	Listen   string
	Protocol string
	Workers  int
	Strict   bool
}

type GraphiteLineReceiver

type GraphiteLineReceiver struct {
	Config

	Metrics Metrics
	// contains filtered or unexported fields
}

func NewGraphiteLineReceiver

func NewGraphiteLineReceiver(config Config, router routers.Router, exitChan <-chan struct{}, maxBatchSize int, sendInterval time.Duration) (*GraphiteLineReceiver, error)

func (*GraphiteLineReceiver) Parse

func (l *GraphiteLineReceiver) Parse(line []byte) (*carbon.Metric, error)

func (*GraphiteLineReceiver) Start

func (l *GraphiteLineReceiver) Start()

type Metrics

type Metrics struct {
	ProcessedMetrics uint64
	ProcessingTimeNS uint64
}

type Receiver

type Receiver interface {
	Start()
	Parse(line []byte) (*carbon.Metric, error)
}