49
}
50
51
>
func NewDefaultReplicationResolverFactory() ReplicationResolverFactory {
replication_resolver.go
52
>
return func(detail *persistencespb.NamespaceDetail) ReplicationResolver {
53
>
// By convention, a namespace with non-zero failover version is a global namespace
54
>
// This can be overridden by WithGlobalFlag mutation if needed
55
>
isGlobal := detail.FailoverVersion != 0
56
>
return &defaultReplicationResolver{
57
>
replicationConfig: detail.ReplicationConfig,
58
>
isGlobalNamespace: isGlobal,
59
>
failoverVersion: detail.FailoverVersion,
60
>
failoverNotificationVersion: detail.FailoverNotificationVersion,
61
>
}
62
>
}
63
}
64