You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ji...@apache.org on 2016/12/13 22:53:26 UTC
[34/74] [abbrv] hadoop git commit: YARN-5461. Initial code ported
from slider-core module. (jianhe)
http://git-wip-us.apache.org/repos/asf/hadoop/blob/31c4a419/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/proto/SliderClusterAPI.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/proto/SliderClusterAPI.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/proto/SliderClusterAPI.java
new file mode 100644
index 0000000..081b7fa
--- /dev/null
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/proto/SliderClusterAPI.java
@@ -0,0 +1,2293 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: SliderClusterProtocol.proto
+
+package org.apache.slider.api.proto;
+
+public final class SliderClusterAPI {
+ private SliderClusterAPI() {}
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistry registry) {
+ }
+ /**
+ * Protobuf service {@code org.apache.slider.api.SliderClusterProtocolPB}
+ *
+ * <pre>
+ **
+ * Protocol used from between Slider Client and AM
+ * </pre>
+ */
+ public static abstract class SliderClusterProtocolPB
+ implements com.google.protobuf.Service {
+ protected SliderClusterProtocolPB() {}
+
+ public interface Interface {
+ /**
+ * <code>rpc stopCluster(.org.apache.slider.api.StopClusterRequestProto) returns (.org.apache.slider.api.StopClusterResponseProto);</code>
+ */
+ public abstract void stopCluster(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.StopClusterRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.StopClusterResponseProto> done);
+
+ /**
+ * <code>rpc upgradeContainers(.org.apache.slider.api.UpgradeContainersRequestProto) returns (.org.apache.slider.api.UpgradeContainersResponseProto);</code>
+ *
+ * <pre>
+ **
+ * Upgrade containers
+ * </pre>
+ */
+ public abstract void upgradeContainers(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.UpgradeContainersRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.UpgradeContainersResponseProto> done);
+
+ /**
+ * <code>rpc flexCluster(.org.apache.slider.api.FlexClusterRequestProto) returns (.org.apache.slider.api.FlexClusterResponseProto);</code>
+ *
+ * <pre>
+ **
+ * Flex the cluster.
+ * </pre>
+ */
+ public abstract void flexCluster(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.FlexClusterRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.FlexClusterResponseProto> done);
+
+ /**
+ * <code>rpc getJSONClusterStatus(.org.apache.slider.api.GetJSONClusterStatusRequestProto) returns (.org.apache.slider.api.GetJSONClusterStatusResponseProto);</code>
+ *
+ * <pre>
+ **
+ * Get the current cluster status
+ * </pre>
+ */
+ public abstract void getJSONClusterStatus(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetJSONClusterStatusRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetJSONClusterStatusResponseProto> done);
+
+ /**
+ * <code>rpc getInstanceDefinition(.org.apache.slider.api.GetInstanceDefinitionRequestProto) returns (.org.apache.slider.api.GetInstanceDefinitionResponseProto);</code>
+ *
+ * <pre>
+ **
+ * Get the instance definition
+ * </pre>
+ */
+ public abstract void getInstanceDefinition(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetInstanceDefinitionRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetInstanceDefinitionResponseProto> done);
+
+ /**
+ * <code>rpc listNodeUUIDsByRole(.org.apache.slider.api.ListNodeUUIDsByRoleRequestProto) returns (.org.apache.slider.api.ListNodeUUIDsByRoleResponseProto);</code>
+ *
+ * <pre>
+ **
+ * List all running nodes in a role
+ * </pre>
+ */
+ public abstract void listNodeUUIDsByRole(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleResponseProto> done);
+
+ /**
+ * <code>rpc getNode(.org.apache.slider.api.GetNodeRequestProto) returns (.org.apache.slider.api.GetNodeResponseProto);</code>
+ *
+ * <pre>
+ **
+ * Get the details on a node
+ * </pre>
+ */
+ public abstract void getNode(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetNodeRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetNodeResponseProto> done);
+
+ /**
+ * <code>rpc getClusterNodes(.org.apache.slider.api.GetClusterNodesRequestProto) returns (.org.apache.slider.api.GetClusterNodesResponseProto);</code>
+ *
+ * <pre>
+ **
+ * Get the
+ * details on a list of nodes.
+ * Unknown nodes are not returned
+ * <i>Important: the order of the results are undefined</i>
+ * </pre>
+ */
+ public abstract void getClusterNodes(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetClusterNodesRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetClusterNodesResponseProto> done);
+
+ /**
+ * <code>rpc echo(.org.apache.slider.api.EchoRequestProto) returns (.org.apache.slider.api.EchoResponseProto);</code>
+ *
+ * <pre>
+ **
+ * echo some text
+ * </pre>
+ */
+ public abstract void echo(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EchoRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.EchoResponseProto> done);
+
+ /**
+ * <code>rpc killContainer(.org.apache.slider.api.KillContainerRequestProto) returns (.org.apache.slider.api.KillContainerResponseProto);</code>
+ *
+ * <pre>
+ **
+ * kill a container
+ * </pre>
+ */
+ public abstract void killContainer(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.KillContainerRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.KillContainerResponseProto> done);
+
+ /**
+ * <code>rpc amSuicide(.org.apache.slider.api.AMSuicideRequestProto) returns (.org.apache.slider.api.AMSuicideResponseProto);</code>
+ *
+ * <pre>
+ **
+ * kill the AM
+ * </pre>
+ */
+ public abstract void amSuicide(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.AMSuicideRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.AMSuicideResponseProto> done);
+
+ /**
+ * <code>rpc getLivenessInformation(.org.apache.slider.api.GetApplicationLivenessRequestProto) returns (.org.apache.slider.api.ApplicationLivenessInformationProto);</code>
+ */
+ public abstract void getLivenessInformation(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetApplicationLivenessRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ApplicationLivenessInformationProto> done);
+
+ /**
+ * <code>rpc getLiveContainers(.org.apache.slider.api.GetLiveContainersRequestProto) returns (.org.apache.slider.api.GetLiveContainersResponseProto);</code>
+ */
+ public abstract void getLiveContainers(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveContainersRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetLiveContainersResponseProto> done);
+
+ /**
+ * <code>rpc getLiveContainer(.org.apache.slider.api.GetLiveContainerRequestProto) returns (.org.apache.slider.api.ContainerInformationProto);</code>
+ */
+ public abstract void getLiveContainer(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveContainerRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ContainerInformationProto> done);
+
+ /**
+ * <code>rpc getLiveComponents(.org.apache.slider.api.GetLiveComponentsRequestProto) returns (.org.apache.slider.api.GetLiveComponentsResponseProto);</code>
+ */
+ public abstract void getLiveComponents(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveComponentsRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetLiveComponentsResponseProto> done);
+
+ /**
+ * <code>rpc getLiveComponent(.org.apache.slider.api.GetLiveComponentRequestProto) returns (.org.apache.slider.api.ComponentInformationProto);</code>
+ */
+ public abstract void getLiveComponent(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveComponentRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ComponentInformationProto> done);
+
+ /**
+ * <code>rpc getLiveNodes(.org.apache.slider.api.GetLiveNodesRequestProto) returns (.org.apache.slider.api.GetLiveNodesResponseProto);</code>
+ */
+ public abstract void getLiveNodes(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveNodesRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetLiveNodesResponseProto> done);
+
+ /**
+ * <code>rpc getLiveNode(.org.apache.slider.api.GetLiveNodeRequestProto) returns (.org.apache.slider.api.NodeInformationProto);</code>
+ */
+ public abstract void getLiveNode(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveNodeRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.NodeInformationProto> done);
+
+ /**
+ * <code>rpc getModelDesired(.org.apache.slider.api.EmptyPayloadProto) returns (.org.apache.slider.api.WrappedJsonProto);</code>
+ *
+ * <pre>
+ * AggregateConf getModelDesired()
+ * </pre>
+ */
+ public abstract void getModelDesired(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done);
+
+ /**
+ * <code>rpc getModelDesiredAppconf(.org.apache.slider.api.EmptyPayloadProto) returns (.org.apache.slider.api.WrappedJsonProto);</code>
+ *
+ * <pre>
+ * ConfTree getModelDesiredAppconf
+ * </pre>
+ */
+ public abstract void getModelDesiredAppconf(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done);
+
+ /**
+ * <code>rpc getModelDesiredResources(.org.apache.slider.api.EmptyPayloadProto) returns (.org.apache.slider.api.WrappedJsonProto);</code>
+ *
+ * <pre>
+ * ConfTree getModelDesiredResources
+ * </pre>
+ */
+ public abstract void getModelDesiredResources(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done);
+
+ /**
+ * <code>rpc getModelResolved(.org.apache.slider.api.EmptyPayloadProto) returns (.org.apache.slider.api.WrappedJsonProto);</code>
+ *
+ * <pre>
+ * AggregateConf getModelResolved()
+ * </pre>
+ */
+ public abstract void getModelResolved(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done);
+
+ /**
+ * <code>rpc getModelResolvedAppconf(.org.apache.slider.api.EmptyPayloadProto) returns (.org.apache.slider.api.WrappedJsonProto);</code>
+ *
+ * <pre>
+ * ConfTree getModelResolvedAppconf
+ * </pre>
+ */
+ public abstract void getModelResolvedAppconf(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done);
+
+ /**
+ * <code>rpc getModelResolvedResources(.org.apache.slider.api.EmptyPayloadProto) returns (.org.apache.slider.api.WrappedJsonProto);</code>
+ *
+ * <pre>
+ * ConfTree getModelResolvedResources
+ * </pre>
+ */
+ public abstract void getModelResolvedResources(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done);
+
+ /**
+ * <code>rpc getLiveResources(.org.apache.slider.api.EmptyPayloadProto) returns (.org.apache.slider.api.WrappedJsonProto);</code>
+ *
+ * <pre>
+ * ConfTree getLiveResources
+ * </pre>
+ */
+ public abstract void getLiveResources(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done);
+
+ /**
+ * <code>rpc getClientCertificateStore(.org.apache.slider.api.GetCertificateStoreRequestProto) returns (.org.apache.slider.api.GetCertificateStoreResponseProto);</code>
+ */
+ public abstract void getClientCertificateStore(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetCertificateStoreRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetCertificateStoreResponseProto> done);
+
+ }
+
+ public static com.google.protobuf.Service newReflectiveService(
+ final Interface impl) {
+ return new SliderClusterProtocolPB() {
+ @java.lang.Override
+ public void stopCluster(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.StopClusterRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.StopClusterResponseProto> done) {
+ impl.stopCluster(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void upgradeContainers(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.UpgradeContainersRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.UpgradeContainersResponseProto> done) {
+ impl.upgradeContainers(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void flexCluster(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.FlexClusterRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.FlexClusterResponseProto> done) {
+ impl.flexCluster(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getJSONClusterStatus(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetJSONClusterStatusRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetJSONClusterStatusResponseProto> done) {
+ impl.getJSONClusterStatus(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getInstanceDefinition(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetInstanceDefinitionRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetInstanceDefinitionResponseProto> done) {
+ impl.getInstanceDefinition(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void listNodeUUIDsByRole(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleResponseProto> done) {
+ impl.listNodeUUIDsByRole(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getNode(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetNodeRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetNodeResponseProto> done) {
+ impl.getNode(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getClusterNodes(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetClusterNodesRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetClusterNodesResponseProto> done) {
+ impl.getClusterNodes(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void echo(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EchoRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.EchoResponseProto> done) {
+ impl.echo(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void killContainer(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.KillContainerRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.KillContainerResponseProto> done) {
+ impl.killContainer(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void amSuicide(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.AMSuicideRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.AMSuicideResponseProto> done) {
+ impl.amSuicide(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getLivenessInformation(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetApplicationLivenessRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ApplicationLivenessInformationProto> done) {
+ impl.getLivenessInformation(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getLiveContainers(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveContainersRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetLiveContainersResponseProto> done) {
+ impl.getLiveContainers(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getLiveContainer(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveContainerRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ContainerInformationProto> done) {
+ impl.getLiveContainer(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getLiveComponents(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveComponentsRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetLiveComponentsResponseProto> done) {
+ impl.getLiveComponents(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getLiveComponent(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveComponentRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ComponentInformationProto> done) {
+ impl.getLiveComponent(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getLiveNodes(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveNodesRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetLiveNodesResponseProto> done) {
+ impl.getLiveNodes(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getLiveNode(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveNodeRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.NodeInformationProto> done) {
+ impl.getLiveNode(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getModelDesired(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done) {
+ impl.getModelDesired(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getModelDesiredAppconf(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done) {
+ impl.getModelDesiredAppconf(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getModelDesiredResources(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done) {
+ impl.getModelDesiredResources(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getModelResolved(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done) {
+ impl.getModelResolved(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getModelResolvedAppconf(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done) {
+ impl.getModelResolvedAppconf(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getModelResolvedResources(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done) {
+ impl.getModelResolvedResources(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getLiveResources(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done) {
+ impl.getLiveResources(controller, request, done);
+ }
+
+ @java.lang.Override
+ public void getClientCertificateStore(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetCertificateStoreRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetCertificateStoreResponseProto> done) {
+ impl.getClientCertificateStore(controller, request, done);
+ }
+
+ };
+ }
+
+ public static com.google.protobuf.BlockingService
+ newReflectiveBlockingService(final BlockingInterface impl) {
+ return new com.google.protobuf.BlockingService() {
+ public final com.google.protobuf.Descriptors.ServiceDescriptor
+ getDescriptorForType() {
+ return getDescriptor();
+ }
+
+ public final com.google.protobuf.Message callBlockingMethod(
+ com.google.protobuf.Descriptors.MethodDescriptor method,
+ com.google.protobuf.RpcController controller,
+ com.google.protobuf.Message request)
+ throws com.google.protobuf.ServiceException {
+ if (method.getService() != getDescriptor()) {
+ throw new java.lang.IllegalArgumentException(
+ "Service.callBlockingMethod() given method descriptor for " +
+ "wrong service type.");
+ }
+ switch(method.getIndex()) {
+ case 0:
+ return impl.stopCluster(controller, (org.apache.slider.api.proto.Messages.StopClusterRequestProto)request);
+ case 1:
+ return impl.upgradeContainers(controller, (org.apache.slider.api.proto.Messages.UpgradeContainersRequestProto)request);
+ case 2:
+ return impl.flexCluster(controller, (org.apache.slider.api.proto.Messages.FlexClusterRequestProto)request);
+ case 3:
+ return impl.getJSONClusterStatus(controller, (org.apache.slider.api.proto.Messages.GetJSONClusterStatusRequestProto)request);
+ case 4:
+ return impl.getInstanceDefinition(controller, (org.apache.slider.api.proto.Messages.GetInstanceDefinitionRequestProto)request);
+ case 5:
+ return impl.listNodeUUIDsByRole(controller, (org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleRequestProto)request);
+ case 6:
+ return impl.getNode(controller, (org.apache.slider.api.proto.Messages.GetNodeRequestProto)request);
+ case 7:
+ return impl.getClusterNodes(controller, (org.apache.slider.api.proto.Messages.GetClusterNodesRequestProto)request);
+ case 8:
+ return impl.echo(controller, (org.apache.slider.api.proto.Messages.EchoRequestProto)request);
+ case 9:
+ return impl.killContainer(controller, (org.apache.slider.api.proto.Messages.KillContainerRequestProto)request);
+ case 10:
+ return impl.amSuicide(controller, (org.apache.slider.api.proto.Messages.AMSuicideRequestProto)request);
+ case 11:
+ return impl.getLivenessInformation(controller, (org.apache.slider.api.proto.Messages.GetApplicationLivenessRequestProto)request);
+ case 12:
+ return impl.getLiveContainers(controller, (org.apache.slider.api.proto.Messages.GetLiveContainersRequestProto)request);
+ case 13:
+ return impl.getLiveContainer(controller, (org.apache.slider.api.proto.Messages.GetLiveContainerRequestProto)request);
+ case 14:
+ return impl.getLiveComponents(controller, (org.apache.slider.api.proto.Messages.GetLiveComponentsRequestProto)request);
+ case 15:
+ return impl.getLiveComponent(controller, (org.apache.slider.api.proto.Messages.GetLiveComponentRequestProto)request);
+ case 16:
+ return impl.getLiveNodes(controller, (org.apache.slider.api.proto.Messages.GetLiveNodesRequestProto)request);
+ case 17:
+ return impl.getLiveNode(controller, (org.apache.slider.api.proto.Messages.GetLiveNodeRequestProto)request);
+ case 18:
+ return impl.getModelDesired(controller, (org.apache.slider.api.proto.Messages.EmptyPayloadProto)request);
+ case 19:
+ return impl.getModelDesiredAppconf(controller, (org.apache.slider.api.proto.Messages.EmptyPayloadProto)request);
+ case 20:
+ return impl.getModelDesiredResources(controller, (org.apache.slider.api.proto.Messages.EmptyPayloadProto)request);
+ case 21:
+ return impl.getModelResolved(controller, (org.apache.slider.api.proto.Messages.EmptyPayloadProto)request);
+ case 22:
+ return impl.getModelResolvedAppconf(controller, (org.apache.slider.api.proto.Messages.EmptyPayloadProto)request);
+ case 23:
+ return impl.getModelResolvedResources(controller, (org.apache.slider.api.proto.Messages.EmptyPayloadProto)request);
+ case 24:
+ return impl.getLiveResources(controller, (org.apache.slider.api.proto.Messages.EmptyPayloadProto)request);
+ case 25:
+ return impl.getClientCertificateStore(controller, (org.apache.slider.api.proto.Messages.GetCertificateStoreRequestProto)request);
+ default:
+ throw new java.lang.AssertionError("Can't get here.");
+ }
+ }
+
+ public final com.google.protobuf.Message
+ getRequestPrototype(
+ com.google.protobuf.Descriptors.MethodDescriptor method) {
+ if (method.getService() != getDescriptor()) {
+ throw new java.lang.IllegalArgumentException(
+ "Service.getRequestPrototype() given method " +
+ "descriptor for wrong service type.");
+ }
+ switch(method.getIndex()) {
+ case 0:
+ return org.apache.slider.api.proto.Messages.StopClusterRequestProto.getDefaultInstance();
+ case 1:
+ return org.apache.slider.api.proto.Messages.UpgradeContainersRequestProto.getDefaultInstance();
+ case 2:
+ return org.apache.slider.api.proto.Messages.FlexClusterRequestProto.getDefaultInstance();
+ case 3:
+ return org.apache.slider.api.proto.Messages.GetJSONClusterStatusRequestProto.getDefaultInstance();
+ case 4:
+ return org.apache.slider.api.proto.Messages.GetInstanceDefinitionRequestProto.getDefaultInstance();
+ case 5:
+ return org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleRequestProto.getDefaultInstance();
+ case 6:
+ return org.apache.slider.api.proto.Messages.GetNodeRequestProto.getDefaultInstance();
+ case 7:
+ return org.apache.slider.api.proto.Messages.GetClusterNodesRequestProto.getDefaultInstance();
+ case 8:
+ return org.apache.slider.api.proto.Messages.EchoRequestProto.getDefaultInstance();
+ case 9:
+ return org.apache.slider.api.proto.Messages.KillContainerRequestProto.getDefaultInstance();
+ case 10:
+ return org.apache.slider.api.proto.Messages.AMSuicideRequestProto.getDefaultInstance();
+ case 11:
+ return org.apache.slider.api.proto.Messages.GetApplicationLivenessRequestProto.getDefaultInstance();
+ case 12:
+ return org.apache.slider.api.proto.Messages.GetLiveContainersRequestProto.getDefaultInstance();
+ case 13:
+ return org.apache.slider.api.proto.Messages.GetLiveContainerRequestProto.getDefaultInstance();
+ case 14:
+ return org.apache.slider.api.proto.Messages.GetLiveComponentsRequestProto.getDefaultInstance();
+ case 15:
+ return org.apache.slider.api.proto.Messages.GetLiveComponentRequestProto.getDefaultInstance();
+ case 16:
+ return org.apache.slider.api.proto.Messages.GetLiveNodesRequestProto.getDefaultInstance();
+ case 17:
+ return org.apache.slider.api.proto.Messages.GetLiveNodeRequestProto.getDefaultInstance();
+ case 18:
+ return org.apache.slider.api.proto.Messages.EmptyPayloadProto.getDefaultInstance();
+ case 19:
+ return org.apache.slider.api.proto.Messages.EmptyPayloadProto.getDefaultInstance();
+ case 20:
+ return org.apache.slider.api.proto.Messages.EmptyPayloadProto.getDefaultInstance();
+ case 21:
+ return org.apache.slider.api.proto.Messages.EmptyPayloadProto.getDefaultInstance();
+ case 22:
+ return org.apache.slider.api.proto.Messages.EmptyPayloadProto.getDefaultInstance();
+ case 23:
+ return org.apache.slider.api.proto.Messages.EmptyPayloadProto.getDefaultInstance();
+ case 24:
+ return org.apache.slider.api.proto.Messages.EmptyPayloadProto.getDefaultInstance();
+ case 25:
+ return org.apache.slider.api.proto.Messages.GetCertificateStoreRequestProto.getDefaultInstance();
+ default:
+ throw new java.lang.AssertionError("Can't get here.");
+ }
+ }
+
+ public final com.google.protobuf.Message
+ getResponsePrototype(
+ com.google.protobuf.Descriptors.MethodDescriptor method) {
+ if (method.getService() != getDescriptor()) {
+ throw new java.lang.IllegalArgumentException(
+ "Service.getResponsePrototype() given method " +
+ "descriptor for wrong service type.");
+ }
+ switch(method.getIndex()) {
+ case 0:
+ return org.apache.slider.api.proto.Messages.StopClusterResponseProto.getDefaultInstance();
+ case 1:
+ return org.apache.slider.api.proto.Messages.UpgradeContainersResponseProto.getDefaultInstance();
+ case 2:
+ return org.apache.slider.api.proto.Messages.FlexClusterResponseProto.getDefaultInstance();
+ case 3:
+ return org.apache.slider.api.proto.Messages.GetJSONClusterStatusResponseProto.getDefaultInstance();
+ case 4:
+ return org.apache.slider.api.proto.Messages.GetInstanceDefinitionResponseProto.getDefaultInstance();
+ case 5:
+ return org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleResponseProto.getDefaultInstance();
+ case 6:
+ return org.apache.slider.api.proto.Messages.GetNodeResponseProto.getDefaultInstance();
+ case 7:
+ return org.apache.slider.api.proto.Messages.GetClusterNodesResponseProto.getDefaultInstance();
+ case 8:
+ return org.apache.slider.api.proto.Messages.EchoResponseProto.getDefaultInstance();
+ case 9:
+ return org.apache.slider.api.proto.Messages.KillContainerResponseProto.getDefaultInstance();
+ case 10:
+ return org.apache.slider.api.proto.Messages.AMSuicideResponseProto.getDefaultInstance();
+ case 11:
+ return org.apache.slider.api.proto.Messages.ApplicationLivenessInformationProto.getDefaultInstance();
+ case 12:
+ return org.apache.slider.api.proto.Messages.GetLiveContainersResponseProto.getDefaultInstance();
+ case 13:
+ return org.apache.slider.api.proto.Messages.ContainerInformationProto.getDefaultInstance();
+ case 14:
+ return org.apache.slider.api.proto.Messages.GetLiveComponentsResponseProto.getDefaultInstance();
+ case 15:
+ return org.apache.slider.api.proto.Messages.ComponentInformationProto.getDefaultInstance();
+ case 16:
+ return org.apache.slider.api.proto.Messages.GetLiveNodesResponseProto.getDefaultInstance();
+ case 17:
+ return org.apache.slider.api.proto.Messages.NodeInformationProto.getDefaultInstance();
+ case 18:
+ return org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance();
+ case 19:
+ return org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance();
+ case 20:
+ return org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance();
+ case 21:
+ return org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance();
+ case 22:
+ return org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance();
+ case 23:
+ return org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance();
+ case 24:
+ return org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance();
+ case 25:
+ return org.apache.slider.api.proto.Messages.GetCertificateStoreResponseProto.getDefaultInstance();
+ default:
+ throw new java.lang.AssertionError("Can't get here.");
+ }
+ }
+
+ };
+ }
+
+ /**
+ * <code>rpc stopCluster(.org.apache.slider.api.StopClusterRequestProto) returns (.org.apache.slider.api.StopClusterResponseProto);</code>
+ */
+ public abstract void stopCluster(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.StopClusterRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.StopClusterResponseProto> done);
+
+ /**
+ * <code>rpc upgradeContainers(.org.apache.slider.api.UpgradeContainersRequestProto) returns (.org.apache.slider.api.UpgradeContainersResponseProto);</code>
+ *
+ * <pre>
+ **
+ * Upgrade containers
+ * </pre>
+ */
+ public abstract void upgradeContainers(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.UpgradeContainersRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.UpgradeContainersResponseProto> done);
+
+ /**
+ * <code>rpc flexCluster(.org.apache.slider.api.FlexClusterRequestProto) returns (.org.apache.slider.api.FlexClusterResponseProto);</code>
+ *
+ * <pre>
+ **
+ * Flex the cluster.
+ * </pre>
+ */
+ public abstract void flexCluster(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.FlexClusterRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.FlexClusterResponseProto> done);
+
+ /**
+ * <code>rpc getJSONClusterStatus(.org.apache.slider.api.GetJSONClusterStatusRequestProto) returns (.org.apache.slider.api.GetJSONClusterStatusResponseProto);</code>
+ *
+ * <pre>
+ **
+ * Get the current cluster status
+ * </pre>
+ */
+ public abstract void getJSONClusterStatus(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetJSONClusterStatusRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetJSONClusterStatusResponseProto> done);
+
+ /**
+ * <code>rpc getInstanceDefinition(.org.apache.slider.api.GetInstanceDefinitionRequestProto) returns (.org.apache.slider.api.GetInstanceDefinitionResponseProto);</code>
+ *
+ * <pre>
+ **
+ * Get the instance definition
+ * </pre>
+ */
+ public abstract void getInstanceDefinition(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetInstanceDefinitionRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetInstanceDefinitionResponseProto> done);
+
+ /**
+ * <code>rpc listNodeUUIDsByRole(.org.apache.slider.api.ListNodeUUIDsByRoleRequestProto) returns (.org.apache.slider.api.ListNodeUUIDsByRoleResponseProto);</code>
+ *
+ * <pre>
+ **
+ * List all running nodes in a role
+ * </pre>
+ */
+ public abstract void listNodeUUIDsByRole(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleResponseProto> done);
+
+ /**
+ * <code>rpc getNode(.org.apache.slider.api.GetNodeRequestProto) returns (.org.apache.slider.api.GetNodeResponseProto);</code>
+ *
+ * <pre>
+ **
+ * Get the details on a node
+ * </pre>
+ */
+ public abstract void getNode(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetNodeRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetNodeResponseProto> done);
+
+ /**
+ * <code>rpc getClusterNodes(.org.apache.slider.api.GetClusterNodesRequestProto) returns (.org.apache.slider.api.GetClusterNodesResponseProto);</code>
+ *
+ * <pre>
+ **
+ * Get the
+ * details on a list of nodes.
+ * Unknown nodes are not returned
+ * <i>Important: the order of the results are undefined</i>
+ * </pre>
+ */
+ public abstract void getClusterNodes(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetClusterNodesRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetClusterNodesResponseProto> done);
+
+ /**
+ * <code>rpc echo(.org.apache.slider.api.EchoRequestProto) returns (.org.apache.slider.api.EchoResponseProto);</code>
+ *
+ * <pre>
+ **
+ * echo some text
+ * </pre>
+ */
+ public abstract void echo(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EchoRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.EchoResponseProto> done);
+
+ /**
+ * <code>rpc killContainer(.org.apache.slider.api.KillContainerRequestProto) returns (.org.apache.slider.api.KillContainerResponseProto);</code>
+ *
+ * <pre>
+ **
+ * kill a container
+ * </pre>
+ */
+ public abstract void killContainer(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.KillContainerRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.KillContainerResponseProto> done);
+
+ /**
+ * <code>rpc amSuicide(.org.apache.slider.api.AMSuicideRequestProto) returns (.org.apache.slider.api.AMSuicideResponseProto);</code>
+ *
+ * <pre>
+ **
+ * kill the AM
+ * </pre>
+ */
+ public abstract void amSuicide(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.AMSuicideRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.AMSuicideResponseProto> done);
+
+ /**
+ * <code>rpc getLivenessInformation(.org.apache.slider.api.GetApplicationLivenessRequestProto) returns (.org.apache.slider.api.ApplicationLivenessInformationProto);</code>
+ */
+ public abstract void getLivenessInformation(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetApplicationLivenessRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ApplicationLivenessInformationProto> done);
+
+ /**
+ * <code>rpc getLiveContainers(.org.apache.slider.api.GetLiveContainersRequestProto) returns (.org.apache.slider.api.GetLiveContainersResponseProto);</code>
+ */
+ public abstract void getLiveContainers(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveContainersRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetLiveContainersResponseProto> done);
+
+ /**
+ * <code>rpc getLiveContainer(.org.apache.slider.api.GetLiveContainerRequestProto) returns (.org.apache.slider.api.ContainerInformationProto);</code>
+ */
+ public abstract void getLiveContainer(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveContainerRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ContainerInformationProto> done);
+
+ /**
+ * <code>rpc getLiveComponents(.org.apache.slider.api.GetLiveComponentsRequestProto) returns (.org.apache.slider.api.GetLiveComponentsResponseProto);</code>
+ */
+ public abstract void getLiveComponents(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveComponentsRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetLiveComponentsResponseProto> done);
+
+ /**
+ * <code>rpc getLiveComponent(.org.apache.slider.api.GetLiveComponentRequestProto) returns (.org.apache.slider.api.ComponentInformationProto);</code>
+ */
+ public abstract void getLiveComponent(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveComponentRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ComponentInformationProto> done);
+
+ /**
+ * <code>rpc getLiveNodes(.org.apache.slider.api.GetLiveNodesRequestProto) returns (.org.apache.slider.api.GetLiveNodesResponseProto);</code>
+ */
+ public abstract void getLiveNodes(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveNodesRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetLiveNodesResponseProto> done);
+
+ /**
+ * <code>rpc getLiveNode(.org.apache.slider.api.GetLiveNodeRequestProto) returns (.org.apache.slider.api.NodeInformationProto);</code>
+ */
+ public abstract void getLiveNode(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveNodeRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.NodeInformationProto> done);
+
+ /**
+ * <code>rpc getModelDesired(.org.apache.slider.api.EmptyPayloadProto) returns (.org.apache.slider.api.WrappedJsonProto);</code>
+ *
+ * <pre>
+ * AggregateConf getModelDesired()
+ * </pre>
+ */
+ public abstract void getModelDesired(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done);
+
+ /**
+ * <code>rpc getModelDesiredAppconf(.org.apache.slider.api.EmptyPayloadProto) returns (.org.apache.slider.api.WrappedJsonProto);</code>
+ *
+ * <pre>
+ * ConfTree getModelDesiredAppconf
+ * </pre>
+ */
+ public abstract void getModelDesiredAppconf(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done);
+
+ /**
+ * <code>rpc getModelDesiredResources(.org.apache.slider.api.EmptyPayloadProto) returns (.org.apache.slider.api.WrappedJsonProto);</code>
+ *
+ * <pre>
+ * ConfTree getModelDesiredResources
+ * </pre>
+ */
+ public abstract void getModelDesiredResources(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done);
+
+ /**
+ * <code>rpc getModelResolved(.org.apache.slider.api.EmptyPayloadProto) returns (.org.apache.slider.api.WrappedJsonProto);</code>
+ *
+ * <pre>
+ * AggregateConf getModelResolved()
+ * </pre>
+ */
+ public abstract void getModelResolved(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done);
+
+ /**
+ * <code>rpc getModelResolvedAppconf(.org.apache.slider.api.EmptyPayloadProto) returns (.org.apache.slider.api.WrappedJsonProto);</code>
+ *
+ * <pre>
+ * ConfTree getModelResolvedAppconf
+ * </pre>
+ */
+ public abstract void getModelResolvedAppconf(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done);
+
+ /**
+ * <code>rpc getModelResolvedResources(.org.apache.slider.api.EmptyPayloadProto) returns (.org.apache.slider.api.WrappedJsonProto);</code>
+ *
+ * <pre>
+ * ConfTree getModelResolvedResources
+ * </pre>
+ */
+ public abstract void getModelResolvedResources(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done);
+
+ /**
+ * <code>rpc getLiveResources(.org.apache.slider.api.EmptyPayloadProto) returns (.org.apache.slider.api.WrappedJsonProto);</code>
+ *
+ * <pre>
+ * ConfTree getLiveResources
+ * </pre>
+ */
+ public abstract void getLiveResources(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done);
+
+ /**
+ * <code>rpc getClientCertificateStore(.org.apache.slider.api.GetCertificateStoreRequestProto) returns (.org.apache.slider.api.GetCertificateStoreResponseProto);</code>
+ */
+ public abstract void getClientCertificateStore(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetCertificateStoreRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetCertificateStoreResponseProto> done);
+
+ public static final
+ com.google.protobuf.Descriptors.ServiceDescriptor
+ getDescriptor() {
+ return org.apache.slider.api.proto.SliderClusterAPI.getDescriptor().getServices().get(0);
+ }
+ public final com.google.protobuf.Descriptors.ServiceDescriptor
+ getDescriptorForType() {
+ return getDescriptor();
+ }
+
+ public final void callMethod(
+ com.google.protobuf.Descriptors.MethodDescriptor method,
+ com.google.protobuf.RpcController controller,
+ com.google.protobuf.Message request,
+ com.google.protobuf.RpcCallback<
+ com.google.protobuf.Message> done) {
+ if (method.getService() != getDescriptor()) {
+ throw new java.lang.IllegalArgumentException(
+ "Service.callMethod() given method descriptor for wrong " +
+ "service type.");
+ }
+ switch(method.getIndex()) {
+ case 0:
+ this.stopCluster(controller, (org.apache.slider.api.proto.Messages.StopClusterRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.StopClusterResponseProto>specializeCallback(
+ done));
+ return;
+ case 1:
+ this.upgradeContainers(controller, (org.apache.slider.api.proto.Messages.UpgradeContainersRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.UpgradeContainersResponseProto>specializeCallback(
+ done));
+ return;
+ case 2:
+ this.flexCluster(controller, (org.apache.slider.api.proto.Messages.FlexClusterRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.FlexClusterResponseProto>specializeCallback(
+ done));
+ return;
+ case 3:
+ this.getJSONClusterStatus(controller, (org.apache.slider.api.proto.Messages.GetJSONClusterStatusRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.GetJSONClusterStatusResponseProto>specializeCallback(
+ done));
+ return;
+ case 4:
+ this.getInstanceDefinition(controller, (org.apache.slider.api.proto.Messages.GetInstanceDefinitionRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.GetInstanceDefinitionResponseProto>specializeCallback(
+ done));
+ return;
+ case 5:
+ this.listNodeUUIDsByRole(controller, (org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleResponseProto>specializeCallback(
+ done));
+ return;
+ case 6:
+ this.getNode(controller, (org.apache.slider.api.proto.Messages.GetNodeRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.GetNodeResponseProto>specializeCallback(
+ done));
+ return;
+ case 7:
+ this.getClusterNodes(controller, (org.apache.slider.api.proto.Messages.GetClusterNodesRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.GetClusterNodesResponseProto>specializeCallback(
+ done));
+ return;
+ case 8:
+ this.echo(controller, (org.apache.slider.api.proto.Messages.EchoRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.EchoResponseProto>specializeCallback(
+ done));
+ return;
+ case 9:
+ this.killContainer(controller, (org.apache.slider.api.proto.Messages.KillContainerRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.KillContainerResponseProto>specializeCallback(
+ done));
+ return;
+ case 10:
+ this.amSuicide(controller, (org.apache.slider.api.proto.Messages.AMSuicideRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.AMSuicideResponseProto>specializeCallback(
+ done));
+ return;
+ case 11:
+ this.getLivenessInformation(controller, (org.apache.slider.api.proto.Messages.GetApplicationLivenessRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.ApplicationLivenessInformationProto>specializeCallback(
+ done));
+ return;
+ case 12:
+ this.getLiveContainers(controller, (org.apache.slider.api.proto.Messages.GetLiveContainersRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.GetLiveContainersResponseProto>specializeCallback(
+ done));
+ return;
+ case 13:
+ this.getLiveContainer(controller, (org.apache.slider.api.proto.Messages.GetLiveContainerRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.ContainerInformationProto>specializeCallback(
+ done));
+ return;
+ case 14:
+ this.getLiveComponents(controller, (org.apache.slider.api.proto.Messages.GetLiveComponentsRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.GetLiveComponentsResponseProto>specializeCallback(
+ done));
+ return;
+ case 15:
+ this.getLiveComponent(controller, (org.apache.slider.api.proto.Messages.GetLiveComponentRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.ComponentInformationProto>specializeCallback(
+ done));
+ return;
+ case 16:
+ this.getLiveNodes(controller, (org.apache.slider.api.proto.Messages.GetLiveNodesRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.GetLiveNodesResponseProto>specializeCallback(
+ done));
+ return;
+ case 17:
+ this.getLiveNode(controller, (org.apache.slider.api.proto.Messages.GetLiveNodeRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.NodeInformationProto>specializeCallback(
+ done));
+ return;
+ case 18:
+ this.getModelDesired(controller, (org.apache.slider.api.proto.Messages.EmptyPayloadProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.WrappedJsonProto>specializeCallback(
+ done));
+ return;
+ case 19:
+ this.getModelDesiredAppconf(controller, (org.apache.slider.api.proto.Messages.EmptyPayloadProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.WrappedJsonProto>specializeCallback(
+ done));
+ return;
+ case 20:
+ this.getModelDesiredResources(controller, (org.apache.slider.api.proto.Messages.EmptyPayloadProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.WrappedJsonProto>specializeCallback(
+ done));
+ return;
+ case 21:
+ this.getModelResolved(controller, (org.apache.slider.api.proto.Messages.EmptyPayloadProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.WrappedJsonProto>specializeCallback(
+ done));
+ return;
+ case 22:
+ this.getModelResolvedAppconf(controller, (org.apache.slider.api.proto.Messages.EmptyPayloadProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.WrappedJsonProto>specializeCallback(
+ done));
+ return;
+ case 23:
+ this.getModelResolvedResources(controller, (org.apache.slider.api.proto.Messages.EmptyPayloadProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.WrappedJsonProto>specializeCallback(
+ done));
+ return;
+ case 24:
+ this.getLiveResources(controller, (org.apache.slider.api.proto.Messages.EmptyPayloadProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.WrappedJsonProto>specializeCallback(
+ done));
+ return;
+ case 25:
+ this.getClientCertificateStore(controller, (org.apache.slider.api.proto.Messages.GetCertificateStoreRequestProto)request,
+ com.google.protobuf.RpcUtil.<org.apache.slider.api.proto.Messages.GetCertificateStoreResponseProto>specializeCallback(
+ done));
+ return;
+ default:
+ throw new java.lang.AssertionError("Can't get here.");
+ }
+ }
+
+ public final com.google.protobuf.Message
+ getRequestPrototype(
+ com.google.protobuf.Descriptors.MethodDescriptor method) {
+ if (method.getService() != getDescriptor()) {
+ throw new java.lang.IllegalArgumentException(
+ "Service.getRequestPrototype() given method " +
+ "descriptor for wrong service type.");
+ }
+ switch(method.getIndex()) {
+ case 0:
+ return org.apache.slider.api.proto.Messages.StopClusterRequestProto.getDefaultInstance();
+ case 1:
+ return org.apache.slider.api.proto.Messages.UpgradeContainersRequestProto.getDefaultInstance();
+ case 2:
+ return org.apache.slider.api.proto.Messages.FlexClusterRequestProto.getDefaultInstance();
+ case 3:
+ return org.apache.slider.api.proto.Messages.GetJSONClusterStatusRequestProto.getDefaultInstance();
+ case 4:
+ return org.apache.slider.api.proto.Messages.GetInstanceDefinitionRequestProto.getDefaultInstance();
+ case 5:
+ return org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleRequestProto.getDefaultInstance();
+ case 6:
+ return org.apache.slider.api.proto.Messages.GetNodeRequestProto.getDefaultInstance();
+ case 7:
+ return org.apache.slider.api.proto.Messages.GetClusterNodesRequestProto.getDefaultInstance();
+ case 8:
+ return org.apache.slider.api.proto.Messages.EchoRequestProto.getDefaultInstance();
+ case 9:
+ return org.apache.slider.api.proto.Messages.KillContainerRequestProto.getDefaultInstance();
+ case 10:
+ return org.apache.slider.api.proto.Messages.AMSuicideRequestProto.getDefaultInstance();
+ case 11:
+ return org.apache.slider.api.proto.Messages.GetApplicationLivenessRequestProto.getDefaultInstance();
+ case 12:
+ return org.apache.slider.api.proto.Messages.GetLiveContainersRequestProto.getDefaultInstance();
+ case 13:
+ return org.apache.slider.api.proto.Messages.GetLiveContainerRequestProto.getDefaultInstance();
+ case 14:
+ return org.apache.slider.api.proto.Messages.GetLiveComponentsRequestProto.getDefaultInstance();
+ case 15:
+ return org.apache.slider.api.proto.Messages.GetLiveComponentRequestProto.getDefaultInstance();
+ case 16:
+ return org.apache.slider.api.proto.Messages.GetLiveNodesRequestProto.getDefaultInstance();
+ case 17:
+ return org.apache.slider.api.proto.Messages.GetLiveNodeRequestProto.getDefaultInstance();
+ case 18:
+ return org.apache.slider.api.proto.Messages.EmptyPayloadProto.getDefaultInstance();
+ case 19:
+ return org.apache.slider.api.proto.Messages.EmptyPayloadProto.getDefaultInstance();
+ case 20:
+ return org.apache.slider.api.proto.Messages.EmptyPayloadProto.getDefaultInstance();
+ case 21:
+ return org.apache.slider.api.proto.Messages.EmptyPayloadProto.getDefaultInstance();
+ case 22:
+ return org.apache.slider.api.proto.Messages.EmptyPayloadProto.getDefaultInstance();
+ case 23:
+ return org.apache.slider.api.proto.Messages.EmptyPayloadProto.getDefaultInstance();
+ case 24:
+ return org.apache.slider.api.proto.Messages.EmptyPayloadProto.getDefaultInstance();
+ case 25:
+ return org.apache.slider.api.proto.Messages.GetCertificateStoreRequestProto.getDefaultInstance();
+ default:
+ throw new java.lang.AssertionError("Can't get here.");
+ }
+ }
+
+ public final com.google.protobuf.Message
+ getResponsePrototype(
+ com.google.protobuf.Descriptors.MethodDescriptor method) {
+ if (method.getService() != getDescriptor()) {
+ throw new java.lang.IllegalArgumentException(
+ "Service.getResponsePrototype() given method " +
+ "descriptor for wrong service type.");
+ }
+ switch(method.getIndex()) {
+ case 0:
+ return org.apache.slider.api.proto.Messages.StopClusterResponseProto.getDefaultInstance();
+ case 1:
+ return org.apache.slider.api.proto.Messages.UpgradeContainersResponseProto.getDefaultInstance();
+ case 2:
+ return org.apache.slider.api.proto.Messages.FlexClusterResponseProto.getDefaultInstance();
+ case 3:
+ return org.apache.slider.api.proto.Messages.GetJSONClusterStatusResponseProto.getDefaultInstance();
+ case 4:
+ return org.apache.slider.api.proto.Messages.GetInstanceDefinitionResponseProto.getDefaultInstance();
+ case 5:
+ return org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleResponseProto.getDefaultInstance();
+ case 6:
+ return org.apache.slider.api.proto.Messages.GetNodeResponseProto.getDefaultInstance();
+ case 7:
+ return org.apache.slider.api.proto.Messages.GetClusterNodesResponseProto.getDefaultInstance();
+ case 8:
+ return org.apache.slider.api.proto.Messages.EchoResponseProto.getDefaultInstance();
+ case 9:
+ return org.apache.slider.api.proto.Messages.KillContainerResponseProto.getDefaultInstance();
+ case 10:
+ return org.apache.slider.api.proto.Messages.AMSuicideResponseProto.getDefaultInstance();
+ case 11:
+ return org.apache.slider.api.proto.Messages.ApplicationLivenessInformationProto.getDefaultInstance();
+ case 12:
+ return org.apache.slider.api.proto.Messages.GetLiveContainersResponseProto.getDefaultInstance();
+ case 13:
+ return org.apache.slider.api.proto.Messages.ContainerInformationProto.getDefaultInstance();
+ case 14:
+ return org.apache.slider.api.proto.Messages.GetLiveComponentsResponseProto.getDefaultInstance();
+ case 15:
+ return org.apache.slider.api.proto.Messages.ComponentInformationProto.getDefaultInstance();
+ case 16:
+ return org.apache.slider.api.proto.Messages.GetLiveNodesResponseProto.getDefaultInstance();
+ case 17:
+ return org.apache.slider.api.proto.Messages.NodeInformationProto.getDefaultInstance();
+ case 18:
+ return org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance();
+ case 19:
+ return org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance();
+ case 20:
+ return org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance();
+ case 21:
+ return org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance();
+ case 22:
+ return org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance();
+ case 23:
+ return org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance();
+ case 24:
+ return org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance();
+ case 25:
+ return org.apache.slider.api.proto.Messages.GetCertificateStoreResponseProto.getDefaultInstance();
+ default:
+ throw new java.lang.AssertionError("Can't get here.");
+ }
+ }
+
+ public static Stub newStub(
+ com.google.protobuf.RpcChannel channel) {
+ return new Stub(channel);
+ }
+
+ public static final class Stub extends org.apache.slider.api.proto.SliderClusterAPI.SliderClusterProtocolPB implements Interface {
+ private Stub(com.google.protobuf.RpcChannel channel) {
+ this.channel = channel;
+ }
+
+ private final com.google.protobuf.RpcChannel channel;
+
+ public com.google.protobuf.RpcChannel getChannel() {
+ return channel;
+ }
+
+ public void stopCluster(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.StopClusterRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.StopClusterResponseProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(0),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.StopClusterResponseProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.StopClusterResponseProto.class,
+ org.apache.slider.api.proto.Messages.StopClusterResponseProto.getDefaultInstance()));
+ }
+
+ public void upgradeContainers(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.UpgradeContainersRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.UpgradeContainersResponseProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(1),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.UpgradeContainersResponseProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.UpgradeContainersResponseProto.class,
+ org.apache.slider.api.proto.Messages.UpgradeContainersResponseProto.getDefaultInstance()));
+ }
+
+ public void flexCluster(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.FlexClusterRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.FlexClusterResponseProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(2),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.FlexClusterResponseProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.FlexClusterResponseProto.class,
+ org.apache.slider.api.proto.Messages.FlexClusterResponseProto.getDefaultInstance()));
+ }
+
+ public void getJSONClusterStatus(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetJSONClusterStatusRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetJSONClusterStatusResponseProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(3),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.GetJSONClusterStatusResponseProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.GetJSONClusterStatusResponseProto.class,
+ org.apache.slider.api.proto.Messages.GetJSONClusterStatusResponseProto.getDefaultInstance()));
+ }
+
+ public void getInstanceDefinition(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetInstanceDefinitionRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetInstanceDefinitionResponseProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(4),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.GetInstanceDefinitionResponseProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.GetInstanceDefinitionResponseProto.class,
+ org.apache.slider.api.proto.Messages.GetInstanceDefinitionResponseProto.getDefaultInstance()));
+ }
+
+ public void listNodeUUIDsByRole(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleResponseProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(5),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleResponseProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleResponseProto.class,
+ org.apache.slider.api.proto.Messages.ListNodeUUIDsByRoleResponseProto.getDefaultInstance()));
+ }
+
+ public void getNode(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetNodeRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetNodeResponseProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(6),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.GetNodeResponseProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.GetNodeResponseProto.class,
+ org.apache.slider.api.proto.Messages.GetNodeResponseProto.getDefaultInstance()));
+ }
+
+ public void getClusterNodes(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetClusterNodesRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetClusterNodesResponseProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(7),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.GetClusterNodesResponseProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.GetClusterNodesResponseProto.class,
+ org.apache.slider.api.proto.Messages.GetClusterNodesResponseProto.getDefaultInstance()));
+ }
+
+ public void echo(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EchoRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.EchoResponseProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(8),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.EchoResponseProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.EchoResponseProto.class,
+ org.apache.slider.api.proto.Messages.EchoResponseProto.getDefaultInstance()));
+ }
+
+ public void killContainer(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.KillContainerRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.KillContainerResponseProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(9),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.KillContainerResponseProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.KillContainerResponseProto.class,
+ org.apache.slider.api.proto.Messages.KillContainerResponseProto.getDefaultInstance()));
+ }
+
+ public void amSuicide(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.AMSuicideRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.AMSuicideResponseProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(10),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.AMSuicideResponseProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.AMSuicideResponseProto.class,
+ org.apache.slider.api.proto.Messages.AMSuicideResponseProto.getDefaultInstance()));
+ }
+
+ public void getLivenessInformation(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetApplicationLivenessRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ApplicationLivenessInformationProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(11),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.ApplicationLivenessInformationProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.ApplicationLivenessInformationProto.class,
+ org.apache.slider.api.proto.Messages.ApplicationLivenessInformationProto.getDefaultInstance()));
+ }
+
+ public void getLiveContainers(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveContainersRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetLiveContainersResponseProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(12),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.GetLiveContainersResponseProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.GetLiveContainersResponseProto.class,
+ org.apache.slider.api.proto.Messages.GetLiveContainersResponseProto.getDefaultInstance()));
+ }
+
+ public void getLiveContainer(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveContainerRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ContainerInformationProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(13),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.ContainerInformationProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.ContainerInformationProto.class,
+ org.apache.slider.api.proto.Messages.ContainerInformationProto.getDefaultInstance()));
+ }
+
+ public void getLiveComponents(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveComponentsRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetLiveComponentsResponseProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(14),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.GetLiveComponentsResponseProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.GetLiveComponentsResponseProto.class,
+ org.apache.slider.api.proto.Messages.GetLiveComponentsResponseProto.getDefaultInstance()));
+ }
+
+ public void getLiveComponent(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveComponentRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.ComponentInformationProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(15),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.ComponentInformationProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.ComponentInformationProto.class,
+ org.apache.slider.api.proto.Messages.ComponentInformationProto.getDefaultInstance()));
+ }
+
+ public void getLiveNodes(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveNodesRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetLiveNodesResponseProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(16),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.GetLiveNodesResponseProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.GetLiveNodesResponseProto.class,
+ org.apache.slider.api.proto.Messages.GetLiveNodesResponseProto.getDefaultInstance()));
+ }
+
+ public void getLiveNode(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetLiveNodeRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.NodeInformationProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(17),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.NodeInformationProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.NodeInformationProto.class,
+ org.apache.slider.api.proto.Messages.NodeInformationProto.getDefaultInstance()));
+ }
+
+ public void getModelDesired(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(18),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.class,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance()));
+ }
+
+ public void getModelDesiredAppconf(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(19),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.class,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance()));
+ }
+
+ public void getModelDesiredResources(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(20),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.class,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance()));
+ }
+
+ public void getModelResolved(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(21),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.class,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance()));
+ }
+
+ public void getModelResolvedAppconf(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(22),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.class,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance()));
+ }
+
+ public void getModelResolvedResources(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(23),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.class,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance()));
+ }
+
+ public void getLiveResources(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.EmptyPayloadProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.WrappedJsonProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(24),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.class,
+ org.apache.slider.api.proto.Messages.WrappedJsonProto.getDefaultInstance()));
+ }
+
+ public void getClientCertificateStore(
+ com.google.protobuf.RpcController controller,
+ org.apache.slider.api.proto.Messages.GetCertificateStoreRequestProto request,
+ com.google.protobuf.RpcCallback<org.apache.slider.api.proto.Messages.GetCertificateStoreResponseProto> done) {
+ channel.callMethod(
+ getDescriptor().getMethods().get(25),
+ controller,
+ request,
+ org.apache.slider.api.proto.Messages.GetCertificateStoreResponseProto.getDefaultInstance(),
+ com.google.protobuf.RpcUtil.generalizeCallback(
+ done,
+ org.apache.slider.api.proto.Messages.GetCertificateStoreResponseProto.class,
+ org.apache.slider.api.proto.Messages.GetCertificateStoreResponseProto.getDefaultInstance()));
+ }
+ }
+
+ public static BlockingInterface newBlockingStub(
+ com.google.protobuf.BlockingRpcChannel channel) {
+ return new BlockingStub(channel);
+ }
+
+ public interface BlockingInterface {
+ public org.apache.slider.api.proto.Messages.StopClusterResponseProto stopCluster(
+ com.google.protobuf.RpcController controller,
+
<TRUNCATED>
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org