command

type Command interface {
	// Run begins execution of the command on an input Record with given bindings, returning a record.Stream of results
	// and derivative bindings for that stream. Execution may continue asynchronously after return, until a call to
	// out.Next returns non-nil error (normally io.EOF).
	//
	// outBinds must be either binds itself or a derivative binding.
	//
	// Both Run and its returned record.Stream operate under ctx, and may return early with ctx.Err() on cancellation.
	//
	// Run is safe for concurrent use by multiple goroutines, and concurrent use with draining the record.Stream returned
	// by any previous call to Run.
	Run(ctx context.Context, in record.Record, binds *scope.Bindings) (out record.Stream, outBinds *scope.Bindings, err error)
}