Bedrock.DataPlane.Resolver.Server (bedrock v0.6.0)

View Source

GenServer implementation for the Resolver conflict detection engine.

Manages resolver state including version ordering through waiting queues. Handles out-of-order transaction resolution by queuing later versions until earlier ones complete.

Starts in running mode and is immediately ready to process transaction resolution requests.

Summary

Functions

Returns a specification to start this module under a supervisor.

Types

reply_fn()

@type reply_fn() :: (result :: {:ok, [non_neg_integer()]} | {:error, any()} -> :ok)

Functions

child_spec(init_arg)

@spec child_spec(
  opts :: [
    lock_token: Bedrock.lock_token(),
    key_range: Bedrock.key_range(),
    epoch: Bedrock.epoch(),
    last_version: Bedrock.version(),
    director: pid(),
    cluster: module(),
    sweep_interval_ms: pos_integer(),
    version_retention_ms: pos_integer()
  ]
) :: Supervisor.child_spec()

Returns a specification to start this module under a supervisor.

See Supervisor.