| 130 | } |
| 131 | |
| 132 | type ApiVersionsResponse struct { |
| 133 | // Version defines the protocol version to use for encode and decode |
| 134 | Version int16 |
| 135 | // ErrorCode contains the top-level error code. |
| 136 | ErrorCode int16 |
| 137 | // ApiKeys contains the APIs supported by the broker. |
| 138 | ApiKeys []ApiVersionsResponseKey |
| 139 | // ThrottleTimeMs contains the duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota. |
| 140 | ThrottleTimeMs int32 |
| 141 | // SupportedFeatures contains the features supported by the broker. (v3+, tag 0) |
| 142 | SupportedFeatures []SupportedFeatureKey |
| 143 | // FinalizedFeaturesEpoch contains the monotonically increasing epoch for the finalized features information, or -1 if unknown. (v3+, tag 1) |
| 144 | FinalizedFeaturesEpoch int64 |
| 145 | // FinalizedFeatures contains the cluster-wide finalized features; the information is only valid if FinalizedFeaturesEpoch >= 0. (v3+, tag 2) |
| 146 | FinalizedFeatures []FinalizedFeatureKey |
| 147 | } |
| 148 | |
| 149 | func (r *ApiVersionsResponse) setVersion(v int16) { |
| 150 | r.Version = v |
nothing calls this directly
no outgoing calls
no test coverage detected