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

Method Split

protocol/protocol.go:518–518  ·  view source on GitHub ↗

For a given cluster layout, returns the list of messages constructed from the receiver for each requests that should be sent to the cluster. The second return value is a Merger which can be used to merge back the results of each request into a single message (or an error).

(Cluster)

Source from the content-addressed store, hash-verified

516 // The second return value is a Merger which can be used to merge back the
517 // results of each request into a single message (or an error).
518 Split(Cluster) ([]Message, Merger, error)
519}
520
521// Merger is an interface implemented by messages which can merge multiple

Callers 4

roundTripMethod · 0.65
connectMethod · 0.65
getKafkaReaderFunction · 0.65
parseVersionFunction · 0.65

Implementers 4

Requestprotocol/describegroups/describegroups
Requestprotocol/listoffsets/listoffsets.go
Requestprotocol/describeconfigs/describeconfi
Requestprotocol/listgroups/listgroups.go

Calls

no outgoing calls

Tested by

no test coverage detected