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

Function arrayEncodeFuncOf

protocol/encode.go:496–511  ·  view source on GitHub ↗
(typ reflect.Type, version int16, flexible bool, tag structTag)

Source from the content-addressed store, hash-verified

494}
495
496func arrayEncodeFuncOf(typ reflect.Type, version int16, flexible bool, tag structTag) encodeFunc {
497 elemType := typ.Elem()
498 elemFunc := encodeFuncOf(elemType, version, flexible, tag)
499 switch {
500 case flexible && tag.Nullable:
501 // In flexible messages, all arrays are compact
502 return func(e *encoder, v value) { e.encodeCompactNullArray(v, elemType, elemFunc) }
503 case flexible:
504 // In flexible messages, all arrays are compact
505 return func(e *encoder, v value) { e.encodeCompactArray(v, elemType, elemFunc) }
506 case tag.Nullable:
507 return func(e *encoder, v value) { e.encodeNullArray(v, elemType, elemFunc) }
508 default:
509 return func(e *encoder, v value) { e.encodeArray(v, elemType, elemFunc) }
510 }
511}
512
513func writerEncodeFuncOf(typ reflect.Type) encodeFunc {
514 typ = reflect.PtrTo(typ)

Callers 1

encodeFuncOfFunction · 0.85

Calls 5

encodeFuncOfFunction · 0.85
encodeCompactArrayMethod · 0.80
encodeNullArrayMethod · 0.80
encodeArrayMethod · 0.80

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…