MCPcopy Create free account
hub / github.com/cloudwego/eino-examples / CallbackInput

Struct CallbackInput

compose/batch/batch/types.go:98–101  ·  view source on GitHub ↗

CallbackInput is passed to callbacks.OnStart when batch processing begins.

Source from the content-addressed store, hash-verified

96
97// CallbackInput is passed to callbacks.OnStart when batch processing begins.
98type CallbackInput[I any] struct {
99 Inputs []I // All input items to be processed
100 MaxConcurrency int // Configured concurrency limit
101}
102
103// CallbackOutput is passed to callbacks.OnEnd when batch processing completes.
104type CallbackOutput[O any] struct {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected