Struct ClusterAdminServiceImpl 

pub struct ClusterAdminServiceImpl { /* private fields */ }

Raft cluster administrative operations.

Responsibilities

• Manages the Raft cluster

Protocol Safety

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

Implementations

impl ClusterAdminServiceImpl

pub fn new(raft_node: Raft<TypeConfig>) -> Self

Creates a new instance of the API service

Arguments

• raft_node - The Raft node instance this service will use

Trait Implementations

impl ClusterAdminService for ClusterAdminServiceImpl

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

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

Initializes a new Raft cluster with the specified nodes

Arguments

• request - Contains the initial set of nodes for the cluster

Returns

• Success response with initialization details
• Error if initialization fails

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

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

Adds a learner node to the Raft cluster

Arguments

• request - Contains the node information and blocking preference

Returns

• Success response with learner addition details
• Error if the operation fails

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

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

Changes the membership of the Raft cluster

Arguments

• request - Contains the new member set and retention policy

Returns

• Success response with membership change details
• Error if the operation fails

fn metrics<'life0, 'async_trait>( &'life0 self, _request: Request<()>, ) -> Pin<Box<dyn Future<Output = Result<Response<MetricsResponse>, Status>> + Send + 'async_trait>>

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

Retrieves metrics about the Raft node