ClusterProperties

How the nodes of a service share the partitions of each context's log, and forward commands to their owners.

Constructors

Link copied to clipboard
constructor()

Properties

Link copied to clipboard

How long a hand-off of a partition waits for its commands in flight before it moves on.

Link copied to clipboard

How long a forward waits for the owner's reply, capped by the command's own deadline: wow.wait.default-timeout when not set, so a node whose waits are longer forwards as long. A forward the owner received and did not answer by then is reported unknown (wow.command.unknown), not run here, so the command never runs twice and a retry with the same request id is safe.

Link copied to clipboard

How often a node sends its heartbeat; less than half of member-ttl, so one late heartbeat is harmless.

Link copied to clipboard

The most lease acquisitions a node runs at a time.

Link copied to clipboard

How long a partition stays with a node that stopped renewing its lease.

Link copied to clipboard

The forwards one node may have outstanding with another; one more runs here instead.

Link copied to clipboard

How long a node stays a member of the cluster after its last heartbeat.

Link copied to clipboard

How often a node compares the partitions it holds with those it should hold; a change of the members it notices reconciles at once.

Link copied to clipboard

How long one reconcile may run before the node takes itself as stuck and leaves the members until it ends, so the other nodes take the partitions it cannot run; longer than drain-timeout. One still running after wow.health.liveness.stall-timeout fails the node's liveness.

Link copied to clipboard

How often a node renews its leases; less than half of lease-ttl, or every lease is lost between rounds.

Link copied to clipboard

How often the route table is read from the leases and members; a failed forward refreshes it at once.

Functions

Link copied to clipboard

The cluster options, a forward waiting ClusterOptions' default when forwardTimeout is not set.

fun options(defaultWaitTimeout: Duration): ClusterOptions

The cluster options, a forward waiting defaultWaitTimeout when forwardTimeout is not set.