common

Documentation

Index

• type AMQPConnector
  • func (ac *AMQPConnector) Close(channel *amqp.Channel, conn *amqp.Connection) error
  • func (ac *AMQPConnector) Connect(url string, tlsConfig *tls.Config, exchange, exchangeType, queueName string, ...) (*amqp.Connection, *amqp.Channel, amqp.Queue, <-chan amqp.Confirmation, ...)
  • func (ac *AMQPConnector) DeleteQueue(channel *amqp.Channel, queueName string) error
  • func (*AMQPConnector) InspectQueue(channel *amqp.Channel, queueName string) (*amqp.Queue, error)
  • func (ac *AMQPConnector) Open(url string, tlsConfig *tls.Config) (*amqp.Connection, *amqp.Channel, error)
• type RedisConnector
  • func (rc *RedisConnector) NewPool(socketPath, host, password string, db int, cnf *config.RedisConfig) *redis.Pool

Types

type AMQPConnector

type AMQPConnector struct{}

AMQPConnector ...

func (*AMQPConnector) Close

func (ac *AMQPConnector) Close(channel *amqp.Channel, conn *amqp.Connection) error

Close connection

func (*AMQPConnector) Connect

func (ac *AMQPConnector) Connect(url string, tlsConfig *tls.Config, exchange, exchangeType, queueName string, queueDurable, queueDelete bool, queueBindingKey string, exchangeDeclareArgs, queueDeclareArgs, queueBindingArgs amqp.Table) (*amqp.Connection, *amqp.Channel, amqp.Queue, <-chan amqp.Confirmation, <-chan *amqp.Error, error)

Connect opens a connection to RabbitMQ, declares an exchange, opens a channel, declares and binds the queue and enables publish notifications

func (*AMQPConnector) DeleteQueue

func (ac *AMQPConnector) DeleteQueue(channel *amqp.Channel, queueName string) error

DeleteQueue deletes a queue by name

func (*AMQPConnector) InspectQueue

func (*AMQPConnector) InspectQueue(channel *amqp.Channel, queueName string) (*amqp.Queue, error)

InspectQueue provides information about a specific queue

func (*AMQPConnector) Open

func (ac *AMQPConnector) Open(url string, tlsConfig *tls.Config) (*amqp.Connection, *amqp.Channel, error)

Open new RabbitMQ connection

type RedisConnector

type RedisConnector struct{}

RedisConnector ...

func (*RedisConnector) NewPool

func (rc *RedisConnector) NewPool(socketPath, host, password string, db int, cnf *config.RedisConfig) *redis.Pool

NewPool returns a new pool of Redis connections