Documentation
¶
Index ¶
- Constants
- func NewKafkaMessageBus(host string, port int, topic string, tlsCfg *KafkaTLSConfig) (messagebus.Messagebus, error)
- func NewKafkaMessageBusFromConn(conn *kafka.Conn, topic string) (messagebus.Messagebus, error)
- type KafkaMessagebus
- func (m *KafkaMessagebus) Close() error
- func (m *KafkaMessagebus) ReceiveMessage(message chan<- string, queue string) (messagebus.Subscription, error)
- func (m *KafkaMessagebus) RecieveLoop(conn *kafka.Conn, message chan<- string, queue string)
- func (m *KafkaMessagebus) SendMessage(message []byte, queue string) error
- func (m *KafkaMessagebus) SendMessageWithHeaders(message []byte, queue string, headers map[string]string) error
- func (m *KafkaMessagebus) TopicConnect(queue string) (*kafka.Conn, error)
- type KafkaSubscription
- type KafkaTLSConfig
Constants ¶
View Source
const KafkaMaxMessageBytes = 16 * 1024
Variables ¶
This section is empty.
Functions ¶
func NewKafkaMessageBus ¶
func NewKafkaMessageBus(host string, port int, topic string, tlsCfg *KafkaTLSConfig) (messagebus.Messagebus, error)
func NewKafkaMessageBusFromConn ¶
func NewKafkaMessageBusFromConn(conn *kafka.Conn, topic string) (messagebus.Messagebus, error)
Types ¶
type KafkaMessagebus ¶
type KafkaMessagebus struct {
// contains filtered or unexported fields
}
func (*KafkaMessagebus) Close ¶
func (m *KafkaMessagebus) Close() error
func (*KafkaMessagebus) ReceiveMessage ¶
func (m *KafkaMessagebus) ReceiveMessage(message chan<- string, queue string) (messagebus.Subscription, error)
func (*KafkaMessagebus) RecieveLoop ¶
func (m *KafkaMessagebus) RecieveLoop(conn *kafka.Conn, message chan<- string, queue string)
func (*KafkaMessagebus) SendMessage ¶
func (m *KafkaMessagebus) SendMessage(message []byte, queue string) error
func (*KafkaMessagebus) SendMessageWithHeaders ¶
func (*KafkaMessagebus) TopicConnect ¶
func (m *KafkaMessagebus) TopicConnect(queue string) (*kafka.Conn, error)
type KafkaSubscription ¶
type KafkaSubscription struct {
}
func (*KafkaSubscription) Close ¶
func (m *KafkaSubscription) Close() error
Source Files
Click to show internal directories.
Click to hide internal directories.