package Ġnet . h ane k awa . k af k ak ai ju Ċ Ċ import Ġgraphql . Execution Result Ċ import Ġgraphql . GraphQL Ċ import Ġgraphql . schema . idl . Runtime W iring Ċ import Ġgraphql . schema . idl . Schema Generator Ċ import Ġgraphql . schema . idl . Schema Parser Ċ Ċ class ĠK ai ju GraphQL ( val Ġcluster StateManager : ĠCluster StateManager ) Ġ{ ĊĠĠĠ Ġcompanion Ġobject Ġ{ ĊĠĠĠĠĠĠĠ Ġval ĠLOG Ġ= Ġget Logger ( this :: class . java ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprivate Ġval Ġschema Parser Ġ= ĠSchema Parser () ĊĠĠĠ Ġprivate Ġval Ġschema Generator Ġ= ĠSchema Generator () ĊĊĠĠĠ Ġprivate Ġval Ġschema File Ġ= Ġthis :: class . java . getResource (" ../../../ k af k ak ai ju . graphql s "). read Text () ĊĊĠĠĠ Ġprivate Ġval Ġtype Registry Ġ= Ġschema Parser . parse ( schema File ) ĊĠĠĠ Ġprivate Ġval Ġw iring Ġ= Ġbuild Runtime W iring () ĊĠĠĠ Ġprivate Ġval Ġgraph QL Schema Ġ= Ġschema Generator . make Executable Schema ( type Registry , Ġw iring ) ĊĊĠĠĠ Ġprivate Ġval Ġgraph QL Ġ= ĠGraphQL . new GraphQL ( graph QL Schema ). build () ĊĊĠĠĠ Ġfun Ġexecute ( request String : ĠString , Ġoperation Name : ĠString ? Ġ= Ġnull , Ġarguments : ĠMap < String , ĠAny >? Ġ= Ġnull ): ĠExecution Result Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġgraph QL . execute ( request String , Ġoperation Name , Ġnull , Ġarguments Ġ?: Ġempty Map ()) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprivate Ġfun Ġbuild Runtime W iring (): ĠRuntime W iring Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠRuntime W iring . new Runtime W iring () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. type (" Query Type ", Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit . data Fetcher (" bro kers ", Ġ{ Ġenvironment Ġ-> ĊĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġdata Ġclass ĠFoo ( val Ġid : ĠInt , Ġval Ġhost : ĠString , Ġval Ġport : ĠInt , Ġval Ġrack : ĠString ) ĊĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠKafka K ai ju App . LOG . info (" environment Ġarguments : Ġ" Ġ+ Ġenvironment . arguments ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠKafka K ai ju App . LOG . info (" environment Ġfields : Ġ" Ġ+ Ġenvironment . fields ) ĊĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġcluster StateManager . getNode ById s ( cluster StateManager . getNode Ids ()). map Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit . let Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠFoo ( id Ġ= Ġit !!. id (), Ġhost Ġ= Ġit !!. host (), Ġport Ġ= Ġit !!. port (), Ġrack Ġ= Ġit !!. rack ()) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ}) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ}) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. build () ĊĠĠĠ Ġ} Ċ }