probes

Documentation

Index

• type Repository
  • func New(client *redis.Client, c clockwork.Clock) *Repository
  • func (r *Repository) Add(ctx context.Context, prb probe.Probe) error
  • func (r *Repository) AddBetween(ctx context.Context, prb probe.Probe, after time.Time, before time.Time) error
  • func (r *Repository) Count(ctx context.Context) (int, error)
  • func (r *Repository) Peek(ctx context.Context) (probe.Probe, error)
  • func (r *Repository) Pop(ctx context.Context) (probe.Probe, error)
  • func (r *Repository) PopMany(ctx context.Context, count int) ([]probe.Probe, int, error)

Types

type Repository

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

func New

func New(client *redis.Client, c clockwork.Clock) *Repository

func (*Repository) Add

func (r *Repository) Add(ctx context.Context, prb probe.Probe) error

func (*Repository) AddBetween

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

func (*Repository) Count

func (r *Repository) Count(ctx context.Context) (int, error)

func (*Repository) Peek

func (r *Repository) Peek(ctx context.Context) (probe.Probe, error)

func (*Repository) Pop

func (r *Repository) Pop(ctx context.Context) (probe.Probe, error)

func (*Repository) PopMany

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