MCPcopy
hub / github.com/IBM/sarama / Dial

Method Dial

broker_test.go:252–256  ·  view source on GitHub ↗
(_, _ string)

Source from the content-addressed store, hash-verified

250type closeImmediatelyDialer struct{}
251
252func (closeImmediatelyDialer) Dial(_, _ string) (net.Conn, error) {
253 client, server := net.Pipe()
254 _ = server.Close()
255 return client, nil
256}
257
258func TestBrokerOpenApiVersionsTransportError(t *testing.T) {
259 t.Parallel()

Callers 3

OpenMethod · 0.80
resolveCanonicalNamesMethod · 0.80

Calls 1

CloseMethod · 0.65

Tested by

no test coverage detected