ActorStateProvider Interface

Pacote:

microsoft.servicefabric.actors.runtime

public interface ActorStateProvider extends StateProviderReplica

Representa a interface que um provedor de estado de ator precisa implementar para que o runtime do ator se comunique com ele.

Resumo do método

Modificador e tipo	Método e descrição
CompletableFuture<?>	actorActivatedAsync(ActorId actorId, CancellationToken cancellationToken) Esse método é invocado como parte do processo de ativação do ator com a ID especificada.
CompletableFuture<Boolean>	containsStateAsync(ActorId actorId, String stateName, CancellationToken cancellationToken) Verifica se o provedor de estado do ator contém um estado de ator com o nome de estado especificado.
CompletableFuture<?>	deleteReminderAsync(ActorId actorId, String reminderName, CancellationToken cancellationToken) Exclui o lembrete de ator especificado se ele existir.
CompletableFuture<?>	deleteRemindersAsync(Map<ActorId, Collection<String>> reminderNames, CancellationToken cancellationToken) Exclui o conjunto de lembretes especificado
CompletableFuture<List<String>>	enumerateStateNamesAsync(ActorId actorId, CancellationToken cancellationToken) Cria uma enumerável de todos os nomes de estado associados ao ator especificado. Observações:O enumerador retornado do provedor de estado de ator é seguro para usar simultaneamente com leituras e gravações no provedor de estado. Ele representa uma exibição instantâneo consistente do provedor de estado.
CompletableFuture<PagedResult<ActorId>>	getActorsAsync(int numItemsToReturn, ContinuationToken continuationToken, CancellationToken cancellationToken) Obtém ActorIds do Provedor de Estado. Observações: O
void	initialize(ActorTypeInformation actorTypeInformation) Inicializa o provedor de estado do ator com informações de tipo do tipo de ator associado a ele.
CompletableFuture<ActorReminderCollection>	loadRemindersAsync(CancellationToken cancellationToken) Carrega todos os lembretes contidos no provedor de estado do ator.
<T> CompletableFuture<T>	loadStateAsync(ActorId actorId, String stateName, CancellationToken cancellationToken) Carrega o estado do ator associado ao nome de estado especificado.
CompletableFuture<?>	reminderCallbackCompletedAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken) Invocado quando um lembrete é acionado e termina de executar seu retorno de chamada com êxito receiveReminderAsync(String reminderName, byte[] context, Duration timeSpan, Duration period)
CompletableFuture<?>	removeActorAsync(ActorId actorId, CancellationToken cancellationToken) Remove todos os estados e lembretes existentes associados ao ator especificado atomicamente.
CompletableFuture<?>	saveReminderAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken) Salva o lembrete de ator especificado. Se um lembrete de ator com determinado nome não existir, ele adicionará o lembrete de ator, caso contrário, o lembrete de ator existente com o mesmo nome será atualizado.
CompletableFuture<?>	saveStateAsync(ActorId actorId, List<ActorStateChange> stateChanges, CancellationToken cancellationToken) Salva o conjunto especificado de alterações de estado do ator atomicamente. Observações: A coleção de alterações de estado deve conter apenas um item para um determinado nome de estado. A operação de salvamento falhará ao tentar adicionar um estado de ator que já existe ou atualizar/remover um estado de ator que não existe.

Membros herdados

StateProviderReplica.abort() StateProviderReplica.backupAsync(BiFunction<BackupInfo, CancellationToken, CompletableFuture<Boolean>> backupCallback) StateProviderReplica.backupAsync(BackupOption option, Duration timeout, CancellationToken cancellationToken, BiFunction<BackupInfo, CancellationToken, CompletableFuture<Boolean>> backupCallback) StateProviderReplica.changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken) StateProviderReplica.closeAsync(CancellationToken cancellationToken) StateProviderReplica.initialize(StatefulServiceInitializationParameters initializationParameters) StateProviderReplica.openAsync(ReplicaOpenMode openMode, StatefulServicePartition partition, CancellationToken cancellationToken) StateProviderReplica.restoreAsync(String backupFolderPath) StateProviderReplica.restoreAsync(String backupFolderPath, RestorePolicy restorePolicy, Duration timeout, CancellationToken cancellationToken) StateProviderReplica.setOnDataLossCallback(Function<CancellationToken, CompletableFuture<Boolean>> onDataLossAsync)

Detalhes do método

actorActivatedAsync

public CompletableFuture actorActivatedAsync(ActorId actorId, CancellationToken cancellationToken)

Esse método é invocado como parte do processo de ativação do ator com a ID especificada.

Parâmetros:

actorId - ID do ator que está ativado.

cancellationToken -

CancellationTokenpara indicar o status de cancelamento da operação.

Retornos:

Uma tarefa que representa o processamento de notificação de ativação de ator assíncrono.

containsStateAsync

public CompletableFuture containsStateAsync(ActorId actorId, String stateName, CancellationToken cancellationToken)

Verifica se o provedor de estado do ator contém um estado de ator com o nome de estado especificado.

Parâmetros:

actorId - ID do ator para o qual marcar existência de estado.

stateName - Nome do estado do ator a ser marcar para existência.

cancellationToken -

CancellationTokenpara indicar o status de cancelamento da operação.

Retornos:

Uma tarefa que representa a operação de marcar assíncrona. O valor do parâmetro TResult será true se o estado com o nome especificado existir de outra forma false.

deleteReminderAsync

public CompletableFuture deleteReminderAsync(ActorId actorId, String reminderName, CancellationToken cancellationToken)

Exclui o lembrete de ator especificado se ele existir.

Parâmetros:

actorId - ID do ator para o qual excluir o lembrete.

reminderName - Nome do lembrete a ser excluído.

cancellationToken -

CancellationTokenpara indicar o status de cancelamento da operação.

Retornos:

Uma tarefa que representa a operação de exclusão assíncrona.

deleteRemindersAsync

public CompletableFuture deleteRemindersAsync(Map> reminderNames, CancellationToken cancellationToken)

Exclui o conjunto de lembretes especificado

Parâmetros:

reminderNames - O conjunto de lembretes a serem excluídos

cancellationToken -

CancellationTokenpara indicar o status de cancelamento da operação.

Retornos:

Uma tarefa que representa a operação de exclusão assíncrona.

enumerateStateNamesAsync

public CompletableFuture> enumerateStateNamesAsync(ActorId actorId, CancellationToken cancellationToken)

Cria uma enumerável de todos os nomes de estado associados ao ator especificado.

Observações:O enumerador retornado do provedor de estado de ator é seguro para usar simultaneamente com leituras e gravações no provedor de estado. Ele representa uma exibição instantâneo consistente do provedor de estado.

Parâmetros:

actorId - ID do ator para o qual criar enumerável.

cancellationToken -

CancellationTokenpara indicar o status de cancelamento da operação.

Retornos:

Uma tarefa que representa a operação de enumeração assíncrona. O valor do parâmetro TResult é um enumerável de todos os nomes de estado associados ao ator especificado.

getActorsAsync

public CompletableFuture> getActorsAsync(int numItemsToReturn, ContinuationToken continuationToken, CancellationToken cancellationToken)

Obtém ActorIds do Provedor de Estado.

Observações: O

Parâmetros:

numItemsToReturn - Número de itens solicitados a serem retornados.

continuationToken - Um token de continuação do qual começar a consultar os resultados. Um valor nulo do token de continuação significa iniciar o retorno de valores que formam o início.

cancellationToken -

CancellationTokenpara indicar o status de cancelamento da operação.

Retornos:

Uma tarefa que representa a operação assíncrona da chamada ao servidor.

initialize

public void initialize(ActorTypeInformation actorTypeInformation)

Inicializa o provedor de estado do ator com informações de tipo do tipo de ator associado a ele.

Parâmetros:

actorTypeInformation - Informações de tipo da classe de ator

loadRemindersAsync

public CompletableFuture loadRemindersAsync(CancellationToken cancellationToken)

Carrega todos os lembretes contidos no provedor de estado do ator.

Parâmetros:

cancellationToken -

CancellationTokenpara indicar o status de cancelamento da operação.

Retornos:

Uma tarefa que representa a operação de carga assíncrona. O valor do parâmetro TResult é uma coleção de todos os lembretes de ator contidos no provedor de estado do ator.

loadStateAsync

public CompletableFuture loadStateAsync(ActorId actorId, String stateName, CancellationToken cancellationToken)

Carrega o estado do ator associado ao nome de estado especificado.

Parâmetros:

actorId - ID do ator para o qual carregar o estado.

stateName - Nome do estado do ator a ser carregado.

cancellationToken -

CancellationTokenpara indicar o status de cancelamento da operação.

Retornos:

Uma tarefa que representa a operação de carga assíncrona. O valor do parâmetro TResult contém o valor do estado do ator associado a determinado nome de estado.

reminderCallbackCompletedAsync

public CompletableFuture reminderCallbackCompletedAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken)

Invocado quando um lembrete é acionado e termina de executar seu retorno de chamada com êxito receiveReminderAsync(String reminderName, byte[] context, Duration timeSpan, Duration period)

Parâmetros:

actorId - ID do ator que possui lembrete

reminder - Lembrete do ator que foi concluído com êxito.

cancellationToken - O token a se monitorar para solicitações de cancelamento.

Retornos:

Uma tarefa que representa o processamento de notificação de retorno de chamada de lembrete assíncrono concluído.

removeActorAsync

public CompletableFuture removeActorAsync(ActorId actorId, CancellationToken cancellationToken)

Remove todos os estados e lembretes existentes associados ao ator especificado atomicamente.

Parâmetros:

actorId - ID do ator para o qual remover o estado.

cancellationToken -

CancellationTokenpara indicar o status de cancelamento da operação.

Retornos:

Uma tarefa que representa a operação de remoção assíncrona.

saveReminderAsync

public CompletableFuture saveReminderAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken)

Salva o lembrete de ator especificado. Se um lembrete de ator com determinado nome não existir, ele adicionará o lembrete de ator, caso contrário, o lembrete de ator existente com o mesmo nome será atualizado.

Parâmetros:

actorId - ID do ator para o qual salvar o lembrete.

reminder - Lembrete do ator a ser salvo.

cancellationToken -

CancellationTokenpara indicar o status de cancelamento da operação.

Retornos:

Uma tarefa que representa a operação de salvar assíncrona.

saveStateAsync

public CompletableFuture saveStateAsync(ActorId actorId, List stateChanges, CancellationToken cancellationToken)

Salva o conjunto especificado de alterações de estado do ator atomicamente.

Observações: A coleção de alterações de estado deve conter apenas um item para um determinado nome de estado. A operação de salvamento falhará ao tentar adicionar um estado de ator que já existe ou atualizar/remover um estado de ator que não existe.

Parâmetros:

actorId - ID do ator para o qual salvar as alterações de estado.

stateChanges - Coleção de alterações de estado a serem salvas.

cancellationToken -

CancellationTokenpara indicar o status de cancelamento da operação.

Retornos:

Uma tarefa que representa a operação de salvar assíncrona.