Dependencies
- com.fasterxml.jackson.core/jackson-annotations/2.11.2
- com.fasterxml.jackson.core/jackson-core/2.11.2
- com.fasterxml.jackson.core/jackson-databind/2.11.2
- com.fasterxml.jackson.datatype/jackson-datatype-jdk8/2.11.2
- com.fasterxml.jackson.datatype/jackson-datatype-jsr310/2.11.2
- com.github.spotbugs/spotbugs-annotations/4.0.3
- com.google.code.findbugs/jsr305/3.0.2
- io.micronaut/micronaut-aop/2.2.0
- io.micronaut/micronaut-core/2.2.0
- io.micronaut/micronaut-http/2.2.0
- io.micronaut/micronaut-inject/2.2.0
- io.micronaut/micronaut-runtime/2.2.0
- io.micronaut/micronaut-websocket/2.2.0
- io.reactivex.rxjava2/rxjava/2.2.10
- java/11
- javax.annotation/javax.annotation-api/1.3.2
- javax.inject/javax.inject/1
- javax.validation/validation-api/2.0.1.Final
- org.reactivestreams/reactive-streams/1.0.2
- org.slf4j/slf4j-api/1.7.26
- org.yaml/snakeyaml/1.26
Declarations
-
io
-
micronaut
-
http
-
client
-
BlockingHttpClient
-
exchange(HttpRequest<Object>, Argument<Object>, Argument<Object>): HttpResponse<Object>
-
exchange(HttpRequest<Object>, Argument<Object>): HttpResponse<Object>
-
exchange(HttpRequest<Object>): HttpResponse<Object>
-
exchange(HttpRequest<Object>, Class<Object>): HttpResponse<Object>
-
retrieve(HttpRequest<Object>, Argument<Object>): Object
-
retrieve(HttpRequest<Object>, Argument<Object>, Argument<Object>): Object
-
retrieve(HttpRequest<Object>, Class<Object>): Object
-
retrieve(HttpRequest<Object>): String
-
retrieve(String): String
-
retrieve(String, Class<Object>): Object
-
retrieve(String, Class<Object>, Class<Object>): Object
-
exchange(String): HttpResponse<Object>
-
exchange(String, Class<Object>): HttpResponse<Object>
-
exchange(String, Class<Object>, Class<Object>): HttpResponse<Object>
-
-
DefaultHttpClientConfiguration
-
PREFIX: String
-
connectionPoolConfiguration: DefaultConnectionPoolConfiguration
-
DefaultHttpClientConfiguration(): void
-
DefaultHttpClientConfiguration(DefaultConnectionPoolConfiguration, ApplicationConfiguration): void
-
getConnectionPoolConfiguration(): ConnectionPoolConfiguration
-
setClientSslConfiguration(ClientSslConfiguration): void
-
DefaultConnectionPoolConfiguration
-
-
DefaultLoadBalancerResolver
-
serviceInstanceLists: Map<String, ServiceInstanceList>
-
beanContext: BeanContext
-
DefaultLoadBalancerResolver(BeanContext, ServiceInstanceList[]): void
-
DefaultLoadBalancerResolver(BeanContext, List<ServiceInstanceList>): void
-
resolve(String[]): Optional<LoadBalancer>
-
resolveLoadBalancerForServiceID(String): Optional<LoadBalancer>
-
-
HttpClient
-
DEFAULT_ERROR_TYPE: Argument<JsonError>
-
toBlocking(): BlockingHttpClient
-
exchange(HttpRequest<Object>, Argument<Object>, Argument<Object>): Publisher<HttpResponse<Object>>
-
exchange(HttpRequest<Object>, Argument<Object>): Publisher<HttpResponse<Object>>
-
exchange(HttpRequest<Object>): Publisher<HttpResponse<ByteBuffer>>
-
exchange(String): Publisher<HttpResponse<ByteBuffer>>
-
exchange(String, Class<Object>): Publisher<HttpResponse<Object>>
-
exchange(HttpRequest<Object>, Class<Object>): Publisher<HttpResponse<Object>>
-
retrieve(HttpRequest<Object>, Argument<Object>, Argument<Object>): Publisher<Object>
-
retrieve(HttpRequest<Object>, Argument<Object>): Publisher<Object>
-
retrieve(HttpRequest<Object>, Class<Object>): Publisher<Object>
-
retrieve(HttpRequest<Object>): Publisher<String>
-
retrieve(String): Publisher<String>
-
refresh(): HttpClient
-
create(URL): HttpClient
-
create(URL, HttpClientConfiguration): HttpClient
-
-
HttpClientConfiguration
-
proxyUsername: String
-
proxyAddress: SocketAddress
-
DEFAULT_READ_TIMEOUT_SECONDS: long
-
DEFAULT_READ_IDLE_TIMEOUT_MINUTES: long
-
DEFAULT_SHUTDOWN_QUIET_PERIOD_MILLISECONDS: long
-
DEFAULT_SHUTDOWN_TIMEOUT_MILLISECONDS: long
-
DEFAULT_MAX_CONTENT_LENGTH: int
-
DEFAULT_FOLLOW_REDIRECTS: boolean
-
DEFAULT_EXCEPTION_ON_ERROR_STATUS: boolean
-
clientFactory: RxHttpClientFactory
-
channelOptions: Map<String, Object>
-
numOfThreads: Integer
-
threadFactory: Class<ThreadFactory>
-
connectTimeout: Duration
-
connectTtl: Duration
-
readTimeout: Duration
-
readIdleTimeout: Duration
-
shutdownQuietPeriod: Duration
-
shutdownTimeout: Duration
-
maxContentLength: int
-
proxyType: Type
-
proxyPassword: String
-
proxySelector: ProxySelector
-
defaultCharset: Charset
-
followRedirects: boolean
-
exceptionOnErrorStatus: boolean
-
sslConfiguration: SslConfiguration
-
loggerName: String
-
eventLoopGroup: String
-
httpVersion: HttpVersion
-
logLevel: LogLevel
-
HttpClientConfiguration(): void
-
HttpClientConfiguration(ApplicationConfiguration): void
-
HttpClientConfiguration(HttpClientConfiguration): void
-
getHttpVersion(): HttpVersion
-
setHttpVersion(HttpVersion): void
-
getLogLevel(): Optional<LogLevel>
-
setLogLevel(LogLevel): void
-
getEventLoopGroup(): String
-
setEventLoopGroup(String): void
-
getConnectionPoolConfiguration(): ConnectionPoolConfiguration
-
getSslConfiguration(): SslConfiguration
-
setSslConfiguration(SslConfiguration): void
-
isFollowRedirects(): boolean
-
isExceptionOnErrorStatus(): boolean
-
setExceptionOnErrorStatus(boolean): void
-
getLoggerName(): Optional<String>
-
setLoggerName(String): void
-
setFollowRedirects(boolean): void
-
getDefaultCharset(): Charset
-
setDefaultCharset(Charset): void
-
getChannelOptions(): Map<String, Object>
-
setChannelOptions(Map<String, Object>): void
-
getReadTimeout(): Optional<Duration>
-
getReadIdleTimeout(): Optional<Duration>
-
getConnectTimeout(): Optional<Duration>
-
getConnectTtl(): Optional<Duration>
-
getShutdownQuietPeriod(): Optional<Duration>
-
getShutdownTimeout(): Optional<Duration>
-
setShutdownQuietPeriod(Duration): void
-
setShutdownTimeout(Duration): void
-
setReadTimeout(Duration): void
-
setReadIdleTimeout(Duration): void
-
setConnectTimeout(Duration): void
-
setConnectTtl(Duration): void
-
getNumOfThreads(): OptionalInt
-
setNumOfThreads(Integer): void
-
getThreadFactory(): Optional<Class<ThreadFactory>>
-
setThreadFactory(Class<ThreadFactory>): void
-
getMaxContentLength(): int
-
setMaxContentLength(int): void
-
getProxyType(): Type
-
setProxyType(Type): void
-
getProxyAddress(): Optional<SocketAddress>
-
setProxyAddress(SocketAddress): void
-
getProxyUsername(): Optional<String>
-
setProxyUsername(String): void
-
getProxyPassword(): Optional<String>
-
setProxyPassword(String): void
-
setProxySelector(ProxySelector): void
-
getProxySelector(): Optional<ProxySelector>
-
resolveProxy(boolean, String, int): Proxy
-
createClient(URL): RxHttpClient
-
createClient(URL, HttpClientConfiguration): RxHttpClient
-
createStreamingClient(URL): RxStreamingHttpClient
-
createStreamingClient(URL, HttpClientConfiguration): RxStreamingHttpClient
-
getRxHttpClientFactory(): RxHttpClientFactory
-
resolveClientFactory(): RxHttpClientFactory
-
ConnectionPoolConfiguration
-
PREFIX: String
-
DEFAULT_ENABLED: boolean
-
DEFAULT_MAXCONNECTIONS: int
-
maxConnections: int
-
maxPendingAcquires: int
-
acquireTimeout: Duration
-
enabled: boolean
-
isEnabled(): boolean
-
setEnabled(boolean): void
-
getMaxConnections(): int
-
setMaxConnections(int): void
-
getMaxPendingAcquires(): int
-
setMaxPendingAcquires(int): void
-
getAcquireTimeout(): Optional<Duration>
-
setAcquireTimeout(Duration): void
-
-
-
LoadBalancer
-
LoadBalancerResolver
-
ProxyHttpClient
-
ReactiveClientResultTransformer
-
RxHttpClient
-
exchange(HttpRequest<Object>, Argument<Object>): Flowable<HttpResponse<Object>>
-
exchange(HttpRequest<Object>, Argument<Object>, Argument<Object>): Flowable<HttpResponse<Object>>
-
retrieve(HttpRequest<Object>, Argument<Object>, Argument<Object>): Flowable<Object>
-
exchange(HttpRequest<Object>): Flowable<HttpResponse<ByteBuffer>>
-
exchange(String): Flowable<HttpResponse<ByteBuffer>>
-
exchange(String, Class<Object>): Flowable<HttpResponse<Object>>
-
exchange(HttpRequest<Object>, Class<Object>): Flowable<HttpResponse<Object>>
-
retrieve(HttpRequest<Object>, Argument<Object>): Flowable<Object>
-
retrieve(HttpRequest<Object>, Class<Object>): Flowable<Object>
-
retrieve(HttpRequest<Object>): Flowable<String>
-
retrieve(String): Flowable<String>
-
create(URL): RxHttpClient
-
-
RxHttpClientFactory
-
RxHttpClientRegistry
-
RxProxyHttpClient
-
RxStreamingHttpClient
-
dataStream(HttpRequest<Object>): Flowable<ByteBuffer<Object>>
-
exchangeStream(HttpRequest<Object>): Flowable<HttpResponse<ByteBuffer<Object>>>
-
jsonStream(HttpRequest<Object>): Flowable<Map<String, Object>>
-
jsonStream(HttpRequest<Object>, Argument<Object>): Flowable<Object>
-
jsonStream(HttpRequest<Object>, Class<Object>): Flowable<Object>
-
create(URL): RxStreamingHttpClient
-
create(URL, HttpClientConfiguration): RxStreamingHttpClient
-
-
ServiceHttpClientCondition
-
ServiceHttpClientConfiguration
-
PREFIX: String
-
DEFAULT_HEALTHCHECKURI: String
-
DEFAULT_HEALTHCHECK: boolean
-
DEFAULT_HEALTHCHECKINTERVAL_SECONDS: long
-
serviceId: String
-
connectionPoolConfiguration: ServiceConnectionPoolConfiguration
-
urls: List<URI>
-
healthCheckUri: String
-
healthCheck: boolean
-
healthCheckInterval: Duration
-
path: String
-
ServiceHttpClientConfiguration(String, ServiceConnectionPoolConfiguration, ServiceSslClientConfiguration, ApplicationConfiguration): void
-
ServiceHttpClientConfiguration(String, ServiceConnectionPoolConfiguration, ServiceSslClientConfiguration, HttpClientConfiguration): void
-
getServiceId(): String
-
getUrls(): List<URI>
-
setUrls(List<URI>): void
-
setUrl(URI): void
-
getHealthCheckUri(): String
-
setHealthCheckUri(String): void
-
isHealthCheck(): boolean
-
setHealthCheck(boolean): void
-
getPath(): Optional<String>
-
setPath(String): void
-
getContextPath(): Optional<String>
-
getHealthCheckInterval(): Duration
-
setHealthCheckInterval(Duration): void
-
getConnectionPoolConfiguration(): ConnectionPoolConfiguration
-
ServiceConnectionPoolConfiguration
-
ServiceSslClientConfiguration
-
-
ServiceHttpClientFactory
-
taskScheduler: TaskScheduler
-
clientFactory: Provider<RxHttpClientRegistry>
-
ServiceHttpClientFactory(TaskScheduler, Provider<RxHttpClientRegistry>): void
-
serviceInstanceList(ServiceHttpClientConfiguration): StaticServiceInstanceList
-
healthCheckStarter(ServiceHttpClientConfiguration, StaticServiceInstanceList): ApplicationEventListener<ServerStartupEvent>
-
-
StreamingHttpClient
-
dataStream(HttpRequest<Object>): Publisher<ByteBuffer<Object>>
-
exchangeStream(HttpRequest<Object>): Publisher<HttpResponse<ByteBuffer<Object>>>
-
jsonStream(HttpRequest<Object>): Publisher<Map<String, Object>>
-
jsonStream(HttpRequest<Object>, Argument<Object>): Publisher<Object>
-
jsonStream(HttpRequest<Object>, Class<Object>): Publisher<Object>
-
-
annotation
-
bind
-
AnnotatedClientArgumentRequestBinder
-
ClientArgumentRequestBinder
-
ClientRequestUriContext
-
pathParameters: Map<String, Object>
-
queryParameters: Map<String, String>
-
uriTemplate: UriMatchTemplate
-
ClientRequestUriContext(UriMatchTemplate, Map<String, Object>, Map<String, String>): void
-
getUriTemplate(): UriMatchTemplate
-
getPathParameters(): Map<String, Object>
-
getQueryParameters(): Map<String, String>
-
-
DefaultHttpClientBinderRegistry
-
byAnnotation: Map<Class<Annotation>, ClientArgumentRequestBinder>
-
byType: Map<Integer, ClientArgumentRequestBinder>
-
DefaultHttpClientBinderRegistry(ConversionService<ConversionService>, List<ClientArgumentRequestBinder>): void
-
Lambda implementing ClientArgumentRequestBinder<HttpHeaders>
-
Lambda implementing ClientArgumentRequestBinder<Cookies>
-
Lambda implementing ClientArgumentRequestBinder<Cookie>
-
Lambda implementing ClientArgumentRequestBinder<BasicAuth>
-
Lambda implementing ClientArgumentRequestBinder
-
Lambda implementing ClientArgumentRequestBinder
-
Lambda implementing ClientArgumentRequestBinder
-
Lambda implementing ClientArgumentRequestBinder
-
Lambda implementing ClientArgumentRequestBinder
-
Lambda implementing ClientArgumentRequestBinder<Object>
-
-
findArgumentBinder(Argument<Object>): Optional<ClientArgumentRequestBinder<Object>>
-
addBinder(ClientArgumentRequestBinder<Object>): void
-
-
HttpClientBinderRegistry
-
TypedClientArgumentRequestBinder
-
-
converters
-
exceptions
-
ContentLengthExceededException
-
EmptyResponseException
-
HttpClientErrorDecoder
-
HttpClientException
-
HttpClientResponseException
-
response: HttpResponse<Object>
-
errorDecoder: HttpClientErrorDecoder
-
HttpClientResponseException(String, HttpResponse<Object>): void
-
HttpClientResponseException(String, Throwable, HttpResponse<Object>): void
-
HttpClientResponseException(String, Throwable, HttpResponse<Object>, HttpClientErrorDecoder): void
-
getMessage(): String
-
getResponse(): HttpResponse<Object>
-
getStatus(): HttpStatus
-
initResponse(HttpResponse<Object>): void
-
getErrorType(HttpResponse<Object>): Argument<Object>
-
-
NoHostException
-
ReadTimeoutException
-
-
filter
-
ClientFilterResolutionContext
-
DefaultHttpClientFilterResolver
-
clientFilters: List<HttpClientFilter>
-
annotationMetadataResolver: AnnotationMetadataResolver
-
DefaultHttpClientFilterResolver(AnnotationMetadataResolver, List<HttpClientFilter>): void
-
resolveFilterEntries(ClientFilterResolutionContext): List<FilterEntry<HttpClientFilter>>
-
resolveFilters(HttpRequest<Object>, List<FilterEntry<HttpClientFilter>>): List<HttpClientFilter>
-
containsIdentifier(Collection<String>, String[]): boolean
-
anyPatternMatches(String, String[]): boolean
-
anyMethodMatches(HttpMethod, Collection<HttpMethod>): boolean
-
-
-
filters
-
interceptor
-
HttpClientIntroductionAdvice
-
transformers: List<ReactiveClientResultTransformer>
-
LOG: Logger
-
DEFAULT_ACCEPT_TYPES: MediaType[]
-
HEADERS_INITIAL_CAPACITY: int
-
ATTRIBUTES_INITIAL_CAPACITY: int
-
beanContext: BeanContext
-
versioningConfigurations: Map<String, ClientVersioningConfiguration>
-
binderRegistry: HttpClientBinderRegistry
-
jsonMediaTypeCodec: JsonMediaTypeCodec
-
clientFactory: RxHttpClientRegistry
-
HttpClientIntroductionAdvice(BeanContext, RxHttpClientRegistry, JsonMediaTypeCodec, List<ReactiveClientResultTransformer>, HttpClientBinderRegistry): void
-
intercept(MethodInvocationContext<Object, Object>): Object
-
httpClientResponsePublisher(HttpClient, MutableHttpRequest<Object>, ReturnType<Object>, Argument<Object>, Argument<Object>): Publisher
-
httpClientResponseStreamingPublisher(StreamingHttpClient, MediaType[], MutableHttpRequest<Object>, Argument<Object>): Publisher
-
getValue(Argument, MethodInvocationContext<Object, Object>, Map<String, MutableArgumentValue<Object>>, Map<String, Object>): Object
-
handleBlockingCall(Class, Supplier<Object>): Object
-
getVersioningConfiguration(AnnotationMetadata): ClientVersioningConfiguration
-
isJsonParsedMediaType(MediaType[]): boolean
-
resolveTemplate(AnnotationMetadata, String): String
-
getClientId(AnnotationMetadata): String
-
appendQuery(String, Map<String, String>): String
-
-
configuration
-
-
loadbalance
-
multipart
-
AbstractFilePart
-
BytePart
-
FilePart
-
InputStreamPart
-
MultipartBody
-
parts: List<Part<Object>>
-
MultipartBody(List<Part<Object>>): void
-
getData(MultipartDataFactory<Object>): List<Object>
-
builder(): Builder
-
Builder
-
parts: List<Part<Object>>
-
Builder(): void
-
addPart(String, File): Builder
-
addPart(String, String, File): Builder
-
addPart(String, String, MediaType, File): Builder
-
addPart(String, String, byte[]): Builder
-
addPart(String, String, MediaType, byte[]): Builder
-
addPart(String, String, InputStream, long): Builder
-
addPart(String, String, MediaType, InputStream, long): Builder
-
addPart(String, String): Builder
-
addFilePart(AbstractFilePart): Builder
-
build(): MultipartBody
-
-
-
MultipartDataFactory
-
Part
-
StringPart
-
-
reactor
-
rxjava2
-
sse
-
RxSseClient
-
eventStream(HttpRequest<Object>): Flowable<Event<ByteBuffer<Object>>>
-
eventStream(HttpRequest<Object>, Argument<Object>): Flowable<Event<Object>>
-
eventStream(HttpRequest<Object>, Class<Object>): Flowable<Event<Object>>
-
eventStream(String, Class<Object>): Flowable<Event<Object>>
-
eventStream(String, Argument<Object>): Flowable<Event<Object>>
-
-
SseClient
-
eventStream(HttpRequest<Object>): Publisher<Event<ByteBuffer<Object>>>
-
eventStream(HttpRequest<Object>, Argument<Object>): Publisher<Event<Object>>
-
eventStream(HttpRequest<Object>, Class<Object>): Publisher<Event<Object>>
-
eventStream(String, Class<Object>): Publisher<Event<Object>>
-
eventStream(String, Argument<Object>): Publisher<Event<Object>>
-
-
-
-
-
-
Java files
io/micronaut/http/client/
Class files