redis

package

v0.0.0-...-5aac58a Latest Latest Go to latest Published: Jul 21, 2023 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

View Source

var ErrEmptyQueue = errors.New("empty queue")

This section is empty.

type Message struct {
	Id         string `json:"id"`
	WorkerName string `json:"worker_name"`
	Data       interface{}
}

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

func NewRedisBroker(host, port, password string) (*RedisBroker, error)

func (r *RedisBroker) Ack(queue string, msg *Message) error

func (r *RedisBroker) Cancel(queue string, Jid string) error

func (r *RedisBroker) GetCancel(queue string) (string, error)

func (r *RedisBroker) Next(ctx context.Context, queue string) (msg *Message, err error)

func (r *RedisBroker) Send(queue string, msg *Message) error

type RedisClient struct {
	WaitQueue   string
	WorkQueue   string
	CancelQueue string
	// contains filtered or unexported fields
}

func NewRedisClient(host, port, password string) (*RedisClient, error)

func (r *RedisClient) CancelPop(ctx context.Context, prefix string) (string, error)

func (r *RedisClient) LPush(ctx context.Context, prefix string, values ...interface{}) error

func (r *RedisClient) LRem(ctx context.Context, prefix string, count int64, value interface{}) error

func (r *RedisClient) Push(ctx context.Context, prefix string, values ...interface{}) error

func (r *RedisClient) RPopLPush(ctx context.Context, prefix string) (string, error)