MCPcopy
hub / github.com/segmentio/kafka-go / newLocalClient

Function newLocalClient

client_test.go:82–84  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

80}
81
82func newLocalClient() (*Client, func()) {
83 return newClient(TCP("localhost"))
84}
85
86func newClient(addr net.Addr) (*Client, func()) {
87 conns := &ktesting.ConnWaitGroup{

Callers 15

TestClientJoinGroupFunction · 0.70
TestClientCreatePartitionsFunction · 0.70
TestClientCreatePartitionsNoAssignmentsFunction · 0.70
TestCloseLeavesGroupFunction · 0.70
testReaderConsumerGroupReadContentAcrossPartitionsFunction · 0.70
testReaderConsumerGroupRebalanceFunction · 0.70
testReaderConsumerGroupRebalanceAcrossManyPartitionsAndConsumersFunction · 0.70
TestConsumerGroupWithGroupTopicsMultipleFunction · 0.70
TestClientCreateACLsFunction · 0.70
TestDescribeUserScramCredentialsFunction · 0.70
TestClientApiVersionsFunction · 0.70
TestClientCreateTopicsFunction · 0.70

Calls 2

TCPFunction · 0.85
newClientFunction · 0.70

Tested by

no test coverage detected