FabricActorService クラス

パッケージ:

microsoft.servicefabric.actors.runtime

• java.lang.Object
• • StatefulServiceBase
  • • microsoft.servicefabric.actors.runtime.FabricActorService

public class FabricActorService extends StatefulServiceBase implements ActorService

Microsoft Service Fabric ベースの信頼できるアクター サービスの基本クラスを表します。

発言：アクターのサービス レベルの動作をオーバーライドする場合は、このクラスから派生して独自のカスタム アクター サービスを実装します。

コンストラクターの概要

コンストラクター	説明
FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo)	ActorService クラスの新しいインスタンスを初期化します。
FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo, BiFunction<FabricActorService, ActorId, ActorBase> actorFactory)	ActorService クラスの新しいインスタンスを初期化します。
FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo, BiFunction<FabricActorService, ActorId, ActorBase> actorFactory, BiFunction<ActorBase, ActorStateProvider, ActorStateManager> stateManagerFactory, ActorStateProvider stateProvider, ActorServiceSettings settings)	ActorService クラスの新しいインスタンスを初期化します。

メソッドの概要

修飾子と型	メソッドと説明
List<ServiceReplicaListener>	createServiceReplicaListeners() サービス レプリカ リスナーを作成します。
CompletableFuture<?>	deleteActorAsync(ActorId actorId, CancellationToken cancellationToken) アクター サービスからアクターを削除します。 アクティブなアクターは非アクティブになり、その状態も状態プロバイダーから削除されます。 アクティブなアクターの状態は、状態プロバイダーから削除されます。 システム内の存在しないアクター ID に対してこのメソッドが呼び出された場合は、no-op になります。
CompletableFuture<PagedResult<ActorInformation>>	getActorsAsync(ContinuationToken continuationToken, CancellationToken cancellationToken) アクター サービスに対してクエリを実行して、アクターの一覧を取得します。
ActorTypeInformation	getActorTypeInformation() アクター サービスの ActorTypeInformation を取得します。
ActorServiceSettings	getSettings() アクター サービスの設定を取得します。
ActorStateProvider	getStateProvider() アクター サービスの ActorStateProvider 状態プロバイダーを表す を取得します。
void	onAbort() onAbort() をオーバーライドします。
CompletableFuture<?>	onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken) onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken) をオーバーライドします。
CompletableFuture<?>	onCloseAsync(CancellationToken cancellationToken) onCloseAsync(CancellationToken cancellationToken) をオーバーライドします。
CompletableFuture<?>	onOpenAsync(ReplicaOpenMode openMode, CancellationToken cancellationToken) このメソッドは、サービスを開く最後の手順として呼び出されます。 このレプリカの内部コンポーネントに対して Open が完了したことを通知するには、このメソッドをオーバーライドします。
CompletableFuture<?>	runAsync(CancellationToken cancellationToken) runAsync(CancellationToken cancellationToken) をオーバーライドします。

継承メンバー

StatefulServiceBase.backupAsync(BackupDescription backupDescription) StatefulServiceBase.backupAsync(BackupDescription backupDescription, Duration timeout, CancellationToken cancellationToken) StatefulServiceBase.getAddresses() StatefulServiceBase.getPartition() StatefulServiceBase.getServiceContext() StatefulServiceBase.getStateProviderReplica() StatefulServiceBase.onDataLossAsync(RestoreContext context, CancellationToken cancellationToken) StatefulServiceBase.setAddresses(Map<String, String> addresses) StatefulServiceBase.setPartition(StatefulServicePartition partition) StatefulServiceBase.StatefulServiceBase(StatefulServiceContext serviceContext, StateProviderReplica stateProviderReplica)

コンストラクターの詳細

FabricActorService

public FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo)

ActorService クラスの新しいインスタンスを初期化します。

パラメーター:

context - アクター サービスが動作しているサービス コンテキスト。

actorTypeInfo - アクターの情報を入力します。

FabricActorService

public FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo, BiFunction actorFactory)

ActorService クラスの新しいインスタンスを初期化します。

パラメーター:

context - アクター サービスが動作しているサービス コンテキスト。

actorTypeInfo - アクターの情報を入力します。

actorFactory - アクター オブジェクトを作成するファクトリ メソッド。

FabricActorService

public FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo, BiFunction actorFactory, BiFunction stateManagerFactory, ActorStateProvider stateProvider, ActorServiceSettings settings)

ActorService クラスの新しいインスタンスを初期化します。

パラメーター:

context - アクター サービスが動作しているサービス コンテキスト。

actorTypeInfo - アクターの情報を入力します。

actorFactory - アクター オブジェクトを作成するファクトリ メソッド。

stateManagerFactory - を作成 ActorStateManagerするファクトリ メソッド。

stateProvider - アクター オブジェクトの状態を格納する状態プロバイダー。

settings - アクター サービスの動作を構成するための設定。

メソッドの詳細

createServiceReplicaListeners

protected List createServiceReplicaListeners()

サービス レプリカ リスナーを作成します。

戻り値:

{"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}} のようなエンドポイント文字列ペア

deleteActorAsync

public CompletableFuture deleteActorAsync(ActorId actorId, CancellationToken cancellationToken)

アクター サービスからアクターを削除します。

アクティブなアクターは非アクティブになり、その状態も状態プロバイダーから削除されます。 アクティブなアクターの状態は、状態プロバイダーから削除されます。 システム内の存在しないアクター ID に対してこのメソッドが呼び出された場合は、no-op になります。

上書き:

FabricActorService.deleteActorAsync(ActorId actorId, CancellationToken cancellationToken)

パラメーター:

actorId -

ActorId 削除するアクターの 。

cancellationToken -

CancellationToken オブジェクトを使用して、操作のキャンセル状態を示します。

戻り値:

サーバーへの呼び出しの非同期操作を表すタスク。

getActorsAsync

public CompletableFuture> getActorsAsync(ContinuationToken continuationToken, CancellationToken cancellationToken)

アクター サービスに対してクエリを実行して、アクターの一覧を取得します。

上書き:

FabricActorService.getActorsAsync(ContinuationToken continuationToken, CancellationToken cancellationToken)

パラメーター:

continuationToken - 結果のクエリを開始する継続トークン。 継続トークンの null 値は、先頭から値を返す開始を意味します。

cancellationToken -

CancellationToken オブジェクトを使用して、操作のキャンセル状態を示します。

戻り値:

CompletableFutureサーバーへの呼び出しの非同期操作を表す 。

getActorTypeInformation

public ActorTypeInformation getActorTypeInformation()

アクター サービスの ActorTypeInformation を取得します。

戻り値:

ActorTypeInformation サービス レプリカによってホストされるアクターの 。

getSettings

public ActorServiceSettings getSettings()

アクター サービスの設定を取得します。

戻り値:

アクター サービスの設定。

getStateProvider

public ActorStateProvider getStateProvider()

アクター サービスの ActorStateProvider 状態プロバイダーを表す を取得します。

戻り値:

ActorStateProvider アクター サービスの状態プロバイダーを表します。

onAbort

protected void onAbort()

onAbort() をオーバーライドします。

onChangeRoleAsync

protected CompletableFuture onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)

onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken) をオーバーライドします。

パラメーター:

newRole - レプリカの新しいロール。

cancellationToken -

CancellationToken オブジェクトを使用して、操作のキャンセル状態を示します。

戻り値:

レプリカがプライマリになったときに実行される非同期操作を表すタスク。

onCloseAsync

protected CompletableFuture onCloseAsync(CancellationToken cancellationToken)

onCloseAsync(CancellationToken cancellationToken) をオーバーライドします。

パラメーター:

cancellationToken - キャンセル要求を監視するためのトークン。

戻り値:

レプリカが閉じられたときに実行される非同期操作を表すタスク。

onOpenAsync

protected CompletableFuture onOpenAsync(ReplicaOpenMode openMode, CancellationToken cancellationToken)

このメソッドは、サービスを開く最後の手順として呼び出されます。 このレプリカの内部コンポーネントに対して Open が完了したことを通知するには、このメソッドをオーバーライドします。

パラメーター:

openMode - このサービス レプリカに対して。

cancellationToken -

CancellationToken オブジェクトを使用して、操作のキャンセル状態を示します。

戻り値:

CompletableFuture未処理の操作を表す 。

runAsync

protected CompletableFuture runAsync(CancellationToken cancellationToken)

runAsync(CancellationToken cancellationToken) をオーバーライドします。

パラメーター:

cancellationToken -

CancellationToken オブジェクトを使用して、操作のキャンセル状態を示します。

戻り値:

レプリカがプライマリになったときにアラームを読み込む非同期操作を表すタスク。