public interface com.datastax.oss.driver.api.core.retry.RetryPolicy extends java.lang.AutoCloseable
minor version: 0
major version: 59
flags: flags: (0x0601) ACC_PUBLIC, ACC_INTERFACE, ACC_ABSTRACT
this_class: com.datastax.oss.driver.api.core.retry.RetryPolicy
super_class: java.lang.Object
{
public abstract com.datastax.oss.driver.api.core.retry.RetryDecision onReadTimeout(com.datastax.oss.driver.api.core.session.Request, com.datastax.oss.driver.api.core.ConsistencyLevel, int, int, boolean, int);
descriptor: (Lcom/datastax/oss/driver/api/core/session/Request;Lcom/datastax/oss/driver/api/core/ConsistencyLevel;IIZI)Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
java.lang.Deprecated()
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
1:
edu.umd.cs.findbugs.annotations.NonNull()
2:
3:
4:
5:
MethodParameters:
Name Flags
request
cl
blockFor
received
dataPresent
retryCount
public com.datastax.oss.driver.api.core.retry.RetryVerdict onReadTimeoutVerdict(com.datastax.oss.driver.api.core.session.Request, com.datastax.oss.driver.api.core.ConsistencyLevel, int, int, boolean, int);
descriptor: (Lcom/datastax/oss/driver/api/core/session/Request;Lcom/datastax/oss/driver/api/core/ConsistencyLevel;IIZI)Lcom/datastax/oss/driver/api/core/retry/RetryVerdict;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=8, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
aload 1
aload 2
iload 3
iload 4
iload 5
iload 6
invokeinterface com.datastax.oss.driver.api.core.retry.RetryPolicy.onReadTimeout:(Lcom/datastax/oss/driver/api/core/session/Request;Lcom/datastax/oss/driver/api/core/ConsistencyLevel;IIZI)Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
1: astore 7
start local 7 2: aload 7
invokedynamic getRetryDecision(Lcom/datastax/oss/driver/api/core/retry/RetryDecision;)Lcom/datastax/oss/driver/api/core/retry/RetryVerdict;
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:
()Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
com/datastax/oss/driver/api/core/retry/RetryPolicy.lambda$0(Lcom/datastax/oss/driver/api/core/retry/RetryDecision;)Lcom/datastax/oss/driver/api/core/retry/RetryDecision; (6 itf)
()Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
areturn
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 3 0 this Lcom/datastax/oss/driver/api/core/retry/RetryPolicy;
0 3 1 request Lcom/datastax/oss/driver/api/core/session/Request;
0 3 2 cl Lcom/datastax/oss/driver/api/core/ConsistencyLevel;
0 3 3 blockFor I
0 3 4 received I
0 3 5 dataPresent Z
0 3 6 retryCount I
2 3 7 decision Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
1:
edu.umd.cs.findbugs.annotations.NonNull()
2:
3:
4:
5:
MethodParameters:
Name Flags
request
cl
blockFor
received
dataPresent
retryCount
public abstract com.datastax.oss.driver.api.core.retry.RetryDecision onWriteTimeout(com.datastax.oss.driver.api.core.session.Request, com.datastax.oss.driver.api.core.ConsistencyLevel, com.datastax.oss.driver.api.core.servererrors.WriteType, int, int, int);
descriptor: (Lcom/datastax/oss/driver/api/core/session/Request;Lcom/datastax/oss/driver/api/core/ConsistencyLevel;Lcom/datastax/oss/driver/api/core/servererrors/WriteType;III)Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
java.lang.Deprecated()
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
1:
edu.umd.cs.findbugs.annotations.NonNull()
2:
edu.umd.cs.findbugs.annotations.NonNull()
3:
4:
5:
MethodParameters:
Name Flags
request
cl
writeType
blockFor
received
retryCount
public com.datastax.oss.driver.api.core.retry.RetryVerdict onWriteTimeoutVerdict(com.datastax.oss.driver.api.core.session.Request, com.datastax.oss.driver.api.core.ConsistencyLevel, com.datastax.oss.driver.api.core.servererrors.WriteType, int, int, int);
descriptor: (Lcom/datastax/oss/driver/api/core/session/Request;Lcom/datastax/oss/driver/api/core/ConsistencyLevel;Lcom/datastax/oss/driver/api/core/servererrors/WriteType;III)Lcom/datastax/oss/driver/api/core/retry/RetryVerdict;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=8, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
aload 1
aload 2
aload 3
iload 4
iload 5
iload 6
invokeinterface com.datastax.oss.driver.api.core.retry.RetryPolicy.onWriteTimeout:(Lcom/datastax/oss/driver/api/core/session/Request;Lcom/datastax/oss/driver/api/core/ConsistencyLevel;Lcom/datastax/oss/driver/api/core/servererrors/WriteType;III)Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
astore 7
start local 7 1: aload 7
invokedynamic getRetryDecision(Lcom/datastax/oss/driver/api/core/retry/RetryDecision;)Lcom/datastax/oss/driver/api/core/retry/RetryVerdict;
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:
()Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
com/datastax/oss/driver/api/core/retry/RetryPolicy.lambda$1(Lcom/datastax/oss/driver/api/core/retry/RetryDecision;)Lcom/datastax/oss/driver/api/core/retry/RetryDecision; (6 itf)
()Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
areturn
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 2 0 this Lcom/datastax/oss/driver/api/core/retry/RetryPolicy;
0 2 1 request Lcom/datastax/oss/driver/api/core/session/Request;
0 2 2 cl Lcom/datastax/oss/driver/api/core/ConsistencyLevel;
0 2 3 writeType Lcom/datastax/oss/driver/api/core/servererrors/WriteType;
0 2 4 blockFor I
0 2 5 received I
0 2 6 retryCount I
1 2 7 decision Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
1:
edu.umd.cs.findbugs.annotations.NonNull()
2:
edu.umd.cs.findbugs.annotations.NonNull()
3:
4:
5:
MethodParameters:
Name Flags
request
cl
writeType
blockFor
received
retryCount
public abstract com.datastax.oss.driver.api.core.retry.RetryDecision onUnavailable(com.datastax.oss.driver.api.core.session.Request, com.datastax.oss.driver.api.core.ConsistencyLevel, int, int, int);
descriptor: (Lcom/datastax/oss/driver/api/core/session/Request;Lcom/datastax/oss/driver/api/core/ConsistencyLevel;III)Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
java.lang.Deprecated()
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
1:
edu.umd.cs.findbugs.annotations.NonNull()
2:
3:
4:
MethodParameters:
Name Flags
request
cl
required
alive
retryCount
public com.datastax.oss.driver.api.core.retry.RetryVerdict onUnavailableVerdict(com.datastax.oss.driver.api.core.session.Request, com.datastax.oss.driver.api.core.ConsistencyLevel, int, int, int);
descriptor: (Lcom/datastax/oss/driver/api/core/session/Request;Lcom/datastax/oss/driver/api/core/ConsistencyLevel;III)Lcom/datastax/oss/driver/api/core/retry/RetryVerdict;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=7, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
aload 1
aload 2
iload 3
iload 4
iload 5
invokeinterface com.datastax.oss.driver.api.core.retry.RetryPolicy.onUnavailable:(Lcom/datastax/oss/driver/api/core/session/Request;Lcom/datastax/oss/driver/api/core/ConsistencyLevel;III)Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
astore 6
start local 6 1: aload 6
invokedynamic getRetryDecision(Lcom/datastax/oss/driver/api/core/retry/RetryDecision;)Lcom/datastax/oss/driver/api/core/retry/RetryVerdict;
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:
()Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
com/datastax/oss/driver/api/core/retry/RetryPolicy.lambda$2(Lcom/datastax/oss/driver/api/core/retry/RetryDecision;)Lcom/datastax/oss/driver/api/core/retry/RetryDecision; (6 itf)
()Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
areturn
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 2 0 this Lcom/datastax/oss/driver/api/core/retry/RetryPolicy;
0 2 1 request Lcom/datastax/oss/driver/api/core/session/Request;
0 2 2 cl Lcom/datastax/oss/driver/api/core/ConsistencyLevel;
0 2 3 required I
0 2 4 alive I
0 2 5 retryCount I
1 2 6 decision Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
1:
edu.umd.cs.findbugs.annotations.NonNull()
2:
3:
4:
MethodParameters:
Name Flags
request
cl
required
alive
retryCount
public abstract com.datastax.oss.driver.api.core.retry.RetryDecision onRequestAborted(com.datastax.oss.driver.api.core.session.Request, java.lang.Throwable, int);
descriptor: (Lcom/datastax/oss/driver/api/core/session/Request;Ljava/lang/Throwable;I)Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
java.lang.Deprecated()
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
1:
edu.umd.cs.findbugs.annotations.NonNull()
2:
MethodParameters:
Name Flags
request
error
retryCount
public com.datastax.oss.driver.api.core.retry.RetryVerdict onRequestAbortedVerdict(com.datastax.oss.driver.api.core.session.Request, java.lang.Throwable, int);
descriptor: (Lcom/datastax/oss/driver/api/core/session/Request;Ljava/lang/Throwable;I)Lcom/datastax/oss/driver/api/core/retry/RetryVerdict;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
iload 3
invokeinterface com.datastax.oss.driver.api.core.retry.RetryPolicy.onRequestAborted:(Lcom/datastax/oss/driver/api/core/session/Request;Ljava/lang/Throwable;I)Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
astore 4
start local 4 1: aload 4
invokedynamic getRetryDecision(Lcom/datastax/oss/driver/api/core/retry/RetryDecision;)Lcom/datastax/oss/driver/api/core/retry/RetryVerdict;
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:
()Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
com/datastax/oss/driver/api/core/retry/RetryPolicy.lambda$3(Lcom/datastax/oss/driver/api/core/retry/RetryDecision;)Lcom/datastax/oss/driver/api/core/retry/RetryDecision; (6 itf)
()Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/datastax/oss/driver/api/core/retry/RetryPolicy;
0 2 1 request Lcom/datastax/oss/driver/api/core/session/Request;
0 2 2 error Ljava/lang/Throwable;
0 2 3 retryCount I
1 2 4 decision Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
1:
edu.umd.cs.findbugs.annotations.NonNull()
2:
MethodParameters:
Name Flags
request
error
retryCount
public abstract com.datastax.oss.driver.api.core.retry.RetryDecision onErrorResponse(com.datastax.oss.driver.api.core.session.Request, com.datastax.oss.driver.api.core.servererrors.CoordinatorException, int);
descriptor: (Lcom/datastax/oss/driver/api/core/session/Request;Lcom/datastax/oss/driver/api/core/servererrors/CoordinatorException;I)Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
java.lang.Deprecated()
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
1:
edu.umd.cs.findbugs.annotations.NonNull()
2:
MethodParameters:
Name Flags
request
error
retryCount
public com.datastax.oss.driver.api.core.retry.RetryVerdict onErrorResponseVerdict(com.datastax.oss.driver.api.core.session.Request, com.datastax.oss.driver.api.core.servererrors.CoordinatorException, int);
descriptor: (Lcom/datastax/oss/driver/api/core/session/Request;Lcom/datastax/oss/driver/api/core/servererrors/CoordinatorException;I)Lcom/datastax/oss/driver/api/core/retry/RetryVerdict;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
iload 3
invokeinterface com.datastax.oss.driver.api.core.retry.RetryPolicy.onErrorResponse:(Lcom/datastax/oss/driver/api/core/session/Request;Lcom/datastax/oss/driver/api/core/servererrors/CoordinatorException;I)Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
astore 4
start local 4 1: aload 4
invokedynamic getRetryDecision(Lcom/datastax/oss/driver/api/core/retry/RetryDecision;)Lcom/datastax/oss/driver/api/core/retry/RetryVerdict;
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:
()Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
com/datastax/oss/driver/api/core/retry/RetryPolicy.lambda$4(Lcom/datastax/oss/driver/api/core/retry/RetryDecision;)Lcom/datastax/oss/driver/api/core/retry/RetryDecision; (6 itf)
()Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/datastax/oss/driver/api/core/retry/RetryPolicy;
0 2 1 request Lcom/datastax/oss/driver/api/core/session/Request;
0 2 2 error Lcom/datastax/oss/driver/api/core/servererrors/CoordinatorException;
0 2 3 retryCount I
1 2 4 decision Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
1:
edu.umd.cs.findbugs.annotations.NonNull()
2:
MethodParameters:
Name Flags
request
error
retryCount
public abstract void close();
descriptor: ()V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
private static com.datastax.oss.driver.api.core.retry.RetryDecision lambda$0(com.datastax.oss.driver.api.core.retry.RetryDecision);
descriptor: (Lcom/datastax/oss/driver/api/core/retry/RetryDecision;)Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
areturn
LocalVariableTable:
Start End Slot Name Signature
private static com.datastax.oss.driver.api.core.retry.RetryDecision lambda$1(com.datastax.oss.driver.api.core.retry.RetryDecision);
descriptor: (Lcom/datastax/oss/driver/api/core/retry/RetryDecision;)Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
areturn
LocalVariableTable:
Start End Slot Name Signature
private static com.datastax.oss.driver.api.core.retry.RetryDecision lambda$2(com.datastax.oss.driver.api.core.retry.RetryDecision);
descriptor: (Lcom/datastax/oss/driver/api/core/retry/RetryDecision;)Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
areturn
LocalVariableTable:
Start End Slot Name Signature
private static com.datastax.oss.driver.api.core.retry.RetryDecision lambda$3(com.datastax.oss.driver.api.core.retry.RetryDecision);
descriptor: (Lcom/datastax/oss/driver/api/core/retry/RetryDecision;)Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
areturn
LocalVariableTable:
Start End Slot Name Signature
private static com.datastax.oss.driver.api.core.retry.RetryDecision lambda$4(com.datastax.oss.driver.api.core.retry.RetryDecision);
descriptor: (Lcom/datastax/oss/driver/api/core/retry/RetryDecision;)Lcom/datastax/oss/driver/api/core/retry/RetryDecision;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
areturn
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "RetryPolicy.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles