Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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
144
func
(c *Client) timeoutMs(ctx context.Context, defaultTimeout time.Duration) int32 {
145
return
milliseconds(c.timeout(ctx, defaultTimeout))
146
}
Callers
5
CreatePartitions
Method · 0.95
RawProduce
Method · 0.95
DeleteTopics
Method · 0.95
CreateTopics
Method · 0.95
Produce
Method · 0.95
Calls
2
timeout
Method · 0.95
milliseconds
Function · 0.85
Tested by
no test coverage detected