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

Method SetReadDeadline

conn.go:572–575  ·  view source on GitHub ↗

SetReadDeadline sets the deadline for future Read calls and any currently-blocked Read call. A zero value for t means Read will not time out.

(t time.Time)

Source from the content-addressed store, hash-verified

570// currently-blocked Read call.
571// A zero value for t means Read will not time out.
572func (c *Conn) SetReadDeadline(t time.Time) error {
573 c.rdeadline.setDeadline(t)
574 return nil
575}
576
577// SetWriteDeadline sets the deadline for future Write calls and any
578// currently-blocked Write call.

Callers 4

readPartitionFunction · 0.95
setDeadlineMethod · 0.45
setConnReadDeadlineMethod · 0.45
readMethod · 0.45

Calls 1

setDeadlineMethod · 0.80

Tested by 1

readPartitionFunction · 0.76