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

Function RegisterOverride

protocol/protocol.go:230–245  ·  protocol/protocol.go::RegisterOverride
(req, res Message, key OverrideTypeKey)

Source from the content-addressed store, hash-verified

228var overrideApiTypes [numApis]map[OverrideTypeKey]apiType
229
230func RegisterOverride(req, res Message, key OverrideTypeKey) {
231 k1 := req.ApiKey()
232 k2 := res.ApiKey()
233
234 if k1 != k2 {
235 panic(fmt.Sprintf("[%T/%T]: request and response API keys mismatch: %d != %d", req, res, k1, k2))
236 }
237
238 if overrideApiTypes[k1] == nil {
239 overrideApiTypes[k1] = make(map[OverrideTypeKey]apiType)
240 }
241 overrideApiTypes[k1][key] = apiType{
242 requests: typesOf(req),
243 responses: typesOf(res),
244 }
245}
246
247func typesOf(v interface{}) []messageType {
248 return makeTypes(reflect.TypeOf(v).Elem())

Callers 1

initFunction · 0.92

Calls 2

typesOfFunction · 0.85
ApiKeyMethod · 0.65

Tested by

no test coverage detected