connection.proto
path mgmt/v1alpha1/connection.proto
package mgmt.v1alpha1
Messages
AwsS3ConnectionConfig
Name | Type | Description |
---|
bucket_arn | string | |
path_prefix | optional string | |
credentials | optional AwsS3Credentials | |
region | optional string | |
endpoint | optional string | |
bucket | string | |
AwsS3Credentials
S3 Credentials that are used by the worker process.
Note: this may be optionally provided if the worker that is being hosted has environment credentials to the S3 bucket instead.
Name | Type | Description |
---|
profile | optional string | |
access_key_id | optional string | |
secret_access_key | optional string | |
session_token | optional string | |
from_ec2_role | optional bool | |
role_arn | optional string | |
role_external_id | optional string | |
CheckConnectionConfigRequest
CheckConnectionConfigResponse
Name | Type | Description |
---|
is_connected | bool | Whether or not the API was able to ping the connection |
connection_error | optional string | This is the error that was received if the API was unable to connect |
CheckSqlQueryRequest
Name | Type | Description |
---|
id | string | The connection id that the query will be checked against |
query | string | The full query that will be run through a PREPARE statement |
CheckSqlQueryResponse
Name | Type | Description |
---|
is_valid | bool | The query is run through PREPARE. Returns valid if it correctly compiled |
erorr_message | optional string | The error message returned by the sql client if the prepare did not return successfully |
Connection
Name | Type | Description |
---|
id | string | |
name | string | |
connection_config | ConnectionConfig | |
created_by_user_id | string | |
created_at | google.protobuf.Timestamp | |
updated_by_user_id | string | |
updated_at | google.protobuf.Timestamp | |
account_id | string | |
ConnectionConfig
CreateConnectionRequest
Name | Type | Description |
---|
account_id | string | |
name | string | The friendly name of the connection |
connection_config | ConnectionConfig | |
CreateConnectionResponse
DeleteConnectionRequest
Name | Type | Description |
---|
id | string | |
DeleteConnectionResponse
GetConnectionRequest
Name | Type | Description |
---|
id | string | |
GetConnectionResponse
GetConnectionsRequest
Name | Type | Description |
---|
account_id | string | |
GetConnectionsResponse
IsConnectionNameAvailableRequest
Name | Type | Description |
---|
account_id | string | |
connection_name | string | |
IsConnectionNameAvailableResponse
Name | Type | Description |
---|
is_available | bool | |
MysqlConnection
Name | Type | Description |
---|
user | string | |
pass | string | |
protocol | string | |
host | string | |
port | int32 | |
name | string | |
MysqlConnectionConfig
PostgresConnection
Name | Type | Description |
---|
host | string | |
port | int32 | |
name | string | |
user | string | |
pass | string | |
ssl_mode | optional string | |
PostgresConnectionConfig
UpdateConnectionRequest
UpdateConnectionResponse
Services
ConnectionService
Service for managing datasource connections.
This is a primary data model in Neosync and is used in reference when hooking up Jobs to synchronize and generate data.
GetConnections
GetConnection
CreateConnection
UpdateConnection
DeleteConnection
IsConnectionNameAvailable
CheckConnectionConfig
CheckSqlQuery
Method | CheckSqlQuery |
---|
Request | CheckSqlQueryRequest |
---|
Response | CheckSqlQueryResponse |
---|
Description | Checks a constructed SQL query against a sql-based connection to see if it's valid based on that connection's data schema
This is useful when constructing subsets to see if the WHERE clause is correct |
---|