gerrit.onap Code Review - ccsdk/sli/adaptors.git/blob

   1 /*
   2  * Copyright (C) 2019 Bell Canada.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *      http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16 package org.onap.ccsdk.sli.adaptors.grpc.cds;
  17
  18 import io.grpc.ManagedChannel;
  19 import io.grpc.internal.DnsNameResolverProvider;
  20 import io.grpc.internal.PickFirstLoadBalancerProvider;
  21 import io.grpc.netty.NettyChannelBuilder;
  22 import java.util.Map;
  23 import org.onap.ccsdk.sli.adaptors.grpc.GrpcClient;
  24 import org.onap.ccsdk.sli.adaptors.grpc.GrpcProperties;
  25 import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
  26 import org.onap.ccsdk.sli.core.sli.SvcLogicResource.QueryStatus;
  27 import org.slf4j.Logger;
  28 import org.slf4j.LoggerFactory;
  29
  30 public class BlueprintProcessingClient implements GrpcClient {
  31
  32     private static final Logger log = LoggerFactory.getLogger(BlueprintProcessingClient.class);
  33
  34     private ManagedChannel channel;
  35     private BlueprintProcessingHandler handler;
  36
  37     public BlueprintProcessingClient(BlueprintProcessingHandler handler, GrpcProperties props) {
  38         this.channel = NettyChannelBuilder
  39             .forAddress(props.getUrl(), props.getPort())
  40             .nameResolverFactory(new DnsNameResolverProvider())
  41             .loadBalancerFactory(new PickFirstLoadBalancerProvider())
  42             .usePlaintext()
  43             .build();
  44         this.handler = handler;
  45     }
  46
  47     // Used by blueprint
  48     public void start() {
  49         log.info("BlueprintProcessingClient started");
  50     }
  51
  52     // Used by blueprint
  53     public void stop() {
  54         if (channel != null) {
  55             channel.shutdown();
  56         }
  57         log.info("BlueprintProcessingClient stopped");
  58     }
  59
  60     /*
  61      * @param parameters HashMap<String,String> of parameters passed by the DG to this function.
  62      * <table border="1">
  63      * <thead><th>parameter</th><th>Mandatory/Optional</th><th>description</th></thead>
  64      * <tbody>
  65      * <tr><td>is_force</td><td>Optional</td><td>Whether to force or not the request.</td></tr>
  66      * <tr><td>ttl</td><td>Optional</td><td>Duration of the request.</td></tr>
  67      * <tr><td>blueprint_name</td><td>Mandatory</td><td>Name of the blueprint to process.</td></tr>
  68      * <tr><td>blueprint_version</td><td>Mandatory</td><td>Version of the blueprint to process.</td></tr>
  69      * <tr><td>action</td><td>Mandatory</td><td>Action of the blueprint to process.</td></tr>
  70      * <tr><td>mode</td><td>Mandatory</td><td>Mode to operate the transaction.</td></tr>
  71      * <tr><td>payload</td><td>Mandatory</td><td>Payload.</td></tr>
  72      * </tbody>
  73      * </table>
  74      */
  75     @Override
  76     public QueryStatus sendRequest(Map<String, String> parameters, SvcLogicContext ctx) {
  77         return handler.process(parameters, channel);
  78     }
  79 }