74
}
75
}
77
// Don't replicate deleted namespace changes.
78
return nil
79
}
80
82
>
task := &replicationspb.ReplicationTask_NamespaceTaskAttributes{
83
>
NamespaceTaskAttributes: &replicationspb.NamespaceTaskAttributes{
84
>
NamespaceOperation: namespaceOperation,
85
>
Id: info.Id,
86
>
Info: &namespacepb.NamespaceInfo{
87
>
Name: info.Name,
88
>
State: info.State,
89
>
Description: info.Description,
90
>
OwnerEmail: info.Owner,
91
>
Data: info.Data,
92
>
},
93
>
Config: &namespacepb.NamespaceConfig{
94
>
WorkflowExecutionRetentionTtl: config.Retention,
95
>
HistoryArchivalState: config.HistoryArchivalState,
96
>
HistoryArchivalUri: config.HistoryArchivalUri,
97
>
VisibilityArchivalState: config.VisibilityArchivalState,
98
>
VisibilityArchivalUri: config.VisibilityArchivalUri,
99
>
BadBinaries: config.BadBinaries,
100
>
CustomSearchAttributeAliases: config.CustomSearchAttributeAliases,
101
>
},
102
>
ReplicationConfig: &replicationpb.NamespaceReplicationConfig{
103
>
ActiveClusterName: replicationConfig.ActiveClusterName,
104
>
Clusters: convertClusterReplicationConfigToProto(replicationConfig.Clusters),
105
>
},
106
>
ConfigVersion: configVersion,
107
>
FailoverVersion: failoverVersion,
108
>
FailoverHistory: convertFailoverHistoryToReplicationProto(failoverHistoy),
109
>
},
110
>
}
111
>
112
>
if replicationConfig.State == enumspb.REPLICATION_STATE_NORMAL {
113
task.NamespaceTaskAttributes.ReplicationConfig.State = replicationConfig.State
114
}
115
117
>
ctx,
118
>
&replicationspb.ReplicationTask{
119
>
TaskType: taskType,
120
>
Attributes: task,
121
>
})
122
}
123
124
func convertClusterReplicationConfigToProto(
125
input []string,
127
>
output := make([]*replicationpb.ClusterReplicationConfig, 0, len(input))
128
>
for _, clusterName := range input {
129
>
output = append(output, &replicationpb.ClusterReplicationConfig{ClusterName: clusterName})
130
>
}
131
>
return output
132
}
133
134
func convertFailoverHistoryToReplicationProto(
135
failoverHistoy []*persistencespb.FailoverStatus,
137
>
var replicationProto []*replicationpb.FailoverStatus
138
>
for _, failoverStatus := range failoverHistoy {
139
replicationProto = append(replicationProto, &replicationpb.FailoverStatus{
140
FailoverTime: failoverStatus.GetFailoverTime(),