Documentation ¶
Index ¶
- Variables
- func CreateJudgeRequestConsumer(topics []string, group string)
- func CreateJudgeResponseConsumer(topics []string, group string)
- func InitAsyncProducer()
- func InitKafka(ctx context.Context)
- func InitProducer()
- func InitSyncProducer()
- func PublishMessageAsync(topic string, key, value []byte)
- func PublishMessageSync(topic string, key, value []byte) error
- type JudgeRequestConsumer
- type JudgeResponseConsumer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( Version sarama.KafkaVersion CancelCtx context.Context )
View Source
var ( SyncProducer sarama.SyncProducer AsyncProducer sarama.AsyncProducer )
View Source
var ( JudgeRequestDeliveryChan chan []byte JudgeResponseDeliveryChan chan []byte )
Functions ¶
func InitAsyncProducer ¶
func InitAsyncProducer()
func InitProducer ¶
func InitProducer()
func InitSyncProducer ¶
func InitSyncProducer()
func PublishMessageAsync ¶
func PublishMessageSync ¶
Types ¶
type JudgeRequestConsumer ¶
type JudgeRequestConsumer struct {
// contains filtered or unexported fields
}
func (*JudgeRequestConsumer) Cleanup ¶
func (consumer *JudgeRequestConsumer) Cleanup(sarama.ConsumerGroupSession) error
func (*JudgeRequestConsumer) ConsumeClaim ¶
func (consumer *JudgeRequestConsumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
func (*JudgeRequestConsumer) Setup ¶
func (consumer *JudgeRequestConsumer) Setup(sarama.ConsumerGroupSession) error
type JudgeResponseConsumer ¶
type JudgeResponseConsumer struct {
// contains filtered or unexported fields
}
func (*JudgeResponseConsumer) Cleanup ¶
func (consumer *JudgeResponseConsumer) Cleanup(sarama.ConsumerGroupSession) error
func (*JudgeResponseConsumer) ConsumeClaim ¶
func (consumer *JudgeResponseConsumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
func (*JudgeResponseConsumer) Setup ¶
func (consumer *JudgeResponseConsumer) Setup(sarama.ConsumerGroupSession) error
Click to show internal directories.
Click to hide internal directories.