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) 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewClient ¶
func NewClient(cfg config.Configuration) (*redis.Client, taskq.Factory, error)
Types ¶
type RedisQueue ¶
type RedisQueue struct { Name string // contains filtered or unexported fields }
func (*RedisQueue) CheckEventDeliveryinPending ¶
func (*RedisQueue) CheckEventDeliveryinStream ¶
func (*RedisQueue) CheckEventDeliveryinZSET ¶
func (*RedisQueue) Close ¶
func (q *RedisQueue) Close() error
func (*RedisQueue) Consumer ¶
func (q *RedisQueue) Consumer() taskq.QueueConsumer
func (*RedisQueue) DeleteEvenDeliveryfromStream ¶
func (*RedisQueue) DeleteEventDeliveriesFromStream ¶ added in v0.4.10
func (q *RedisQueue) DeleteEventDeliveriesFromStream(ctx context.Context, ids []string) error
func (*RedisQueue) DeleteEventDeliveriesFromZSET ¶ added in v0.4.10
func (q *RedisQueue) DeleteEventDeliveriesFromZSET(ctx context.Context, ids []string) error
func (*RedisQueue) DeleteEventDeliveryFromZSET ¶ added in v0.4.10
func (*RedisQueue) Length ¶ added in v0.4.10
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 (*RedisQueue) XRange ¶
func (q *RedisQueue) XRange(ctx context.Context, start string, end string) *redis.XMessageSliceCmd
func (*RedisQueue) ZRangebyScore ¶
Click to show internal directories.
Click to hide internal directories.