import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
@POST
@Produces(Protocol.MIME_TYPES_ALL)
@Consumes(Protocol.MIME_TYPES_RDF)
@TypeHint(Stream.class)
public Response post(final Stream<Statement> statements) throws OperationException {

	closeOnCompletion(statements);

	// Validate preconditions and handle probe requests here, before body is consumed
	// POST URI does not support GET, hence no tag and last modified
	init(true, null);

	Outcome outcome = getSession().sparqlupdate().statements(statements).exec();

	// Setup the response stream
	final int httpStatus = outcome.getStatus().getHTTPStatus();
	final Stream<Outcome> entity = Stream.create(outcome);

	// Stream the result to the client
	return newResponseBuilder(httpStatus, entity, Protocol.STREAM_OF_OUTCOMES).build();
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
@POST
@Produces(Protocol.MIME_TYPES_ALL)
@Consumes(Protocol.MIME_TYPES_RDF)
@TypeHint(Stream.class)
public Response post(final Stream<Statement> statements) throws OperationException {

	closeOnCompletion(statements);

	// Validate preconditions and handle probe requests here, before body is consumed
	// POST URI does not support GET, hence no tag and last modified
	init(true, null);

	Outcome outcome = getSession().sparqldelete().statements(statements).exec();

	// Setup the response stream
	final int httpStatus = outcome.getStatus().getHTTPStatus();
	final Stream<Outcome> entity = Stream.create(outcome);

	// Stream the result to the client
	return newResponseBuilder(httpStatus, entity, Protocol.STREAM_OF_OUTCOMES).build();
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
/**
 * Returns a list of static routes present on the given container
 *
 * @param containerName Name of the Container. The Container name for the base controller is "default".
 * @return List of configured static routes on the given container
 */
@Path("/{containerName}")
@GET
@Produces( { MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@TypeHint(StaticRoutes.class)
@StatusCodes( {
        @ResponseCode(code = 200, condition = "Operation successful"),
        @ResponseCode(code = 404, condition = "The containerName passed was not found") })
public StaticRoutes getStaticRoutes(
        @PathParam("containerName") String containerName) {

    if(!NorthboundUtils.isAuthorized(getUserName(), containerName,
            Privilege.WRITE, this)){
        throw new
            UnauthorizedException("User is not authorized to perform this operation on container "
                        + containerName);
    }
    return new StaticRoutes(getStaticRoutesInternal(containerName));
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
/**
 * Returns a list of Flows configured on the given container
 *
 * @param containerName
 *            Name of the Container. The Container name for the base
 *            controller is "default".
 * @return List of configured flows configured on a given container
 */
@Path("/{containerName}")
@GET
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@TypeHint(FlowConfigs.class)
@StatusCodes({
        @ResponseCode(code = 200, condition = "Operation successful"),
        @ResponseCode(code = 404, condition = "The containerName is not found"),
        @ResponseCode(code = 503, condition = "One or more of Controller Services are unavailable") })
public FlowConfigs getStaticFlows(
        @PathParam("containerName") String containerName) {
    if (!NorthboundUtils.isAuthorized(
            getUserName(), containerName, Privilege.READ, this)) {
        throw new UnauthorizedException(
                "User is not authorized to perform this operation on container "
                        + containerName);
    }

    List<FlowConfig> flowConfigs = getStaticFlowsInternal(containerName,
            null);
    return new FlowConfigs(flowConfigs);
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
/**
 *
 * Add ports to a subnet
 *
 * @param containerName
 *            Name of the Container
 * @param name
 *            Name of the SubnetConfig to be modified
 * @param subnetConfigData
 *            the {@link SubnetConfig} structure in JSON passed as a POST
 *            parameter
 * @return If the operation is successful or not
 */
@Path("/{containerName}/{subnetName}/add")
@POST
@Consumes({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@StatusCodes({
    @ResponseCode(code = 202, condition = "Operation successful"),
    @ResponseCode(code = 400, condition = "Invalid request"),
    @ResponseCode(code = 404, condition = "The containerName or subnetName is not found"),
    @ResponseCode(code = 500, condition = "Internal server error") })
public Response addNodePorts(
        @PathParam("containerName") String containerName,
        @PathParam("subnetName") String name,
        @TypeHint(SubnetConfig.class) JAXBElement<SubnetConfig> subnetConfigData) {

    SubnetConfig subnetConf = subnetConfigData.getValue();
    return addOrDeletePorts(containerName, name, subnetConf, "add");
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
/**
 *
 * Delete ports from a subnet
 *
 * @param containerName
 *            Name of the Container
 * @param name
 *            Name of the SubnetConfig to be modified
 * @param subnetConfigData
 *            the {@link SubnetConfig} structure in JSON passed as a POST
 *            parameter
 * @return If the operation is successful or not
 */
@Path("/{containerName}/{subnetName}/delete")
@POST
@Consumes({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@StatusCodes({
    @ResponseCode(code = 202, condition = "Operation successful"),
    @ResponseCode(code = 400, condition = "Invalid request"),
    @ResponseCode(code = 404, condition = "The containerName or subnetName is not found"),
    @ResponseCode(code = 500, condition = "Internal server error") })
public Response deleteNodePorts(
        @PathParam("containerName") String containerName,
        @PathParam("subnetName") String name,
        @TypeHint(SubnetConfig.class) JAXBElement<SubnetConfig> subnetConfigData) {

    SubnetConfig subnetConf = subnetConfigData.getValue();
    return addOrDeletePorts(containerName, name, subnetConf, "delete");
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
/**
 * Returns a list of all Hosts : both configured via PUT API and dynamically
 * learnt on the network.
 *
 * @param containerName
 *            Name of the Container. The Container name for the base
 *            controller is "default".
 * @return List of Active Hosts.
 */
@Path("/{containerName}")
@GET
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@TypeHint(Hosts.class)
@StatusCodes({
        @ResponseCode(code = 200, condition = "Operation successful"),
        @ResponseCode(code = 404, condition = "The containerName is not found"),
        @ResponseCode(code = 503, condition = "One or more of Controller Services are unavailable") })
public Hosts getActiveHosts(@PathParam("containerName") String containerName) {

    if (!NorthboundUtils.isAuthorized(
            getUserName(), containerName, Privilege.READ, this)) {
        throw new UnauthorizedException(
                "User is not authorized to perform this operation on container "
                        + containerName);
    }
    IfIptoHost hostTracker = getIfIpToHostService(containerName);
    if (hostTracker == null) {
        throw new ServiceUnavailableException("Host Tracker "
                + RestMessages.SERVICEUNAVAILABLE.toString());
    }

    return new Hosts(hostTracker.getAllHosts());
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
/**
 * Returns a list of Hosts that are statically configured and are connected
 * to a NodeConnector that is down.
 *
 * @param containerName
 *            Name of the Container. The Container name for the base
 *            controller is "default".
 * @return List of inactive Hosts.
 */
@Path("/{containerName}/inactive")
@GET
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@TypeHint(Hosts.class)
@StatusCodes({
        @ResponseCode(code = 200, condition = "Operation successful"),
        @ResponseCode(code = 404, condition = "The containerName is not found"),
        @ResponseCode(code = 503, condition = "One or more of Controller Services are unavailable") })
public Hosts getInactiveHosts(
        @PathParam("containerName") String containerName) {
    if (!NorthboundUtils.isAuthorized(
            getUserName(), containerName, Privilege.READ, this)) {
        throw new UnauthorizedException(
                "User is not authorized to perform this operation on container "
                        + containerName);
    }
    IfIptoHost hostTracker = getIfIpToHostService(containerName);
    if (hostTracker == null) {
        throw new ServiceUnavailableException("Host Tracker "
                + RestMessages.SERVICEUNAVAILABLE.toString());
    }

    return new Hosts(hostTracker.getInactiveStaticHosts());
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
@Path("/{containerName}")
@GET
@Produces( { MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@TypeHint(Pools.class)
@StatusCodes( {
    @ResponseCode(code = 200, condition = "Operation successful"),
    @ResponseCode(code = 404, condition = "The containerName is not found"),
    @ResponseCode(code = 503, condition = "Load balancer service is unavailable") })
public Pools getAllPools(
        @PathParam("containerName") String containerName) {

    IConfigManager configManager = getConfigManagerService(containerName);
    if (configManager == null) {
        throw new ServiceUnavailableException("Load Balancer "
                                                + RestMessages.SERVICEUNAVAILABLE.toString());
    }

    return new Pools(configManager.getAllPools());
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
@Path("/{containerName}/vips")
@GET
@Produces( { MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@TypeHint(VIPs.class)
@StatusCodes( {
    @ResponseCode(code = 200, condition = "Operation successful"),
    @ResponseCode(code = 404, condition = "The containerName is not found"),
    @ResponseCode(code = 503, condition = "Load balancer service is unavailable") })
public VIPs getAllVIPs(
        @PathParam("containerName") String containerName) {

    IConfigManager configManager = getConfigManagerService(containerName);
    if (configManager == null) {
        throw new ServiceUnavailableException("Load Balancer "
                + RestMessages.SERVICEUNAVAILABLE.toString());
    }

    return new VIPs(configManager.getAllVIPs());
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
@Path("/{containerName}/hello/{helloId}")
@GET
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@TypeHint(HelloDTO.class)
public Response getHello(@PathParam("containerName") String containerName,
        @PathParam("helloId") String helloId) {
    HelloService service = (HelloService) ServiceHelper.getGlobalInstance(
            HelloService.class, this);

    GetHelloInput input = new GetHelloInputBuilder().setHelloId(helloId)
            .build();
    Future<RpcResult<GetHelloOutput>> output = service.getHello(input);
    try {
        if (output.get().getResult() != null) {
            log.debug("RESULT: {}", output.get().getResult().getName());
            return Response.ok(
                    new HelloDTO(output.get().getResult().getName(),
                            output.get().getResult().getValue())).build();
        } else {
            return Response.status(404).build();
        }
    } catch (InterruptedException | ExecutionException e) {
        log.error("Unexpected exception when attempting to GET", e);
        return Response.serverError().build();
    }
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
@GET
@Produces(Protocol.MIME_TYPES_ALL)
@TypeHint(Stream.class)
public Response get(
        @QueryParam(Protocol.PARAMETER_DEFAULT_GRAPH) final List<String> defaultGraphs,
        @QueryParam(Protocol.PARAMETER_NAMED_GRAPH) final List<String> namedGraphs,
        @QueryParam(Protocol.PARAMETER_QUERY) final String query) throws OperationException {
    return query(query, defaultGraphs, namedGraphs);
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
@POST
@Consumes("application/x-www-form-urlencoded")
@Produces(Protocol.MIME_TYPES_ALL)
@TypeHint(Stream.class)
public Response postURLencoded(
        @FormParam(Protocol.PARAMETER_DEFAULT_GRAPH) final List<String> defaultGraphs,
        @FormParam(Protocol.PARAMETER_NAMED_GRAPH) final List<String> namedGraphs,
        @FormParam(Protocol.PARAMETER_QUERY) final String query) throws OperationException {
    return query(query, defaultGraphs, namedGraphs);
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
@POST
@Consumes("application/sparql-query")
@Produces(Protocol.MIME_TYPES_ALL)
@TypeHint(Stream.class)
public Response postDirect(
        @QueryParam(Protocol.PARAMETER_DEFAULT_GRAPH) final List<String> defaultGraphs,
        @QueryParam(Protocol.PARAMETER_NAMED_GRAPH) final List<String> namedGraphs,
        final String query) throws OperationException {
    return query(query, defaultGraphs, namedGraphs);
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
/**
 * Creates new Bgpvpns.
 */
@POST
@Produces({ MediaType.APPLICATION_JSON })
@Consumes({ MediaType.APPLICATION_JSON })
@TypeHint(NeutronBgpvpn.class)
@StatusCodes({ @ResponseCode(code = HttpURLConnection.HTTP_CREATED, condition = "Created"),
        @ResponseCode(code = HttpURLConnection.HTTP_UNAVAILABLE, condition = "No providers available") })
public Response createBgpvpns(final NeutronBgpvpnRequest input) {
    return create(input);
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
/**
 * Creates new VPN Service.
 */
@POST
@Produces({ MediaType.APPLICATION_JSON })
@Consumes({ MediaType.APPLICATION_JSON })
@TypeHint(NeutronVpnService.class)
@StatusCodes({ @ResponseCode(code = HttpURLConnection.HTTP_CREATED, condition = "Created"),
        @ResponseCode(code = HttpURLConnection.HTTP_UNAVAILABLE, condition = "No providers available") })
public Response createVPNService(final NeutronVpnServiceRequest input) {
    return create(input);
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
/**
 * Creates new Networks.
 */
@POST
@Produces({ MediaType.APPLICATION_JSON })
@Consumes({ MediaType.APPLICATION_JSON })
@TypeHint(NeutronNetwork.class)
@StatusCodes({ @ResponseCode(code = HttpURLConnection.HTTP_CREATED, condition = "Created"),
        @ResponseCode(code = HttpURLConnection.HTTP_UNAVAILABLE, condition = "No providers available") })
public Response createNetworks(final NeutronNetworkRequest input) {
    return create(input);
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
/**
 * Creates new VPN IKE Policy.
 */
@POST
@Produces({ MediaType.APPLICATION_JSON })
@Consumes({ MediaType.APPLICATION_JSON })
@TypeHint(NeutronVpnIkePolicy.class)
@StatusCodes({ @ResponseCode(code = HttpURLConnection.HTTP_CREATED, condition = "Created"),
        @ResponseCode(code = HttpURLConnection.HTTP_UNAVAILABLE, condition = "No providers available") })
public Response createVpnIkePolicy(final NeutronVpnIkePolicyRequest input) {
    return create(input);
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
/**
 * Creates new VPN IPSEC SiteConnection.
 */
@POST
@Produces({ MediaType.APPLICATION_JSON })
@Consumes({ MediaType.APPLICATION_JSON })
@TypeHint(NeutronVpnIpSecSiteConnection.class)
@StatusCodes({ @ResponseCode(code = HttpURLConnection.HTTP_CREATED, condition = "Created"),
        @ResponseCode(code = HttpURLConnection.HTTP_UNAVAILABLE, condition = "No providers available") })
public Response createVpnIPSecSiteConnection(final NeutronVpnIpSecSiteConnectionRequest input) {
    return create(input);
}
 

import org.codehaus.enunciate.jaxrs.TypeHint; //导入依赖的package包/类
/**
 * Creates new VPN IPSEC Policy.
 */
@POST
@Produces({ MediaType.APPLICATION_JSON })
@Consumes({ MediaType.APPLICATION_JSON })
@TypeHint(NeutronVpnIpSecPolicy.class)
@StatusCodes({ @ResponseCode(code = HttpURLConnection.HTTP_CREATED, condition = "Created"),
        @ResponseCode(code = HttpURLConnection.HTTP_UNAVAILABLE, condition = "No providers available") })
public Response createVpnIPSecPolicy(final NeutronVpnIpSecPolicyRequest input) {
    return create(input);
}