Package com.alibaba.spring.boot.rsocket

Class RSocketEndpoint

java.lang.Object

com.alibaba.spring.boot.rsocket.RSocketEndpoint

@Endpoint(id="rsocket")
public class RSocketEndpoint
extends Object

rsocket endpoint for spring boot actuator

Author:

leijuan

Constructor Summary

Constructors

Constructor	Description
RSocketEndpoint(RSocketProperties properties, UpstreamManager upstreamManager, RSocketRequesterSupport rsocketRequesterSupport)

Method Summary

Modifier and Type	Method	Description
Integer	getRsocketServiceStatus()
Map<String,Object>	info()
boolean	isServiceProvider()
reactor.core.publisher.Mono<String>	operate(String action)
reactor.core.publisher.Mono<Void>	sendAppStatus(Integer status)
reactor.core.publisher.Mono<Void>	sendRegisterService(ServiceLocator targetService)
reactor.core.publisher.Mono<Void>	sendUnRegisterService(ServiceLocator targetService)

Methods inherited from class java.lang.Object

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

Constructor Details

RSocketEndpoint

public RSocketEndpoint(RSocketProperties properties,
 UpstreamManager upstreamManager,
 RSocketRequesterSupport rsocketRequesterSupport)

Method Details

info

@ReadOperation
public Map<String,Object> info()

operate

@WriteOperation
public reactor.core.publisher.Mono<String> operate(@Selector
 String action)

sendAppStatus

public reactor.core.publisher.Mono<Void> sendAppStatus(Integer status)

sendRegisterService

public reactor.core.publisher.Mono<Void> sendRegisterService(ServiceLocator targetService)

sendUnRegisterService

public reactor.core.publisher.Mono<Void> sendUnRegisterService(ServiceLocator targetService)

getRsocketServiceStatus

public Integer getRsocketServiceStatus()

isServiceProvider

public boolean isServiceProvider()