package Ġio . ark it ik . tr av ako . operation . runner . operation Ċ Ċ import Ġio . ark it ik . radix . develop . operation . ext . operation Builder Ċ import Ġio . ark it ik . radix . develop . shared . ext . not Accept able Ċ import Ġio . ark it ik . tr av ako . core . domain . runner . Scheduler Runner Domain Ċ import Ġio . ark it ik . tr av ako . core . domain . runner . embedded . InstanceState Ċ import Ġio . ark it ik . tr av ako . core . domain . server . Server Domain Ċ import Ġio . ark it ik . tr av ako . function . transaction . Transactional Executor Ċ import Ġio . ark it ik . tr av ako . operation . runner . errors . Runner Errors Ċ import Ġio . ark it ik . tr av ako . store . runner . query . Scheduler Runner Store Query Ċ Ċ /** Ċ Ġ* ĠCreated ĠBy Ġ[* I br ah im ĠAl - T am imi Ġ ï £ ¿ * ]( https :// www . linkedin . com / in / ilo om /) Ċ Ġ* ĠCreated ĠAt Ġ 2 5 Ġ 9 : 1 9 ĠPM , Ġ** Sat , ĠDecember Ġ 2 0 2 1 ** Ċ Ġ* ĠProject Ġ* tr av ako * Ġ[ ark it ik . io ]( https :// ark it ik . io ) Ċ Ġ*/ Ċ class ĠFetch Ol dest Heartbeat Runner Operation Provider ( ĊĠĠĠ Ġprivate Ġval Ġscheduler Runner Store Query : ĠScheduler Runner Store Query , ĊĠĠĠ Ġprivate Ġval Ġtransaction al Executor : ĠTransaction al Executor , Ċ ) Ġ{ ĊĠĠĠ Ġval Ġfetch Ol dest Heartbeat Runner Ġ= Ġoperation Builder < Server Domain , ĠScheduler Runner Domain > Ġ{ ĊĠĠĠĠĠĠĠ Ġmain Operation Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġtransaction al Executor . run On Transaction Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġwith ( scheduler Runner Store Query ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġfind Server Ol dest Runner By Heartbeat And Status ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġserver Ġ= Ġthis @ main Operation , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġstatus Ġ= ĠInstance State . UP ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ) Ġ?: Ġthrow ĠRunner Errors . NO _ REGISTER ED _ RUN NER . not Accept able () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} Ġ?: Ġthrow ĠRunner Errors . NO _ REGISTER ED _ RUN NER . not Accept able () ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ } Ċ