in service/history/config/config.go [345:601]
func New(dc *dynamicconfig.Collection, numberOfShards int, maxMessageSize int, storeType string, isAdvancedVisConfigExist bool, hostname string) *Config {
cfg := &Config{
NumberOfShards: numberOfShards,
IsAdvancedVisConfigExist: isAdvancedVisConfigExist,
RPS: dc.GetIntProperty(dynamicconfig.HistoryRPS),
MaxIDLengthWarnLimit: dc.GetIntProperty(dynamicconfig.MaxIDLengthWarnLimit),
DomainNameMaxLength: dc.GetIntPropertyFilteredByDomain(dynamicconfig.DomainNameMaxLength),
IdentityMaxLength: dc.GetIntPropertyFilteredByDomain(dynamicconfig.IdentityMaxLength),
WorkflowIDMaxLength: dc.GetIntPropertyFilteredByDomain(dynamicconfig.WorkflowIDMaxLength),
SignalNameMaxLength: dc.GetIntPropertyFilteredByDomain(dynamicconfig.SignalNameMaxLength),
WorkflowTypeMaxLength: dc.GetIntPropertyFilteredByDomain(dynamicconfig.WorkflowTypeMaxLength),
RequestIDMaxLength: dc.GetIntPropertyFilteredByDomain(dynamicconfig.RequestIDMaxLength),
TaskListNameMaxLength: dc.GetIntPropertyFilteredByDomain(dynamicconfig.TaskListNameMaxLength),
ActivityIDMaxLength: dc.GetIntPropertyFilteredByDomain(dynamicconfig.ActivityIDMaxLength),
ActivityTypeMaxLength: dc.GetIntPropertyFilteredByDomain(dynamicconfig.ActivityTypeMaxLength),
MarkerNameMaxLength: dc.GetIntPropertyFilteredByDomain(dynamicconfig.MarkerNameMaxLength),
TimerIDMaxLength: dc.GetIntPropertyFilteredByDomain(dynamicconfig.TimerIDMaxLength),
PersistenceMaxQPS: dc.GetIntProperty(dynamicconfig.HistoryPersistenceMaxQPS),
PersistenceGlobalMaxQPS: dc.GetIntProperty(dynamicconfig.HistoryPersistenceGlobalMaxQPS),
ShutdownDrainDuration: dc.GetDurationProperty(dynamicconfig.HistoryShutdownDrainDuration),
EnableVisibilitySampling: dc.GetBoolProperty(dynamicconfig.EnableVisibilitySampling),
EnableReadFromClosedExecutionV2: dc.GetBoolProperty(dynamicconfig.EnableReadFromClosedExecutionV2),
VisibilityOpenMaxQPS: dc.GetIntPropertyFilteredByDomain(dynamicconfig.HistoryVisibilityOpenMaxQPS),
VisibilityClosedMaxQPS: dc.GetIntPropertyFilteredByDomain(dynamicconfig.HistoryVisibilityClosedMaxQPS),
MaxAutoResetPoints: dc.GetIntPropertyFilteredByDomain(dynamicconfig.HistoryMaxAutoResetPoints),
MaxDecisionStartToCloseSeconds: dc.GetIntPropertyFilteredByDomain(dynamicconfig.MaxDecisionStartToCloseSeconds),
AdvancedVisibilityWritingMode: dc.GetStringProperty(dynamicconfig.AdvancedVisibilityWritingMode),
EmitShardDiffLog: dc.GetBoolProperty(dynamicconfig.EmitShardDiffLog),
HistoryCacheInitialSize: dc.GetIntProperty(dynamicconfig.HistoryCacheInitialSize),
HistoryCacheMaxSize: dc.GetIntProperty(dynamicconfig.HistoryCacheMaxSize),
HistoryCacheTTL: dc.GetDurationProperty(dynamicconfig.HistoryCacheTTL),
EventsCacheInitialCount: dc.GetIntProperty(dynamicconfig.EventsCacheInitialCount),
EventsCacheMaxCount: dc.GetIntProperty(dynamicconfig.EventsCacheMaxCount),
EventsCacheMaxSize: dc.GetIntProperty(dynamicconfig.EventsCacheMaxSize),
EventsCacheTTL: dc.GetDurationProperty(dynamicconfig.EventsCacheTTL),
EventsCacheGlobalEnable: dc.GetBoolProperty(dynamicconfig.EventsCacheGlobalEnable),
EventsCacheGlobalInitialCount: dc.GetIntProperty(dynamicconfig.EventsCacheGlobalInitialCount),
EventsCacheGlobalMaxCount: dc.GetIntProperty(dynamicconfig.EventsCacheGlobalMaxCount),
RangeSizeBits: 20, // 20 bits for sequencer, 2^20 sequence number for any range
AcquireShardInterval: dc.GetDurationProperty(dynamicconfig.AcquireShardInterval),
AcquireShardConcurrency: dc.GetIntProperty(dynamicconfig.AcquireShardConcurrency),
StandbyClusterDelay: dc.GetDurationProperty(dynamicconfig.StandbyClusterDelay),
StandbyTaskMissingEventsResendDelay: dc.GetDurationProperty(dynamicconfig.StandbyTaskMissingEventsResendDelay),
StandbyTaskMissingEventsDiscardDelay: dc.GetDurationProperty(dynamicconfig.StandbyTaskMissingEventsDiscardDelay),
WorkflowDeletionJitterRange: dc.GetIntPropertyFilteredByDomain(dynamicconfig.WorkflowDeletionJitterRange),
MaxResponseSize: maxMessageSize,
TaskProcessRPS: dc.GetIntPropertyFilteredByDomain(dynamicconfig.TaskProcessRPS),
TaskSchedulerType: dc.GetIntProperty(dynamicconfig.TaskSchedulerType),
TaskSchedulerWorkerCount: dc.GetIntProperty(dynamicconfig.TaskSchedulerWorkerCount),
TaskSchedulerShardWorkerCount: dc.GetIntProperty(dynamicconfig.TaskSchedulerShardWorkerCount),
TaskSchedulerQueueSize: dc.GetIntProperty(dynamicconfig.TaskSchedulerQueueSize),
TaskSchedulerShardQueueSize: dc.GetIntProperty(dynamicconfig.TaskSchedulerShardQueueSize),
TaskSchedulerDispatcherCount: dc.GetIntProperty(dynamicconfig.TaskSchedulerDispatcherCount),
TaskSchedulerRoundRobinWeights: dc.GetMapProperty(dynamicconfig.TaskSchedulerRoundRobinWeights),
TaskCriticalRetryCount: dc.GetIntProperty(dynamicconfig.TaskCriticalRetryCount),
ActiveTaskRedispatchInterval: dc.GetDurationProperty(dynamicconfig.ActiveTaskRedispatchInterval),
StandbyTaskRedispatchInterval: dc.GetDurationProperty(dynamicconfig.StandbyTaskRedispatchInterval),
TaskRedispatchIntervalJitterCoefficient: dc.GetFloat64Property(dynamicconfig.TaskRedispatchIntervalJitterCoefficient),
StandbyTaskReReplicationContextTimeout: dc.GetDurationPropertyFilteredByDomainID(dynamicconfig.StandbyTaskReReplicationContextTimeout),
EnableDropStuckTaskByDomainID: dc.GetBoolPropertyFilteredByDomainID(dynamicconfig.EnableDropStuckTaskByDomainID),
ResurrectionCheckMinDelay: dc.GetDurationPropertyFilteredByDomain(dynamicconfig.ResurrectionCheckMinDelay),
QueueProcessorEnableSplit: dc.GetBoolProperty(dynamicconfig.QueueProcessorEnableSplit),
QueueProcessorSplitMaxLevel: dc.GetIntProperty(dynamicconfig.QueueProcessorSplitMaxLevel),
QueueProcessorEnableRandomSplitByDomainID: dc.GetBoolPropertyFilteredByDomainID(dynamicconfig.QueueProcessorEnableRandomSplitByDomainID),
QueueProcessorRandomSplitProbability: dc.GetFloat64Property(dynamicconfig.QueueProcessorRandomSplitProbability),
QueueProcessorEnablePendingTaskSplitByDomainID: dc.GetBoolPropertyFilteredByDomainID(dynamicconfig.QueueProcessorEnablePendingTaskSplitByDomainID),
QueueProcessorPendingTaskSplitThreshold: dc.GetMapProperty(dynamicconfig.QueueProcessorPendingTaskSplitThreshold),
QueueProcessorEnableStuckTaskSplitByDomainID: dc.GetBoolPropertyFilteredByDomainID(dynamicconfig.QueueProcessorEnableStuckTaskSplitByDomainID),
QueueProcessorStuckTaskSplitThreshold: dc.GetMapProperty(dynamicconfig.QueueProcessorStuckTaskSplitThreshold),
QueueProcessorSplitLookAheadDurationByDomainID: dc.GetDurationPropertyFilteredByDomainID(dynamicconfig.QueueProcessorSplitLookAheadDurationByDomainID),
QueueProcessorPollBackoffInterval: dc.GetDurationProperty(dynamicconfig.QueueProcessorPollBackoffInterval),
QueueProcessorPollBackoffIntervalJitterCoefficient: dc.GetFloat64Property(dynamicconfig.QueueProcessorPollBackoffIntervalJitterCoefficient),
QueueProcessorEnablePersistQueueStates: dc.GetBoolProperty(dynamicconfig.QueueProcessorEnablePersistQueueStates),
QueueProcessorEnableLoadQueueStates: dc.GetBoolProperty(dynamicconfig.QueueProcessorEnableLoadQueueStates),
QueueProcessorEnableGracefulSyncShutdown: dc.GetBoolProperty(dynamicconfig.QueueProcessorEnableGracefulSyncShutdown),
TimerTaskBatchSize: dc.GetIntProperty(dynamicconfig.TimerTaskBatchSize),
TimerTaskDeleteBatchSize: dc.GetIntProperty(dynamicconfig.TimerTaskDeleteBatchSize),
TimerProcessorGetFailureRetryCount: dc.GetIntProperty(dynamicconfig.TimerProcessorGetFailureRetryCount),
TimerProcessorCompleteTimerFailureRetryCount: dc.GetIntProperty(dynamicconfig.TimerProcessorCompleteTimerFailureRetryCount),
TimerProcessorUpdateAckInterval: dc.GetDurationProperty(dynamicconfig.TimerProcessorUpdateAckInterval),
TimerProcessorUpdateAckIntervalJitterCoefficient: dc.GetFloat64Property(dynamicconfig.TimerProcessorUpdateAckIntervalJitterCoefficient),
TimerProcessorCompleteTimerInterval: dc.GetDurationProperty(dynamicconfig.TimerProcessorCompleteTimerInterval),
TimerProcessorFailoverMaxStartJitterInterval: dc.GetDurationProperty(dynamicconfig.TimerProcessorFailoverMaxStartJitterInterval),
TimerProcessorFailoverMaxPollRPS: dc.GetIntProperty(dynamicconfig.TimerProcessorFailoverMaxPollRPS),
TimerProcessorMaxPollRPS: dc.GetIntProperty(dynamicconfig.TimerProcessorMaxPollRPS),
TimerProcessorMaxPollInterval: dc.GetDurationProperty(dynamicconfig.TimerProcessorMaxPollInterval),
TimerProcessorMaxPollIntervalJitterCoefficient: dc.GetFloat64Property(dynamicconfig.TimerProcessorMaxPollIntervalJitterCoefficient),
TimerProcessorSplitQueueInterval: dc.GetDurationProperty(dynamicconfig.TimerProcessorSplitQueueInterval),
TimerProcessorSplitQueueIntervalJitterCoefficient: dc.GetFloat64Property(dynamicconfig.TimerProcessorSplitQueueIntervalJitterCoefficient),
TimerProcessorMaxRedispatchQueueSize: dc.GetIntProperty(dynamicconfig.TimerProcessorMaxRedispatchQueueSize),
TimerProcessorMaxTimeShift: dc.GetDurationProperty(dynamicconfig.TimerProcessorMaxTimeShift),
TimerProcessorHistoryArchivalSizeLimit: dc.GetIntProperty(dynamicconfig.TimerProcessorHistoryArchivalSizeLimit),
TimerProcessorArchivalTimeLimit: dc.GetDurationProperty(dynamicconfig.TimerProcessorArchivalTimeLimit),
TransferTaskBatchSize: dc.GetIntProperty(dynamicconfig.TransferTaskBatchSize),
TransferTaskDeleteBatchSize: dc.GetIntProperty(dynamicconfig.TransferTaskDeleteBatchSize),
TransferProcessorFailoverMaxStartJitterInterval: dc.GetDurationProperty(dynamicconfig.TransferProcessorFailoverMaxStartJitterInterval),
TransferProcessorFailoverMaxPollRPS: dc.GetIntProperty(dynamicconfig.TransferProcessorFailoverMaxPollRPS),
TransferProcessorMaxPollRPS: dc.GetIntProperty(dynamicconfig.TransferProcessorMaxPollRPS),
TransferProcessorCompleteTransferFailureRetryCount: dc.GetIntProperty(dynamicconfig.TransferProcessorCompleteTransferFailureRetryCount),
TransferProcessorMaxPollInterval: dc.GetDurationProperty(dynamicconfig.TransferProcessorMaxPollInterval),
TransferProcessorMaxPollIntervalJitterCoefficient: dc.GetFloat64Property(dynamicconfig.TransferProcessorMaxPollIntervalJitterCoefficient),
TransferProcessorSplitQueueInterval: dc.GetDurationProperty(dynamicconfig.TransferProcessorSplitQueueInterval),
TransferProcessorSplitQueueIntervalJitterCoefficient: dc.GetFloat64Property(dynamicconfig.TransferProcessorSplitQueueIntervalJitterCoefficient),
TransferProcessorUpdateAckInterval: dc.GetDurationProperty(dynamicconfig.TransferProcessorUpdateAckInterval),
TransferProcessorUpdateAckIntervalJitterCoefficient: dc.GetFloat64Property(dynamicconfig.TransferProcessorUpdateAckIntervalJitterCoefficient),
TransferProcessorCompleteTransferInterval: dc.GetDurationProperty(dynamicconfig.TransferProcessorCompleteTransferInterval),
TransferProcessorMaxRedispatchQueueSize: dc.GetIntProperty(dynamicconfig.TransferProcessorMaxRedispatchQueueSize),
TransferProcessorEnableValidator: dc.GetBoolProperty(dynamicconfig.TransferProcessorEnableValidator),
TransferProcessorValidationInterval: dc.GetDurationProperty(dynamicconfig.TransferProcessorValidationInterval),
TransferProcessorVisibilityArchivalTimeLimit: dc.GetDurationProperty(dynamicconfig.TransferProcessorVisibilityArchivalTimeLimit),
CrossClusterTaskBatchSize: dc.GetIntProperty(dynamicconfig.CrossClusterTaskBatchSize),
CrossClusterTaskDeleteBatchSize: dc.GetIntProperty(dynamicconfig.CrossClusterTaskDeleteBatchSize),
CrossClusterTaskFetchBatchSize: dc.GetIntPropertyFilteredByShardID(dynamicconfig.CrossClusterTaskFetchBatchSize),
CrossClusterSourceProcessorMaxPollRPS: dc.GetIntProperty(dynamicconfig.CrossClusterSourceProcessorMaxPollRPS),
CrossClusterSourceProcessorMaxPollInterval: dc.GetDurationProperty(dynamicconfig.CrossClusterSourceProcessorMaxPollInterval),
CrossClusterSourceProcessorMaxPollIntervalJitterCoefficient: dc.GetFloat64Property(dynamicconfig.CrossClusterSourceProcessorMaxPollIntervalJitterCoefficient),
CrossClusterSourceProcessorUpdateAckInterval: dc.GetDurationProperty(dynamicconfig.CrossClusterSourceProcessorUpdateAckInterval),
CrossClusterSourceProcessorUpdateAckIntervalJitterCoefficient: dc.GetFloat64Property(dynamicconfig.CrossClusterSourceProcessorUpdateAckIntervalJitterCoefficient),
CrossClusterSourceProcessorMaxRedispatchQueueSize: dc.GetIntProperty(dynamicconfig.CrossClusterSourceProcessorMaxRedispatchQueueSize),
CrossClusterSourceProcessorMaxPendingTaskSize: dc.GetIntProperty(dynamicconfig.CrossClusterSourceProcessorMaxPendingTaskSize),
CrossClusterTargetProcessorMaxPendingTasks: dc.GetIntProperty(dynamicconfig.CrossClusterTargetProcessorMaxPendingTasks),
CrossClusterTargetProcessorMaxRetryCount: dc.GetIntProperty(dynamicconfig.CrossClusterTargetProcessorMaxRetryCount),
CrossClusterTargetProcessorTaskWaitInterval: dc.GetDurationProperty(dynamicconfig.CrossClusterTargetProcessorTaskWaitInterval),
CrossClusterTargetProcessorServiceBusyBackoffInterval: dc.GetDurationProperty(dynamicconfig.CrossClusterTargetProcessorServiceBusyBackoffInterval),
CrossClusterTargetProcessorJitterCoefficient: dc.GetFloat64Property(dynamicconfig.CrossClusterTargetProcessorJitterCoefficient),
CrossClusterFetcherParallelism: dc.GetIntProperty(dynamicconfig.CrossClusterFetcherParallelism),
CrossClusterFetcherAggregationInterval: dc.GetDurationProperty(dynamicconfig.CrossClusterFetcherAggregationInterval),
CrossClusterFetcherServiceBusyBackoffInterval: dc.GetDurationProperty(dynamicconfig.CrossClusterFetcherServiceBusyBackoffInterval),
CrossClusterFetcherErrorBackoffInterval: dc.GetDurationProperty(dynamicconfig.CrossClusterFetcherErrorBackoffInterval),
CrossClusterFetcherJitterCoefficient: dc.GetFloat64Property(dynamicconfig.CrossClusterFetcherJitterCoefficient),
ReplicatorTaskDeleteBatchSize: dc.GetIntProperty(dynamicconfig.ReplicatorTaskDeleteBatchSize),
ReplicatorReadTaskMaxRetryCount: dc.GetIntProperty(dynamicconfig.ReplicatorReadTaskMaxRetryCount),
ReplicatorProcessorFetchTasksBatchSize: dc.GetIntPropertyFilteredByShardID(dynamicconfig.ReplicatorTaskBatchSize),
ReplicatorUpperLatency: dc.GetDurationProperty(dynamicconfig.ReplicatorUpperLatency),
ReplicatorCacheCapacity: dc.GetIntProperty(dynamicconfig.ReplicatorCacheCapacity),
ExecutionMgrNumConns: dc.GetIntProperty(dynamicconfig.ExecutionMgrNumConns),
HistoryMgrNumConns: dc.GetIntProperty(dynamicconfig.HistoryMgrNumConns),
MaximumBufferedEventsBatch: dc.GetIntProperty(dynamicconfig.MaximumBufferedEventsBatch),
MaximumSignalsPerExecution: dc.GetIntPropertyFilteredByDomain(dynamicconfig.MaximumSignalsPerExecution),
ShardUpdateMinInterval: dc.GetDurationProperty(dynamicconfig.ShardUpdateMinInterval),
ShardSyncMinInterval: dc.GetDurationProperty(dynamicconfig.ShardSyncMinInterval),
ShardSyncTimerJitterCoefficient: dc.GetFloat64Property(dynamicconfig.TransferProcessorMaxPollIntervalJitterCoefficient),
// history client: client/history/client.go set the client timeout 30s
LongPollExpirationInterval: dc.GetDurationPropertyFilteredByDomain(dynamicconfig.HistoryLongPollExpirationInterval),
EventEncodingType: dc.GetStringPropertyFilteredByDomain(dynamicconfig.DefaultEventEncoding),
EnableParentClosePolicy: dc.GetBoolPropertyFilteredByDomain(dynamicconfig.EnableParentClosePolicy),
NumParentClosePolicySystemWorkflows: dc.GetIntProperty(dynamicconfig.NumParentClosePolicySystemWorkflows),
EnableParentClosePolicyWorker: dc.GetBoolProperty(dynamicconfig.EnableParentClosePolicyWorker),
ParentClosePolicyThreshold: dc.GetIntPropertyFilteredByDomain(dynamicconfig.ParentClosePolicyThreshold),
NumArchiveSystemWorkflows: dc.GetIntProperty(dynamicconfig.NumArchiveSystemWorkflows),
ArchiveRequestRPS: dc.GetIntProperty(dynamicconfig.ArchiveRequestRPS),
ArchiveInlineHistoryRPS: dc.GetIntProperty(dynamicconfig.ArchiveInlineHistoryRPS),
ArchiveInlineHistoryGlobalRPS: dc.GetIntProperty(dynamicconfig.ArchiveInlineHistoryGlobalRPS),
ArchiveInlineVisibilityRPS: dc.GetIntProperty(dynamicconfig.ArchiveInlineVisibilityRPS),
ArchiveInlineVisibilityGlobalRPS: dc.GetIntProperty(dynamicconfig.ArchiveInlineVisibilityGlobalRPS),
AllowArchivingIncompleteHistory: dc.GetBoolProperty(dynamicconfig.AllowArchivingIncompleteHistory),
BlobSizeLimitError: dc.GetIntPropertyFilteredByDomain(dynamicconfig.BlobSizeLimitError),
BlobSizeLimitWarn: dc.GetIntPropertyFilteredByDomain(dynamicconfig.BlobSizeLimitWarn),
HistorySizeLimitError: dc.GetIntPropertyFilteredByDomain(dynamicconfig.HistorySizeLimitError),
HistorySizeLimitWarn: dc.GetIntPropertyFilteredByDomain(dynamicconfig.HistorySizeLimitWarn),
HistoryCountLimitError: dc.GetIntPropertyFilteredByDomain(dynamicconfig.HistoryCountLimitError),
HistoryCountLimitWarn: dc.GetIntPropertyFilteredByDomain(dynamicconfig.HistoryCountLimitWarn),
PendingActivitiesCountLimitError: dc.GetIntProperty(dynamicconfig.PendingActivitiesCountLimitError),
PendingActivitiesCountLimitWarn: dc.GetIntProperty(dynamicconfig.PendingActivitiesCountLimitWarn),
PendingActivityValidationEnabled: dc.GetBoolProperty(dynamicconfig.EnablePendingActivityValidation),
ThrottledLogRPS: dc.GetIntProperty(dynamicconfig.HistoryThrottledLogRPS),
EnableStickyQuery: dc.GetBoolPropertyFilteredByDomain(dynamicconfig.EnableStickyQuery),
ValidSearchAttributes: dc.GetMapProperty(dynamicconfig.ValidSearchAttributes),
SearchAttributesNumberOfKeysLimit: dc.GetIntPropertyFilteredByDomain(dynamicconfig.SearchAttributesNumberOfKeysLimit),
SearchAttributesSizeOfValueLimit: dc.GetIntPropertyFilteredByDomain(dynamicconfig.SearchAttributesSizeOfValueLimit),
SearchAttributesTotalSizeLimit: dc.GetIntPropertyFilteredByDomain(dynamicconfig.SearchAttributesTotalSizeLimit),
StickyTTL: dc.GetDurationPropertyFilteredByDomain(dynamicconfig.StickyTTL),
DecisionHeartbeatTimeout: dc.GetDurationPropertyFilteredByDomain(dynamicconfig.DecisionHeartbeatTimeout),
DecisionRetryCriticalAttempts: dc.GetIntProperty(dynamicconfig.DecisionRetryCriticalAttempts),
DecisionRetryMaxAttempts: dc.GetIntPropertyFilteredByDomain(dynamicconfig.DecisionRetryMaxAttempts),
NormalDecisionScheduleToStartMaxAttempts: dc.GetIntPropertyFilteredByDomain(dynamicconfig.NormalDecisionScheduleToStartMaxAttempts),
NormalDecisionScheduleToStartTimeout: dc.GetDurationPropertyFilteredByDomain(dynamicconfig.NormalDecisionScheduleToStartTimeout),
ReplicationTaskFetcherParallelism: dc.GetIntProperty(dynamicconfig.ReplicationTaskFetcherParallelism),
ReplicationTaskFetcherAggregationInterval: dc.GetDurationProperty(dynamicconfig.ReplicationTaskFetcherAggregationInterval),
ReplicationTaskFetcherTimerJitterCoefficient: dc.GetFloat64Property(dynamicconfig.ReplicationTaskFetcherTimerJitterCoefficient),
ReplicationTaskFetcherErrorRetryWait: dc.GetDurationProperty(dynamicconfig.ReplicationTaskFetcherErrorRetryWait),
ReplicationTaskFetcherServiceBusyWait: dc.GetDurationProperty(dynamicconfig.ReplicationTaskFetcherServiceBusyWait),
ReplicationTaskFetcherEnableGracefulSyncShutdown: dc.GetBoolProperty(dynamicconfig.ReplicationTaskFetcherEnableGracefulSyncShutdown),
ReplicationTaskProcessorErrorRetryWait: dc.GetDurationPropertyFilteredByShardID(dynamicconfig.ReplicationTaskProcessorErrorRetryWait),
ReplicationTaskProcessorErrorRetryMaxAttempts: dc.GetIntPropertyFilteredByShardID(dynamicconfig.ReplicationTaskProcessorErrorRetryMaxAttempts),
ReplicationTaskProcessorErrorSecondRetryWait: dc.GetDurationPropertyFilteredByShardID(dynamicconfig.ReplicationTaskProcessorErrorSecondRetryWait),
ReplicationTaskProcessorErrorSecondRetryMaxWait: dc.GetDurationPropertyFilteredByShardID(dynamicconfig.ReplicationTaskProcessorErrorSecondRetryMaxWait),
ReplicationTaskProcessorErrorSecondRetryExpiration: dc.GetDurationPropertyFilteredByShardID(dynamicconfig.ReplicationTaskProcessorErrorSecondRetryExpiration),
ReplicationTaskProcessorNoTaskRetryWait: dc.GetDurationPropertyFilteredByShardID(dynamicconfig.ReplicationTaskProcessorNoTaskInitialWait),
ReplicationTaskProcessorCleanupInterval: dc.GetDurationPropertyFilteredByShardID(dynamicconfig.ReplicationTaskProcessorCleanupInterval),
ReplicationTaskProcessorCleanupJitterCoefficient: dc.GetFloat64PropertyFilteredByShardID(dynamicconfig.ReplicationTaskProcessorCleanupJitterCoefficient),
ReplicationTaskProcessorStartWait: dc.GetDurationPropertyFilteredByShardID(dynamicconfig.ReplicationTaskProcessorStartWait),
ReplicationTaskProcessorStartWaitJitterCoefficient: dc.GetFloat64PropertyFilteredByShardID(dynamicconfig.ReplicationTaskProcessorStartWaitJitterCoefficient),
ReplicationTaskProcessorHostQPS: dc.GetFloat64Property(dynamicconfig.ReplicationTaskProcessorHostQPS),
ReplicationTaskProcessorShardQPS: dc.GetFloat64Property(dynamicconfig.ReplicationTaskProcessorShardQPS),
ReplicationTaskGenerationQPS: dc.GetFloat64Property(dynamicconfig.ReplicationTaskGenerationQPS),
EnableReplicationTaskGeneration: dc.GetBoolPropertyFilteredByDomainIDAndWorkflowID(dynamicconfig.EnableReplicationTaskGeneration),
EnableRecordWorkflowExecutionUninitialized: dc.GetBoolPropertyFilteredByDomain(dynamicconfig.EnableRecordWorkflowExecutionUninitialized),
WorkflowIDCacheExternalEnabled: dc.GetBoolPropertyFilteredByDomain(dynamicconfig.WorkflowIDCacheExternalEnabled),
WorkflowIDCacheInternalEnabled: dc.GetBoolPropertyFilteredByDomain(dynamicconfig.WorkflowIDCacheInternalEnabled),
WorkflowIDExternalRateLimitEnabled: dc.GetBoolPropertyFilteredByDomain(dynamicconfig.WorkflowIDExternalRateLimitEnabled),
WorkflowIDInternalRateLimitEnabled: dc.GetBoolPropertyFilteredByDomain(dynamicconfig.WorkflowIDInternalRateLimitEnabled),
WorkflowIDExternalRPS: dc.GetIntPropertyFilteredByDomain(dynamicconfig.WorkflowIDExternalRPS),
WorkflowIDInternalRPS: dc.GetIntPropertyFilteredByDomain(dynamicconfig.WorkflowIDInternalRPS),
EnableConsistentQuery: dc.GetBoolProperty(dynamicconfig.EnableConsistentQuery),
EnableConsistentQueryByDomain: dc.GetBoolPropertyFilteredByDomain(dynamicconfig.EnableConsistentQueryByDomain),
EnableCrossClusterEngine: dc.GetBoolProperty(dynamicconfig.EnableCrossClusterEngine),
EnableCrossClusterOperationsForDomain: dc.GetBoolPropertyFilteredByDomain(dynamicconfig.EnableCrossClusterOperationsForDomain),
MaxBufferedQueryCount: dc.GetIntProperty(dynamicconfig.MaxBufferedQueryCount),
MutableStateChecksumGenProbability: dc.GetIntPropertyFilteredByDomain(dynamicconfig.MutableStateChecksumGenProbability),
MutableStateChecksumVerifyProbability: dc.GetIntPropertyFilteredByDomain(dynamicconfig.MutableStateChecksumVerifyProbability),
MutableStateChecksumInvalidateBefore: dc.GetFloat64Property(dynamicconfig.MutableStateChecksumInvalidateBefore),
EnableRetryForChecksumFailure: dc.GetBoolPropertyFilteredByDomain(dynamicconfig.EnableRetryForChecksumFailure),
EnableHistoryCorruptionCheck: dc.GetBoolPropertyFilteredByDomain(dynamicconfig.EnableHistoryCorruptionCheck),
NotifyFailoverMarkerInterval: dc.GetDurationProperty(dynamicconfig.NotifyFailoverMarkerInterval),
NotifyFailoverMarkerTimerJitterCoefficient: dc.GetFloat64Property(dynamicconfig.NotifyFailoverMarkerTimerJitterCoefficient),
EnableGracefulFailover: dc.GetBoolProperty(dynamicconfig.EnableGracefulFailover),
EnableActivityLocalDispatchByDomain: dc.GetBoolPropertyFilteredByDomain(dynamicconfig.EnableActivityLocalDispatchByDomain),
MaxActivityCountDispatchByDomain: dc.GetIntPropertyFilteredByDomain(dynamicconfig.MaxActivityCountDispatchByDomain),
ActivityMaxScheduleToStartTimeoutForRetry: dc.GetDurationPropertyFilteredByDomain(dynamicconfig.ActivityMaxScheduleToStartTimeoutForRetry),
EnableDebugMode: dc.GetBoolProperty(dynamicconfig.EnableDebugMode)(),
EnableTaskInfoLogByDomainID: dc.GetBoolPropertyFilteredByDomainID(dynamicconfig.HistoryEnableTaskInfoLogByDomainID),
EnableTimerDebugLogByDomainID: dc.GetBoolPropertyFilteredByDomainID(dynamicconfig.EnableTimerDebugLogByDomainID),
SampleLoggingRate: dc.GetIntProperty(dynamicconfig.SampleLoggingRate),
EnableShardIDMetrics: dc.GetBoolProperty(dynamicconfig.EnableShardIDMetrics),
LargeShardHistorySizeMetricThreshold: dc.GetIntProperty(dynamicconfig.LargeShardHistorySizeMetricThreshold),
LargeShardHistoryEventMetricThreshold: dc.GetIntProperty(dynamicconfig.LargeShardHistoryEventMetricThreshold),
LargeShardHistoryBlobMetricThreshold: dc.GetIntProperty(dynamicconfig.LargeShardHistoryBlobMetricThreshold),
HostName: hostname,
}
return cfg
}