pub struct JormungandrProcess {
pub child: Child,
pub logger: JormungandrLogger,
grpc_client: JormungandrClient,
temp_dir: Option<TestingDirectory>,
alias: String,
p2p_public_address: Multiaddr,
p2p_listen_address: SocketAddr,
rest_socket_addr: SocketAddr,
}
Fields§
§child: Child
§logger: JormungandrLogger
§grpc_client: JormungandrClient
§temp_dir: Option<TestingDirectory>
§alias: String
§p2p_public_address: Multiaddr
§p2p_listen_address: SocketAddr
§rest_socket_addr: SocketAddr
Implementations§
source§impl JormungandrProcess
impl JormungandrProcess
pub fn new( child: Child, comm_config: CommunicationParams, temp_dir: Option<TestingDirectory>, alias: String ) -> Result<Self, StartupError>
pub fn process_id(&self) -> u32
pub fn grpc(&self) -> JormungandrClient
pub fn wait_for_bootstrap( &self, verification_mode: &StartupVerificationMode, timeout: Duration ) -> Result<(), StartupError>
pub fn wait_for_shutdown( &mut self, timeout: Duration ) -> Result<Option<ExitStatus>, ShutdownError>
fn check_startup_errors_in_logs(&self) -> Result<(), JormungandrError>
pub fn status( &self, strategy: &StartupVerificationMode ) -> Result<Status, StartupError>
pub fn as_named_process(&self) -> NamedProcess
pub fn p2p_listen_addr(&self) -> SocketAddr
pub fn p2p_public_address(&self) -> Multiaddr
pub fn rest_address(&self) -> SocketAddr
pub fn alias(&self) -> NodeAlias
pub fn temp_dir(&self) -> Option<PathBuf>
pub fn rest(&self) -> JormungandrRest
pub fn rest_debug(&self) -> JormungandrRest
pub fn secure_rest<P: AsRef<Path>>(&self, cert: P) -> JormungandrRest
pub fn shutdown(&self)
pub fn address(&self) -> SocketAddr
pub fn correct_state_verifier(&self) -> JormungandrStateVerifier
pub fn log_stats(&self)
pub fn assert_no_errors_in_log_with_message(&self, message: &str)
pub fn assert_no_errors_in_log(&self)
pub fn check_no_errors_in_log(&self) -> Result<(), JormungandrError>
pub fn rest_uri(&self) -> String
pub fn pid(&self) -> u32
pub fn explorer( &self, params: ExplorerParams ) -> Result<ExplorerProcess, ExplorerError>
pub fn to_trusted_peer(&self) -> TrustedPeer
pub fn time_era(&self) -> TimeEra
pub fn ports_are_opened(&self) -> bool
fn port_opened(&self, port: u16) -> bool
pub fn to_remote(&self) -> RemoteJormungandr
pub fn steal_temp_dir(&mut self) -> Option<TestingDirectory>
pub fn stop(self)
Trait Implementations§
source§impl Drop for JormungandrProcess
impl Drop for JormungandrProcess
source§impl FragmentNode for JormungandrProcess
impl FragmentNode for JormungandrProcess
fn alias(&self) -> NodeAlias
fn fragment_logs( &self ) -> Result<HashMap<FragmentId, FragmentLog>, FragmentNodeError>
fn send_fragment( &self, fragment: Fragment ) -> Result<MemPoolCheck, FragmentNodeError>
fn send_batch_fragments( &self, fragments: Vec<Fragment>, fail_fast: bool ) -> Result<FragmentsProcessingSummary, FragmentNodeError>
fn log_pending_fragment(&self, fragment_id: FragmentId)
fn log_rejected_fragment(&self, fragment_id: FragmentId, reason: String)
fn log_in_block_fragment( &self, fragment_id: FragmentId, date: BlockDate, block: Hash )
fn log_content(&self) -> Vec<String>
source§impl SyncNode for JormungandrProcess
impl SyncNode for JormungandrProcess
Auto Trait Implementations§
impl !RefUnwindSafe for JormungandrProcess
impl Send for JormungandrProcess
impl !Sync for JormungandrProcess
impl Unpin for JormungandrProcess
impl !UnwindSafe for JormungandrProcess
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request