org.springframework.yarn.boot.actuate.endpoint.mvc

Class YarnContainerRegisterMvcEndpoint

java.lang.Object

org.springframework.boot.actuate.endpoint.mvc.AbstractEndpointMvcAdapter<org.springframework.boot.actuate.endpoint.Endpoint<?>>

org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter

org.springframework.yarn.boot.actuate.endpoint.mvc.YarnContainerRegisterMvcEndpoint

All Implemented Interfaces:

org.springframework.boot.actuate.endpoint.mvc.MvcEndpoint

public class YarnContainerRegisterMvcEndpoint
extends org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter

A custom MvcEndpoint adding specific rest API used to handle graceful YARN application shutdown.

Author:

Janne Valkealahti

Field Summary

Fields inherited from interface org.springframework.boot.actuate.endpoint.mvc.MvcEndpoint

DISABLED_RESPONSE

Constructor Summary

Constructors

Constructor and Description
YarnContainerRegisterMvcEndpoint(YarnContainerRegisterEndpoint delegate) Instantiates a new yarn container register mvc endpoint.

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.Object	invoke()
org.springframework.http.HttpEntity<java.lang.Void>	register(ContainerRegisterResource request)

Methods inherited from class org.springframework.boot.actuate.endpoint.mvc.AbstractEndpointMvcAdapter

getDelegate, getDisabledResponse, getEndpointType, getPath, isSensitive, setPath

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

YarnContainerRegisterMvcEndpoint

public YarnContainerRegisterMvcEndpoint(YarnContainerRegisterEndpoint delegate)

Instantiates a new yarn container register mvc endpoint.

Parameters:

delegate - the delegate endpoint

Method Detail

invoke

@RequestMapping(method=GET)
@ResponseBody
public java.lang.Object invoke()

Overrides:

invoke in class org.springframework.boot.actuate.endpoint.mvc.EndpointMvcAdapter

register

@RequestMapping(method=POST)
public org.springframework.http.HttpEntity<java.lang.Void> register(@RequestBody
                                                                          ContainerRegisterResource request)