diff --git a/service/history/engine/engineimpl/register_domain_failover_callback.go b/service/history/engine/engineimpl/register_domain_failover_callback.go index d604c24dc53..01c7cae1d18 100644 --- a/service/history/engine/engineimpl/register_domain_failover_callback.go +++ b/service/history/engine/engineimpl/register_domain_failover_callback.go @@ -161,7 +161,7 @@ func (e *historyEngineImpl) unlockProcessingForFailover() { e.timerProcessor.UnlockTaskProcessing() } -func (e historyEngineImpl) failoverPredicate(shardNotificationVersion int64, nextDomain *cache.DomainCacheEntry, action func()) { +func (e *historyEngineImpl) failoverPredicate(shardNotificationVersion int64, nextDomain *cache.DomainCacheEntry, action func()) { domainFailoverNotificationVersion := nextDomain.GetFailoverNotificationVersion() domainActiveCluster := nextDomain.GetReplicationConfig().ActiveClusterName