Struct IdentityServiceImpl 

pub struct IdentityServiceImpl { /* private fields */ }

External API service implementation providing key-value store operations. This service handles client requests for getting and setting values in the distributed store.

Responsibilities

• Ensure consistency through Raft consensus

Protocol Safety

This service implements the client-facing API and should validate all inputs before processing them through the Raft consensus protocol.

Implementations

impl IdentityServiceImpl

pub fn new( raft_node: Raft<TypeConfig>, state_machine_store: Arc<FjallStateMachine>, ) -> Self

Creates a new instance of the API service

Arguments

• raft_node - The Raft node instance this service will use
• state_machine_store - The state machine store for reading data

Trait Implementations

impl IdentityService for IdentityServiceImpl

fn set<'life0, 'async_trait>( &'life0 self, request: Request<SetRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PbResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sets a value for a given key in the distributed store

Arguments

• request - Contains the key and value to set

Returns

• Ok(Response) - Success response after the value is set
• Err(Status) - Error status if the set operation fails

fn get<'life0, 'async_trait>( &'life0 self, request: Request<GetRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PbResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gets a value for a given key from the distributed store

Arguments

• request - Contains the key to retrieve

Returns

• Ok(Response) - Success response containing the value
• Err(Status) - Error status if the get operation fails