Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitMQConnector ¶
type RabbitMQConnector struct {
// contains filtered or unexported fields
}
func (*RabbitMQConnector) Close ¶
func (s *RabbitMQConnector) Close()
func (*RabbitMQConnector) Connect ¶
func (s *RabbitMQConnector) Connect(uri string, o Options)
type RabbitMQConsumeSettings ¶
type RabbitMQPublishSettings ¶
type RabbitMQPublishSettings struct {
QueueName string
}
type RabbitMQStream ¶
type RabbitMQStream struct {
RabbitMQConnector
}
func (*RabbitMQStream) Consume ¶
func (s *RabbitMQStream) Consume(opts interface{}) ([][]byte, error)
func (*RabbitMQStream) Publish ¶
func (s *RabbitMQStream) Publish(msg []byte, opts interface{}) error
Click to show internal directories.
Click to hide internal directories.