Class RequestManager

Namespace

Org.Apache.Kafka.Raft

Assembly

MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/RequestManager.html

public class RequestManager : JVMBridgeBase<RequestManager>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<RequestManager>

RequestManager

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

Constructors

RequestManager(Collection<Node>, int, int, Random)

https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/RequestManager.html#%3Cinit%3E(java.util.Collection,int,int,java.util.Random)

public RequestManager(Collection<Node> arg0, int arg1, int arg2, Random arg3)

Parameters

arg0 Collection<Node>

Collection

arg1 int

int

arg2 int

int

arg3 Random

Random

RequestManager(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 RequestManager(IJVMBridgeBaseInitializer initializer)

Parameters

initializer IJVMBridgeBaseInitializer

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

true if the BridgeClassName is an abstract class, i.e. cannot be created an instance

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

true if the BridgeClassName implements java.lang.AutoCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

true if the BridgeClassName is an interface, i.e. does not have any public constructor

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

true if the BridgeClassName is a static class, i.e. does not have any public constructor

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

BackoffBeforeAvailableBootstrapServer(long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/RequestManager.html#backoffBeforeAvailableBootstrapServer(long)

public long BackoffBeforeAvailableBootstrapServer(long arg0)

Parameters

arg0 long

long

Returns

long

long

CreatePoolableInstance(Collection<Node>, int, int, Random)

HPA initializer for RequestManager(Java.Util.Collection%3COrg.Apache.Kafka.Common.Node%3E arg0, int arg1, int arg2, Java.Util.Random arg3)

public static RequestManager CreatePoolableInstance(Collection<Node> arg0, int arg1, int arg2, Random arg3)

Parameters

arg0 Collection<Node>

arg1 int

arg2 int

arg3 Random

Returns

RequestManager

FindReadyBootstrapServer(long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/RequestManager.html#findReadyBootstrapServer(long)

public Optional<Node> FindReadyBootstrapServer(long arg0)

Parameters

arg0 long

long

Returns

Optional<Node>

Optional

HasAnyInflightRequest(long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/RequestManager.html#hasAnyInflightRequest(long)

public bool HasAnyInflightRequest(long arg0)

Parameters

arg0 long

long

Returns

bool

bool

HasRequestTimedOut(Node, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/RequestManager.html#hasRequestTimedOut(org.apache.kafka.common.Node,long)

public bool HasRequestTimedOut(Node arg0, long arg1)

Parameters

arg0 Node

Node

arg1 long

long

Returns

bool

bool

IsBackingOff(Node, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/RequestManager.html#isBackingOff(org.apache.kafka.common.Node,long)

public bool IsBackingOff(Node arg0, long arg1)

Parameters

arg0 Node

Node

arg1 long

long

Returns

bool

bool

IsReady(Node, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/RequestManager.html#isReady(org.apache.kafka.common.Node,long)

public bool IsReady(Node arg0, long arg1)

Parameters

arg0 Node

Node

arg1 long

long

Returns

bool

bool

IsResponseExpected(Node, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/RequestManager.html#isResponseExpected(org.apache.kafka.common.Node,long)

public bool IsResponseExpected(Node arg0, long arg1)

Parameters

arg0 Node

Node

arg1 long

long

Returns

bool

bool

OnRequestSent(Node, long, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/RequestManager.html#onRequestSent(org.apache.kafka.common.Node,long,long)

public void OnRequestSent(Node arg0, long arg1, long arg2)

Parameters

arg0 Node

Node

arg1 long

long

arg2 long

long

OnResponseResult(Node, long, bool, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/RequestManager.html#onResponseResult(org.apache.kafka.common.Node,long,boolean,long)

public void OnResponseResult(Node arg0, long arg1, bool arg2, long arg3)

Parameters

arg0 Node

Node

arg1 long

long

arg2 bool

bool

arg3 long

long

RemainingBackoffMs(Node, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/RequestManager.html#remainingBackoffMs(org.apache.kafka.common.Node,long)

public long RemainingBackoffMs(Node arg0, long arg1)

Parameters

arg0 Node

Node

arg1 long

long

Returns

long

long

RemainingRequestTimeMs(Node, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/RequestManager.html#remainingRequestTimeMs(org.apache.kafka.common.Node,long)

public long RemainingRequestTimeMs(Node arg0, long arg1)

Parameters

arg0 Node

Node

arg1 long

long

Returns

long

long

Reset(Node)

https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/RequestManager.html#reset(org.apache.kafka.common.Node)

public void Reset(Node arg0)

Parameters

arg0 Node

Node

ResetAll()

https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/4.2.1/org/apache/kafka/raft/RequestManager.html#resetAll()

public void ResetAll()