Crate rustfs_protos 

Modules

compat_manifest

Rolling-upgrade compatibility manifest for the internode RPC dual-write payload fields in node.proto.

heal_control

Structural wire codec for heal-control commands.

models

proto_gen

scoped_dirty_usage

Bounded, authenticated receiver contract for per-bucket dirty acknowledgements.

Structs

TierMutationRpcResponseProofInput

Enums

ChannelClass

Class of internode gRPC channel used to route an RPC (grpc-optimization P1).

ConnectionEvictionLogLevel

Log level to use when reporting cached gRPC connection eviction.

TierMutationRpcPhase

Constants

BACKGROUND_HEAL_STATUS_PROTOCOL_VERSION

CROSS_POOL_FENCE_CAPABILITY_PROBE_PREFIX

DEFAULT_GRPC_SERVER_MESSAGE_LEN

DYNAMIC_CONFIG_PROTOCOL_VERSION

HEAL_CONTROL_CAPABILITY_PROBE_PREFIX

HEAL_CONTROL_PROTOCOL_VERSION

HEAL_CONTROL_RPC_MAX_MESSAGE_SIZE

ILM_RECOVERY_EXPORT_CAPABILITY_PROBE_PREFIX

PEER_RESTDRY_RUN

PEER_RESTSIGNAL

PEER_RESTSUB_SYS

REMOTE_VERSION_STATE_CAPABILITY_PROBE_PREFIX

TIER_MUTATION_RPC_MAX_ABORT_PAYLOAD_SIZE

TIER_MUTATION_RPC_MAX_COMMIT_PAYLOAD_SIZE

TIER_MUTATION_RPC_MAX_ERROR_INFO_SIZE

TIER_MUTATION_RPC_MAX_MESSAGE_SIZE

TIER_MUTATION_RPC_MAX_PREPARE_PAYLOAD_SIZE

TIER_MUTATION_RPC_MAX_RESPONSE_PROOF_SIZE

TIER_MUTATION_RPC_PREVIOUS_PROTOCOL_VERSION

TIER_MUTATION_RPC_PROTOCOL_VERSION

TRANSITION_TRANSACTION_COMPACTION_CAPABILITY_PROBE_PREFIX

Traits

CanonicalMutationBody

A stable semantic body for a side-effecting unary RPC.

Functions

canonical_compare_and_update_file_request_body

canonical_delete_paths_request_body

canonical_delete_request_body

canonical_delete_version_request_body

canonical_delete_versions_request_body

canonical_delete_volume_request_body

canonical_heal_control_capability_ack

Builds the exact acknowledgement expected from a peer that supports the heal-control protocol and agrees with the caller’s storage topology.

canonical_heal_control_request_body

Builds the stable byte representation authenticated for a heal-control request.

canonical_heal_control_response_body

canonical_make_volume_request_body

canonical_make_volumes_request_body

canonical_prepare_part_transaction_request_body

canonical_rename_data_request_body

canonical_rename_file_request_body

canonical_rename_part_request_body

canonical_scanner_activity_request_body

Builds the stable byte representation authenticated for a scanner activity request.

canonical_scanner_activity_response_body

Builds the stable byte representation authenticated for a scanner activity response.

canonical_scanner_activity_v4_response_body

Builds the protocol-v4 byte representation authenticated for a scanner activity response.

canonical_scanner_activity_v7_response_body

Builds the protocol-v7 response body. The optional movement fields are presence-bound so a missing terminal-generation proof cannot authenticate as the value zero.

canonical_scanner_dirty_usage_snapshot_request_body

canonical_scanner_dirty_usage_snapshot_response_body

canonical_scanner_publication_lease_release_request_body

Builds the body authenticated by a remote scanner publication lease release request.

canonical_scanner_publication_lease_release_response_body

canonical_scanner_publication_lease_request_body

Builds the body authenticated by the short-lived remote scanner publication lease request. This is a separate domain from ScannerActivity so v6/v7 observation proofs remain byte-for-byte compatible.

canonical_scanner_publication_lease_response_body

canonical_settle_part_transaction_request_body

canonical_snapshot_lease_release_request_body

canonical_snapshot_lease_renew_request_body

canonical_snapshot_lease_request_body

canonical_tier_mutation_rpc_body

canonical_tier_mutation_rpc_response_body

canonical_update_metadata_request_body

canonical_write_all_request_body

canonical_write_metadata_request_body

create_new_channel

Creates a new gRPC channel with optimized keepalive settings for cluster resilience.

decode_remote_version_state_capability

encode_cross_pool_fence_capability

encode_remote_version_state_capability

evict_failed_connection

Evict a connection from the cache after a failure. This should be called when an RPC fails to ensure fresh connections are tried.

evict_failed_connection_with_log_level

Evict a connection from the cache after a failure with an explicit log level.

get_channel_for_class

Acquire a cached-or-newly-dialed channel for the given peer and channel class.

heal_control_capability_probe

heal_control_coordinator_epoch

heal_control_execution_timeout

Budget for one heal-control execution, kept below the transport timeout so the coordinator stops waiting for admission before the caller gives up.

ilm_recovery_export_capability_probe

internode_rpc_max_message_size

Maximum encoded/decoded internode gRPC message size (bytes), shared by the client NodeServiceClient and server NodeServiceServer. Defaults to DEFAULT_GRPC_SERVER_MESSAGE_LEN (100 MiB) when the env var is unset.

internode_rpc_msgpack_only

Whether internode metadata RPCs should send only the msgpack _bin payloads and leave the JSON compatibility strings empty (grpc-optimization P2-1). Shared by the client (remote_disk) and server (node_service) send paths.

is_cross_pool_fence_capability_probe

is_heal_control_capability_probe

is_ilm_recovery_export_capability_probe

is_remote_version_state_capability_probe

is_transition_transaction_compaction_capability_probe

remote_version_state_capability_probe

transition_transaction_compaction_capability_probe

Type Aliases

NodeServiceClientType