228
}
229
231
>
if registerRequest.GetIsGlobalNamespace() {
232
failoverVersion = d.clusterMetadata.GetNextFailoverVersion(activeClusterName, 0)
233
}
234
236
>
Namespace: &persistencespb.NamespaceDetail{
237
>
Info: info,
238
>
Config: config,
239
>
ReplicationConfig: replicationConfig,
240
>
ConfigVersion: 0,
241
>
FailoverVersion: failoverVersion,
242
>
},
243
>
IsGlobalNamespace: isGlobalNamespace,
244
>
}
245
>
246
>
namespaceResponse, err := d.metadataMgr.CreateNamespace(ctx, namespaceRequest)
247
>
if err != nil {
248
return nil, err
249
}
250
252
>
ctx,
253
>
enumsspb.NAMESPACE_OPERATION_CREATE,
254
>
namespaceRequest.Namespace.Info,
255
>
namespaceRequest.Namespace.Config,
256
>
namespaceRequest.Namespace.ReplicationConfig,
257
>
false,
258
>
namespaceRequest.Namespace.ConfigVersion,
259
>
namespaceRequest.Namespace.FailoverVersion,
260
>
namespaceRequest.IsGlobalNamespace,
261
>
nil,
262
>
false, // forceReplicate
263
>
)
264
>
if err != nil {
265
return nil, err
266
}
267
269
>
tag.WorkflowNamespace(registerRequest.GetNamespace()),
270
>
tag.WorkflowNamespaceID(namespaceResponse.ID),
271
>
)
272
>
273
>
return &workflowservice.RegisterNamespaceResponse{}, nil
274
}
275