server

Documentation

Index

• type Config
  • func NewDefaultConfig() Config
• type IdIssuer
• type Params
• type Result
  • func New(p Params) Result
• type Server
• type Socket
  • func NewSocket() Socket

Types

type Config

type Config struct {
	Port         uint16
	QueryTimeout time.Duration
}

func NewDefaultConfig

func NewDefaultConfig() Config

type IdIssuer

type IdIssuer interface {
	Issue() string
}

type Params

type Params struct {
	fx.In
	Config    Config
	Responder responder.Responder
	Logger    *zap.SugaredLogger
}

type Result

type Result struct {
	fx.Out
	Server            Server
	AppHook           fx.Hook              `group:"app_hooks"`
	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

type Server

type Server interface {
	Ready() <-chan struct{}
	Query(ctx context.Context, addr netip.AddrPort, q string, args dht.MsgArgs) (dht.RecvMsg, error)
}

type Socket

type Socket interface {
	Open(localAddr netip.AddrPort) error
	Close() error
	Send(netip.AddrPort, []byte) error
	Receive([]byte) (int, netip.AddrPort, error)
}

func NewSocket

func NewSocket() Socket