queue

Documentation

Index

• type Connection
  • func Connect(queueType QueueType, url string) (Connection, error)
  • func NewRabbitMQConnection(url string) (Connection, error)
  • func NewRedisConnection(url string) (Connection, error)
• type Consumer
• type Publisher
• type QueueType

Types

type Connection

type Connection interface {
	NewPublisher(queueName string) (Publisher, error)
	NewConsumer(queueName string, handler app.Handler) (Consumer, error)
	Close() error
}

func Connect

func Connect(queueType QueueType, url string) (Connection, error)

func NewRabbitMQConnection

func NewRabbitMQConnection(url string) (Connection, error)

func NewRedisConnection

func NewRedisConnection(url string) (Connection, error)

type Consumer

type Consumer interface {
	Consume()
	Stop()
}

type Publisher

type Publisher interface {
	Publish(ctx context.Context, message []byte) error
	Close() error
}

type QueueType

type QueueType string

const (
	RabbitMQ QueueType = "rabbitmq"
	Redis    QueueType = "redis"
)