aboutsummaryrefslogtreecommitdiffstats
path: root/grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/cds/BlueprintProcessingClient.java
diff options
context:
space:
mode:
Diffstat (limited to 'grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/cds/BlueprintProcessingClient.java')
-rw-r--r--grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/cds/BlueprintProcessingClient.java86
1 files changed, 0 insertions, 86 deletions
diff --git a/grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/cds/BlueprintProcessingClient.java b/grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/cds/BlueprintProcessingClient.java
deleted file mode 100644
index f922f9ec..00000000
--- a/grpc-resource/provider/src/main/java/org/onap/ccsdk/sli/adaptors/grpc/cds/BlueprintProcessingClient.java
+++ /dev/null
@@ -1,86 +0,0 @@
-/*
- * Copyright (C) 2019 Bell Canada.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.onap.ccsdk.sli.adaptors.grpc.cds;
-
-import io.grpc.ManagedChannel;
-import io.grpc.internal.DnsNameResolverProvider;
-import io.grpc.internal.PickFirstLoadBalancerProvider;
-import io.grpc.netty.NettyChannelBuilder;
-import java.util.Map;
-import org.onap.ccsdk.sli.adaptors.grpc.GrpcClient;
-import org.onap.ccsdk.sli.adaptors.grpc.GrpcProperties;
-import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
-import org.onap.ccsdk.sli.core.sli.SvcLogicResource.QueryStatus;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class BlueprintProcessingClient implements GrpcClient {
-
- private static final Logger log = LoggerFactory.getLogger(BlueprintProcessingClient.class);
-
- private ManagedChannel channel;
- private BlueprintProcessingHandler handler;
-
- public BlueprintProcessingClient(GrpcProperties props) {
- this.channel = NettyChannelBuilder
- .forAddress(props.getUrl(), props.getPort())
- .nameResolverFactory(new DnsNameResolverProvider())
- .loadBalancerFactory(new PickFirstLoadBalancerProvider())
- .intercept(new BasicAuthClientInterceptor(props))
- .usePlaintext()
- .build();
- this.handler = new BlueprintProcessingHandler();
- }
-
- public BlueprintProcessingClient(ManagedChannel channel, BlueprintProcessingHandler handler) {
- this.channel = channel;
- this.handler = handler;
- }
-
- // Used by blueprint
- public void start() {
- log.info("BlueprintProcessingClient started");
- }
-
- // Used by blueprint
- public void stop() {
- if (channel != null) {
- channel.shutdown();
- }
- log.info("BlueprintProcessingClient stopped");
- }
-
- /*
- * @param parameters HashMap<String,String> of parameters passed by the DG to this function.
- * <table border="1">
- * <thead><th>parameter</th><th>Mandatory/Optional</th><th>description</th></thead>
- * <tbody>
- * <tr><td>is_force</td><td>Optional</td><td>Whether to force or not the request.</td></tr>
- * <tr><td>ttl</td><td>Optional</td><td>Duration of the request.</td></tr>
- * <tr><td>blueprint_name</td><td>Mandatory</td><td>Name of the blueprint to process.</td></tr>
- * <tr><td>blueprint_version</td><td>Mandatory</td><td>Version of the blueprint to process.</td></tr>
- * <tr><td>action</td><td>Mandatory</td><td>Action of the blueprint to process.</td></tr>
- * <tr><td>mode</td><td>Mandatory</td><td>Mode to operate the transaction.</td></tr>
- * <tr><td>payload</td><td>Mandatory</td><td>Payload.</td></tr>
- * <tr><td>prefix</td><td>Mandatory</td><td>Prefix string to put response in context.</td></tr>
- * </tbody>
- * </table>
- */
- @Override
- public QueryStatus sendRequest(Map<String, String> parameters, SvcLogicContext ctx) {
- return handler.process(parameters, channel, ctx);
- }
-} \ No newline at end of file