redis

Documentation

Index

• func NewClient(cfg config.Configuration) (*redis.Client, taskq.Factory, error)
• func NewQueue(opts queue.QueueOptions) queue.Queuer
• type RedisQueue
  • func (q *RedisQueue) CheckEventDeliveryinPending(ctx context.Context, id string) (bool, error)
  • func (q *RedisQueue) CheckEventDeliveryinStream(ctx context.Context, id string, start string, end string) (bool, error)
  • func (q *RedisQueue) CheckEventDeliveryinZSET(ctx context.Context, id string, min string, max string) (bool, error)
  • func (q *RedisQueue) Close() error
  • func (q *RedisQueue) Consumer() taskq.QueueConsumer
  • func (q *RedisQueue) DeleteEvenDeliveryfromStream(ctx context.Context, id string) (bool, error)
  • func (q *RedisQueue) DeleteEventDeliveriesFromStream(ctx context.Context, ids []string) error
  • func (q *RedisQueue) DeleteEventDeliveriesFromZSET(ctx context.Context, ids []string) error
  • func (q *RedisQueue) DeleteEventDeliveryFromZSET(ctx context.Context, id string) (bool, error)
  • func (q *RedisQueue) ExportMessagesfromStream(ctx context.Context) ([]taskq.Message, error)
  • func (q *RedisQueue) ExportMessagesfromStreamXACK(ctx context.Context) ([]taskq.Message, error)
  • func (q *RedisQueue) Length() (int, error)
  • func (q *RedisQueue) Write(ctx context.Context, name convoy.TaskName, e *datastore.EventDelivery, ...) error
  • func (q *RedisQueue) XInfoConsumers(ctx context.Context) *redis.XInfoConsumersCmd
  • func (q *RedisQueue) XInfoStream(ctx context.Context) *redis.XInfoStreamCmd
  • func (q *RedisQueue) XPending(ctx context.Context) (*redis.XPending, error)
  • func (q *RedisQueue) XPendingExt(ctx context.Context, start string, end string) ([]redis.XPendingExt, error)
  • func (q *RedisQueue) XRange(ctx context.Context, start string, end string) *redis.XMessageSliceCmd
  • func (q *RedisQueue) XRangeN(ctx context.Context, start string, end string, count int64) *redis.XMessageSliceCmd
  • func (q *RedisQueue) ZRangebyScore(ctx context.Context, min string, max string) ([]string, error)

Functions

func NewClient

func NewClient(cfg config.Configuration) (*redis.Client, taskq.Factory, error)

func NewQueue

func NewQueue(opts queue.QueueOptions) queue.Queuer

Types

type RedisQueue

type RedisQueue struct {
	Name string
	// contains filtered or unexported fields
}

func (*RedisQueue) CheckEventDeliveryinPending

func (q *RedisQueue) CheckEventDeliveryinPending(ctx context.Context, id string) (bool, error)

func (*RedisQueue) CheckEventDeliveryinStream

func (q *RedisQueue) CheckEventDeliveryinStream(ctx context.Context, id string, start string, end string) (bool, error)

func (*RedisQueue) CheckEventDeliveryinZSET

func (q *RedisQueue) CheckEventDeliveryinZSET(ctx context.Context, id string, min string, max string) (bool, error)

func (*RedisQueue) Close

func (q *RedisQueue) Close() error

func (*RedisQueue) Consumer

func (q *RedisQueue) Consumer() taskq.QueueConsumer

func (*RedisQueue) DeleteEvenDeliveryfromStream

func (q *RedisQueue) DeleteEvenDeliveryfromStream(ctx context.Context, id string) (bool, error)

func (*RedisQueue) DeleteEventDeliveriesFromStream

func (q *RedisQueue) DeleteEventDeliveriesFromStream(ctx context.Context, ids []string) error

func (*RedisQueue) DeleteEventDeliveriesFromZSET

func (q *RedisQueue) DeleteEventDeliveriesFromZSET(ctx context.Context, ids []string) error

func (*RedisQueue) DeleteEventDeliveryFromZSET

func (q *RedisQueue) DeleteEventDeliveryFromZSET(ctx context.Context, id string) (bool, error)

func (*RedisQueue) ExportMessagesfromStream

func (q *RedisQueue) ExportMessagesfromStream(ctx context.Context) ([]taskq.Message, error)

func (*RedisQueue) ExportMessagesfromStreamXACK

func (q *RedisQueue) ExportMessagesfromStreamXACK(ctx context.Context) ([]taskq.Message, error)

func (*RedisQueue) Length

func (q *RedisQueue) Length() (int, error)

func (*RedisQueue) Write

func (q *RedisQueue) Write(ctx context.Context, name convoy.TaskName, e *datastore.EventDelivery, delay time.Duration) error

func (*RedisQueue) XInfoConsumers

func (q *RedisQueue) XInfoConsumers(ctx context.Context) *redis.XInfoConsumersCmd

func (*RedisQueue) XInfoStream

func (q *RedisQueue) XInfoStream(ctx context.Context) *redis.XInfoStreamCmd

func (*RedisQueue) XPending

func (q *RedisQueue) XPending(ctx context.Context) (*redis.XPending, error)

func (*RedisQueue) XPendingExt

func (q *RedisQueue) XPendingExt(ctx context.Context, start string, end string) ([]redis.XPendingExt, error)

func (*RedisQueue) XRange

func (q *RedisQueue) XRange(ctx context.Context, start string, end string) *redis.XMessageSliceCmd

func (*RedisQueue) XRangeN

func (q *RedisQueue) XRangeN(ctx context.Context, start string, end string, count int64) *redis.XMessageSliceCmd

func (*RedisQueue) ZRangebyScore

func (q *RedisQueue) ZRangebyScore(ctx context.Context, min string, max string) ([]string, error)