runner

package

v0.5.0 Latest Latest Go to latest Published: Jul 16, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type BatchExecutor[I any, O any] interface {
	Execute(input I) (O, error)
}

func NewBatchExecutor[I any, O any](executor ExecuteFunc[I, Output[O]], capacity int, timeout time.Duration) BatchExecutor[I, O]

func NewSerialExecutor[I any, O any](executor ExecuteFunc[I, Output[O]]) BatchExecutor[I, O]

type BatchRunner[V any] interface {
	Run(v V) error
}

func NewBatchRunner[V any](runner func([]V) []error, capacity int, timeout time.Duration) BatchRunner[V]

func NewSerialRunner[V any](runner ExecuteFunc[V, error]) BatchRunner[V]

type ExecuteFunc[I any, O any] func([]I) []O

type Output[O any] struct {
	Val O
	Err error
}