rabbitmq

package

Go to main page

Versions in this module

v0

v0.3.20

Aug 22, 2024

Changes in this version

type Message

+ ID int

+ func (m *Message) UnmarshalJSON(data []byte) error

v0.3.19

Dec 28, 2023

Changes in this version

+ const DefaultUnlimitedRetryCount

+ const DefaultUnlimitedWaitTime

type Config

+ Exchange string

+ Key string

+ Queue string

+ func (c *Config) Clone() *Config

+ type PoolConfig struct

+ InitConnections int

+ KeepAliveInterval int

+ MaxConnections int

+ MaxIdleConnections int

+ MaxIdleTime int

+ MaxRetryCount int

+ MaxWaitTime int

+ func NewPoolConfig(addr, user, host, vhost, tag, exchange, queue, key string, ...) *PoolConfig

+ func NewPoolConfigWithConfig(config *Config, ...) *PoolConfig

+ func (pc *PoolConfig) Clone() *PoolConfig

+ func (pc *PoolConfig) Validate() error

v0.3.18

Dec 13, 2023

v0.3.17

Jul 19, 2023

Changes in this version

+ const ErrChannelOrConnectionClosedCode

+ const ErrChannelOrConnectionClosedReason

type Consumer

+ Chan *amqp.Channel

+ func (c *Consumer) IsChannelOrConnectionClosedError(err error) bool

type Message

+ func (m *Message) Split() []*Message

v0.3.16

Jul 26, 2022

Changes in this version

+ const DefaultRabbitmqVhost

+ const ErrQueueExclusiveUseCode

+ const ErrQueueExclusiveUseReasonTemplate

+ const SQLTypeDelete

+ const SQLTypeInsert

+ const SQLTypeUpdate

+ type Config struct

+ Addr string

+ Pass string

+ Tag string

+ User string

+ Vhost string

+ func NewConfig(addr, user, pass, vhost, tag string) *Config

+ func NewConfigWithDefault(addr, user, pass string) *Config

+ func (c *Config) GetAddr() string

+ func (c *Config) GetPass() string

+ func (c *Config) GetTag() string

+ func (c *Config) GetURL() string

+ func (c *Config) GetUser() string

+ func (c *Config) GetVhost() string

+ type Conn struct

+ Config *Config

+ func NewConn(addr, user, pass, vhost, tag string) (*Conn, error)

+ func NewConnWithConfig(config *Config) (*Conn, error)

+ func NewConnWithDefault(addr, user, pass string) (*Conn, error)

+ func (c *Conn) Close() error

+ func (c *Conn) GetConfig() *Config

+ func (c *Conn) GetConnection() *amqp.Connection

+ type Consumer struct

+ Channel *amqp.Channel

+ Conn *Conn

+ Queue amqp.Queue

+ func NewConsumer(addr, user, pass, vhost, tag string) (*Consumer, error)

+ func NewConsumerWithConfig(config *Config) (*Consumer, error)

+ func NewConsumerWithConn(conn *Conn) (*Consumer, error)

+ func NewConsumerWithDefault(addr, user, pass string) (*Consumer, error)

+ func (c *Consumer) Ack(tag uint64, multiple bool) error

+ func (c *Consumer) Cancel() error

+ func (c *Consumer) Close() error

+ func (c *Consumer) CloseChannel() error

+ func (c *Consumer) Consume(queue string, exclusive bool) (<-chan amqp.Delivery, error)

+ func (c *Consumer) ExchangeDeclare(name, kind string) error

+ func (c *Consumer) GetChannel() *amqp.Channel

+ func (c *Consumer) GetConn() *Conn

+ func (c *Consumer) GetQueue() amqp.Queue

+ func (c *Consumer) IsExclusiveUseError(queue string, err error) bool

+ func (c *Consumer) Nack(tag uint64, multiple bool, requeue bool) error

+ func (c *Consumer) Qos(prefetchCount int, global bool) error

+ func (c *Consumer) QueueBind(queue, exchange, key string) error

+ func (c *Consumer) QueueDeclare(name string) (amqp.Queue, error)

+ type Message struct

+ Columns map[string]string

+ DBName string

+ Data []map[string]interface{}

+ IsDDL bool

+ Old []map[string]interface{}

+ PKNames []string

+ SQLType string

+ TableName string

+ func NewEmptyMessage() *Message

+ func NewMessage(sqlType string, isDDL bool, dbName string, tableName string, pkNames []string, ...) *Message

+ func (m *Message) ConvertToSQL(ignoreDDL bool, useReplace bool) ([]map[string][]interface{}, error)

+ func (m *Message) GetColumnNames() []string

+ func (m *Message) GetColumns() map[string]string

+ func (m *Message) GetDBName() string

+ func (m *Message) GetData() []map[string]interface{}

+ func (m *Message) GetIsDDL() bool

+ func (m *Message) GetOld() []map[string]interface{}

+ func (m *Message) GetPKNames() []string

+ func (m *Message) GetSQLType() string

+ func (m *Message) GetTableName() string

+ type Producer struct

+ Channel *amqp.Channel

+ Conn *Conn

+ func NewProducer(addr, user, pass, vhost, tag string) (*Producer, error)

+ func NewProducerWithConfig(config *Config) (*Producer, error)

+ func NewProducerWithConn(conn *Conn) (*Producer, error)

+ func NewProducerWithDefault(addr, user, pass string) (*Producer, error)

+ func (p *Producer) BuildMessage(message, contentType string) amqp.Publishing

+ func (p *Producer) BuildMessageWithExpiration(message, contentType string, expiration int) amqp.Publishing

+ func (p *Producer) Close() error

+ func (p *Producer) Disconnect() error

+ func (p *Producer) ExchangeDeclare(name, kind string) error

+ func (p *Producer) GetChannel() *amqp.Channel

+ func (p *Producer) GetConn() *Conn

+ func (p *Producer) Publish(exchange, key string, msg amqp.Publishing) error

+ func (p *Producer) QueueBind(queue, exchange, key string) error

+ func (p *Producer) QueueDeclare(name string) (amqp.Queue, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL