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