memory

Documentation

Index

• type Memory
  • func NewMemory(poolNum uint) *Memory
  • func (m *Memory) Consumer(ctx context.Context, name string, f queueLib.ConsumerFunc, ...)
  • func (m *Memory) Publish(ctx context.Context, msg messageLib.IMessage, ...) error
  • func (m *Memory) RpcRequest(ctx context.Context, key string, data []byte, ...) ([]byte, error)
  • func (m *Memory) Run(ctx context.Context)
  • func (m *Memory) Shutdown(ctx context.Context)
  • func (*Memory) String() string

Types

type Memory

type Memory struct {
	PoolNum uint
	// contains filtered or unexported fields
}

func NewMemory

func NewMemory(poolNum uint) *Memory

NewMemory 内存模式

func (*Memory) Consumer

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

Consumer 监听消费者

func (*Memory) Publish

func (m *Memory) Publish(ctx context.Context, msg messageLib.IMessage, optionFuncs ...func(*queueLib.PublishOptions)) error

Publish 消息入生产者

func (*Memory) RpcRequest

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

func (*Memory) Run

func (m *Memory) Run(ctx context.Context)

func (*Memory) Shutdown

func (m *Memory) Shutdown(ctx context.Context)

func (*Memory) String

func (*Memory) String() string