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

Method timeoutMs

client.go:144–146  ·  view source on GitHub ↗
(ctx context.Context, defaultTimeout time.Duration)

Source from the content-addressed store, hash-verified

142}
143
144func (c *Client) timeoutMs(ctx context.Context, defaultTimeout time.Duration) int32 {
145 return milliseconds(c.timeout(ctx, defaultTimeout))
146}

Callers 5

CreatePartitionsMethod · 0.95
RawProduceMethod · 0.95
DeleteTopicsMethod · 0.95
CreateTopicsMethod · 0.95
ProduceMethod · 0.95

Calls 2

timeoutMethod · 0.95
millisecondsFunction · 0.85

Tested by

no test coverage detected