Method BatchCheck

internal/check/engine.go:272–303

BatchCheck makes parallelized check requests for tuples. The check results are returned as slice, where the result index matches the tuple index of the incoming tuples array.

(ctx context.Context,
	tuples []*ketoapi.RelationTuple,
	maxDepth int)

// BatchCheck makes parallelized check requests for tuples. The check results are returned as slice, where the
// result index matches the tuple index of the incoming tuples array.
func (e *Engine) BatchCheck(ctx context.Context,
	tuples []*ketoapi.RelationTuple,
	maxDepth int) ([]checkgroup.Result, error) {

	eg := &errgroup.Group{}
	eg.SetLimit(e.d.Config(ctx).BatchCheckParallelizationLimit())

	mapper := e.d.ReadOnlyMapper()
	results := make([]checkgroup.Result, len(tuples))
	for i, tuple := range tuples {
		i := i
		tuple := tuple
		eg.Go(func() error {
			internalTuple, err := mapper.FromTuple(ctx, tuple)
			if err != nil {
				results[i] = checkgroup.Result{
					Membership: checkgroup.MembershipUnknown,
					Err:        err,
				}
			} else {
				results[i] = e.CheckRelationTuple(ctx, internalTuple[0], maxDepth)
			}
			return nil
		})
	}

	if err := eg.Wait(); err != nil {
		return nil, err
	}

	return results, nil
}