Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func OptKafkaSendOnly ¶
OptKafkaSendOnly creates producer only. Subscribe operation will panic
func OptRabbitMQExchangeName ¶ added in v0.1.18
OptRabbitMQExchangeName sets the name of the RabbitMQ exchange used by the transport.
func OptRabbitMQSendOnly ¶
OptRabbitMQSendOnly creates only sending connection. Subscribe operation will panic.
Types ¶
type InMemory ¶ added in v0.1.20
type InMemory struct {
// contains filtered or unexported fields
}
InMemory provides event transport implemented completely in memory.
func NewInMemory ¶ added in v0.1.20
func NewInMemory() *InMemory
NewInMemory returns an initialized instance of InMemory event transport.
func (*InMemory) Close ¶ added in v0.1.20
func (m *InMemory) Close()
Close implements Transport interface close method.
type Kafka ¶
type Kafka struct {
// contains filtered or unexported fields
}
Kafka Implements transport interface using Kafka broker.
type Noop ¶
type Noop struct {
// contains filtered or unexported fields
}
Noop implements dummy transport which does nothing (optionally prints to the output specified)
func NewNoop ¶
NewNoop creates an instance of transport. out can be set to configure optional output.
type RabbitMQ ¶
type RabbitMQ struct {
// contains filtered or unexported fields
}
RabbitMQ implements transport over AMQP protocol and RabbitMQ messaging service
func NewRabbitMQ ¶
NewRabbitMQ creates new instance of RabbitMQ MessageQueue driver. Accepts variadic list of function options.
func (*RabbitMQ) Close ¶
func (mq *RabbitMQ) Close()
Close closes AMQP connections and stops all subscriptions
Source Files