queue

Documentation

Index

• func RegQueueCreator(typeName string, creator QueueCreatorFunc)
• type NatsQueueClient
  • func (o *NatsQueueClient) Consume(name string, consumer QueueConsumerFunc)
  • func (o *NatsQueueClient) Publish(name string, payload interface{}) error
• type QueueClient
  • func Get(name ...string) QueueClient
• type QueueConsumerFunc
• type QueueCreatorFunc
• type RedisQueue
  • func (o *RedisQueue) Consume(name string, consumer QueueConsumerFunc)
  • func (o *RedisQueue) Publish(name string, payload interface{}) 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) Publish

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

type QueueClient

type QueueClient interface {
	Publish(name string, payload interface{}) error
	Consume(name string, consumer QueueConsumerFunc)
}

func Get

func Get(name ...string) QueueClient

type QueueConsumerFunc

type QueueConsumerFunc func(name, payload string)

type QueueCreatorFunc

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

type RedisQueue

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

func (*RedisQueue) Consume

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

func (*RedisQueue) Publish

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