package Ġcom . info bip . k af k ist ry . webapp . controller Ċ Ċ import Ġcom . info bip . k af k ist ry . api .* Ċ import Ġcom . info bip . k af k ist ry . model . Kafka Cluster Identifier Ċ import Ġcom . info bip . k af k ist ry . service . generator . balance . Balance Settings Ċ import Ġcom . info bip . k af k ist ry . webapp . url . Clusters Urls Ċ import Ġcom . info bip . k af k ist ry . webapp . url . Clusters Urls . Companion . CL UST ERS Ċ import Ġcom . info bip . k af k ist ry . webapp . url . Clusters Urls . Companion . CL UST ERS _ ADD Ċ import Ġcom . info bip . k af k ist ry . webapp . url . Clusters Urls . Companion . CL UST ERS _ BAL ANCE Ċ import Ġcom . info bip . k af k ist ry . webapp . url . Clusters Urls . Companion . CL UST ERS _ EDIT Ċ import Ġcom . info bip . k af k ist ry . webapp . url . Clusters Urls . Companion . CL UST ERS _ INCREMENT AL _ BAL AN C ING Ċ import Ġcom . info bip . k af k ist ry . webapp . url . Clusters Urls . Companion . CL UST ERS _ INCREMENT AL _ BAL AN C ING _ SU G GEST ION Ċ import Ġcom . info bip . k af k ist ry . webapp . url . Clusters Urls . Companion . CL UST ERS _ INS PECT Ċ import Ġcom . info bip . k af k ist ry . webapp . url . Clusters Urls . Companion . CL UST ERS _ REMOVE Ċ import Ġcom . info bip . k af k ist ry . webapp . url . Clusters Urls . Companion . CL UST ERS _ RESOURCES Ċ import Ġorg . springframework . stereotype . Controller Ċ import Ġorg . springframework . web . bind . annotation .* Ċ import Ġorg . springframework . web . servlet . Model AndView Ċ Ċ @ Controller Ċ @ RequestMapping ("\ ${ app . http . root - path }$ CL UST ERS ") Ċ class ĠCl usters Controller ( ĊĠĠĠ Ġprivate Ġval Ġclusters Api : ĠCl usters Api , ĊĠĠĠ Ġprivate Ġval Ġtopics Api : ĠTop ics Api , ĊĠĠĠ Ġprivate Ġval Ġinspect Api : ĠIn spect Api , ĊĠĠĠ Ġprivate Ġval Ġcluster Bal ancing Api : ĠCluster Bal ancing Api , ĊĠĠĠ Ġprivate Ġval Ġresources Analyzer Api : ĠResource Analyzer Api , ĊĠĠĠ Ġprivate Ġval Ġexisting Values Api : ĠExisting Values Api , Ċ ) Ġ: ĠBaseController () Ġ{ ĊĊĠĠĠ Ġ@ GetMapping ĊĠĠĠ Ġfun Ġshow Clusters (): ĠModelAndView Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġclusters Ġ= Ġinspect Api . inspect Clusters () ĊĠĠĠĠĠĠĠ Ġval Ġpending Clusters Requests Ġ= Ġclusters Api . pending Clusters Requests () ĊĠĠĠĠĠĠĠ Ġreturn ĠModelAndView (" clusters / all ", Ġmutable Map Of ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" clusters " Ġto Ġclusters , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" pending Clusters Updates " Ġto Ġpending Clusters Requests ĊĠĠĠĠĠĠĠ Ġ)) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ GetMapping ( CL UST ERS _ ADD ) ĊĠĠĠ Ġfun Ġshow Add Cluster (): ĠModelAndView Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġexisting Values Ġ= Ġexisting Values Api . all () ĊĠĠĠĠĠĠĠ Ġreturn ĠModelAndView (" clusters / add ", Ġmap Of ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ" existing Values " Ġto Ġexisting Values ĊĠĠĠĠĠĠĠ Ġ)) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ GetMapping ( CL UST ERS _ EDIT ) ĊĠĠĠ Ġfun Ġshow Edit Cluster ( ĊĠĠĠĠĠĠĠ Ġ@ RequestParam (" cluster Identifier ") Ġcluster Identifier : ĠKafka Cluster Identifier ĊĠĠĠ Ġ): ĠModelAndView Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġcluster Ġ= Ġclusters Api . get Cluster ( cluster Identifier ) ĊĠĠĠĠĠĠĠ Ġval Ġexisting Values Ġ= Ġexisting Values Api . all () ĊĠĠĠĠĠĠĠ Ġreturn ĠModelAndView (" clusters / edit ", Ġmap Of ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ" cluster " Ġto Ġcluster , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ" existing Values " Ġto Ġexisting Values ĊĠĠĠĠĠĠĠ Ġ)) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ GetMapping ( CL UST ERS _ INS PECT ) ĊĠĠĠ Ġfun Ġshow Cluster ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ@ RequestParam (" cluster Identifier ") Ġcluster Identifier : ĠKafka Cluster Identifier ĊĠĠĠ Ġ): ĠModelAndView Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġcluster Statuses Ġ= Ġinspect Api . inspect Cluster ( cluster Identifier ) ĊĠĠĠĠĠĠĠ Ġval Ġcluster State Ġ= Ġinspect Api . cluster State ( cluster Identifier ) ĊĠĠĠĠĠĠĠ Ġval Ġpending Cluster Requests Ġ= Ġclusters Api . pending Clusters Requests ( cluster Identifier ) ĊĠĠĠĠĠĠĠ Ġval Ġpending Topics Requests Ġ= Ġtopics Api . pending Topics Requests () ĊĠĠĠĠĠĠĠ Ġreturn ĠModelAndView (" clusters / cluster ", Ġmutable Map Of ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" cluster " Ġto Ġcluster Statuses , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" cluster State " Ġto Ġcluster State , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" pending Cluster Requests " Ġto Ġpending Cluster Requests , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" pending Topics Requests " Ġto Ġpending Topics Requests , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" broker Config Doc " Ġto Ġexisting Values Api . all (). broker Config Doc , ĊĠĠĠĠĠĠĠ Ġ)) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ GetMapping ( CL UST ERS _ REMOVE ) ĊĠĠĠ Ġfun Ġshow Remove Cluster ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ@ RequestParam (" cluster Identifier ") Ġcluster Identifier : ĠKafka Cluster Identifier ĊĠĠĠ Ġ): ĠModelAndView Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġcluster Ġ= Ġclusters Api . get Cluster ( cluster Identifier ) ĊĠĠĠĠĠĠĠ Ġreturn ĠModelAndView (" clusters / remove ", Ġmutable Map Of ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" cluster " Ġto Ġcluster ĊĠĠĠĠĠĠĠ Ġ)) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ GetMapping ( CL UST ERS _ BAL ANCE ) ĊĠĠĠ Ġfun Ġshow Cluster Balance ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ@ RequestParam (" cluster Identifier ") Ġcluster Identifier : ĠKafka Cluster Identifier ĊĠĠĠ Ġ): ĠModelAndView Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġbalance Status Ġ= Ġcluster Bal ancing Api . getStatus ( cluster Identifier ) ĊĠĠĠĠĠĠĠ Ġreturn ĠModelAndView (" clusters / balance ", Ġmutable Map Of ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" cluster Identifier " Ġto Ġcluster Identifier , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" balance Status " Ġto Ġbalance Status , ĊĠĠĠĠĠĠĠ Ġ)) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ GetMapping ( CL UST ERS _ INCREMENT AL _ BAL AN C ING ) ĊĠĠĠ Ġfun Ġshow Global Bal ancing ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ@ RequestParam (" cluster Identifier ") Ġcluster Identifier : ĠKafka Cluster Identifier ĊĠĠĠ Ġ): ĠModelAndView Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġbalance Status Ġ= Ġcluster Bal ancing Api . getStatus ( cluster Identifier ) ĊĠĠĠĠĠĠĠ Ġreturn ĠModelAndView (" clusters / incremental Bal ancing ", Ġmutable Map Of ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" cluster Identifier " Ġto Ġcluster Identifier , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" balance Status " Ġto Ġbalance Status , ĊĠĠĠĠĠĠĠ Ġ)) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ PostMapping ( CL UST ERS _ INCREMENT AL _ BAL AN C ING _ SU G GEST ION ) ĊĠĠĠ Ġfun Ġshow Global Bal ancing Suggestion ( ĊĠĠĠĠĠĠĠ Ġ@ RequestParam (" cluster Identifier ") Ġcluster Identifier : ĠKafka Cluster Identifier , ĊĠĠĠĠĠĠĠ Ġ@ RequestBody Ġbalance Settings : ĠBalance Settings ĊĠĠĠ Ġ): ĠModelAndView Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġproposed Migrations Ġ= Ġcluster Bal ancing Api . get Pro posed Migrations ( cluster Identifier , Ġbalance Settings ) ĊĠĠĠĠĠĠĠ Ġreturn ĠModelAndView (" clusters / incremental Pro posed Migrations ", Ġmutable Map Of ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" cluster Identifier " Ġto Ġcluster Identifier , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" pro posed Migrations " Ġto Ġproposed Migrations , ĊĠĠĠĠĠĠĠ Ġ)) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ GetMapping ( CL UST ERS _ RESOURCES ) ĊĠĠĠ Ġfun Ġshow Cluster Resources ( ĊĠĠĠĠĠĠĠ Ġ@ RequestParam (" cluster Identifier ") Ġcluster Identifier : ĠKafka Cluster Identifier ĊĠĠĠ Ġ): ĠModelAndView Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġcluster Resources Ġ= Ġresources Analyzer Api . get Cluster Status ( cluster Identifier ) ĊĠĠĠĠĠĠĠ Ġreturn ĠModelAndView (" clusters / resources ", Ġmutable Map Of ( ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ" cluster Identifier " Ġto Ġcluster Identifier , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ" cluster Resources " Ġto Ġcluster Resources , ĊĠĠĠĠĠĠĠ Ġ)) ĊĠĠĠ Ġ} ĊĊ Ċ }