Documentation
¶
Index ¶
Constants ¶
View Source
const ( Kafka_Topic_Extractor_EventOnChain = "Kafka_Topic_Extractor_EventOnChain" Kafka_Group_RelayCluster_EventOnChain = "Kafka_Group_RelayCluster_EventOnChain" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumerRegister ¶
type ConsumerRegister struct {
// contains filtered or unexported fields
}
func (*ConsumerRegister) Close ¶
func (cr *ConsumerRegister) Close()
func (*ConsumerRegister) Initialize ¶
func (cr *ConsumerRegister) Initialize(brokerList []string)
func (*ConsumerRegister) RegisterTopicAndHandler ¶
func (cr *ConsumerRegister) RegisterTopicAndHandler(topic string, groupId string, data interface{}, action HandlerFunc) error
type HandlerFunc ¶
type HandlerFunc func(event interface{}) error
type KafkaOptions ¶
type KafkaOptions struct {
Brokers []string
}
type MessageProducer ¶
type MessageProducer struct {
// contains filtered or unexported fields
}
func (*MessageProducer) Close ¶
func (md *MessageProducer) Close() error
func (*MessageProducer) Initialize ¶
func (md *MessageProducer) Initialize(brokerList []string) (err error)
func (*MessageProducer) SendMessage ¶
Source Files
Click to show internal directories.
Click to hide internal directories.