EventRouter Service, gRPC: ConnectorService.Get
Returns the specified bus.
To get the list of all available connectors, make a List request.
gRPC request
rpc Get (GetConnectorRequest) returns (Connector)
GetConnectorRequest
{
"connector_id": "string"
}
Field |
Description |
connector_id |
string Required field. ID of the connector to return. |
Connector
{
"id": "string",
"bus_id": "string",
"folder_id": "string",
"cloud_id": "string",
"created_at": "google.protobuf.Timestamp",
"name": "string",
"description": "string",
"labels": "map<string, string>",
"source": {
// Includes only one of the fields `data_stream`, `message_queue`, `timer`
"data_stream": {
"database": "string",
"stream_name": "string",
"consumer": "string",
"service_account_id": "string"
},
"message_queue": {
"queue_arn": "string",
"service_account_id": "string",
"visibility_timeout": "google.protobuf.Duration",
"batch_size": "int64",
"polling_timeout": "google.protobuf.Duration"
},
"timer": {
"cron_expression": "string",
"time_zone": "string",
"payload": "string"
}
// end of the list of possible fields
},
"deletion_protection": "bool",
"status": "Status"
}
Field |
Description |
id |
string ID of the connector. |
bus_id |
string ID of the bus that the connector belongs to. |
folder_id |
string ID of the folder that the connector resides in. |
cloud_id |
string ID of the cloud that the connector resides in. |
created_at |
Creation timestamp. |
name |
string Name of the connector. |
description |
string Description of the connector. |
labels |
object (map<string, string>) Resource labels as |
source |
Source of the connector. |
deletion_protection |
bool Deletion protection. |
status |
enum Status Status of the connector.
|
Source
Field |
Description |
data_stream |
Includes only one of the fields |
message_queue |
Includes only one of the fields |
timer |
Includes only one of the fields |
DataStream
Field |
Description |
database |
string Required field. Stream database. |
stream_name |
string Required field. Stream name, absolute or relative. |
consumer |
string Required field. Consumer name. |
service_account_id |
string Required field. Service account which has read permission on the stream. |
MessageQueue
Field |
Description |
queue_arn |
string Required field. Queue ARN. |
service_account_id |
string Required field. Service account which has read access to the queue. |
visibility_timeout |
Queue visibility timeout override. |
batch_size |
int64 Batch size for polling. |
polling_timeout |
Queue polling timeout. |
Timer
Field |
Description |
cron_expression |
string Required field. cron expression, with second precision |
time_zone |
string time zone, e.g. Europe/Moscow |
payload |
string payload to send to target |