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

Method SetDeadline

conn.go:563–567  ·  view source on GitHub ↗

SetDeadline sets the read and write deadlines associated with the connection. It is equivalent to calling both SetReadDeadline and SetWriteDeadline. A deadline is an absolute time after which I/O operations fail with a timeout (see type Error) instead of blocking. The deadline applies to all future

(t time.Time)

Source from the content-addressed store, hash-verified

561//
562// A zero value for t means I/O operations will not time out.
563func (c *Conn) SetDeadline(t time.Time) error {
564 c.rdeadline.setDeadline(t)
565 c.wdeadline.setDeadline(t)
566 return nil
567}
568
569// SetReadDeadline sets the deadline for future Read calls and any
570// currently-blocked Read call.

Callers 15

connectMethod · 0.95
ReadLagMethod · 0.95
SetOffsetAtMethod · 0.95
createTopicFunction · 0.45
deleteTopicFunction · 0.45
roundTripMethod · 0.45
initializeMethod · 0.45
readOffsetsMethod · 0.45
findCoordinatorMethod · 0.45
joinGroupMethod · 0.45
syncGroupMethod · 0.45

Calls 1

setDeadlineMethod · 0.80

Tested by 3

createTopicFunction · 0.36
deleteTopicFunction · 0.36