Struct holochain::conductor::handle::MockConductorHandleT [−][src]
pub struct MockConductorHandleT { /* fields omitted */ }
Expand description
Base trait for ConductorHandle
Implementations
Validate that all current expectations for all methods have been satisfied, and discard them.
Create a new mock object with no expectations.
This method will not be generated if the real struct
already has a new
method. However, it will be
generated if the struct implements a trait with a new
method. The trait’s new
method can still be called
like <MockX as TraitY>::new
Create an Expectation
for mocking the check_running
method
Create an Expectation
for mocking the initialize_conductor
method
Create an Expectation
for mocking the add_admin_interfaces
method
Create an Expectation
for mocking the add_app_interface
method
Create an Expectation
for mocking the list_app_interfaces
method
Create an Expectation
for mocking the register_dna
method
Create an Expectation
for mocking the list_dnas
method
Create an Expectation
for mocking the get_dna
method
Create an Expectation
for mocking the get_ribosome
method
Create an Expectation
for mocking the get_entry_def
method
Create an Expectation
for mocking the load_dnas
method
Create an Expectation
for mocking the dispatch_holochain_p2p_event
method
Create an Expectation
for mocking the call_zome
method
Create an Expectation
for mocking the call_zome_with_workspace
method
Create an Expectation
for mocking the get_arbitrary_admin_websocket_port
method
Create an Expectation
for mocking the take_shutdown_handle
method
Create an Expectation
for mocking the shutdown
method
Create an Expectation
for mocking the keystore
method
Create an Expectation
for mocking the holochain_p2p
method
Create an Expectation
for mocking the create_clone_cell
method
Create an Expectation
for mocking the destroy_clone_cell
method
Create an Expectation
for mocking the install_app
method
Create an Expectation
for mocking the install_app_bundle
method
Create an Expectation
for mocking the uninstall_app
method
Create an Expectation
for mocking the reconcile_app_status_with_cell_status
method
Create an Expectation
for mocking the reconcile_cell_status_with_app_status
method
Create an Expectation
for mocking the enable_app
method
Create an Expectation
for mocking the disable_app
method
Create an Expectation
for mocking the start_app
method
Create an Expectation
for mocking the start_scheduler
method
Create an Expectation
for mocking the dispatch_scheduled_fns
method
Create an Expectation
for mocking the post_commit_permit
method
Create an Expectation
for mocking the pause_app
method
Create an Expectation
for mocking the list_cell_ids
method
Create an Expectation
for mocking the list_running_apps
method
Create an Expectation
for mocking the list_apps
method
Create an Expectation
for mocking the list_running_apps_for_required_cell_id
method
Create an Expectation
for mocking the dump_cell_state
method
Create an Expectation
for mocking the dump_full_cell_state
method
Create an Expectation
for mocking the signal_broadcaster
method
Create an Expectation
for mocking the get_app_info
method
Create an Expectation
for mocking the add_agent_infos
method
Create an Expectation
for mocking the get_agent_infos
method
Create an Expectation
for mocking the print_setup
method
Create an Expectation
for mocking the get_cell_env_readonly
method
Create an Expectation
for mocking the remove_cells
method
Create an Expectation
for mocking the get_cell_env
method
Create an Expectation
for mocking the get_cache_env
method
Create an Expectation
for mocking the get_p2p_env
method
Create an Expectation
for mocking the get_cell_triggers
method
Create an Expectation
for mocking the get_state_from_handle
method
Create an Expectation
for mocking the add_test_app_interface
method
Create an Expectation
for mocking the dev_settings
method
Create an Expectation
for mocking the update_dev_settings
method
Create an Expectation
for mocking the update_cell_status
method
Create an Expectation
for mocking the transition_app_status
method
Trait Implementations
Base trait for ConductorHandle
Returns error if conductor is shutting down
fn initialize_conductor<'async_trait>(
self: Arc<Self>,
admin_configs: Vec<AdminInterfaceConfig>
) -> Pin<Box<dyn Future<Output = ConductorResult<CellStartupErrors>> + Send + 'async_trait>> where
Self: 'async_trait,
fn initialize_conductor<'async_trait>(
self: Arc<Self>,
admin_configs: Vec<AdminInterfaceConfig>
) -> Pin<Box<dyn Future<Output = ConductorResult<CellStartupErrors>> + Send + 'async_trait>> where
Self: 'async_trait,
Initialize the task manager, add admin interfaces from config, start up app interfaces from db, and register all tasks.
This requires a concrete ConductorHandle to be passed into the interface tasks. This is a bit weird to do, but it was the only way around having a circular reference in the types.
Never use a ConductorHandle for different Conductor here!
fn add_admin_interfaces<'async_trait>(
self: Arc<Self>,
configs: Vec<AdminInterfaceConfig>
) -> Pin<Box<dyn Future<Output = ConductorResult<()>> + Send + 'async_trait>> where
Self: 'async_trait,
fn add_admin_interfaces<'async_trait>(
self: Arc<Self>,
configs: Vec<AdminInterfaceConfig>
) -> Pin<Box<dyn Future<Output = ConductorResult<()>> + Send + 'async_trait>> where
Self: 'async_trait,
Add a collection of admin interfaces from config
fn add_app_interface<'async_trait>(
self: Arc<Self>,
port: u16
) -> Pin<Box<dyn Future<Output = ConductorResult<u16>> + Send + 'async_trait>> where
Self: 'async_trait,
fn add_app_interface<'async_trait>(
self: Arc<Self>,
port: u16
) -> Pin<Box<dyn Future<Output = ConductorResult<u16>> + Send + 'async_trait>> where
Self: 'async_trait,
Add an app interface
fn list_app_interfaces<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = ConductorResult<Vec<u16>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn list_app_interfaces<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = ConductorResult<Vec<u16>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
List the app interfaces currently install.
fn register_dna<'life0, 'async_trait>(
&'life0 self,
dna: DnaFile
) -> Pin<Box<dyn Future<Output = ConductorResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn register_dna<'life0, 'async_trait>(
&'life0 self,
dna: DnaFile
) -> Pin<Box<dyn Future<Output = ConductorResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Install a DnaFile in this Conductor
Get the list of hashes of installed Dnas in this Conductor
Get an instance of a RealRibosome for the DnaHash
Get a EntryDef from the [EntryDefBuffer]
Add the DnaFiles from the wasm and dna_def databases into memory
fn dispatch_holochain_p2p_event<'life0, 'async_trait>(
&'life0 self,
event: HolochainP2pEvent
) -> Pin<Box<dyn Future<Output = ConductorApiResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn dispatch_holochain_p2p_event<'life0, 'async_trait>(
&'life0 self,
event: HolochainP2pEvent
) -> Pin<Box<dyn Future<Output = ConductorApiResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Dispatch a network event to the correct cell. Warning: returning an error from this function kills the network for the conductor.
fn call_zome<'life0, 'async_trait>(
&'life0 self,
invocation: ZomeCall
) -> Pin<Box<dyn Future<Output = ConductorApiResult<ZomeCallResult>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn call_zome<'life0, 'async_trait>(
&'life0 self,
invocation: ZomeCall
) -> Pin<Box<dyn Future<Output = ConductorApiResult<ZomeCallResult>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Invoke a zome function on a Cell
fn call_zome_with_workspace<'life0, 'async_trait>(
&'life0 self,
invocation: ZomeCall,
workspace_lock: HostFnWorkspace
) -> Pin<Box<dyn Future<Output = ConductorApiResult<ZomeCallResult>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn call_zome_with_workspace<'life0, 'async_trait>(
&'life0 self,
invocation: ZomeCall,
workspace_lock: HostFnWorkspace
) -> Pin<Box<dyn Future<Output = ConductorApiResult<ZomeCallResult>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Invoke a zome function on a Cell with a workspace
Get a Websocket port which will
Return the JoinHandle for all managed tasks, which when resolved will signal that the Conductor has completely shut down.
NB: The JoinHandle is not cloneable, so this can only ever be called successfully once.
Request access to this conductor’s keystore
Request access to this conductor’s networking handle
fn create_clone_cell<'async_trait>(
self: Arc<Self>,
payload: CreateCloneCellPayload
) -> Pin<Box<dyn Future<Output = ConductorResult<CellId>> + Send + 'async_trait>> where
Self: 'async_trait,
fn create_clone_cell<'async_trait>(
self: Arc<Self>,
payload: CreateCloneCellPayload
) -> Pin<Box<dyn Future<Output = ConductorResult<CellId>> + Send + 'async_trait>> where
Self: 'async_trait,
Create a new Cell in an existing App based on an existing DNA
fn destroy_clone_cell<'async_trait>(
self: Arc<Self>,
cell_id: CellId
) -> Pin<Box<dyn Future<Output = ConductorResult<()>> + Send + 'async_trait>> where
Self: 'async_trait,
fn destroy_clone_cell<'async_trait>(
self: Arc<Self>,
cell_id: CellId
) -> Pin<Box<dyn Future<Output = ConductorResult<()>> + Send + 'async_trait>> where
Self: 'async_trait,
Destroy a cloned Cell
fn install_app<'async_trait>(
self: Arc<Self>,
installed_app_id: InstalledAppId,
cell_data_with_proofs: Vec<(InstalledCell, Option<MembraneProof>)>
) -> Pin<Box<dyn Future<Output = ConductorResult<()>> + Send + 'async_trait>> where
Self: 'async_trait,
fn install_app<'async_trait>(
self: Arc<Self>,
installed_app_id: InstalledAppId,
cell_data_with_proofs: Vec<(InstalledCell, Option<MembraneProof>)>
) -> Pin<Box<dyn Future<Output = ConductorResult<()>> + Send + 'async_trait>> where
Self: 'async_trait,
Install Cells into ConductorState based on installation info, and run genesis on all new source chains
fn install_app_bundle<'async_trait>(
self: Arc<Self>,
payload: InstallAppBundlePayload
) -> Pin<Box<dyn Future<Output = ConductorResult<StoppedApp>> + Send + 'async_trait>> where
Self: 'async_trait,
fn install_app_bundle<'async_trait>(
self: Arc<Self>,
payload: InstallAppBundlePayload
) -> Pin<Box<dyn Future<Output = ConductorResult<StoppedApp>> + Send + 'async_trait>> where
Self: 'async_trait,
Install DNAs and set up Cells as specified by an AppBundle
fn uninstall_app<'life0, 'async_trait>(
self: Arc<Self>,
app: &'life0 InstalledAppId
) -> Pin<Box<dyn Future<Output = ConductorResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn uninstall_app<'life0, 'async_trait>(
self: Arc<Self>,
app: &'life0 InstalledAppId
) -> Pin<Box<dyn Future<Output = ConductorResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Uninstall an app from the state DB and remove all running Cells
fn reconcile_app_status_with_cell_status<'life0, 'async_trait>(
&'life0 self,
app_ids: Option<HashSet<InstalledAppId>>
) -> Pin<Box<dyn Future<Output = ConductorResult<AppStatusFx>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn reconcile_app_status_with_cell_status<'life0, 'async_trait>(
&'life0 self,
app_ids: Option<HashSet<InstalledAppId>>
) -> Pin<Box<dyn Future<Output = ConductorResult<AppStatusFx>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Adjust app statuses (via state transitions) to match the current reality of which Cells are present in the conductor.
fn reconcile_cell_status_with_app_status<'async_trait>(
self: Arc<Self>
) -> Pin<Box<dyn Future<Output = ConductorResult<CellStartupErrors>> + Send + 'async_trait>> where
Self: 'async_trait,
fn reconcile_cell_status_with_app_status<'async_trait>(
self: Arc<Self>
) -> Pin<Box<dyn Future<Output = ConductorResult<CellStartupErrors>> + Send + 'async_trait>> where
Self: 'async_trait,
Adjust which cells are present in the Conductor (adding and removing as needed) to match the current reality of all app statuses.
- If a Cell is used by at least one Running app, then ensure it is added
- If a Cell is used by no running apps, then ensure it is removed.
fn enable_app<'async_trait>(
self: Arc<Self>,
app_id: InstalledAppId
) -> Pin<Box<dyn Future<Output = ConductorResult<(InstalledApp, CellStartupErrors)>> + Send + 'async_trait>> where
Self: 'async_trait,
fn enable_app<'async_trait>(
self: Arc<Self>,
app_id: InstalledAppId
) -> Pin<Box<dyn Future<Output = ConductorResult<(InstalledApp, CellStartupErrors)>> + Send + 'async_trait>> where
Self: 'async_trait,
Activate an app
fn disable_app<'async_trait>(
self: Arc<Self>,
app_id: InstalledAppId,
reason: DisabledAppReason
) -> Pin<Box<dyn Future<Output = ConductorResult<InstalledApp>> + Send + 'async_trait>> where
Self: 'async_trait,
fn disable_app<'async_trait>(
self: Arc<Self>,
app_id: InstalledAppId,
reason: DisabledAppReason
) -> Pin<Box<dyn Future<Output = ConductorResult<InstalledApp>> + Send + 'async_trait>> where
Self: 'async_trait,
Disable an app
fn start_app<'async_trait>(
self: Arc<Self>,
app_id: InstalledAppId
) -> Pin<Box<dyn Future<Output = ConductorResult<InstalledApp>> + Send + 'async_trait>> where
Self: 'async_trait,
fn start_app<'async_trait>(
self: Arc<Self>,
app_id: InstalledAppId
) -> Pin<Box<dyn Future<Output = ConductorResult<InstalledApp>> + Send + 'async_trait>> where
Self: 'async_trait,
Start an enabled but stopped (paused) app
Start the scheduler. All ephemeral tasks are deleted.
Dispatch all due scheduled functions.
fn post_commit_permit<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = Result<OwnedPermit<PostCommitArgs>, SendError<()>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn post_commit_permit<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = Result<OwnedPermit<PostCommitArgs>, SendError<()>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Get an OwnedPermit to the post commit task.
fn pause_app<'async_trait>(
self: Arc<Self>,
app_id: InstalledAppId,
reason: PausedAppReason
) -> Pin<Box<dyn Future<Output = ConductorResult<InstalledApp>> + Send + 'async_trait>> where
Self: 'async_trait,
fn pause_app<'async_trait>(
self: Arc<Self>,
app_id: InstalledAppId,
reason: PausedAppReason
) -> Pin<Box<dyn Future<Output = ConductorResult<InstalledApp>> + Send + 'async_trait>> where
Self: 'async_trait,
Stop a running app while leaving it enabled. FOR TESTING ONLY.
List Cell Ids
fn list_running_apps<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = ConductorResult<Vec<InstalledAppId>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn list_running_apps<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = ConductorResult<Vec<InstalledAppId>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
List Active AppIds
fn list_apps<'life0, 'async_trait>(
&'life0 self,
status_filter: Option<AppStatusFilter>
) -> Pin<Box<dyn Future<Output = ConductorResult<Vec<InstalledAppInfo>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn list_apps<'life0, 'async_trait>(
&'life0 self,
status_filter: Option<AppStatusFilter>
) -> Pin<Box<dyn Future<Output = ConductorResult<Vec<InstalledAppInfo>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
List Apps with their information
fn list_running_apps_for_required_cell_id<'life0, 'life1, 'async_trait>(
&'life0 self,
cell_id: &'life1 CellId
) -> Pin<Box<dyn Future<Output = ConductorResult<HashSet<InstalledAppId>>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn list_running_apps_for_required_cell_id<'life0, 'life1, 'async_trait>(
&'life0 self,
cell_id: &'life1 CellId
) -> Pin<Box<dyn Future<Output = ConductorResult<HashSet<InstalledAppId>>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Get the IDs of all active installed Apps which use this Cell
fn dump_cell_state<'life0, 'life1, 'async_trait>(
&'life0 self,
cell_id: &'life1 CellId
) -> Pin<Box<dyn Future<Output = ConductorApiResult<String>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn dump_cell_state<'life0, 'life1, 'async_trait>(
&'life0 self,
cell_id: &'life1 CellId
) -> Pin<Box<dyn Future<Output = ConductorApiResult<String>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Dump the cells state
fn dump_full_cell_state<'life0, 'life1, 'async_trait>(
&'life0 self,
cell_id: &'life1 CellId,
dht_ops_cursor: Option<u64>
) -> Pin<Box<dyn Future<Output = ConductorApiResult<FullStateDump>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn dump_full_cell_state<'life0, 'life1, 'async_trait>(
&'life0 self,
cell_id: &'life1 CellId,
dht_ops_cursor: Option<u64>
) -> Pin<Box<dyn Future<Output = ConductorApiResult<FullStateDump>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Dump the full cells state
fn signal_broadcaster<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = SignalBroadcaster> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn signal_broadcaster<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = SignalBroadcaster> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Access the broadcast Sender which will send a Signal across every attached app interface
fn get_app_info<'life0, 'life1, 'async_trait>(
&'life0 self,
installed_app_id: &'life1 InstalledAppId
) -> Pin<Box<dyn Future<Output = ConductorResult<Option<InstalledAppInfo>>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn get_app_info<'life0, 'life1, 'async_trait>(
&'life0 self,
installed_app_id: &'life1 InstalledAppId
) -> Pin<Box<dyn Future<Output = ConductorResult<Option<InstalledAppInfo>>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Get info about an installed App, whether active or inactive
fn add_agent_infos<'life0, 'async_trait>(
&'life0 self,
agent_infos: Vec<AgentInfoSigned>
) -> Pin<Box<dyn Future<Output = ConductorApiResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn add_agent_infos<'life0, 'async_trait>(
&'life0 self,
agent_infos: Vec<AgentInfoSigned>
) -> Pin<Box<dyn Future<Output = ConductorApiResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Add signed agent info to the conductor
fn get_agent_infos<'life0, 'async_trait>(
&'life0 self,
cell_id: Option<CellId>
) -> Pin<Box<dyn Future<Output = ConductorApiResult<Vec<AgentInfoSigned>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn get_agent_infos<'life0, 'async_trait>(
&'life0 self,
cell_id: Option<CellId>
) -> Pin<Box<dyn Future<Output = ConductorApiResult<Vec<AgentInfoSigned>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Get signed agent info from the conductor
Print the current setup in a machine readable way.
Retrieve the environment for this cell.
Manually remove some cells. Should only be used when handling errors in Cells, allowing individual Cells to be shut down.
Retrieve the environment for this cell. FOR TESTING ONLY.
Retrieve the database for this cell. FOR TESTING ONLY.
Retrieve the database for networking. FOR TESTING ONLY.
Retrieve Senders for triggering workflows. FOR TESTING ONLY.
fn get_state_from_handle<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = ConductorApiResult<ConductorState>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn get_state_from_handle<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = ConductorApiResult<ConductorState>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Retrieve the ConductorState. FOR TESTING ONLY.
fn add_test_app_interface<'life0, 'async_trait>(
&'life0 self,
id: AppInterfaceId
) -> Pin<Box<dyn Future<Output = ConductorResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn add_test_app_interface<'life0, 'async_trait>(
&'life0 self,
id: AppInterfaceId
) -> Pin<Box<dyn Future<Output = ConductorResult<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Add a “test” app interface for sending and receiving signals. FOR TESTING ONLY.
Get the current dev settings
Update the current dev settings
Manually coerce cells to a given CellStatus. FOR TESTING ONLY.
fn transition_app_status<'life0, 'async_trait>(
&'life0 self,
app_id: InstalledAppId,
transition: AppStatusTransition
) -> Pin<Box<dyn Future<Output = ConductorResult<(InstalledApp, AppStatusFx)>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn transition_app_status<'life0, 'async_trait>(
&'life0 self,
app_id: InstalledAppId,
transition: AppStatusTransition
) -> Pin<Box<dyn Future<Output = ConductorResult<(InstalledApp, AppStatusFx)>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Manually coerce app to a given AppStatus. FOR TESTING ONLY.
Auto Trait Implementations
impl !RefUnwindSafe for MockConductorHandleT
impl Send for MockConductorHandleT
impl Sync for MockConductorHandleT
impl Unpin for MockConductorHandleT
impl !UnwindSafe for MockConductorHandleT
Blanket Implementations
fn type_id_compat(&self) -> TypeId
fn type_id_compat(&self) -> TypeId
TODO: once 1.33.0 is the minimum supported compiler version, remove Any::type_id_compat and use StdAny::type_id instead. https://github.com/rust-lang/rust/issues/27745 Read more
type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
pub fn pointer_metadata(
&<T as ArchivePointee>::ArchivedMetadata
) -> <T as Pointee>::Metadata
pub fn pointer_metadata(
&<T as ArchivePointee>::ArchivedMetadata
) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
Mutably borrows from an owned value. Read more
fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more