probe

Documentation

Index

• type Service
  • func NewService(repo repositories.ProbeRepository, metrics *monitoring.MetricService) *Service
  • func (s *Service) AddAfter(ctx context.Context, prb probe.Probe, after time.Time) error
  • func (s *Service) AddBefore(ctx context.Context, prb probe.Probe, before time.Time) error
  • func (s *Service) AddBetween(ctx context.Context, prb probe.Probe, after time.Time, before time.Time) error
  • func (s *Service) PopMany(ctx context.Context, count int) ([]probe.Probe, error)

Types

type Service

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

func NewService

func NewService(repo repositories.ProbeRepository, metrics *monitoring.MetricService) *Service

func (*Service) AddAfter

func (s *Service) AddAfter(ctx context.Context, prb probe.Probe, after time.Time) error

func (*Service) AddBefore

func (s *Service) AddBefore(ctx context.Context, prb probe.Probe, before time.Time) error

func (*Service) AddBetween

func (s *Service) AddBetween(ctx context.Context, prb probe.Probe, after time.Time, before time.Time) error

func (*Service) PopMany

func (s *Service) PopMany(ctx context.Context, count int) ([]probe.Probe, error)