reporter

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 27, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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)
}

Directories

Path Synopsis
handlers

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL