A B C D E G H I J M O P R S U V W

A

accept(CloudEventImpl<?>) - Method in class com.alibaba.spring.boot.rsocket.CloudEventToListenerConsumer

accept(CloudEventImpl<?>) - Method in class com.alibaba.spring.boot.rsocket.InvalidCacheEventConsumer

addRequesterInterceptor(RSocketInterceptor) - Method in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

addRequesterInterceptor(RSocketInterceptor) - Method in interface com.alibaba.spring.boot.rsocket.upstream.RSocketRequesterSupportBuilder

addRequesterInterceptor(RSocketInterceptor) - Method in class com.alibaba.spring.boot.rsocket.upstream.RSocketRequesterSupportBuilderImpl

addResponderInterceptor(RSocketInterceptor) - Method in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

addResponderInterceptor(RSocketInterceptor) - Method in interface com.alibaba.spring.boot.rsocket.upstream.RSocketRequesterSupportBuilder

addResponderInterceptor(RSocketInterceptor) - Method in class com.alibaba.spring.boot.rsocket.upstream.RSocketRequesterSupportBuilderImpl

analyze(Throwable, JwtTokenNotFoundException) - Method in class com.alibaba.spring.boot.rsocket.upstream.JwtTokenFailureAnalyzer

applicationContext - Variable in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

appName - Variable in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

B

build() - Method in interface com.alibaba.spring.boot.rsocket.upstream.RSocketRequesterSupportBuilder

build() - Method in class com.alibaba.spring.boot.rsocket.upstream.RSocketRequesterSupportBuilderImpl

C

canDecode(ResolvableType, MimeType) - Method in class com.alibaba.spring.boot.rsocket.hessian.HessianDecoder

canEncode(ResolvableType, MimeType) - Method in class com.alibaba.spring.boot.rsocket.hessian.HessianEncoder

check(String) - Method in class com.alibaba.spring.boot.rsocket.health.RSocketServiceHealthImpl

cloudEventsProcessor(TopicProcessor<CloudEventImpl>, ObjectProvider<CloudEventsConsumer>) - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

CloudEventToListenerConsumer - Class in com.alibaba.spring.boot.rsocket

CloudEvent to @EventListener handler

CloudEventToListenerConsumer() - Constructor for class com.alibaba.spring.boot.rsocket.CloudEventToListenerConsumer

cloudEventToListenerConsumer() - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

com.alibaba.spring.boot.rsocket - package com.alibaba.spring.boot.rsocket

com.alibaba.spring.boot.rsocket.health - package com.alibaba.spring.boot.rsocket.health

com.alibaba.spring.boot.rsocket.hessian - package com.alibaba.spring.boot.rsocket.hessian

com.alibaba.spring.boot.rsocket.observability - package com.alibaba.spring.boot.rsocket.observability

com.alibaba.spring.boot.rsocket.responder - package com.alibaba.spring.boot.rsocket.responder

com.alibaba.spring.boot.rsocket.responder.invocation - package com.alibaba.spring.boot.rsocket.responder.invocation

com.alibaba.spring.boot.rsocket.upstream - package com.alibaba.spring.boot.rsocket.upstream

customize(RSocketRequesterSupportBuilder) - Method in interface com.alibaba.spring.boot.rsocket.upstream.RSocketRequesterSupportCustomizer

D

decode(DataBuffer) - Method in class com.alibaba.spring.boot.rsocket.hessian.HessianCodecSupport

decode(Publisher<DataBuffer>, ResolvableType, MimeType, Map<String, Object>) - Method in class com.alibaba.spring.boot.rsocket.hessian.HessianDecoder

decodeToMono(Publisher<DataBuffer>, ResolvableType, MimeType, Map<String, Object>) - Method in class com.alibaba.spring.boot.rsocket.hessian.HessianDecoder

defaultRSocketListenerCustomizer(SocketAcceptor, RSocketProperties) - Method in class com.alibaba.spring.boot.rsocket.RSocketListenerAutoConfiguration

E

encode(Object, DataBufferFactory) - Method in class com.alibaba.spring.boot.rsocket.hessian.HessianCodecSupport

encode(Publisher<?>, DataBufferFactory, ResolvableType, MimeType, Map<String, Object>) - Method in class com.alibaba.spring.boot.rsocket.hessian.HessianEncoder

encodeValue(Object, DataBufferFactory, ResolvableType, MimeType, Map<String, Object>) - Method in class com.alibaba.spring.boot.rsocket.hessian.HessianEncoder

env - Variable in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

EnvironmentProperties - Class in com.alibaba.spring.boot.rsocket

environment with properties wrapper

EnvironmentProperties(Environment) - Constructor for class com.alibaba.spring.boot.rsocket.EnvironmentProperties

equals(Object) - Method in class com.alibaba.spring.boot.rsocket.EnvironmentProperties

exposedServices() - Method in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

G

getBrokers() - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

getDecodableMimeTypes() - Method in class com.alibaba.spring.boot.rsocket.hessian.HessianDecoder

getEncodableMimeTypes() - Method in class com.alibaba.spring.boot.rsocket.hessian.HessianEncoder

getGroup() - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

getJwtToken() - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

getMetadata() - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

getP2pServices() - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

getPort() - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

getProperty(String) - Method in class com.alibaba.spring.boot.rsocket.EnvironmentProperties

getProperty(String, String) - Method in class com.alibaba.spring.boot.rsocket.EnvironmentProperties

getRoutes() - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

getRsocketServiceStatus() - Method in class com.alibaba.spring.boot.rsocket.RSocketEndpoint

getSchema() - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

getTimeout() - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

getTopology() - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

getVersion() - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

H

hashCode() - Method in class com.alibaba.spring.boot.rsocket.EnvironmentProperties

health() - Method in class com.alibaba.spring.boot.rsocket.RSocketBrokerHealthIndicator

HESSIAN_MIME_TYPE - Static variable in class com.alibaba.spring.boot.rsocket.hessian.HessianCodecSupport

HESSIAN_MIME_TYPES - Static variable in class com.alibaba.spring.boot.rsocket.hessian.HessianCodecSupport

HessianCodecSupport - Class in com.alibaba.spring.boot.rsocket.hessian

Hessian Codec support

HessianCodecSupport() - Constructor for class com.alibaba.spring.boot.rsocket.hessian.HessianCodecSupport

HessianDecoder - Class in com.alibaba.spring.boot.rsocket.hessian

Hessian Decoder

HessianDecoder() - Constructor for class com.alibaba.spring.boot.rsocket.hessian.HessianDecoder

HessianEncoder - Class in com.alibaba.spring.boot.rsocket.hessian

Hessian encoder

HessianEncoder() - Constructor for class com.alibaba.spring.boot.rsocket.hessian.HessianEncoder

I

info() - Method in class com.alibaba.spring.boot.rsocket.RSocketEndpoint

init() - Method in class com.alibaba.spring.boot.rsocket.upstream.SmartLifecycleUpstreamManagerImpl

inputStreamToString(InputStream) - Method in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

InvalidCacheEventConsumer - Class in com.alibaba.spring.boot.rsocket

InvalidCacheEvent consumer

InvalidCacheEventConsumer() - Constructor for class com.alibaba.spring.boot.rsocket.InvalidCacheEventConsumer

isRunning() - Method in class com.alibaba.spring.boot.rsocket.upstream.SmartLifecycleUpstreamManagerImpl

isServiceProvider() - Method in class com.alibaba.spring.boot.rsocket.RSocketEndpoint

J

jwtToken - Variable in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

JwtTokenFailureAnalyzer - Class in com.alibaba.spring.boot.rsocket.upstream

JWT token failure analyzer

JwtTokenFailureAnalyzer() - Constructor for class com.alibaba.spring.boot.rsocket.upstream.JwtTokenFailureAnalyzer

JwtTokenNotFoundException - Exception in com.alibaba.spring.boot.rsocket.upstream

JWT token not found exception

JwtTokenNotFoundException() - Constructor for exception com.alibaba.spring.boot.rsocket.upstream.JwtTokenNotFoundException

M

metricsService(PrometheusMeterRegistry) - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

MetricsServicePrometheusImpl - Class in com.alibaba.spring.boot.rsocket.observability

metrics service Prometheus implementation

MetricsServicePrometheusImpl(PrometheusMeterRegistry) - Constructor for class com.alibaba.spring.boot.rsocket.observability.MetricsServicePrometheusImpl

O

onApplicationEvent(ApplicationReadyEvent) - Method in class com.alibaba.spring.boot.rsocket.responder.RSocketServicesPublishHook

operate(String) - Method in class com.alibaba.spring.boot.rsocket.RSocketEndpoint

originUri() - Method in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

P

postProcessAfterInitialization(Object, String) - Method in class com.alibaba.spring.boot.rsocket.responder.invocation.RSocketServiceAnnotationProcessor

postProcessBeforeInitialization(Object, String) - Method in class com.alibaba.spring.boot.rsocket.responder.invocation.RSocketServiceAnnotationProcessor

properties - Variable in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

propertyNames() - Method in class com.alibaba.spring.boot.rsocket.EnvironmentProperties

R

reactiveCloudEventProcessor() - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

requesterSupport(RSocketRequesterSupport) - Method in class com.alibaba.spring.boot.rsocket.upstream.RSocketRequesterSupportBuilderImpl

requestInterceptors - Variable in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

requestInterceptors() - Method in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

responderInterceptors - Variable in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

responderInterceptors() - Method in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

RSocketAutoConfiguration - Class in com.alibaba.spring.boot.rsocket

RSocket Auto configuration: listen, upstream manager, handler etc

RSocketAutoConfiguration() - Constructor for class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

rsocketBrokerHealth(RSocketEndpoint, UpstreamManager, String) - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

RSocketBrokerHealthIndicator - Class in com.alibaba.spring.boot.rsocket

RSocket Broker health indicator

RSocketBrokerHealthIndicator(RSocketEndpoint, UpstreamManager, String) - Constructor for class com.alibaba.spring.boot.rsocket.RSocketBrokerHealthIndicator

rsocketEndpoint(UpstreamManager, RSocketRequesterSupport) - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

RSocketEndpoint - Class in com.alibaba.spring.boot.rsocket

rsocket endpoint for spring boot actuator

RSocketEndpoint(RSocketProperties, UpstreamManager, RSocketRequesterSupport) - Constructor for class com.alibaba.spring.boot.rsocket.RSocketEndpoint

rsocketListener(ObjectProvider<RSocketListenerCustomizer>) - Method in class com.alibaba.spring.boot.rsocket.RSocketListenerAutoConfiguration

RSocketListenerAutoConfiguration - Class in com.alibaba.spring.boot.rsocket

RSocket listener configuration

RSocketListenerAutoConfiguration() - Constructor for class com.alibaba.spring.boot.rsocket.RSocketListenerAutoConfiguration

RSocketProperties - Class in com.alibaba.spring.boot.rsocket

RSocket Properties

RSocketProperties() - Constructor for class com.alibaba.spring.boot.rsocket.RSocketProperties

rsocketRequesterSupport(RSocketProperties, Environment, SocketAcceptor, ObjectProvider<RSocketRequesterSupportCustomizer>) - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

RSocketRequesterSupportBuilder - Interface in com.alibaba.spring.boot.rsocket.upstream

RSocket Requester support builder

RSocketRequesterSupportBuilderImpl - Class in com.alibaba.spring.boot.rsocket.upstream

RSocket Requester support builder implementation

RSocketRequesterSupportBuilderImpl(RSocketProperties, Properties, SocketAcceptor) - Constructor for class com.alibaba.spring.boot.rsocket.upstream.RSocketRequesterSupportBuilderImpl

RSocketRequesterSupportCustomizer - Interface in com.alibaba.spring.boot.rsocket.upstream

rsocket requester support customizer

RSocketRequesterSupportImpl - Class in com.alibaba.spring.boot.rsocket

RSocket Requester Support implementation: setup payload, published service, token and app info

RSocketRequesterSupportImpl(RSocketProperties, Properties, SocketAcceptor) - Constructor for class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

rsocketResponderHandlerFactory(LocalReactiveServiceCaller, TopicProcessor<CloudEventImpl>) - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

socket responder handler as SocketAcceptor bean.

rsocketResponderHandlerFactoryWithZipkin(LocalReactiveServiceCaller, TopicProcessor<CloudEventImpl>) - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

RSocketServiceAnnotationProcessor - Class in com.alibaba.spring.boot.rsocket.responder.invocation

RSocketService annotation processor

RSocketServiceAnnotationProcessor(RSocketProperties) - Constructor for class com.alibaba.spring.boot.rsocket.responder.invocation.RSocketServiceAnnotationProcessor

rSocketServiceAnnotationProcessor(RSocketProperties) - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

rsocketServiceHealth() - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

RSocketServiceHealthImpl - Class in com.alibaba.spring.boot.rsocket.health

RSocket service health default implementation

RSocketServiceHealthImpl() - Constructor for class com.alibaba.spring.boot.rsocket.health.RSocketServiceHealthImpl

RSocketServicesPublishHook - Class in com.alibaba.spring.boot.rsocket.responder

RSocket services publish hook

RSocketServicesPublishHook() - Constructor for class com.alibaba.spring.boot.rsocket.responder.RSocketServicesPublishHook

rsocketServicesPublishHook() - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

rsocketUpstreamManager(RSocketRequesterSupport) - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

S

scanRSocketServiceAnnotation(Object, String) - Method in class com.alibaba.spring.boot.rsocket.responder.invocation.RSocketServiceAnnotationProcessor

scrape() - Method in class com.alibaba.spring.boot.rsocket.observability.MetricsServicePrometheusImpl

sendAppStatus(Integer) - Method in class com.alibaba.spring.boot.rsocket.RSocketEndpoint

sendRegisterService(ServiceLocator) - Method in class com.alibaba.spring.boot.rsocket.RSocketEndpoint

sendUnRegisterService(ServiceLocator) - Method in class com.alibaba.spring.boot.rsocket.RSocketEndpoint

serviceInstancesChangedEventConsumer(UpstreamManager) - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

servicesExposedEvent() - Method in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

setApplicationContext(ApplicationContext) - Method in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

setBrokers(List<String>) - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

setGroup(String) - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

setJwtToken(String) - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

setMetadata(Map<String, String>) - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

setP2pServices(List<String>) - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

setPort(Integer) - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

setRoutes(List<RoutingEndpoint>) - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

setSchema(String) - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

setTimeout(Integer) - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

setTopology(String) - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

setupPayload(String) - Method in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

setVersion(String) - Method in class com.alibaba.spring.boot.rsocket.RSocketProperties

shouldAccept(CloudEventImpl<?>) - Method in class com.alibaba.spring.boot.rsocket.CloudEventToListenerConsumer

shouldAccept(CloudEventImpl<?>) - Method in class com.alibaba.spring.boot.rsocket.InvalidCacheEventConsumer

SmartLifecycleUpstreamManagerImpl - Class in com.alibaba.spring.boot.rsocket.upstream

SmartLifecycle UpstreamManager implementation with graceful shutdown support

SmartLifecycleUpstreamManagerImpl(RSocketRequesterSupport) - Constructor for class com.alibaba.spring.boot.rsocket.upstream.SmartLifecycleUpstreamManagerImpl

socketAcceptor - Variable in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

socketAcceptor() - Method in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

start() - Method in class com.alibaba.spring.boot.rsocket.upstream.SmartLifecycleUpstreamManagerImpl

stop() - Method in class com.alibaba.spring.boot.rsocket.upstream.SmartLifecycleUpstreamManagerImpl

stop(Runnable) - Method in class com.alibaba.spring.boot.rsocket.upstream.SmartLifecycleUpstreamManagerImpl

stringPropertyNames() - Method in class com.alibaba.spring.boot.rsocket.EnvironmentProperties

subscribedServices() - Method in class com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

U

upstreamClusterChangedEventConsumer(UpstreamManager) - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

V

version - Variable in class com.alibaba.spring.boot.rsocket.RSocketProperties

version for exposed services

W

webServerInitializedEventApplicationListener() - Method in class com.alibaba.spring.boot.rsocket.RSocketAutoConfiguration

A B C D E G H I J M O P R S U V W