probing

Documentation

Index

• Variables
• type Prober
• type Service
  • func NewService(servers repositories.ServerRepository, queue *ps.Service, ...) *Service
  • func (s *Service) Probe(ctx context.Context, prb probe.Probe) error
  • func (s *Service) Register(pg probe.Goal, prober Prober) error
• type ServiceOpts

Variables

var (
	ErrProbeRetried = errors.New("probe is retried")
	ErrOutOfRetries = errors.New("retry limit reached")
)

Types

type Prober

type Prober interface {
	Probe(context.Context, server.Server, int, time.Duration) (any, error)
	HandleSuccess(any, server.Server) server.Server
	HandleRetry(server.Server) server.Server
	HandleFailure(server.Server) server.Server
}

type Service

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

func NewService

func NewService(
	servers repositories.ServerRepository,
	queue *ps.Service,
	logger *zerolog.Logger,
	opts ServiceOpts,
) *Service

func (*Service) Probe

func (s *Service) Probe(ctx context.Context, prb probe.Probe) error

func (*Service) Register

func (s *Service) Register(pg probe.Goal, prober Prober) error

type ServiceOpts

type ServiceOpts struct {
	MaxRetries   int
	ProbeTimeout time.Duration
}