Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumerService ¶
type ConsumerService struct {
// contains filtered or unexported fields
}
func NewConsumer ¶
func NewConsumer(brokers []string, topic string, consumerGroup string) (*ConsumerService, error)
func (*ConsumerService) Start ¶
func (kcs *ConsumerService) Start(process func(accessLog *Log)) error
func (*ConsumerService) Stop ¶
func (kcs *ConsumerService) Stop()
type ProducerClient ¶
type ProducerClient struct {
// contains filtered or unexported fields
}
func NewProducer ¶
func NewProducer(brokers []string, topic string) (*ProducerClient, error)
func (*ProducerClient) ProduceLog ¶
func (kpc *ProducerClient) ProduceLog(l *Log) error
func (*ProducerClient) Stop ¶
func (kpc *ProducerClient) Stop()
Click to show internal directories.
Click to hide internal directories.