MCPcopy
hub / github.com/uber/aresdb / kafka_test.go

File kafka_test.go

subscriber/common/sink/kafka_test.go:None–None  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1package sink
2
3import (
4 "encoding/json"

Callers

nothing calls this directly

Calls 10

NewKafkaPublisherFunction · 0.85
SetNamespaceMethod · 0.80
SetPrimaryKeyBytesMethod · 0.80
WriteMethod · 0.65
StartMethod · 0.65
StringMethod · 0.65
CloseMethod · 0.65
ClusterMethod · 0.65
SaveMethod · 0.65
ShutdownMethod · 0.65

Tested by

no test coverage detected