forked from opensearch-project/OpenSearch
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Signed-off-by: Finn Carroll <[email protected]>
- Loading branch information
1 parent
81503ce
commit ee85066
Showing
2 changed files
with
48 additions
and
50 deletions.
There are no files selected for viewing
54 changes: 26 additions & 28 deletions
54
server/src/main/java/org/opensearch/grpc/services/gRPCServiceRegistry.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,28 +1,26 @@ | ||
| /* | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| * | ||
| * The OpenSearch Contributors require contributions made to | ||
| * this file be licensed under the Apache-2.0 license or a | ||
| * compatible open source license. | ||
| */ | ||
|
|
||
| package org.opensearch.grpc.services; | ||
|
|
||
| import io.grpc.BindableService; | ||
| import java.util.ArrayList; | ||
|
|
||
| import org.opensearch.server.proto.action.admin.cluster.node.stats.NodesStatsProto; | ||
|
|
||
| public class gRPCServiceRegistry { | ||
| private final ArrayList<BindableService> services = new ArrayList<>(); | ||
|
|
||
| gRPCServiceRegistry() { } | ||
|
|
||
| public void addService(BindableService bindableService) { | ||
| services.add(bindableService); | ||
| } | ||
|
|
||
| public ArrayList<BindableService> getServices() { | ||
| return services; | ||
| } | ||
| } | ||
| ///* | ||
| // * SPDX-License-Identifier: Apache-2.0 | ||
| // * | ||
| // * The OpenSearch Contributors require contributions made to | ||
| // * this file be licensed under the Apache-2.0 license or a | ||
| // * compatible open source license. | ||
| // */ | ||
| // | ||
| //package org.opensearch.grpc.services; | ||
| // | ||
| //import io.grpc.BindableService; | ||
| //import java.util.ArrayList; | ||
| // | ||
| //public class gRPCServiceRegistry { | ||
| // private final ArrayList<BindableService> services = new ArrayList<>(); | ||
| // | ||
| // gRPCServiceRegistry() { } | ||
| // | ||
| // public void addService(BindableService bindableService) { | ||
| // services.add(bindableService); | ||
| // } | ||
| // | ||
| // public ArrayList<BindableService> getServices() { | ||
| // return services; | ||
| // } | ||
| //} |
44 changes: 22 additions & 22 deletions
44
server/src/main/java/org/opensearch/grpc/services/nodesInfo/NodesInfoServiceImple.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,22 +1,22 @@ | ||
| /* | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| * | ||
| * The OpenSearch Contributors require contributions made to | ||
| * this file be licensed under the Apache-2.0 license or a | ||
| * compatible open source license. | ||
| */ | ||
|
|
||
| package org.opensearch.grpc.services.nodesInfo; | ||
|
|
||
| public class NodesInfoServiceImpl extends NodesInfoServiceGrpc.NodesInfoServiceImplBase { | ||
|
|
||
| @Override | ||
| public void getNodesInfo(NodesInfoRequest request, StreamObserver<NodesInfoResponse> responseObserver) { | ||
|
|
||
| } | ||
|
|
||
| @Override | ||
| public void streamNodesInfo(NodesInfoRequest request, StreamObserver<NodesInfoResponse> responseObserver) { | ||
|
|
||
| } | ||
| } | ||
| ///* | ||
| // * SPDX-License-Identifier: Apache-2.0 | ||
| // * | ||
| // * The OpenSearch Contributors require contributions made to | ||
| // * this file be licensed under the Apache-2.0 license or a | ||
| // * compatible open source license. | ||
| // */ | ||
| // | ||
| //package org.opensearch.grpc.services.nodesInfo; | ||
| // | ||
| //public class NodesInfoServiceImpl extends NodesInfoServiceGrpc.NodesInfoServiceImplBase { | ||
| // | ||
| // @Override | ||
| // public void getNodesInfo(NodesInfoRequest request, StreamObserver<NodesInfoResponse> responseObserver) { | ||
| // | ||
| // } | ||
| // | ||
| // @Override | ||
| // public void streamNodesInfo(NodesInfoRequest request, StreamObserver<NodesInfoResponse> responseObserver) { | ||
| // | ||
| // } | ||
| //} |