public class io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectorBuilder extends java.lang.Object
{
private final io.fabric.kubernetes.clnt.v.dsl.Namespaceable client;
private io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig leaderElectionConfig;
public void <init>(io.fabric.kubernetes.clnt.v.dsl.Namespaceable)
{
io.fabric.kubernetes.clnt.v.dsl.Namespaceable v;
io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectorBuilder v;
v := @this: io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectorBuilder;
v := @parameter: io.fabric.kubernetes.clnt.v.dsl.Namespaceable;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectorBuilder: io.fabric.kubernetes.clnt.v.dsl.Namespaceable client> = v;
return;
}
public io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectorBuilder withConfig(io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig)
{
io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig v, v;
io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectorBuilder v;
v := @this: io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectorBuilder;
v := @parameter: io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig;
v = staticinvoke <io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectorBuilder: io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig validate(io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig)>(v);
v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectorBuilder: io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig leaderElectionConfig> = v;
return v;
}
public io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElector build()
{
io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig v;
io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElector v;
io.fabric.kubernetes.clnt.v.dsl.Namespaceable v;
io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectorBuilder v;
v := @this: io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectorBuilder;
v = new io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElector;
v = v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectorBuilder: io.fabric.kubernetes.clnt.v.dsl.Namespaceable client>;
v = v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectorBuilder: io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig leaderElectionConfig>;
specialinvoke v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElector: void <init>(io.fabric.kubernetes.clnt.v.dsl.Namespaceable,io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig)>(v, v);
return v;
}
private static io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig validate(io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig)
{
io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig v;
byte v, v, v;
java.time.Duration v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Double v;
long v, v, v, v;
io.fabric.kubernetes.clnt.v.extended.leaderelection.resourcelock.Lock v;
int v, v;
io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderCallbacks v;
java.lang.String v;
double v, v, v;
java.lang.IllegalArgumentException v, v, v, v, v;
v := @parameter: io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig;
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "LeaderElectionConfig is required");
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig: java.lang.String getName()>();
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "name is required");
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig: java.time.Duration getLeaseDuration()>();
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "leaseDuration is required");
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig: java.time.Duration getRenewDeadline()>();
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "renewDeadLine is required");
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig: java.time.Duration getRetryPeriod()>();
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "retryPeriod is required");
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig: io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderCallbacks getLeaderCallbacks()>();
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "leaderCallbacks are required");
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig: io.fabric.kubernetes.clnt.v.extended.leaderelection.resourcelock.Lock getLock()>();
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "lock is required");
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig: java.time.Duration getLeaseDuration()>();
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig: java.time.Duration getRenewDeadline()>();
v = virtualinvoke v.<java.time.Duration: int compareTo(java.time.Duration)>(v);
if v > 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("leaseDuration must be greater than renewDeadLine");
throw v;
label:
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig: java.time.Duration getRetryPeriod()>();
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig: java.time.Duration getRetryPeriod()>();
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
v = <io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElector: java.lang.Double JITTER_FACTOR>;
v = virtualinvoke v.<java.lang.Double: double doubleValue()>();
v = v * v;
v = staticinvoke <java.lang.Math: double ceil(double)>(v);
v = virtualinvoke v.<java.time.Duration: java.time.Duration plusMillis(long)>(v);
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig: java.time.Duration getRenewDeadline()>();
v = virtualinvoke v.<java.time.Duration: int compareTo(java.time.Duration)>(v);
if v > 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("renewDeadline must be greater than retryPeriod + retryPeriod*JITTER_FACTOR");
throw v;
label:
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig: java.time.Duration getLeaseDuration()>();
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
v = v cmp 1L;
if v >= 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("leaseDuration must be greater than zero");
throw v;
label:
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig: java.time.Duration getRenewDeadline()>();
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
v = v cmp 1L;
if v >= 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("renewDeadline must be greater than zero");
throw v;
label:
v = virtualinvoke v.<io.fabric.kubernetes.clnt.v.extended.leaderelection.LeaderElectionConfig: java.time.Duration getRetryPeriod()>();
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
v = v cmp 1L;
if v >= 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("retryPeriod must be greater than zero");
throw v;
label:
return v;
}
}