queue

Documentation

Index

• type IQueue
  • func NewSimpleRedis(cnf *RedisQueueConfig, name string) IQueue
• type RedisQueueConfig

Types

type IQueue

type IQueue interface {
	Push(ctx context.Context, transNo string) error
	Pop(ctx context.Context) (string, error)
}

IQueue 简单队列约定

func NewSimpleRedis

func NewSimpleRedis(cnf *RedisQueueConfig, name string) IQueue

NewSimpleRedis 创建简单的 Redis 队列

type RedisQueueConfig

type RedisQueueConfig struct {
	Addr     string
	Password string
	Timeout  time.Duration
}

RedisQueueConfig Redis 队列参数