rabbitmq

package

v0.1.140 Latest Latest Go to latest Published: Jan 28, 2021 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pinguo/pgo2

Links

Open Source Insights

Documentation ¶

Index ¶

func New(config map[string]interface{}) (interface{}, error)
type ChannelBox
- func (c *ChannelBox) Close(force bool) error
- func (c *ChannelBox) GetChannel() *amqp.Channel
type Client
type ConnBox
- func (c *ConnBox) Disable() bool
type ConsumeData
type ExchangeData
type Pool
type PublishData
type RabbitHeaders

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func New ¶

func New(config map[string]interface{}) (interface{}, error)

RabbitMq client component, support Publisher-Consumer configuration: components:

rabbitMq:
    tlsRootCAs:""
    tlsCert: ""
    tlsCertKey: ""
    user: "guest"
    pass: "guest"
    exchangeName: ""
    exchangeType: ""
    maxChannelNum: 2000
    maxIdleChannel: "200"
    maxIdleChannelTime:"10s"
    probeInterval: "0s"
    maxWaitTime: "200ms"
    serviceName: "pgo-xxx"
    servers:
        - "127.0.0.1:6379"
        - "127.0.0.1:6380"

Types ¶

type ChannelBox ¶

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

func (*ChannelBox) Close ¶

func (c *ChannelBox) Close(force bool) error

func (*ChannelBox) GetChannel ¶

func (c *ChannelBox) GetChannel() *amqp.Channel

type Client ¶

type Client struct {
	Pool
}

func (*Client) Consume ¶

func (c *Client) Consume(parameter *ConsumeData) (<-chan amqp.Delivery, error)

func (*Client) DecodeBody ¶

func (c *Client) DecodeBody(d amqp.Delivery, ret interface{}) error

func (*Client) DecodeHeaders ¶

func (c *Client) DecodeHeaders(d amqp.Delivery) *RabbitHeaders

func (*Client) FreeChannel ¶ added in v0.1.103

func (c *Client) FreeChannel() (*ChannelBox, error)

func (*Client) GetConsumeChannelBox ¶

func (c *Client) GetConsumeChannelBox(queueName string, opCodes []string, exchange *ExchangeData) (*ChannelBox, error)

func (*Client) Publish ¶

func (c *Client) Publish(parameter *PublishData, logId string) (bool, error)

func (*Client) SetExchangeDeclare ¶

func (c *Client) SetExchangeDeclare(exchange *ExchangeData) error

type ConnBox ¶

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

func (*ConnBox) Disable ¶ added in v0.1.107

func (c *ConnBox) Disable() bool

type ConsumeData ¶

type ConsumeData struct {
	ExChange  *ExchangeData
	QueueName string
	Name      string
	OpCodes   []string
	AutoAck   bool
	NoWait    bool
	Exclusive bool
	Limit     int
}

type ExchangeData ¶ added in v0.1.99

type ExchangeData struct {
	Name       string // 交换机名
	Type       string // 交换机类型
	Durable    bool
	AutoDelete bool
	Internal   bool
	NoWait     bool
	Args       amqp.Table
}

type Pool ¶

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

func (*Pool) ExchangeType ¶ added in v0.1.99

func (c *Pool) ExchangeType(exchangeType string) string

func (*Pool) GetServers ¶

func (c *Pool) GetServers() (servers []string)

func (*Pool) Init ¶

func (c *Pool) Init() error

func (*Pool) ServiceName ¶

func (c *Pool) ServiceName(serviceName string) string

func (*Pool) SetExchangeName ¶

func (c *Pool) SetExchangeName(v string)

func (*Pool) SetExchangeType ¶

func (c *Pool) SetExchangeType(v string)

func (*Pool) SetLogger ¶ added in v0.1.7

func (c *Pool) SetLogger(logger logs.ILogger)

func (*Pool) SetMaxChannelNum ¶

func (c *Pool) SetMaxChannelNum(v int)

func (*Pool) SetMaxIdleChannel ¶

func (c *Pool) SetMaxIdleChannel(v int)

func (*Pool) SetMaxWaitTime ¶

func (c *Pool) SetMaxWaitTime(v string) error

func (*Pool) SetPass ¶

func (c *Pool) SetPass(v string)

func (*Pool) SetProbeInterval ¶

func (c *Pool) SetProbeInterval(v string) error

func (*Pool) SetServers ¶

func (c *Pool) SetServers(v []interface{})

func (*Pool) SetServiceName ¶

func (c *Pool) SetServiceName(v string)

func (*Pool) SetTlsCert ¶

func (c *Pool) SetTlsCert(v string)

func (*Pool) SetTlsCertKey ¶

func (c *Pool) SetTlsCertKey(v string)

func (*Pool) SetTlsRootCAs ¶

func (c *Pool) SetTlsRootCAs(v string)

func (*Pool) SetUser ¶

func (c *Pool) SetUser(v string)

type PublishData ¶

type PublishData struct {
	DeliveryMode uint8  // Transient (0 or 1)  or Persistent (2)
	ServiceName  string // 服务名
	ExChange     *ExchangeData
	OpCode       string      // 操作code 和queue绑定相关
	OpUid        string      // 操作用户id 可以为空
	ContentType  string      // 内容类型 默认为："text/plain"
	Data         interface{} // 发送数据
}

rabbit 发布结构

type RabbitHeaders ¶

type RabbitHeaders struct {
	LogId     string
	Exchange  string
	RouteKey  string
	Service   string
	OpUid     string
	Timestamp time.Time
	MessageId string
}

Source Files ¶

View all Source files

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