redisbroker

Documentation

Index

• Constants
• func QueueKey(name string) string
• type RedisBroker
  • func NewRedisBroker(client redis.UniversalClient) *RedisBroker
  • func (rtx *RedisBroker) Archive(ctx context.Context, msg *structs.TaskMessage, errMsg string) error
  • func (rtx *RedisBroker) CancelationPubSub(ctx context.Context) (*redis.PubSub, error)
  • func (rtx *RedisBroker) CheckAndEnqueue(ctx context.Context, qnames ...string) error
  • func (rtx *RedisBroker) ClearServerState(ctx context.Context, host string, pid int, serverID string) error
  • func (rtx *RedisBroker) Close(ctx context.Context) error
  • func (rtx *RedisBroker) Dequeue(ctx context.Context, qnames ...string) (*structs.TaskMessage, time.Time, error)
  • func (rtx *RedisBroker) Done(ctx context.Context, msg *structs.TaskMessage) error
  • func (rtx *RedisBroker) Enqueue(ctx context.Context, msg *structs.TaskMessage) error
  • func (rtx *RedisBroker) EnqueueUnique(ctx context.Context, msg *structs.TaskMessage, ttl time.Duration) error
  • func (rtx *RedisBroker) ListDeadlineExceeded(ctx context.Context, deadline time.Time, qnames ...string) ([]*structs.TaskMessage, error)
  • func (rtx *RedisBroker) Ping(ctx context.Context) error
  • func (rtx *RedisBroker) PublishCancelation(ctx context.Context, id string) error
  • func (rtx *RedisBroker) Requeue(ctx context.Context, msg *structs.TaskMessage) error
  • func (rtx *RedisBroker) Retry(ctx context.Context, msg *structs.TaskMessage, processAt time.Time, ...) error
  • func (rtx *RedisBroker) Schedule(ctx context.Context, msg *structs.TaskMessage, processAt time.Time) error
  • func (rtx *RedisBroker) ScheduleUnique(ctx context.Context, msg *structs.TaskMessage, processAt time.Time, ...) error
  • func (rtx *RedisBroker) WriteServerState(ctx context.Context, info *structs.ServerInfo, workers []*structs.WorkerInfo, ...) error

Constants

const (
	AllQueens = "tq:queens" // SET, 用到的所有的队列名
)

Functions

func QueueKey

func QueueKey(name string) string

QueueKey 返回对应队列的 redis key

Types

type RedisBroker

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

func NewRedisBroker

func NewRedisBroker(client redis.UniversalClient) *RedisBroker

func (*RedisBroker) Archive

func (rtx *RedisBroker) Archive(ctx context.Context, msg *structs.TaskMessage, errMsg string) error

func (*RedisBroker) CancelationPubSub

func (rtx *RedisBroker) CancelationPubSub(ctx context.Context) (*redis.PubSub, error)

func (*RedisBroker) CheckAndEnqueue

func (rtx *RedisBroker) CheckAndEnqueue(ctx context.Context, qnames ...string) error

func (*RedisBroker) ClearServerState

func (rtx *RedisBroker) ClearServerState(ctx context.Context, host string, pid int, serverID string) error

func (*RedisBroker) Close

func (rtx *RedisBroker) Close(ctx context.Context) error

func (*RedisBroker) Dequeue

func (rtx *RedisBroker) Dequeue(ctx context.Context, qnames ...string) (*structs.TaskMessage, time.Time, error)

func (*RedisBroker) Done

func (rtx *RedisBroker) Done(ctx context.Context, msg *structs.TaskMessage) error

func (*RedisBroker) Enqueue

func (rtx *RedisBroker) Enqueue(ctx context.Context, msg *structs.TaskMessage) error

Enqueue ...

func (*RedisBroker) EnqueueUnique

func (rtx *RedisBroker) EnqueueUnique(ctx context.Context, msg *structs.TaskMessage, ttl time.Duration) error

EnqueueUnique 首先检查 msg 是否已经在 唯一队列 中，如果在，返回错误；如果不在，执行 Enqueue 逻辑

func (*RedisBroker) ListDeadlineExceeded

func (rtx *RedisBroker) ListDeadlineExceeded(ctx context.Context, deadline time.Time, qnames ...string) ([]*structs.TaskMessage, error)

func (*RedisBroker) Ping

func (rtx *RedisBroker) Ping(ctx context.Context) error

func (*RedisBroker) PublishCancelation

func (rtx *RedisBroker) PublishCancelation(ctx context.Context, id string) error

func (*RedisBroker) Requeue

func (rtx *RedisBroker) Requeue(ctx context.Context, msg *structs.TaskMessage) error

func (*RedisBroker) Retry

func (rtx *RedisBroker) Retry(ctx context.Context, msg *structs.TaskMessage, processAt time.Time, errMsg string) error

func (*RedisBroker) Schedule

func (rtx *RedisBroker) Schedule(ctx context.Context, msg *structs.TaskMessage, processAt time.Time) error

func (*RedisBroker) ScheduleUnique

func (rtx *RedisBroker) ScheduleUnique(ctx context.Context, msg *structs.TaskMessage, processAt time.Time, ttl time.Duration) error

func (*RedisBroker) WriteServerState

func (rtx *RedisBroker) WriteServerState(ctx context.Context, info *structs.ServerInfo, workers []*structs.WorkerInfo, ttl time.Duration) error