Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaConsumer ¶
type KafkaConsumer struct {
// contains filtered or unexported fields
}
func NewKafkaConsumer ¶
func NewKafkaConsumer(info constants.ConnectionInfo) *KafkaConsumer
func (*KafkaConsumer) RegisterChannel ¶
func (c *KafkaConsumer) RegisterChannel(channel string, processor constants.TaskProcessor) error
func (*KafkaConsumer) Stop ¶
func (c *KafkaConsumer) Stop()
func (*KafkaConsumer) Work ¶
func (c *KafkaConsumer) Work()
type KafkaProducer ¶
type KafkaProducer struct {
// contains filtered or unexported fields
}
func NewKafkaProducer ¶
func NewKafkaProducer(info constants.ConnectionInfo) *KafkaProducer
func (*KafkaProducer) Stop ¶
func (p *KafkaProducer) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.