Compartilhar via


StateProviderReplica Interface

public interface StateProviderReplica

Define métodos que um provedor de estado confiável réplica deve implementar para que o Service Fabric interaja com ele.

Resumo do método

Modificador e tipo Método e descrição
void abort()

Anule com força a réplica do provedor de estado.

Observações:Isso geralmente ocorre quando uma falha permanente é detectada no nó ou quando o Service Fabric não pode gerenciar de forma confiável o ciclo de vida do réplica devido a falhas internas.

CompletableFuture<?> backupAsync(BackupOption option, Duration timeout, CancellationToken cancellationToken, BiFunction<BackupInfo, CancellationToken, CompletableFuture<Boolean>> backupCallback)

Executa um backup completo de todo o estado confiável gerenciado por este ReliableStateManager.

Observações: Um backup COMPLETO será executado com um tempo limite de uma hora. Booliano retornado pelo backupCallback indica se o serviço foi capaz de mover com êxito a pasta de backup para um local externo. Se false for retornado, BackupAsync lançará UnsupportedOperationException com a mensagem relevante indicando que backupCallback retornou false. Além disso, o backup será marcado como malsucedido.

CompletableFuture<?> backupAsync(BiFunction<BackupInfo, CancellationToken, CompletableFuture<Boolean>> backupCallback)

Executa um backup completo de todo o estado confiável gerenciado por este ReliableStateManager.

Observações: Um backup COMPLETO será executado com um tempo limite de uma hora. Booliano retornado pelo backupCallback indica se o serviço foi capaz de mover com êxito a pasta de backup para um local externo. Se false for retornado, BackupAsync lançará UnsupportedOperationException com a mensagem relevante indicando que backupCallback retornou false. Além disso, o backup será marcado como malsucedido.

CompletableFuture<?> changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)

Notifique o provedor de estado réplica que sua função está sendo alterada, por exemplo, para Primária ou Secundária.

CompletableFuture<?> closeAsync(CancellationToken cancellationToken)

Feche normalmente o provedor de estado réplica.

Observações:Isso geralmente ocorre quando o código do réplica está sendo atualizado, o réplica está sendo movido devido ao balanceamento de carga ou uma falha transitória é detectada.

void initialize(StatefulServiceInitializationParameters initializationParameters)

Inicialize o provedor de estado réplica usando as informações de inicialização do serviço.

Observações:Nenhum processamento complexo deve ser feito durante Inicializar. A inicialização cara ou de execução longa deve ser feita no OpenAsync.

CompletableFuture<Replicator> openAsync(ReplicaOpenMode openMode, StatefulServicePartition partition, CancellationToken cancellationToken)

Abra o provedor de estado réplica para uso.

Observações:As tarefas de inicialização do provedor de estado estendido podem ser iniciadas no momento.

CompletableFuture<?> restoreAsync(String backupFolderPath)

Restaurar um backup feito.

Observações:Uma restauração segura será executada, o que significa que a restauração só será concluída se os dados a serem restaurados estiverem à frente do estado do réplica atual.

CompletableFuture<?> restoreAsync(String backupFolderPath, RestorePolicy restorePolicy, Duration timeout, CancellationToken cancellationToken)

Restaurar um backup feito

void setOnDataLossCallback(Function<CancellationToken, CompletableFuture<Boolean>> onDataLossAsync)

Função chamada durante suspeita de perda de dados

Detalhes do método

abort

public void abort()

Anule com força a réplica do provedor de estado.

Observações:Isso geralmente ocorre quando uma falha permanente é detectada no nó ou quando o Service Fabric não pode gerenciar de forma confiável o ciclo de vida do réplica devido a falhas internas.

backupAsync

public CompletableFuture backupAsync(BackupOption option, Duration timeout, CancellationToken cancellationToken, BiFunction> backupCallback)

Executa um backup completo de todo o estado confiável gerenciado por este ReliableStateManager.

Observações: Um backup COMPLETO será executado com um tempo limite de uma hora. Booliano retornado pelo backupCallback indica se o serviço foi capaz de mover com êxito a pasta de backup para um local externo. Se false for retornado, BackupAsync lançará UnsupportedOperationException com a mensagem relevante indicando que backupCallback retornou false. Além disso, o backup será marcado como malsucedido.

Parameters:

option - O tipo de backup a ser executado.
timeout - O tempo limite para esta operação.
cancellationToken - O token a se monitorar para solicitações de cancelamento.
backupCallback - Retorno de chamada a ser chamado quando a pasta de backup tiver sido criada localmente e estiver pronta para ser movida para fora do nó

Returns:

Tarefa que representa a operação de backup assíncrona.

backupAsync

public CompletableFuture backupAsync(BiFunction> backupCallback)

Executa um backup completo de todo o estado confiável gerenciado por este ReliableStateManager.

Observações: Um backup COMPLETO será executado com um tempo limite de uma hora. Booliano retornado pelo backupCallback indica se o serviço foi capaz de mover com êxito a pasta de backup para um local externo. Se false for retornado, BackupAsync lançará UnsupportedOperationException com a mensagem relevante indicando que backupCallback retornou false. Além disso, o backup será marcado como malsucedido.

Parameters:

backupCallback - Retorno de chamada a ser chamado quando a pasta de backup tiver sido criada localmente e estiver pronta para ser movida para fora do nó

Returns:

Tarefa que representa a operação de backup assíncrona.

changeRoleAsync

public CompletableFuture changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)

Notifique o provedor de estado réplica que sua função está sendo alterada, por exemplo, para Primária ou Secundária.

Parameters:

newRole - O novo réplica função, como primário ou secundário.
cancellationToken -

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

Returns:

Tarefa que representa a operação de função de alteração assíncrona.

closeAsync

public CompletableFuture closeAsync(CancellationToken cancellationToken)

Feche normalmente o provedor de estado réplica.

Observações:Isso geralmente ocorre quando o código do réplica está sendo atualizado, o réplica está sendo movido devido ao balanceamento de carga ou uma falha transitória é detectada.

Parameters:

cancellationToken -

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

Returns:

Tarefa que representa a operação de fechamento assíncrona.

initialize

public void initialize(StatefulServiceInitializationParameters initializationParameters)

Inicialize o provedor de estado réplica usando as informações de inicialização do serviço.

Observações:Nenhum processamento complexo deve ser feito durante Inicializar. A inicialização cara ou de execução longa deve ser feita no OpenAsync.

Parameters:

initializationParameters - Informações de inicialização de serviço, como nome do serviço, ID de partição, ID de réplica e informações do pacote de código.

openAsync

public CompletableFuture openAsync(ReplicaOpenMode openMode, StatefulServicePartition partition, CancellationToken cancellationToken)

Abra o provedor de estado réplica para uso.

Observações:As tarefas de inicialização do provedor de estado estendido podem ser iniciadas no momento.

Parameters:

openMode - Indica se este é um réplica novo ou existente.
partition - A partição à qual este réplica pertence.
cancellationToken -

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

Returns:

Tarefa que representa a operação de abertura assíncrona. O resultado contém o replicador responsável por replicar o estado entre outras réplicas de provedor de estado na partição.

restoreAsync

public CompletableFuture restoreAsync(String backupFolderPath)

Restaurar um backup feito.

Observações:Uma restauração segura será executada, o que significa que a restauração só será concluída se os dados a serem restaurados estiverem à frente do estado do réplica atual.

Parameters:

backupFolderPath - O diretório do qual o réplica deve ser restaurado. Esse parâmetro não pode ser nulo, vazio ou conter apenas espaço em branco. Caminhos UNC também podem ser fornecidos.

Returns:

Tarefa que representa a operação de restauração assíncrona.

restoreAsync

public CompletableFuture restoreAsync(String backupFolderPath, RestorePolicy restorePolicy, Duration timeout, CancellationToken cancellationToken)

Restaurar um backup feito

Parameters:

backupFolderPath - O diretório do qual o réplica deve ser restaurado. Esse parâmetro não pode ser nulo, vazio ou conter apenas espaço em branco. Caminhos UNC também podem ser fornecidos.
restorePolicy - A política de restauração.
timeout - O tempo limite para esta operação.
cancellationToken - O token a se monitorar para solicitações de cancelamento.

Returns:

Tarefa que representa a operação de restauração assíncrona.

setOnDataLossCallback

public void setOnDataLossCallback(Function> onDataLossAsync)

Função chamada durante suspeita de perda de dados

Parameters:

onDataLossAsync - TODO. Função chamada como parte do processamento suspeito de perda de dados. A função usa CancellationToken e retorna um CompleteableFuture que representa o processamento assíncrono do evento. Retornando true, indica que o estado do réplica foi restaurado. False indica que o estado do réplica não foi alterado.

Aplica-se a