1103
ctx context.Context,
1104
request *adminservice.ListClustersRequest,
1105
>
) (_ *adminservice.ListClustersResponse, retError error) {
admin_handler.go
1106
>
defer log.CapturePanic(adh.logger, &retError)
1107
>
if request == nil {
1108
return nil, errRequestNotSet
1109
}
1111
request.PageSize = listClustersPageSize
1112
}
1113
1114
>
resp, err := adh.clusterMetadataManager.ListClusterMetadata(ctx, &persistence.ListClusterMetadataRequest{
admin_handler.go
1115
>
PageSize: int(request.GetPageSize()),
1116
>
NextPageToken: request.GetNextPageToken(),
1117
>
})
1118
>
if err != nil {
1119
return nil, err
1120
}
1121
1122
>
var clusterMetadataList []*persistencespb.ClusterMetadata
admin_handler.go
1123
>
for _, clusterResp := range resp.ClusterMetadata {
1124
>
clusterMetadataList = append(clusterMetadataList, clusterResp.ClusterMetadata)
1125
>
}
1126
>
return &adminservice.ListClustersResponse{
1127
>
Clusters: clusterMetadataList,
1128
>
NextPageToken: resp.NextPageToken,
1129
>
}, nil
1130
}
1131