receiver

Documentation

Index

• Constants
• func ControlReusePort(network string, address string, conn syscall.RawConn) error
• type CallbackHandler
  • func (c CallbackHandler) HandleMetrics(b *tlstatshouse.MetricBytes, cb mapping.MapCallbackFunc) (h data_model.MappedMetricHeader, done bool)
  • func (c CallbackHandler) HandleParseError(pkt []byte, err error)
• type Handler
• type RPCReceiver
  • func MakeRPCReceiver(ag *agent.Agent, h Handler) *RPCReceiver
  • func (r *RPCReceiver) RawAddMetricsBatch(ctx context.Context, hctx *rpc.HandlerContext) error
• type UDP
  • func ListenUDP(address string, bufferSize int, reusePort bool, bm *agent.Agent, ...) (*UDP, error)
  • func (u *UDP) Addr() string
  • func (u *UDP) Close() error
  • func (u *UDP) Serve(h Handler) error
  • func (u *UDP) StatBatchesTotalErr() uint64
  • func (u *UDP) StatBatchesTotalOK() uint64
  • func (u *UDP) StatBytesTotal() uint64
  • func (u *UDP) StatPacketsTotal() uint64

Constants

const (
	DefaultConnBufSize = 16 * 1024 * 1024
)

Functions

func ControlReusePort

func ControlReusePort(network string, address string, conn syscall.RawConn) error

Types

type CallbackHandler

type CallbackHandler struct {
	Metrics    func(*tlstatshouse.MetricBytes, mapping.MapCallbackFunc) (h data_model.MappedMetricHeader, done bool)
	ParseError func([]byte, error)
}

func (CallbackHandler) HandleMetrics

func (c CallbackHandler) HandleMetrics(b *tlstatshouse.MetricBytes, cb mapping.MapCallbackFunc) (h data_model.MappedMetricHeader, done bool)

func (CallbackHandler) HandleParseError

func (c CallbackHandler) HandleParseError(pkt []byte, err error)

type Handler

type Handler interface {
	HandleMetrics(*tlstatshouse.MetricBytes, mapping.MapCallbackFunc) (h data_model.MappedMetricHeader, done bool) // if cannot process immediately, and needs to own data, should swap another metric from the pool
	HandleParseError([]byte, error)
}

type RPCReceiver

type RPCReceiver struct {
	Handler Handler

	StatCallsTotalOK  atomic.Uint64
	StatCallsTotalErr atomic.Uint64
	// contains filtered or unexported fields
}

func MakeRPCReceiver

func MakeRPCReceiver(ag *agent.Agent, h Handler) *RPCReceiver

func (*RPCReceiver) RawAddMetricsBatch

func (r *RPCReceiver) RawAddMetricsBatch(ctx context.Context, hctx *rpc.HandlerContext) error

type UDP

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

func ListenUDP

func ListenUDP(address string, bufferSize int, reusePort bool, bm *agent.Agent, logPacket func(format string, args ...interface{})) (*UDP, error)

func (*UDP) Addr

func (u *UDP) Addr() string

func (*UDP) Close

func (u *UDP) Close() error

func (*UDP) Serve

func (u *UDP) Serve(h Handler) error

func (*UDP) StatBatchesTotalErr

func (u *UDP) StatBatchesTotalErr() uint64

func (*UDP) StatBatchesTotalOK

func (u *UDP) StatBatchesTotalOK() uint64

func (*UDP) StatBytesTotal

func (u *UDP) StatBytesTotal() uint64

func (*UDP) StatPacketsTotal

func (u *UDP) StatPacketsTotal() uint64