reporter

Documentation

Index

• func ParseInstanceID(payload []byte) (string, []byte, error)
• type Dispatcher
  • func NewDispatcher(metrics *monitoring.MetricService, clock clockwork.Clock, ...) *Dispatcher
  • func (d *Dispatcher) Handle(ctx context.Context, conn *net.UDPConn, addr *net.UDPAddr, payload []byte)
  • func (d *Dispatcher) Register(msgType master.Msg, handler Handler) error
• type Handler

Functions

func ParseInstanceID

func ParseInstanceID(payload []byte) (string, []byte, error)

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(
	metrics *monitoring.MetricService,
	clock clockwork.Clock,
	logger *zerolog.Logger,
) *Dispatcher

func (*Dispatcher) Handle

func (d *Dispatcher) Handle(
	ctx context.Context,
	conn *net.UDPConn,
	addr *net.UDPAddr,
	payload []byte,
)

func (*Dispatcher) Register

func (d *Dispatcher) Register(msgType master.Msg, handler Handler) error

type Handler

type Handler interface {
	Handle(ctx context.Context, connAddr *net.UDPAddr, payload []byte) ([]byte, error)
}