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

Function readMapStringInt32

read.go:213–245  ·  view source on GitHub ↗
(r *bufio.Reader, sz int, v *map[string][]int32)

Source from the content-addressed store, hash-verified

211}
212
213func readMapStringInt32(r *bufio.Reader, sz int, v *map[string][]int32) (remain int, err error) {
214 var len int32
215 if remain, err = readInt32(r, sz, &len); err != nil {
216 return
217 }
218
219 content := make(map[string][]int32, len)
220 for i := 0; i < int(len); i++ {
221 var key string
222 var values []int32
223
224 if remain, err = readString(r, remain, &key); err != nil {
225 return
226 }
227
228 fn := func(r *bufio.Reader, size int) (fnRemain int, fnErr error) {
229 var value int32
230 if fnRemain, fnErr = readInt32(r, size, &value); fnErr != nil {
231 return
232 }
233 values = append(values, value)
234 return
235 }
236 if remain, err = readArrayWith(r, remain, fn); err != nil {
237 return
238 }
239
240 content[key] = values
241 }
242 *v = content
243
244 return
245}
246
247func read(r *bufio.Reader, sz int, a interface{}) (int, error) {
248 switch v := a.(type) {

Callers 2

TestReadMapStringInt32Function · 0.85
readFromMethod · 0.85

Calls 3

readStringFunction · 0.85
readArrayWithFunction · 0.85
readInt32Function · 0.70

Tested by 1

TestReadMapStringInt32Function · 0.68