ctx context.Context,
request *CreateNamespaceRequest,
var response *CreateNamespaceResponse
op := func(ctx context.Context) error {
var err error
response, err = p.persistence.CreateNamespace(ctx, request)
return err
}
err := backoff.ThrottleRetryContext(ctx, op, p.policy, p.isRetryable)
persistence_retryable_clients.go
return response, err
}