Struct sui_core::authority_aggregator::AuthorityAggregator

pub struct AuthorityAggregator<A: Clone> {
    pub committee: Arc<Committee>,
    pub validator_display_names: Arc<HashMap<AuthorityName, String>>,
    pub authority_clients: Arc<BTreeMap<AuthorityName, Arc<SafeClient<A>>>>,
    pub metrics: Arc<AuthAggMetrics>,
    pub safe_client_metrics_base: SafeClientMetricsBase,
    pub timeouts: TimeoutConfig,
    pub committee_store: Arc<CommitteeStore>,
}

Fields

committee: Arc<Committee>

Our Sui committee.

validator_display_names: Arc<HashMap<AuthorityName, String>>

For more human readable metrics reporting. It’s OK for this map to be empty or missing validators, it then defaults to use concise validator public keys.

authority_clients: Arc<BTreeMap<AuthorityName, Arc<SafeClient<A>>>>

How to talk to this committee.

metrics: Arc<AuthAggMetrics>

Metrics

safe_client_metrics_base: SafeClientMetricsBase

Metric base for the purpose of creating new safe clients during reconfiguration.

timeouts: TimeoutConfig

committee_store: Arc<CommitteeStore>

Store here for clone during re-config.

Implementations

impl<A: Clone> AuthorityAggregator<A>

pub fn new( committee: Committee, committee_store: Arc<CommitteeStore>, authority_clients: BTreeMap<AuthorityName, A>, registry: &Registry, validator_display_names: Arc<HashMap<AuthorityName, String>> ) -> Self

pub fn new_with_timeouts( committee: Committee, committee_store: Arc<CommitteeStore>, authority_clients: BTreeMap<AuthorityName, A>, registry: &Registry, validator_display_names: Arc<HashMap<AuthorityName, String>>, timeouts: TimeoutConfig ) -> Self

pub fn new_with_metrics( committee: Committee, committee_store: Arc<CommitteeStore>, authority_clients: BTreeMap<AuthorityName, A>, safe_client_metrics_base: SafeClientMetricsBase, auth_agg_metrics: Arc<AuthAggMetrics>, validator_display_names: Arc<HashMap<AuthorityName, String>> ) -> Self

pub fn recreate_with_net_addresses( &self, committee: CommitteeWithNetworkMetadata, network_config: &Config, disallow_missing_intermediate_committees: bool ) -> SuiResult<AuthorityAggregator<NetworkAuthorityClient>>

This function recreates AuthorityAggregator with the given committee. It also updates committee store which impacts other of its references. When disallow_missing_intermediate_committees is true, it requires the new committee needs to be current epoch + 1. The function could be used along with reconfig_from_genesis to fill in all previous epoch’s committee info.

pub fn get_client(&self, name: &AuthorityName) -> Option<&Arc<SafeClient<A>>>

pub fn clone_client_test_only(&self, name: &AuthorityName) -> Arc<SafeClient<A>>

where A: Clone,

pub fn clone_committee_store(&self) -> Arc<CommitteeStore>

pub fn clone_inner_committee_test_only(&self) -> Committee

pub fn clone_inner_clients_test_only( &self ) -> BTreeMap<AuthorityName, SafeClient<A>>

impl AuthorityAggregator<NetworkAuthorityClient>

pub fn new_from_local_system_state( store: &Arc<dyn ExecutionCacheRead>, committee_store: &Arc<CommitteeStore>, safe_client_metrics_base: SafeClientMetricsBase, auth_agg_metrics: AuthAggMetrics ) -> Result<Self>

Create a new network authority aggregator by reading the committee and network address information from the system state object on-chain. This function needs metrics parameters because registry will panic if we attempt to register already-registered metrics again.

pub fn new_from_committee( committee: CommitteeWithNetworkMetadata, committee_store: &Arc<CommitteeStore>, safe_client_metrics_base: SafeClientMetricsBase, auth_agg_metrics: Arc<AuthAggMetrics>, validator_display_names: Arc<HashMap<AuthorityName, String>> ) -> Result<Self>

impl<A> AuthorityAggregator<A>

where A: AuthorityAPI + Send + Sync + 'static + Clone,

pub async fn get_latest_object_version_for_testing( &self, object_id: ObjectID ) -> SuiResult<Object>

Query the object with highest version number from the authorities. We stop after receiving responses from 2f+1 validators. This function is untrusted because we simply assume each response is valid and there are no byzantine validators. Because of this, this function should only be used for testing or benchmarking.

pub async fn get_latest_system_state_object_for_testing( &self ) -> Result<SuiSystemState>

Get the latest system state object from the authorities. This function assumes all validators are honest. It should only be used for testing or benchmarking.

pub async fn process_transaction( &self, transaction: Transaction, client_addr: Option<SocketAddr> ) -> Result<ProcessTransactionResult, AggregatorProcessTransactionError>

Submits the transaction to a quorum of validators to make a certificate.

pub async fn process_certificate( &self, request: HandleCertificateRequestV3, client_addr: Option<SocketAddr> ) -> Result<QuorumDriverResponse, AggregatorProcessCertificateError>

pub async fn execute_transaction_block( &self, transaction: &Transaction, client_addr: Option<SocketAddr> ) -> Result<VerifiedCertifiedTransactionEffects, Error>

pub async fn handle_transaction_info_request_from_some_validators( &self, tx_digest: &TransactionDigest, validators: &BTreeSet<AuthorityName>, timeout_total: Option<Duration> ) -> SuiResult<PlainTransactionInfoResponse>

This function tries to get SignedTransaction OR CertifiedTransaction from an given list of validators who are supposed to know about it.

Trait Implementations

impl<A: Clone + Clone> Clone for AuthorityAggregator<A>

fn clone(&self) -> AuthorityAggregator<A>

Returns a copy of the value.

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

Performs copy-assignment from source.