public final class org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext extends java.lang.Object
{
private final java.lang.String groupId;
private final org.apache.kafkaesque.clients.admin.AbstractOptions options;
private final long deadline;
private final org.apache.kafkaesque.common.internals.KafkaFutureImpl future;
private java.util.Optional node;
public void <init>(java.lang.String, org.apache.kafkaesque.clients.admin.AbstractOptions, long, org.apache.kafkaesque.common.internals.KafkaFutureImpl)
{
org.apache.kafkaesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesque.clients.admin.AbstractOptions v;
org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext v;
java.util.Optional v;
long v;
java.lang.String v;
v := @this: org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext;
v := @parameter: java.lang.String;
v := @parameter: org.apache.kafkaesque.clients.admin.AbstractOptions;
v := @parameter: long;
v := @parameter: org.apache.kafkaesque.common.internals.KafkaFutureImpl;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext: java.lang.String groupId> = v;
v.<org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext: org.apache.kafkaesque.clients.admin.AbstractOptions options> = v;
v.<org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext: long deadline> = v;
v.<org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext: org.apache.kafkaesque.common.internals.KafkaFutureImpl future> = v;
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
v.<org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext: java.util.Optional node> = v;
return;
}
public java.lang.String groupId()
{
java.lang.String v;
org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext v;
v := @this: org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext;
v = v.<org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext: java.lang.String groupId>;
return v;
}
public org.apache.kafkaesque.clients.admin.AbstractOptions options()
{
org.apache.kafkaesque.clients.admin.AbstractOptions v;
org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext v;
v := @this: org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext;
v = v.<org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext: org.apache.kafkaesque.clients.admin.AbstractOptions options>;
return v;
}
public long deadline()
{
long v;
org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext v;
v := @this: org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext;
v = v.<org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext: long deadline>;
return v;
}
public org.apache.kafkaesque.common.internals.KafkaFutureImpl future()
{
org.apache.kafkaesque.common.internals.KafkaFutureImpl v;
org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext v;
v := @this: org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext;
v = v.<org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext: org.apache.kafkaesque.common.internals.KafkaFutureImpl future>;
return v;
}
public java.util.Optional node()
{
java.util.Optional v;
org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext v;
v := @this: org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext;
v = v.<org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext: java.util.Optional node>;
return v;
}
public void setNode(org.apache.kafkaesque.common.Node)
{
java.util.Optional v;
org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext v;
org.apache.kafkaesque.common.Node v;
v := @this: org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext;
v := @parameter: org.apache.kafkaesque.common.Node;
v = staticinvoke <java.util.Optional: java.util.Optional ofNullable(java.lang.Object)>(v);
v.<org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext: java.util.Optional node> = v;
return;
}
public static boolean hasCoordinatorMoved(org.apache.kafkaesque.common.requests.AbstractResponse)
{
java.util.stream.Stream v;
java.util.function.Predicate v;
java.util.Map v;
java.util.Set v;
org.apache.kafkaesque.common.requests.AbstractResponse v;
boolean v;
v := @parameter: org.apache.kafkaesque.common.requests.AbstractResponse;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.AbstractResponse: java.util.Map errorCounts()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.kafkaesque.clients.admin.internals.ConsumerGroupOperationContext$lambda_hasCoordinatorMoved_0__491: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: boolean anyMatch(java.util.function.Predicate)>(v);
return v;
}
public static boolean shouldRefreshCoordinator(org.apache.kafkaesque.common.protocol.Errors)
{
org.apache.kafkaesque.common.protocol.Errors v, v, v;
boolean v;
v := @parameter: org.apache.kafkaesque.common.protocol.Errors;
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors COORDINATOR_LOAD_IN_PROGRESS>;
if v == v goto label;
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors COORDINATOR_NOT_AVAILABLE>;
if v != v goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
}