public interface io.micronaut.http.client.LoadBalancer
minor version: 0
major version: 59
flags: flags: (0x0601) ACC_PUBLIC, ACC_INTERFACE, ACC_ABSTRACT
this_class: io.micronaut.http.client.LoadBalancer
super_class: java.lang.Object
{
public abstract org.reactivestreams.Publisher<io.micronaut.discovery.ServiceInstance> select();
descriptor: (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Ljava/lang/Object;)Lorg/reactivestreams/Publisher<Lio/micronaut/discovery/ServiceInstance;>;
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.Nullable()
MethodParameters:
Name Flags
discriminator
public java.util.Optional<java.lang.String> getContextPath();
descriptor: ()Ljava/util/Optional;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: invokestatic java.util.Optional.empty:()Ljava/util/Optional;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/micronaut/http/client/LoadBalancer;
Signature: ()Ljava/util/Optional<Ljava/lang/String;>;
public org.reactivestreams.Publisher<io.micronaut.discovery.ServiceInstance> select();
descriptor: ()Lorg/reactivestreams/Publisher;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
aconst_null
invokeinterface io.micronaut.http.client.LoadBalancer.select:(Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/micronaut/http/client/LoadBalancer;
Signature: ()Lorg/reactivestreams/Publisher<Lio/micronaut/discovery/ServiceInstance;>;
public static io.micronaut.http.client.LoadBalancer fixed(java.net.URL);
descriptor: (Ljava/net/URL;)Lio/micronaut/http/client/LoadBalancer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.micronaut.http.client.loadbalance.FixedLoadBalancer
dup
aload 0
invokespecial io.micronaut.http.client.loadbalance.FixedLoadBalancer.<init>:(Ljava/net/URL;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 url Ljava/net/URL;
MethodParameters:
Name Flags
url
public static io.micronaut.http.client.LoadBalancer empty();
descriptor: ()Lio/micronaut/http/client/LoadBalancer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: invokedynamic select()Lio/micronaut/http/client/LoadBalancer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
io/micronaut/http/client/LoadBalancer.lambda$0(Ljava/lang/Object;)Lorg/reactivestreams/Publisher; (6 itf)
(Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static org.reactivestreams.Publisher lambda$0(java.lang.Object);
descriptor: (Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.micronaut.discovery.exceptions.NoAvailableServiceException
dup
ldc "Load balancer contains no servers"
invokespecial io.micronaut.discovery.exceptions.NoAvailableServiceException.<init>:(Ljava/lang/String;)V
invokestatic io.micronaut.core.async.publisher.Publishers.just:(Ljava/lang/Throwable;)Lorg/reactivestreams/Publisher;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 discriminator Ljava/lang/Object;
}
SourceFile: "LoadBalancer.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
RuntimeVisibleAnnotations:
java.lang.FunctionalInterface()