SLIDER-782 new messages & RPC calls defined;, marshall and indirect code in progress
Project: http://git-wip-us.apache.org/repos/asf/incubator-slider/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-slider/commit/bc15807c Tree: http://git-wip-us.apache.org/repos/asf/incubator-slider/tree/bc15807c Diff: http://git-wip-us.apache.org/repos/asf/incubator-slider/diff/bc15807c Branch: refs/heads/develop Commit: bc15807cbfe32b0dc4ea9591d7a9a64ba2e1055b Parents: ae6f813 Author: Steve Loughran <[email protected]> Authored: Thu Feb 12 14:48:59 2015 +0000 Committer: Steve Loughran <[email protected]> Committed: Thu Feb 12 14:48:59 2015 +0000 ---------------------------------------------------------------------- .../slider/api/SliderClusterProtocol.java | 11 + .../org/apache/slider/api/proto/Messages.java | 11626 ++++++++++++++++- .../slider/api/proto/RestTypeMarshalling.java | 133 + .../slider/api/proto/SliderClusterAPI.java | 396 +- .../slider/api/types/ComponentInformation.java | 2 +- .../slider/client/SliderClusterOperations.java | 23 +- .../rpc/SliderClusterProtocolPBImpl.java | 12 +- .../rpc/SliderClusterProtocolProxy.java | 54 +- .../server/appmaster/rpc/SliderIPCService.java | 34 +- .../src/main/proto/SliderClusterMessages.proto | 131 +- .../src/main/proto/SliderClusterProtocol.proto | 55 +- .../model/mock/MockSliderClusterProtocol.groovy | 108 - .../view/TestClusterSpecificationBlock.groovy | 3 - .../web/view/TestContainerStatsBlock.groovy | 1 - .../appmaster/web/view/TestIndexBlock.groovy | 1 - 15 files changed, 12374 insertions(+), 216 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-slider/blob/bc15807c/slider-core/src/main/java/org/apache/slider/api/SliderClusterProtocol.java ---------------------------------------------------------------------- diff --git a/slider-core/src/main/java/org/apache/slider/api/SliderClusterProtocol.java b/slider-core/src/main/java/org/apache/slider/api/SliderClusterProtocol.java index fc5c21b..556e918 100644 --- a/slider-core/src/main/java/org/apache/slider/api/SliderClusterProtocol.java +++ b/slider-core/src/main/java/org/apache/slider/api/SliderClusterProtocol.java @@ -22,6 +22,7 @@ import org.apache.hadoop.ipc.VersionedProtocol; import org.apache.hadoop.security.KerberosInfo; import org.apache.hadoop.yarn.exceptions.YarnException; import org.apache.slider.api.proto.Messages; +import org.apache.slider.api.types.ApplicationLivenessInformation; import org.apache.slider.common.SliderXmlConfKeys; import java.io.IOException; @@ -118,4 +119,14 @@ public interface SliderClusterProtocol extends VersionedProtocol { Messages.GetInstanceDefinitionResponseProto getInstanceDefinition( Messages.GetInstanceDefinitionRequestProto request) throws IOException, YarnException; + + /** + * Get the application liveness + * @return current liveness information + * @throws IOException + */ + Messages.ApplicationLivenessInformationProto getLivenessInformation( + Messages.GetApplicationLivenessRequestProto request + ) throws IOException; + }
