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

Struct Conn

protocol/conn.go:11–17  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

9)
10
11type Conn struct {
12 buffer *bufio.Reader
13 conn net.Conn
14 clientID string
15 idgen int32
16 versions atomic.Value // map[ApiKey]int16
17}
18
19func NewConn(conn net.Conn, clientID string) *Conn {
20 return &Conn{

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected