queue

Documentation

Index

• func RegQueueCreator(typeName string, creator QueueCreatorFunc)
• type NatsQueueClient
  • func (o *NatsQueueClient) Consume(name string, consumer QueueConsumerFunc)
  • func (o *NatsQueueClient) ConsumeRaw(name string, consumer QueueRawConsumerFunc)
  • func (o *NatsQueueClient) Publish(name string, msg interface{}) error
  • func (o *NatsQueueClient) PublishRaw(name string, msg []byte) error
  • func (o *NatsQueueClient) Reply(subject string, eventHandler QueueReqHandler)
  • func (o *NatsQueueClient) ReplyRaw(subject string, eventHandler QueueRawReqHandler)
  • func (o *NatsQueueClient) Request(subject string, msg interface{}, timeOut ...time.Duration) (string, error)
  • func (o *NatsQueueClient) RequestRaw(subject string, msg []byte, timeOut ...time.Duration) ([]byte, error)
• type QueueClient
  • func Get(name ...string) QueueClient
• type QueueConsumerFunc
• type QueueCreatorFunc
• type QueueRawConsumerFunc
• type QueueRawReqHandler
• type QueueReqHandler
• type RedisQueue
  • func (o *RedisQueue) Consume(name string, consumer QueueConsumerFunc)
  • func (o *RedisQueue) ConsumeRaw(name string, consumer QueueRawConsumerFunc)
  • func (o *RedisQueue) Publish(name string, payload interface{}) error
  • func (o *RedisQueue) PublishRaw(name string, payload []byte) error
  • func (o *RedisQueue) Reply(subject string, eventHandler QueueReqHandler)
  • func (o *RedisQueue) ReplyRaw(subject string, eventHandler QueueRawReqHandler)
  • func (o *RedisQueue) Request(subject string, msg interface{}, timeOut ...time.Duration) (string, error)
  • func (o *RedisQueue) RequestRaw(subject string, msg []byte, timeOut ...time.Duration) ([]byte, error)

Functions

func RegQueueCreator

func RegQueueCreator(typeName string, creator QueueCreatorFunc)

Types

type NatsQueueClient

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

func (*NatsQueueClient) Consume

func (o *NatsQueueClient) Consume(name string, consumer QueueConsumerFunc)

func (*NatsQueueClient) ConsumeRaw

func (o *NatsQueueClient) ConsumeRaw(name string, consumer QueueRawConsumerFunc)

func (*NatsQueueClient) Publish

func (o *NatsQueueClient) Publish(name string, msg interface{}) error

func (*NatsQueueClient) PublishRaw

func (o *NatsQueueClient) PublishRaw(name string, msg []byte) error

func (*NatsQueueClient) Reply

func (o *NatsQueueClient) Reply(subject string, eventHandler QueueReqHandler)

func (*NatsQueueClient) ReplyRaw

func (o *NatsQueueClient) ReplyRaw(subject string, eventHandler QueueRawReqHandler)

func (*NatsQueueClient) Request

func (o *NatsQueueClient) Request(subject string, msg interface{}, timeOut ...time.Duration) (string, error)

func (*NatsQueueClient) RequestRaw

func (o *NatsQueueClient) RequestRaw(subject string, msg []byte, timeOut ...time.Duration) ([]byte, error)

type QueueClient

type QueueClient interface {
	Publish(name string, msg interface{}) error
	PublishRaw(name string, msg []byte) error
	Consume(name string, consumer QueueConsumerFunc)
	ConsumeRaw(name string, consumer QueueRawConsumerFunc)
	Request(subject string, msg interface{}, timeOut ...time.Duration) (string, error)
	RequestRaw(subject string, msg []byte, timeOut ...time.Duration) ([]byte, error)
	Reply(subject string, eventHandler QueueReqHandler)
	ReplyRaw(subject string, eventHandler QueueRawReqHandler)
}

func Get

func Get(name ...string) QueueClient

type QueueConsumerFunc

type QueueConsumerFunc func(name, msg string)

type QueueCreatorFunc

type QueueCreatorFunc func(url string) (QueueClient, error)

type QueueRawConsumerFunc

type QueueRawConsumerFunc func(name string, msg []byte)

type QueueRawReqHandler

type QueueRawReqHandler func(name string, msg []byte) []byte

type QueueReqHandler

type QueueReqHandler func(name, msg string) string

type RedisQueue

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

func (*RedisQueue) Consume

func (o *RedisQueue) Consume(name string, consumer QueueConsumerFunc)

func (*RedisQueue) ConsumeRaw

func (o *RedisQueue) ConsumeRaw(name string, consumer QueueRawConsumerFunc)

func (*RedisQueue) Publish

func (o *RedisQueue) Publish(name string, payload interface{}) error

func (*RedisQueue) PublishRaw

func (o *RedisQueue) PublishRaw(name string, payload []byte) error

func (*RedisQueue) Reply

func (o *RedisQueue) Reply(subject string, eventHandler QueueReqHandler)

func (*RedisQueue) ReplyRaw

func (o *RedisQueue) ReplyRaw(subject string, eventHandler QueueRawReqHandler)

func (*RedisQueue) Request

func (o *RedisQueue) Request(subject string, msg interface{}, timeOut ...time.Duration) (string, error)

func (*RedisQueue) RequestRaw

func (o *RedisQueue) RequestRaw(subject string, msg []byte, timeOut ...time.Duration) ([]byte, error)