Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrInvalidBatchSize = errors.New("batch size must be great than zero")
)
Functions ¶
func ScattergatherWithFuncs ¶ added in v0.1.1
ScattergatherWithFuncs executes multiple futures funtions Return error if anfuture has failed.
func ScattergatherWithInputParams ¶
func ScattergatherWithInputParams[K, V any](params []K, batchSize int, fn func([]K) ([]V, error)) ([]V, error)
ScattergatherWithInputParams executes with input params array. Input params array will be partitioned by batchSize Each batch is executed by fn Return errors if any params is failed.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.