redisScanner

Documentation

Index

• func Each(ctx context.Context, uc redis.UniversalClient, prefix string, count int64, ...) (bool, error)
• func Periodic(ctx context.Context, uc redis.UniversalClient, prefix string, ...)
• func ScanRedis(ctx context.Context, uc redis.UniversalClient, match string, count int64) (chan string, chan error)
• type PeriodicOptions
  • func (o *PeriodicOptions) Validate() error

Functions

func Each

func Each(ctx context.Context, uc redis.UniversalClient, prefix string, count int64, fn func(ctx context.Context, id sharedTypes.UUID) bool) (bool, error)

func Periodic

func Periodic(ctx context.Context, uc redis.UniversalClient, prefix string, pc PeriodicOptions, msg string, fn func(ctx context.Context, id sharedTypes.UUID) bool)

func ScanRedis

func ScanRedis(ctx context.Context, uc redis.UniversalClient, match string, count int64) (chan string, chan error)

Types

type PeriodicOptions

type PeriodicOptions struct {
	Count    int64         `json:"count"`
	Interval time.Duration `json:"interval"`
}

func (*PeriodicOptions) Validate

func (o *PeriodicOptions) Validate() error