657
}
658
659
>
applied, err := h.clusterMetadataManager.SaveClusterMetadata(ctx, &persistence.SaveClusterMetadataRequest{
operator_handler.go
660
>
ClusterMetadata: &persistencespb.ClusterMetadata{
661
>
ClusterName: resp.GetClusterName(),
662
>
HistoryShardCount: resp.GetHistoryShardCount(),
663
>
ClusterId: resp.GetClusterId(),
664
>
ClusterAddress: request.GetFrontendAddress(),
665
>
HttpAddress: resp.GetHttpAddress(),
666
>
FailoverVersionIncrement: resp.GetFailoverVersionIncrement(),
667
>
InitialFailoverVersion: resp.GetInitialFailoverVersion(),
668
>
IsGlobalNamespaceEnabled: resp.GetIsGlobalNamespaceEnabled(),
669
>
IsConnectionEnabled: request.GetEnableRemoteClusterConnection(),
670
>
IsReplicationEnabled: request.GetEnableReplication(),
671
>
Tags: resp.GetTags(),
672
>
},
673
>
Version: updateRequestVersion,
674
>
})
675
>
if err != nil {
676
return nil, serviceerror.NewInternalf(errUnableToStoreClusterInfo, err)
677
}