TxProducerSessionState

org.sigilaris.node.gossip.tx.TxProducerSessionState

See theTxProducerSessionState companion object

final case class TxProducerSessionState(sessionId: DirectionalSessionId, peer: PeerIdentity, peerCorrelationId: PeerCorrelationId, subscriptions: SessionSubscription, negotiated: NegotiatedSessionParameters, durableCursor: CompositeCursor, streamCursor: CompositeCursor, filters: Map[ChainTopic, TxBloomFilter], filterReceiptTimes: Map[ChainTopic, Instant], exactKnownIds: Map[ChainId, Set[StableArtifactId]], exactKnownScopeIds: Map[ExactKnownSetScope, Set[StableArtifactId]], pendingReplay: Map[ChainTopic, Option[CursorToken]], pendingRequestByIds: Map[ChainId, Vector[StableArtifactId]], pendingRequestScopeIds: Map[ExactKnownSetScope, Vector[StableArtifactId]], requestScopeRetryCounts: Map[ExactKnownSetScope, Int], sidecarHolds: Map[ChainTopic, GossipSidecarHoldState], sidecarDiagnostics: Vector[GossipSidecarDiagnostic], idempotencyKeys: Map[ControlIdempotencyKey, Instant], batchingConfig: TxBatchingConfig)

Attributes

Companion: object
Source: TxRuntimeState.scala
Graph
Supertypes: trait Serializable

trait Product

trait Equals

class Object

trait Matchable

class Any
Show all

Appends planner diagnostics while retaining only the recent bounded tail.

Clears a proposal sidecar hold after delivery or fallback.

Extracts the base GossipProducerSessionState from this extended state.

Records a bounded hold for a proposal sidecar decision.

Updates the cursor and replay state from a base producer session state.

In this article

Generated with