Method InsertMany

rivertype/river_type.go:465–465

InsertMany is invoked around a batch insert operation. Implementations must always include a call to doInner to call down the middleware stack and perform the batch insertion, and may run custom code before and after. Returning an error from this function will fail the overarching insert operation,

(ctx context.Context, manyParams []*JobInsertParams, doInner func(context.Context) ([]*JobInsertResult, error))

	// Returning an error from this function will fail the overarching insert
	// operation, even if the inner insertion originally succeeded.
	InsertMany(ctx context.Context, manyParams []*JobInsertParams, doInner func(context.Context) ([]*JobInsertResult, error)) ([]*JobInsertResult, error)
}

// WorkerMiddleware provides an interface for middleware that integrations can