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

Method requestHeader

conn.go:1432–1439  ·  view source on GitHub ↗
(apiKey apiKey, apiVersion apiVersion, correlationID int32)

Source from the content-addressed store, hash-verified

1430}
1431
1432func (c *Conn) requestHeader(apiKey apiKey, apiVersion apiVersion, correlationID int32) requestHeader {
1433 return requestHeader{
1434 ApiKey: int16(apiKey),
1435 ApiVersion: int16(apiVersion),
1436 CorrelationID: correlationID,
1437 ClientID: c.clientID,
1438 }
1439}
1440
1441func (c *Conn) ApiVersions() ([]ApiVersion, error) {
1442 deadline := &c.rdeadline

Callers 1

writeRequestMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected