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

Method writeTo

createtopics.go:290–296  ·  view source on GitHub ↗
(wb *writeBuffer)

Source from the content-addressed store, hash-verified

288}
289
290func (t createTopicsRequest) writeTo(wb *writeBuffer) {
291 wb.writeArray(len(t.Topics), func(i int) { t.Topics[i].writeTo(wb) })
292 wb.writeInt32(t.Timeout)
293 if t.v >= v1 {
294 wb.writeBool(t.ValidateOnly)
295 }
296}
297
298type createTopicsResponseTopicError struct {
299 v apiVersion

Callers

nothing calls this directly

Calls 4

writeArrayMethod · 0.80
writeBoolMethod · 0.80
writeToMethod · 0.65
writeInt32Method · 0.45

Tested by

no test coverage detected