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

Function TCP

address.go:9–9  ·  view source on GitHub ↗

TCP constructs an address with the network set to "tcp".

(address ...string)

Source from the content-addressed store, hash-verified

7
8// TCP constructs an address with the network set to "tcp".
9func TCP(address ...string) net.Addr { return makeNetAddr("tcp", address) }
10
11func makeNetAddr(network string, addresses []string) net.Addr {
12 switch len(addresses) {

Callers 15

TestOffsetFetchRequestWithNoTopicFunction · 0.85
TestOffsetFetchRequestWithOneTopicFunction · 0.85
waitForTopicFunction · 0.85
testReaderConsumerGroupReadContentAcrossPartitionsFunction · 0.85
testReaderConsumerGroupRebalanceFunction · 0.85
testReaderConsumerGroupRebalanceAcrossTopicsFunction · 0.85
testReaderConsumerGroupRebalanceAcrossManyPartitionsAndConsumersFunction · 0.85
TestConsumerGroupWithMissingTopicFunction · 0.85
TestConsumerGroupWithTopicFunction · 0.85
TestConsumerGroupWithGroupTopicsSingleFunction · 0.85
TestConsumerGroupWithGroupTopicsMultipleFunction · 0.85
TestClientInitProducerIdFunction · 0.85

Calls 1

makeNetAddrFunction · 0.85

Tested by 15

TestOffsetFetchRequestWithNoTopicFunction · 0.68
TestOffsetFetchRequestWithOneTopicFunction · 0.68
waitForTopicFunction · 0.68
testReaderConsumerGroupReadContentAcrossPartitionsFunction · 0.68
testReaderConsumerGroupRebalanceFunction · 0.68
testReaderConsumerGroupRebalanceAcrossTopicsFunction · 0.68
testReaderConsumerGroupRebalanceAcrossManyPartitionsAndConsumersFunction · 0.68
TestConsumerGroupWithMissingTopicFunction · 0.68
TestConsumerGroupWithTopicFunction · 0.68
TestConsumerGroupWithGroupTopicsSingleFunction · 0.68
TestConsumerGroupWithGroupTopicsMultipleFunction · 0.68
TestClientInitProducerIdFunction · 0.68