()
| 246 | } |
| 247 | |
| 248 | func (t createTopicsRequestV0Topic) size() int32 { |
| 249 | return sizeofString(t.Topic) + |
| 250 | sizeofInt32(t.NumPartitions) + |
| 251 | sizeofInt16(t.ReplicationFactor) + |
| 252 | sizeofArray(len(t.ReplicaAssignments), func(i int) int32 { return t.ReplicaAssignments[i].size() }) + |
| 253 | sizeofArray(len(t.ConfigEntries), func(i int) int32 { return t.ConfigEntries[i].size() }) |
| 254 | } |
| 255 | |
| 256 | func (t createTopicsRequestV0Topic) writeTo(wb *writeBuffer) { |
| 257 | wb.writeString(t.Topic) |
nothing calls this directly
no test coverage detected