dogudp

Documentation

Index

• Constants
• func DefaultErrHandler(err error) error
• func DefaultMetricHandler(metric dogproto.Metric) error
• type ErrHandler
• type ErrListen
  • func (err *ErrListen) Error() string
  • func (err *ErrListen) Unwrap() error
• type ErrParse
  • func (err *ErrParse) Error() string
  • func (err *ErrParse) Unwrap() error
• type MetricHandler
  • func MultiHandler(handlers ...MetricHandler) MetricHandler
• type Server
  • func Listen(ctx context.Context, addr string, metricHandler MetricHandler, ...) (*Server, error)
  • func ListenUDP(ctx context.Context, addr *net.UDPAddr, metricHandler MetricHandler, ...) (*Server, error)
  • func (srv *Server) Serve() error

Constants

const DefaultAddr = "0.0.0.0:8125"

Functions

func DefaultErrHandler

func DefaultErrHandler(err error) error

func DefaultMetricHandler

func DefaultMetricHandler(metric dogproto.Metric) error

Types

type ErrHandler

type ErrHandler func(err error) error

type ErrListen

type ErrListen struct {
	Inner error
}

func (*ErrListen) Error

func (err *ErrListen) Error() string

func (*ErrListen) Unwrap

func (err *ErrListen) Unwrap() error

type ErrParse

type ErrParse struct {
	Inner error
}

func (*ErrParse) Error

func (err *ErrParse) Error() string

func (*ErrParse) Unwrap

func (err *ErrParse) Unwrap() error

type MetricHandler

type MetricHandler func(ctx context.Context, metric dogproto.Metric) (abort error)

func MultiHandler

func MultiHandler(handlers ...MetricHandler) MetricHandler

type Server

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

func Listen

func Listen(
	ctx context.Context,
	addr string,
	metricHandler MetricHandler,
	errHandler ErrHandler,
) (*Server, error)

func ListenUDP

func ListenUDP(
	ctx context.Context,
	addr *net.UDPAddr,
	metricHandler MetricHandler,
	errHandler ErrHandler,
) (*Server, error)

func (*Server) Serve

func (srv *Server) Serve() error