Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageBroker ¶
type MessageBroker struct {
Connection string
Host string
Port string
Username string
Password string
Name string
Partition int
}
func (*MessageBroker) Kafka ¶
func (messageBroker *MessageBroker) Kafka() (*MessageBrokerConnection, error)
func (*MessageBroker) RabbitMQ ¶
func (messageBroker *MessageBroker) RabbitMQ() (*MessageBrokerConnection, error)
type MessageBrokerConnection ¶
type MessageBrokerConnection struct {
Name string
RabbitMQ *RabbitMQConnection
Kafka *kafka.Conn
}
func New ¶
func New(messageBroker *MessageBroker) (*MessageBrokerConnection, error)
func (*MessageBrokerConnection) Close ¶
func (messageBrokerConnection *MessageBrokerConnection) Close()
type RabbitMQConnection ¶
type RabbitMQConnection struct {
Connection *amqp.Connection
Channel *amqp.Channel
}
Source Files
Click to show internal directories.
Click to hide internal directories.