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

Method readOperation

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

Source from the content-addressed store, hash-verified

1325}
1326
1327func (c *Conn) readOperation(write func(time.Time, int32) error, read func(time.Time, int) error) error {
1328 return c.do(&c.rdeadline, write, read)
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)

Callers 8

ControllerMethod · 0.95
BrokersMethod · 0.95
findCoordinatorMethod · 0.95
listGroupsMethod · 0.95
offsetFetchMethod · 0.95
syncGroupMethod · 0.95
readOffsetMethod · 0.95
ReadPartitionsMethod · 0.95

Calls 1

doMethod · 0.95

Tested by

no test coverage detected