Struct 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>, safe_client_metrics_base: SafeClientMetricsBase, auth_agg_metrics: Arc<AuthAggMetrics>, validator_display_names: Arc<HashMap<AuthorityName, String>>, timeouts: TimeoutConfig, ) -> 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_epoch_start_state( epoch_start_state: &EpochStartSystemState, committee_store: &Arc<CommitteeStore>, safe_client_metrics_base: SafeClientMetricsBase, auth_agg_metrics: Arc<AuthAggMetrics>, ) -> Self

Create a new network authority aggregator by reading the committee and network addresses information from the given epoch start system state.

pub fn recreate_with_new_epoch_start_state( &self, epoch_start_state: &EpochStartSystemState, ) -> Self

Create a new AuthorityAggregator using information from the given epoch start system state. This is typically used during reconfiguration to create a new AuthorityAggregator with the new committee and network addresses.

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>>, ) -> 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.