Class LeaderState<T>
public class LeaderState<T> : EpochState, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IEpochState, ICloseable, IAutoCloseableType Parameters
T
- Inheritance
-
JVMBridgeBaseJVMBridgeBase<AutoCloseable>LeaderState<T>
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Inherited Members
-
JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])JVMBridgeBase<AutoCloseable>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])JVMBridgeBase<AutoCloseable>.IsAssignableFrom(IJavaType)JVMBridgeBase<AutoCloseable>.IsAssignableFrom<T>()JVMBridgeBase<AutoCloseable>.Execute<T>(params T[])JVMBridgeBase<AutoCloseable>.DynBridgeClazzJVMBridgeBase<AutoCloseable>.BridgeClazzJVMBridgeBase.RuntimeClassNameOf<T>()JVMBridgeBase.ClassNameOf<T>()JVMBridgeBase.ClassOf<T>()JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)JVMBridgeBase.Wraps<TNewClass>(IJavaObject)JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)JVMBridgeBase.MonitorEnter()JVMBridgeBase.MonitorExit()JVMBridgeBase.IsInstanceOf(IJavaType)JVMBridgeBase.IsInstanceOf<T>()JVMBridgeBase.RuntimeIsInstanceOf<T>()JVMBridgeBase.CastTo<TNewClass>()JVMBridgeBase.CastDirect<TNewClass>()JVMBridgeBase.Dispose()JVMBridgeBase.ToString()JVMBridgeBase.GetHashCode()JVMBridgeBase.Notify()JVMBridgeBase.NotifyAll()JVMBridgeBase.Wait()JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeListener
Constructors
LeaderState()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public LeaderState()LeaderState(params object[])
Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class
public LeaderState(params object[] args)Parameters
argsobject[]
Properties
BridgeClassName
https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm
public override string BridgeClassName { get; }Property Value
IsBridgeAbstract
public override bool IsBridgeAbstract { get; }Property Value
IsBridgeCloseable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
public override bool IsBridgeStatic { get; }Property Value
Methods
AddAcknowledgementFrom(int)
public void AddAcknowledgementFrom(int arg0)Parameters
AppendStartOfEpochControlRecords(VoterNode, long)
public void AppendStartOfEpochControlRecords(VoterSet.VoterNode arg0, long arg1)Parameters
AppendVotersRecord(VoterSet, long)
public long AppendVotersRecord(VoterSet arg0, long arg1)Parameters
Returns
CanGrantVote(ReplicaKey, bool)
public bool CanGrantVote(ReplicaKey arg0, bool arg1)Parameters
arg0ReplicaKeyarg1bool
Returns
Close()
public void Close()Election()
public ElectionState Election()Returns
Epoch()
public int Epoch()Returns
EpochStartOffset()
public long EpochStartOffset()Returns
GetReplicaState(ReplicaKey)
public Optional<LeaderState.ReplicaState> GetReplicaState(ReplicaKey arg0)Parameters
arg0ReplicaKey
Returns
GrantingVoters()
public Set<Integer> GrantingVoters()Returns
HighWatermark()
public Optional<LogOffsetMetadata> HighWatermark()Returns
IsOperationPending(long)
public bool IsOperationPending(long arg0)Parameters
Returns
IsReplicaCaughtUp(ReplicaKey, long)
public bool IsReplicaCaughtUp(ReplicaKey arg0, long arg1)Parameters
arg0ReplicaKeyarg1long
Returns
IsResignRequested()
public bool IsResignRequested()Returns
LeaderEndpoints()
public Endpoints LeaderEndpoints()Returns
MaybeExpirePendingOperation(long)
public long MaybeExpirePendingOperation(long arg0)Parameters
Returns
Name()
public String Name()Returns
NonLeaderVotersByDescendingFetchOffset()
public List<ReplicaKey> NonLeaderVotersByDescendingFetchOffset()Returns
RequestResign()
public void RequestResign()ResetBeginQuorumEpochTimer(long)
public void ResetBeginQuorumEpochTimer(long arg0)Parameters
TimeUntilBeginQuorumEpochTimerExpires(long)
public long TimeUntilBeginQuorumEpochTimerExpires(long arg0)Parameters
Returns
TimeUntilCheckQuorumExpires(long)
public long TimeUntilCheckQuorumExpires(long arg0)Parameters
Returns
UpdateCheckQuorumForFollowingVoter(ReplicaKey, long)
public void UpdateCheckQuorumForFollowingVoter(ReplicaKey arg0, long arg1)Parameters
arg0ReplicaKeyarg1long
UpdateLocalState(LogOffsetMetadata, VoterSet)
public bool UpdateLocalState(LogOffsetMetadata arg0, VoterSet arg1)Parameters
arg0LogOffsetMetadataarg1VoterSet
Returns
UpdateReplicaState(ReplicaKey, long, LogOffsetMetadata)
public bool UpdateReplicaState(ReplicaKey arg0, long arg1, LogOffsetMetadata arg2)Parameters
arg0ReplicaKeyarg1longarg2LogOffsetMetadata
Returns
Operators
implicit operator LeaderState(LeaderState<T>)
Converter from LeaderState<T> to LeaderState
public static implicit operator LeaderState(LeaderState<T> t)Parameters
tLeaderState<T>