FabricServicePartitionResolver Classe

Pacote:

microsoft.servicefabric.services.client

• java.lang.Object
• • ServicePartitionResolver
  • • microsoft.servicefabric.services.client.FabricServicePartitionResolver

public class FabricServicePartitionResolver implements ServicePartitionResolver

Implementa a classe que ajuda a determinar o ponto de extremidade de um serviço. Essa classe encapsula o método fabricClient system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(java.net.URI) e implementa um mecanismo de retirada/repetição em erros desse método.

Resumo do campo

Modificador e tipo	Campo e descrição
final Duration	defaultMaxRetryBackoffInterval Esse é o intervalo de retirada de repetição máximo padrão usado pelo método ResolveAsync de ServicePartitionResolver quando ele é invocado sem especificar explicitamente o argumento maxRetryBackoffInterval.
final Duration	defaultResolveTimeout Esse é o tempo limite padrão resolve por tentativa usado pelo método ResolveAsync de ServicePartitionResolver quando ele é invocado sem especificar explicitamente o argumento resolveTimeoutPerTry.

Resumo do Construtor

Construtor	Description
FabricServicePartitionResolver(FabricClientSettings settings, String... connectionEndpoints)	Cria uma instância de ServicePartitionResolver, usa as Configurações de FabricClient fornecidas e os connectionEndpoints para criar uma nova instância do FabricClient.
FabricServicePartitionResolver(String... connectionEndpoints)	Instancia um ServicePartitionResolver, usa os connectionEndpoints especificados para criar uma nova instância do FabricClient.
FabricServicePartitionResolver(Supplier<FabricClient> createFabricClient)	Cria uma instância de um ServicePartitionResolver, invocando o delegado especificado para instanciar o FabricClient.
FabricServicePartitionResolver(Supplier<FabricClient> createFabricClient, Supplier<FabricClient> recreateFabricClient)	Cria uma instância de um ServicePartionResolver, invocando o primeiro delegado para instanciar o FabricClient. Durante a resolução de partição, se o objeto FabricClient for descartado e o segundo delegado for fornecido, ele usará o segundo delegado para recriar o FabricClient. O segundo delegado fornece uma maneira de especificar uma maneira alternativa de criar FabricClient se FabricClient criado com os primeiros delegados forem descartados.

Resumo do método

Modificador e tipo	Método e descrição
ServicePartitionResolver	getDefault() Obtém o ServicePartitionResolver padrão
Duration	getResolveTimeout()
Duration	getRetryBackoffInterval()
CompletableFuture<ResolvedServicePartition>	resolveAsync(ResolvedServicePartition previousRsp) Resolve uma partição do serviço especificado invocando o método fabricClient system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI) com back-off/repetição em erros retriáveis. Isso usa a partição de serviço resolvida que foi obtémda por meio de uma invocação anterior do método ResolveAsync(). Essa sobrecarga de api é usada nos casos em que o cliente sabe que a partição de serviço resolvida que ela tem não é mais válida.
CompletableFuture<ResolvedServicePartition>	resolveAsync(ResolvedServicePartition previousRsp, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval) Resolve uma partição do serviço especificado com retirada/repetição em erros retriáveis. Isso usa a partição de serviço resolvida que foi obtémda por meio de uma invocação anterior do método ResolveAsync(). Essa sobrecarga de api é usada nos casos em que o cliente sabe que a partição de serviço resolvida que ela tem não é mais válida.
CompletableFuture<ResolvedServicePartition>	resolveAsync(URI serviceUri, ServicePartitionKey partitionKey) Resolve uma partição do serviço especificado invocando o método fabricClient system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI)com back-off/repetição em erros retriáveis.
CompletableFuture<ResolvedServicePartition>	resolveAsync(URI serviceUri, ServicePartitionKey partitionKey, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval) Resolve uma partição do serviço especificado invocando system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI) o método com back-off/retry em erros retriáveis.
void	setDefault(ServicePartitionResolver defaultServiceResolver) Atualizações o ServicePartitionResolver padrão
void	setResolveTimeout(Duration resolveTimeout)
void	setRetryBackoffInterval(Duration retryBackoffInterval)

Detalhes do campo

defaultMaxRetryBackoffInterval

public static final Duration defaultMaxRetryBackoffInterval= Duration.ofSeconds(5)

Esse é o intervalo de retirada de repetição máximo padrão usado pelo método ResolveAsync de ServicePartitionResolver quando ele é invocado sem especificar explicitamente o argumento maxRetryBackoffInterval.

defaultResolveTimeout

public static final Duration defaultResolveTimeout= Duration.ofSeconds(30)

Esse é o tempo limite padrão resolve por tentativa usado pelo método ResolveAsync de ServicePartitionResolver quando ele é invocado sem especificar explicitamente o argumento resolveTimeoutPerTry.

Detalhes do construtor

FabricServicePartitionResolver

public FabricServicePartitionResolver(FabricClientSettings settings, String... connectionEndpoints)

Cria uma instância de ServicePartitionResolver, usa as Configurações de FabricClient fornecidas e os connectionEndpoints para criar uma nova instância do FabricClient.

Parameters:

settings - Configurações do cliente fabric

connectionEndpoints - Matriz de pontos de extremidade de gerenciamento do cluster

FabricServicePartitionResolver

public FabricServicePartitionResolver(String... connectionEndpoints)

Instancia um ServicePartitionResolver, usa os connectionEndpoints especificados para criar uma nova instância do FabricClient.

Parameters:

connectionEndpoints - Matriz de pontos de extremidade de gerenciamento do cluster

FabricServicePartitionResolver

public FabricServicePartitionResolver(Supplier createFabricClient)

Cria uma instância de um ServicePartitionResolver, invocando o delegado especificado para instanciar o FabricClient.

Parameters:

createFabricClient - Delegar para criar um cliente de malha

FabricServicePartitionResolver

public FabricServicePartitionResolver(Supplier createFabricClient, Supplier recreateFabricClient)

Cria uma instância de um ServicePartionResolver, invocando o primeiro delegado para instanciar o FabricClient. Durante a resolução de partição, se o objeto FabricClient for descartado e o segundo delegado for fornecido, ele usará o segundo delegado para recriar o FabricClient. O segundo delegado fornece uma maneira de especificar uma maneira alternativa de criar FabricClient se FabricClient criado com os primeiros delegados forem descartados.

Parameters:

createFabricClient - Delegar para criar um cliente de malha

recreateFabricClient - Delegar para criar um cliente de malha

Detalhes do método

getDefault

public static ServicePartitionResolver getDefault()

Obtém o ServicePartitionResolver padrão

Returns:

Padrão ServicePartitionResolver

getResolveTimeout

public Duration getResolveTimeout()

getRetryBackoffInterval

public Duration getRetryBackoffInterval()

resolveAsync

public CompletableFuture resolveAsync(ResolvedServicePartition previousRsp)

Resolve uma partição do serviço especificado invocando o método fabricClient system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI) com back-off/repetição em erros retriáveis. Isso usa a partição de serviço resolvida que foi obtémda por meio de uma invocação anterior do método ResolveAsync(). Essa sobrecarga de api é usada nos casos em que o cliente sabe que a partição de serviço resolvida que ela tem não é mais válida.

Parameters:

previousRsp - Partição de serviço resolvida anteriormente

Returns:

Um CompletableFuture que representa uma operação pendente. O resultado da Tarefa é o ResolvedServicePartition objeto , que contém as informações sobre a partição de serviço resolvida, incluindo os pontos de extremidade de serviço.

resolveAsync

public CompletableFuture resolveAsync(ResolvedServicePartition previousRsp, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Resolve uma partição do serviço especificado com retirada/repetição em erros retriáveis. Isso usa a partição de serviço resolvida que foi obtémda por meio de uma invocação anterior do método ResolveAsync(). Essa sobrecarga de api é usada nos casos em que o cliente sabe que a partição de serviço resolvida que ela tem não é mais válida.

Overrides:

FabricServicePartitionResolver.resolveAsync(ResolvedServicePartition previousRsp, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Parameters:

previousRsp - Partição de serviço resolvida anteriormente

resolveTimeoutPerTry - O tempo limite passado para o método ServiceManagementClient::resolveServicePartitionAsync(URI)

maxRetryBackoffInterval - O intervalo para recuar antes de tentar novamente quando resolve partição de serviço falha com uma exceção retriável.

Returns:

Um CompletableFuture que representa uma operação pendente. O resultado da Tarefa é o ResolvedServicePartition objeto , que contém as informações sobre a partição de serviço resolvida, incluindo os pontos de extremidade de serviço.

resolveAsync

public CompletableFuture resolveAsync(URI serviceUri, ServicePartitionKey partitionKey)

Resolve uma partição do serviço especificado invocando o método fabricClient system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI)com back-off/repetição em erros retriáveis.

Parameters:

serviceUri - Uri do serviço para resolve

partitionKey - Chave que identifica a partição para resolve

Returns:

Um CompletableFuture que representa uma operação pendente. O resultado da Tarefa é o ResolvedServicePartition objeto , que contém as informações sobre a partição de serviço resolvida, incluindo os pontos de extremidade de serviço.

resolveAsync

public CompletableFuture resolveAsync(URI serviceUri, ServicePartitionKey partitionKey, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Resolve uma partição do serviço especificado invocando system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI) o método com back-off/retry em erros retriáveis.

Overrides:

FabricServicePartitionResolver.resolveAsync(URI serviceUri, ServicePartitionKey partitionKey, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Parameters:

serviceUri - Uri do serviço para resolve

partitionKey - Chave que identifica a partição para resolve

resolveTimeoutPerTry - O tempo limite passado para o system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI) método

maxRetryBackoffInterval - O intervalo a ser recuado antes de tentar novamente quando system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI)o método falha com uma exceção retriável.

Returns:

Um CompletableFuture que representa uma operação pendente. O resultado da Tarefa é o ResolvedServicePartition objeto , que contém as informações sobre a partição de serviço resolvida, incluindo os pontos de extremidade de serviço.

setDefault

public static void setDefault(ServicePartitionResolver defaultServiceResolver)

Atualizações o ServicePartitionResolver padrão

Parameters:

defaultServiceResolver - O novo valor padrão

setResolveTimeout

public void setResolveTimeout(Duration resolveTimeout)

Parameters:

resolveTimeout

setRetryBackoffInterval

public void setRetryBackoffInterval(Duration retryBackoffInterval)

Parameters:

retryBackoffInterval