15
15
16
16
import com .fasterxml .jackson .databind .ObjectMapper ;
17
17
import com .google .common .base .Strings ;
18
- import com .google .common .collect .ImmutableList ;
19
18
import com .google .inject .Inject ;
20
19
import io .airlift .log .Logger ;
21
20
import io .trino .gateway .ha .clustermonitor .ClusterStats ;
@@ -90,7 +89,7 @@ public Response updateEntity(
90
89
EntityType entityType = EntityType .valueOf (entityTypeStr );
91
90
try {
92
91
switch (entityType ) {
93
- case GATEWAY_BACKEND :
92
+ case GATEWAY_BACKEND -> {
94
93
//TODO: make the gateway backend database sensitive
95
94
ProxyBackendConfiguration backend =
96
95
OBJECT_MAPPER .readValue (jsonPayload , ProxyBackendConfiguration .class );
@@ -105,13 +104,13 @@ public Response updateEntity(
105
104
ClusterStats .builder (backend .getName ())
106
105
.trinoStatus (trinoStatus )
107
106
.build ());
108
- break ;
109
- case RESOURCE_GROUP :
107
+ }
108
+ case RESOURCE_GROUP -> {
110
109
ResourceGroupsDetail resourceGroupDetails = OBJECT_MAPPER .readValue (jsonPayload ,
111
110
ResourceGroupsDetail .class );
112
111
resourceGroupsManager .updateResourceGroup (resourceGroupDetails , database );
113
- break ;
114
- case SELECTOR :
112
+ }
113
+ case SELECTOR -> {
115
114
SelectorsDetail selectorDetails = OBJECT_MAPPER .readValue (jsonPayload ,
116
115
SelectorsDetail .class );
117
116
List <SelectorsDetail > oldSelectorDetails =
@@ -123,8 +122,7 @@ public Response updateEntity(
123
122
else {
124
123
resourceGroupsManager .createSelector (selectorDetails , database );
125
124
}
126
- break ;
127
- default :
125
+ }
128
126
}
129
127
}
130
128
catch (IOException e ) {
@@ -143,15 +141,10 @@ public Response getAllEntitiesForType(
143
141
{
144
142
EntityType entityType = EntityType .valueOf (entityTypeStr );
145
143
146
- switch (entityType ) {
147
- case GATEWAY_BACKEND :
148
- return Response .ok (gatewayBackendManager .getAllBackends ()).build ();
149
- case RESOURCE_GROUP :
150
- return Response .ok (resourceGroupsManager .readAllResourceGroups (database )).build ();
151
- case SELECTOR :
152
- return Response .ok (resourceGroupsManager .readAllSelectors (database )).build ();
153
- default :
154
- }
155
- return Response .ok (ImmutableList .of ()).build ();
144
+ return switch (entityType ) {
145
+ case GATEWAY_BACKEND -> Response .ok (gatewayBackendManager .getAllBackends ()).build ();
146
+ case RESOURCE_GROUP -> Response .ok (resourceGroupsManager .readAllResourceGroups (database )).build ();
147
+ case SELECTOR -> Response .ok (resourceGroupsManager .readAllSelectors (database )).build ();
148
+ };
156
149
}
157
150
}
0 commit comments