responder

Documentation

Index

• Variables
• type Limiter
  • func NewLimiter(overallRate rate.Limit, overallBurst int, perIpRate rate.Limit, perIpBurst int, ...) Limiter
• type Params
• type Responder
• type Result
  • func New(p Params) Result

Variables

var ErrInvalidToken = dht.Error{
	Code: dht.ErrorCodeProtocolError,
	Msg:  "invalid token",
}

var ErrMethodUnknown = dht.Error{
	Code: dht.ErrorCodeMethodUnknown,
	Msg:  "method Unknown",
}

var ErrMissingArguments = dht.Error{
	Code: dht.ErrorCodeProtocolError,
	Msg:  "missing arguments",
}

var ErrTooManyRequests = dht.Error{
	Code: dht.ErrorCodeGenericError,
	Msg:  "too many requests",
}

Types

type Limiter

type Limiter interface {
	Allow(addr netip.Addr) bool
}

func NewLimiter

func NewLimiter(
	overallRate rate.Limit,
	overallBurst int,
	perIpRate rate.Limit,
	perIpBurst int,
	perIpSize int,
	perIpTtl time.Duration,
) Limiter

type Params

type Params struct {
	fx.In
	KTable          ktable.Table
	DiscoveredNodes concurrency.BatchingChannel[ktable.Node] `name:"dht_discovered_nodes"`
	Logger          *zap.SugaredLogger
}

type Responder

type Responder interface {
	Respond(context.Context, dht.RecvMsg) (dht.Return, error)
}

type Result

type Result struct {
	fx.Out
	Responder         Responder
	QueryDuration     prometheus.Collector `group:"prometheus_collectors"`
	QuerySuccessTotal prometheus.Collector `group:"prometheus_collectors"`
	QueryErrorTotal   prometheus.Collector `group:"prometheus_collectors"`
	QueryConcurrency  prometheus.Collector `group:"prometheus_collectors"`
}

func New

func New(p Params) Result