ReplicatorSettings Classe

Pacote:

system.fabric

• java.lang.Object
• • system.fabric.ReplicatorSettings

public class ReplicatorSettings

Permite que um réplica com estado configure o FabricReplicator ao criá-locreateReplicator(StateProvider stateProvider, ReplicatorSettings replicatorSettings)

Resumo do Construtor

Construtor	Description
ReplicatorSettings()

Resumo do método

Modificador e tipo	Método e descrição
Duration	getBatchAcknowledgementInterval() Obtém a quantidade de tempo que o replicador aguarda após receber uma operação antes de enviar uma confirmação de volta. Observações:Outras operações recebidas e confirmadas durante esse período de tempo terão suas confirmações enviadas novamente em uma única mensagem. Aumentar o valor diminui a system.fabric.ReplicatorSettings#batchAcknowledgementInterval latência de operações de replicação individuais, mas aumenta a taxa de transferência do replicador. O valor padrão é 0,05 Segundos (50 milissegundos)
long	getInitialCopyQueueSize() Obtém o tamanho inicial da fila de operação de cópia dentro FabricReplicatorde , que contém cópias Operationainda não bombeadas e processadas pelo serviço. Observações:O valor padrão é 64. Observe que os valores para esse parâmetro devem ser uma potência de 2.
long	getInitialPrimaryReplicationQueueSize() Define o tamanho inicial da fila de operações de replicação primária dentro FabricReplicatorde , que contém a replicação Operations.A unidade aqui é o número de operações na fila. Observações:Essa configuração é específica para o Replicador quando a função do serviço é Primária O valor padrão é 64. Observe que os valores para esse parâmetro devem ser uma potência de 2.
long	getInitialReplicationQueueSize() Obtém o tamanho inicial do tamanho da fila de replicação.
long	getInitialSecondaryReplicationQueueSize() Define o tamanho inicial da fila de operações de replicação secundária dentro FabricReplicatorde , que contém s de replicação Operation Observações:Essa configuração é específica para o Replicador quando a função do serviço é Secundária/Ociosa O valor padrão é 64. Observe que os valores para esse parâmetro devem ser uma potência de 2.
long	getMaxCopyQueueSize() Obtém o tamanho máximo da fila de operação de cópia dentro FabricReplicatorde , que contém cópias Operationainda não bombeadas e processadas pelo serviço. Observações:Se esse tamanho de fila for atingido no secundário, as operações serão armazenadas em buffer na fila de cópia do Primário. Se essa fila também for preenchida, o Primário começará a ver system.fabric.FabricErrorCode#ReplicationQueueFull exceções. O valor padrão é 1024
long	getMaxPrimaryReplicationQueueMemorySize() Define o tamanho máximo da fila de operação de replicação primária dentro FabricReplicatorde , que contém s de replicação Operation Observações:Essa configuração é específica para o Replicador quando a função do serviço é Primária. O valor padrão é 0. Isso implica que não há limite de memória
long	getMaxPrimaryReplicationQueueSize() Define o tamanho máximo da fila de operação de replicação primária dentro FabricReplicatorde , que contém s de replicação Operation Observações:Se esse tamanho de fila for atingido, o Primário começará a ver system.fabric.FabricErrorCode#ReplicationQueueFull exceções. O valor padrão é 1024 Observe que os valores para esse parâmetro devem ser uma potência de 2. Essa configuração é específica para o Replicador quando a função do serviço é Primária
Long	getMaxReplicationMessageSize() Obtém o tamanho máximo de uma mensagem que pode ser transmitida por meio do replicador. Isso inclui mensagens de replicação, copiar mensagens e copiar mensagens de contexto. A unidade de representação é bytes. Observações:O valor padrão é 50 MB
long	getMaxReplicationQueueMemorySize() Obtém o tamanho máximo para a memória da fila de replicação. Observações:O valor padrão é 0. Isso implica que não há limite de memória
long	getMaxReplicationQueueSize() Obtém o tamanho máximo da fila de replicação.
long	getMaxSecondaryReplicationQueueMemorySize() Define o tamanho máximo da fila de operações de replicação secundária dentro FabricReplicatorde , que contém replicações Operations. Observações:Essa configuração é específica para o Replicador quando a função do serviço é Secundária/Ociosa. O valor padrão é 0. Isso implica que não há limite de memória
long	getMaxSecondaryReplicationQueueSize() Define o tamanho máximo da fila de operações de replicação secundária dentro FabricReplicatorde , que contém replicações Operations Observações:Se esse tamanho de fila for atingido, as operações serão armazenadas em buffer na fila de replicação do Primário. Se essa fila também for preenchida, o Primário começará a ver system.fabric.FabricErrorCode#ReplicationQueueFull exceções. O valor padrão é 2048.Observe que os valores para esse parâmetro devem ser uma potência de 2. Essa configuração é específica para o Replicador quando a função do serviço é Secundária/Ociosa
Duration	getPrimaryWaitForPendingQuorumsTimeout() Define por quanto tempo o replicador primário aguarda o recebimento de um quorum de confirmações para quaisquer operações de replicação pendentes antes de processar uma solicitação de reconfiguração, o que pode resultar em 'cancelar' as operações de replicação pendentes. Observações:O valor padrão é 0. Isso implica que as reconfigurações não são aguardadas para receber quorum nas operações de replicação pendentes. Isso ajuda a concluir reconfigurações mais cedo. Observe que valores maiores para esse parâmetro podem resultar potencialmente em reconfigurações mais lentas, implicando durações mais longas para failover de um primário.
String	getReplicatorAddress() Configura o endereço que esse replicador usará ao se comunicar com outros Replicadores. Observações:A cadeia de caracteres é formatada como "hostname:port", em que o nome do host pode ser FQDN ou endereço IP. O valor padrão é localhost:0
Duration	getRetryInterval() Define quanto tempo a FabricReplicator espera depois de transmitir uma mensagem do primário para o secundário para que o secundário reconheça que recebeu a mensagem. Observações:Receber uma mensagem não necessariamente indica que a mensagem foi processada. Se esse temporizador for excedido, a mensagem será retransmitida. O valor padrão é de 5 segundos.
SecurityCredentials	getSecurityCredentials() Permite que o serviço defina credenciais de segurança para proteger o tráfego entre replicadores.
boolean	isRequireServiceAck() Impede a confirmação otimista de operações em serviços não persistentes, exigindo que o serviço chame acknowledge() antes de bombear a próxima operação. Observações:Serviços não persistentes que exigem confirmação explícita podem definir essa propriedade como True para evitar a confirmação otimista das operações pelo Replicador. Essa configuração não tem efeito para serviços persistentes. O valor padrão é false.
boolean	isSecondaryClearAcknowledgedOperations() Normalmente, as operações no replicador secundário são mantidas na fila para serem capazes de capturar réplicas se elas forem promovidas para uma primária. Com esse sinalizador habilitado, o replicador secundário libera a operação assim que é confirmada pelo serviço de usuário. Observações:O valor padrão é false
boolean	isUseStreamFaultsAndEndOfStreamOperationAck() Especifica se o replicador usa falhas de fluxo. Observações:O valor padrão é false
ReplicatorSettings	loadFrom(FabricCodePackageActivationContext codePackageActivationContext, String configPackageName, String sectionName)
void	setBatchAcknowledgementInterval(Duration batchAcknowledgementInterval) Define a quantidade de tempo que o replicador aguarda após receber uma operação antes de enviar uma confirmação de volta. Observações:Outras operações recebidas e confirmadas durante esse período de tempo terão suas confirmações enviadas novamente em uma única mensagem. Aumentar o valor diminui a system.fabric.ReplicatorSettings#batchAcknowledgementInterval latência de operações de replicação individuais, mas aumenta a taxa de transferência do replicador. O valor padrão é 0,05 Segundos (50 milissegundos)
void	setInitialCopyQueueSize(long initialCopyQueueSize) Obtém ou define o tamanho inicial da fila de operação de cópia dentro FabricReplicatorde , que contém cópias Operationainda não bombeadas e processadas pelo serviço. Observações:O valor padrão é 64. Observe que os valores para esse parâmetro devem ser uma potência de 2.
void	setInitialPrimaryReplicationQueueSize(long initialPrimaryReplicationQueueSize) Define o tamanho inicial da fila de operações de replicação primária dentro FabricReplicatorde , que contém a replicação Operations.A unidade aqui é o número de operações na fila. Observações:Essa configuração é específica para o Replicador quando a função do serviço é Primária O valor padrão é 64. Observe que os valores para esse parâmetro devem ser uma potência de 2.
void	setInitialReplicationQueueSize(long initialReplicationQueueSize) Define o tamanho inicial do tamanho da fila de replicação.
void	setInitialSecondaryReplicationQueueSize(long initialSecondaryReplicationQueueSize) Define o tamanho inicial da fila de operações de replicação secundária dentro FabricReplicatorde , que contém s de replicação Operation Observações:Essa configuração é específica para o Replicador quando a função do serviço é Secundária/Ociosa O valor padrão é 64. Observe que os valores para esse parâmetro devem ser uma potência de 2.
void	setMaxCopyQueueSize(long maxCopyQueueSize) Define o tamanho máximo da fila de operação de cópia dentro FabricReplicatorde , que contém cópias Operationainda não bombeadas e processadas pelo serviço. Observações:Se esse tamanho de fila for atingido no secundário, as operações serão armazenadas em buffer na fila de cópia do Primário. Se essa fila também for preenchida, o Primário começará a ver system.fabric.FabricErrorCode#ReplicationQueueFull exceções. O valor padrão é 1024
void	setMaxPrimaryReplicationQueueMemorySize(long maxPrimaryReplicationQueueMemorySize) Define o tamanho máximo da fila de operação de replicação primária dentro FabricReplicatorde , que contém s de replicação Operation Observações:Essa configuração é específica para o Replicador quando a função do serviço é Primária. O valor padrão é 0. Isso implica que não há limite de memória
void	setMaxPrimaryReplicationQueueSize(long maxPrimaryReplicationQueueSize) Define o tamanho máximo da fila de operação de replicação primária dentro FabricReplicatorde , que contém s de replicação Operation Observações:Se esse tamanho de fila for atingido, o Primário começará a ver system.fabric.FabricErrorCode#ReplicationQueueFull exceções. O valor padrão é 1024 Observe que os valores para esse parâmetro devem ser uma potência de 2. Essa configuração é específica para o Replicador quando a função do serviço é Primária
void	setMaxReplicationMessageSize(long maxReplicationMessageSize) Define o tamanho máximo de uma mensagem que pode ser transmitida por meio do replicador. Isso inclui mensagens de replicação, copiar mensagens e copiar mensagens de contexto. A unidade de representação é bytes. Observações:O valor padrão é 50 MB
void	setMaxReplicationQueueMemorySize(long maxReplicationQueueMemorySize) Define o tamanho máximo para a memória da fila de replicação. Observações:O valor padrão é 0. Isso implica que não há limite de memória
void	setMaxReplicationQueueSize(long maxReplicationQueueSize) Define o tamanho máximo da fila de replicação.
void	setMaxSecondaryReplicationQueueMemorySize(long maxSecondaryReplicationQueueMemorySize) Define o tamanho máximo da fila de operações de replicação secundária dentro FabricReplicatorde , que contém replicações Operations. Observações:Essa configuração é específica para o Replicador quando a função do serviço é Secundária/Ociosa. O valor padrão é 0. Isso implica que não há limite de memória
void	setMaxSecondaryReplicationQueueSize(long maxSecondaryReplicationQueueSize) Define o tamanho máximo da fila de operações de replicação secundária dentro FabricReplicatorde , que contém replicações Operations Observações:Se esse tamanho de fila for atingido, as operações serão armazenadas em buffer na fila de replicação do Primário. Se essa fila também for preenchida, o Primário começará a ver system.fabric.FabricErrorCode#ReplicationQueueFull exceções. O valor padrão é 2048.Observe que os valores para esse parâmetro devem ser uma potência de 2. Essa configuração é específica para o Replicador quando a função do serviço é Secundária/Ociosa
void	setPrimaryWaitForPendingQuorumsTimeout(Duration primaryWaitForPendingQuorumsTimeout) Define por quanto tempo o replicador primário aguarda o recebimento de um quorum de confirmações para quaisquer operações de replicação pendentes antes de processar uma solicitação de reconfiguração, o que pode resultar em 'cancelamento' das operações de replicação pendentes. Observações:O valor padrão é 0. Isso implica que as reconfigurações não são aguardadas para receber quorum nas operações de replicação pendentes. Isso ajuda a concluir reconfigurações mais cedo. Observe que valores maiores para esse parâmetro podem resultar potencialmente em reconfigurações mais lentas, implicando durações mais longas para failover de um primário.
void	setReplicatorAddress(String replicatorAddress) Configura o endereço que esse replicador usará ao se comunicar com outros Replicadores. Observações:A cadeia de caracteres é formatada como "hostname:port", em que o nome do host pode ser FQDN ou endereço IP. O valor padrão é localhost:0
void	setRequireServiceAck(boolean requireServiceAck) Impede a confirmação otimista de operações em serviços não persistentes, exigindo que o serviço chame acknowledge() antes de bombear a próxima operação. Observações:Serviços não persistentes que exigem confirmação explícita podem definir essa propriedade como True para evitar a confirmação otimista das operações pelo Replicador. Essa configuração não tem efeito para serviços persistentes. O valor padrão é false.
void	setRetryInterval(Duration retryInterval) Define quanto tempo a FabricReplicator espera depois de transmitir uma mensagem do primário para o secundário para que o secundário reconheça que recebeu a mensagem. Observações:Receber uma mensagem não necessariamente indica que a mensagem foi processada. Se esse temporizador for excedido, a mensagem será retransmitida. O valor padrão é de 5 segundos.
void	setSecondaryClearAcknowledgedOperations(boolean secondaryClearAcknowledgedOperations) Normalmente, as operações no replicador secundário são mantidas na fila para poder capturar réplicas se elas forem promovidas a um primário. Com esse sinalizador habilitado, o replicador secundário libera a operação assim que ela é reconhecida pelo serviço de usuário. Observações:O valor padrão é false
void	setSecurityCredentials(SecurityCredentials securityCredentials) Permite que o serviço defina credenciais de segurança para proteger o tráfego entre replicadores.
void	setUseStreamFaultsAndEndOfStreamOperationAck(boolean useStreamFaultsAndEndOfStreamOperationAck) Especifica se o replicador usa falhas de fluxo. Observações:O valor padrão é false
long	toNative(PinCollection pinCollection)
String	toString()

Detalhes do construtor

ReplicatorSettings

public ReplicatorSettings()

Detalhes do método

getBatchAcknowledgementInterval

public Duration getBatchAcknowledgementInterval()

Obtém a quantidade de tempo que o replicador aguarda após receber uma operação antes de enviar uma confirmação de volta.

Observações:Outras operações recebidas e confirmadas durante esse período de tempo terão suas confirmações enviadas novamente em uma única mensagem. Aumentar o valor diminui a system.fabric.ReplicatorSettings#batchAcknowledgementInterval latência de operações de replicação individuais, mas aumenta a taxa de transferência do replicador. O valor padrão é 0,05 Segundos (50 milissegundos)

Retornos:

A quantidade de tempo que o replicador aguarda após receber uma operação antes de enviar uma confirmação de volta.

getInitialCopyQueueSize

public long getInitialCopyQueueSize()

Obtém o tamanho inicial da fila de operação de cópia dentro FabricReplicatorde , que contém cópias Operationainda não bombeadas e processadas pelo serviço.

Observações:O valor padrão é 64. Observe que os valores para esse parâmetro devem ser uma potência de 2.

Retornos:

O tamanho inicial da fila de operação de cópia dentro FabricReplicatorde , que contém cópias Operationainda não bombeadas e processadas pelo serviço.

getInitialPrimaryReplicationQueueSize

public long getInitialPrimaryReplicationQueueSize()

Define o tamanho inicial da fila de operações de replicação primária dentro FabricReplicatorde , que contém a replicação Operations.A unidade aqui é o número de operações na fila.

Observações:Essa configuração é específica para o Replicador quando a função do serviço é Primária O valor padrão é 64. Observe que os valores para esse parâmetro devem ser uma potência de 2.

Retornos:

O tamanho inicial da fila de operações de replicação primária dentro FabricReplicator

getInitialReplicationQueueSize

public long getInitialReplicationQueueSize()

Obtém o tamanho inicial do tamanho da fila de replicação.

Retornos:

O tamanho inicial do tamanho da fila de replicação.

getInitialSecondaryReplicationQueueSize

public long getInitialSecondaryReplicationQueueSize()

Define o tamanho inicial da fila de operações de replicação secundária dentro FabricReplicatorde , que contém s de replicação Operation

Observações:Essa configuração é específica para o Replicador quando a função do serviço é Secundária/Ociosa O valor padrão é 64. Observe que os valores para esse parâmetro devem ser uma potência de 2.

Retornos:

O tamanho inicial da fila de operação de replicação secundária dentro FabricReplicatorde , que contém replicação Operationainda não bombeada e processada pelo serviço. A unidade aqui é o número de operações na fila

getMaxCopyQueueSize

public long getMaxCopyQueueSize()

Obtém o tamanho máximo da fila de operação de cópia dentro FabricReplicatorde , que contém cópias Operationainda não bombeadas e processadas pelo serviço.

Observações:Se esse tamanho de fila for atingido no secundário, as operações serão armazenadas em buffer na fila de cópia do Primário. Se essa fila também for preenchida, o Primário começará a ver system.fabric.FabricErrorCode#ReplicationQueueFull exceções. O valor padrão é 1024

Retornos:

O tamanho máximo da fila de operação de cópia dentro FabricReplicatorde , que contém cópias Operationainda não bombeadas e processadas pelo serviço.

getMaxPrimaryReplicationQueueMemorySize

public long getMaxPrimaryReplicationQueueMemorySize()

Define o tamanho máximo da fila de operação de replicação primária dentro FabricReplicatorde , que contém s de replicação Operation

Observações:Essa configuração é específica para o Replicador quando a função do serviço é Primária. O valor padrão é 0. Isso implica que não há limite de memória

Retornos:

. Retorna o tamanho máximo da fila de operação de replicação primária dentro FabricReplicatorde , que contém replicação Operations A unidade aqui é o consumo de memória virtual da fila . Retorna long.

getMaxPrimaryReplicationQueueSize

public long getMaxPrimaryReplicationQueueSize()

Define o tamanho máximo da fila de operação de replicação primária dentro FabricReplicatorde , que contém s de replicação Operation

Observações:Se esse tamanho de fila for atingido, o Primário começará a ver system.fabric.FabricErrorCode#ReplicationQueueFull exceções. O valor padrão é 1024 Observe que os valores para esse parâmetro devem ser uma potência de 2. Essa configuração é específica para o Replicador quando a função do serviço é Primária

Retornos:

O tamanho máximo da fila de operações de replicação primária dentro FabricReplicatorde , que contém replicações Operations. A unidade aqui é o número de operações na fila.

getMaxReplicationMessageSize

public Long getMaxReplicationMessageSize()

Obtém o tamanho máximo de uma mensagem que pode ser transmitida por meio do replicador. Isso inclui mensagens de replicação, copiar mensagens e copiar mensagens de contexto. A unidade de representação é bytes.

Observações:O valor padrão é 50 MB

Retornos:

O tamanho máximo de uma mensagem que pode ser transmitida por meio do replicador.

getMaxReplicationQueueMemorySize

public long getMaxReplicationQueueMemorySize()

Obtém o tamanho máximo para a memória da fila de replicação.

Observações:O valor padrão é 0. Isso implica que não há limite de memória

Retornos:

O tamanho máximo da memória da fila de replicação.

getMaxReplicationQueueSize

public long getMaxReplicationQueueSize()

Obtém o tamanho máximo da fila de replicação.

Retornos:

o tamanho máximo da fila de replicação.

getMaxSecondaryReplicationQueueMemorySize

public long getMaxSecondaryReplicationQueueMemorySize()

Define o tamanho máximo da fila de operações de replicação secundária dentro FabricReplicatorde , que contém replicações Operations.

Observações:Essa configuração é específica para o Replicador quando a função do serviço é Secundária/Ociosa. O valor padrão é 0. Isso implica que não há limite de memória

Retornos:

Retorna o tamanho máximo da fila de operação de replicação secundária dentro FabricReplicatorde , que contém s de replicação Operation. A unidade aqui é o consumo de memória virtual da fila.

getMaxSecondaryReplicationQueueSize

public long getMaxSecondaryReplicationQueueSize()

Define o tamanho máximo da fila de operações de replicação secundária dentro FabricReplicatorde , que contém replicações Operations

Observações:Se esse tamanho de fila for atingido, as operações serão armazenadas em buffer na fila de replicação do Primário. Se essa fila também for preenchida, o Primário começará a ver system.fabric.FabricErrorCode#ReplicationQueueFull exceções. O valor padrão é 2048.Observe que os valores para esse parâmetro devem ser uma potência de 2. Essa configuração é específica para o Replicador quando a função do serviço é Secundária/Ociosa

Retornos:

O tamanho máximo da fila de operações de replicação secundária dentro FabricReplicatorde , que contém replicação Operationainda não bombeada e processada pelo serviço. A unidade aqui é o número de operações na fila

getPrimaryWaitForPendingQuorumsTimeout

public Duration getPrimaryWaitForPendingQuorumsTimeout()

Define por quanto tempo o replicador primário aguarda o recebimento de um quorum de confirmações para quaisquer operações de replicação pendentes antes de processar uma solicitação de reconfiguração, o que pode resultar em 'cancelar' as operações de replicação pendentes.

Observações:O valor padrão é 0. Isso implica que as reconfigurações não são aguardadas para receber quorum nas operações de replicação pendentes. Isso ajuda a concluir reconfigurações mais cedo. Observe que valores maiores para esse parâmetro podem resultar potencialmente em reconfigurações mais lentas, implicando durações mais longas para failover de um primário.

Retornos:

Quantidade de tempo que o replicador primário aguarda o recebimento de um quorum de confirmações para quaisquer operações de replicação pendentes quando há uma solicitação para que o replicador primário processe uma reconfiguração java.time.Duration.

getReplicatorAddress

public String getReplicatorAddress()

Configura o endereço que esse replicador usará ao se comunicar com outros Replicadores.

Observações:A cadeia de caracteres é formatada como "hostname:port", em que o nome do host pode ser FQDN ou endereço IP. O valor padrão é localhost:0

Retornos:

O endereço que esse replicador usará ao se comunicar com outros Replicadores.

getRetryInterval

public Duration getRetryInterval()

Define quanto tempo a FabricReplicator espera depois de transmitir uma mensagem do primário para o secundário para que o secundário reconheça que recebeu a mensagem.

Observações:Receber uma mensagem não necessariamente indica que a mensagem foi processada. Se esse temporizador for excedido, a mensagem será retransmitida. O valor padrão é de 5 segundos.

Retornos:

O tempo necessário para as FabricReplicator esperas depois que ele transmite uma mensagem do primário para o secundário para que o secundário reconheça que recebeu a mensagem.

getSecurityCredentials

public SecurityCredentials getSecurityCredentials()

Permite que o serviço defina credenciais de segurança para proteger o tráfego entre replicadores.

Retornos:

O serviço para definir credenciais de segurança para proteger o tráfego entre replicadores.

isRequireServiceAck

public boolean isRequireServiceAck()

Impede a confirmação otimista de operações em serviços não persistentes, exigindo que o serviço chame acknowledge() antes de bombear a próxima operação.

Observações:Serviços não persistentes que exigem confirmação explícita podem definir essa propriedade como True para evitar a confirmação otimista das operações pelo Replicador. Essa configuração não tem efeito para serviços persistentes. O valor padrão é false.

Retornos:

true se a confirmação otimista de operações em serviços não persistentes;caso contrário, false.

isSecondaryClearAcknowledgedOperations

public boolean isSecondaryClearAcknowledgedOperations()

Normalmente, as operações no replicador secundário são mantidas na fila para serem capazes de capturar réplicas se elas forem promovidas para uma primária. Com esse sinalizador habilitado, o replicador secundário libera a operação assim que é confirmada pelo serviço de usuário.

Observações:O valor padrão é false

Retornos:

true se o replicador secundário liberar a operação assim que ela for confirmada pelo serviço de usuário; caso contrário, false.

isUseStreamFaultsAndEndOfStreamOperationAck

public boolean isUseStreamFaultsAndEndOfStreamOperationAck()

Especifica se o replicador usa falhas de fluxo.

Observações:O valor padrão é false

Retornos:

true se o replicador usar falhas de fluxo; caso contrário, false.

loadFrom

public static ReplicatorSettings loadFrom(FabricCodePackageActivationContext codePackageActivationContext, String configPackageName, String sectionName)

Parâmetros:

codePackageActivationContext

configPackageName

sectionName

setBatchAcknowledgementInterval

public void setBatchAcknowledgementInterval(Duration batchAcknowledgementInterval)

Define a quantidade de tempo que o replicador aguarda após receber uma operação antes de enviar uma confirmação de volta.

Observações:Outras operações recebidas e confirmadas durante esse período de tempo terão suas confirmações enviadas novamente em uma única mensagem. Aumentar o valor diminui a system.fabric.ReplicatorSettings#batchAcknowledgementInterval latência de operações de replicação individuais, mas aumenta a taxa de transferência do replicador. O valor padrão é 0,05 Segundos (50 milissegundos)

Parâmetros:

batchAcknowledgementInterval - A quantidade de tempo que o replicador aguarda após receber uma operação antes de enviar uma confirmação de volta.

setInitialCopyQueueSize

public void setInitialCopyQueueSize(long initialCopyQueueSize)

Obtém ou define o tamanho inicial da fila de operação de cópia dentro FabricReplicatorde , que contém cópias Operationainda não bombeadas e processadas pelo serviço.

Observações:O valor padrão é 64. Observe que os valores para esse parâmetro devem ser uma potência de 2.

Parâmetros:

initialCopyQueueSize - O tamanho inicial da fila de operação de cópia dentro FabricReplicatorde , que contém cópias Operationainda não bombeadas e processadas pelo serviço.

setInitialPrimaryReplicationQueueSize

public void setInitialPrimaryReplicationQueueSize(long initialPrimaryReplicationQueueSize)

Define o tamanho inicial da fila de operações de replicação primária dentro FabricReplicatorde , que contém a replicação Operations.A unidade aqui é o número de operações na fila.

Observações:Essa configuração é específica para o Replicador quando a função do serviço é Primária O valor padrão é 64. Observe que os valores para esse parâmetro devem ser uma potência de 2.

Parâmetros:

initialPrimaryReplicationQueueSize - O tamanho inicial da fila de operações de replicação primária dentro FabricReplicator

setInitialReplicationQueueSize

public void setInitialReplicationQueueSize(long initialReplicationQueueSize)

Define o tamanho inicial do tamanho da fila de replicação.

Parâmetros:

initialReplicationQueueSize - O tamanho inicial do tamanho da fila de replicação.

setInitialSecondaryReplicationQueueSize

public void setInitialSecondaryReplicationQueueSize(long initialSecondaryReplicationQueueSize)

Define o tamanho inicial da fila de operações de replicação secundária dentro FabricReplicatorde , que contém s de replicação Operation

Observações:Essa configuração é específica para o Replicador quando a função do serviço é Secundária/Ociosa O valor padrão é 64. Observe que os valores para esse parâmetro devem ser uma potência de 2.

Parâmetros:

initialSecondaryReplicationQueueSize - O tamanho inicial da fila de operação de replicação secundária dentro FabricReplicatorde , que contém replicação Operationainda não bombeada e processada pelo serviço. A unidade aqui é o número de operações na fila

setMaxCopyQueueSize

public void setMaxCopyQueueSize(long maxCopyQueueSize)

Define o tamanho máximo da fila de operação de cópia dentro FabricReplicatorde , que contém cópias Operationainda não bombeadas e processadas pelo serviço.

Observações:Se esse tamanho de fila for atingido no secundário, as operações serão armazenadas em buffer na fila de cópia do Primário. Se essa fila também for preenchida, o Primário começará a ver system.fabric.FabricErrorCode#ReplicationQueueFull exceções. O valor padrão é 1024

Parâmetros:

maxCopyQueueSize - O tamanho máximo da fila de operação de cópia dentro FabricReplicatorde , que contém cópias Operationainda não bombeadas e processadas pelo serviço.

setMaxPrimaryReplicationQueueMemorySize

public void setMaxPrimaryReplicationQueueMemorySize(long maxPrimaryReplicationQueueMemorySize)

Define o tamanho máximo da fila de operação de replicação primária dentro FabricReplicatorde , que contém s de replicação Operation

Observações:Essa configuração é específica para o Replicador quando a função do serviço é Primária. O valor padrão é 0. Isso implica que não há limite de memória

Parâmetros:

maxPrimaryReplicationQueueMemorySize - o tamanho máximo da fila de operação de replicação primária dentro FabricReplicatorde , que contém replicação Operations A unidade aqui é o consumo de memória virtual da fila . Retorna long.

setMaxPrimaryReplicationQueueSize

public void setMaxPrimaryReplicationQueueSize(long maxPrimaryReplicationQueueSize)

Define o tamanho máximo da fila de operação de replicação primária dentro FabricReplicatorde , que contém s de replicação Operation

Observações:Se esse tamanho de fila for atingido, o Primário começará a ver system.fabric.FabricErrorCode#ReplicationQueueFull exceções. O valor padrão é 1024 Observe que os valores para esse parâmetro devem ser uma potência de 2. Essa configuração é específica para o Replicador quando a função do serviço é Primária

Parâmetros:

maxPrimaryReplicationQueueSize - O tamanho máximo da fila de operações de replicação primária dentro FabricReplicatorde , que contém replicações Operations. A unidade aqui é o número de operações na fila.

setMaxReplicationMessageSize

public void setMaxReplicationMessageSize(long maxReplicationMessageSize)

Define o tamanho máximo de uma mensagem que pode ser transmitida por meio do replicador. Isso inclui mensagens de replicação, copiar mensagens e copiar mensagens de contexto. A unidade de representação é bytes.

Observações:O valor padrão é 50 MB

Parâmetros:

maxReplicationMessageSize - O tamanho máximo de uma mensagem que pode ser transmitida por meio do replicador.

setMaxReplicationQueueMemorySize

public void setMaxReplicationQueueMemorySize(long maxReplicationQueueMemorySize)

Define o tamanho máximo para a memória da fila de replicação.

Observações:O valor padrão é 0. Isso implica que não há limite de memória

Parâmetros:

maxReplicationQueueMemorySize - O tamanho máximo da memória da fila de replicação.

setMaxReplicationQueueSize

public void setMaxReplicationQueueSize(long maxReplicationQueueSize)

Define o tamanho máximo da fila de replicação.

Parâmetros:

maxReplicationQueueSize - o tamanho máximo da fila de replicação.

setMaxSecondaryReplicationQueueMemorySize

public void setMaxSecondaryReplicationQueueMemorySize(long maxSecondaryReplicationQueueMemorySize)

Define o tamanho máximo da fila de operações de replicação secundária dentro FabricReplicatorde , que contém replicações Operations.

Observações:Essa configuração é específica para o Replicador quando a função do serviço é Secundária/Ociosa. O valor padrão é 0. Isso implica que não há limite de memória

Parâmetros:

maxSecondaryReplicationQueueMemorySize - Retorna o tamanho máximo da fila de operação de replicação secundária dentro FabricReplicatorde , que contém s de replicação Operation. A unidade aqui é o consumo de memória virtual da fila.

setMaxSecondaryReplicationQueueSize

public void setMaxSecondaryReplicationQueueSize(long maxSecondaryReplicationQueueSize)

Define o tamanho máximo da fila de operações de replicação secundária dentro FabricReplicatorde , que contém replicações Operations

Observações:Se esse tamanho de fila for atingido, as operações serão armazenadas em buffer na fila de replicação do Primário. Se essa fila também for preenchida, o Primário começará a ver system.fabric.FabricErrorCode#ReplicationQueueFull exceções. O valor padrão é 2048.Observe que os valores para esse parâmetro devem ser uma potência de 2. Essa configuração é específica para o Replicador quando a função do serviço é Secundária/Ociosa

Parâmetros:

maxSecondaryReplicationQueueSize - O tamanho máximo da fila de operações de replicação secundária dentro FabricReplicatorde , que contém replicação Operationainda não bombeada e processada pelo serviço. A unidade aqui é o número de operações na fila

setPrimaryWaitForPendingQuorumsTimeout

public void setPrimaryWaitForPendingQuorumsTimeout(Duration primaryWaitForPendingQuorumsTimeout)

Define por quanto tempo o replicador primário aguarda o recebimento de um quorum de confirmações para quaisquer operações de replicação pendentes antes de processar uma solicitação de reconfiguração, o que pode resultar em 'cancelamento' das operações de replicação pendentes.

Observações:O valor padrão é 0. Isso implica que as reconfigurações não são aguardadas para receber quorum nas operações de replicação pendentes. Isso ajuda a concluir reconfigurações mais cedo. Observe que valores maiores para esse parâmetro podem resultar potencialmente em reconfigurações mais lentas, implicando durações mais longas para failover de um primário.

Parâmetros:

primaryWaitForPendingQuorumsTimeout - Quantidade de tempo que o replicador primário aguarda para receber um quorum de confirmações para quaisquer operações de replicação pendentes quando há uma solicitação para que o replicador primário processe uma reconfiguração java.time.Duration.

setReplicatorAddress

public void setReplicatorAddress(String replicatorAddress)

Configura o endereço que esse replicador usará ao se comunicar com outros Replicadores.

Observações:A cadeia de caracteres é formatada como "hostname:port", em que o nome do host pode ser FQDN ou endereço IP. O valor padrão é localhost:0

Parâmetros:

replicatorAddress - O endereço que esse replicador usará ao se comunicar com outros Replicadores.

setRequireServiceAck

public void setRequireServiceAck(boolean requireServiceAck)

Impede a confirmação otimista de operações em serviços não persistentes, exigindo que o serviço chame acknowledge() antes de bombear a próxima operação.

Observações:Serviços não persistentes que exigem confirmação explícita podem definir essa propriedade como True para evitar a confirmação otimista das operações pelo Replicador. Essa configuração não tem efeito para serviços persistentes. O valor padrão é false.

Parâmetros:

requireServiceAck - true se a confirmação otimista de operações em serviços não persistentes;caso contrário, false.

setRetryInterval

public void setRetryInterval(Duration retryInterval)

Define quanto tempo a FabricReplicator espera depois de transmitir uma mensagem do primário para o secundário para que o secundário reconheça que recebeu a mensagem.

Observações:Receber uma mensagem não necessariamente indica que a mensagem foi processada. Se esse temporizador for excedido, a mensagem será retransmitida. O valor padrão é de 5 segundos.

Parâmetros:

retryInterval - O tempo necessário para as FabricReplicator esperas depois de transmitir uma mensagem do primário para o secundário para que o secundário reconheça que recebeu a mensagem.

setSecondaryClearAcknowledgedOperations

public void setSecondaryClearAcknowledgedOperations(boolean secondaryClearAcknowledgedOperations)

Normalmente, as operações no replicador secundário são mantidas na fila para poder capturar réplicas se elas forem promovidas a um primário. Com esse sinalizador habilitado, o replicador secundário libera a operação assim que ela é reconhecida pelo serviço de usuário.

Observações:O valor padrão é false

Parâmetros:

secondaryClearAcknowledgedOperations - true se o replicador secundário liberar a operação assim que for reconhecido pelo serviço de usuário; caso contrário, false.

setSecurityCredentials

public void setSecurityCredentials(SecurityCredentials securityCredentials)

Permite que o serviço defina credenciais de segurança para proteger o tráfego entre replicadores.

Parâmetros:

securityCredentials - O serviço para definir credenciais de segurança para proteger o tráfego entre replicadores.

setUseStreamFaultsAndEndOfStreamOperationAck

public void setUseStreamFaultsAndEndOfStreamOperationAck(boolean useStreamFaultsAndEndOfStreamOperationAck)

Especifica se o replicador usa falhas de fluxo.

Observações:O valor padrão é false

Parâmetros:

useStreamFaultsAndEndOfStreamOperationAck - true se o replicador usar falhas de fluxo; caso contrário, false.

toNative

public long toNative(PinCollection pinCollection)

Parâmetros:

pinCollection

toString

public String toString()