Struct SurfpoolAdminRpc

pub struct SurfpoolAdminRpc;

Trait Implementations

impl AdminRpc for SurfpoolAdminRpc

type Metadata = Option<RunloopContext>

fn exit(&self, meta: Self::Metadata) -> Result<()>

Immediately shuts down the RPC server.

fn reload_plugin( &self, _meta: Self::Metadata, _name: String, _config_file: String, ) -> BoxFuture<Result<()>>

fn unload_plugin( &self, _meta: Self::Metadata, _name: String, ) -> BoxFuture<Result<()>>

Reloads a runtime plugin with new configuration.

fn load_plugin( &self, meta: Self::Metadata, config_file: String, ) -> BoxFuture<Result<String>>

Dynamically loads a new plugin into the runtime from a configuration file.

fn list_plugins(&self, _meta: Self::Metadata) -> BoxFuture<Result<Vec<String>>>

Returns a list of all currently loaded plugin names.

fn rpc_addr(&self, _meta: Self::Metadata) -> Result<Option<SocketAddr>>

Returns the address of the RPC server.

fn set_log_filter(&self, _filter: String) -> Result<()>

Sets a filter for log messages in the system.

fn start_time(&self, _meta: Self::Metadata) -> Result<SystemTime>

Returns the system start time.

fn add_authorized_voter( &self, _meta: Self::Metadata, _keypair_file: String, ) -> Result<()>

Adds an authorized voter to the system.

fn add_authorized_voter_from_bytes( &self, _meta: Self::Metadata, _keypair: Vec<u8>, ) -> Result<()>

Adds an authorized voter to the system using a byte-encoded keypair.

fn remove_all_authorized_voters(&self, _meta: Self::Metadata) -> Result<()>

Removes all authorized voters from the system.

fn set_identity( &self, _meta: Self::Metadata, _keypair_file: String, _require_tower: bool, ) -> Result<()>

Sets the identity for the system using the provided keypair.

fn set_identity_from_bytes( &self, _meta: Self::Metadata, _identity_keypair: Vec<u8>, _require_tower: bool, ) -> Result<()>

Sets the identity for the system using a keypair provided as a byte array.

fn set_staked_nodes_overrides( &self, _meta: Self::Metadata, _path: String, ) -> Result<()>

Sets the overrides for staked nodes using a specified path.

fn repair_shred_from_peer( &self, _meta: Self::Metadata, _pubkey: Option<Pubkey>, _slot: u64, _shred_index: u64, ) -> Result<()>

Repairs a shred from a peer node in the network.

fn set_repair_whitelist( &self, _meta: Self::Metadata, _whitelist: Vec<Pubkey>, ) -> Result<()>

Sets the whitelist of nodes allowed to repair shreds.

fn get_secondary_index_key_size( &self, _meta: Self::Metadata, _pubkey_str: String, ) -> Result<HashMap<RpcAccountIndex, usize>>

Retrieves the size of the secondary index key for a given account.

fn set_public_tpu_address( &self, _meta: Self::Metadata, _public_tpu_addr: SocketAddr, ) -> Result<()>

Sets the public TPU (Transaction Processing Unit) address.

fn set_public_tpu_forwards_address( &self, _meta: Self::Metadata, _public_tpu_forwards_addr: SocketAddr, ) -> Result<()>

Sets the public TPU forwards address.

fn to_delegate(self) -> IoDelegate<Self, Self::Metadata>

Create an IoDelegate, wiring rpc calls to the trait methods.