heartbeat

Documentation

Index

• type Handler
  • func New(dispatcher *reporter.Dispatcher, metrics *metrics.Collector, ...) (Handler, error)
  • func (h Handler) Handle(ctx context.Context, connAddr *net.UDPAddr, payload []byte) ([]byte, error)

Types

type Handler

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

func New

func New(
	dispatcher *reporter.Dispatcher,
	metrics *metrics.Collector,
	reportServerUC reportserver.UseCase,
	removeServerUC removeserver.UseCase,
) (Handler, error)

func (Handler) Handle

func (h Handler) Handle(
	ctx context.Context,
	connAddr *net.UDPAddr,
	payload []byte,
) ([]byte, error)