public static interface SqlDataServiceGrpc.AsyncServiceService for streaming data to and from Cloud SQL instances.
Methods
streamSqlData(StreamObserver<StreamSqlDataResponse> responseObserver)
public default StreamObserver<StreamSqlDataRequest> streamSqlData(StreamObserver<StreamSqlDataResponse> responseObserver) StreamSqlData establishes a bidirectional stream to a Cloud SQL instance,
and then streams data to and from the instance.
The first message from the client MUST be a StreamSqlDataRequest request
with configuration settings, including required values for the
connection_settings field. Subsequent messages from the client may
contain the payload field.
Messages from the server may contain the payload field.
The payload fields of the request and response streams contain the raw
data of the database's native wire protocol (e.g., PostgreSQL wire
protocol). The database client is responsible for generating and parsing
this data.
Any errors on initial connection (e.g., connection failure, authorization
issues, network problems) will result in the stream being terminated with
an appropriate RPC status exception.
After a successful connection is made, if an error occurs, then the server
terminates connection and returns the appropriate RPC status exception.
Add the request params headers to the request to ensure that
the streaming request is routed to the correct service for your database.
Use this format for the request params header:
x-goog-request-params:
location_id={location_path}&instance_id={instance_path}
location_path is locations/{location_name}
instance_path is projects/{project_name}/instances/{instance_name}
for example:
x-goog-request-params:
location_id=locations/us-central1&instance_id=projects/myproject/instances/instancename`
| Parameter | |
|---|---|
| Name | Description |
responseObserver |
io.grpc.stub.StreamObserver<StreamSqlDataResponse> |
| Returns | |
|---|---|
| Type | Description |
io.grpc.stub.StreamObserver<StreamSqlDataRequest> |
|