Table of Contents

Class LeaderState

Namespace
Org.Apache.Kafka.Raft
Assembly
MASES.KNet.dll
public class LeaderState : EpochState, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IEpochState, ICloseable, IAutoCloseable
Inheritance
JVMBridgeBase
JVMBridgeBase<AutoCloseable>
LeaderState
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Inherited Members
JVMBridgeBase<AutoCloseable>.IsAssignableFrom(IJavaType)
JVMBridgeBase<AutoCloseable>.IsAssignableFrom<T>()
JVMBridgeBase<AutoCloseable>.Execute<T>(params T[])
JVMBridgeBase<AutoCloseable>.DynBridgeClazz
JVMBridgeBase<AutoCloseable>.BridgeClazz
JVMBridgeBase.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.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.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

args object[]

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

AddAcknowledgementFrom(int)

public void AddAcknowledgementFrom(int arg0)

Parameters

arg0 int

int

AppendStartOfEpochControlRecords(VoterNode, long)

public void AppendStartOfEpochControlRecords(VoterSet.VoterNode arg0, long arg1)

Parameters

arg0 VoterSet.VoterNode

VoterSet.VoterNode

arg1 long

long

AppendVotersRecord(VoterSet, long)

public long AppendVotersRecord(VoterSet arg0, long arg1)

Parameters

arg0 VoterSet

VoterSet

arg1 long

long

Returns

long

long

CanGrantVote(ReplicaKey, bool)

public bool CanGrantVote(ReplicaKey arg0, bool arg1)

Parameters

arg0 ReplicaKey

ReplicaKey

arg1 bool

bool

Returns

bool

bool

Close()

public void Close()

Election()

public ElectionState Election()

Returns

ElectionState

ElectionState

Epoch()

public int Epoch()

Returns

int

int

EpochStartOffset()

public long EpochStartOffset()

Returns

long

long

GetReplicaState(ReplicaKey)

public Optional GetReplicaState(ReplicaKey arg0)

Parameters

arg0 ReplicaKey

ReplicaKey

Returns

Optional

Optional

GrantingVoters()

public Set GrantingVoters()

Returns

Set

Set

HighWatermark()

public Optional HighWatermark()

Returns

Optional

Optional

IsOperationPending(long)

public bool IsOperationPending(long arg0)

Parameters

arg0 long

long

Returns

bool

bool

IsReplicaCaughtUp(ReplicaKey, long)

public bool IsReplicaCaughtUp(ReplicaKey arg0, long arg1)

Parameters

arg0 ReplicaKey

ReplicaKey

arg1 long

long

Returns

bool

bool

IsResignRequested()

public bool IsResignRequested()

Returns

bool

bool

LeaderEndpoints()

public Endpoints LeaderEndpoints()

Returns

Endpoints

Endpoints

MaybeExpirePendingOperation(long)

public long MaybeExpirePendingOperation(long arg0)

Parameters

arg0 long

long

Returns

long

long

Name()

public String Name()

Returns

String

String

NonLeaderVotersByDescendingFetchOffset()

public List NonLeaderVotersByDescendingFetchOffset()

Returns

List

List

RequestResign()

public void RequestResign()

ResetBeginQuorumEpochTimer(long)

public void ResetBeginQuorumEpochTimer(long arg0)

Parameters

arg0 long

long

TimeUntilBeginQuorumEpochTimerExpires(long)

public long TimeUntilBeginQuorumEpochTimerExpires(long arg0)

Parameters

arg0 long

long

Returns

long

long

TimeUntilCheckQuorumExpires(long)

public long TimeUntilCheckQuorumExpires(long arg0)

Parameters

arg0 long

long

Returns

long

long

UpdateCheckQuorumForFollowingVoter(ReplicaKey, long)

public void UpdateCheckQuorumForFollowingVoter(ReplicaKey arg0, long arg1)

Parameters

arg0 ReplicaKey

ReplicaKey

arg1 long

long

UpdateLocalState(LogOffsetMetadata, VoterSet)

public bool UpdateLocalState(LogOffsetMetadata arg0, VoterSet arg1)

Parameters

arg0 LogOffsetMetadata

LogOffsetMetadata

arg1 VoterSet

VoterSet

Returns

bool

bool

UpdateReplicaState(ReplicaKey, long, LogOffsetMetadata)

public bool UpdateReplicaState(ReplicaKey arg0, long arg1, LogOffsetMetadata arg2)

Parameters

arg0 ReplicaKey

ReplicaKey

arg1 long

long

arg2 LogOffsetMetadata

LogOffsetMetadata

Returns

bool

bool