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

Method SetWriteDeadline

conn.go:582–585  ·  view source on GitHub ↗

SetWriteDeadline sets the deadline for future Write calls and any currently-blocked Write call. Even if write times out, it may return n > 0, indicating that some of the data was successfully written. A zero value for t means Write will not time out.

(t time.Time)

Source from the content-addressed store, hash-verified

580// data was successfully written.
581// A zero value for t means Write will not time out.
582func (c *Conn) SetWriteDeadline(t time.Time) error {
583 c.wdeadline.setDeadline(t)
584 return nil
585}
586
587// Offset returns the current offset of the connection as pair of integers,
588// where the first one is an offset value and the second one indicates how

Callers 2

setDeadlineMethod · 0.45
setConnWriteDeadlineMethod · 0.45

Calls 1

setDeadlineMethod · 0.80

Tested by

no test coverage detected