diff --git a/src/EventStoreSyncConnection.php b/src/EventStoreSyncConnection.php index ebb888a1..26cebebf 100644 --- a/src/EventStoreSyncConnection.php +++ b/src/EventStoreSyncConnection.php @@ -14,6 +14,9 @@ namespace Prooph\EventStoreClient; use Prooph\EventStoreClient\Internal\ListenerHandler; +use Prooph\EventStoreClient\Internal\PersistentSubscriptionCreateResult; +use Prooph\EventStoreClient\Internal\PersistentSubscriptionDeleteResult; +use Prooph\EventStoreClient\Internal\PersistentSubscriptionUpdateResult; interface EventStoreSyncConnection { @@ -122,6 +125,29 @@ public function getRawStreamMetadata(string $stream, ?UserCredentials $userCrede public function setSystemSettings(SystemSettings $settings, ?UserCredentials $userCredentials = null): WriteResult; + /** @throws Throwable */ + public function createPersistentSubscription( + string $stream, + string $groupName, + PersistentSubscriptionSettings $settings, + ?UserCredentials $userCredentials = null + ): PersistentSubscriptionCreateResult; + + /** @throws Throwable */ + public function updatePersistentSubscription( + string $stream, + string $groupName, + PersistentSubscriptionSettings $settings, + ?UserCredentials $userCredentials = null + ): PersistentSubscriptionUpdateResult; + + /** @throws Throwable */ + public function deletePersistentSubscription( + string $stream, + string $groupName, + ?UserCredentials $userCredentials = null + ): PersistentSubscriptionDeleteResult; + public function startTransaction( string $stream, int $expectedVersion,