*/ #[Query] #[Module(\Modules::KAFKA)] public function changes(int $limit = 100): iterable { return $this->changesUtil->getChanges($limit); } /** * Potvrdí zpracování všech změn, které mají ID menší než specifikované ID. * * Volání `changesConfirm` stačí provádět vždy po zpracování dávky změn - např. načtu 100 změn, zpracuji je a na konci zavolám * `changesConfirm` s nejvyšším ID zpracované změny. */ #[Mutation] #[Module(\Modules::KAFKA)] public function changesConfirm(int $changeId): MutateResponse { return $this->changesUtil->confirmChanges($changeId); } /** * Nastaví změny zpět k danému datumu a času – např. při potřebě opětovné synchronizace. */ #[Mutation] #[Module(\Modules::KAFKA)] public function changesReset(\DateTimeInterface $date): ChangesResetMutateResponse { return $this->changesUtil->resetChanges($date); } }