probers

Documentation

Index

• Variables
• type DetailsProber
  • func NewDetailsProber(service *probing.Service, metrics *monitoring.MetricService, ...) (*DetailsProber, error)
  • func (s *DetailsProber) HandleFailure(svr servers.Server) servers.Server
  • func (s *DetailsProber) HandleRetry(svr servers.Server) servers.Server
  • func (s *DetailsProber) HandleSuccess(result any, svr servers.Server) servers.Server
  • func (s *DetailsProber) Probe(ctx context.Context, svr servers.Server, queryPort int, timeout time.Duration) (any, error)
• type PortProber
  • func NewPortProber(service *probing.Service, metrics *monitoring.MetricService, ...) (*PortProber, error)
  • func (s *PortProber) HandleFailure(svr servers.Server) servers.Server
  • func (s *PortProber) HandleRetry(svr servers.Server) servers.Server
  • func (s *PortProber) HandleSuccess(res any, svr servers.Server) servers.Server
  • func (s *PortProber) Probe(ctx context.Context, svr servers.Server, _ int, timeout time.Duration) (any, error)
• type PortProberOpts
• type Result

Variables

var (
	ErrGlobalProbeTimeout = errors.New("global probe timeout reached")
	ErrPortProbesFailed   = errors.New("all port probes failed")
)

Types

type DetailsProber

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

func NewDetailsProber

func NewDetailsProber(
	service *probing.Service,
	metrics *monitoring.MetricService,
	validate *validator.Validate,
	logger *zerolog.Logger,
) (*DetailsProber, error)

func (*DetailsProber) HandleFailure

func (s *DetailsProber) HandleFailure(svr servers.Server) servers.Server

func (*DetailsProber) HandleRetry

func (s *DetailsProber) HandleRetry(svr servers.Server) servers.Server

func (*DetailsProber) HandleSuccess

func (s *DetailsProber) HandleSuccess(result any, svr servers.Server) servers.Server

func (*DetailsProber) Probe

func (s *DetailsProber) Probe(
	ctx context.Context,
	svr servers.Server,
	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

type PortProber

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

func NewPortProber

func NewPortProber(
	service *probing.Service,
	metrics *monitoring.MetricService,
	validate *validator.Validate,
	logger *zerolog.Logger,
	opts PortProberOpts,
) (*PortProber, error)

func (*PortProber) HandleFailure

func (s *PortProber) HandleFailure(svr servers.Server) servers.Server

func (*PortProber) HandleRetry

func (s *PortProber) HandleRetry(svr servers.Server) servers.Server

func (*PortProber) HandleSuccess

func (s *PortProber) HandleSuccess(res any, svr servers.Server) servers.Server

func (*PortProber) Probe

func (s *PortProber) Probe(
	ctx context.Context,
	svr servers.Server,
	_ int,
	timeout time.Duration,
) (any, error)

Probe attempts to discover a query port for a given server address. To discover the query port, several ports are tried: public port +1, +2 and so forth. In case when multiple query ports are available, the preferred port would be selected according to this order: gs1 mod, admin mod, vanilla response.

type PortProberOpts

type PortProberOpts struct {
	Offsets []int
}

type Result

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

var NoResult Result