queue

Documentation

Index

• type QueueInterface
  • func LoadQueueDriver(config *rcconfig.Queue) (queue QueueInterface, err error)

Types

type QueueInterface

type QueueInterface interface {

	// IsConnected 确认连接
	IsConnected(ctx context.Context) bool

	// ProduceMessage 生产消息
	ProduceMessage(ctx context.Context, job *model.Job) error

	// ConsumeMessage 消费消息
	ConsumeMessage(ctx context.Context) (*model.Job, error)

	// QueueLength 获取队列长度
	QueueLength(ctx context.Context) (int, error)

	// Close 关闭队列连接
	Close(ctx context.Context) error
}

func LoadQueueDriver

func LoadQueueDriver(config *rcconfig.Queue) (queue QueueInterface, err error)