Skip to main content

Crate rhiza_node

Crate rhiza_node 

Source

Re-exports§

pub use durability::restore_checkpoint_to_fresh_data_dir;
pub use durability::restore_checkpoint_to_fresh_data_dir_for_node;
pub use durability::CheckpointCoordinator;
pub use durability::DurabilityError;
pub use durability::DurabilityHealth;
pub use durability::DurabilityMode;
pub use durability::SuccessorRestorePreparation;

Modules§

durability

Structs§

AdminActivateRequest
AdminActivateResponse
AdminCompactRequest
AdminCompactResponse
AdminConfig
AdminErrorResponse
AdminInstallSuccessorRequest
AdminInstallSuccessorResponse
AdminStatusResponse
AdminStopRequest
AdminStopResponse
AdminStoppedTransition
AdminSuccessorBundle
AdminTaskTracker
CertifiedTailRecord
CertifiedTailRequest
CertifiedTailResponse
ClientErrorResponse
E2eConfig
E2eReport
FetchLogRequest
FetchLogResponse
HttpLogPeer
HttpRecorderClient
InMemoryLogPeer
LearnerProgress
LearnerStore
NodeConfig
NodeRuntime
NodeService
NodeStatus
PeerConfig
ReadRequest
ReadResponse
RecorderTlsClientConfig
RecorderTlsServerConfig
SqlExecuteRequest
SqlExecuteResponse
SqlQueryRequest
SqlQueryResponse
SqlStatementResult
SqlWriteProfileSample
Timing for one successfully committed physical SQL QWAL batch.
SqlWriteProfileSnapshot
A point-in-time copy of a SQL write profiler’s bounded samples.
SqlWriteProfiler
A bounded, clone-shared observer for successful physical SQL write batches.
StartupIoContext
StopInformation
TailReaderConfig
TcpPostcardRecorderClient
VerifiedSnapshotPublication
WriteRequest
WriteResponse

Enums§

AckMode
AdminErrorCode
CertifiedTailErrorResponse
CertifiedTailValidationError
ConfigError
FetchLogError
LearnerStoreError
NodeError
ReadConsistency
RuntimeConfigurationStatus
TailReaderConfigError

Constants§

ADMIN_ACTIVATE_PATH
ADMIN_COMPACT_PATH
ADMIN_INSTALL_SUCCESSOR_PATH
ADMIN_STATUS_PATH
ADMIN_STOP_PATH
CERTIFIED_TAIL_PATH
CERTIFIED_TAIL_READ_TIMEOUT
DEFAULT_CERTIFIED_TAIL_ENTRIES
DEFAULT_CLIENT_CONCURRENCY
DEFAULT_PEER_CONCURRENCY
DEFAULT_SQL_GROUP_COMMIT_QUEUE_CAPACITY
DEFAULT_SQL_MAX_ROWS
DEFAULT_WRITER_BATCH_MAX
DEFAULT_WRITER_BATCH_WINDOW
LIVEZ_PATH
LOG_FETCH_PATH
MAX_CERTIFIED_TAIL_ENCODED_BYTES
MAX_CERTIFIED_TAIL_ENTRIES
MAX_CERTIFIED_TAIL_ENTRY_PAYLOAD_BYTES
MAX_COMMAND_BYTES
MAX_CONCURRENT_CERTIFIED_TAIL_READS
MAX_FETCH_ENTRIES
MAX_HTTP_BODY_BYTES
MAX_KEY_BYTES
MAX_REQUEST_ID_BYTES
MAX_SQL_GROUP_COMMIT_QUEUE_CAPACITY
MAX_SQL_MAX_ROWS
MAX_SQL_RESPONSE_BYTES
MAX_SQL_RESULT_BYTES
MAX_TYPED_SQL_WRITE_BATCH_MEMBERS
MAX_VALUE_BYTES
NODE_ID_HEADER
PROTOCOL_VERSION
READYZ_PATH
READ_PATH
RECORDER_FETCH_COMMAND_PATH
RECORDER_IDENTITY_PATH
RECORDER_INSPECT_PROOF_PATH
RECORDER_INSPECT_RECORD_PATH
RECORDER_INSTALL_PROOF_PATH
RECORDER_PROTOCOL_VERSION
RECORDER_READ_FENCE_PATH
RECORDER_RECORD_PATH
RECORDER_STORE_COMMAND_PATH
RECOVERY_GENERATION_HEADER
SQL_EXECUTE_PATH
SQL_QUERY_PATH
TAIL_CLUSTER_ID_HEADER
TAIL_CONFIG_ID_HEADER
TAIL_EPOCH_HEADER
TAIL_MEMBERSHIP_DIGEST_HEADER
TAIL_PROTOCOL_VERSION
TAIL_VERSION_HEADER
VERSION_HEADER
WRITE_PATH

Traits§

LogPeer

Functions§

catch_up_missing_entries
certified_tail_router
certified_tail_router_for_runtime
confirm_write_durability
Confirms that a committed write has reached the configured durability boundary.
effective_cluster_id
execution_profile_compiled
install_successor_recorder
log_peer_router
log_peer_router_for_generation
node_router
node_router_with_admin
node_router_with_admin_and_tasks
node_router_with_checkpoint
node_router_with_checkpoint_and_admin
node_router_with_checkpoint_and_admin_tasks
node_router_with_checkpoint_and_limits
node_router_with_limits
node_rpc_router
node_rpc_router_for_generation
node_rpc_router_with_limits
node_rpc_router_with_limits_for_generation
recorder_router
recorder_router_for_generation
recover_successor_recorder_after_checkpoint
rehydrate_recorder_after_checkpoint
run_e2e
serve_recorder_tcp
serve_recorder_tcp_tls
validate_certified_tail_response
validate_recorder_tcp_endpoint

Type Aliases§

RuntimeError