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