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 and Description
RSocketEndpoint(RSocketProperties properties, UpstreamManager upstreamManager, RSocketRequesterSupport rsocketRequesterSupport)

Method Summary

Modifier and Type	Method and 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 Detail

RSocketEndpoint

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

Method Detail

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()