MCPcopy
hub / github.com/ccfos/nightingale / Producer

Interface Producer

pushgw/kafka/producer.go:41–44  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

39
40type (
41 Producer interface {
42 Send(*sarama.ProducerMessage) error
43 Close() error
44 }
45
46 AsyncProducerWrapper struct {
47 asyncProducer sarama.AsyncProducer

Callers 9

WriteMethod · 0.65
generateAISummaryMethod · 0.65
startEmailSenderFunction · 0.65
sendWebhookFunction · 0.65
GetOutboundIPFunction · 0.65
CloseMethod · 0.65
CloseMethod · 0.65
readDatadogBodyFunction · 0.65
falconPushMethod · 0.65

Implementers 2

AsyncProducerWrapperpushgw/kafka/producer.go
SyncProducerWrapperpushgw/kafka/producer.go

Calls

no outgoing calls

Tested by

no test coverage detected