Function NewDeleteQuery

runtime/exec/delete.go:18–23

(rctx *runtime.Context, puller vio.Puller, deletes *sync.Map)

var _ runtime.DeleteQuery = (*DeleteQuery)(nil)

func NewDeleteQuery(rctx *runtime.Context, puller vio.Puller, deletes *sync.Map) *DeleteQuery {
	return &DeleteQuery{
		Query:   NewQuery(rctx, puller, nil),
		deletes: deletes,
	}
}

func (d *DeleteQuery) DeletionSet() []ksuid.KSUID {
	var ids []ksuid.KSUID