Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetClientJWTmiddlewares ¶
SetClientJWTmiddlewares func
func SubmitKafkaPayload ¶
SubmitKafkaPayload submits payload to kafka
Types ¶
type Covid19KafkaHandlers ¶
type Covid19KafkaHandlers struct { KafkaConsumer sarama.Consumer PartitionConsumer sarama.PartitionConsumer }
Covid19KafkaHandlers type
func (*Covid19KafkaHandlers) Listen ¶
func (k *Covid19KafkaHandlers) Listen() ([]byte, error)
Listen to kafka
func (*Covid19KafkaHandlers) SetPartitionConsumer ¶
func (k *Covid19KafkaHandlers) SetPartitionConsumer(topic string) (err error)
SetPartitionConsumer func
Click to show internal directories.
Click to hide internal directories.