pub struct StatefulServiceReplicaProxy { /* private fields */ }Implementations§
Source§impl StatefulServiceReplicaProxy
impl StatefulServiceReplicaProxy
pub fn new( com_impl: IFabricStatefulServiceReplica, ) -> StatefulServiceReplicaProxy
Trait Implementations§
Source§impl IStatefulServiceReplica for StatefulServiceReplicaProxy
impl IStatefulServiceReplica for StatefulServiceReplicaProxy
Source§fn open<'life0, 'async_trait>(
&'life0 self,
openmode: OpenMode,
partition: Arc<dyn IStatefulServicePartition>,
cancellation_token: BoxedCancelToken,
) -> Pin<Box<dyn Future<Output = Result<Box<dyn IPrimaryReplicator>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn open<'life0, 'async_trait>(
&'life0 self,
openmode: OpenMode,
partition: Arc<dyn IStatefulServicePartition>,
cancellation_token: BoxedCancelToken,
) -> Pin<Box<dyn Future<Output = Result<Box<dyn IPrimaryReplicator>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Opens an initialized service replica so that additional actions can be taken.
Returns PrimaryReplicator that is used by the stateful service.
Note:
Most user calls IFabricStatefulServicePartition.CreateReplicator instead of
writing their own replicator (TODO: not supported in mssf yet),
or use FabricCreateKeyValueStoreReplica.
Source§fn change_role<'life0, 'async_trait>(
&'life0 self,
newrole: ReplicaRole,
cancellation_token: BoxedCancelToken,
) -> Pin<Box<dyn Future<Output = Result<WString>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn change_role<'life0, 'async_trait>(
&'life0 self,
newrole: ReplicaRole,
cancellation_token: BoxedCancelToken,
) -> Pin<Box<dyn Future<Output = Result<WString>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Changes the role of the service replica to one of the ReplicaRole.
Returns the service’s new connection address that is to be associated with the replica via Service Fabric Naming.
Remarks:
The new role is indicated as a parameter. When the service transitions to the new role,
the service has a chance to update its current listening address. The listening address is the address
where clients connect to it and the one returned via the ResolveAsync API. This enables the service when
it is a primary replica to only claim some resources such as ports when communication from clients is expected.
Source§fn close<'life0, 'async_trait>(
&'life0 self,
cancellation_token: BoxedCancelToken,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn close<'life0, 'async_trait>(
&'life0 self,
cancellation_token: BoxedCancelToken,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Closes the service replica gracefully when it is being shut down.
Source§fn abort(&self)
fn abort(&self)
Ungracefully terminates the service replica.
Remarks: Network issues resulting in Service Fabric process shutdown
and the use of ReportFault(FaultType) to report a Permanent fault are examples of ungraceful termination.
When this method is invoked, the service replica should immediately release and clean up all references and return.
Auto Trait Implementations§
impl Freeze for StatefulServiceReplicaProxy
impl RefUnwindSafe for StatefulServiceReplicaProxy
impl Send for StatefulServiceReplicaProxy
impl Sync for StatefulServiceReplicaProxy
impl Unpin for StatefulServiceReplicaProxy
impl UnsafeUnpin for StatefulServiceReplicaProxy
impl UnwindSafe for StatefulServiceReplicaProxy
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