public class io.vertx.config.kubernetes.ConfigMapStore implements io.vertx.config.spi.ConfigStore
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.config.kubernetes.ConfigMapStore
super_class: java.lang.Object
{
private static final java.lang.String KUBERNETES_NAMESPACE;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.util.Base64$Decoder DECODER;
descriptor: Ljava/util/Base64$Decoder;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final io.vertx.core.impl.VertxInternal vertx;
descriptor: Lio/vertx/core/impl/VertxInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.json.JsonObject configuration;
descriptor: Lio/vertx/core/json/JsonObject;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.String namespace;
descriptor: Ljava/lang/String;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.String name;
descriptor: Ljava/lang/String;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.String key;
descriptor: Ljava/lang/String;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final boolean secret;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final boolean optional;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.ext.web.client.WebClient client;
descriptor: Lio/vertx/ext/web/client/WebClient;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private java.lang.String token;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc "KUBERNETES_NAMESPACE"
invokestatic java.lang.System.getenv:(Ljava/lang/String;)Ljava/lang/String;
putstatic io.vertx.config.kubernetes.ConfigMapStore.KUBERNETES_NAMESPACE:Ljava/lang/String;
1: invokestatic java.util.Base64.getDecoder:()Ljava/util/Base64$Decoder;
putstatic io.vertx.config.kubernetes.ConfigMapStore.DECODER:Ljava/util/Base64$Decoder;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(io.vertx.core.Vertx, io.vertx.core.json.JsonObject);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/core/json/JsonObject;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=8, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
checkcast io.vertx.core.impl.VertxInternal
putfield io.vertx.config.kubernetes.ConfigMapStore.vertx:Lio/vertx/core/impl/VertxInternal;
2: aload 0
aload 2
putfield io.vertx.config.kubernetes.ConfigMapStore.configuration:Lio/vertx/core/json/JsonObject;
3: aload 2
ldc "namespace"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 3
start local 3 4: aload 3
ifnonnull 9
5: getstatic io.vertx.config.kubernetes.ConfigMapStore.KUBERNETES_NAMESPACE:Ljava/lang/String;
ifnull 8
6: getstatic io.vertx.config.kubernetes.ConfigMapStore.KUBERNETES_NAMESPACE:Ljava/lang/String;
astore 3
7: goto 9
8: StackMap locals: io.vertx.config.kubernetes.ConfigMapStore io.vertx.core.Vertx io.vertx.core.json.JsonObject java.lang.String
StackMap stack:
ldc "default"
astore 3
9: StackMap locals:
StackMap stack:
aload 0
aload 2
ldc "optional"
iconst_1
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokevirtual io.vertx.core.json.JsonObject.getBoolean:(Ljava/lang/String;Ljava/lang/Boolean;)Ljava/lang/Boolean;
invokevirtual java.lang.Boolean.booleanValue:()Z
putfield io.vertx.config.kubernetes.ConfigMapStore.optional:Z
10: aload 0
aload 3
putfield io.vertx.config.kubernetes.ConfigMapStore.namespace:Ljava/lang/String;
11: aload 0
aload 2
ldc "name"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
putfield io.vertx.config.kubernetes.ConfigMapStore.name:Ljava/lang/String;
12: aload 0
aload 2
ldc "key"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
putfield io.vertx.config.kubernetes.ConfigMapStore.key:Ljava/lang/String;
13: aload 0
aload 2
ldc "secret"
iconst_0
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokevirtual io.vertx.core.json.JsonObject.getBoolean:(Ljava/lang/String;Ljava/lang/Boolean;)Ljava/lang/Boolean;
invokevirtual java.lang.Boolean.booleanValue:()Z
putfield io.vertx.config.kubernetes.ConfigMapStore.secret:Z
14: aload 2
ldc "port"
iconst_0
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual io.vertx.core.json.JsonObject.getInteger:(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer;
invokevirtual java.lang.Integer.intValue:()I
istore 4
start local 4 15: iload 4
ifne 20
16: aload 2
ldc "ssl"
iconst_1
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokevirtual io.vertx.core.json.JsonObject.getBoolean:(Ljava/lang/String;Ljava/lang/Boolean;)Ljava/lang/Boolean;
invokevirtual java.lang.Boolean.booleanValue:()Z
ifeq 19
17: sipush 443
istore 4
18: goto 20
19: StackMap locals: int
StackMap stack:
bipush 80
istore 4
20: StackMap locals:
StackMap stack:
ldc "KUBERNETES_SERVICE_PORT"
invokestatic java.lang.System.getenv:(Ljava/lang/String;)Ljava/lang/String;
astore 5
start local 5 21: aload 5
ifnull 23
22: aload 5
invokestatic java.lang.Integer.valueOf:(Ljava/lang/String;)Ljava/lang/Integer;
invokevirtual java.lang.Integer.intValue:()I
istore 4
23: StackMap locals: java.lang.String
StackMap stack:
aload 2
ldc "host"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 6
start local 6 24: ldc "KUBERNETES_SERVICE_HOST"
invokestatic java.lang.System.getenv:(Ljava/lang/String;)Ljava/lang/String;
astore 7
start local 7 25: aload 7
ifnull 27
26: aload 7
astore 6
27: StackMap locals: java.lang.String java.lang.String
StackMap stack:
aload 0
aload 1
28: new io.vertx.ext.web.client.WebClientOptions
dup
invokespecial io.vertx.ext.web.client.WebClientOptions.<init>:()V
29: iconst_1
invokevirtual io.vertx.ext.web.client.WebClientOptions.setTrustAll:(Z)Lio/vertx/ext/web/client/WebClientOptions;
30: aload 2
ldc "ssl"
iconst_1
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokevirtual io.vertx.core.json.JsonObject.getBoolean:(Ljava/lang/String;Ljava/lang/Boolean;)Ljava/lang/Boolean;
invokevirtual java.lang.Boolean.booleanValue:()Z
invokevirtual io.vertx.ext.web.client.WebClientOptions.setSsl:(Z)Lio/vertx/ext/web/client/WebClientOptions;
31: aload 6
invokevirtual io.vertx.ext.web.client.WebClientOptions.setDefaultHost:(Ljava/lang/String;)Lio/vertx/ext/web/client/WebClientOptions;
32: iload 4
invokevirtual io.vertx.ext.web.client.WebClientOptions.setDefaultPort:(I)Lio/vertx/ext/web/client/WebClientOptions;
33: iconst_1
invokevirtual io.vertx.ext.web.client.WebClientOptions.setFollowRedirects:(Z)Lio/vertx/ext/web/client/WebClientOptions;
34: invokestatic io.vertx.ext.web.client.WebClient.create:(Lio/vertx/core/Vertx;Lio/vertx/ext/web/client/WebClientOptions;)Lio/vertx/ext/web/client/WebClient;
putfield io.vertx.config.kubernetes.ConfigMapStore.client:Lio/vertx/ext/web/client/WebClient;
35: aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.name:Ljava/lang/String;
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
36: return
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 37 0 this Lio/vertx/config/kubernetes/ConfigMapStore;
0 37 1 vertx Lio/vertx/core/Vertx;
0 37 2 configuration Lio/vertx/core/json/JsonObject;
4 37 3 ns Ljava/lang/String;
15 37 4 port I
21 37 5 p Ljava/lang/String;
24 37 6 host Ljava/lang/String;
25 37 7 h Ljava/lang/String;
MethodParameters:
Name Flags
vertx
configuration
public io.vertx.core.Future<java.lang.Void> close();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.client:Lio/vertx/ext/web/client/WebClient;
ifnull 2
1: aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.client:Lio/vertx/ext/web/client/WebClient;
invokeinterface io.vertx.ext.web.client.WebClient.close:()V
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:()Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/config/kubernetes/ConfigMapStore;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
private io.vertx.core.Future<java.lang.String> getToken();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.configuration:Lio/vertx/core/json/JsonObject;
ldc "token"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 1
start local 1 1: aload 1
ifnull 4
aload 1
invokevirtual java.lang.String.trim:()Ljava/lang/String;
invokevirtual java.lang.String.isEmpty:()Z
ifne 4
2: aload 0
aload 1
putfield io.vertx.config.kubernetes.ConfigMapStore.token:Ljava/lang/String;
3: aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
aload 1
invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
4: StackMap locals: java.lang.String
StackMap stack:
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.fileSystem:()Lio/vertx/core/file/FileSystem;
ldc "/var/run/secrets/kubernetes.io/serviceaccount/token"
invokeinterface io.vertx.core.file.FileSystem.readFile:(Ljava/lang/String;)Lio/vertx/core/Future;
5: aload 0
invokedynamic apply(Lio/vertx/config/kubernetes/ConfigMapStore;)Ljava/util/function/Function;
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;)Ljava/lang/Object;
io/vertx/config/kubernetes/ConfigMapStore.lambda$0(Ljava/lang/Throwable;)Lio/vertx/core/Future; (7)
(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.recover:(Ljava/util/function/Function;)Lio/vertx/core/Future;
6: invokedynamic apply()Ljava/util/function/Function;
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;)Ljava/lang/Object;
io/vertx/core/buffer/Buffer.toString()Ljava/lang/String; (9 itf)
(Lio/vertx/core/buffer/Buffer;)Ljava/lang/String;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
7: aload 0
invokedynamic handle(Lio/vertx/config/kubernetes/ConfigMapStore;)Lio/vertx/core/Handler;
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;)V
io/vertx/config/kubernetes/ConfigMapStore.lambda$2(Ljava/lang/String;)V (7)
(Ljava/lang/String;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
8: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/config/kubernetes/ConfigMapStore;
1 9 1 token Ljava/lang/String;
Signature: ()Lio/vertx/core/Future<Ljava/lang/String;>;
public io.vertx.core.Future<io.vertx.core.buffer.Buffer> get();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.token:Ljava/lang/String;
ifnonnull 3
1: aload 0
invokevirtual io.vertx.config.kubernetes.ConfigMapStore.getToken:()Lio/vertx/core/Future;
astore 1
start local 1 2: goto 4
end local 1 3: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.token:Ljava/lang/String;
invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
astore 1
start local 1 4: StackMap locals: io.vertx.core.Future
StackMap stack:
aload 1
aload 0
invokedynamic apply(Lio/vertx/config/kubernetes/ConfigMapStore;)Ljava/util/function/Function;
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;)Ljava/lang/Object;
io/vertx/config/kubernetes/ConfigMapStore.lambda$3(Ljava/lang/String;)Lio/vertx/core/Future; (7)
(Ljava/lang/String;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.flatMap:(Ljava/util/function/Function;)Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/config/kubernetes/ConfigMapStore;
2 3 1 retrieveToken Lio/vertx/core/Future<Ljava/lang/String;>;
4 5 1 retrieveToken Lio/vertx/core/Future<Ljava/lang/String;>;
Signature: ()Lio/vertx/core/Future<Lio/vertx/core/buffer/Buffer;>;
private io.vertx.core.Future<io.vertx.core.buffer.Buffer> handle404();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.optional:Z
ifeq 2
1: ldc "{}"
invokestatic io.vertx.core.buffer.Buffer.buffer:(Ljava/lang/String;)Lio/vertx/core/buffer/Buffer;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
2: StackMap locals:
StackMap stack:
new java.lang.StringBuilder
dup
ldc "Cannot find the config map '"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.name:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "' in '"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.namespace:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "'"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/config/kubernetes/ConfigMapStore;
Signature: ()Lio/vertx/core/Future<Lio/vertx/core/buffer/Buffer;>;
private io.vertx.core.Future<io.vertx.core.buffer.Buffer> handle403();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.StringBuilder
dup
ldc "Access denied to configmap or secret in namespace "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.namespace:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ": "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.name:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/config/kubernetes/ConfigMapStore;
Signature: ()Lio/vertx/core/Future<Lio/vertx/core/buffer/Buffer;>;
private io.vertx.core.Future<io.vertx.core.buffer.Buffer> handleOtherErrors(io.vertx.ext.web.client.HttpResponse<io.vertx.core.buffer.Buffer>);
descriptor: (Lio/vertx/ext/web/client/HttpResponse;)Lio/vertx/core/Future;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.optional:Z
ifeq 2
1: ldc "{}"
invokestatic io.vertx.core.buffer.Buffer.buffer:(Ljava/lang/String;)Lio/vertx/core/buffer/Buffer;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
2: StackMap locals:
StackMap stack:
new java.lang.StringBuilder
dup
ldc "Cannot retrieve the configmap or secret in namespace "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
3: aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.namespace:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ": "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.name:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", status code: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokeinterface io.vertx.ext.web.client.HttpResponse.statusCode:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ", error: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
4: aload 1
invokeinterface io.vertx.ext.web.client.HttpResponse.bodyAsString:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
5: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/config/kubernetes/ConfigMapStore;
0 6 1 response Lio/vertx/ext/web/client/HttpResponse<Lio/vertx/core/buffer/Buffer;>;
Signature: (Lio/vertx/ext/web/client/HttpResponse<Lio/vertx/core/buffer/Buffer;>;)Lio/vertx/core/Future<Lio/vertx/core/buffer/Buffer;>;
MethodParameters:
Name Flags
response
private io.vertx.core.Future<io.vertx.core.buffer.Buffer> handle200(io.vertx.ext.web.client.HttpResponse<io.vertx.core.buffer.Buffer>);
descriptor: (Lio/vertx/ext/web/client/HttpResponse;)Lio/vertx/core/Future;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface io.vertx.ext.web.client.HttpResponse.bodyAsJsonObject:()Lio/vertx/core/json/JsonObject;
ldc "data"
invokevirtual io.vertx.core.json.JsonObject.getJsonObject:(Ljava/lang/String;)Lio/vertx/core/json/JsonObject;
astore 2
start local 2 1: aload 2
ifnonnull 5
2: new java.lang.StringBuilder
dup
ldc "Invalid secret of configmap in namespace "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.namespace:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.name:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
3: ldc ", the data "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "entry is empty"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
4: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
areturn
5: StackMap locals: io.vertx.core.json.JsonObject
StackMap stack:
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.key:Ljava/lang/String;
ifnonnull 9
6: aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.secret:Z
ifeq 8
7: new io.vertx.core.json.JsonObject
dup
aload 2
invokevirtual io.vertx.core.json.JsonObject.getMap:()Ljava/util/Map;
invokestatic io.vertx.config.kubernetes.ConfigMapStore.asSecretObjectMap:(Ljava/util/Map;)Ljava/util/Map;
invokespecial io.vertx.core.json.JsonObject.<init>:(Ljava/util/Map;)V
invokevirtual io.vertx.core.json.JsonObject.toBuffer:()Lio/vertx/core/buffer/Buffer;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
8: StackMap locals:
StackMap stack:
new io.vertx.core.json.JsonObject
dup
aload 2
invokevirtual io.vertx.core.json.JsonObject.getMap:()Ljava/util/Map;
invokestatic io.vertx.config.kubernetes.ConfigMapStore.asObjectMap:(Ljava/util/Map;)Ljava/util/Map;
invokespecial io.vertx.core.json.JsonObject.<init>:(Ljava/util/Map;)V
invokevirtual io.vertx.core.json.JsonObject.toBuffer:()Lio/vertx/core/buffer/Buffer;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
9: StackMap locals:
StackMap stack:
aload 2
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.key:Ljava/lang/String;
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 3
start local 3 10: aload 3
ifnonnull 12
11: new java.lang.StringBuilder
dup
ldc "Cannot find key '"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.key:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "' in the configmap or secret '"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.name:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "'"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
areturn
12: StackMap locals: java.lang.String
StackMap stack:
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.secret:Z
ifeq 14
13: getstatic io.vertx.config.kubernetes.ConfigMapStore.DECODER:Ljava/util/Base64$Decoder;
aload 3
invokevirtual java.util.Base64$Decoder.decode:(Ljava/lang/String;)[B
invokestatic io.vertx.core.buffer.Buffer.buffer:([B)Lio/vertx/core/buffer/Buffer;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
14: StackMap locals:
StackMap stack:
aload 3
invokestatic io.vertx.core.buffer.Buffer.buffer:(Ljava/lang/String;)Lio/vertx/core/buffer/Buffer;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/config/kubernetes/ConfigMapStore;
0 15 1 response Lio/vertx/ext/web/client/HttpResponse<Lio/vertx/core/buffer/Buffer;>;
1 15 2 data Lio/vertx/core/json/JsonObject;
10 15 3 string Ljava/lang/String;
Signature: (Lio/vertx/ext/web/client/HttpResponse<Lio/vertx/core/buffer/Buffer;>;)Lio/vertx/core/Future<Lio/vertx/core/buffer/Buffer;>;
MethodParameters:
Name Flags
response
private static java.util.Map<java.lang.String, java.lang.Object> asObjectMap(java.util.Map<java.lang.String, java.lang.Object>);
descriptor: (Ljava/util/Map;)Ljava/util/Map;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ifnonnull 2
1: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
areturn
2: StackMap locals:
StackMap stack:
aload 0
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
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;)Ljava/lang/Object;
java/util/Map$Entry.getKey()Ljava/lang/Object; (9 itf)
(Ljava/util/Map$Entry;)Ljava/lang/String;
3: invokedynamic apply()Ljava/util/function/Function;
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;)Ljava/lang/Object;
io/vertx/config/kubernetes/ConfigMapStore.lambda$6(Ljava/util/Map$Entry;)Ljava/lang/Object; (6)
(Ljava/util/Map$Entry;)Ljava/lang/Object;
4: invokestatic java.util.stream.Collectors.toMap:(Ljava/util/function/Function;Ljava/util/function/Function;)Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Map
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 source Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;)Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
MethodParameters:
Name Flags
source
private static java.util.Map<java.lang.String, java.lang.Object> asSecretObjectMap(java.util.Map<java.lang.String, java.lang.Object>);
descriptor: (Ljava/util/Map;)Ljava/util/Map;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ifnonnull 2
1: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
areturn
2: StackMap locals:
StackMap stack:
aload 0
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
3: invokedynamic apply()Ljava/util/function/Function;
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;)Ljava/lang/Object;
java/util/Map$Entry.getKey()Ljava/lang/Object; (9 itf)
(Ljava/util/Map$Entry;)Ljava/lang/String;
4: invokedynamic apply()Ljava/util/function/Function;
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;)Ljava/lang/Object;
io/vertx/config/kubernetes/ConfigMapStore.lambda$8(Ljava/util/Map$Entry;)Ljava/lang/Object; (6)
(Ljava/util/Map$Entry;)Ljava/lang/Object;
5: invokestatic java.util.stream.Collectors.toMap:(Ljava/util/function/Function;Ljava/util/function/Function;)Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Map
6: areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 source Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;)Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
MethodParameters:
Name Flags
source
private io.vertx.core.Future lambda$0(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Lio/vertx/core/Future;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.optional:Z
ifeq 1
invokestatic io.vertx.core.buffer.Buffer.buffer:()Lio/vertx/core/buffer/Buffer;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
goto 2
StackMap locals:
StackMap stack:
1: aload 1
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
StackMap locals:
StackMap stack: io.vertx.core.Future
2: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/config/kubernetes/ConfigMapStore;
0 3 1 throwable Ljava/lang/Throwable;
private void lambda$2(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.config.kubernetes.ConfigMapStore.token:Ljava/lang/String;
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/config/kubernetes/ConfigMapStore;
0 2 1 tk Ljava/lang/String;
private io.vertx.core.Future lambda$3(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual java.lang.String.isEmpty:()Z
ifeq 2
1: ldc "{}"
invokestatic io.vertx.core.buffer.Buffer.buffer:(Ljava/lang/String;)Lio/vertx/core/buffer/Buffer;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
2: StackMap locals:
StackMap stack:
new java.lang.StringBuilder
dup
ldc "/api/v1/namespaces/"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.namespace:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 2
start local 2 3: aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.secret:Z
ifeq 6
4: new java.lang.StringBuilder
dup
aload 2
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "/secrets/"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.name:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 2
5: goto 7
6: StackMap locals: java.lang.String
StackMap stack:
new java.lang.StringBuilder
dup
aload 2
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "/configmaps/"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.name:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 2
7: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.config.kubernetes.ConfigMapStore.client:Lio/vertx/ext/web/client/WebClient;
aload 2
invokeinterface io.vertx.ext.web.client.WebClient.get:(Ljava/lang/String;)Lio/vertx/ext/web/client/HttpRequest;
8: ldc "Authorization"
new java.lang.StringBuilder
dup
ldc "Bearer "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface io.vertx.ext.web.client.HttpRequest.putHeader:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/ext/web/client/HttpRequest;
9: invokeinterface io.vertx.ext.web.client.HttpRequest.send:()Lio/vertx/core/Future;
10: aload 0
invokedynamic apply(Lio/vertx/config/kubernetes/ConfigMapStore;)Ljava/util/function/Function;
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;)Ljava/lang/Object;
io/vertx/config/kubernetes/ConfigMapStore.lambda$4(Lio/vertx/ext/web/client/HttpResponse;)Lio/vertx/core/Future; (7)
(Lio/vertx/ext/web/client/HttpResponse;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.flatMap:(Ljava/util/function/Function;)Lio/vertx/core/Future;
11: areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/config/kubernetes/ConfigMapStore;
0 12 1 token Ljava/lang/String;
3 12 2 path Ljava/lang/String;
private static java.lang.Object lambda$6(java.util.Map$Entry);
descriptor: (Ljava/util/Map$Entry;)Ljava/lang/Object;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
invokestatic io.vertx.config.spi.utils.JsonObjectHelper.convert:(Ljava/lang/String;)Ljava/lang/Object;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 entry Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/Object;>;
private static java.lang.Object lambda$8(java.util.Map$Entry);
descriptor: (Ljava/util/Map$Entry;)Ljava/lang/Object;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=1
start local 0 0: aload 0
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
astore 1
start local 1 1: new java.lang.String
dup
getstatic io.vertx.config.kubernetes.ConfigMapStore.DECODER:Ljava/util/Base64$Decoder;
aload 1
invokevirtual java.util.Base64$Decoder.decode:(Ljava/lang/String;)[B
getstatic java.nio.charset.StandardCharsets.UTF_8:Ljava/nio/charset/Charset;
invokespecial java.lang.String.<init>:([BLjava/nio/charset/Charset;)V
astore 2
start local 2 2: aload 2
invokestatic io.vertx.config.spi.utils.JsonObjectHelper.convert:(Ljava/lang/String;)Ljava/lang/Object;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 entry Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/Object;>;
1 3 1 encodedString Ljava/lang/String;
2 3 2 decodedString Ljava/lang/String;
private io.vertx.core.Future lambda$4(io.vertx.ext.web.client.HttpResponse);
descriptor: (Lio/vertx/ext/web/client/HttpResponse;)Lio/vertx/core/Future;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface io.vertx.ext.web.client.HttpResponse.statusCode:()I
sipush 404
if_icmpne 2
1: aload 0
invokevirtual io.vertx.config.kubernetes.ConfigMapStore.handle404:()Lio/vertx/core/Future;
areturn
2: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.vertx.ext.web.client.HttpResponse.statusCode:()I
sipush 403
if_icmpne 4
3: aload 0
invokevirtual io.vertx.config.kubernetes.ConfigMapStore.handle403:()Lio/vertx/core/Future;
areturn
4: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.vertx.ext.web.client.HttpResponse.statusCode:()I
sipush 200
if_icmpeq 6
5: aload 0
aload 1
invokevirtual io.vertx.config.kubernetes.ConfigMapStore.handleOtherErrors:(Lio/vertx/ext/web/client/HttpResponse;)Lio/vertx/core/Future;
areturn
6: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual io.vertx.config.kubernetes.ConfigMapStore.handle200:(Lio/vertx/ext/web/client/HttpResponse;)Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/config/kubernetes/ConfigMapStore;
0 7 1 response Lio/vertx/ext/web/client/HttpResponse<Lio/vertx/core/buffer/Buffer;>;
}
SourceFile: "ConfigMapStore.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public Decoder = java.util.Base64$Decoder of java.util.Base64
public abstract Entry = java.util.Map$Entry of java.util.Map