Versions in this module Expand all Collapse all v0 v0.3.1 Mar 24, 2017 v0.3.0 Mar 21, 2017 Changes in this version + const DefaultAPIPort + const DefaultDeliveryMode + const DefaultRoutingKey + const DefaultURI + type Client struct + func NewClient(options ...ClientOptionFunc) (*Client, error) + func (c *Client) Close() + func (c *Client) Connect() (client.Session, error) + type ClientOptionFunc func(*Client) error + func WithCACerts(certs []string) ClientOptionFunc + func WithSSL(ssl bool) ClientOptionFunc + func WithURI(uri string) ClientOptionFunc + type RabbitMQ struct + APIPort int + CACerts []string + DeliveryMode uint8 + KeyInField bool + RoutingKey string + SSL bool + func (r *RabbitMQ) Client() (client.Client, error) + func (r *RabbitMQ) Description() string + func (r *RabbitMQ) Reader() (client.Reader, error) + func (r *RabbitMQ) SampleConfig() string + func (r *RabbitMQ) Writer(done chan struct{}, wg *sync.WaitGroup) (client.Writer, error) + type Reader struct + func (r *Reader) Read(filterFn client.NsFilterFunc) client.MessageChanFunc + type Session struct + type Writer struct + DeliveryMode uint8 + KeyInField bool + RoutingKey string + func (w *Writer) Write(msg message.Msg) func(client.Session) (message.Msg, error)
Go to main page