queue

Documentation

Index

• func Marshal(v any) ([]byte, error)
• func NewQueue(prefix string, queue queueLib.IQueue) queueLib.IQueue
• type Queue
  • func (e *Queue) Consumer(ctx context.Context, name string, f queueLib.ConsumerFunc, ...)
  • func (e *Queue) Publish(ctx context.Context, msg message.IMessage, ...) error
  • func (e *Queue) RpcRequest(ctx context.Context, key string, data []byte, ...) ([]byte, error)
  • func (e *Queue) Run(ctx context.Context)
  • func (e *Queue) Shutdown(ctx context.Context)
  • func (e *Queue) String() string

Functions

func Marshal

func Marshal(v any) ([]byte, error)

func NewQueue

func NewQueue(prefix string, queue queueLib.IQueue) queueLib.IQueue

NewQueue 创建对应上下文队列

Types

type Queue

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

func (*Queue) Consumer

func (e *Queue) Consumer(ctx context.Context, name string, f queueLib.ConsumerFunc, optionFuncs ...func(*queueLib.ConsumeOptions))

Consumer 注册消费者

func (*Queue) Publish

func (e *Queue) Publish(ctx context.Context, msg message.IMessage, optionFuncs ...func(*queueLib.PublishOptions)) error

Publish 数据生产者

func (*Queue) RpcRequest

func (e *Queue) RpcRequest(ctx context.Context, key string, data []byte, optionFuncs ...func(*queueLib.ClientOptions)) ([]byte, error)

func (*Queue) Run

func (e *Queue) Run(ctx context.Context)

Run 运行

func (*Queue) Shutdown

func (e *Queue) Shutdown(ctx context.Context)

Shutdown 停止

func (*Queue) String

func (e *Queue) String() string