pub struct StatefulServiceReplicaProxy { /* private fields */ }Implementations§
Source§impl StatefulServiceReplicaProxy
impl StatefulServiceReplicaProxy
pub fn new( com_impl: IFabricStatefulServiceReplica, ) -> StatefulServiceReplicaProxy
Trait Implementations§
Source§impl StatefulServiceReplica for StatefulServiceReplicaProxy
impl StatefulServiceReplica for StatefulServiceReplicaProxy
Source§async fn open(
&self,
openmode: OpenMode,
partition: &StatefulServicePartition,
cancellation_token: BoxedCancelToken,
) -> Result<impl PrimaryReplicator>
async fn open( &self, openmode: OpenMode, partition: &StatefulServicePartition, cancellation_token: BoxedCancelToken, ) -> Result<impl PrimaryReplicator>
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§async fn change_role(
&self,
newrole: ReplicaRole,
cancellation_token: BoxedCancelToken,
) -> Result<WString>
async fn change_role( &self, newrole: ReplicaRole, cancellation_token: BoxedCancelToken, ) -> Result<WString>
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§async fn close(&self, cancellation_token: BoxedCancelToken) -> Result<()>
async fn close(&self, cancellation_token: BoxedCancelToken) -> Result<()>
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 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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<TraitVariantBlanketType> LocalStatefulServiceReplica for TraitVariantBlanketTypewhere
TraitVariantBlanketType: StatefulServiceReplica,
impl<TraitVariantBlanketType> LocalStatefulServiceReplica for TraitVariantBlanketTypewhere
TraitVariantBlanketType: StatefulServiceReplica,
Source§async fn open(
&self,
openmode: OpenMode,
partition: &StatefulServicePartition,
cancellation_token: Box<dyn CancelToken>,
) -> Result<impl PrimaryReplicator, Error>
async fn open( &self, openmode: OpenMode, partition: &StatefulServicePartition, cancellation_token: Box<dyn CancelToken>, ) -> Result<impl PrimaryReplicator, Error>
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§async fn change_role(
&self,
newrole: ReplicaRole,
cancellation_token: Box<dyn CancelToken>,
) -> Result<WString, Error>
async fn change_role( &self, newrole: ReplicaRole, cancellation_token: Box<dyn CancelToken>, ) -> Result<WString, Error>
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§async fn close(
&self,
cancellation_token: Box<dyn CancelToken>,
) -> Result<(), Error>
async fn close( &self, cancellation_token: Box<dyn CancelToken>, ) -> Result<(), Error>
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.