diff --git a/internal/eventstore/v2/abstraction.go b/internal/eventstore/v2/abstraction.go deleted file mode 100644 index 0716490f57..0000000000 --- a/internal/eventstore/v2/abstraction.go +++ /dev/null @@ -1,18 +0,0 @@ -package eventstore - -import "context" - -func PushAggregate(ctx context.Context, es *Eventstore, writeModel queryReducer, aggregate *Aggregate) error { - err := es.FilterToQueryReducer(ctx, writeModel) - if err != nil { - return err - } - - events, err := es.PushAggregates(ctx, aggregate) - if err != nil { - return err - } - - writeModel.AppendEvents(events...) - return writeModel.Reduce() -}