Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Channel ¶
type Channel struct {
// contains filtered or unexported fields
}
func NewChannel ¶
func (*Channel) ExchangeDeclare ¶
func (c *Channel) ExchangeDeclare(config *ExchangeDeclareConfig) error
func (*Channel) Publish ¶
func (c *Channel) Publish(data *PublishData) error
func (*Channel) QueueDeclare ¶
func (c *Channel) QueueDeclare(config *QueueDeclareConfig) (amqp.Queue, error)
type ChannelPool ¶
type ChannelPool struct {
// contains filtered or unexported fields
}
func NewChannelPool ¶
func NewChannelPool(pool *list.List) *ChannelPool
func (*ChannelPool) Get ¶
func (p *ChannelPool) Get() (*Channel, error)
func (*ChannelPool) Release ¶
func (p *ChannelPool) Release(channel *Channel)
type ChannelService ¶
type ChannelService interface {
Publish() error
}
type ConnPoolConfig ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func NewConnection ¶
func NewConnection(config *ConnectionConfig) *Connection
func (*Connection) GetChannelPool ¶
func (c *Connection) GetChannelPool() *ChannelPool
type ConnectionConfig ¶
type ConnectionPool ¶
type ConnectionPool struct {
// contains filtered or unexported fields
}
func NewConnectionPool ¶
func NewConnectionPool(config *ConnPoolConfig) *ConnectionPool
func (*ConnectionPool) Get ¶
func (c *ConnectionPool) Get() (*Connection, error)
func (*ConnectionPool) Release ¶
func (c *ConnectionPool) Release(conn *Connection)
type ExchangeDeclareConfig ¶
type ExchangeDeclareConfig struct { Name string Kind string Durable bool AutoDelete bool Internal bool NoWait bool Args amqp.Table }
name, kind string, durable, autoDelete, internal, noWait bool, args Table
type PublishData ¶
Click to show internal directories.
Click to hide internal directories.