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

Method deadline

conn.go:1511–1516  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

1509}
1510
1511func (d *connDeadline) deadline() time.Time {
1512 d.mutex.Lock()
1513 t := d.value
1514 d.mutex.Unlock()
1515 return t
1516}
1517
1518func (d *connDeadline) setDeadline(t time.Time) {
1519 d.mutex.Lock()

Callers 3

readDeadlineMethod · 0.80
writeDeadlineMethod · 0.80
ApiVersionsMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected