278
ctx context.Context,
279
listRequest *workflowservice.ListNamespacesRequest,
281
>
282
>
pageSize := 100
283
>
if listRequest.GetPageSize() != 0 {
284
>
pageSize = int(listRequest.GetPageSize())
285
>
}
286
287
>
resp, err := d.metadataMgr.ListNamespaces(ctx, &persistence.ListNamespacesRequest{
namespace_handler.go
288
>
PageSize: pageSize,
289
>
NextPageToken: listRequest.NextPageToken,
290
>
IncludeDeleted: listRequest.GetNamespaceFilter().GetIncludeDeleted(),
291
>
})
292
>
293
>
if err != nil {
294
return nil, err
295
}
296
298
>
for _, namespace := range resp.Namespaces {
299
>
desc := &workflowservice.DescribeNamespaceResponse{
300
>
IsGlobalNamespace: namespace.IsGlobalNamespace,
301
>
FailoverVersion: namespace.Namespace.FailoverVersion,
302
>
}
303
>
desc.NamespaceInfo, desc.Config, desc.ReplicationConfig, desc.FailoverHistory =
304
>
d.createResponse(
305
>
namespace.Namespace.Info,
306
>
namespace.Namespace.Config,
307
>
namespace.Namespace.ReplicationConfig)
308
>
namespaces = append(namespaces, desc)
309
>
}
310
312
>
Namespaces: namespaces,
313
>
NextPageToken: resp.NextPageToken,
314
>
}
315
>
316
>
return response, nil
317
}
318