Documentation
¶
Index ¶
- type BrokerSender
- type KafkaSender
- type KafkaTarget
- type RabbitMQSender
- type RabbitMQTarget
- type Sender
- func CreateBrokerSender(brokerAddress string, brokerTryNo int, rabbitMQServer string, exchange string, ...) Sender
- func CreateKafkaSender(brokers []string, topic string, writeTimeout time.Duration) Sender
- func CreateRabbitMQSender(server string, exchange string, routeKey string, writeTimeout time.Duration) Sender
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BrokerSender ¶ added in v0.2.0
type BrokerSender struct { BrokerAddress string BrokerTryNo int Target RabbitMQTarget }
func (*BrokerSender) SendMessage ¶ added in v0.2.0
func (s *BrokerSender) SendMessage(message []byte) error
type KafkaSender ¶
type KafkaSender struct { Target KafkaTarget Debug bool }
func (*KafkaSender) SendMessage ¶
func (s *KafkaSender) SendMessage(message []byte) error
type KafkaTarget ¶
type RabbitMQSender ¶
type RabbitMQSender struct { Target RabbitMQTarget Debug bool }
func (*RabbitMQSender) SendMessage ¶
func (s *RabbitMQSender) SendMessage(message []byte) error
type RabbitMQTarget ¶
Click to show internal directories.
Click to hide internal directories.