detailsprober

Documentation

Index

• Variables
• type DetailsProber
  • func New(validate *validator.Validate, clock clockwork.Clock, ...) DetailsProber
  • func (p DetailsProber) HandleFailure(svr server.Server) server.Server
  • func (p DetailsProber) HandleRetry(svr server.Server) server.Server
  • func (p DetailsProber) HandleSuccess(result any, svr server.Server) server.Server
  • func (p DetailsProber) Probe(ctx context.Context, svrAddr addr.Addr, queryPort int, timeout time.Duration) (any, error)

Variables

var (
	ErrQueryTimeout     = errors.New("query timeout")
	ErrQueryFailed      = errors.New("failed to query server")
	ErrParseFailed      = errors.New("failed to parse server query response")
	ErrValidationFailed = errors.New("failed to validate server query response")
)

Types

type DetailsProber

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

func New

func New(
	validate *validator.Validate,
	clock clockwork.Clock,
	metrics *metrics.Collector,
	logger *zerolog.Logger,
) DetailsProber

func (DetailsProber) HandleFailure

func (p DetailsProber) HandleFailure(svr server.Server) server.Server

func (DetailsProber) HandleRetry

func (p DetailsProber) HandleRetry(svr server.Server) server.Server

func (DetailsProber) HandleSuccess

func (p DetailsProber) HandleSuccess(result any, svr server.Server) server.Server

func (DetailsProber) Probe

func (p DetailsProber) Probe(
	ctx context.Context,
	svrAddr addr.Addr,
	queryPort int,
	timeout time.Duration,
) (any, error)

Probe probes specified server's GS1 query port On success, update the server's extended params In case a server with specified identifier does not exit, create the server beforehand