MCPcopy Create free account

hub / github.com/Trendyol/kafka-shovel / functions

Functions27 in github.com/Trendyol/kafka-shovel

⨍ Functions 27◇ Types & classes 10
↓ 1 callersFunctionKafkaConfig
(version, clientId string)
main.go:122
↓ 1 callersFunctionNewConsumer
(connectionParams ConnectionParameters)
kafka/consumer.go:26
↓ 1 callersFunctionNewEventHandler
(service Service, notificationChannel chan string)
services/handler.go:22
↓ 1 callersFunctionNewProducer
(connectionParams ConnectionParameters)
kafka/producer.go:7
↓ 1 callersFunctionNewService
(producer sarama.SyncProducer, shovel Shovel)
services/service.go:27
↓ 1 callersMethodOperateEvent
(ctx context.Context, message *sarama.ConsumerMessage)
services/service.go:24
↓ 1 callersMethodStart
()
kafka/consumer.go:11
↓ 1 callersMethodStop
()
kafka/consumer.go:12
↓ 1 callersMethodSubscribe
(handler EventHandler)
kafka/consumer.go:10
↓ 1 callersMethoddoesMessageProcessed
(message *sarama.ConsumerMessage)
services/handler.go:57
↓ 1 callersFunctiongetInt
(s []byte)
services/service.go:83
↓ 1 callersFunctiongetRetryCountFromHeader
(message *sarama.ConsumerMessage)
services/service.go:74
↓ 1 callersFunctiongetShovels
(conf EnvConfig)
main.go:86
↓ 1 callersFunctionreplaceRetryCount
(message *sarama.ConsumerMessage, retryCount int)
services/service.go:56
↓ 1 callersFunctionrunKafkaShovelListener
(conf EnvConfig, shovel services.Shovel)
main.go:49
MethodCleanup
(sarama.ConsumerGroupSession)
services/handler.go:34
MethodCleanup
(sarama.ConsumerGroupSession)
kafka/consumer.go:17
MethodConsumeClaim
(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim)
services/handler.go:38
MethodConsumeClaim
(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim)
kafka/consumer.go:18
MethodOperateEvent
(ctx context.Context, message *sarama.ConsumerMessage)
services/service.go:34
MethodSetup
(session sarama.ConsumerGroupSession)
services/handler.go:30
MethodSetup
(sarama.ConsumerGroupSession)
kafka/consumer.go:16
MethodStart
()
kafka/consumer.go:61
MethodStop
()
kafka/consumer.go:65
MethodSubscribe
(handler EventHandler)
kafka/consumer.go:38
FunctionhealthCheck
(c *gin.Context)
main.go:158
Functionmain
()
main.go:26