Variables
PrivateConnection_State_name, PrivateConnection_State_value
var (
PrivateConnection_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "CREATING",
2: "CREATED",
3: "FAILED",
4: "DELETING",
5: "FAILED_TO_DELETE",
}
PrivateConnection_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"CREATING": 1,
"CREATED": 2,
"FAILED": 3,
"DELETING": 4,
"FAILED_TO_DELETE": 5,
}
)Enum value maps for PrivateConnection_State.
JsonFileFormat_SchemaFileFormat_name, JsonFileFormat_SchemaFileFormat_value
var (
JsonFileFormat_SchemaFileFormat_name = map[int32]string{
0: "SCHEMA_FILE_FORMAT_UNSPECIFIED",
1: "NO_SCHEMA_FILE",
2: "AVRO_SCHEMA_FILE",
}
JsonFileFormat_SchemaFileFormat_value = map[string]int32{
"SCHEMA_FILE_FORMAT_UNSPECIFIED": 0,
"NO_SCHEMA_FILE": 1,
"AVRO_SCHEMA_FILE": 2,
}
)Enum value maps for JsonFileFormat_SchemaFileFormat.
JsonFileFormat_JsonCompression_name, JsonFileFormat_JsonCompression_value
var (
JsonFileFormat_JsonCompression_name = map[int32]string{
0: "JSON_COMPRESSION_UNSPECIFIED",
1: "NO_COMPRESSION",
2: "GZIP",
}
JsonFileFormat_JsonCompression_value = map[string]int32{
"JSON_COMPRESSION_UNSPECIFIED": 0,
"NO_COMPRESSION": 1,
"GZIP": 2,
}
)Enum value maps for JsonFileFormat_JsonCompression.
Stream_State_name, Stream_State_value
var (
Stream_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "NOT_STARTED",
2: "RUNNING",
3: "PAUSED",
4: "MAINTENANCE",
5: "FAILED",
6: "FAILED_PERMANENTLY",
7: "STARTING",
8: "DRAINING",
}
Stream_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"NOT_STARTED": 1,
"RUNNING": 2,
"PAUSED": 3,
"MAINTENANCE": 4,
"FAILED": 5,
"FAILED_PERMANENTLY": 6,
"STARTING": 7,
"DRAINING": 8,
}
)Enum value maps for Stream_State.
BackfillJob_State_name, BackfillJob_State_value
var (
BackfillJob_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "NOT_STARTED",
2: "PENDING",
3: "ACTIVE",
4: "STOPPED",
5: "FAILED",
6: "COMPLETED",
7: "UNSUPPORTED",
}
BackfillJob_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"NOT_STARTED": 1,
"PENDING": 2,
"ACTIVE": 3,
"STOPPED": 4,
"FAILED": 5,
"COMPLETED": 6,
"UNSUPPORTED": 7,
}
)Enum value maps for BackfillJob_State.
BackfillJob_Trigger_name, BackfillJob_Trigger_value
var (
BackfillJob_Trigger_name = map[int32]string{
0: "TRIGGER_UNSPECIFIED",
1: "AUTOMATIC",
2: "MANUAL",
}
BackfillJob_Trigger_value = map[string]int32{
"TRIGGER_UNSPECIFIED": 0,
"AUTOMATIC": 1,
"MANUAL": 2,
}
)Enum value maps for BackfillJob_Trigger.
Validation_State_name, Validation_State_value
var (
Validation_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "NOT_EXECUTED",
2: "FAILED",
3: "PASSED",
}
Validation_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"NOT_EXECUTED": 1,
"FAILED": 2,
"PASSED": 3,
}
)Enum value maps for Validation_State.
ValidationMessage_Level_name, ValidationMessage_Level_value
var (
ValidationMessage_Level_name = map[int32]string{
0: "LEVEL_UNSPECIFIED",
1: "WARNING",
2: "ERROR",
}
ValidationMessage_Level_value = map[string]int32{
"LEVEL_UNSPECIFIED": 0,
"WARNING": 1,
"ERROR": 2,
}
)Enum value maps for ValidationMessage_Level.
File_google_cloud_datastream_v1_datastream_proto
var File_google_cloud_datastream_v1_datastream_proto protoreflect.FileDescriptorFile_google_cloud_datastream_v1_datastream_resources_proto
var File_google_cloud_datastream_v1_datastream_resources_proto protoreflect.FileDescriptorFunctions
func RegisterDatastreamServer
func RegisterDatastreamServer(s *grpc.Server, srv DatastreamServer)AvroFileFormat
type AvroFileFormat struct {
// contains filtered or unexported fields
}AVRO file format configuration.
func (*AvroFileFormat) Descriptor
func (*AvroFileFormat) Descriptor() ([]byte, []int)Deprecated: Use AvroFileFormat.ProtoReflect.Descriptor instead.
func (*AvroFileFormat) ProtoMessage
func (*AvroFileFormat) ProtoMessage()func (*AvroFileFormat) ProtoReflect
func (x *AvroFileFormat) ProtoReflect() protoreflect.Messagefunc (*AvroFileFormat) Reset
func (x *AvroFileFormat) Reset()func (*AvroFileFormat) String
func (x *AvroFileFormat) String() stringBackfillJob
type BackfillJob struct {
// Backfill job state.
State BackfillJob_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.datastream.v1.BackfillJob_State" json:"state,omitempty"`
// Backfill job's triggering reason.
Trigger BackfillJob_Trigger `protobuf:"varint,2,opt,name=trigger,proto3,enum=google.cloud.datastream.v1.BackfillJob_Trigger" json:"trigger,omitempty"`
// Output only. Backfill job's start time.
LastStartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_start_time,json=lastStartTime,proto3" json:"last_start_time,omitempty"`
// Output only. Backfill job's end time.
LastEndTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_end_time,json=lastEndTime,proto3" json:"last_end_time,omitempty"`
// Output only. Errors which caused the backfill job to fail.
Errors []*Error `protobuf:"bytes,5,rep,name=errors,proto3" json:"errors,omitempty"`
// contains filtered or unexported fields
}Represents a backfill job on a specific stream object.
func (*BackfillJob) Descriptor
func (*BackfillJob) Descriptor() ([]byte, []int)Deprecated: Use BackfillJob.ProtoReflect.Descriptor instead.
func (*BackfillJob) GetErrors
func (x *BackfillJob) GetErrors() []*Errorfunc (*BackfillJob) GetLastEndTime
func (x *BackfillJob) GetLastEndTime() *timestamppb.Timestampfunc (*BackfillJob) GetLastStartTime
func (x *BackfillJob) GetLastStartTime() *timestamppb.Timestampfunc (*BackfillJob) GetState
func (x *BackfillJob) GetState() BackfillJob_Statefunc (*BackfillJob) GetTrigger
func (x *BackfillJob) GetTrigger() BackfillJob_Triggerfunc (*BackfillJob) ProtoMessage
func (*BackfillJob) ProtoMessage()func (*BackfillJob) ProtoReflect
func (x *BackfillJob) ProtoReflect() protoreflect.Messagefunc (*BackfillJob) Reset
func (x *BackfillJob) Reset()func (*BackfillJob) String
func (x *BackfillJob) String() stringBackfillJob_State
type BackfillJob_State int32State of the stream object's backfill job.
BackfillJob_STATE_UNSPECIFIED, BackfillJob_NOT_STARTED, BackfillJob_PENDING, BackfillJob_ACTIVE, BackfillJob_STOPPED, BackfillJob_FAILED, BackfillJob_COMPLETED, BackfillJob_UNSUPPORTED
const (
// Default value.
BackfillJob_STATE_UNSPECIFIED BackfillJob_State = 0
// Backfill job was never started for the stream object (stream has backfill
// strategy defined as manual or object was explicitly excluded from
// automatic backfill).
BackfillJob_NOT_STARTED BackfillJob_State = 1
// Backfill job will start pending available resources.
BackfillJob_PENDING BackfillJob_State = 2
// Backfill job is running.
BackfillJob_ACTIVE BackfillJob_State = 3
// Backfill job stopped (next job run will start from beginning).
BackfillJob_STOPPED BackfillJob_State = 4
// Backfill job failed (due to an error).
BackfillJob_FAILED BackfillJob_State = 5
// Backfill completed successfully.
BackfillJob_COMPLETED BackfillJob_State = 6
// Backfill job failed since the table structure is currently unsupported
// for backfill.
BackfillJob_UNSUPPORTED BackfillJob_State = 7
)func (BackfillJob_State) Descriptor
func (BackfillJob_State) Descriptor() protoreflect.EnumDescriptorfunc (BackfillJob_State) Enum
func (x BackfillJob_State) Enum() *BackfillJob_Statefunc (BackfillJob_State) EnumDescriptor
func (BackfillJob_State) EnumDescriptor() ([]byte, []int)Deprecated: Use BackfillJob_State.Descriptor instead.
func (BackfillJob_State) Number
func (x BackfillJob_State) Number() protoreflect.EnumNumberfunc (BackfillJob_State) String
func (x BackfillJob_State) String() stringfunc (BackfillJob_State) Type
func (BackfillJob_State) Type() protoreflect.EnumTypeBackfillJob_Trigger
type BackfillJob_Trigger int32Triggering reason for a backfill job.
BackfillJob_TRIGGER_UNSPECIFIED, BackfillJob_AUTOMATIC, BackfillJob_MANUAL
const (
// Default value.
BackfillJob_TRIGGER_UNSPECIFIED BackfillJob_Trigger = 0
// Object backfill job was triggered automatically according to the stream's
// backfill strategy.
BackfillJob_AUTOMATIC BackfillJob_Trigger = 1
// Object backfill job was triggered manually using the dedicated API.
BackfillJob_MANUAL BackfillJob_Trigger = 2
)func (BackfillJob_Trigger) Descriptor
func (BackfillJob_Trigger) Descriptor() protoreflect.EnumDescriptorfunc (BackfillJob_Trigger) Enum
func (x BackfillJob_Trigger) Enum() *BackfillJob_Triggerfunc (BackfillJob_Trigger) EnumDescriptor
func (BackfillJob_Trigger) EnumDescriptor() ([]byte, []int)Deprecated: Use BackfillJob_Trigger.Descriptor instead.
func (BackfillJob_Trigger) Number
func (x BackfillJob_Trigger) Number() protoreflect.EnumNumberfunc (BackfillJob_Trigger) String
func (x BackfillJob_Trigger) String() stringfunc (BackfillJob_Trigger) Type
func (BackfillJob_Trigger) Type() protoreflect.EnumTypeBigQueryDestinationConfig
type BigQueryDestinationConfig struct {
// Target dataset(s) configuration.
//
// Types that are assignable to DatasetConfig:
//
// *BigQueryDestinationConfig_SingleTargetDataset_
// *BigQueryDestinationConfig_SourceHierarchyDatasets_
DatasetConfig isBigQueryDestinationConfig_DatasetConfig `protobuf_oneof:"dataset_config"`
// The guaranteed data freshness (in seconds) when querying tables created by
// the stream. Editing this field will only affect new tables created in the
// future, but existing tables will not be impacted. Lower values mean that
// queries will return fresher data, but may result in higher cost.
DataFreshness *durationpb.Duration `protobuf:"bytes,300,opt,name=data_freshness,json=dataFreshness,proto3" json:"data_freshness,omitempty"`
// contains filtered or unexported fields
}BigQuery destination configuration
func (*BigQueryDestinationConfig) Descriptor
func (*BigQueryDestinationConfig) Descriptor() ([]byte, []int)Deprecated: Use BigQueryDestinationConfig.ProtoReflect.Descriptor instead.
func (*BigQueryDestinationConfig) GetDataFreshness
func (x *BigQueryDestinationConfig) GetDataFreshness() *durationpb.Durationfunc (*BigQueryDestinationConfig) GetDatasetConfig
func (m *BigQueryDestinationConfig) GetDatasetConfig() isBigQueryDestinationConfig_DatasetConfigfunc (*BigQueryDestinationConfig) GetSingleTargetDataset
func (x *BigQueryDestinationConfig) GetSingleTargetDataset() *BigQueryDestinationConfig_SingleTargetDatasetfunc (*BigQueryDestinationConfig) GetSourceHierarchyDatasets
func (x *BigQueryDestinationConfig) GetSourceHierarchyDatasets() *BigQueryDestinationConfig_SourceHierarchyDatasetsfunc (*BigQueryDestinationConfig) ProtoMessage
func (*BigQueryDestinationConfig) ProtoMessage()func (*BigQueryDestinationConfig) ProtoReflect
func (x *BigQueryDestinationConfig) ProtoReflect() protoreflect.Messagefunc (*BigQueryDestinationConfig) Reset
func (x *BigQueryDestinationConfig) Reset()func (*BigQueryDestinationConfig) String
func (x *BigQueryDestinationConfig) String() stringBigQueryDestinationConfig_SingleTargetDataset
type BigQueryDestinationConfig_SingleTargetDataset struct {
// The dataset ID of the target dataset.
DatasetId string `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
// contains filtered or unexported fields
}A single target dataset to which all data will be streamed.
func (*BigQueryDestinationConfig_SingleTargetDataset) Descriptor
func (*BigQueryDestinationConfig_SingleTargetDataset) Descriptor() ([]byte, []int)Deprecated: Use BigQueryDestinationConfig_SingleTargetDataset.ProtoReflect.Descriptor instead.
func (*BigQueryDestinationConfig_SingleTargetDataset) GetDatasetId
func (x *BigQueryDestinationConfig_SingleTargetDataset) GetDatasetId() stringfunc (*BigQueryDestinationConfig_SingleTargetDataset) ProtoMessage
func (*BigQueryDestinationConfig_SingleTargetDataset) ProtoMessage()func (*BigQueryDestinationConfig_SingleTargetDataset) ProtoReflect
func (x *BigQueryDestinationConfig_SingleTargetDataset) ProtoReflect() protoreflect.Messagefunc (*BigQueryDestinationConfig_SingleTargetDataset) Reset
func (x *BigQueryDestinationConfig_SingleTargetDataset) Reset()func (*BigQueryDestinationConfig_SingleTargetDataset) String
func (x *BigQueryDestinationConfig_SingleTargetDataset) String() stringBigQueryDestinationConfig_SingleTargetDataset_
type BigQueryDestinationConfig_SingleTargetDataset_ struct {
// Single destination dataset.
SingleTargetDataset *BigQueryDestinationConfig_SingleTargetDataset `protobuf:"bytes,201,opt,name=single_target_dataset,json=singleTargetDataset,proto3,oneof"`
}BigQueryDestinationConfig_SourceHierarchyDatasets
type BigQueryDestinationConfig_SourceHierarchyDatasets struct {
// The dataset template to use for dynamic dataset creation.
DatasetTemplate *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate `protobuf:"bytes,2,opt,name=dataset_template,json=datasetTemplate,proto3" json:"dataset_template,omitempty"`
// contains filtered or unexported fields
}Destination datasets are created so that hierarchy of the destination data objects matches the source hierarchy.
func (*BigQueryDestinationConfig_SourceHierarchyDatasets) Descriptor
func (*BigQueryDestinationConfig_SourceHierarchyDatasets) Descriptor() ([]byte, []int)Deprecated: Use BigQueryDestinationConfig_SourceHierarchyDatasets.ProtoReflect.Descriptor instead.
func (*BigQueryDestinationConfig_SourceHierarchyDatasets) GetDatasetTemplate
func (x *BigQueryDestinationConfig_SourceHierarchyDatasets) GetDatasetTemplate() *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplatefunc (*BigQueryDestinationConfig_SourceHierarchyDatasets) ProtoMessage
func (*BigQueryDestinationConfig_SourceHierarchyDatasets) ProtoMessage()func (*BigQueryDestinationConfig_SourceHierarchyDatasets) ProtoReflect
func (x *BigQueryDestinationConfig_SourceHierarchyDatasets) ProtoReflect() protoreflect.Messagefunc (*BigQueryDestinationConfig_SourceHierarchyDatasets) Reset
func (x *BigQueryDestinationConfig_SourceHierarchyDatasets) Reset()func (*BigQueryDestinationConfig_SourceHierarchyDatasets) String
func (x *BigQueryDestinationConfig_SourceHierarchyDatasets) String() stringBigQueryDestinationConfig_SourceHierarchyDatasets_
type BigQueryDestinationConfig_SourceHierarchyDatasets_ struct {
// Source hierarchy datasets.
SourceHierarchyDatasets *BigQueryDestinationConfig_SourceHierarchyDatasets `protobuf:"bytes,202,opt,name=source_hierarchy_datasets,json=sourceHierarchyDatasets,proto3,oneof"`
}BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate
type BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate struct {
// Required. The geographic location where the dataset should reside. See
// https://cloud.google.com/bigquery/docs/locations for supported
// locations.
Location string `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
// If supplied, every created dataset will have its name prefixed by the
// provided value. The prefix and name will be separated by an underscore.
// i.e. Dataset template used for dynamic dataset creation.
func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) Descriptor
func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) Descriptor() ([]byte, []int)Deprecated: Use BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate.ProtoReflect.Descriptor instead.
func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetDatasetIdPrefix
func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetDatasetIdPrefix() stringfunc (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetKmsKeyName
func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetKmsKeyName() stringfunc (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetLocation
func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetLocation() stringfunc (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) ProtoMessage
func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) ProtoMessage()func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) ProtoReflect
func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) ProtoReflect() protoreflect.Messagefunc (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) Reset
func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) Reset()func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) String
func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) String() stringBigQueryProfile
type BigQueryProfile struct {
// contains filtered or unexported fields
}BigQuery warehouse profile.
func (*BigQueryProfile) Descriptor
func (*BigQueryProfile) Descriptor() ([]byte, []int)Deprecated: Use BigQueryProfile.ProtoReflect.Descriptor instead.
func (*BigQueryProfile) ProtoMessage
func (*BigQueryProfile) ProtoMessage()func (*BigQueryProfile) ProtoReflect
func (x *BigQueryProfile) ProtoReflect() protoreflect.Messagefunc (*BigQueryProfile) Reset
func (x *BigQueryProfile) Reset()func (*BigQueryProfile) String
func (x *BigQueryProfile) String() stringConnectionProfile
type ConnectionProfile struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
Labels map[string]string "" /* 153 byte string literal not displayed */
DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
Profile isConnectionProfile_Profile `protobuf_oneof:"profile"`
Connectivity isConnectionProfile_Connectivity `protobuf_oneof:"connectivity"`
}A set of reusable connection configurations to be used as a source or destination for a stream.
func (*ConnectionProfile) Descriptor
func (*ConnectionProfile) Descriptor() ([]byte, []int)Deprecated: Use ConnectionProfile.ProtoReflect.Descriptor instead.
func (*ConnectionProfile) GetBigqueryProfile
func (x *ConnectionProfile) GetBigqueryProfile() *BigQueryProfilefunc (*ConnectionProfile) GetConnectivity
func (m *ConnectionProfile) GetConnectivity() isConnectionProfile_Connectivityfunc (*ConnectionProfile) GetCreateTime
func (x *ConnectionProfile) GetCreateTime() *timestamppb.Timestampfunc (*ConnectionProfile) GetDisplayName
func (x *ConnectionProfile) GetDisplayName() stringfunc (*ConnectionProfile) GetForwardSshConnectivity
func (x *ConnectionProfile) GetForwardSshConnectivity() *ForwardSshTunnelConnectivityfunc (*ConnectionProfile) GetGcsProfile
func (x *ConnectionProfile) GetGcsProfile() *GcsProfilefunc (*ConnectionProfile) GetLabels
func (x *ConnectionProfile) GetLabels() map[string]stringfunc (*ConnectionProfile) GetMysqlProfile
func (x *ConnectionProfile) GetMysqlProfile() *MysqlProfilefunc (*ConnectionProfile) GetName
func (x *ConnectionProfile) GetName() stringfunc (*ConnectionProfile) GetOracleProfile
func (x *ConnectionProfile) GetOracleProfile() *OracleProfilefunc (*ConnectionProfile) GetPostgresqlProfile
func (x *ConnectionProfile) GetPostgresqlProfile() *PostgresqlProfilefunc (*ConnectionProfile) GetPrivateConnectivity
func (x *ConnectionProfile) GetPrivateConnectivity() *PrivateConnectivityfunc (*ConnectionProfile) GetProfile
func (m *ConnectionProfile) GetProfile() isConnectionProfile_Profilefunc (*ConnectionProfile) GetStaticServiceIpConnectivity
func (x *ConnectionProfile) GetStaticServiceIpConnectivity() *StaticServiceIpConnectivityfunc (*ConnectionProfile) GetUpdateTime
func (x *ConnectionProfile) GetUpdateTime() *timestamppb.Timestampfunc (*ConnectionProfile) ProtoMessage
func (*ConnectionProfile) ProtoMessage()func (*ConnectionProfile) ProtoReflect
func (x *ConnectionProfile) ProtoReflect() protoreflect.Messagefunc (*ConnectionProfile) Reset
func (x *ConnectionProfile) Reset()func (*ConnectionProfile) String
func (x *ConnectionProfile) String() stringConnectionProfile_BigqueryProfile
type ConnectionProfile_BigqueryProfile struct {
// BigQuery Connection Profile configuration.
BigqueryProfile *BigQueryProfile `protobuf:"bytes,103,opt,name=bigquery_profile,json=bigqueryProfile,proto3,oneof"`
}ConnectionProfile_ForwardSshConnectivity
type ConnectionProfile_ForwardSshConnectivity struct {
// Forward SSH tunnel connectivity.
ForwardSshConnectivity *ForwardSshTunnelConnectivity `protobuf:"bytes,201,opt,name=forward_ssh_connectivity,json=forwardSshConnectivity,proto3,oneof"`
}ConnectionProfile_GcsProfile
type ConnectionProfile_GcsProfile struct {
// Cloud Storage ConnectionProfile configuration.
GcsProfile *GcsProfile `protobuf:"bytes,101,opt,name=gcs_profile,json=gcsProfile,proto3,oneof"`
}ConnectionProfile_MysqlProfile
type ConnectionProfile_MysqlProfile struct {
// MySQL ConnectionProfile configuration.
MysqlProfile *MysqlProfile `protobuf:"bytes,102,opt,name=mysql_profile,json=mysqlProfile,proto3,oneof"`
}ConnectionProfile_OracleProfile
type ConnectionProfile_OracleProfile struct {
// Oracle ConnectionProfile configuration.
OracleProfile *OracleProfile `protobuf:"bytes,100,opt,name=oracle_profile,json=oracleProfile,proto3,oneof"`
}ConnectionProfile_PostgresqlProfile
type ConnectionProfile_PostgresqlProfile struct {
// PostgreSQL Connection Profile configuration.
PostgresqlProfile *PostgresqlProfile `protobuf:"bytes,104,opt,name=postgresql_profile,json=postgresqlProfile,proto3,oneof"`
}ConnectionProfile_PrivateConnectivity
type ConnectionProfile_PrivateConnectivity struct {
// Private connectivity.
PrivateConnectivity *PrivateConnectivity `protobuf:"bytes,202,opt,name=private_connectivity,json=privateConnectivity,proto3,oneof"`
}ConnectionProfile_StaticServiceIpConnectivity
type ConnectionProfile_StaticServiceIpConnectivity struct {
// Static Service IP connectivity.
StaticServiceIpConnectivity *StaticServiceIpConnectivity `protobuf:"bytes,200,opt,name=static_service_ip_connectivity,json=staticServiceIpConnectivity,proto3,oneof"`
}CreateConnectionProfileRequest
type CreateConnectionProfileRequest struct {
// Required. The parent that owns the collection of ConnectionProfiles.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The connection profile identifier.
ConnectionProfileId string `protobuf:"bytes,2,opt,name=connection_profile_id,json=connectionProfileId,proto3" json:"connection_profile_id,omitempty"`
// Required. The connection profile resource to create.
ConnectionProfile *ConnectionProfile `protobuf:"bytes,3,opt,name=connection_profile,json=connectionProfile,proto3" json:"connection_profile,omitempty"`
// Optional. A request ID to identify requests. Specify a unique request ID
// so that if you must retry your request, the server will know to ignore
// the request if it has already been completed. The server will guarantee
// that for at least 60 minutes since the first request.
//
// For example, consider a situation where you make an initial request and the
// request times out. If you make the request again with the same request ID,
// the server can check if original operation with the same request ID was
// received, and if so, will ignore the second request. This prevents clients
// from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// Optional. Only validate the connection profile, but don't create any
// resources. The default is false.
ValidateOnly bool `protobuf:"varint,5,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
// Optional. Create the connection profile without validating it.
Force bool `protobuf:"varint,6,opt,name=force,proto3" json:"force,omitempty"`
// contains filtered or unexported fields
}Request message for creating a connection profile.
func (*CreateConnectionProfileRequest) Descriptor
func (*CreateConnectionProfileRequest) Descriptor() ([]byte, []int)Deprecated: Use CreateConnectionProfileRequest.ProtoReflect.Descriptor instead.
func (*CreateConnectionProfileRequest) GetConnectionProfile
func (x *CreateConnectionProfileRequest) GetConnectionProfile() *ConnectionProfilefunc (*CreateConnectionProfileRequest) GetConnectionProfileId
func (x *CreateConnectionProfileRequest) GetConnectionProfileId() stringfunc (*CreateConnectionProfileRequest) GetForce
func (x *CreateConnectionProfileRequest) GetForce() boolfunc (*CreateConnectionProfileRequest) GetParent
func (x *CreateConnectionProfileRequest) GetParent() stringfunc (*CreateConnectionProfileRequest) GetRequestId
func (x *CreateConnectionProfileRequest) GetRequestId() stringfunc (*CreateConnectionProfileRequest) GetValidateOnly
func (x *CreateConnectionProfileRequest) GetValidateOnly() boolfunc (*CreateConnectionProfileRequest) ProtoMessage
func (*CreateConnectionProfileRequest) ProtoMessage()func (*CreateConnectionProfileRequest) ProtoReflect
func (x *CreateConnectionProfileRequest) ProtoReflect() protoreflect.Messagefunc (*CreateConnectionProfileRequest) Reset
func (x *CreateConnectionProfileRequest) Reset()func (*CreateConnectionProfileRequest) String
func (x *CreateConnectionProfileRequest) String() stringCreatePrivateConnectionRequest
type CreatePrivateConnectionRequest struct {
// Required. The parent that owns the collection of PrivateConnections.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The private connectivity identifier.
PrivateConnectionId string `protobuf:"bytes,2,opt,name=private_connection_id,json=privateConnectionId,proto3" json:"private_connection_id,omitempty"`
// Required. The Private Connectivity resource to create.
PrivateConnection *PrivateConnection `protobuf:"bytes,3,opt,name=private_connection,json=privateConnection,proto3" json:"private_connection,omitempty"`
// Optional. A request ID to identify requests. Specify a unique request ID
// so that if you must retry your request, the server will know to ignore
// the request if it has already been completed. The server will guarantee
// that for at least 60 minutes since the first request.
//
// For example, consider a situation where you make an initial request and the
// request times out. If you make the request again with the same request ID,
// the server can check if original operation with the same request ID was
// received, and if so, will ignore the second request. This prevents clients
// from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// Optional. If set to true, will skip validations.
Force bool `protobuf:"varint,6,opt,name=force,proto3" json:"force,omitempty"`
// contains filtered or unexported fields
}Request for creating a private connection.
func (*CreatePrivateConnectionRequest) Descriptor
func (*CreatePrivateConnectionRequest) Descriptor() ([]byte, []int)Deprecated: Use CreatePrivateConnectionRequest.ProtoReflect.Descriptor instead.
func (*CreatePrivateConnectionRequest) GetForce
func (x *CreatePrivateConnectionRequest) GetForce() boolfunc (*CreatePrivateConnectionRequest) GetParent
func (x *CreatePrivateConnectionRequest) GetParent() stringfunc (*CreatePrivateConnectionRequest) GetPrivateConnection
func (x *CreatePrivateConnectionRequest) GetPrivateConnection() *PrivateConnectionfunc (*CreatePrivateConnectionRequest) GetPrivateConnectionId
func (x *CreatePrivateConnectionRequest) GetPrivateConnectionId() stringfunc (*CreatePrivateConnectionRequest) GetRequestId
func (x *CreatePrivateConnectionRequest) GetRequestId() stringfunc (*CreatePrivateConnectionRequest) ProtoMessage
func (*CreatePrivateConnectionRequest) ProtoMessage()func (*CreatePrivateConnectionRequest) ProtoReflect
func (x *CreatePrivateConnectionRequest) ProtoReflect() protoreflect.Messagefunc (*CreatePrivateConnectionRequest) Reset
func (x *CreatePrivateConnectionRequest) Reset()func (*CreatePrivateConnectionRequest) String
func (x *CreatePrivateConnectionRequest) String() stringCreateRouteRequest
type CreateRouteRequest struct {
// Required. The parent that owns the collection of Routes.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The Route identifier.
RouteId string `protobuf:"bytes,2,opt,name=route_id,json=routeId,proto3" json:"route_id,omitempty"`
// Required. The Route resource to create.
Route *Route `protobuf:"bytes,3,opt,name=route,proto3" json:"route,omitempty"`
// Optional. A request ID to identify requests. Specify a unique request ID
// so that if you must retry your request, the server will know to ignore
// the request if it has already been completed. The server will guarantee
// that for at least 60 minutes since the first request.
//
// For example, consider a situation where you make an initial request and the
// request times out. If you make the request again with the same request ID,
// the server can check if original operation with the same request ID was
// received, and if so, will ignore the second request. This prevents clients
// from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}Route creation request.
func (*CreateRouteRequest) Descriptor
func (*CreateRouteRequest) Descriptor() ([]byte, []int)Deprecated: Use CreateRouteRequest.ProtoReflect.Descriptor instead.
func (*CreateRouteRequest) GetParent
func (x *CreateRouteRequest) GetParent() stringfunc (*CreateRouteRequest) GetRequestId
func (x *CreateRouteRequest) GetRequestId() stringfunc (*CreateRouteRequest) GetRoute
func (x *CreateRouteRequest) GetRoute() *Routefunc (*CreateRouteRequest) GetRouteId
func (x *CreateRouteRequest) GetRouteId() stringfunc (*CreateRouteRequest) ProtoMessage
func (*CreateRouteRequest) ProtoMessage()func (*CreateRouteRequest) ProtoReflect
func (x *CreateRouteRequest) ProtoReflect() protoreflect.Messagefunc (*CreateRouteRequest) Reset
func (x *CreateRouteRequest) Reset()func (*CreateRouteRequest) String
func (x *CreateRouteRequest) String() stringCreateStreamRequest
type CreateStreamRequest struct {
// Required. The parent that owns the collection of streams.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The stream identifier.
StreamId string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
// Required. The stream resource to create.
Stream *Stream `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"`
// Optional. A request ID to identify requests. Specify a unique request ID
// so that if you must retry your request, the server will know to ignore
// the request if it has already been completed. The server will guarantee
// that for at least 60 minutes since the first request.
//
// For example, consider a situation where you make an initial request and the
// request times out. If you make the request again with the same request ID,
// the server can check if original operation with the same request ID was
// received, and if so, will ignore the second request. This prevents clients
// from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// Optional. Only validate the stream, but don't create any resources.
// The default is false.
ValidateOnly bool `protobuf:"varint,5,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
// Optional. Create the stream without validating it.
Force bool `protobuf:"varint,6,opt,name=force,proto3" json:"force,omitempty"`
// contains filtered or unexported fields
}Request message for creating a stream.
func (*CreateStreamRequest) Descriptor
func (*CreateStreamRequest) Descriptor() ([]byte, []int)Deprecated: Use CreateStreamRequest.ProtoReflect.Descriptor instead.
func (*CreateStreamRequest) GetForce
func (x *CreateStreamRequest) GetForce() boolfunc (*CreateStreamRequest) GetParent
func (x *CreateStreamRequest) GetParent() stringfunc (*CreateStreamRequest) GetRequestId
func (x *CreateStreamRequest) GetRequestId() stringfunc (*CreateStreamRequest) GetStream
func (x *CreateStreamRequest) GetStream() *Streamfunc (*CreateStreamRequest) GetStreamId
func (x *CreateStreamRequest) GetStreamId() stringfunc (*CreateStreamRequest) GetValidateOnly
func (x *CreateStreamRequest) GetValidateOnly() boolfunc (*CreateStreamRequest) ProtoMessage
func (*CreateStreamRequest) ProtoMessage()func (*CreateStreamRequest) ProtoReflect
func (x *CreateStreamRequest) ProtoReflect() protoreflect.Messagefunc (*CreateStreamRequest) Reset
func (x *CreateStreamRequest) Reset()func (*CreateStreamRequest) String
func (x *CreateStreamRequest) String() stringDatastreamClient
type DatastreamClient interface {
// Use this method to list connection profiles created in a project and
// location.
ListConnectionProfiles(ctx context.Context, in *ListConnectionProfilesRequest, opts ...grpc.CallOption) (*ListConnectionProfilesResponse, error)
// Use this method to get details about a connection profile.
GetConnectionProfile(ctx context.Context, in *GetConnectionProfileRequest, opts ...grpc.CallOption) (*ConnectionProfile, error)
// Use this method to create a connection profile in a project and location.
CreateConnectionProfile(ctx context.Context, in *CreateConnectionProfileRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Use this method to update the parameters of a connection profile.
UpdateConnectionProfile(ctx context.Context, in *UpdateConnectionProfileRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Use this method to delete a connection profile.
DeleteConnectionProfile(ctx context.Context, in *DeleteConnectionProfileRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Use this method to discover a connection profile.
// The discover API call exposes the data objects and metadata belonging to
// the profile. Typically, a request returns children data objects of a
// parent data object that's optionally supplied in the request.
DiscoverConnectionProfile(ctx context.Context, in *DiscoverConnectionProfileRequest, opts ...grpc.CallOption) (*DiscoverConnectionProfileResponse, error)
// Use this method to list streams in a project and location.
ListStreams(ctx context.Context, in *ListStreamsRequest, opts ...grpc.CallOption) (*ListStreamsResponse, error)
// Use this method to get details about a stream.
GetStream(ctx context.Context, in *GetStreamRequest, opts ...grpc.CallOption) (*Stream, error)
// Use this method to create a stream.
CreateStream(ctx context.Context, in *CreateStreamRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Use this method to update the configuration of a stream.
UpdateStream(ctx context.Context, in *UpdateStreamRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Use this method to delete a stream.
DeleteStream(ctx context.Context, in *DeleteStreamRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Use this method to get details about a stream object.
GetStreamObject(ctx context.Context, in *GetStreamObjectRequest, opts ...grpc.CallOption) (*StreamObject, error)
// Use this method to look up a stream object by its source object identifier.
LookupStreamObject(ctx context.Context, in *LookupStreamObjectRequest, opts ...grpc.CallOption) (*StreamObject, error)
// Use this method to list the objects of a specific stream.
ListStreamObjects(ctx context.Context, in *ListStreamObjectsRequest, opts ...grpc.CallOption) (*ListStreamObjectsResponse, error)
// Use this method to start a backfill job for the specified stream object.
StartBackfillJob(ctx context.Context, in *StartBackfillJobRequest, opts ...grpc.CallOption) (*StartBackfillJobResponse, error)
// Use this method to stop a backfill job for the specified stream object.
StopBackfillJob(ctx context.Context, in *StopBackfillJobRequest, opts ...grpc.CallOption) (*StopBackfillJobResponse, error)
// The FetchStaticIps API call exposes the static IP addresses used by
// Datastream.
FetchStaticIps(ctx context.Context, in *FetchStaticIpsRequest, opts ...grpc.CallOption) (*FetchStaticIpsResponse, error)
// Use this method to create a private connectivity configuration.
CreatePrivateConnection(ctx context.Context, in *CreatePrivateConnectionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Use this method to get details about a private connectivity configuration.
GetPrivateConnection(ctx context.Context, in *GetPrivateConnectionRequest, opts ...grpc.CallOption) (*PrivateConnection, error)
// Use this method to list private connectivity configurations in a project
// and location.
ListPrivateConnections(ctx context.Context, in *ListPrivateConnectionsRequest, opts ...grpc.CallOption) (*ListPrivateConnectionsResponse, error)
// Use this method to delete a private connectivity configuration.
DeletePrivateConnection(ctx context.Context, in *DeletePrivateConnectionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Use this method to create a route for a private connectivity configuration
// in a project and location.
CreateRoute(ctx context.Context, in *CreateRouteRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Use this method to get details about a route.
GetRoute(ctx context.Context, in *GetRouteRequest, opts ...grpc.CallOption) (*Route, error)
// Use this method to list routes created for a private connectivity
// configuration in a project and location.
ListRoutes(ctx context.Context, in *ListRoutesRequest, opts ...grpc.CallOption) (*ListRoutesResponse, error)
// Use this method to delete a route.
DeleteRoute(ctx context.Context, in *DeleteRouteRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
}DatastreamClient is the client API for Datastream service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDatastreamClient
func NewDatastreamClient(cc grpc.ClientConnInterface) DatastreamClientDatastreamServer
type DatastreamServer interface {
// Use this method to list connection profiles created in a project and
// location.
ListConnectionProfiles(context.Context, *ListConnectionProfilesRequest) (*ListConnectionProfilesResponse, error)
// Use this method to get details about a connection profile.
GetConnectionProfile(context.Context, *GetConnectionProfileRequest) (*ConnectionProfile, error)
// Use this method to create a connection profile in a project and location.
CreateConnectionProfile(context.Context, *CreateConnectionProfileRequest) (*longrunningpb.Operation, error)
// Use this method to update the parameters of a connection profile.
UpdateConnectionProfile(context.Context, *UpdateConnectionProfileRequest) (*longrunningpb.Operation, error)
// Use this method to delete a connection profile.
DeleteConnectionProfile(context.Context, *DeleteConnectionProfileRequest) (*longrunningpb.Operation, error)
// Use this method to discover a connection profile.
// The discover API call exposes the data objects and metadata belonging to
// the profile. Typically, a request returns children data objects of a
// parent data object that's optionally supplied in the request.
DiscoverConnectionProfile(context.Context, *DiscoverConnectionProfileRequest) (*DiscoverConnectionProfileResponse, error)
// Use this method to list streams in a project and location.
ListStreams(context.Context, *ListStreamsRequest) (*ListStreamsResponse, error)
// Use this method to get details about a stream.
GetStream(context.Context, *GetStreamRequest) (*Stream, error)
// Use this method to create a stream.
CreateStream(context.Context, *CreateStreamRequest) (*longrunningpb.Operation, error)
// Use this method to update the configuration of a stream.
UpdateStream(context.Context, *UpdateStreamRequest) (*longrunningpb.Operation, error)
// Use this method to delete a stream.
DeleteStream(context.Context, *DeleteStreamRequest) (*longrunningpb.Operation, error)
// Use this method to get details about a stream object.
GetStreamObject(context.Context, *GetStreamObjectRequest) (*StreamObject, error)
// Use this method to look up a stream object by its source object identifier.
LookupStreamObject(context.Context, *LookupStreamObjectRequest) (*StreamObject, error)
// Use this method to list the objects of a specific stream.
ListStreamObjects(context.Context, *ListStreamObjectsRequest) (*ListStreamObjectsResponse, error)
// Use this method to start a backfill job for the specified stream object.
StartBackfillJob(context.Context, *StartBackfillJobRequest) (*StartBackfillJobResponse, error)
// Use this method to stop a backfill job for the specified stream object.
StopBackfillJob(context.Context, *StopBackfillJobRequest) (*StopBackfillJobResponse, error)
// The FetchStaticIps API call exposes the static IP addresses used by
// Datastream.
FetchStaticIps(context.Context, *FetchStaticIpsRequest) (*FetchStaticIpsResponse, error)
// Use this method to create a private connectivity configuration.
CreatePrivateConnection(context.Context, *CreatePrivateConnectionRequest) (*longrunningpb.Operation, error)
// Use this method to get details about a private connectivity configuration.
GetPrivateConnection(context.Context, *GetPrivateConnectionRequest) (*PrivateConnection, error)
// Use this method to list private connectivity configurations in a project
// and location.
ListPrivateConnections(context.Context, *ListPrivateConnectionsRequest) (*ListPrivateConnectionsResponse, error)
// Use this method to delete a private connectivity configuration.
DeletePrivateConnection(context.Context, *DeletePrivateConnectionRequest) (*longrunningpb.Operation, error)
// Use this method to create a route for a private connectivity configuration
// in a project and location.
CreateRoute(context.Context, *CreateRouteRequest) (*longrunningpb.Operation, error)
// Use this method to get details about a route.
GetRoute(context.Context, *GetRouteRequest) (*Route, error)
// Use this method to list routes created for a private connectivity
// configuration in a project and location.
ListRoutes(context.Context, *ListRoutesRequest) (*ListRoutesResponse, error)
// Use this method to delete a route.
DeleteRoute(context.Context, *DeleteRouteRequest) (*longrunningpb.Operation, error)
}DatastreamServer is the server API for Datastream service.
DeleteConnectionProfileRequest
type DeleteConnectionProfileRequest struct {
// Required. The name of the connection profile resource to delete.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Optional. A request ID to identify requests. Specify a unique request ID
// so that if you must retry your request, the server will know to ignore
// the request if it has already been completed. The server will guarantee
// that for at least 60 minutes after the first request.
//
// For example, consider a situation where you make an initial request and the
// request times out. If you make the request again with the same request ID,
// the server can check if original operation with the same request ID was
// received, and if so, will ignore the second request. This prevents clients
// from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}Request message for deleting a connection profile.
func (*DeleteConnectionProfileRequest) Descriptor
func (*DeleteConnectionProfileRequest) Descriptor() ([]byte, []int)Deprecated: Use DeleteConnectionProfileRequest.ProtoReflect.Descriptor instead.
func (*DeleteConnectionProfileRequest) GetName
func (x *DeleteConnectionProfileRequest) GetName() stringfunc (*DeleteConnectionProfileRequest) GetRequestId
func (x *DeleteConnectionProfileRequest) GetRequestId() stringfunc (*DeleteConnectionProfileRequest) ProtoMessage
func (*DeleteConnectionProfileRequest) ProtoMessage()func (*DeleteConnectionProfileRequest) ProtoReflect
func (x *DeleteConnectionProfileRequest) ProtoReflect() protoreflect.Messagefunc (*DeleteConnectionProfileRequest) Reset
func (x *DeleteConnectionProfileRequest) Reset()func (*DeleteConnectionProfileRequest) String
func (x *DeleteConnectionProfileRequest) String() stringDeletePrivateConnectionRequest
type DeletePrivateConnectionRequest struct {
// Required. The name of the private connectivity configuration to delete.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Optional. A request ID to identify requests. Specify a unique request ID
// so that if you must retry your request, the server will know to ignore
// the request if it has already been completed. The server will guarantee
// that for at least 60 minutes after the first request.
//
// For example, consider a situation where you make an initial request and the
// request times out. If you make the request again with the same request ID,
// the server can check if original operation with the same request ID was
// received, and if so, will ignore the second request. This prevents clients
// from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// Optional. If set to true, any child routes that belong to this
// PrivateConnection will also be deleted.
Force bool `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
// contains filtered or unexported fields
}Request to delete a private connection.
func (*DeletePrivateConnectionRequest) Descriptor
func (*DeletePrivateConnectionRequest) Descriptor() ([]byte, []int)Deprecated: Use DeletePrivateConnectionRequest.ProtoReflect.Descriptor instead.
func (*DeletePrivateConnectionRequest) GetForce
func (x *DeletePrivateConnectionRequest) GetForce() boolfunc (*DeletePrivateConnectionRequest) GetName
func (x *DeletePrivateConnectionRequest) GetName() stringfunc (*DeletePrivateConnectionRequest) GetRequestId
func (x *DeletePrivateConnectionRequest) GetRequestId() stringfunc (*DeletePrivateConnectionRequest) ProtoMessage
func (*DeletePrivateConnectionRequest) ProtoMessage()func (*DeletePrivateConnectionRequest) ProtoReflect
func (x *DeletePrivateConnectionRequest) ProtoReflect() protoreflect.Messagefunc (*DeletePrivateConnectionRequest) Reset
func (x *DeletePrivateConnectionRequest) Reset()func (*DeletePrivateConnectionRequest) String
func (x *DeletePrivateConnectionRequest) String() stringDeleteRouteRequest
type DeleteRouteRequest struct {
// Required. The name of the Route resource to delete.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Optional. A request ID to identify requests. Specify a unique request ID
// so that if you must retry your request, the server will know to ignore
// the request if it has already been completed. The server will guarantee
// that for at least 60 minutes after the first request.
//
// For example, consider a situation where you make an initial request and the
// request times out. If you make the request again with the same request ID,
// the server can check if original operation with the same request ID was
// received, and if so, will ignore the second request. This prevents clients
// from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}Route deletion request.
func (*DeleteRouteRequest) Descriptor
func (*DeleteRouteRequest) Descriptor() ([]byte, []int)Deprecated: Use DeleteRouteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRouteRequest) GetName
func (x *DeleteRouteRequest) GetName() stringfunc (*DeleteRouteRequest) GetRequestId
func (x *DeleteRouteRequest) GetRequestId() stringfunc (*DeleteRouteRequest) ProtoMessage
func (*DeleteRouteRequest) ProtoMessage()func (*DeleteRouteRequest) ProtoReflect
func (x *DeleteRouteRequest) ProtoReflect() protoreflect.Messagefunc (*DeleteRouteRequest) Reset
func (x *DeleteRouteRequest) Reset()func (*DeleteRouteRequest) String
func (x *DeleteRouteRequest) String() stringDeleteStreamRequest
type DeleteStreamRequest struct {
// Required. The name of the stream resource to delete.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Optional. A request ID to identify requests. Specify a unique request ID
// so that if you must retry your request, the server will know to ignore
// the request if it has already been completed. The server will guarantee
// that for at least 60 minutes after the first request.
//
// For example, consider a situation where you make an initial request and the
// request times out. If you make the request again with the same request ID,
// the server can check if original operation with the same request ID was
// received, and if so, will ignore the second request. This prevents clients
// from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}Request message for deleting a stream.
func (*DeleteStreamRequest) Descriptor
func (*DeleteStreamRequest) Descriptor() ([]byte, []int)Deprecated: Use DeleteStreamRequest.ProtoReflect.Descriptor instead.
func (*DeleteStreamRequest) GetName
func (x *DeleteStreamRequest) GetName() stringfunc (*DeleteStreamRequest) GetRequestId
func (x *DeleteStreamRequest) GetRequestId() stringfunc (*DeleteStreamRequest) ProtoMessage
func (*DeleteStreamRequest) ProtoMessage()func (*DeleteStreamRequest) ProtoReflect
func (x *DeleteStreamRequest) ProtoReflect() protoreflect.Messagefunc (*DeleteStreamRequest) Reset
func (x *DeleteStreamRequest) Reset()func (*DeleteStreamRequest) String
func (x *DeleteStreamRequest) String() stringDestinationConfig
type DestinationConfig struct {
DestinationConnectionProfile string "" /* 147 byte string literal not displayed */
DestinationStreamConfig isDestinationConfig_DestinationStreamConfig `protobuf_oneof:"destination_stream_config"`
}The configuration of the stream destination.
func (*DestinationConfig) Descriptor
func (*DestinationConfig) Descriptor() ([]byte, []int)Deprecated: Use DestinationConfig.ProtoReflect.Descriptor instead.
func (*DestinationConfig) GetBigqueryDestinationConfig
func (x *DestinationConfig) GetBigqueryDestinationConfig() *BigQueryDestinationConfigfunc (*DestinationConfig) GetDestinationConnectionProfile
func (x *DestinationConfig) GetDestinationConnectionProfile() stringfunc (*DestinationConfig) GetDestinationStreamConfig
func (m *DestinationConfig) GetDestinationStreamConfig() isDestinationConfig_DestinationStreamConfigfunc (*DestinationConfig) GetGcsDestinationConfig
func (x *DestinationConfig) GetGcsDestinationConfig() *GcsDestinationConfigfunc (*DestinationConfig) ProtoMessage
func (*DestinationConfig) ProtoMessage()func (*DestinationConfig) ProtoReflect
func (x *DestinationConfig) ProtoReflect() protoreflect.Messagefunc (*DestinationConfig) Reset
func (x *DestinationConfig) Reset()func (*DestinationConfig) String
func (x *DestinationConfig) String() stringDestinationConfig_BigqueryDestinationConfig
type DestinationConfig_BigqueryDestinationConfig struct {
// BigQuery destination configuration.
BigqueryDestinationConfig *BigQueryDestinationConfig `protobuf:"bytes,101,opt,name=bigquery_destination_config,json=bigqueryDestinationConfig,proto3,oneof"`
}DestinationConfig_GcsDestinationConfig
type DestinationConfig_GcsDestinationConfig struct {
// A configuration for how data should be loaded to Cloud Storage.
GcsDestinationConfig *GcsDestinationConfig `protobuf:"bytes,100,opt,name=gcs_destination_config,json=gcsDestinationConfig,proto3,oneof"`
}DiscoverConnectionProfileRequest
type DiscoverConnectionProfileRequest struct {
// Required. The parent resource of the connection profile type. Must be in
// the format `projects/*/locations/*`.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The connection profile on which to run discover.
//
// Types that are assignable to Target:
//
// *DiscoverConnectionProfileRequest_ConnectionProfile
// *DiscoverConnectionProfileRequest_ConnectionProfileName
Target isDiscoverConnectionProfileRequest_Target `protobuf_oneof:"target"`
// The depth of the retrieved hierarchy of data objects.
//
// Types that are assignable to Hierarchy:
//
// *DiscoverConnectionProfileRequest_FullHierarchy
// *DiscoverConnectionProfileRequest_HierarchyDepth
Hierarchy isDiscoverConnectionProfileRequest_Hierarchy `protobuf_oneof:"hierarchy"`
// The data object to populate with child data objects and metadata.
//
// Types that are assignable to DataObject:
//
// *DiscoverConnectionProfileRequest_OracleRdbms
// *DiscoverConnectionProfileRequest_MysqlRdbms
// *DiscoverConnectionProfileRequest_PostgresqlRdbms
DataObject isDiscoverConnectionProfileRequest_DataObject `protobuf_oneof:"data_object"`
// contains filtered or unexported fields
}Request message for 'discover' ConnectionProfile request.
func (*DiscoverConnectionProfileRequest) Descriptor
func (*DiscoverConnectionProfileRequest) Descriptor() ([]byte, []int)Deprecated: Use DiscoverConnectionProfileRequest.ProtoReflect.Descriptor instead.
func (*DiscoverConnectionProfileRequest) GetConnectionProfile
func (x *DiscoverConnectionProfileRequest) GetConnectionProfile() *ConnectionProfilefunc (*DiscoverConnectionProfileRequest) GetConnectionProfileName
func (x *DiscoverConnectionProfileRequest) GetConnectionProfileName() stringfunc (*DiscoverConnectionProfileRequest) GetDataObject
func (m *DiscoverConnectionProfileRequest) GetDataObject() isDiscoverConnectionProfileRequest_DataObjectfunc (*DiscoverConnectionProfileRequest) GetFullHierarchy
func (x *DiscoverConnectionProfileRequest) GetFullHierarchy() boolfunc (*DiscoverConnectionProfileRequest) GetHierarchy
func (m *DiscoverConnectionProfileRequest) GetHierarchy() isDiscoverConnectionProfileRequest_Hierarchyfunc (*DiscoverConnectionProfileRequest) GetHierarchyDepth
func (x *DiscoverConnectionProfileRequest) GetHierarchyDepth() int32func (*DiscoverConnectionProfileRequest) GetMysqlRdbms
func (x *DiscoverConnectionProfileRequest) GetMysqlRdbms() *MysqlRdbmsfunc (*DiscoverConnectionProfileRequest) GetOracleRdbms
func (x *DiscoverConnectionProfileRequest) GetOracleRdbms() *OracleRdbmsfunc (*DiscoverConnectionProfileRequest) GetParent
func (x *DiscoverConnectionProfileRequest) GetParent() stringfunc (*DiscoverConnectionProfileRequest) GetPostgresqlRdbms
func (x *DiscoverConnectionProfileRequest) GetPostgresqlRdbms() *PostgresqlRdbmsfunc (*DiscoverConnectionProfileRequest) GetTarget
func (m *DiscoverConnectionProfileRequest) GetTarget() isDiscoverConnectionProfileRequest_Targetfunc (*DiscoverConnectionProfileRequest) ProtoMessage
func (*DiscoverConnectionProfileRequest) ProtoMessage()func (*DiscoverConnectionProfileRequest) ProtoReflect
func (x *DiscoverConnectionProfileRequest) ProtoReflect() protoreflect.Messagefunc (*DiscoverConnectionProfileRequest) Reset
func (x *DiscoverConnectionProfileRequest) Reset()func (*DiscoverConnectionProfileRequest) String
func (x *DiscoverConnectionProfileRequest) String() stringDiscoverConnectionProfileRequest_ConnectionProfile
type DiscoverConnectionProfileRequest_ConnectionProfile struct {
// An ad-hoc connection profile configuration.
ConnectionProfile *ConnectionProfile `protobuf:"bytes,200,opt,name=connection_profile,json=connectionProfile,proto3,oneof"`
}DiscoverConnectionProfileRequest_ConnectionProfileName
type DiscoverConnectionProfileRequest_ConnectionProfileName struct {
// A reference to an existing connection profile.
ConnectionProfileName string `protobuf:"bytes,201,opt,name=connection_profile_name,json=connectionProfileName,proto3,oneof"`
}DiscoverConnectionProfileRequest_FullHierarchy
type DiscoverConnectionProfileRequest_FullHierarchy struct {
// Whether to retrieve the full hierarchy of data objects (TRUE) or only the
// current level (FALSE).
FullHierarchy bool `protobuf:"varint,3,opt,name=full_hierarchy,json=fullHierarchy,proto3,oneof"`
}DiscoverConnectionProfileRequest_HierarchyDepth
type DiscoverConnectionProfileRequest_HierarchyDepth struct {
// The number of hierarchy levels below the current level to be retrieved.
HierarchyDepth int32 `protobuf:"varint,4,opt,name=hierarchy_depth,json=hierarchyDepth,proto3,oneof"`
}DiscoverConnectionProfileRequest_MysqlRdbms
type DiscoverConnectionProfileRequest_MysqlRdbms struct {
// MySQL RDBMS to enrich with child data objects and metadata.
MysqlRdbms *MysqlRdbms `protobuf:"bytes,101,opt,name=mysql_rdbms,json=mysqlRdbms,proto3,oneof"`
}DiscoverConnectionProfileRequest_OracleRdbms
type DiscoverConnectionProfileRequest_OracleRdbms struct {
// Oracle RDBMS to enrich with child data objects and metadata.
OracleRdbms *OracleRdbms `protobuf:"bytes,100,opt,name=oracle_rdbms,json=oracleRdbms,proto3,oneof"`
}DiscoverConnectionProfileRequest_PostgresqlRdbms
type DiscoverConnectionProfileRequest_PostgresqlRdbms struct {
// PostgreSQL RDBMS to enrich with child data objects and metadata.
PostgresqlRdbms *PostgresqlRdbms `protobuf:"bytes,102,opt,name=postgresql_rdbms,json=postgresqlRdbms,proto3,oneof"`
}DiscoverConnectionProfileResponse
type DiscoverConnectionProfileResponse struct {
// The data object that has been enriched by the discover API call.
//
// Types that are assignable to DataObject:
//
// *DiscoverConnectionProfileResponse_OracleRdbms
// *DiscoverConnectionProfileResponse_MysqlRdbms
// *DiscoverConnectionProfileResponse_PostgresqlRdbms
DataObject isDiscoverConnectionProfileResponse_DataObject `protobuf_oneof:"data_object"`
// contains filtered or unexported fields
}Response from a discover request.
func (*DiscoverConnectionProfileResponse) Descriptor
func (*DiscoverConnectionProfileResponse) Descriptor() ([]byte, []int)Deprecated: Use DiscoverConnectionProfileResponse.ProtoReflect.Descriptor instead.
func (*DiscoverConnectionProfileResponse) GetDataObject
func (m *DiscoverConnectionProfileResponse) GetDataObject() isDiscoverConnectionProfileResponse_DataObjectfunc (*DiscoverConnectionProfileResponse) GetMysqlRdbms
func (x *DiscoverConnectionProfileResponse) GetMysqlRdbms() *MysqlRdbmsfunc (*DiscoverConnectionProfileResponse) GetOracleRdbms
func (x *DiscoverConnectionProfileResponse) GetOracleRdbms() *OracleRdbmsfunc (*DiscoverConnectionProfileResponse) GetPostgresqlRdbms
func (x *DiscoverConnectionProfileResponse) GetPostgresqlRdbms() *PostgresqlRdbmsfunc (*DiscoverConnectionProfileResponse) ProtoMessage
func (*DiscoverConnectionProfileResponse) ProtoMessage()func (*DiscoverConnectionProfileResponse) ProtoReflect
func (x *DiscoverConnectionProfileResponse) ProtoReflect() protoreflect.Messagefunc (*DiscoverConnectionProfileResponse) Reset
func (x *DiscoverConnectionProfileResponse) Reset()func (*DiscoverConnectionProfileResponse) String
func (x *DiscoverConnectionProfileResponse) String() stringDiscoverConnectionProfileResponse_MysqlRdbms
type DiscoverConnectionProfileResponse_MysqlRdbms struct {
// Enriched MySQL RDBMS object.
MysqlRdbms *MysqlRdbms `protobuf:"bytes,101,opt,name=mysql_rdbms,json=mysqlRdbms,proto3,oneof"`
}DiscoverConnectionProfileResponse_OracleRdbms
type DiscoverConnectionProfileResponse_OracleRdbms struct {
// Enriched Oracle RDBMS object.
OracleRdbms *OracleRdbms `protobuf:"bytes,100,opt,name=oracle_rdbms,json=oracleRdbms,proto3,oneof"`
}DiscoverConnectionProfileResponse_PostgresqlRdbms
type DiscoverConnectionProfileResponse_PostgresqlRdbms struct {
// Enriched PostgreSQL RDBMS object.
PostgresqlRdbms *PostgresqlRdbms `protobuf:"bytes,102,opt,name=postgresql_rdbms,json=postgresqlRdbms,proto3,oneof"`
}Error
type Error struct {
Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
ErrorUuid string `protobuf:"bytes,2,opt,name=error_uuid,json=errorUuid,proto3" json:"error_uuid,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
ErrorTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=error_time,json=errorTime,proto3" json:"error_time,omitempty"`
Details map[string]string "" /* 155 byte string literal not displayed */
}Represent a user-facing Error.
func (*Error) Descriptor
Deprecated: Use Error.ProtoReflect.Descriptor instead.
func (*Error) GetDetails
func (*Error) GetErrorTime
func (x *Error) GetErrorTime() *timestamppb.Timestampfunc (*Error) GetErrorUuid
func (*Error) GetMessage
func (*Error) GetReason
func (*Error) ProtoMessage
func (*Error) ProtoMessage()func (*Error) ProtoReflect
func (x *Error) ProtoReflect() protoreflect.Messagefunc (*Error) Reset
func (x *Error) Reset()func (*Error) String
FetchStaticIpsRequest
type FetchStaticIpsRequest struct {
// Required. The resource name for the location for which static IPs should be
// returned. Must be in the format `projects/*/locations/*`.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Maximum number of Ips to return, will likely not be specified.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// A page token, received from a previous `ListStaticIps` call.
// will likely not be specified.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}Request message for 'FetchStaticIps' request.
func (*FetchStaticIpsRequest) Descriptor
func (*FetchStaticIpsRequest) Descriptor() ([]byte, []int)Deprecated: Use FetchStaticIpsRequest.ProtoReflect.Descriptor instead.
func (*FetchStaticIpsRequest) GetName
func (x *FetchStaticIpsRequest) GetName() stringfunc (*FetchStaticIpsRequest) GetPageSize
func (x *FetchStaticIpsRequest) GetPageSize() int32func (*FetchStaticIpsRequest) GetPageToken
func (x *FetchStaticIpsRequest) GetPageToken() stringfunc (*FetchStaticIpsRequest) ProtoMessage
func (*FetchStaticIpsRequest) ProtoMessage()func (*FetchStaticIpsRequest) ProtoReflect
func (x *FetchStaticIpsRequest) ProtoReflect() protoreflect.Messagefunc (*FetchStaticIpsRequest) Reset
func (x *FetchStaticIpsRequest) Reset()func (*FetchStaticIpsRequest) String
func (x *FetchStaticIpsRequest) String() stringFetchStaticIpsResponse
type FetchStaticIpsResponse struct {
// list of static ips by account
StaticIps []string `protobuf:"bytes,1,rep,name=static_ips,json=staticIps,proto3" json:"static_ips,omitempty"`
// A token that can be sent as `page_token` to retrieve the next page.
// If this field is omitted, there are no subsequent pages.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}Response message for a 'FetchStaticIps' response.
func (*FetchStaticIpsResponse) Descriptor
func (*FetchStaticIpsResponse) Descriptor() ([]byte, []int)Deprecated: Use FetchStaticIpsResponse.ProtoReflect.Descriptor instead.
func (*FetchStaticIpsResponse) GetNextPageToken
func (x *FetchStaticIpsResponse) GetNextPageToken() stringfunc (*FetchStaticIpsResponse) GetStaticIps
func (x *FetchStaticIpsResponse) GetStaticIps() []stringfunc (*FetchStaticIpsResponse) ProtoMessage
func (*FetchStaticIpsResponse) ProtoMessage()func (*FetchStaticIpsResponse) ProtoReflect
func (x *FetchStaticIpsResponse) ProtoReflect() protoreflect.Messagefunc (*FetchStaticIpsResponse) Reset
func (x *FetchStaticIpsResponse) Reset()func (*FetchStaticIpsResponse) String
func (x *FetchStaticIpsResponse) String() stringForwardSshTunnelConnectivity
type ForwardSshTunnelConnectivity struct {
// Required. Hostname for the SSH tunnel.
Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
// Required. Username for the SSH tunnel.
Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
// Port for the SSH tunnel, default value is 22.
Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
// Types that are assignable to AuthenticationMethod:
//
// *ForwardSshTunnelConnectivity_Password
// *ForwardSshTunnelConnectivity_PrivateKey
AuthenticationMethod isForwardSshTunnelConnectivity_AuthenticationMethod `protobuf_oneof:"authentication_method"`
// contains filtered or unexported fields
}Forward SSH Tunnel connectivity.
func (*ForwardSshTunnelConnectivity) Descriptor
func (*ForwardSshTunnelConnectivity) Descriptor() ([]byte, []int)Deprecated: Use ForwardSshTunnelConnectivity.ProtoReflect.Descriptor instead.
func (*ForwardSshTunnelConnectivity) GetAuthenticationMethod
func (m *ForwardSshTunnelConnectivity) GetAuthenticationMethod() isForwardSshTunnelConnectivity_AuthenticationMethodfunc (*ForwardSshTunnelConnectivity) GetHostname
func (x *ForwardSshTunnelConnectivity) GetHostname() stringfunc (*ForwardSshTunnelConnectivity) GetPassword
func (x *ForwardSshTunnelConnectivity) GetPassword() stringfunc (*ForwardSshTunnelConnectivity) GetPort
func (x *ForwardSshTunnelConnectivity) GetPort() int32func (*ForwardSshTunnelConnectivity) GetPrivateKey
func (x *ForwardSshTunnelConnectivity) GetPrivateKey() stringfunc (*ForwardSshTunnelConnectivity) GetUsername
func (x *ForwardSshTunnelConnectivity) GetUsername() stringfunc (*ForwardSshTunnelConnectivity) ProtoMessage
func (*ForwardSshTunnelConnectivity) ProtoMessage()func (*ForwardSshTunnelConnectivity) ProtoReflect
func (x *ForwardSshTunnelConnectivity) ProtoReflect() protoreflect.Messagefunc (*ForwardSshTunnelConnectivity) Reset
func (x *ForwardSshTunnelConnectivity) Reset()func (*ForwardSshTunnelConnectivity) String
func (x *ForwardSshTunnelConnectivity) String() stringForwardSshTunnelConnectivity_Password
type ForwardSshTunnelConnectivity_Password struct {
// Input only. SSH password.
Password string `protobuf:"bytes,100,opt,name=password,proto3,oneof"`
}ForwardSshTunnelConnectivity_PrivateKey
type ForwardSshTunnelConnectivity_PrivateKey struct {
// Input only. SSH private key.
PrivateKey string `protobuf:"bytes,101,opt,name=private_key,json=privateKey,proto3,oneof"`
}GcsDestinationConfig
type GcsDestinationConfig struct {
// Path inside the Cloud Storage bucket to write data to.
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
// The maximum file size to be saved in the bucket.
FileRotationMb int32 `protobuf:"varint,2,opt,name=file_rotation_mb,json=fileRotationMb,proto3" json:"file_rotation_mb,omitempty"`
// The maximum duration for which new events are added before a file is
// closed and a new file is created. Values within the range of 15-60 seconds
// are allowed.
FileRotationInterval *durationpb.Duration `protobuf:"bytes,3,opt,name=file_rotation_interval,json=fileRotationInterval,proto3" json:"file_rotation_interval,omitempty"`
// File Format that the data should be written in.
//
// Types that are assignable to FileFormat:
//
// *GcsDestinationConfig_AvroFileFormat
// *GcsDestinationConfig_JsonFileFormat
FileFormat isGcsDestinationConfig_FileFormat `protobuf_oneof:"file_format"`
// contains filtered or unexported fields
}Google Cloud Storage destination configuration
func (*GcsDestinationConfig) Descriptor
func (*GcsDestinationConfig) Descriptor() ([]byte, []int)Deprecated: Use GcsDestinationConfig.ProtoReflect.Descriptor instead.
func (*GcsDestinationConfig) GetAvroFileFormat
func (x *GcsDestinationConfig) GetAvroFileFormat() *AvroFileFormatfunc (*GcsDestinationConfig) GetFileFormat
func (m *GcsDestinationConfig) GetFileFormat() isGcsDestinationConfig_FileFormatfunc (*GcsDestinationConfig) GetFileRotationInterval
func (x *GcsDestinationConfig) GetFileRotationInterval() *durationpb.Durationfunc (*GcsDestinationConfig) GetFileRotationMb
func (x *GcsDestinationConfig) GetFileRotationMb() int32func (*GcsDestinationConfig) GetJsonFileFormat
func (x *GcsDestinationConfig) GetJsonFileFormat() *JsonFileFormatfunc (*GcsDestinationConfig) GetPath
func (x *GcsDestinationConfig) GetPath() stringfunc (*GcsDestinationConfig) ProtoMessage
func (*GcsDestinationConfig) ProtoMessage()func (*GcsDestinationConfig) ProtoReflect
func (x *GcsDestinationConfig) ProtoReflect() protoreflect.Messagefunc (*GcsDestinationConfig) Reset
func (x *GcsDestinationConfig) Reset()func (*GcsDestinationConfig) String
func (x *GcsDestinationConfig) String() stringGcsDestinationConfig_AvroFileFormat
type GcsDestinationConfig_AvroFileFormat struct {
// AVRO file format configuration.
AvroFileFormat *AvroFileFormat `protobuf:"bytes,100,opt,name=avro_file_format,json=avroFileFormat,proto3,oneof"`
}GcsDestinationConfig_JsonFileFormat
type GcsDestinationConfig_JsonFileFormat struct {
// JSON file format configuration.
JsonFileFormat *JsonFileFormat `protobuf:"bytes,101,opt,name=json_file_format,json=jsonFileFormat,proto3,oneof"`
}GcsProfile
type GcsProfile struct {
// Required. The Cloud Storage bucket name.
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
// The root path inside the Cloud Storage bucket.
RootPath string `protobuf:"bytes,2,opt,name=root_path,json=rootPath,proto3" json:"root_path,omitempty"`
// contains filtered or unexported fields
}Cloud Storage bucket profile.
func (*GcsProfile) Descriptor
func (*GcsProfile) Descriptor() ([]byte, []int)Deprecated: Use GcsProfile.ProtoReflect.Descriptor instead.
func (*GcsProfile) GetBucket
func (x *GcsProfile) GetBucket() stringfunc (*GcsProfile) GetRootPath
func (x *GcsProfile) GetRootPath() stringfunc (*GcsProfile) ProtoMessage
func (*GcsProfile) ProtoMessage()func (*GcsProfile) ProtoReflect
func (x *GcsProfile) ProtoReflect() protoreflect.Messagefunc (*GcsProfile) Reset
func (x *GcsProfile) Reset()func (*GcsProfile) String
func (x *GcsProfile) String() stringGetConnectionProfileRequest
type GetConnectionProfileRequest struct {
// Required. The name of the connection profile resource to get.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}Request message for getting a connection profile.
func (*GetConnectionProfileRequest) Descriptor
func (*GetConnectionProfileRequest) Descriptor() ([]byte, []int)Deprecated: Use GetConnectionProfileRequest.ProtoReflect.Descriptor instead.
func (*GetConnectionProfileRequest) GetName
func (x *GetConnectionProfileRequest) GetName() stringfunc (*GetConnectionProfileRequest) ProtoMessage
func (*GetConnectionProfileRequest) ProtoMessage()func (*GetConnectionProfileRequest) ProtoReflect
func (x *GetConnectionProfileRequest) ProtoReflect() protoreflect.Messagefunc (*GetConnectionProfileRequest) Reset
func (x *GetConnectionProfileRequest) Reset()func (*GetConnectionProfileRequest) String
func (x *GetConnectionProfileRequest) String() stringGetPrivateConnectionRequest
type GetPrivateConnectionRequest struct {
// Required. The name of the private connectivity configuration to get.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}Request to get a private connection configuration.
func (*GetPrivateConnectionRequest) Descriptor
func (*GetPrivateConnectionRequest) Descriptor() ([]byte, []int)Deprecated: Use GetPrivateConnectionRequest.ProtoReflect.Descriptor instead.
func (*GetPrivateConnectionRequest) GetName
func (x *GetPrivateConnectionRequest) GetName() stringfunc (*GetPrivateConnectionRequest) ProtoMessage
func (*GetPrivateConnectionRequest) ProtoMessage()func (*GetPrivateConnectionRequest) ProtoReflect
func (x *GetPrivateConnectionRequest) ProtoReflect() protoreflect.Messagefunc (*GetPrivateConnectionRequest) Reset
func (x *GetPrivateConnectionRequest) Reset()func (*GetPrivateConnectionRequest) String
func (x *GetPrivateConnectionRequest) String() stringGetRouteRequest
type GetRouteRequest struct {
// Required. The name of the Route resource to get.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}Route get request.
func (*GetRouteRequest) Descriptor
func (*GetRouteRequest) Descriptor() ([]byte, []int)Deprecated: Use GetRouteRequest.ProtoReflect.Descriptor instead.
func (*GetRouteRequest) GetName
func (x *GetRouteRequest) GetName() stringfunc (*GetRouteRequest) ProtoMessage
func (*GetRouteRequest) ProtoMessage()func (*GetRouteRequest) ProtoReflect
func (x *GetRouteRequest) ProtoReflect() protoreflect.Messagefunc (*GetRouteRequest) Reset
func (x *GetRouteRequest) Reset()func (*GetRouteRequest) String
func (x *GetRouteRequest) String() stringGetStreamObjectRequest
type GetStreamObjectRequest struct {
// Required. The name of the stream object resource to get.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}Request for fetching a specific stream object.
func (*GetStreamObjectRequest) Descriptor
func (*GetStreamObjectRequest) Descriptor() ([]byte, []int)Deprecated: Use GetStreamObjectRequest.ProtoReflect.Descriptor instead.
func (*GetStreamObjectRequest) GetName
func (x *GetStreamObjectRequest) GetName() stringfunc (*GetStreamObjectRequest) ProtoMessage
func (*GetStreamObjectRequest) ProtoMessage()func (*GetStreamObjectRequest) ProtoReflect
func (x *GetStreamObjectRequest) ProtoReflect() protoreflect.Messagefunc (*GetStreamObjectRequest) Reset
func (x *GetStreamObjectRequest) Reset()func (*GetStreamObjectRequest) String
func (x *GetStreamObjectRequest) String() stringGetStreamRequest
type GetStreamRequest struct {
// Required. The name of the stream resource to get.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}Request message for getting a stream.
func (*GetStreamRequest) Descriptor
func (*GetStreamRequest) Descriptor() ([]byte, []int)Deprecated: Use GetStreamRequest.ProtoReflect.Descriptor instead.
func (*GetStreamRequest) GetName
func (x *GetStreamRequest) GetName() stringfunc (*GetStreamRequest) ProtoMessage
func (*GetStreamRequest) ProtoMessage()func (*GetStreamRequest) ProtoReflect
func (x *GetStreamRequest) ProtoReflect() protoreflect.Messagefunc (*GetStreamRequest) Reset
func (x *GetStreamRequest) Reset()func (*GetStreamRequest) String
func (x *GetStreamRequest) String() stringJsonFileFormat
type JsonFileFormat struct {
SchemaFileFormat JsonFileFormat_SchemaFileFormat "" /* 176 byte string literal not displayed */
Compression JsonFileFormat_JsonCompression "" /* 139 byte string literal not displayed */
}JSON file format configuration.
func (*JsonFileFormat) Descriptor
func (*JsonFileFormat) Descriptor() ([]byte, []int)Deprecated: Use JsonFileFormat.ProtoReflect.Descriptor instead.
func (*JsonFileFormat) GetCompression
func (x *JsonFileFormat) GetCompression() JsonFileFormat_JsonCompressionfunc (*JsonFileFormat) GetSchemaFileFormat
func (x *JsonFileFormat) GetSchemaFileFormat() JsonFileFormat_SchemaFileFormatfunc (*JsonFileFormat) ProtoMessage
func (*JsonFileFormat) ProtoMessage()func (*JsonFileFormat) ProtoReflect
func (x *JsonFileFormat) ProtoReflect() protoreflect.Messagefunc (*JsonFileFormat) Reset
func (x *JsonFileFormat) Reset()func (*JsonFileFormat) String
func (x *JsonFileFormat) String() stringJsonFileFormat_JsonCompression
type JsonFileFormat_JsonCompression int32Json file compression.
JsonFileFormat_JSON_COMPRESSION_UNSPECIFIED, JsonFileFormat_NO_COMPRESSION, JsonFileFormat_GZIP
const (
// Unspecified json file compression.
JsonFileFormat_JSON_COMPRESSION_UNSPECIFIED JsonFileFormat_JsonCompression = 0
// Do not compress JSON file.
JsonFileFormat_NO_COMPRESSION JsonFileFormat_JsonCompression = 1
// Gzip compression.
JsonFileFormat_GZIP JsonFileFormat_JsonCompression = 2
)func (JsonFileFormat_JsonCompression) Descriptor
func (JsonFileFormat_JsonCompression) Descriptor() protoreflect.EnumDescriptorfunc (JsonFileFormat_JsonCompression) Enum
func (x JsonFileFormat_JsonCompression) Enum() *JsonFileFormat_JsonCompressionfunc (JsonFileFormat_JsonCompression) EnumDescriptor
func (JsonFileFormat_JsonCompression) EnumDescriptor() ([]byte, []int)Deprecated: Use JsonFileFormat_JsonCompression.Descriptor instead.
func (JsonFileFormat_JsonCompression) Number
func (x JsonFileFormat_JsonCompression) Number() protoreflect.EnumNumberfunc (JsonFileFormat_JsonCompression) String
func (x JsonFileFormat_JsonCompression) String() stringfunc (JsonFileFormat_JsonCompression) Type
func (JsonFileFormat_JsonCompression) Type() protoreflect.EnumTypeJsonFileFormat_SchemaFileFormat
type JsonFileFormat_SchemaFileFormat int32Schema file format.
JsonFileFormat_SCHEMA_FILE_FORMAT_UNSPECIFIED, JsonFileFormat_NO_SCHEMA_FILE, JsonFileFormat_AVRO_SCHEMA_FILE
const (
// Unspecified schema file format.
JsonFileFormat_SCHEMA_FILE_FORMAT_UNSPECIFIED JsonFileFormat_SchemaFileFormat = 0
// Do not attach schema file.
JsonFileFormat_NO_SCHEMA_FILE JsonFileFormat_SchemaFileFormat = 1
// Avro schema format.
JsonFileFormat_AVRO_SCHEMA_FILE JsonFileFormat_SchemaFileFormat = 2
)func (JsonFileFormat_SchemaFileFormat) Descriptor
func (JsonFileFormat_SchemaFileFormat) Descriptor() protoreflect.EnumDescriptorfunc (JsonFileFormat_SchemaFileFormat) Enum
func (x JsonFileFormat_SchemaFileFormat) Enum() *JsonFileFormat_SchemaFileFormatfunc (JsonFileFormat_SchemaFileFormat) EnumDescriptor
func (JsonFileFormat_SchemaFileFormat) EnumDescriptor() ([]byte, []int)Deprecated: Use JsonFileFormat_SchemaFileFormat.Descriptor instead.
func (JsonFileFormat_SchemaFileFormat) Number
func (x JsonFileFormat_SchemaFileFormat) Number() protoreflect.EnumNumberfunc (JsonFileFormat_SchemaFileFormat) String
func (x JsonFileFormat_SchemaFileFormat) String() stringfunc (JsonFileFormat_SchemaFileFormat) Type
func (JsonFileFormat_SchemaFileFormat) Type() protoreflect.EnumTypeListConnectionProfilesRequest
type ListConnectionProfilesRequest struct {
// Required. The parent that owns the collection of connection profiles.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Maximum number of connection profiles to return.
// If unspecified, at most 50 connection profiles will be returned.
// The maximum value is 1000; values above 1000 will be coerced to 1000.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// Page token received from a previous `ListConnectionProfiles` call.
// Provide this to retrieve the subsequent page.
//
// When paginating, all other parameters provided to `ListConnectionProfiles`
// must match the call that provided the page token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// Filter request.
Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
// Order by fields for the result.
OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
// contains filtered or unexported fields
}Request message for listing connection profiles.
func (*ListConnectionProfilesRequest) Descriptor
func (*ListConnectionProfilesRequest) Descriptor() ([]byte, []int)Deprecated: Use ListConnectionProfilesRequest.ProtoReflect.Descriptor instead.
func (*ListConnectionProfilesRequest) GetFilter
func (x *ListConnectionProfilesRequest) GetFilter() stringfunc (*ListConnectionProfilesRequest) GetOrderBy
func (x *ListConnectionProfilesRequest) GetOrderBy() stringfunc (*ListConnectionProfilesRequest) GetPageSize
func (x *ListConnectionProfilesRequest) GetPageSize() int32func (*ListConnectionProfilesRequest) GetPageToken
func (x *ListConnectionProfilesRequest) GetPageToken() stringfunc (*ListConnectionProfilesRequest) GetParent
func (x *ListConnectionProfilesRequest) GetParent() stringfunc (*ListConnectionProfilesRequest) ProtoMessage
func (*ListConnectionProfilesRequest) ProtoMessage()func (*ListConnectionProfilesRequest) ProtoReflect
func (x *ListConnectionProfilesRequest) ProtoReflect() protoreflect.Messagefunc (*ListConnectionProfilesRequest) Reset
func (x *ListConnectionProfilesRequest) Reset()func (*ListConnectionProfilesRequest) String
func (x *ListConnectionProfilesRequest) String() stringListConnectionProfilesResponse
type ListConnectionProfilesResponse struct {
// List of connection profiles.
ConnectionProfiles []*ConnectionProfile `protobuf:"bytes,1,rep,name=connection_profiles,json=connectionProfiles,proto3" json:"connection_profiles,omitempty"`
// A token, which can be sent as `page_token` to retrieve the next page.
// If this field is omitted, there are no subsequent pages.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Locations that could not be reached.
Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}Response message for listing connection profiles.
func (*ListConnectionProfilesResponse) Descriptor
func (*ListConnectionProfilesResponse) Descriptor() ([]byte, []int)Deprecated: Use ListConnectionProfilesResponse.ProtoReflect.Descriptor instead.
func (*ListConnectionProfilesResponse) GetConnectionProfiles
func (x *ListConnectionProfilesResponse) GetConnectionProfiles() []*ConnectionProfilefunc (*ListConnectionProfilesResponse) GetNextPageToken
func (x *ListConnectionProfilesResponse) GetNextPageToken() stringfunc (*ListConnectionProfilesResponse) GetUnreachable
func (x *ListConnectionProfilesResponse) GetUnreachable() []stringfunc (*ListConnectionProfilesResponse) ProtoMessage
func (*ListConnectionProfilesResponse) ProtoMessage()func (*ListConnectionProfilesResponse) ProtoReflect
func (x *ListConnectionProfilesResponse) ProtoReflect() protoreflect.Messagefunc (*ListConnectionProfilesResponse) Reset
func (x *ListConnectionProfilesResponse) Reset()func (*ListConnectionProfilesResponse) String
func (x *ListConnectionProfilesResponse) String() stringListPrivateConnectionsRequest
type ListPrivateConnectionsRequest struct {
// Required. The parent that owns the collection of private connectivity
// configurations.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Maximum number of private connectivity configurations to return.
// If unspecified, at most 50 private connectivity configurations that will be
// returned. The maximum value is 1000; values above 1000 will be coerced to
// 1000.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// Page token received from a previous `ListPrivateConnections` call.
// Provide this to retrieve the subsequent page.
//
// When paginating, all other parameters provided to
// `ListPrivateConnections` must match the call that provided the page
// token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// Filter request.
Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
// Order by fields for the result.
OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
// contains filtered or unexported fields
}Request for listing private connections.
func (*ListPrivateConnectionsRequest) Descriptor
func (*ListPrivateConnectionsRequest) Descriptor() ([]byte, []int)Deprecated: Use ListPrivateConnectionsRequest.ProtoReflect.Descriptor instead.
func (*ListPrivateConnectionsRequest) GetFilter
func (x *ListPrivateConnectionsRequest) GetFilter() stringfunc (*ListPrivateConnectionsRequest) GetOrderBy
func (x *ListPrivateConnectionsRequest) GetOrderBy() stringfunc (*ListPrivateConnectionsRequest) GetPageSize
func (x *ListPrivateConnectionsRequest) GetPageSize() int32func (*ListPrivateConnectionsRequest) GetPageToken
func (x *ListPrivateConnectionsRequest) GetPageToken() stringfunc (*ListPrivateConnectionsRequest) GetParent
func (x *ListPrivateConnectionsRequest) GetParent() stringfunc (*ListPrivateConnectionsRequest) ProtoMessage
func (*ListPrivateConnectionsRequest) ProtoMessage()func (*ListPrivateConnectionsRequest) ProtoReflect
func (x *ListPrivateConnectionsRequest) ProtoReflect() protoreflect.Messagefunc (*ListPrivateConnectionsRequest) Reset
func (x *ListPrivateConnectionsRequest) Reset()func (*ListPrivateConnectionsRequest) String
func (x *ListPrivateConnectionsRequest) String() stringListPrivateConnectionsResponse
type ListPrivateConnectionsResponse struct {
// List of private connectivity configurations.
PrivateConnections []*PrivateConnection `protobuf:"bytes,1,rep,name=private_connections,json=privateConnections,proto3" json:"private_connections,omitempty"`
// A token, which can be sent as `page_token` to retrieve the next page.
// If this field is omitted, there are no subsequent pages.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Locations that could not be reached.
Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}Response containing a list of private connection configurations.
func (*ListPrivateConnectionsResponse) Descriptor
func (*ListPrivateConnectionsResponse) Descriptor() ([]byte, []int)Deprecated: Use ListPrivateConnectionsResponse.ProtoReflect.Descriptor instead.
func (*ListPrivateConnectionsResponse) GetNextPageToken
func (x *ListPrivateConnectionsResponse) GetNextPageToken() stringfunc (*ListPrivateConnectionsResponse) GetPrivateConnections
func (x *ListPrivateConnectionsResponse) GetPrivateConnections() []*PrivateConnectionfunc (*ListPrivateConnectionsResponse) GetUnreachable
func (x *ListPrivateConnectionsResponse) GetUnreachable() []stringfunc (*ListPrivateConnectionsResponse) ProtoMessage
func (*ListPrivateConnectionsResponse) ProtoMessage()func (*ListPrivateConnectionsResponse) ProtoReflect
func (x *ListPrivateConnectionsResponse) ProtoReflect() protoreflect.Messagefunc (*ListPrivateConnectionsResponse) Reset
func (x *ListPrivateConnectionsResponse) Reset()func (*ListPrivateConnectionsResponse) String
func (x *ListPrivateConnectionsResponse) String() stringListRoutesRequest
type ListRoutesRequest struct {
// Required. The parent that owns the collection of Routess.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Maximum number of Routes to return. The service may return
// fewer than this value. If unspecified, at most 50 Routes
// will be returned. The maximum value is 1000; values above 1000 will be
// coerced to 1000.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// Page token received from a previous `ListRoutes` call.
// Provide this to retrieve the subsequent page.
//
// When paginating, all other parameters provided to
// `ListRoutes` must match the call that provided the page
// token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// Filter request.
Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
// Order by fields for the result.
OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
// contains filtered or unexported fields
}Route list request.
func (*ListRoutesRequest) Descriptor
func (*ListRoutesRequest) Descriptor() ([]byte, []int)Deprecated: Use ListRoutesRequest.ProtoReflect.Descriptor instead.
func (*ListRoutesRequest) GetFilter
func (x *ListRoutesRequest) GetFilter() stringfunc (*ListRoutesRequest) GetOrderBy
func (x *ListRoutesRequest) GetOrderBy() stringfunc (*ListRoutesRequest) GetPageSize
func (x *ListRoutesRequest) GetPageSize() int32func (*ListRoutesRequest) GetPageToken
func (x *ListRoutesRequest) GetPageToken() stringfunc (*ListRoutesRequest) GetParent
func (x *ListRoutesRequest) GetParent() stringfunc (*ListRoutesRequest) ProtoMessage
func (*ListRoutesRequest) ProtoMessage()func (*ListRoutesRequest) ProtoReflect
func (x *ListRoutesRequest) ProtoReflect() protoreflect.Messagefunc (*ListRoutesRequest) Reset
func (x *ListRoutesRequest) Reset()func (*ListRoutesRequest) String
func (x *ListRoutesRequest) String() stringListRoutesResponse
type ListRoutesResponse struct {
// List of Routes.
Routes []*Route `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
// A token, which can be sent as `page_token` to retrieve the next page.
// If this field is omitted, there are no subsequent pages.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Locations that could not be reached.
Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}Route list response.
func (*ListRoutesResponse) Descriptor
func (*ListRoutesResponse) Descriptor() ([]byte, []int)Deprecated: Use ListRoutesResponse.ProtoReflect.Descriptor instead.
func (*ListRoutesResponse) GetNextPageToken
func (x *ListRoutesResponse) GetNextPageToken() stringfunc (*ListRoutesResponse) GetRoutes
func (x *ListRoutesResponse) GetRoutes() []*Routefunc (*ListRoutesResponse) GetUnreachable
func (x *ListRoutesResponse) GetUnreachable() []stringfunc (*ListRoutesResponse) ProtoMessage
func (*ListRoutesResponse) ProtoMessage()func (*ListRoutesResponse) ProtoReflect
func (x *ListRoutesResponse) ProtoReflect() protoreflect.Messagefunc (*ListRoutesResponse) Reset
func (x *ListRoutesResponse) Reset()func (*ListRoutesResponse) String
func (x *ListRoutesResponse) String() stringListStreamObjectsRequest
type ListStreamObjectsRequest struct {
// Required. The parent stream that owns the collection of objects.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Maximum number of objects to return. Default is 50.
// The maximum value is 1000; values above 1000 will be coerced to 1000.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// Page token received from a previous `ListStreamObjectsRequest` call.
// Provide this to retrieve the subsequent page.
//
// When paginating, all other parameters provided to
// `ListStreamObjectsRequest` must match the call that provided the page
// token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}Request for listing all objects for a specific stream.
func (*ListStreamObjectsRequest) Descriptor
func (*ListStreamObjectsRequest) Descriptor() ([]byte, []int)Deprecated: Use ListStreamObjectsRequest.ProtoReflect.Descriptor instead.
func (*ListStreamObjectsRequest) GetPageSize
func (x *ListStreamObjectsRequest) GetPageSize() int32func (*ListStreamObjectsRequest) GetPageToken
func (x *ListStreamObjectsRequest) GetPageToken() stringfunc (*ListStreamObjectsRequest) GetParent
func (x *ListStreamObjectsRequest) GetParent() stringfunc (*ListStreamObjectsRequest) ProtoMessage
func (*ListStreamObjectsRequest) ProtoMessage()func (*ListStreamObjectsRequest) ProtoReflect
func (x *ListStreamObjectsRequest) ProtoReflect() protoreflect.Messagefunc (*ListStreamObjectsRequest) Reset
func (x *ListStreamObjectsRequest) Reset()func (*ListStreamObjectsRequest) String
func (x *ListStreamObjectsRequest) String() stringListStreamObjectsResponse
type ListStreamObjectsResponse struct {
// List of stream objects.
StreamObjects []*StreamObject `protobuf:"bytes,1,rep,name=stream_objects,json=streamObjects,proto3" json:"stream_objects,omitempty"`
// A token, which can be sent as `page_token` to retrieve the next page.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// contains filtered or unexported fields
}Response containing the objects for a stream.
func (*ListStreamObjectsResponse) Descriptor
func (*ListStreamObjectsResponse) Descriptor() ([]byte, []int)Deprecated: Use ListStreamObjectsResponse.ProtoReflect.Descriptor instead.
func (*ListStreamObjectsResponse) GetNextPageToken
func (x *ListStreamObjectsResponse) GetNextPageToken() stringfunc (*ListStreamObjectsResponse) GetStreamObjects
func (x *ListStreamObjectsResponse) GetStreamObjects() []*StreamObjectfunc (*ListStreamObjectsResponse) ProtoMessage
func (*ListStreamObjectsResponse) ProtoMessage()func (*ListStreamObjectsResponse) ProtoReflect
func (x *ListStreamObjectsResponse) ProtoReflect() protoreflect.Messagefunc (*ListStreamObjectsResponse) Reset
func (x *ListStreamObjectsResponse) Reset()func (*ListStreamObjectsResponse) String
func (x *ListStreamObjectsResponse) String() stringListStreamsRequest
type ListStreamsRequest struct {
// Required. The parent that owns the collection of streams.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Maximum number of streams to return.
// If unspecified, at most 50 streams will be returned. The maximum
// value is 1000; values above 1000 will be coerced to 1000.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// Page token received from a previous `ListStreams` call.
// Provide this to retrieve the subsequent page.
//
// When paginating, all other parameters provided to `ListStreams`
// must match the call that provided the page token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// Filter request.
Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
// Order by fields for the result.
OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
// contains filtered or unexported fields
}Request message for listing streams.
func (*ListStreamsRequest) Descriptor
func (*ListStreamsRequest) Descriptor() ([]byte, []int)Deprecated: Use ListStreamsRequest.ProtoReflect.Descriptor instead.
func (*ListStreamsRequest) GetFilter
func (x *ListStreamsRequest) GetFilter() stringfunc (*ListStreamsRequest) GetOrderBy
func (x *ListStreamsRequest) GetOrderBy() stringfunc (*ListStreamsRequest) GetPageSize
func (x *ListStreamsRequest) GetPageSize() int32func (*ListStreamsRequest) GetPageToken
func (x *ListStreamsRequest) GetPageToken() stringfunc (*ListStreamsRequest) GetParent
func (x *ListStreamsRequest) GetParent() stringfunc (*ListStreamsRequest) ProtoMessage
func (*ListStreamsRequest) ProtoMessage()func (*ListStreamsRequest) ProtoReflect
func (x *ListStreamsRequest) ProtoReflect() protoreflect.Messagefunc (*ListStreamsRequest) Reset
func (x *ListStreamsRequest) Reset()func (*ListStreamsRequest) String
func (x *ListStreamsRequest) String() stringListStreamsResponse
type ListStreamsResponse struct {
// List of streams
Streams []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
// A token, which can be sent as `page_token` to retrieve the next page.
// If this field is omitted, there are no subsequent pages.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Locations that could not be reached.
Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}Response message for listing streams.
func (*ListStreamsResponse) Descriptor
func (*ListStreamsResponse) Descriptor() ([]byte, []int)Deprecated: Use ListStreamsResponse.ProtoReflect.Descriptor instead.
func (*ListStreamsResponse) GetNextPageToken
func (x *ListStreamsResponse) GetNextPageToken() stringfunc (*ListStreamsResponse) GetStreams
func (x *ListStreamsResponse) GetStreams() []*Streamfunc (*ListStreamsResponse) GetUnreachable
func (x *ListStreamsResponse) GetUnreachable() []stringfunc (*ListStreamsResponse) ProtoMessage
func (*ListStreamsResponse) ProtoMessage()func (*ListStreamsResponse) ProtoReflect
func (x *ListStreamsResponse) ProtoReflect() protoreflect.Messagefunc (*ListStreamsResponse) Reset
func (x *ListStreamsResponse) Reset()func (*ListStreamsResponse) String
func (x *ListStreamsResponse) String() stringLookupStreamObjectRequest
type LookupStreamObjectRequest struct {
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
SourceObjectIdentifier *SourceObjectIdentifier "" /* 129 byte string literal not displayed */
}Request for looking up a specific stream object by its source object identifier.
func (*LookupStreamObjectRequest) Descriptor
func (*LookupStreamObjectRequest) Descriptor() ([]byte, []int)Deprecated: Use LookupStreamObjectRequest.ProtoReflect.Descriptor instead.
func (*LookupStreamObjectRequest) GetParent
func (x *LookupStreamObjectRequest) GetParent() stringfunc (*LookupStreamObjectRequest) GetSourceObjectIdentifier
func (x *LookupStreamObjectRequest) GetSourceObjectIdentifier() *SourceObjectIdentifierfunc (*LookupStreamObjectRequest) ProtoMessage
func (*LookupStreamObjectRequest) ProtoMessage()func (*LookupStreamObjectRequest) ProtoReflect
func (x *LookupStreamObjectRequest) ProtoReflect() protoreflect.Messagefunc (*LookupStreamObjectRequest) Reset
func (x *LookupStreamObjectRequest) Reset()func (*LookupStreamObjectRequest) String
func (x *LookupStreamObjectRequest) String() stringMysqlColumn
type MysqlColumn struct {
// Column name.
Column string `protobuf:"bytes,1,opt,name=column,proto3" json:"column,omitempty"`
// The MySQL data type. Full data types list can be found here:
// https://dev.mysql.com/doc/refman/8.0/en/data-types.html
DataType string `protobuf:"bytes,2,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty"`
// Column length.
Length int32 `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
// Column collation.
Collation string `protobuf:"bytes,4,opt,name=collation,proto3" json:"collation,omitempty"`
// Whether or not the column represents a primary key.
PrimaryKey bool `protobuf:"varint,5,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
// Whether or not the column can accept a null value.
Nullable bool `protobuf:"varint,6,opt,name=nullable,proto3" json:"nullable,omitempty"`
// The ordinal position of the column in the table.
OrdinalPosition int32 `protobuf:"varint,7,opt,name=ordinal_position,json=ordinalPosition,proto3" json:"ordinal_position,omitempty"`
// Column precision.
Precision int32 `protobuf:"varint,8,opt,name=precision,proto3" json:"precision,omitempty"`
// Column scale.
Scale int32 `protobuf:"varint,9,opt,name=scale,proto3" json:"scale,omitempty"`
// contains filtered or unexported fields
}MySQL Column.
func (*MysqlColumn) Descriptor
func (*MysqlColumn) Descriptor() ([]byte, []int)Deprecated: Use MysqlColumn.ProtoReflect.Descriptor instead.
func (*MysqlColumn) GetCollation
func (x *MysqlColumn) GetCollation() stringfunc (*MysqlColumn) GetColumn
func (x *MysqlColumn) GetColumn() stringfunc (*MysqlColumn) GetDataType
func (x *MysqlColumn) GetDataType() stringfunc (*MysqlColumn) GetLength
func (x *MysqlColumn) GetLength() int32func (*MysqlColumn) GetNullable
func (x *MysqlColumn) GetNullable() boolfunc (*MysqlColumn) GetOrdinalPosition
func (x *MysqlColumn) GetOrdinalPosition() int32func (*MysqlColumn) GetPrecision
func (x *MysqlColumn) GetPrecision() int32func (*MysqlColumn) GetPrimaryKey
func (x *MysqlColumn) GetPrimaryKey() boolfunc (*MysqlColumn) GetScale
func (x *MysqlColumn) GetScale() int32func (*MysqlColumn) ProtoMessage
func (*MysqlColumn) ProtoMessage()func (*MysqlColumn) ProtoReflect
func (x *MysqlColumn) ProtoReflect() protoreflect.Messagefunc (*MysqlColumn) Reset
func (x *MysqlColumn) Reset()func (*MysqlColumn) String
func (x *MysqlColumn) String() stringMysqlDatabase
type MysqlDatabase struct {
// Database name.
Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
// Tables in the database.
MysqlTables []*MysqlTable `protobuf:"bytes,2,rep,name=mysql_tables,json=mysqlTables,proto3" json:"mysql_tables,omitempty"`
// contains filtered or unexported fields
}MySQL database.
func (*MysqlDatabase) Descriptor
func (*MysqlDatabase) Descriptor() ([]byte, []int)Deprecated: Use MysqlDatabase.ProtoReflect.Descriptor instead.
func (*MysqlDatabase) GetDatabase
func (x *MysqlDatabase) GetDatabase() stringfunc (*MysqlDatabase) GetMysqlTables
func (x *MysqlDatabase) GetMysqlTables() []*MysqlTablefunc (*MysqlDatabase) ProtoMessage
func (*MysqlDatabase) ProtoMessage()func (*MysqlDatabase) ProtoReflect
func (x *MysqlDatabase) ProtoReflect() protoreflect.Messagefunc (*MysqlDatabase) Reset
func (x *MysqlDatabase) Reset()func (*MysqlDatabase) String
func (x *MysqlDatabase) String() stringMysqlProfile
type MysqlProfile struct {
// Required. Hostname for the MySQL connection.
Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
// Port for the MySQL connection, default value is 3306.
Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
// Required. Username for the MySQL connection.
Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
// Required. Input only. Password for the MySQL connection.
Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
// SSL configuration for the MySQL connection.
SslConfig *MysqlSslConfig `protobuf:"bytes,5,opt,name=ssl_config,json=sslConfig,proto3" json:"ssl_config,omitempty"`
// contains filtered or unexported fields
}MySQL database profile.
func (*MysqlProfile) Descriptor
func (*MysqlProfile) Descriptor() ([]byte, []int)Deprecated: Use MysqlProfile.ProtoReflect.Descriptor instead.
func (*MysqlProfile) GetHostname
func (x *MysqlProfile) GetHostname() stringfunc (*MysqlProfile) GetPassword
func (x *MysqlProfile) GetPassword() stringfunc (*MysqlProfile) GetPort
func (x *MysqlProfile) GetPort() int32func (*MysqlProfile) GetSslConfig
func (x *MysqlProfile) GetSslConfig() *MysqlSslConfigfunc (*MysqlProfile) GetUsername
func (x *MysqlProfile) GetUsername() stringfunc (*MysqlProfile) ProtoMessage
func (*MysqlProfile) ProtoMessage()func (*MysqlProfile) ProtoReflect
func (x *MysqlProfile) ProtoReflect() protoreflect.Messagefunc (*MysqlProfile) Reset
func (x *MysqlProfile) Reset()func (*MysqlProfile) String
func (x *MysqlProfile) String() stringMysqlRdbms
type MysqlRdbms struct {
// Mysql databases on the server
MysqlDatabases []*MysqlDatabase `protobuf:"bytes,1,rep,name=mysql_databases,json=mysqlDatabases,proto3" json:"mysql_databases,omitempty"`
// contains filtered or unexported fields
}MySQL database structure
func (*MysqlRdbms) Descriptor
func (*MysqlRdbms) Descriptor() ([]byte, []int)Deprecated: Use MysqlRdbms.ProtoReflect.Descriptor instead.
func (*MysqlRdbms) GetMysqlDatabases
func (x *MysqlRdbms) GetMysqlDatabases() []*MysqlDatabasefunc (*MysqlRdbms) ProtoMessage
func (*MysqlRdbms) ProtoMessage()func (*MysqlRdbms) ProtoReflect
func (x *MysqlRdbms) ProtoReflect() protoreflect.Messagefunc (*MysqlRdbms) Reset
func (x *MysqlRdbms) Reset()func (*MysqlRdbms) String
func (x *MysqlRdbms) String() stringMysqlSourceConfig
type MysqlSourceConfig struct {
IncludeObjects *MysqlRdbms `protobuf:"bytes,1,opt,name=include_objects,json=includeObjects,proto3" json:"include_objects,omitempty"`
ExcludeObjects *MysqlRdbms `protobuf:"bytes,2,opt,name=exclude_objects,json=excludeObjects,proto3" json:"exclude_objects,omitempty"`
MaxConcurrentCdcTasks int32 "" /* 129 byte string literal not displayed */
MaxConcurrentBackfillTasks int32 "" /* 144 byte string literal not displayed */
}MySQL source configuration
func (*MysqlSourceConfig) Descriptor
func (*MysqlSourceConfig) Descriptor() ([]byte, []int)Deprecated: Use MysqlSourceConfig.ProtoReflect.Descriptor instead.
func (*MysqlSourceConfig) GetExcludeObjects
func (x *MysqlSourceConfig) GetExcludeObjects() *MysqlRdbmsfunc (*MysqlSourceConfig) GetIncludeObjects
func (x *MysqlSourceConfig) GetIncludeObjects() *MysqlRdbmsfunc (*MysqlSourceConfig) GetMaxConcurrentBackfillTasks
func (x *MysqlSourceConfig) GetMaxConcurrentBackfillTasks() int32func (*MysqlSourceConfig) GetMaxConcurrentCdcTasks
func (x *MysqlSourceConfig) GetMaxConcurrentCdcTasks() int32func (*MysqlSourceConfig) ProtoMessage
func (*MysqlSourceConfig) ProtoMessage()func (*MysqlSourceConfig) ProtoReflect
func (x *MysqlSourceConfig) ProtoReflect() protoreflect.Messagefunc (*MysqlSourceConfig) Reset
func (x *MysqlSourceConfig) Reset()func (*MysqlSourceConfig) String
func (x *MysqlSourceConfig) String() stringMysqlSslConfig
type MysqlSslConfig struct {
// Input only. PEM-encoded private key associated with the Client Certificate.
// If this field is used then the 'client_certificate' and the
// 'ca_certificate' fields are mandatory.
ClientKey string `protobuf:"bytes,1,opt,name=client_key,json=clientKey,proto3" json:"client_key,omitempty"`
// Output only. Indicates whether the client_key field is set.
ClientKeySet bool `protobuf:"varint,2,opt,name=client_key_set,json=clientKeySet,proto3" json:"client_key_set,omitempty"`
// Input only. PEM-encoded certificate that will be used by the replica to
// authenticate against the source database server. If this field is used
// then the 'client_key' and the 'ca_certificate' fields are mandatory.
ClientCertificate string `protobuf:"bytes,3,opt,name=client_certificate,json=clientCertificate,proto3" json:"client_certificate,omitempty"`
// Output only. Indicates whether the client_certificate field is set.
ClientCertificateSet bool `protobuf:"varint,4,opt,name=client_certificate_set,json=clientCertificateSet,proto3" json:"client_certificate_set,omitempty"`
// Input only. PEM-encoded certificate of the CA that signed the source
// database server's certificate.
CaCertificate string `protobuf:"bytes,5,opt,name=ca_certificate,json=caCertificate,proto3" json:"ca_certificate,omitempty"`
// Output only. Indicates whether the ca_certificate field is set.
CaCertificateSet bool `protobuf:"varint,6,opt,name=ca_certificate_set,json=caCertificateSet,proto3" json:"ca_certificate_set,omitempty"`
// contains filtered or unexported fields
}MySQL SSL configuration information.
func (*MysqlSslConfig) Descriptor
func (*MysqlSslConfig) Descriptor() ([]byte, []int)Deprecated: Use MysqlSslConfig.ProtoReflect.Descriptor instead.
func (*MysqlSslConfig) GetCaCertificate
func (x *MysqlSslConfig) GetCaCertificate() stringfunc (*MysqlSslConfig) GetCaCertificateSet
func (x *MysqlSslConfig) GetCaCertificateSet() boolfunc (*MysqlSslConfig) GetClientCertificate
func (x *MysqlSslConfig) GetClientCertificate() stringfunc (*MysqlSslConfig) GetClientCertificateSet
func (x *MysqlSslConfig) GetClientCertificateSet() boolfunc (*MysqlSslConfig) GetClientKey
func (x *MysqlSslConfig) GetClientKey() stringfunc (*MysqlSslConfig) GetClientKeySet
func (x *MysqlSslConfig) GetClientKeySet() boolfunc (*MysqlSslConfig) ProtoMessage
func (*MysqlSslConfig) ProtoMessage()func (*MysqlSslConfig) ProtoReflect
func (x *MysqlSslConfig) ProtoReflect() protoreflect.Messagefunc (*MysqlSslConfig) Reset
func (x *MysqlSslConfig) Reset()func (*MysqlSslConfig) String
func (x *MysqlSslConfig) String() stringMysqlTable
type MysqlTable struct {
// Table name.
Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
// MySQL columns in the database.
// When unspecified as part of include/exclude objects, includes/excludes
// everything.
MysqlColumns []*MysqlColumn `protobuf:"bytes,2,rep,name=mysql_columns,json=mysqlColumns,proto3" json:"mysql_columns,omitempty"`
// contains filtered or unexported fields
}MySQL table.
func (*MysqlTable) Descriptor
func (*MysqlTable) Descriptor() ([]byte, []int)Deprecated: Use MysqlTable.ProtoReflect.Descriptor instead.
func (*MysqlTable) GetMysqlColumns
func (x *MysqlTable) GetMysqlColumns() []*MysqlColumnfunc (*MysqlTable) GetTable
func (x *MysqlTable) GetTable() stringfunc (*MysqlTable) ProtoMessage
func (*MysqlTable) ProtoMessage()func (*MysqlTable) ProtoReflect
func (x *MysqlTable) ProtoReflect() protoreflect.Messagefunc (*MysqlTable) Reset
func (x *MysqlTable) Reset()func (*MysqlTable) String
func (x *MysqlTable) String() stringOperationMetadata
type OperationMetadata struct {
// Output only. The time the operation was created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The time the operation finished running.
EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
// Output only. Server-defined resource path for the target of the operation.
Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
// Output only. Name of the verb executed by the operation.
Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
// Output only. Human-readable status of the operation, if any.
StatusMessage string `protobuf:"bytes,5,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
// Output only. Identifies whether the user has requested cancellation
// of the operation. Operations that have successfully been cancelled
// have [Operation.error][] value with a
// [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
// `Code.CANCELLED`.
RequestedCancellation bool `protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
// Output only. API version used to start the operation.
ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
// Output only. Results of executed validations if there are any.
ValidationResult *ValidationResult `protobuf:"bytes,8,opt,name=validation_result,json=validationResult,proto3" json:"validation_result,omitempty"`
// contains filtered or unexported fields
}Represents the metadata of the long-running operation.
func (*OperationMetadata) Descriptor
func (*OperationMetadata) Descriptor() ([]byte, []int)Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.
func (*OperationMetadata) GetApiVersion
func (x *OperationMetadata) GetApiVersion() stringfunc (*OperationMetadata) GetCreateTime
func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestampfunc (*OperationMetadata) GetEndTime
func (x *OperationMetadata) GetEndTime() *timestamppb.Timestampfunc (*OperationMetadata) GetRequestedCancellation
func (x *OperationMetadata) GetRequestedCancellation() boolfunc (*OperationMetadata) GetStatusMessage
func (x *OperationMetadata) GetStatusMessage() stringfunc (*OperationMetadata) GetTarget
func (x *OperationMetadata) GetTarget() stringfunc (*OperationMetadata) GetValidationResult
func (x *OperationMetadata) GetValidationResult() *ValidationResultfunc (*OperationMetadata) GetVerb
func (x *OperationMetadata) GetVerb() stringfunc (*OperationMetadata) ProtoMessage
func (*OperationMetadata) ProtoMessage()func (*OperationMetadata) ProtoReflect
func (x *OperationMetadata) ProtoReflect() protoreflect.Messagefunc (*OperationMetadata) Reset
func (x *OperationMetadata) Reset()func (*OperationMetadata) String
func (x *OperationMetadata) String() stringOracleColumn
type OracleColumn struct {
// Column name.
Column string `protobuf:"bytes,1,opt,name=column,proto3" json:"column,omitempty"`
// The Oracle data type.
DataType string `protobuf:"bytes,2,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty"`
// Column length.
Length int32 `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
// Column precision.
Precision int32 `protobuf:"varint,4,opt,name=precision,proto3" json:"precision,omitempty"`
// Column scale.
Scale int32 `protobuf:"varint,5,opt,name=scale,proto3" json:"scale,omitempty"`
// Column encoding.
Encoding string `protobuf:"bytes,6,opt,name=encoding,proto3" json:"encoding,omitempty"`
// Whether or not the column represents a primary key.
PrimaryKey bool `protobuf:"varint,7,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
// Whether or not the column can accept a null value.
Nullable bool `protobuf:"varint,8,opt,name=nullable,proto3" json:"nullable,omitempty"`
// The ordinal position of the column in the table.
OrdinalPosition int32 `protobuf:"varint,9,opt,name=ordinal_position,json=ordinalPosition,proto3" json:"ordinal_position,omitempty"`
// contains filtered or unexported fields
}Oracle Column.
func (*OracleColumn) Descriptor
func (*OracleColumn) Descriptor() ([]byte, []int)Deprecated: Use OracleColumn.ProtoReflect.Descriptor instead.
func (*OracleColumn) GetColumn
func (x *OracleColumn) GetColumn() stringfunc (*OracleColumn) GetDataType
func (x *OracleColumn) GetDataType() stringfunc (*OracleColumn) GetEncoding
func (x *OracleColumn) GetEncoding() stringfunc (*OracleColumn) GetLength
func (x *OracleColumn) GetLength() int32func (*OracleColumn) GetNullable
func (x *OracleColumn) GetNullable() boolfunc (*OracleColumn) GetOrdinalPosition
func (x *OracleColumn) GetOrdinalPosition() int32func (*OracleColumn) GetPrecision
func (x *OracleColumn) GetPrecision() int32func (*OracleColumn) GetPrimaryKey
func (x *OracleColumn) GetPrimaryKey() boolfunc (*OracleColumn) GetScale
func (x *OracleColumn) GetScale() int32func (*OracleColumn) ProtoMessage
func (*OracleColumn) ProtoMessage()func (*OracleColumn) ProtoReflect
func (x *OracleColumn) ProtoReflect() protoreflect.Messagefunc (*OracleColumn) Reset
func (x *OracleColumn) Reset()func (*OracleColumn) String
func (x *OracleColumn) String() stringOracleProfile
type OracleProfile struct {
Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
DatabaseService string `protobuf:"bytes,5,opt,name=database_service,json=databaseService,proto3" json:"database_service,omitempty"`
ConnectionAttributes map[string]string "" /* 209 byte string literal not displayed */
}Oracle database profile.
func (*OracleProfile) Descriptor
func (*OracleProfile) Descriptor() ([]byte, []int)Deprecated: Use OracleProfile.ProtoReflect.Descriptor instead.
func (*OracleProfile) GetConnectionAttributes
func (x *OracleProfile) GetConnectionAttributes() map[string]stringfunc (*OracleProfile) GetDatabaseService
func (x *OracleProfile) GetDatabaseService() stringfunc (*OracleProfile) GetHostname
func (x *OracleProfile) GetHostname() stringfunc (*OracleProfile) GetPassword
func (x *OracleProfile) GetPassword() stringfunc (*OracleProfile) GetPort
func (x *OracleProfile) GetPort() int32func (*OracleProfile) GetUsername
func (x *OracleProfile) GetUsername() stringfunc (*OracleProfile) ProtoMessage
func (*OracleProfile) ProtoMessage()func (*OracleProfile) ProtoReflect
func (x *OracleProfile) ProtoReflect() protoreflect.Messagefunc (*OracleProfile) Reset
func (x *OracleProfile) Reset()func (*OracleProfile) String
func (x *OracleProfile) String() stringOracleRdbms
type OracleRdbms struct {
// Oracle schemas/databases in the database server.
OracleSchemas []*OracleSchema `protobuf:"bytes,1,rep,name=oracle_schemas,json=oracleSchemas,proto3" json:"oracle_schemas,omitempty"`
// contains filtered or unexported fields
}Oracle database structure.
func (*OracleRdbms) Descriptor
func (*OracleRdbms) Descriptor() ([]byte, []int)Deprecated: Use OracleRdbms.ProtoReflect.Descriptor instead.
func (*OracleRdbms) GetOracleSchemas
func (x *OracleRdbms) GetOracleSchemas() []*OracleSchemafunc (*OracleRdbms) ProtoMessage
func (*OracleRdbms) ProtoMessage()func (*OracleRdbms) ProtoReflect
func (x *OracleRdbms) ProtoReflect() protoreflect.Messagefunc (*OracleRdbms) Reset
func (x *OracleRdbms) Reset()func (*OracleRdbms) String
func (x *OracleRdbms) String() stringOracleSchema
type OracleSchema struct {
// Schema name.
Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
// Tables in the schema.
OracleTables []*OracleTable `protobuf:"bytes,2,rep,name=oracle_tables,json=oracleTables,proto3" json:"oracle_tables,omitempty"`
// contains filtered or unexported fields
}Oracle schema.
func (*OracleSchema) Descriptor
func (*OracleSchema) Descriptor() ([]byte, []int)Deprecated: Use OracleSchema.ProtoReflect.Descriptor instead.
func (*OracleSchema) GetOracleTables
func (x *OracleSchema) GetOracleTables() []*OracleTablefunc (*OracleSchema) GetSchema
func (x *OracleSchema) GetSchema() stringfunc (*OracleSchema) ProtoMessage
func (*OracleSchema) ProtoMessage()func (*OracleSchema) ProtoReflect
func (x *OracleSchema) ProtoReflect() protoreflect.Messagefunc (*OracleSchema) Reset
func (x *OracleSchema) Reset()func (*OracleSchema) String
func (x *OracleSchema) String() stringOracleSourceConfig
type OracleSourceConfig struct {
IncludeObjects *OracleRdbms `protobuf:"bytes,1,opt,name=include_objects,json=includeObjects,proto3" json:"include_objects,omitempty"`
ExcludeObjects *OracleRdbms `protobuf:"bytes,2,opt,name=exclude_objects,json=excludeObjects,proto3" json:"exclude_objects,omitempty"`
MaxConcurrentCdcTasks int32 "" /* 129 byte string literal not displayed */
MaxConcurrentBackfillTasks int32 "" /* 144 byte string literal not displayed */
LargeObjectsHandling isOracleSourceConfig_LargeObjectsHandling `protobuf_oneof:"large_objects_handling"`
}Oracle data source configuration
func (*OracleSourceConfig) Descriptor
func (*OracleSourceConfig) Descriptor() ([]byte, []int)Deprecated: Use OracleSourceConfig.ProtoReflect.Descriptor instead.
func (*OracleSourceConfig) GetDropLargeObjects
func (x *OracleSourceConfig) GetDropLargeObjects() *OracleSourceConfig_DropLargeObjectsfunc (*OracleSourceConfig) GetExcludeObjects
func (x *OracleSourceConfig) GetExcludeObjects() *OracleRdbmsfunc (*OracleSourceConfig) GetIncludeObjects
func (x *OracleSourceConfig) GetIncludeObjects() *OracleRdbmsfunc (*OracleSourceConfig) GetLargeObjectsHandling
func (m *OracleSourceConfig) GetLargeObjectsHandling() isOracleSourceConfig_LargeObjectsHandlingfunc (*OracleSourceConfig) GetMaxConcurrentBackfillTasks
func (x *OracleSourceConfig) GetMaxConcurrentBackfillTasks() int32func (*OracleSourceConfig) GetMaxConcurrentCdcTasks
func (x *OracleSourceConfig) GetMaxConcurrentCdcTasks() int32func (*OracleSourceConfig) GetStreamLargeObjects
func (x *OracleSourceConfig) GetStreamLargeObjects() *OracleSourceConfig_StreamLargeObjectsfunc (*OracleSourceConfig) ProtoMessage
func (*OracleSourceConfig) ProtoMessage()func (*OracleSourceConfig) ProtoReflect
func (x *OracleSourceConfig) ProtoReflect() protoreflect.Messagefunc (*OracleSourceConfig) Reset
func (x *OracleSourceConfig) Reset()func (*OracleSourceConfig) String
func (x *OracleSourceConfig) String() stringOracleSourceConfig_DropLargeObjects
type OracleSourceConfig_DropLargeObjects struct {
// contains filtered or unexported fields
}Configuration to drop large object values.
func (*OracleSourceConfig_DropLargeObjects) Descriptor
func (*OracleSourceConfig_DropLargeObjects) Descriptor() ([]byte, []int)Deprecated: Use OracleSourceConfig_DropLargeObjects.ProtoReflect.Descriptor instead.
func (*OracleSourceConfig_DropLargeObjects) ProtoMessage
func (*OracleSourceConfig_DropLargeObjects) ProtoMessage()func (*OracleSourceConfig_DropLargeObjects) ProtoReflect
func (x *OracleSourceConfig_DropLargeObjects) ProtoReflect() protoreflect.Messagefunc (*OracleSourceConfig_DropLargeObjects) Reset
func (x *OracleSourceConfig_DropLargeObjects) Reset()func (*OracleSourceConfig_DropLargeObjects) String
func (x *OracleSourceConfig_DropLargeObjects) String() stringOracleSourceConfig_DropLargeObjects_
type OracleSourceConfig_DropLargeObjects_ struct {
// Drop large object values.
DropLargeObjects *OracleSourceConfig_DropLargeObjects `protobuf:"bytes,100,opt,name=drop_large_objects,json=dropLargeObjects,proto3,oneof"`
}OracleSourceConfig_StreamLargeObjects
type OracleSourceConfig_StreamLargeObjects struct {
// contains filtered or unexported fields
}Configuration to stream large object values.
func (*OracleSourceConfig_StreamLargeObjects) Descriptor
func (*OracleSourceConfig_StreamLargeObjects) Descriptor() ([]byte, []int)Deprecated: Use OracleSourceConfig_StreamLargeObjects.ProtoReflect.Descriptor instead.
func (*OracleSourceConfig_StreamLargeObjects) ProtoMessage
func (*OracleSourceConfig_StreamLargeObjects) ProtoMessage()func (*OracleSourceConfig_StreamLargeObjects) ProtoReflect
func (x *OracleSourceConfig_StreamLargeObjects) ProtoReflect() protoreflect.Messagefunc (*OracleSourceConfig_StreamLargeObjects) Reset
func (x *OracleSourceConfig_StreamLargeObjects) Reset()func (*OracleSourceConfig_StreamLargeObjects) String
func (x *OracleSourceConfig_StreamLargeObjects) String() stringOracleSourceConfig_StreamLargeObjects_
type OracleSourceConfig_StreamLargeObjects_ struct {
// Stream large object values. NOTE: This feature is currently experimental.
StreamLargeObjects *OracleSourceConfig_StreamLargeObjects `protobuf:"bytes,102,opt,name=stream_large_objects,json=streamLargeObjects,proto3,oneof"`
}OracleTable
type OracleTable struct {
// Table name.
Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
// Oracle columns in the schema.
// When unspecified as part of include/exclude objects, includes/excludes
// everything.
OracleColumns []*OracleColumn `protobuf:"bytes,2,rep,name=oracle_columns,json=oracleColumns,proto3" json:"oracle_columns,omitempty"`
// contains filtered or unexported fields
}Oracle table.
func (*OracleTable) Descriptor
func (*OracleTable) Descriptor() ([]byte, []int)Deprecated: Use OracleTable.ProtoReflect.Descriptor instead.
func (*OracleTable) GetOracleColumns
func (x *OracleTable) GetOracleColumns() []*OracleColumnfunc (*OracleTable) GetTable
func (x *OracleTable) GetTable() stringfunc (*OracleTable) ProtoMessage
func (*OracleTable) ProtoMessage()func (*OracleTable) ProtoReflect
func (x *OracleTable) ProtoReflect() protoreflect.Messagefunc (*OracleTable) Reset
func (x *OracleTable) Reset()func (*OracleTable) String
func (x *OracleTable) String() stringPostgresqlColumn
type PostgresqlColumn struct {
// Column name.
Column string `protobuf:"bytes,1,opt,name=column,proto3" json:"column,omitempty"`
// The PostgreSQL data type.
DataType string `protobuf:"bytes,2,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty"`
// Column length.
Length int32 `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
// Column precision.
Precision int32 `protobuf:"varint,4,opt,name=precision,proto3" json:"precision,omitempty"`
// Column scale.
Scale int32 `protobuf:"varint,5,opt,name=scale,proto3" json:"scale,omitempty"`
// Whether or not the column represents a primary key.
PrimaryKey bool `protobuf:"varint,7,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
// Whether or not the column can accept a null value.
Nullable bool `protobuf:"varint,8,opt,name=nullable,proto3" json:"nullable,omitempty"`
// The ordinal position of the column in the table.
OrdinalPosition int32 `protobuf:"varint,9,opt,name=ordinal_position,json=ordinalPosition,proto3" json:"ordinal_position,omitempty"`
// contains filtered or unexported fields
}PostgreSQL Column.
func (*PostgresqlColumn) Descriptor
func (*PostgresqlColumn) Descriptor() ([]byte, []int)Deprecated: Use PostgresqlColumn.ProtoReflect.Descriptor instead.
func (*PostgresqlColumn) GetColumn
func (x *PostgresqlColumn) GetColumn() stringfunc (*PostgresqlColumn) GetDataType
func (x *PostgresqlColumn) GetDataType() stringfunc (*PostgresqlColumn) GetLength
func (x *PostgresqlColumn) GetLength() int32func (*PostgresqlColumn) GetNullable
func (x *PostgresqlColumn) GetNullable() boolfunc (*PostgresqlColumn) GetOrdinalPosition
func (x *PostgresqlColumn) GetOrdinalPosition() int32func (*PostgresqlColumn) GetPrecision
func (x *PostgresqlColumn) GetPrecision() int32func (*PostgresqlColumn) GetPrimaryKey
func (x *PostgresqlColumn) GetPrimaryKey() boolfunc (*PostgresqlColumn) GetScale
func (x *PostgresqlColumn) GetScale() int32func (*PostgresqlColumn) ProtoMessage
func (*PostgresqlColumn) ProtoMessage()func (*PostgresqlColumn) ProtoReflect
func (x *PostgresqlColumn) ProtoReflect() protoreflect.Messagefunc (*PostgresqlColumn) Reset
func (x *PostgresqlColumn) Reset()func (*PostgresqlColumn) String
func (x *PostgresqlColumn) String() stringPostgresqlProfile
type PostgresqlProfile struct {
// Required. Hostname for the PostgreSQL connection.
Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
// Port for the PostgreSQL connection, default value is 5432.
Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
// Required. Username for the PostgreSQL connection.
Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
// Required. Password for the PostgreSQL connection.
Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
// Required. Database for the PostgreSQL connection.
Database string `protobuf:"bytes,5,opt,name=database,proto3" json:"database,omitempty"`
// contains filtered or unexported fields
}PostgreSQL database profile.
func (*PostgresqlProfile) Descriptor
func (*PostgresqlProfile) Descriptor() ([]byte, []int)Deprecated: Use PostgresqlProfile.ProtoReflect.Descriptor instead.
func (*PostgresqlProfile) GetDatabase
func (x *PostgresqlProfile) GetDatabase() stringfunc (*PostgresqlProfile) GetHostname
func (x *PostgresqlProfile) GetHostname() stringfunc (*PostgresqlProfile) GetPassword
func (x *PostgresqlProfile) GetPassword() stringfunc (*PostgresqlProfile) GetPort
func (x *PostgresqlProfile) GetPort() int32func (*PostgresqlProfile) GetUsername
func (x *PostgresqlProfile) GetUsername() stringfunc (*PostgresqlProfile) ProtoMessage
func (*PostgresqlProfile) ProtoMessage()func (*PostgresqlProfile) ProtoReflect
func (x *PostgresqlProfile) ProtoReflect() protoreflect.Messagefunc (*PostgresqlProfile) Reset
func (x *PostgresqlProfile) Reset()func (*PostgresqlProfile) String
func (x *PostgresqlProfile) String() stringPostgresqlRdbms
type PostgresqlRdbms struct {
// PostgreSQL schemas in the database server.
PostgresqlSchemas []*PostgresqlSchema `protobuf:"bytes,1,rep,name=postgresql_schemas,json=postgresqlSchemas,proto3" json:"postgresql_schemas,omitempty"`
// contains filtered or unexported fields
}PostgreSQL database structure.
func (*PostgresqlRdbms) Descriptor
func (*PostgresqlRdbms) Descriptor() ([]byte, []int)Deprecated: Use PostgresqlRdbms.ProtoReflect.Descriptor instead.
func (*PostgresqlRdbms) GetPostgresqlSchemas
func (x *PostgresqlRdbms) GetPostgresqlSchemas() []*PostgresqlSchemafunc (*PostgresqlRdbms) ProtoMessage
func (*PostgresqlRdbms) ProtoMessage()func (*PostgresqlRdbms) ProtoReflect
func (x *PostgresqlRdbms) ProtoReflect() protoreflect.Messagefunc (*PostgresqlRdbms) Reset
func (x *PostgresqlRdbms) Reset()func (*PostgresqlRdbms) String
func (x *PostgresqlRdbms) String() stringPostgresqlSchema
type PostgresqlSchema struct {
// Schema name.
Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
// Tables in the schema.
PostgresqlTables []*PostgresqlTable `protobuf:"bytes,2,rep,name=postgresql_tables,json=postgresqlTables,proto3" json:"postgresql_tables,omitempty"`
// contains filtered or unexported fields
}PostgreSQL schema.
func (*PostgresqlSchema) Descriptor
func (*PostgresqlSchema) Descriptor() ([]byte, []int)Deprecated: Use PostgresqlSchema.ProtoReflect.Descriptor instead.
func (*PostgresqlSchema) GetPostgresqlTables
func (x *PostgresqlSchema) GetPostgresqlTables() []*PostgresqlTablefunc (*PostgresqlSchema) GetSchema
func (x *PostgresqlSchema) GetSchema() stringfunc (*PostgresqlSchema) ProtoMessage
func (*PostgresqlSchema) ProtoMessage()func (*PostgresqlSchema) ProtoReflect
func (x *PostgresqlSchema) ProtoReflect() protoreflect.Messagefunc (*PostgresqlSchema) Reset
func (x *PostgresqlSchema) Reset()func (*PostgresqlSchema) String
func (x *PostgresqlSchema) String() stringPostgresqlSourceConfig
type PostgresqlSourceConfig struct {
IncludeObjects *PostgresqlRdbms `protobuf:"bytes,1,opt,name=include_objects,json=includeObjects,proto3" json:"include_objects,omitempty"`
ExcludeObjects *PostgresqlRdbms `protobuf:"bytes,2,opt,name=exclude_objects,json=excludeObjects,proto3" json:"exclude_objects,omitempty"`
ReplicationSlot string `protobuf:"bytes,3,opt,name=replication_slot,json=replicationSlot,proto3" json:"replication_slot,omitempty"`
Publication string `protobuf:"bytes,4,opt,name=publication,proto3" json:"publication,omitempty"`
MaxConcurrentBackfillTasks int32 "" /* 144 byte string literal not displayed */
}PostgreSQL data source configuration
func (*PostgresqlSourceConfig) Descriptor
func (*PostgresqlSourceConfig) Descriptor() ([]byte, []int)Deprecated: Use PostgresqlSourceConfig.ProtoReflect.Descriptor instead.
func (*PostgresqlSourceConfig) GetExcludeObjects
func (x *PostgresqlSourceConfig) GetExcludeObjects() *PostgresqlRdbmsfunc (*PostgresqlSourceConfig) GetIncludeObjects
func (x *PostgresqlSourceConfig) GetIncludeObjects() *PostgresqlRdbmsfunc (*PostgresqlSourceConfig) GetMaxConcurrentBackfillTasks
func (x *PostgresqlSourceConfig) GetMaxConcurrentBackfillTasks() int32func (*PostgresqlSourceConfig) GetPublication
func (x *PostgresqlSourceConfig) GetPublication() stringfunc (*PostgresqlSourceConfig) GetReplicationSlot
func (x *PostgresqlSourceConfig) GetReplicationSlot() stringfunc (*PostgresqlSourceConfig) ProtoMessage
func (*PostgresqlSourceConfig) ProtoMessage()func (*PostgresqlSourceConfig) ProtoReflect
func (x *PostgresqlSourceConfig) ProtoReflect() protoreflect.Messagefunc (*PostgresqlSourceConfig) Reset
func (x *PostgresqlSourceConfig) Reset()func (*PostgresqlSourceConfig) String
func (x *PostgresqlSourceConfig) String() stringPostgresqlTable
type PostgresqlTable struct {
// Table name.
Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
// PostgreSQL columns in the schema.
// When unspecified as part of include/exclude objects,
// includes/excludes everything.
PostgresqlColumns []*PostgresqlColumn `protobuf:"bytes,2,rep,name=postgresql_columns,json=postgresqlColumns,proto3" json:"postgresql_columns,omitempty"`
// contains filtered or unexported fields
}PostgreSQL table.
func (*PostgresqlTable) Descriptor
func (*PostgresqlTable) Descriptor() ([]byte, []int)Deprecated: Use PostgresqlTable.ProtoReflect.Descriptor instead.
func (*PostgresqlTable) GetPostgresqlColumns
func (x *PostgresqlTable) GetPostgresqlColumns() []*PostgresqlColumnfunc (*PostgresqlTable) GetTable
func (x *PostgresqlTable) GetTable() stringfunc (*PostgresqlTable) ProtoMessage
func (*PostgresqlTable) ProtoMessage()func (*PostgresqlTable) ProtoReflect
func (x *PostgresqlTable) ProtoReflect() protoreflect.Messagefunc (*PostgresqlTable) Reset
func (x *PostgresqlTable) Reset()func (*PostgresqlTable) String
func (x *PostgresqlTable) String() stringPrivateConnection
type PrivateConnection struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
Labels map[string]string "" /* 153 byte string literal not displayed */
DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
State PrivateConnection_State `protobuf:"varint,6,opt,name=state,proto3,enum=google.cloud.datastream.v1.PrivateConnection_State" json:"state,omitempty"`
Error *Error `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"`
VpcPeeringConfig *VpcPeeringConfig `protobuf:"bytes,100,opt,name=vpc_peering_config,json=vpcPeeringConfig,proto3" json:"vpc_peering_config,omitempty"`
}The PrivateConnection resource is used to establish private connectivity between Datastream and a customer's network.
func (*PrivateConnection) Descriptor
func (*PrivateConnection) Descriptor() ([]byte, []int)Deprecated: Use PrivateConnection.ProtoReflect.Descriptor instead.
func (*PrivateConnection) GetCreateTime
func (x *PrivateConnection) GetCreateTime() *timestamppb.Timestampfunc (*PrivateConnection) GetDisplayName
func (x *PrivateConnection) GetDisplayName() stringfunc (*PrivateConnection) GetError
func (x *PrivateConnection) GetError() *Errorfunc (*PrivateConnection) GetLabels
func (x *PrivateConnection) GetLabels() map[string]stringfunc (*PrivateConnection) GetName
func (x *PrivateConnection) GetName() stringfunc (*PrivateConnection) GetState
func (x *PrivateConnection) GetState() PrivateConnection_Statefunc (*PrivateConnection) GetUpdateTime
func (x *PrivateConnection) GetUpdateTime() *timestamppb.Timestampfunc (*PrivateConnection) GetVpcPeeringConfig
func (x *PrivateConnection) GetVpcPeeringConfig() *VpcPeeringConfigfunc (*PrivateConnection) ProtoMessage
func (*PrivateConnection) ProtoMessage()func (*PrivateConnection) ProtoReflect
func (x *PrivateConnection) ProtoReflect() protoreflect.Messagefunc (*PrivateConnection) Reset
func (x *PrivateConnection) Reset()func (*PrivateConnection) String
func (x *PrivateConnection) String() stringPrivateConnection_State
type PrivateConnection_State int32Private Connection state.
PrivateConnection_STATE_UNSPECIFIED, PrivateConnection_CREATING, PrivateConnection_CREATED, PrivateConnection_FAILED, PrivateConnection_DELETING, PrivateConnection_FAILED_TO_DELETE
const (
// Unspecified state.
PrivateConnection_STATE_UNSPECIFIED PrivateConnection_State = 0
// The private connection is in creation state - creating resources.
PrivateConnection_CREATING PrivateConnection_State = 1
// The private connection has been created with all of its resources.
PrivateConnection_CREATED PrivateConnection_State = 2
// The private connection creation has failed.
PrivateConnection_FAILED PrivateConnection_State = 3
// The private connection is being deleted.
PrivateConnection_DELETING PrivateConnection_State = 4
// Delete request has failed, resource is in invalid state.
PrivateConnection_FAILED_TO_DELETE PrivateConnection_State = 5
)func (PrivateConnection_State) Descriptor
func (PrivateConnection_State) Descriptor() protoreflect.EnumDescriptorfunc (PrivateConnection_State) Enum
func (x PrivateConnection_State) Enum() *PrivateConnection_Statefunc (PrivateConnection_State) EnumDescriptor
func (PrivateConnection_State) EnumDescriptor() ([]byte, []int)Deprecated: Use PrivateConnection_State.Descriptor instead.
func (PrivateConnection_State) Number
func (x PrivateConnection_State) Number() protoreflect.EnumNumberfunc (PrivateConnection_State) String
func (x PrivateConnection_State) String() stringfunc (PrivateConnection_State) Type
func (PrivateConnection_State) Type() protoreflect.EnumTypePrivateConnectivity
type PrivateConnectivity struct {
// Required. A reference to a private connection resource.
// Format: `projects/{project}/locations/{location}/privateConnections/{name}`
PrivateConnection string `protobuf:"bytes,1,opt,name=private_connection,json=privateConnection,proto3" json:"private_connection,omitempty"`
// contains filtered or unexported fields
}Private Connectivity
func (*PrivateConnectivity) Descriptor
func (*PrivateConnectivity) Descriptor() ([]byte, []int)Deprecated: Use PrivateConnectivity.ProtoReflect.Descriptor instead.
func (*PrivateConnectivity) GetPrivateConnection
func (x *PrivateConnectivity) GetPrivateConnection() stringfunc (*PrivateConnectivity) ProtoMessage
func (*PrivateConnectivity) ProtoMessage()func (*PrivateConnectivity) ProtoReflect
func (x *PrivateConnectivity) ProtoReflect() protoreflect.Messagefunc (*PrivateConnectivity) Reset
func (x *PrivateConnectivity) Reset()func (*PrivateConnectivity) String
func (x *PrivateConnectivity) String() stringRoute
type Route struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
Labels map[string]string "" /* 153 byte string literal not displayed */
DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
DestinationAddress string `protobuf:"bytes,6,opt,name=destination_address,json=destinationAddress,proto3" json:"destination_address,omitempty"`
DestinationPort int32 `protobuf:"varint,7,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"`
}The route resource is the child of the private connection resource, used for defining a route for a private connection.
func (*Route) Descriptor
Deprecated: Use Route.ProtoReflect.Descriptor instead.
func (*Route) GetCreateTime
func (x *Route) GetCreateTime() *timestamppb.Timestampfunc (*Route) GetDestinationAddress
func (*Route) GetDestinationPort
func (*Route) GetDisplayName
func (*Route) GetLabels
func (*Route) GetName
func (*Route) GetUpdateTime
func (x *Route) GetUpdateTime() *timestamppb.Timestampfunc (*Route) ProtoMessage
func (*Route) ProtoMessage()func (*Route) ProtoReflect
func (x *Route) ProtoReflect() protoreflect.Messagefunc (*Route) Reset
func (x *Route) Reset()func (*Route) String
SourceConfig
type SourceConfig struct {
SourceConnectionProfile string "" /* 132 byte string literal not displayed */
SourceStreamConfig isSourceConfig_SourceStreamConfig `protobuf_oneof:"source_stream_config"`
}The configuration of the stream source.
func (*SourceConfig) Descriptor
func (*SourceConfig) Descriptor() ([]byte, []int)Deprecated: Use SourceConfig.ProtoReflect.Descriptor instead.
func (*SourceConfig) GetMysqlSourceConfig
func (x *SourceConfig) GetMysqlSourceConfig() *MysqlSourceConfigfunc (*SourceConfig) GetOracleSourceConfig
func (x *SourceConfig) GetOracleSourceConfig() *OracleSourceConfigfunc (*SourceConfig) GetPostgresqlSourceConfig
func (x *SourceConfig) GetPostgresqlSourceConfig() *PostgresqlSourceConfigfunc (*SourceConfig) GetSourceConnectionProfile
func (x *SourceConfig) GetSourceConnectionProfile() stringfunc (*SourceConfig) GetSourceStreamConfig
func (m *SourceConfig) GetSourceStreamConfig() isSourceConfig_SourceStreamConfigfunc (*SourceConfig) ProtoMessage
func (*SourceConfig) ProtoMessage()func (*SourceConfig) ProtoReflect
func (x *SourceConfig) ProtoReflect() protoreflect.Messagefunc (*SourceConfig) Reset
func (x *SourceConfig) Reset()func (*SourceConfig) String
func (x *SourceConfig) String() stringSourceConfig_MysqlSourceConfig
type SourceConfig_MysqlSourceConfig struct {
// MySQL data source configuration.
MysqlSourceConfig *MysqlSourceConfig `protobuf:"bytes,101,opt,name=mysql_source_config,json=mysqlSourceConfig,proto3,oneof"`
}SourceConfig_OracleSourceConfig
type SourceConfig_OracleSourceConfig struct {
// Oracle data source configuration.
OracleSourceConfig *OracleSourceConfig `protobuf:"bytes,100,opt,name=oracle_source_config,json=oracleSourceConfig,proto3,oneof"`
}SourceConfig_PostgresqlSourceConfig
type SourceConfig_PostgresqlSourceConfig struct {
// PostgreSQL data source configuration.
PostgresqlSourceConfig *PostgresqlSourceConfig `protobuf:"bytes,102,opt,name=postgresql_source_config,json=postgresqlSourceConfig,proto3,oneof"`
}SourceObjectIdentifier
type SourceObjectIdentifier struct {
// The identifier for an object in the data source.
//
// Types that are assignable to SourceIdentifier:
//
// *SourceObjectIdentifier_OracleIdentifier
// *SourceObjectIdentifier_MysqlIdentifier
// *SourceObjectIdentifier_PostgresqlIdentifier
SourceIdentifier isSourceObjectIdentifier_SourceIdentifier `protobuf_oneof:"source_identifier"`
// contains filtered or unexported fields
}Represents an identifier of an object in the data source.
func (*SourceObjectIdentifier) Descriptor
func (*SourceObjectIdentifier) Descriptor() ([]byte, []int)Deprecated: Use SourceObjectIdentifier.ProtoReflect.Descriptor instead.
func (*SourceObjectIdentifier) GetMysqlIdentifier
func (x *SourceObjectIdentifier) GetMysqlIdentifier() *SourceObjectIdentifier_MysqlObjectIdentifierfunc (*SourceObjectIdentifier) GetOracleIdentifier
func (x *SourceObjectIdentifier) GetOracleIdentifier() *SourceObjectIdentifier_OracleObjectIdentifierfunc (*SourceObjectIdentifier) GetPostgresqlIdentifier
func (x *SourceObjectIdentifier) GetPostgresqlIdentifier() *SourceObjectIdentifier_PostgresqlObjectIdentifierfunc (*SourceObjectIdentifier) GetSourceIdentifier
func (m *SourceObjectIdentifier) GetSourceIdentifier() isSourceObjectIdentifier_SourceIdentifierfunc (*SourceObjectIdentifier) ProtoMessage
func (*SourceObjectIdentifier) ProtoMessage()func (*SourceObjectIdentifier) ProtoReflect
func (x *SourceObjectIdentifier) ProtoReflect() protoreflect.Messagefunc (*SourceObjectIdentifier) Reset
func (x *SourceObjectIdentifier) Reset()func (*SourceObjectIdentifier) String
func (x *SourceObjectIdentifier) String() stringSourceObjectIdentifier_MysqlIdentifier
type SourceObjectIdentifier_MysqlIdentifier struct {
// Mysql data source object identifier.
MysqlIdentifier *SourceObjectIdentifier_MysqlObjectIdentifier `protobuf:"bytes,2,opt,name=mysql_identifier,json=mysqlIdentifier,proto3,oneof"`
}SourceObjectIdentifier_MysqlObjectIdentifier
type SourceObjectIdentifier_MysqlObjectIdentifier struct {
// Required. The database name.
Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
// Required. The table name.
Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
// contains filtered or unexported fields
}Mysql data source object identifier.
func (*SourceObjectIdentifier_MysqlObjectIdentifier) Descriptor
func (*SourceObjectIdentifier_MysqlObjectIdentifier) Descriptor() ([]byte, []int)Deprecated: Use SourceObjectIdentifier_MysqlObjectIdentifier.ProtoReflect.Descriptor instead.
func (*SourceObjectIdentifier_MysqlObjectIdentifier) GetDatabase
func (x *SourceObjectIdentifier_MysqlObjectIdentifier) GetDatabase() stringfunc (*SourceObjectIdentifier_MysqlObjectIdentifier) GetTable
func (x *SourceObjectIdentifier_MysqlObjectIdentifier) GetTable() stringfunc (*SourceObjectIdentifier_MysqlObjectIdentifier) ProtoMessage
func (*SourceObjectIdentifier_MysqlObjectIdentifier) ProtoMessage()func (*SourceObjectIdentifier_MysqlObjectIdentifier) ProtoReflect
func (x *SourceObjectIdentifier_MysqlObjectIdentifier) ProtoReflect() protoreflect.Messagefunc (*SourceObjectIdentifier_MysqlObjectIdentifier) Reset
func (x *SourceObjectIdentifier_MysqlObjectIdentifier) Reset()func (*SourceObjectIdentifier_MysqlObjectIdentifier) String
func (x *SourceObjectIdentifier_MysqlObjectIdentifier) String() stringSourceObjectIdentifier_OracleIdentifier
type SourceObjectIdentifier_OracleIdentifier struct {
// Oracle data source object identifier.
OracleIdentifier *SourceObjectIdentifier_OracleObjectIdentifier `protobuf:"bytes,1,opt,name=oracle_identifier,json=oracleIdentifier,proto3,oneof"`
}SourceObjectIdentifier_OracleObjectIdentifier
type SourceObjectIdentifier_OracleObjectIdentifier struct {
// Required. The schema name.
Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
// Required. The table name.
Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
// contains filtered or unexported fields
}Oracle data source object identifier.
func (*SourceObjectIdentifier_OracleObjectIdentifier) Descriptor
func (*SourceObjectIdentifier_OracleObjectIdentifier) Descriptor() ([]byte, []int)Deprecated: Use SourceObjectIdentifier_OracleObjectIdentifier.ProtoReflect.Descriptor instead.
func (*SourceObjectIdentifier_OracleObjectIdentifier) GetSchema
func (x *SourceObjectIdentifier_OracleObjectIdentifier) GetSchema() stringfunc (*SourceObjectIdentifier_OracleObjectIdentifier) GetTable
func (x *SourceObjectIdentifier_OracleObjectIdentifier) GetTable() stringfunc (*SourceObjectIdentifier_OracleObjectIdentifier) ProtoMessage
func (*SourceObjectIdentifier_OracleObjectIdentifier) ProtoMessage()func (*SourceObjectIdentifier_OracleObjectIdentifier) ProtoReflect
func (x *SourceObjectIdentifier_OracleObjectIdentifier) ProtoReflect() protoreflect.Messagefunc (*SourceObjectIdentifier_OracleObjectIdentifier) Reset
func (x *SourceObjectIdentifier_OracleObjectIdentifier) Reset()func (*SourceObjectIdentifier_OracleObjectIdentifier) String
func (x *SourceObjectIdentifier_OracleObjectIdentifier) String() stringSourceObjectIdentifier_PostgresqlIdentifier
type SourceObjectIdentifier_PostgresqlIdentifier struct {
// PostgreSQL data source object identifier.
PostgresqlIdentifier *SourceObjectIdentifier_PostgresqlObjectIdentifier `protobuf:"bytes,3,opt,name=postgresql_identifier,json=postgresqlIdentifier,proto3,oneof"`
}SourceObjectIdentifier_PostgresqlObjectIdentifier
type SourceObjectIdentifier_PostgresqlObjectIdentifier struct {
// Required. The schema name.
Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
// Required. The table name.
Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
// contains filtered or unexported fields
}PostgreSQL data source object identifier.
func (*SourceObjectIdentifier_PostgresqlObjectIdentifier) Descriptor
func (*SourceObjectIdentifier_PostgresqlObjectIdentifier) Descriptor() ([]byte, []int)Deprecated: Use SourceObjectIdentifier_PostgresqlObjectIdentifier.ProtoReflect.Descriptor instead.
func (*SourceObjectIdentifier_PostgresqlObjectIdentifier) GetSchema
func (x *SourceObjectIdentifier_PostgresqlObjectIdentifier) GetSchema() stringfunc (*SourceObjectIdentifier_PostgresqlObjectIdentifier) GetTable
func (x *SourceObjectIdentifier_PostgresqlObjectIdentifier) GetTable() stringfunc (*SourceObjectIdentifier_PostgresqlObjectIdentifier) ProtoMessage
func (*SourceObjectIdentifier_PostgresqlObjectIdentifier) ProtoMessage()func (*SourceObjectIdentifier_PostgresqlObjectIdentifier) ProtoReflect
func (x *SourceObjectIdentifier_PostgresqlObjectIdentifier) ProtoReflect() protoreflect.Messagefunc (*SourceObjectIdentifier_PostgresqlObjectIdentifier) Reset
func (x *SourceObjectIdentifier_PostgresqlObjectIdentifier) Reset()func (*SourceObjectIdentifier_PostgresqlObjectIdentifier) String
func (x *SourceObjectIdentifier_PostgresqlObjectIdentifier) String() stringStartBackfillJobRequest
type StartBackfillJobRequest struct {
// Required. The name of the stream object resource to start a backfill job
// for.
Object string `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
// contains filtered or unexported fields
}Request for manually initiating a backfill job for a specific stream object.
func (*StartBackfillJobRequest) Descriptor
func (*StartBackfillJobRequest) Descriptor() ([]byte, []int)Deprecated: Use StartBackfillJobRequest.ProtoReflect.Descriptor instead.
func (*StartBackfillJobRequest) GetObject
func (x *StartBackfillJobRequest) GetObject() stringfunc (*StartBackfillJobRequest) ProtoMessage
func (*StartBackfillJobRequest) ProtoMessage()func (*StartBackfillJobRequest) ProtoReflect
func (x *StartBackfillJobRequest) ProtoReflect() protoreflect.Messagefunc (*StartBackfillJobRequest) Reset
func (x *StartBackfillJobRequest) Reset()func (*StartBackfillJobRequest) String
func (x *StartBackfillJobRequest) String() stringStartBackfillJobResponse
type StartBackfillJobResponse struct {
// The stream object resource a backfill job was started for.
Object *StreamObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
// contains filtered or unexported fields
}Response for manually initiating a backfill job for a specific stream object.
func (*StartBackfillJobResponse) Descriptor
func (*StartBackfillJobResponse) Descriptor() ([]byte, []int)Deprecated: Use StartBackfillJobResponse.ProtoReflect.Descriptor instead.
func (*StartBackfillJobResponse) GetObject
func (x *StartBackfillJobResponse) GetObject() *StreamObjectfunc (*StartBackfillJobResponse) ProtoMessage
func (*StartBackfillJobResponse) ProtoMessage()func (*StartBackfillJobResponse) ProtoReflect
func (x *StartBackfillJobResponse) ProtoReflect() protoreflect.Messagefunc (*StartBackfillJobResponse) Reset
func (x *StartBackfillJobResponse) Reset()func (*StartBackfillJobResponse) String
func (x *StartBackfillJobResponse) String() stringStaticServiceIpConnectivity
type StaticServiceIpConnectivity struct {
// contains filtered or unexported fields
}Static IP address connectivity. Used when the source database is configured to allow incoming connections from the Datastream public IP addresses for the region specified in the connection profile.
func (*StaticServiceIpConnectivity) Descriptor
func (*StaticServiceIpConnectivity) Descriptor() ([]byte, []int)Deprecated: Use StaticServiceIpConnectivity.ProtoReflect.Descriptor instead.
func (*StaticServiceIpConnectivity) ProtoMessage
func (*StaticServiceIpConnectivity) ProtoMessage()func (*StaticServiceIpConnectivity) ProtoReflect
func (x *StaticServiceIpConnectivity) ProtoReflect() protoreflect.Messagefunc (*StaticServiceIpConnectivity) Reset
func (x *StaticServiceIpConnectivity) Reset()func (*StaticServiceIpConnectivity) String
func (x *StaticServiceIpConnectivity) String() stringStopBackfillJobRequest
type StopBackfillJobRequest struct {
// Required. The name of the stream object resource to stop the backfill job
// for.
Object string `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
// contains filtered or unexported fields
}Request for manually stopping a running backfill job for a specific stream object.
func (*StopBackfillJobRequest) Descriptor
func (*StopBackfillJobRequest) Descriptor() ([]byte, []int)Deprecated: Use StopBackfillJobRequest.ProtoReflect.Descriptor instead.
func (*StopBackfillJobRequest) GetObject
func (x *StopBackfillJobRequest) GetObject() stringfunc (*StopBackfillJobRequest) ProtoMessage
func (*StopBackfillJobRequest) ProtoMessage()func (*StopBackfillJobRequest) ProtoReflect
func (x *StopBackfillJobRequest) ProtoReflect() protoreflect.Messagefunc (*StopBackfillJobRequest) Reset
func (x *StopBackfillJobRequest) Reset()func (*StopBackfillJobRequest) String
func (x *StopBackfillJobRequest) String() stringStopBackfillJobResponse
type StopBackfillJobResponse struct {
// The stream object resource the backfill job was stopped for.
Object *StreamObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
// contains filtered or unexported fields
}Response for manually stop a backfill job for a specific stream object.
func (*StopBackfillJobResponse) Descriptor
func (*StopBackfillJobResponse) Descriptor() ([]byte, []int)Deprecated: Use StopBackfillJobResponse.ProtoReflect.Descriptor instead.
func (*StopBackfillJobResponse) GetObject
func (x *StopBackfillJobResponse) GetObject() *StreamObjectfunc (*StopBackfillJobResponse) ProtoMessage
func (*StopBackfillJobResponse) ProtoMessage()func (*StopBackfillJobResponse) ProtoReflect
func (x *StopBackfillJobResponse) ProtoReflect() protoreflect.Messagefunc (*StopBackfillJobResponse) Reset
func (x *StopBackfillJobResponse) Reset()func (*StopBackfillJobResponse) String
func (x *StopBackfillJobResponse) String() stringStream
type Stream struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
Labels map[string]string "" /* 153 byte string literal not displayed */
DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
SourceConfig *SourceConfig `protobuf:"bytes,6,opt,name=source_config,json=sourceConfig,proto3" json:"source_config,omitempty"`
DestinationConfig *DestinationConfig `protobuf:"bytes,7,opt,name=destination_config,json=destinationConfig,proto3" json:"destination_config,omitempty"`
State Stream_State `protobuf:"varint,8,opt,name=state,proto3,enum=google.cloud.datastream.v1.Stream_State" json:"state,omitempty"`
BackfillStrategy isStream_BackfillStrategy `protobuf_oneof:"backfill_strategy"`
Errors []*Error `protobuf:"bytes,9,rep,name=errors,proto3" json:"errors,omitempty"`
CustomerManagedEncryptionKey *string "" /* 156 byte string literal not displayed */
}A resource representing streaming data from a source to a destination.
func (*Stream) Descriptor
Deprecated: Use Stream.ProtoReflect.Descriptor instead.
func (*Stream) GetBackfillAll
func (x *Stream) GetBackfillAll() *Stream_BackfillAllStrategyfunc (*Stream) GetBackfillNone
func (x *Stream) GetBackfillNone() *Stream_BackfillNoneStrategyfunc (*Stream) GetBackfillStrategy
func (m *Stream) GetBackfillStrategy() isStream_BackfillStrategyfunc (*Stream) GetCreateTime
func (x *Stream) GetCreateTime() *timestamppb.Timestampfunc (*Stream) GetCustomerManagedEncryptionKey
func (*Stream) GetDestinationConfig
func (x *Stream) GetDestinationConfig() *DestinationConfigfunc (*Stream) GetDisplayName
func (*Stream) GetErrors
func (*Stream) GetLabels
func (*Stream) GetName
func (*Stream) GetSourceConfig
func (x *Stream) GetSourceConfig() *SourceConfigfunc (*Stream) GetState
func (x *Stream) GetState() Stream_Statefunc (*Stream) GetUpdateTime
func (x *Stream) GetUpdateTime() *timestamppb.Timestampfunc (*Stream) ProtoMessage
func (*Stream) ProtoMessage()func (*Stream) ProtoReflect
func (x *Stream) ProtoReflect() protoreflect.Messagefunc (*Stream) Reset
func (x *Stream) Reset()func (*Stream) String
StreamObject
type StreamObject struct {
// Output only. The object resource's name.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Output only. The creation time of the object.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The last update time of the object.
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// Required. Display name.
DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
// Output only. Active errors on the object.
Errors []*Error `protobuf:"bytes,6,rep,name=errors,proto3" json:"errors,omitempty"`
// The latest backfill job that was initiated for the stream object.
BackfillJob *BackfillJob `protobuf:"bytes,7,opt,name=backfill_job,json=backfillJob,proto3" json:"backfill_job,omitempty"`
// The object identifier in the data source.
SourceObject *SourceObjectIdentifier `protobuf:"bytes,8,opt,name=source_object,json=sourceObject,proto3" json:"source_object,omitempty"`
// contains filtered or unexported fields
}A specific stream object (e.g a specific DB table).
func (*StreamObject) Descriptor
func (*StreamObject) Descriptor() ([]byte, []int)Deprecated: Use StreamObject.ProtoReflect.Descriptor instead.
func (*StreamObject) GetBackfillJob
func (x *StreamObject) GetBackfillJob() *BackfillJobfunc (*StreamObject) GetCreateTime
func (x *StreamObject) GetCreateTime() *timestamppb.Timestampfunc (*StreamObject) GetDisplayName
func (x *StreamObject) GetDisplayName() stringfunc (*StreamObject) GetErrors
func (x *StreamObject) GetErrors() []*Errorfunc (*StreamObject) GetName
func (x *StreamObject) GetName() stringfunc (*StreamObject) GetSourceObject
func (x *StreamObject) GetSourceObject() *SourceObjectIdentifierfunc (*StreamObject) GetUpdateTime
func (x *StreamObject) GetUpdateTime() *timestamppb.Timestampfunc (*StreamObject) ProtoMessage
func (*StreamObject) ProtoMessage()func (*StreamObject) ProtoReflect
func (x *StreamObject) ProtoReflect() protoreflect.Messagefunc (*StreamObject) Reset
func (x *StreamObject) Reset()func (*StreamObject) String
func (x *StreamObject) String() stringStream_BackfillAll
type Stream_BackfillAll struct {
// Automatically backfill objects included in the stream source
// configuration. Specific objects can be excluded.
BackfillAll *Stream_BackfillAllStrategy `protobuf:"bytes,101,opt,name=backfill_all,json=backfillAll,proto3,oneof"`
}Stream_BackfillAllStrategy
type Stream_BackfillAllStrategy struct {
// List of objects to exclude.
//
// Types that are assignable to ExcludedObjects:
//
// *Stream_BackfillAllStrategy_OracleExcludedObjects
// *Stream_BackfillAllStrategy_MysqlExcludedObjects
// *Stream_BackfillAllStrategy_PostgresqlExcludedObjects
ExcludedObjects isStream_BackfillAllStrategy_ExcludedObjects `protobuf_oneof:"excluded_objects"`
// contains filtered or unexported fields
}Backfill strategy to automatically backfill the Stream's objects. Specific objects can be excluded.
func (*Stream_BackfillAllStrategy) Descriptor
func (*Stream_BackfillAllStrategy) Descriptor() ([]byte, []int)Deprecated: Use Stream_BackfillAllStrategy.ProtoReflect.Descriptor instead.
func (*Stream_BackfillAllStrategy) GetExcludedObjects
func (m *Stream_BackfillAllStrategy) GetExcludedObjects() isStream_BackfillAllStrategy_ExcludedObjectsfunc (*Stream_BackfillAllStrategy) GetMysqlExcludedObjects
func (x *Stream_BackfillAllStrategy) GetMysqlExcludedObjects() *MysqlRdbmsfunc (*Stream_BackfillAllStrategy) GetOracleExcludedObjects
func (x *Stream_BackfillAllStrategy) GetOracleExcludedObjects() *OracleRdbmsfunc (*Stream_BackfillAllStrategy) GetPostgresqlExcludedObjects
func (x *Stream_BackfillAllStrategy) GetPostgresqlExcludedObjects() *PostgresqlRdbmsfunc (*Stream_BackfillAllStrategy) ProtoMessage
func (*Stream_BackfillAllStrategy) ProtoMessage()func (*Stream_BackfillAllStrategy) ProtoReflect
func (x *Stream_BackfillAllStrategy) ProtoReflect() protoreflect.Messagefunc (*Stream_BackfillAllStrategy) Reset
func (x *Stream_BackfillAllStrategy) Reset()func (*Stream_BackfillAllStrategy) String
func (x *Stream_BackfillAllStrategy) String() stringStream_BackfillAllStrategy_MysqlExcludedObjects
type Stream_BackfillAllStrategy_MysqlExcludedObjects struct {
// MySQL data source objects to avoid backfilling.
MysqlExcludedObjects *MysqlRdbms `protobuf:"bytes,2,opt,name=mysql_excluded_objects,json=mysqlExcludedObjects,proto3,oneof"`
}Stream_BackfillAllStrategy_OracleExcludedObjects
type Stream_BackfillAllStrategy_OracleExcludedObjects struct {
// Oracle data source objects to avoid backfilling.
OracleExcludedObjects *OracleRdbms `protobuf:"bytes,1,opt,name=oracle_excluded_objects,json=oracleExcludedObjects,proto3,oneof"`
}Stream_BackfillAllStrategy_PostgresqlExcludedObjects
type Stream_BackfillAllStrategy_PostgresqlExcludedObjects struct {
// PostgreSQL data source objects to avoid backfilling.
PostgresqlExcludedObjects *PostgresqlRdbms `protobuf:"bytes,3,opt,name=postgresql_excluded_objects,json=postgresqlExcludedObjects,proto3,oneof"`
}Stream_BackfillNone
type Stream_BackfillNone struct {
// Do not automatically backfill any objects.
BackfillNone *Stream_BackfillNoneStrategy `protobuf:"bytes,102,opt,name=backfill_none,json=backfillNone,proto3,oneof"`
}Stream_BackfillNoneStrategy
type Stream_BackfillNoneStrategy struct {
// contains filtered or unexported fields
}Backfill strategy to disable automatic backfill for the Stream's objects.
func (*Stream_BackfillNoneStrategy) Descriptor
func (*Stream_BackfillNoneStrategy) Descriptor() ([]byte, []int)Deprecated: Use Stream_BackfillNoneStrategy.ProtoReflect.Descriptor instead.
func (*Stream_BackfillNoneStrategy) ProtoMessage
func (*Stream_BackfillNoneStrategy) ProtoMessage()func (*Stream_BackfillNoneStrategy) ProtoReflect
func (x *Stream_BackfillNoneStrategy) ProtoReflect() protoreflect.Messagefunc (*Stream_BackfillNoneStrategy) Reset
func (x *Stream_BackfillNoneStrategy) Reset()func (*Stream_BackfillNoneStrategy) String
func (x *Stream_BackfillNoneStrategy) String() stringStream_State
type Stream_State int32Stream state.
Stream_STATE_UNSPECIFIED, Stream_NOT_STARTED, Stream_RUNNING, Stream_PAUSED, Stream_MAINTENANCE, Stream_FAILED, Stream_FAILED_PERMANENTLY, Stream_STARTING, Stream_DRAINING
const (
// Unspecified stream state.
Stream_STATE_UNSPECIFIED Stream_State = 0
// The stream has been created but has not yet started streaming data.
Stream_NOT_STARTED Stream_State = 1
// The stream is running.
Stream_RUNNING Stream_State = 2
// The stream is paused.
Stream_PAUSED Stream_State = 3
// The stream is in maintenance mode.
//
// Updates are rejected on the resource in this state.
Stream_MAINTENANCE Stream_State = 4
// The stream is experiencing an error that is preventing data from being
// streamed.
Stream_FAILED Stream_State = 5
// The stream has experienced a terminal failure.
Stream_FAILED_PERMANENTLY Stream_State = 6
// The stream is starting, but not yet running.
Stream_STARTING Stream_State = 7
// The Stream is no longer reading new events, but still writing events in
// the buffer.
Stream_DRAINING Stream_State = 8
)func (Stream_State) Descriptor
func (Stream_State) Descriptor() protoreflect.EnumDescriptorfunc (Stream_State) Enum
func (x Stream_State) Enum() *Stream_Statefunc (Stream_State) EnumDescriptor
func (Stream_State) EnumDescriptor() ([]byte, []int)Deprecated: Use Stream_State.Descriptor instead.
func (Stream_State) Number
func (x Stream_State) Number() protoreflect.EnumNumberfunc (Stream_State) String
func (x Stream_State) String() stringfunc (Stream_State) Type
func (Stream_State) Type() protoreflect.EnumTypeUnimplementedDatastreamServer
type UnimplementedDatastreamServer struct {
}UnimplementedDatastreamServer can be embedded to have forward compatible implementations.
func (*UnimplementedDatastreamServer) CreateConnectionProfile
func (*UnimplementedDatastreamServer) CreateConnectionProfile(context.Context, *CreateConnectionProfileRequest) (*longrunningpb.Operation, error)func (*UnimplementedDatastreamServer) CreatePrivateConnection
func (*UnimplementedDatastreamServer) CreatePrivateConnection(context.Context, *CreatePrivateConnectionRequest) (*longrunningpb.Operation, error)func (*UnimplementedDatastreamServer) CreateRoute
func (*UnimplementedDatastreamServer) CreateRoute(context.Context, *CreateRouteRequest) (*longrunningpb.Operation, error)func (*UnimplementedDatastreamServer) CreateStream
func (*UnimplementedDatastreamServer) CreateStream(context.Context, *CreateStreamRequest) (*longrunningpb.Operation, error)func (*UnimplementedDatastreamServer) DeleteConnectionProfile
func (*UnimplementedDatastreamServer) DeleteConnectionProfile(context.Context, *DeleteConnectionProfileRequest) (*longrunningpb.Operation, error)func (*UnimplementedDatastreamServer) DeletePrivateConnection
func (*UnimplementedDatastreamServer) DeletePrivateConnection(context.Context, *DeletePrivateConnectionRequest) (*longrunningpb.Operation, error)func (*UnimplementedDatastreamServer) DeleteRoute
func (*UnimplementedDatastreamServer) DeleteRoute(context.Context, *DeleteRouteRequest) (*longrunningpb.Operation, error)func (*UnimplementedDatastreamServer) DeleteStream
func (*UnimplementedDatastreamServer) DeleteStream(context.Context, *DeleteStreamRequest) (*longrunningpb.Operation, error)func (*UnimplementedDatastreamServer) DiscoverConnectionProfile
func (*UnimplementedDatastreamServer) DiscoverConnectionProfile(context.Context, *DiscoverConnectionProfileRequest) (*DiscoverConnectionProfileResponse, error)func (*UnimplementedDatastreamServer) FetchStaticIps
func (*UnimplementedDatastreamServer) FetchStaticIps(context.Context, *FetchStaticIpsRequest) (*FetchStaticIpsResponse, error)func (*UnimplementedDatastreamServer) GetConnectionProfile
func (*UnimplementedDatastreamServer) GetConnectionProfile(context.Context, *GetConnectionProfileRequest) (*ConnectionProfile, error)func (*UnimplementedDatastreamServer) GetPrivateConnection
func (*UnimplementedDatastreamServer) GetPrivateConnection(context.Context, *GetPrivateConnectionRequest) (*PrivateConnection, error)func (*UnimplementedDatastreamServer) GetRoute
func (*UnimplementedDatastreamServer) GetRoute(context.Context, *GetRouteRequest) (*Route, error)func (*UnimplementedDatastreamServer) GetStream
func (*UnimplementedDatastreamServer) GetStream(context.Context, *GetStreamRequest) (*Stream, error)func (*UnimplementedDatastreamServer) GetStreamObject
func (*UnimplementedDatastreamServer) GetStreamObject(context.Context, *GetStreamObjectRequest) (*StreamObject, error)func (*UnimplementedDatastreamServer) ListConnectionProfiles
func (*UnimplementedDatastreamServer) ListConnectionProfiles(context.Context, *ListConnectionProfilesRequest) (*ListConnectionProfilesResponse, error)func (*UnimplementedDatastreamServer) ListPrivateConnections
func (*UnimplementedDatastreamServer) ListPrivateConnections(context.Context, *ListPrivateConnectionsRequest) (*ListPrivateConnectionsResponse, error)func (*UnimplementedDatastreamServer) ListRoutes
func (*UnimplementedDatastreamServer) ListRoutes(context.Context, *ListRoutesRequest) (*ListRoutesResponse, error)func (*UnimplementedDatastreamServer) ListStreamObjects
func (*UnimplementedDatastreamServer) ListStreamObjects(context.Context, *ListStreamObjectsRequest) (*ListStreamObjectsResponse, error)func (*UnimplementedDatastreamServer) ListStreams
func (*UnimplementedDatastreamServer) ListStreams(context.Context, *ListStreamsRequest) (*ListStreamsResponse, error)func (*UnimplementedDatastreamServer) LookupStreamObject
func (*UnimplementedDatastreamServer) LookupStreamObject(context.Context, *LookupStreamObjectRequest) (*StreamObject, error)func (*UnimplementedDatastreamServer) StartBackfillJob
func (*UnimplementedDatastreamServer) StartBackfillJob(context.Context, *StartBackfillJobRequest) (*StartBackfillJobResponse, error)func (*UnimplementedDatastreamServer) StopBackfillJob
func (*UnimplementedDatastreamServer) StopBackfillJob(context.Context, *StopBackfillJobRequest) (*StopBackfillJobResponse, error)func (*UnimplementedDatastreamServer) UpdateConnectionProfile
func (*UnimplementedDatastreamServer) UpdateConnectionProfile(context.Context, *UpdateConnectionProfileRequest) (*longrunningpb.Operation, error)func (*UnimplementedDatastreamServer) UpdateStream
func (*UnimplementedDatastreamServer) UpdateStream(context.Context, *UpdateStreamRequest) (*longrunningpb.Operation, error)UpdateConnectionProfileRequest
type UpdateConnectionProfileRequest struct {
// Optional. Field mask is used to specify the fields to be overwritten in the
// ConnectionProfile resource by the update.
// The fields specified in the update_mask are relative to the resource, not
// the full request. A field will be overwritten if it is in the mask. If the
// user does not provide a mask then all fields will be overwritten.
UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// Required. The connection profile to update.
ConnectionProfile *ConnectionProfile `protobuf:"bytes,2,opt,name=connection_profile,json=connectionProfile,proto3" json:"connection_profile,omitempty"`
// Optional. A request ID to identify requests. Specify a unique request ID
// so that if you must retry your request, the server will know to ignore
// the request if it has already been completed. The server will guarantee
// that for at least 60 minutes since the first request.
//
// For example, consider a situation where you make an initial request and the
// request times out. If you make the request again with the same request ID,
// the server can check if original operation with the same request ID was
// received, and if so, will ignore the second request. This prevents clients
// from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// Optional. Only validate the connection profile, but don't update any
// resources. The default is false.
ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
// Optional. Update the connection profile without validating it.
Force bool `protobuf:"varint,5,opt,name=force,proto3" json:"force,omitempty"`
// contains filtered or unexported fields
}Connection profile update message.
func (*UpdateConnectionProfileRequest) Descriptor
func (*UpdateConnectionProfileRequest) Descriptor() ([]byte, []int)Deprecated: Use UpdateConnectionProfileRequest.ProtoReflect.Descriptor instead.
func (*UpdateConnectionProfileRequest) GetConnectionProfile
func (x *UpdateConnectionProfileRequest) GetConnectionProfile() *ConnectionProfilefunc (*UpdateConnectionProfileRequest) GetForce
func (x *UpdateConnectionProfileRequest) GetForce() boolfunc (*UpdateConnectionProfileRequest) GetRequestId
func (x *UpdateConnectionProfileRequest) GetRequestId() stringfunc (*UpdateConnectionProfileRequest) GetUpdateMask
func (x *UpdateConnectionProfileRequest) GetUpdateMask() *fieldmaskpb.FieldMaskfunc (*UpdateConnectionProfileRequest) GetValidateOnly
func (x *UpdateConnectionProfileRequest) GetValidateOnly() boolfunc (*UpdateConnectionProfileRequest) ProtoMessage
func (*UpdateConnectionProfileRequest) ProtoMessage()func (*UpdateConnectionProfileRequest) ProtoReflect
func (x *UpdateConnectionProfileRequest) ProtoReflect() protoreflect.Messagefunc (*UpdateConnectionProfileRequest) Reset
func (x *UpdateConnectionProfileRequest) Reset()func (*UpdateConnectionProfileRequest) String
func (x *UpdateConnectionProfileRequest) String() stringUpdateStreamRequest
type UpdateStreamRequest struct {
// Optional. Field mask is used to specify the fields to be overwritten in the
// stream resource by the update.
// The fields specified in the update_mask are relative to the resource, not
// the full request. A field will be overwritten if it is in the mask. If the
// user does not provide a mask then all fields will be overwritten.
UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// Required. The stream resource to update.
Stream *Stream `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
// Optional. A request ID to identify requests. Specify a unique request ID
// so that if you must retry your request, the server will know to ignore
// the request if it has already been completed. The server will guarantee
// that for at least 60 minutes since the first request.
//
// For example, consider a situation where you make an initial request and the
// request times out. If you make the request again with the same request ID,
// the server can check if original operation with the same request ID was
// received, and if so, will ignore the second request. This prevents clients
// from accidentally creating duplicate commitments.
//
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// Optional. Only validate the stream with the changes, without actually
// updating it. The default is false.
ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
// Optional. Update the stream without validating it.
Force bool `protobuf:"varint,5,opt,name=force,proto3" json:"force,omitempty"`
// contains filtered or unexported fields
}Request message for updating a stream.
func (*UpdateStreamRequest) Descriptor
func (*UpdateStreamRequest) Descriptor() ([]byte, []int)Deprecated: Use UpdateStreamRequest.ProtoReflect.Descriptor instead.
func (*UpdateStreamRequest) GetForce
func (x *UpdateStreamRequest) GetForce() boolfunc (*UpdateStreamRequest) GetRequestId
func (x *UpdateStreamRequest) GetRequestId() stringfunc (*UpdateStreamRequest) GetStream
func (x *UpdateStreamRequest) GetStream() *Streamfunc (*UpdateStreamRequest) GetUpdateMask
func (x *UpdateStreamRequest) GetUpdateMask() *fieldmaskpb.FieldMaskfunc (*UpdateStreamRequest) GetValidateOnly
func (x *UpdateStreamRequest) GetValidateOnly() boolfunc (*UpdateStreamRequest) ProtoMessage
func (*UpdateStreamRequest) ProtoMessage()func (*UpdateStreamRequest) ProtoReflect
func (x *UpdateStreamRequest) ProtoReflect() protoreflect.Messagefunc (*UpdateStreamRequest) Reset
func (x *UpdateStreamRequest) Reset()func (*UpdateStreamRequest) String
func (x *UpdateStreamRequest) String() stringValidation
type Validation struct {
// A short description of the validation.
Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
// Validation execution status.
State Validation_State `protobuf:"varint,2,opt,name=state,proto3,enum=google.cloud.datastream.v1.Validation_State" json:"state,omitempty"`
// Messages reflecting the validation results.
Message []*ValidationMessage `protobuf:"bytes,3,rep,name=message,proto3" json:"message,omitempty"`
// A custom code identifying this validation.
Code string `protobuf:"bytes,4,opt,name=code,proto3" json:"code,omitempty"`
// contains filtered or unexported fields
}A validation to perform on a stream.
func (*Validation) Descriptor
func (*Validation) Descriptor() ([]byte, []int)Deprecated: Use Validation.ProtoReflect.Descriptor instead.
func (*Validation) GetCode
func (x *Validation) GetCode() stringfunc (*Validation) GetDescription
func (x *Validation) GetDescription() stringfunc (*Validation) GetMessage
func (x *Validation) GetMessage() []*ValidationMessagefunc (*Validation) GetState
func (x *Validation) GetState() Validation_Statefunc (*Validation) ProtoMessage
func (*Validation) ProtoMessage()func (*Validation) ProtoReflect
func (x *Validation) ProtoReflect() protoreflect.Messagefunc (*Validation) Reset
func (x *Validation) Reset()func (*Validation) String
func (x *Validation) String() stringValidationMessage
type ValidationMessage struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
Level ValidationMessage_Level `protobuf:"varint,2,opt,name=level,proto3,enum=google.cloud.datastream.v1.ValidationMessage_Level" json:"level,omitempty"`
Metadata map[string]string "" /* 157 byte string literal not displayed */
Code string `protobuf:"bytes,4,opt,name=code,proto3" json:"code,omitempty"`
}Represent user-facing validation result message.
func (*ValidationMessage) Descriptor
func (*ValidationMessage) Descriptor() ([]byte, []int)Deprecated: Use ValidationMessage.ProtoReflect.Descriptor instead.
func (*ValidationMessage) GetCode
func (x *ValidationMessage) GetCode() stringfunc (*ValidationMessage) GetLevel
func (x *ValidationMessage) GetLevel() ValidationMessage_Levelfunc (*ValidationMessage) GetMessage
func (x *ValidationMessage) GetMessage() stringfunc (*ValidationMessage) GetMetadata
func (x *ValidationMessage) GetMetadata() map[string]stringfunc (*ValidationMessage) ProtoMessage
func (*ValidationMessage) ProtoMessage()func (*ValidationMessage) ProtoReflect
func (x *ValidationMessage) ProtoReflect() protoreflect.Messagefunc (*ValidationMessage) Reset
func (x *ValidationMessage) Reset()func (*ValidationMessage) String
func (x *ValidationMessage) String() stringValidationMessage_Level
type ValidationMessage_Level int32Validation message level.
ValidationMessage_LEVEL_UNSPECIFIED, ValidationMessage_WARNING, ValidationMessage_ERROR
const (
// Unspecified level.
ValidationMessage_LEVEL_UNSPECIFIED ValidationMessage_Level = 0
// Potentially cause issues with the Stream.
ValidationMessage_WARNING ValidationMessage_Level = 1
// Definitely cause issues with the Stream.
ValidationMessage_ERROR ValidationMessage_Level = 2
)func (ValidationMessage_Level) Descriptor
func (ValidationMessage_Level) Descriptor() protoreflect.EnumDescriptorfunc (ValidationMessage_Level) Enum
func (x ValidationMessage_Level) Enum() *ValidationMessage_Levelfunc (ValidationMessage_Level) EnumDescriptor
func (ValidationMessage_Level) EnumDescriptor() ([]byte, []int)Deprecated: Use ValidationMessage_Level.Descriptor instead.
func (ValidationMessage_Level) Number
func (x ValidationMessage_Level) Number() protoreflect.EnumNumberfunc (ValidationMessage_Level) String
func (x ValidationMessage_Level) String() stringfunc (ValidationMessage_Level) Type
func (ValidationMessage_Level) Type() protoreflect.EnumTypeValidationResult
type ValidationResult struct {
// A list of validations (includes both executed as well as not executed
// validations).
Validations []*Validation `protobuf:"bytes,1,rep,name=validations,proto3" json:"validations,omitempty"`
// contains filtered or unexported fields
}Contains the current validation results.
func (*ValidationResult) Descriptor
func (*ValidationResult) Descriptor() ([]byte, []int)Deprecated: Use ValidationResult.ProtoReflect.Descriptor instead.
func (*ValidationResult) GetValidations
func (x *ValidationResult) GetValidations() []*Validationfunc (*ValidationResult) ProtoMessage
func (*ValidationResult) ProtoMessage()func (*ValidationResult) ProtoReflect
func (x *ValidationResult) ProtoReflect() protoreflect.Messagefunc (*ValidationResult) Reset
func (x *ValidationResult) Reset()func (*ValidationResult) String
func (x *ValidationResult) String() stringValidation_State
type Validation_State int32Validation execution state.
Validation_STATE_UNSPECIFIED, Validation_NOT_EXECUTED, Validation_FAILED, Validation_PASSED
const (
// Unspecified state.
Validation_STATE_UNSPECIFIED Validation_State = 0
// Validation did not execute.
Validation_NOT_EXECUTED Validation_State = 1
// Validation failed.
Validation_FAILED Validation_State = 2
// Validation passed.
Validation_PASSED Validation_State = 3
)func (Validation_State) Descriptor
func (Validation_State) Descriptor() protoreflect.EnumDescriptorfunc (Validation_State) Enum
func (x Validation_State) Enum() *Validation_Statefunc (Validation_State) EnumDescriptor
func (Validation_State) EnumDescriptor() ([]byte, []int)Deprecated: Use Validation_State.Descriptor instead.
func (Validation_State) Number
func (x Validation_State) Number() protoreflect.EnumNumberfunc (Validation_State) String
func (x Validation_State) String() stringfunc (Validation_State) Type
func (Validation_State) Type() protoreflect.EnumTypeVpcPeeringConfig
type VpcPeeringConfig struct {
// Required. Fully qualified name of the VPC that Datastream will peer to.
// Format: `projects/{project}/global/{networks}/{name}`
Vpc string `protobuf:"bytes,1,opt,name=vpc,proto3" json:"vpc,omitempty"`
// Required. A free subnet for peering. (CIDR of /29)
Subnet string `protobuf:"bytes,2,opt,name=subnet,proto3" json:"subnet,omitempty"`
// contains filtered or unexported fields
}The VPC Peering configuration is used to create VPC peering between Datastream and the consumer's VPC.
func (*VpcPeeringConfig) Descriptor
func (*VpcPeeringConfig) Descriptor() ([]byte, []int)Deprecated: Use VpcPeeringConfig.ProtoReflect.Descriptor instead.
func (*VpcPeeringConfig) GetSubnet
func (x *VpcPeeringConfig) GetSubnet() stringfunc (*VpcPeeringConfig) GetVpc
func (x *VpcPeeringConfig) GetVpc() stringfunc (*VpcPeeringConfig) ProtoMessage
func (*VpcPeeringConfig) ProtoMessage()func (*VpcPeeringConfig) ProtoReflect
func (x *VpcPeeringConfig) ProtoReflect() protoreflect.Messagefunc (*VpcPeeringConfig) Reset
func (x *VpcPeeringConfig) Reset()func (*VpcPeeringConfig) String
func (x *VpcPeeringConfig) String() string