Reference documentation and code samples for the Cloud Bigtable Client class ResumableStream.
User stream which handles failure from upstream, retries if necessary and provides single retrying user stream.
Namespace
Google \ Cloud \ BigtableMethods
__construct
Constructs a resumable stream.
| Parameters | |
|---|---|
| Name | Description |
apiFunction | callable Function to execute to get server stream. Function signature should match: |
argumentFunction | callable Function which returns the argument to be used while calling |
retryFunction | callable Function which determines whether to retry or not. |
retries | int [optional] Number of times to retry. Defaults to |
readAll
Starts executing the call and reading elements from server stream.
| Returns | |
|---|---|
| Type | Description |
Generator | |
getIterator
| Returns | |
|---|---|
| Type | Description |
Generator | |
static::isRetryable
Checks if code is retryable or not.
| Parameter | |
|---|---|
| Name | Description |
code | int Code to check. |
| Returns | |
|---|---|
| Type | Description |
bool | |
Constants
DEFAULT_MAX_RETRIES
Value: 3