Class UnattachedState
public class UnattachedState : EpochState, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition, IEpochState, ICloseable, IAutoCloseable
- Inheritance
-
UnattachedState
- Implements
Constructors
UnattachedState(IJVMBridgeBaseInitializer)
Initializer used internally by JCOBridge. Do not use directly.
[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public UnattachedState(IJVMBridgeBaseInitializer initializer)
Parameters
initializerIJVMBridgeBaseInitializer
UnattachedState(Time, int, OptionalInt, Optional<ReplicaKey>, Set<Integer>, Optional<LogOffsetMetadata>, long, LogContext)
public UnattachedState(Time arg0, int arg1, OptionalInt arg2, Optional<ReplicaKey> arg3, Set<Integer> arg4, Optional<LogOffsetMetadata> arg5, long arg6, LogContext arg7)
Parameters
arg0Timearg1intarg2OptionalIntarg3Optional<ReplicaKey>arg4Set<Integer>arg5Optional<LogOffsetMetadata>arg6longarg7LogContext
Properties
BridgeClassName
Java class name to be instantiated
public override string BridgeClassName { get; }
Property Value
IsBridgeAbstract
true if the BridgeClassName is an abstract class, i.e. cannot be created an instance
public override bool IsBridgeAbstract { get; }
Property Value
IsBridgeCloseable
true if the BridgeClassName implements java.lang.AutoCloseable
public override bool IsBridgeCloseable { get; }
Property Value
IsBridgeInterface
true if the BridgeClassName is an interface, i.e. does not have any public constructor
public override bool IsBridgeInterface { get; }
Property Value
IsBridgeStatic
true if the BridgeClassName is a static class, i.e. does not have any public constructor
public override bool IsBridgeStatic { get; }
Property Value
Methods
CanGrantVote(ReplicaKey, bool, bool)
public bool CanGrantVote(ReplicaKey arg0, bool arg1, bool arg2)
Parameters
arg0ReplicaKeyarg1boolarg2bool
Returns
Close()
public void Close()
CreatePoolableInstance(Time, int, OptionalInt, Optional<ReplicaKey>, Set<Integer>, Optional<LogOffsetMetadata>, long, LogContext)
HPA initializer for UnattachedState(Org.Apache.Kafka.Common.Utils.Time arg0, int arg1, Java.Util.OptionalInt arg2, Java.Util.Optional%3COrg.Apache.Kafka.Raft.ReplicaKey%3E arg3, Java.Util.Set%3CJava.Lang.Integer%3E arg4, Java.Util.Optional%3COrg.Apache.Kafka.Raft.LogOffsetMetadata%3E arg5, long arg6, Org.Apache.Kafka.Common.Utils.LogContext arg7)
public static UnattachedState CreatePoolableInstance(Time arg0, int arg1, OptionalInt arg2, Optional<ReplicaKey> arg3, Set<Integer> arg4, Optional<LogOffsetMetadata> arg5, long arg6, LogContext arg7)
Parameters
arg0Timearg1intarg2OptionalIntarg3Optional<ReplicaKey>arg4Set<Integer>arg5Optional<LogOffsetMetadata>arg6longarg7LogContext
Returns
Election()
public ElectionState Election()
Returns
ElectionTimeoutMs()
public long ElectionTimeoutMs()
Returns
Epoch()
public int Epoch()
Returns
HasElectionTimeoutExpired(long)
public bool HasElectionTimeoutExpired(long arg0)
Parameters
Returns
HighWatermark()
public Optional<LogOffsetMetadata> HighWatermark()
Returns
LeaderEndpoints()
public Endpoints LeaderEndpoints()
Returns
Name()
public String Name()
Returns
RemainingElectionTimeMs(long)
public long RemainingElectionTimeMs(long arg0)
Parameters
Returns
VotedKey()
public Optional<ReplicaKey> VotedKey()