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

Method writeOperation

conn.go:1331–1333  ·  view source on GitHub ↗
(write func(time.Time, int32) error, read func(time.Time, int) error)

Source from the content-addressed store, hash-verified

1329}
1330
1331func (c *Conn) writeOperation(write func(time.Time, int32) error, read func(time.Time, int) error) error {
1332 return c.do(&c.wdeadline, write, read)
1333}
1334
1335func (c *Conn) enter() {
1336 atomic.AddInt32(&c.inflight, +1)

Callers 9

heartbeatMethod · 0.95
joinGroupMethod · 0.95
leaveGroupMethod · 0.95
offsetCommitMethod · 0.95
saslHandshakeMethod · 0.95
saslAuthenticateMethod · 0.95
deleteTopicsMethod · 0.95
createTopicsMethod · 0.95

Calls 1

doMethod · 0.95

Tested by

no test coverage detected