Struct solana_local_cluster::local_cluster::LocalCluster

pub struct LocalCluster {
    pub funding_keypair: Keypair,
    pub entry_point_info: ContactInfo,
    pub validators: HashMap<Pubkey, ClusterValidatorInfo>,
    pub genesis_config: GenesisConfig,
}

Fields

funding_keypair: Keypair

Keypair with funding to participate in the network

entry_point_info: ContactInfo

Entry point from which the rest of the network can be discovered

validators: HashMap<Pubkey, ClusterValidatorInfo>genesis_config: GenesisConfig

Implementations

Set up validator without voting or staking accounts

Set up validator with voting and staking accounts

Return the next full snapshot archive info after the cluster’s last processed slot

Return the next incremental snapshot archive info (and associated full snapshot archive info) after the cluster’s last processed slot

Return the next snapshot archive infos after the cluster’s last processed slot

Trait Implementations

Executes the destructor for this type. Read more

Auto Trait Implementations

Blanket Implementations

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

Returns the argument unchanged.

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Wrap the input message T in a tonic::Request

The alignment of pointer.

The type for initializers.

Initializes a with the given initializer. Read more

Dereferences the given pointer. Read more

Mutably dereferences the given pointer. Read more

Drops the object pointed to by the given pointer. Read more

Should always be Self

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Struct solana_local_cluster::local_cluster::LocalCluster

Fields

Implementations

impl LocalCluster

pub fn new_with_equal_stakes( num_nodes: usize, cluster_lamports: u64, lamports_per_node: u64, socket_addr_space: SocketAddrSpace) -> Self

pub fn new( config: &mut ClusterConfig, socket_addr_space: SocketAddrSpace) -> Self

pub fn exit(&mut self)

pub fn close_preserve_ledgers(&mut self)

pub fn add_validator_listener( &mut self, validator_config: &ValidatorConfig, stake: u64, validator_keypair: Arc<Keypair>, voting_keypair: Option<Arc<Keypair>>, socket_addr_space: SocketAddrSpace) -> Pubkey

pub fn add_validator( &mut self, validator_config: &ValidatorConfig, stake: u64, validator_keypair: Arc<Keypair>, voting_keypair: Option<Arc<Keypair>>, socket_addr_space: SocketAddrSpace) -> Pubkey

pub fn ledger_path(&self, validator_pubkey: &Pubkey) -> PathBuf

pub fn transfer( &self, source_keypair: &Keypair, dest_pubkey: &Pubkey, lamports: u64) -> u64

pub fn check_for_new_roots( &self, num_new_roots: usize, test_name: &str, socket_addr_space: SocketAddrSpace)

pub fn check_no_new_roots( &self, num_slots_to_wait: usize, test_name: &str, socket_addr_space: SocketAddrSpace)

impl LocalCluster

pub fn wait_for_next_full_snapshot( &self, snapshot_archives_dir: impl AsRef<Path>) -> FullSnapshotArchiveInfo

pub fn wait_for_next_incremental_snapshot( &self, snapshot_archives_dir: impl AsRef<Path>) -> (IncrementalSnapshotArchiveInfo, FullSnapshotArchiveInfo)

pub fn wait_for_next_snapshot( &self, snapshot_archives_dir: impl AsRef<Path>, next_snapshot_type: NextSnapshotType) -> NextSnapshotResult

Trait Implementations

impl Cluster for LocalCluster

fn get_node_pubkeys(&self) -> Vec<Pubkey>ⓘNotable traits for Vec<u8, A>impl<A> Write for Vec<u8, A> where A: Allocator,

fn get_validator_client( &self, pubkey: &Pubkey) -> Option<ThinClient<UdpTpuConnection>>

fn exit_node(&mut self, pubkey: &Pubkey) -> ClusterValidatorInfo

fn create_restart_context( &mut self, pubkey: &Pubkey, cluster_validator_info: &mut ClusterValidatorInfo) -> (Node, Option<ContactInfo>)

fn restart_node( &mut self, pubkey: &Pubkey, cluster_validator_info: ClusterValidatorInfo, socket_addr_space: SocketAddrSpace)

fn add_node( &mut self, pubkey: &Pubkey, cluster_validator_info: ClusterValidatorInfo)

fn restart_node_with_context( cluster_validator_info: ClusterValidatorInfo, (node, entry_point_info): (Node, Option<ContactInfo>), socket_addr_space: SocketAddrSpace) -> ClusterValidatorInfo

fn exit_restart_node( &mut self, pubkey: &Pubkey, validator_config: ValidatorConfig, socket_addr_space: SocketAddrSpace)

fn get_contact_info(&self, pubkey: &Pubkey) -> Option<&ContactInfo>

impl Drop for LocalCluster

fn drop(&mut self)

Auto Trait Implementations

impl !RefUnwindSafe for LocalCluster

impl Send for LocalCluster

impl Sync for LocalCluster

impl Unpin for LocalCluster

impl !UnwindSafe for LocalCluster

Blanket Implementations

impl<T> AbiExample for T

default fn example() -> T

impl<T> Any for T where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for T where U: From<T>,

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Same<T> for T

type Output = T

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> TupleTree<T, ()> for T

const SIZE: Size

fn descendants(_indirect_level: usize) -> usize

fn height() -> usize

fn preorder(self, f: &mut impl FnMut(Visit<T>))

fn preorder_with_size_hint(self, f: &mut impl FnMut(Visit<T>, Size))

fn postorder(self, f: &mut impl FnMut(Visit<T>))

fn postorder_with_size_hint(self, f: &mut impl FnMut(Visit<T>, Size))

impl<V, T> VZip<V> for T where V: MultiLane<T>,

fn vzip(self) -> V

pub fn new_with_equal_stakes(
num_nodes: usize,
cluster_lamports: u64,
lamports_per_node: u64,
socket_addr_space: SocketAddrSpace
) -> Self

pub fn new(
config: &mut ClusterConfig,
socket_addr_space: SocketAddrSpace
) -> Self

pub fn add_validator_listener(
&mut self,
validator_config: &ValidatorConfig,
stake: u64,
validator_keypair: Arc<Keypair>,
voting_keypair: Option<Arc<Keypair>>,
socket_addr_space: SocketAddrSpace
) -> Pubkey

pub fn add_validator(
&mut self,
validator_config: &ValidatorConfig,
stake: u64,
validator_keypair: Arc<Keypair>,
voting_keypair: Option<Arc<Keypair>>,
socket_addr_space: SocketAddrSpace
) -> Pubkey

pub fn transfer(
&self,
source_keypair: &Keypair,
dest_pubkey: &Pubkey,
lamports: u64
) -> u64

pub fn check_for_new_roots(
&self,
num_new_roots: usize,
test_name: &str,
socket_addr_space: SocketAddrSpace
)

pub fn check_no_new_roots(
&self,
num_slots_to_wait: usize,
test_name: &str,
socket_addr_space: SocketAddrSpace
)

pub fn wait_for_next_full_snapshot(
&self,
snapshot_archives_dir: impl AsRef<Path>
) -> FullSnapshotArchiveInfo

pub fn wait_for_next_incremental_snapshot(
&self,
snapshot_archives_dir: impl AsRef<Path>
) -> (IncrementalSnapshotArchiveInfo, FullSnapshotArchiveInfo )

pub fn wait_for_next_snapshot(
&self,
snapshot_archives_dir: impl AsRef<Path>,
next_snapshot_type: NextSnapshotType
) -> NextSnapshotResult

fn get_node_pubkeys(&self) -> Vec<Pubkey>ⓘNotable traits for Vec<u8, A>`impl<A> Write for Vec<u8, A> where A: Allocator,`

fn get_validator_client(
&self,
pubkey: &Pubkey
) -> Option<ThinClient<UdpTpuConnection>>

fn create_restart_context(
&mut self,
pubkey: &Pubkey,
cluster_validator_info: &mut ClusterValidatorInfo
) -> (Node, Option<ContactInfo>)

fn restart_node(
&mut self,
pubkey: &Pubkey,
cluster_validator_info: ClusterValidatorInfo,
socket_addr_space: SocketAddrSpace
)

fn add_node(
&mut self,
pubkey: &Pubkey,
cluster_validator_info: ClusterValidatorInfo
)

fn restart_node_with_context(
cluster_validator_info: ClusterValidatorInfo,
(node, entry_point_info): (Node, Option<ContactInfo>),
socket_addr_space: SocketAddrSpace
) -> ClusterValidatorInfo

fn exit_restart_node(
&mut self,
pubkey: &Pubkey,
validator_config: ValidatorConfig,
socket_addr_space: SocketAddrSpace
)

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<T, U> Into<U> for T where
U: From<T>,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,