2 * Copyright (c) 2014, 2015 Red Hat, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.neutron.northbound.api;
10 import com.webcohesion.enunciate.metadata.rs.ResponseCode;
11 import com.webcohesion.enunciate.metadata.rs.StatusCodes;
12 import java.net.HttpURLConnection;
13 import java.util.ArrayList;
14 import java.util.List;
15 import javax.inject.Inject;
16 import javax.inject.Singleton;
17 import javax.ws.rs.Consumes;
18 import javax.ws.rs.DELETE;
19 import javax.ws.rs.GET;
20 import javax.ws.rs.POST;
21 import javax.ws.rs.PUT;
22 import javax.ws.rs.Path;
23 import javax.ws.rs.PathParam;
24 import javax.ws.rs.Produces;
25 import javax.ws.rs.QueryParam;
26 import javax.ws.rs.core.MediaType;
27 import javax.ws.rs.core.Response;
28 import org.apache.aries.blueprint.annotation.service.Reference;
29 import org.opendaylight.neutron.spi.INeutronLoadBalancerListenerCRUD;
30 import org.opendaylight.neutron.spi.NeutronLoadBalancerListener;
33 * Neutron Northbound REST APIs for LoadBalancerListener Policies.
36 @Path("/lbaas/listeners")
37 public final class NeutronLoadBalancerListenerNorthbound extends AbstractNeutronNorthbound<NeutronLoadBalancerListener,
38 NeutronLoadBalancerListenerRequest, INeutronLoadBalancerListenerCRUD> {
40 private static final String RESOURCE_NAME = "LoadBalancerListener";
43 public NeutronLoadBalancerListenerNorthbound(@Reference INeutronLoadBalancerListenerCRUD neutronCRUD) {
48 protected String getResourceName() {
53 * Returns a list of all LoadBalancerListener.
56 @Produces({ MediaType.APPLICATION_JSON })
58 @ResponseCode(code = HttpURLConnection.HTTP_OK, condition = "Operation successful"),
59 @ResponseCode(code = HttpURLConnection.HTTP_UNAUTHORIZED, condition = "Unauthorized"),
60 @ResponseCode(code = HttpURLConnection.HTTP_NOT_IMPLEMENTED, condition = "Not Implemented"),
61 @ResponseCode(code = HttpURLConnection.HTTP_UNAVAILABLE, condition = "No providers available")
63 public Response listGroups(
65 @QueryParam("fields") List<String> fields,
66 // OpenStack LoadBalancerListener attributes
67 @QueryParam("id") String queryLoadBalancerListenerID,
68 @QueryParam("default_pool_id") String queryLoadBalancerListenerDefaultPoolID,
69 @QueryParam("tenant_id") String queryLoadBalancerListenerTenantID,
70 @QueryParam("name") String queryLoadBalancerListenerName,
71 @QueryParam("protocol") String queryLoadBalancerListenerProtocol,
72 @QueryParam("protocol_port") String queryLoadBalancerListenerProtocolPort,
73 @QueryParam("admin_state_up") Boolean queryLoadBalancerListenerAdminIsUp,
75 @QueryParam("limit") String limit,
76 @QueryParam("marker") String marker,
77 @QueryParam("page_reverse") String pageReverse
78 // sorting not supported
80 INeutronLoadBalancerListenerCRUD loadBalancerListenerInterface = getNeutronCRUD();
81 List<NeutronLoadBalancerListener> allLoadBalancerListeners = loadBalancerListenerInterface.getAll();
82 List<NeutronLoadBalancerListener> ans = new ArrayList<>();
83 for (NeutronLoadBalancerListener nsg : allLoadBalancerListeners) {
84 if ((queryLoadBalancerListenerID == null || queryLoadBalancerListenerID.equals(nsg.getID()))
85 && (queryLoadBalancerListenerDefaultPoolID == null || queryLoadBalancerListenerDefaultPoolID
86 .equals(nsg.getNeutronLoadBalancerListenerDefaultPoolID()))
87 && (queryLoadBalancerListenerTenantID == null
88 || queryLoadBalancerListenerTenantID.equals(nsg.getTenantID()))
89 && (queryLoadBalancerListenerName == null
90 || queryLoadBalancerListenerName.equals(nsg.getName()))
91 && (queryLoadBalancerListenerProtocol == null
92 || queryLoadBalancerListenerProtocol.equals(nsg.getNeutronLoadBalancerListenerProtocol()))
93 && (queryLoadBalancerListenerProtocolPort == null || queryLoadBalancerListenerProtocolPort
94 .equals(nsg.getNeutronLoadBalancerListenerProtocolPort()))
95 && (queryLoadBalancerListenerAdminIsUp == null || queryLoadBalancerListenerAdminIsUp
96 .equals(nsg.getLoadBalancerListenerAdminStateIsUp()))) {
97 if (fields.size() > 0) {
98 ans.add(nsg.extractFields(fields));
104 return Response.status(HttpURLConnection.HTTP_OK).entity(new NeutronLoadBalancerListenerRequest(ans)).build();
108 * Returns a specific LoadBalancerListener.
110 @Path("{loadBalancerListenerID}")
112 @Produces({ MediaType.APPLICATION_JSON })
114 @ResponseCode(code = HttpURLConnection.HTTP_OK, condition = "Operation successful"),
115 @ResponseCode(code = HttpURLConnection.HTTP_UNAUTHORIZED, condition = "Unauthorized"),
116 @ResponseCode(code = HttpURLConnection.HTTP_NOT_FOUND, condition = "Not Found"),
117 @ResponseCode(code = HttpURLConnection.HTTP_NOT_IMPLEMENTED, condition = "Not Implemented"),
118 @ResponseCode(code = HttpURLConnection.HTTP_UNAVAILABLE, condition = "No providers available")
120 public Response showLoadBalancerListener(@PathParam("loadBalancerListenerID") String loadBalancerListenerID,
122 @QueryParam("fields") List<String> fields) {
123 return show(loadBalancerListenerID, fields);
127 * Creates new LoadBalancerListener.
130 @Produces({ MediaType.APPLICATION_JSON })
131 @Consumes({ MediaType.APPLICATION_JSON })
133 @ResponseCode(code = HttpURLConnection.HTTP_CREATED, condition = "Created"),
134 @ResponseCode(code = HttpURLConnection.HTTP_UNAVAILABLE, condition = "No providers available")
136 public Response createLoadBalancerListeners(final NeutronLoadBalancerListenerRequest input) {
137 return create(input);
141 * Updates a LoadBalancerListener Policy.
143 @Path("{loadBalancerListenerID}")
145 @Produces({ MediaType.APPLICATION_JSON })
146 @Consumes({ MediaType.APPLICATION_JSON })
148 @ResponseCode(code = HttpURLConnection.HTTP_OK, condition = "Operation successful"),
149 @ResponseCode(code = HttpURLConnection.HTTP_NOT_FOUND, condition = "Not Found"),
150 @ResponseCode(code = HttpURLConnection.HTTP_UNAVAILABLE, condition = "No providers available")
152 public Response updateLoadBalancerListener(@PathParam("loadBalancerListenerID") String loadBalancerListenerID,
153 final NeutronLoadBalancerListenerRequest input) {
154 return update(loadBalancerListenerID, input);
158 * Deletes a LoadBalancerListener.
160 @Path("{loadBalancerListenerID}")
163 @ResponseCode(code = HttpURLConnection.HTTP_NO_CONTENT, condition = "No Content"),
164 @ResponseCode(code = HttpURLConnection.HTTP_NOT_FOUND, condition = "Not Found"),
165 @ResponseCode(code = HttpURLConnection.HTTP_UNAVAILABLE, condition = "No providers available")
167 public Response deleteLoadBalancerListener(@PathParam("loadBalancerListenerID") String loadBalancerListenerID) {
168 return delete(loadBalancerListenerID);