Struct VeloWorkerClient 

pub struct VeloWorkerClient { /* private fields */ }

Implementations

impl VeloWorkerClient

pub fn new(messenger: Arc<Messenger>, remote: InstanceId) -> Self

Create a new VeloWorkerClient for communicating with a remote worker.

pub fn configure_layout_handles( &self, metadata: &SerializedLayout, ) -> Result<()>

Configure layout handles from serialized metadata.

Call this after worker initialization when handles are known from WorkerLayoutResponse. This allows the VeloWorkerClient to provide layout handles like DirectWorker does.

Arguments

• metadata - SerializedLayout from WorkerLayoutResponse.metadata

Example

let response: WorkerLayoutResponse = worker.initialize(config).await?;
worker_client.configure_layout_handles(&response.metadata)?;

pub fn get_layout_config(&self) -> Result<TypedUnaryResult<LayoutConfig>>

Get the layout configuration from the remote worker.

This calls the kvbm.worker.get_layout_config handler on the remote worker. Used by the leader during Phase 3 to gather G1 layout configs from all workers and validate they match before creating G2/G3 layouts.

Returns

A typed unary result that resolves to the layout configuration

pub fn configure_layouts( &self, config: LeaderLayoutConfig, ) -> Result<TypedUnaryResult<WorkerLayoutResponse>>

Configure additional layouts (G2, G3) on the remote worker.

This calls the kvbm.worker.configure_layouts handler on the remote worker. The worker will create host/pinned cache (G2) and optionally disk cache (G3) based on the provided configuration.

Arguments

• config - Leader-provided configuration specifying block counts and backends

Returns

A typed unary result that resolves to the worker’s response with updated metadata

Trait Implementations

impl Clone for VeloWorkerClient

fn clone(&self) -> VeloWorkerClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ObjectBlockOps for VeloWorkerClient

fn has_blocks( &self, keys: Vec<SequenceHash>, ) -> BoxFuture<'static, Vec<(SequenceHash, Option<usize>)>>

Check if blocks exist in object storage.

fn put_blocks( &self, keys: Vec<SequenceHash>, src_layout: LogicalLayoutHandle, block_ids: Vec<BlockId>, ) -> BoxFuture<'static, Vec<Result<SequenceHash, SequenceHash>>>

Put blocks to object storage.

fn get_blocks( &self, keys: Vec<SequenceHash>, dst_layout: LogicalLayoutHandle, block_ids: Vec<BlockId>, ) -> BoxFuture<'static, Vec<Result<SequenceHash, SequenceHash>>>

Get blocks from object storage.

fn put_blocks_with_layout( &self, keys: Vec<SequenceHash>, _layout: PhysicalLayout, _block_ids: Vec<BlockId>, ) -> BoxFuture<'static, Vec<Result<SequenceHash, SequenceHash>>>

Put blocks to object storage using a resolved physical layout.

fn get_blocks_with_layout( &self, keys: Vec<SequenceHash>, _layout: PhysicalLayout, _block_ids: Vec<BlockId>, ) -> BoxFuture<'static, Vec<Result<SequenceHash, SequenceHash>>>

Get blocks from object storage into a resolved physical layout.

impl Worker for VeloWorkerClient

fn g1_handle(&self) -> Option<LayoutHandle>

Get the G1 layout handle for this worker (if configured).

fn g2_handle(&self) -> Option<LayoutHandle>

Get the G2 layout handle for this worker (if configured).

fn g3_handle(&self) -> Option<LayoutHandle>

Get the G3 layout handle for this worker (if configured).

fn export_metadata(&self) -> Result<SerializedLayoutResponse>

Export the local metadata for this worker.

fn import_metadata( &self, metadata: SerializedLayout, ) -> Result<ImportMetadataResponse>

Import the remote metadata for this worker.

impl WorkerTransfers for VeloWorkerClient

fn execute_local_transfer( &self, src: LogicalLayoutHandle, dst: LogicalLayoutHandle, src_block_ids: Arc<[BlockId]>, dst_block_ids: Arc<[BlockId]>, options: TransferOptions, ) -> Result<TransferCompleteNotification>

Execute a local transfer between two logical layouts.

fn execute_remote_onboard( &self, src: RemoteDescriptor, dst: LogicalLayoutHandle, dst_block_ids: Arc<[BlockId]>, options: TransferOptions, ) -> Result<TransferCompleteNotification>

Execute a remote transfer from a remote layout to a local logical layout.

fn execute_remote_offload( &self, src: LogicalLayoutHandle, src_block_ids: Arc<[BlockId]>, dst: RemoteDescriptor, options: TransferOptions, ) -> Result<TransferCompleteNotification>

Execute a remote offload from a local logical layout to a remote descriptor.

fn connect_remote( &self, instance_id: InstanceId, metadata: Vec<SerializedLayout>, ) -> Result<ConnectRemoteResponse>

Connect to a remote instance by importing its metadata and storing handle mappings.

fn has_remote_metadata(&self, instance_id: InstanceId) -> bool

Check if remote metadata has been imported for an instance.

fn execute_remote_onboard_for_instance( &self, instance_id: InstanceId, remote_logical_type: LogicalLayoutHandle, src_block_ids: Vec<BlockId>, dst: LogicalLayoutHandle, dst_block_ids: Arc<[BlockId]>, options: TransferOptions, ) -> Result<TransferCompleteNotification>

Execute a remote onboard transfer using stored handle mapping.