datastreamv1

package
v1.36.2-20240502114401... Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: unknown License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const BigQueryDestinationConfig_DatasetConfig_not_set_case case_BigQueryDestinationConfig_DatasetConfig = 0
View Source 
const BigQueryDestinationConfig_SingleTargetDataset_case case_BigQueryDestinationConfig_DatasetConfig = 201
View Source 
const BigQueryDestinationConfig_SourceHierarchyDatasets_case case_BigQueryDestinationConfig_DatasetConfig = 202
View Source 
const ConnectionProfile_BigqueryProfile_case case_ConnectionProfile_Profile = 103
View Source 
const ConnectionProfile_Connectivity_not_set_case case_ConnectionProfile_Connectivity = 0
View Source 
const ConnectionProfile_ForwardSshConnectivity_case case_ConnectionProfile_Connectivity = 201
View Source 
const ConnectionProfile_GcsProfile_case case_ConnectionProfile_Profile = 101
View Source 
const ConnectionProfile_MysqlProfile_case case_ConnectionProfile_Profile = 102
View Source 
const ConnectionProfile_OracleProfile_case case_ConnectionProfile_Profile = 100
View Source 
const ConnectionProfile_PostgresqlProfile_case case_ConnectionProfile_Profile = 104
View Source 
const ConnectionProfile_PrivateConnectivity_case case_ConnectionProfile_Connectivity = 202
View Source 
const ConnectionProfile_Profile_not_set_case case_ConnectionProfile_Profile = 0
View Source 
const ConnectionProfile_StaticServiceIpConnectivity_case case_ConnectionProfile_Connectivity = 200
View Source 
const DestinationConfig_BigqueryDestinationConfig_case case_DestinationConfig_DestinationStreamConfig = 101
View Source 
const DestinationConfig_DestinationStreamConfig_not_set_case case_DestinationConfig_DestinationStreamConfig = 0
View Source 
const DestinationConfig_GcsDestinationConfig_case case_DestinationConfig_DestinationStreamConfig = 100
View Source 
const GcsDestinationConfig_AvroFileFormat_case case_GcsDestinationConfig_FileFormat = 100
View Source 
const GcsDestinationConfig_FileFormat_not_set_case case_GcsDestinationConfig_FileFormat = 0
View Source 
const GcsDestinationConfig_JsonFileFormat_case case_GcsDestinationConfig_FileFormat = 101
View Source 
const OracleSourceConfig_DropLargeObjects_case case_OracleSourceConfig_LargeObjectsHandling = 100
View Source 
const OracleSourceConfig_LargeObjectsHandling_not_set_case case_OracleSourceConfig_LargeObjectsHandling = 0
View Source 
const OracleSourceConfig_StreamLargeObjects_case case_OracleSourceConfig_LargeObjectsHandling = 102
View Source 
const SourceConfig_MysqlSourceConfig_case case_SourceConfig_SourceStreamConfig = 101
View Source 
const SourceConfig_OracleSourceConfig_case case_SourceConfig_SourceStreamConfig = 100
View Source 
const SourceConfig_PostgresqlSourceConfig_case case_SourceConfig_SourceStreamConfig = 102
View Source 
const SourceConfig_SourceStreamConfig_not_set_case case_SourceConfig_SourceStreamConfig = 0
View Source 
const Stream_BackfillAllStrategy_ExcludedObjects_not_set_case case_Stream_BackfillAllStrategy_ExcludedObjects = 0
View Source 
const Stream_BackfillAllStrategy_MysqlExcludedObjects_case case_Stream_BackfillAllStrategy_ExcludedObjects = 2
View Source 
const Stream_BackfillAllStrategy_OracleExcludedObjects_case case_Stream_BackfillAllStrategy_ExcludedObjects = 1
View Source 
const Stream_BackfillAllStrategy_PostgresqlExcludedObjects_case case_Stream_BackfillAllStrategy_ExcludedObjects = 3
View Source 
const Stream_BackfillAll_case case_Stream_BackfillStrategy = 101
View Source 
const Stream_BackfillNone_case case_Stream_BackfillStrategy = 102
View Source 
const Stream_BackfillStrategy_not_set_case case_Stream_BackfillStrategy = 0

Variables

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
var File_google_events_cloud_datastream_v1_data_proto protoreflect.FileDescriptor
View Source 
var File_google_events_cloud_datastream_v1_events_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AvroFileFormat 

type AvroFileFormat struct {
	// contains filtered or unexported fields
}

AVRO file format configuration.

func (*AvroFileFormat) ProtoMessage 

func (*AvroFileFormat) ProtoMessage()

func (*AvroFileFormat) ProtoReflect 

func (x *AvroFileFormat) ProtoReflect() protoreflect.Message

func (*AvroFileFormat) Reset 

func (x *AvroFileFormat) Reset()

func (*AvroFileFormat) String 

func (x *AvroFileFormat) String() string

type AvroFileFormat_builder 

type AvroFileFormat_builder struct {
	// contains filtered or unexported fields
}

func (AvroFileFormat_builder) Build 

func (b0 AvroFileFormat_builder) Build() *AvroFileFormat

type BigQueryDestinationConfig 

type BigQueryDestinationConfig struct {

	// Target dataset(s) configuration.
	//
	// Types that are valid to be assigned 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
}

func (*BigQueryDestinationConfig) ClearDataFreshness 

func (x *BigQueryDestinationConfig) ClearDataFreshness()

func (*BigQueryDestinationConfig) ClearDatasetConfig 

func (x *BigQueryDestinationConfig) ClearDatasetConfig()

func (*BigQueryDestinationConfig) ClearSingleTargetDataset 

func (x *BigQueryDestinationConfig) ClearSingleTargetDataset()

func (*BigQueryDestinationConfig) ClearSourceHierarchyDatasets 

func (x *BigQueryDestinationConfig) ClearSourceHierarchyDatasets()

func (*BigQueryDestinationConfig) GetDataFreshness 

func (x *BigQueryDestinationConfig) GetDataFreshness() *durationpb.Duration

func (*BigQueryDestinationConfig) GetDatasetConfig 

func (x *BigQueryDestinationConfig) GetDatasetConfig() isBigQueryDestinationConfig_DatasetConfig

func (*BigQueryDestinationConfig) GetSingleTargetDataset 

func (x *BigQueryDestinationConfig) GetSingleTargetDataset() *BigQueryDestinationConfig_SingleTargetDataset

func (*BigQueryDestinationConfig) GetSourceHierarchyDatasets 

func (x *BigQueryDestinationConfig) GetSourceHierarchyDatasets() *BigQueryDestinationConfig_SourceHierarchyDatasets

func (*BigQueryDestinationConfig) HasDataFreshness 

func (x *BigQueryDestinationConfig) HasDataFreshness() bool

func (*BigQueryDestinationConfig) HasDatasetConfig 

func (x *BigQueryDestinationConfig) HasDatasetConfig() bool

func (*BigQueryDestinationConfig) HasSingleTargetDataset 

func (x *BigQueryDestinationConfig) HasSingleTargetDataset() bool

func (*BigQueryDestinationConfig) HasSourceHierarchyDatasets 

func (x *BigQueryDestinationConfig) HasSourceHierarchyDatasets() bool

func (*BigQueryDestinationConfig) ProtoMessage 

func (*BigQueryDestinationConfig) ProtoMessage()

func (*BigQueryDestinationConfig) ProtoReflect 

func (x *BigQueryDestinationConfig) ProtoReflect() protoreflect.Message

func (*BigQueryDestinationConfig) Reset 

func (x *BigQueryDestinationConfig) Reset()

func (*BigQueryDestinationConfig) SetDataFreshness 

func (x *BigQueryDestinationConfig) SetDataFreshness(v *durationpb.Duration)

func (*BigQueryDestinationConfig) SetSingleTargetDataset 

func (x *BigQueryDestinationConfig) SetSingleTargetDataset(v *BigQueryDestinationConfig_SingleTargetDataset)

func (*BigQueryDestinationConfig) SetSourceHierarchyDatasets 

func (x *BigQueryDestinationConfig) SetSourceHierarchyDatasets(v *BigQueryDestinationConfig_SourceHierarchyDatasets)

func (*BigQueryDestinationConfig) String 

func (x *BigQueryDestinationConfig) String() string

func (*BigQueryDestinationConfig) WhichDatasetConfig 

func (x *BigQueryDestinationConfig) WhichDatasetConfig() case_BigQueryDestinationConfig_DatasetConfig

type BigQueryDestinationConfig_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) GetDatasetId 

func (x *BigQueryDestinationConfig_SingleTargetDataset) GetDatasetId() string

func (*BigQueryDestinationConfig_SingleTargetDataset) ProtoMessage 

func (*BigQueryDestinationConfig_SingleTargetDataset) ProtoMessage()

func (*BigQueryDestinationConfig_SingleTargetDataset) ProtoReflect 

func (x *BigQueryDestinationConfig_SingleTargetDataset) ProtoReflect() protoreflect.Message

func (*BigQueryDestinationConfig_SingleTargetDataset) Reset 

func (x *BigQueryDestinationConfig_SingleTargetDataset) Reset()

func (*BigQueryDestinationConfig_SingleTargetDataset) SetDatasetId 

func (x *BigQueryDestinationConfig_SingleTargetDataset) SetDatasetId(v string)

func (*BigQueryDestinationConfig_SingleTargetDataset) String 

func (x *BigQueryDestinationConfig_SingleTargetDataset) String() string

type BigQueryDestinationConfig_SingleTargetDataset_ 

type BigQueryDestinationConfig_SingleTargetDataset_ struct {
	// Single destination dataset.
	SingleTargetDataset *BigQueryDestinationConfig_SingleTargetDataset `protobuf:"bytes,201,opt,name=single_target_dataset,json=singleTargetDataset,proto3,oneof"`
}

type BigQueryDestinationConfig_SingleTargetDataset_builder 

type BigQueryDestinationConfig_SingleTargetDataset_builder struct {

	// The dataset ID of the target dataset.
	DatasetId string
	// contains filtered or unexported fields
}

func (BigQueryDestinationConfig_SingleTargetDataset_builder) Build 

func (b0 BigQueryDestinationConfig_SingleTargetDataset_builder) Build() *BigQueryDestinationConfig_SingleTargetDataset

type BigQueryDestinationConfig_SourceHierarchyDatasets 

type BigQueryDestinationConfig_SourceHierarchyDatasets struct {
	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) ClearDatasetTemplate 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets) ClearDatasetTemplate()

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) GetDatasetTemplate 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets) GetDatasetTemplate() *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) HasDatasetTemplate 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets) HasDatasetTemplate() bool

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) ProtoMessage 

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) ProtoMessage()

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) ProtoReflect 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets) ProtoReflect() protoreflect.Message

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) Reset 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets) Reset()

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) SetDatasetTemplate 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets) SetDatasetTemplate(v *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate)

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) String 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets) String() string

type BigQueryDestinationConfig_SourceHierarchyDatasets_ 

type BigQueryDestinationConfig_SourceHierarchyDatasets_ struct {
	// Source hierarchy datasets.
	SourceHierarchyDatasets *BigQueryDestinationConfig_SourceHierarchyDatasets `protobuf:"bytes,202,opt,name=source_hierarchy_datasets,json=sourceHierarchyDatasets,proto3,oneof"`
}

type 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. <prefix>_<dataset_name>.
	DatasetIdPrefix string `protobuf:"bytes,2,opt,name=dataset_id_prefix,json=datasetIdPrefix,proto3" json:"dataset_id_prefix,omitempty"`
	// Describes the Cloud KMS encryption key that will be used to
	// protect destination BigQuery table. The BigQuery Service Account
	// associated with your project requires access to this encryption key.
	// i.e.
	// projects/{project}/locations/{location}/keyRings/{key_ring}/cryptoKeys/{cryptoKey}.
	// See https://cloud.google.com/bigquery/docs/customer-managed-encryption
	// for more information.
	KmsKeyName string `protobuf:"bytes,3,opt,name=kms_key_name,json=kmsKeyName,proto3" json:"kms_key_name,omitempty"`
	// contains filtered or unexported fields
}

Dataset template used for dynamic dataset creation.

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetDatasetIdPrefix 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetDatasetIdPrefix() string

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetKmsKeyName 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetKmsKeyName() string

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetLocation 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetLocation() string

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) ProtoMessage 

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) ProtoMessage()

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) ProtoReflect 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) ProtoReflect() protoreflect.Message

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) Reset 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) Reset()

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) SetDatasetIdPrefix 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) SetDatasetIdPrefix(v string)

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) SetKmsKeyName 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) SetKmsKeyName(v string)

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) SetLocation 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) SetLocation(v string)

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) String 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) String() string

type BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate_builder 

type BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate_builder struct {

	// Required. The geographic location where the dataset should reside. See
	// https://cloud.google.com/bigquery/docs/locations for supported
	// locations.
	Location string
	// 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. <prefix>_<dataset_name>.
	DatasetIdPrefix string
	// Describes the Cloud KMS encryption key that will be used to
	// protect destination BigQuery table. The BigQuery Service Account
	// associated with your project requires access to this encryption key.
	// i.e.
	// projects/{project}/locations/{location}/keyRings/{key_ring}/cryptoKeys/{cryptoKey}.
	// See https://cloud.google.com/bigquery/docs/customer-managed-encryption
	// for more information.
	KmsKeyName string
	// contains filtered or unexported fields
}

func (BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate_builder) Build 

func (b0 BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate_builder) Build() *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate

type BigQueryDestinationConfig_SourceHierarchyDatasets_builder 

type BigQueryDestinationConfig_SourceHierarchyDatasets_builder struct {
	DatasetTemplate *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate
	// contains filtered or unexported fields
}

func (BigQueryDestinationConfig_SourceHierarchyDatasets_builder) Build 

func (b0 BigQueryDestinationConfig_SourceHierarchyDatasets_builder) Build() *BigQueryDestinationConfig_SourceHierarchyDatasets

type BigQueryDestinationConfig_builder 

type BigQueryDestinationConfig_builder struct {

	// Fields of oneof DatasetConfig:
	// Single destination dataset.
	SingleTargetDataset *BigQueryDestinationConfig_SingleTargetDataset
	// Source hierarchy datasets.
	SourceHierarchyDatasets *BigQueryDestinationConfig_SourceHierarchyDatasets
	// -- end of DatasetConfig
	// 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
	// contains filtered or unexported fields
}

func (BigQueryDestinationConfig_builder) Build 

func (b0 BigQueryDestinationConfig_builder) Build() *BigQueryDestinationConfig

type BigQueryProfile 

type BigQueryProfile struct {
	// contains filtered or unexported fields
}

BigQuery warehouse profile.

func (*BigQueryProfile) ProtoMessage 

func (*BigQueryProfile) ProtoMessage()

func (*BigQueryProfile) ProtoReflect 

func (x *BigQueryProfile) ProtoReflect() protoreflect.Message

func (*BigQueryProfile) Reset 

func (x *BigQueryProfile) Reset()

func (*BigQueryProfile) String 

func (x *BigQueryProfile) String() string

type BigQueryProfile_builder 

type BigQueryProfile_builder struct {
	// contains filtered or unexported fields
}

func (BigQueryProfile_builder) Build 

func (b0 BigQueryProfile_builder) Build() *BigQueryProfile

type ConnectionProfile 

type ConnectionProfile struct {

	// Output only. The resource's name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The create time of the resource.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The update time of the resource.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Labels.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Required. Display name.
	DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Connection configuration for the ConnectionProfile.
	//
	// Types that are valid to be assigned to Profile:
	//
	//	*ConnectionProfile_OracleProfile
	//	*ConnectionProfile_GcsProfile
	//	*ConnectionProfile_MysqlProfile
	//	*ConnectionProfile_BigqueryProfile
	//	*ConnectionProfile_PostgresqlProfile
	Profile isConnectionProfile_Profile `protobuf_oneof:"profile"`
	// Connectivity options used to establish a connection to the profile.
	//
	// Types that are valid to be assigned to Connectivity:
	//
	//	*ConnectionProfile_StaticServiceIpConnectivity
	//	*ConnectionProfile_ForwardSshConnectivity
	//	*ConnectionProfile_PrivateConnectivity
	Connectivity isConnectionProfile_Connectivity `protobuf_oneof:"connectivity"`
	// contains filtered or unexported fields
}

A set of reusable connection configurations to be used as a source or destination for a stream.

func (*ConnectionProfile) ClearBigqueryProfile 

func (x *ConnectionProfile) ClearBigqueryProfile()

func (*ConnectionProfile) ClearConnectivity 

func (x *ConnectionProfile) ClearConnectivity()

func (*ConnectionProfile) ClearCreateTime 

func (x *ConnectionProfile) ClearCreateTime()

func (*ConnectionProfile) ClearForwardSshConnectivity 

func (x *ConnectionProfile) ClearForwardSshConnectivity()

func (*ConnectionProfile) ClearGcsProfile 

func (x *ConnectionProfile) ClearGcsProfile()

func (*ConnectionProfile) ClearMysqlProfile 

func (x *ConnectionProfile) ClearMysqlProfile()

func (*ConnectionProfile) ClearOracleProfile 

func (x *ConnectionProfile) ClearOracleProfile()

func (*ConnectionProfile) ClearPostgresqlProfile 

func (x *ConnectionProfile) ClearPostgresqlProfile()

func (*ConnectionProfile) ClearPrivateConnectivity 

func (x *ConnectionProfile) ClearPrivateConnectivity()

func (*ConnectionProfile) ClearProfile 

func (x *ConnectionProfile) ClearProfile()

func (*ConnectionProfile) ClearStaticServiceIpConnectivity 

func (x *ConnectionProfile) ClearStaticServiceIpConnectivity()

func (*ConnectionProfile) ClearUpdateTime 

func (x *ConnectionProfile) ClearUpdateTime()

func (*ConnectionProfile) GetBigqueryProfile 

func (x *ConnectionProfile) GetBigqueryProfile() *BigQueryProfile

func (*ConnectionProfile) GetConnectivity 

func (x *ConnectionProfile) GetConnectivity() isConnectionProfile_Connectivity

func (*ConnectionProfile) GetCreateTime 

func (x *ConnectionProfile) GetCreateTime() *timestamppb.Timestamp

func (*ConnectionProfile) GetDisplayName 

func (x *ConnectionProfile) GetDisplayName() string

func (*ConnectionProfile) GetForwardSshConnectivity 

func (x *ConnectionProfile) GetForwardSshConnectivity() *ForwardSshTunnelConnectivity

func (*ConnectionProfile) GetGcsProfile 

func (x *ConnectionProfile) GetGcsProfile() *GcsProfile

func (*ConnectionProfile) GetLabels 

func (x *ConnectionProfile) GetLabels() map[string]string

func (*ConnectionProfile) GetMysqlProfile 

func (x *ConnectionProfile) GetMysqlProfile() *MysqlProfile

func (*ConnectionProfile) GetName 

func (x *ConnectionProfile) GetName() string

func (*ConnectionProfile) GetOracleProfile 

func (x *ConnectionProfile) GetOracleProfile() *OracleProfile

func (*ConnectionProfile) GetPostgresqlProfile 

func (x *ConnectionProfile) GetPostgresqlProfile() *PostgresqlProfile

func (*ConnectionProfile) GetPrivateConnectivity 

func (x *ConnectionProfile) GetPrivateConnectivity() *PrivateConnectivity

func (*ConnectionProfile) GetProfile 

func (x *ConnectionProfile) GetProfile() isConnectionProfile_Profile

func (*ConnectionProfile) GetStaticServiceIpConnectivity 

func (x *ConnectionProfile) GetStaticServiceIpConnectivity() *StaticServiceIpConnectivity

func (*ConnectionProfile) GetUpdateTime 

func (x *ConnectionProfile) GetUpdateTime() *timestamppb.Timestamp

func (*ConnectionProfile) HasBigqueryProfile 

func (x *ConnectionProfile) HasBigqueryProfile() bool

func (*ConnectionProfile) HasConnectivity 

func (x *ConnectionProfile) HasConnectivity() bool

func (*ConnectionProfile) HasCreateTime 

func (x *ConnectionProfile) HasCreateTime() bool

func (*ConnectionProfile) HasForwardSshConnectivity 

func (x *ConnectionProfile) HasForwardSshConnectivity() bool

func (*ConnectionProfile) HasGcsProfile 

func (x *ConnectionProfile) HasGcsProfile() bool

func (*ConnectionProfile) HasMysqlProfile 

func (x *ConnectionProfile) HasMysqlProfile() bool

func (*ConnectionProfile) HasOracleProfile 

func (x *ConnectionProfile) HasOracleProfile() bool

func (*ConnectionProfile) HasPostgresqlProfile 

func (x *ConnectionProfile) HasPostgresqlProfile() bool

func (*ConnectionProfile) HasPrivateConnectivity 

func (x *ConnectionProfile) HasPrivateConnectivity() bool

func (*ConnectionProfile) HasProfile 

func (x *ConnectionProfile) HasProfile() bool

func (*ConnectionProfile) HasStaticServiceIpConnectivity 

func (x *ConnectionProfile) HasStaticServiceIpConnectivity() bool

func (*ConnectionProfile) HasUpdateTime 

func (x *ConnectionProfile) HasUpdateTime() bool

func (*ConnectionProfile) ProtoMessage 

func (*ConnectionProfile) ProtoMessage()

func (*ConnectionProfile) ProtoReflect 

func (x *ConnectionProfile) ProtoReflect() protoreflect.Message

func (*ConnectionProfile) Reset 

func (x *ConnectionProfile) Reset()

func (*ConnectionProfile) SetBigqueryProfile 

func (x *ConnectionProfile) SetBigqueryProfile(v *BigQueryProfile)

func (*ConnectionProfile) SetCreateTime 

func (x *ConnectionProfile) SetCreateTime(v *timestamppb.Timestamp)

func (*ConnectionProfile) SetDisplayName 

func (x *ConnectionProfile) SetDisplayName(v string)

func (*ConnectionProfile) SetForwardSshConnectivity 

func (x *ConnectionProfile) SetForwardSshConnectivity(v *ForwardSshTunnelConnectivity)

func (*ConnectionProfile) SetGcsProfile 

func (x *ConnectionProfile) SetGcsProfile(v *GcsProfile)

func (*ConnectionProfile) SetLabels 

func (x *ConnectionProfile) SetLabels(v map[string]string)

func (*ConnectionProfile) SetMysqlProfile 

func (x *ConnectionProfile) SetMysqlProfile(v *MysqlProfile)

func (*ConnectionProfile) SetName 

func (x *ConnectionProfile) SetName(v string)

func (*ConnectionProfile) SetOracleProfile 

func (x *ConnectionProfile) SetOracleProfile(v *OracleProfile)

func (*ConnectionProfile) SetPostgresqlProfile 

func (x *ConnectionProfile) SetPostgresqlProfile(v *PostgresqlProfile)

func (*ConnectionProfile) SetPrivateConnectivity 

func (x *ConnectionProfile) SetPrivateConnectivity(v *PrivateConnectivity)

func (*ConnectionProfile) SetStaticServiceIpConnectivity 

func (x *ConnectionProfile) SetStaticServiceIpConnectivity(v *StaticServiceIpConnectivity)

func (*ConnectionProfile) SetUpdateTime 

func (x *ConnectionProfile) SetUpdateTime(v *timestamppb.Timestamp)

func (*ConnectionProfile) String 

func (x *ConnectionProfile) String() string

func (*ConnectionProfile) WhichConnectivity 

func (x *ConnectionProfile) WhichConnectivity() case_ConnectionProfile_Connectivity

func (*ConnectionProfile) WhichProfile 

func (x *ConnectionProfile) WhichProfile() case_ConnectionProfile_Profile

type ConnectionProfileCreatedEvent 

type ConnectionProfileCreatedEvent struct {

	// The data associated with the event.
	Data *ConnectionProfileEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a ConnectionProfile is created.

func (*ConnectionProfileCreatedEvent) ClearData 

func (x *ConnectionProfileCreatedEvent) ClearData()

func (*ConnectionProfileCreatedEvent) GetData 

func (x *ConnectionProfileCreatedEvent) GetData() *ConnectionProfileEventData

func (*ConnectionProfileCreatedEvent) HasData 

func (x *ConnectionProfileCreatedEvent) HasData() bool

func (*ConnectionProfileCreatedEvent) ProtoMessage 

func (*ConnectionProfileCreatedEvent) ProtoMessage()

func (*ConnectionProfileCreatedEvent) ProtoReflect 

func (x *ConnectionProfileCreatedEvent) ProtoReflect() protoreflect.Message

func (*ConnectionProfileCreatedEvent) Reset 

func (x *ConnectionProfileCreatedEvent) Reset()

func (*ConnectionProfileCreatedEvent) SetData 

func (x *ConnectionProfileCreatedEvent) SetData(v *ConnectionProfileEventData)

func (*ConnectionProfileCreatedEvent) String 

func (x *ConnectionProfileCreatedEvent) String() string

type ConnectionProfileCreatedEvent_builder 

type ConnectionProfileCreatedEvent_builder struct {

	// The data associated with the event.
	Data *ConnectionProfileEventData
	// contains filtered or unexported fields
}

func (ConnectionProfileCreatedEvent_builder) Build 

func (b0 ConnectionProfileCreatedEvent_builder) Build() *ConnectionProfileCreatedEvent

type ConnectionProfileDeletedEvent 

type ConnectionProfileDeletedEvent struct {

	// The data associated with the event.
	Data *ConnectionProfileEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a ConnectionProfile is deleted.

func (*ConnectionProfileDeletedEvent) ClearData 

func (x *ConnectionProfileDeletedEvent) ClearData()

func (*ConnectionProfileDeletedEvent) GetData 

func (x *ConnectionProfileDeletedEvent) GetData() *ConnectionProfileEventData

func (*ConnectionProfileDeletedEvent) HasData 

func (x *ConnectionProfileDeletedEvent) HasData() bool

func (*ConnectionProfileDeletedEvent) ProtoMessage 

func (*ConnectionProfileDeletedEvent) ProtoMessage()

func (*ConnectionProfileDeletedEvent) ProtoReflect 

func (x *ConnectionProfileDeletedEvent) ProtoReflect() protoreflect.Message

func (*ConnectionProfileDeletedEvent) Reset 

func (x *ConnectionProfileDeletedEvent) Reset()

func (*ConnectionProfileDeletedEvent) SetData 

func (x *ConnectionProfileDeletedEvent) SetData(v *ConnectionProfileEventData)

func (*ConnectionProfileDeletedEvent) String 

func (x *ConnectionProfileDeletedEvent) String() string

type ConnectionProfileDeletedEvent_builder 

type ConnectionProfileDeletedEvent_builder struct {

	// The data associated with the event.
	Data *ConnectionProfileEventData
	// contains filtered or unexported fields
}

func (ConnectionProfileDeletedEvent_builder) Build 

func (b0 ConnectionProfileDeletedEvent_builder) Build() *ConnectionProfileDeletedEvent

type ConnectionProfileEventData 

type ConnectionProfileEventData struct {

	// Optional. The ConnectionProfile event payload. Unset for deletion events.
	Payload *ConnectionProfile `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all ConnectionProfile events.

func (*ConnectionProfileEventData) ClearPayload 

func (x *ConnectionProfileEventData) ClearPayload()

func (*ConnectionProfileEventData) GetPayload 

func (x *ConnectionProfileEventData) GetPayload() *ConnectionProfile

func (*ConnectionProfileEventData) HasPayload 

func (x *ConnectionProfileEventData) HasPayload() bool

func (*ConnectionProfileEventData) ProtoMessage 

func (*ConnectionProfileEventData) ProtoMessage()

func (*ConnectionProfileEventData) ProtoReflect 

func (x *ConnectionProfileEventData) ProtoReflect() protoreflect.Message

func (*ConnectionProfileEventData) Reset 

func (x *ConnectionProfileEventData) Reset()

func (*ConnectionProfileEventData) SetPayload 

func (x *ConnectionProfileEventData) SetPayload(v *ConnectionProfile)

func (*ConnectionProfileEventData) String 

func (x *ConnectionProfileEventData) String() string

type ConnectionProfileEventData_builder 

type ConnectionProfileEventData_builder struct {

	// Optional. The ConnectionProfile event payload. Unset for deletion events.
	Payload *ConnectionProfile
	// contains filtered or unexported fields
}

func (ConnectionProfileEventData_builder) Build 

func (b0 ConnectionProfileEventData_builder) Build() *ConnectionProfileEventData

type ConnectionProfileUpdatedEvent 

type ConnectionProfileUpdatedEvent struct {

	// The data associated with the event.
	Data *ConnectionProfileEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a ConnectionProfile is updated.

func (*ConnectionProfileUpdatedEvent) ClearData 

func (x *ConnectionProfileUpdatedEvent) ClearData()

func (*ConnectionProfileUpdatedEvent) GetData 

func (x *ConnectionProfileUpdatedEvent) GetData() *ConnectionProfileEventData

func (*ConnectionProfileUpdatedEvent) HasData 

func (x *ConnectionProfileUpdatedEvent) HasData() bool

func (*ConnectionProfileUpdatedEvent) ProtoMessage 

func (*ConnectionProfileUpdatedEvent) ProtoMessage()

func (*ConnectionProfileUpdatedEvent) ProtoReflect 

func (x *ConnectionProfileUpdatedEvent) ProtoReflect() protoreflect.Message

func (*ConnectionProfileUpdatedEvent) Reset 

func (x *ConnectionProfileUpdatedEvent) Reset()

func (*ConnectionProfileUpdatedEvent) SetData 

func (x *ConnectionProfileUpdatedEvent) SetData(v *ConnectionProfileEventData)

func (*ConnectionProfileUpdatedEvent) String 

func (x *ConnectionProfileUpdatedEvent) String() string

type ConnectionProfileUpdatedEvent_builder 

type ConnectionProfileUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *ConnectionProfileEventData
	// contains filtered or unexported fields
}

func (ConnectionProfileUpdatedEvent_builder) Build 

func (b0 ConnectionProfileUpdatedEvent_builder) Build() *ConnectionProfileUpdatedEvent

type ConnectionProfile_BigqueryProfile 

type ConnectionProfile_BigqueryProfile struct {
	// BigQuery Connection Profile configuration.
	BigqueryProfile *BigQueryProfile `protobuf:"bytes,103,opt,name=bigquery_profile,json=bigqueryProfile,proto3,oneof"`
}

type ConnectionProfile_ForwardSshConnectivity 

type ConnectionProfile_ForwardSshConnectivity struct {
	// Forward SSH tunnel connectivity.
	ForwardSshConnectivity *ForwardSshTunnelConnectivity `protobuf:"bytes,201,opt,name=forward_ssh_connectivity,json=forwardSshConnectivity,proto3,oneof"`
}

type ConnectionProfile_GcsProfile 

type ConnectionProfile_GcsProfile struct {
	// Cloud Storage ConnectionProfile configuration.
	GcsProfile *GcsProfile `protobuf:"bytes,101,opt,name=gcs_profile,json=gcsProfile,proto3,oneof"`
}

type ConnectionProfile_MysqlProfile 

type ConnectionProfile_MysqlProfile struct {
	// MySQL ConnectionProfile configuration.
	MysqlProfile *MysqlProfile `protobuf:"bytes,102,opt,name=mysql_profile,json=mysqlProfile,proto3,oneof"`
}

type ConnectionProfile_OracleProfile 

type ConnectionProfile_OracleProfile struct {
	// Oracle ConnectionProfile configuration.
	OracleProfile *OracleProfile `protobuf:"bytes,100,opt,name=oracle_profile,json=oracleProfile,proto3,oneof"`
}

type ConnectionProfile_PostgresqlProfile 

type ConnectionProfile_PostgresqlProfile struct {
	// PostgreSQL Connection Profile configuration.
	PostgresqlProfile *PostgresqlProfile `protobuf:"bytes,104,opt,name=postgresql_profile,json=postgresqlProfile,proto3,oneof"`
}

type ConnectionProfile_PrivateConnectivity 

type ConnectionProfile_PrivateConnectivity struct {
	// Private connectivity.
	PrivateConnectivity *PrivateConnectivity `protobuf:"bytes,202,opt,name=private_connectivity,json=privateConnectivity,proto3,oneof"`
}

type 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"`
}

type ConnectionProfile_builder 

type ConnectionProfile_builder struct {

	// Output only. The resource's name.
	Name string
	// Output only. The create time of the resource.
	CreateTime *timestamppb.Timestamp
	// Output only. The update time of the resource.
	UpdateTime *timestamppb.Timestamp
	// Labels.
	Labels map[string]string
	// Required. Display name.
	DisplayName string

	// Fields of oneof Profile:
	// Oracle ConnectionProfile configuration.
	OracleProfile *OracleProfile
	// Cloud Storage ConnectionProfile configuration.
	GcsProfile *GcsProfile
	// MySQL ConnectionProfile configuration.
	MysqlProfile *MysqlProfile
	// BigQuery Connection Profile configuration.
	BigqueryProfile *BigQueryProfile
	// PostgreSQL Connection Profile configuration.
	PostgresqlProfile *PostgresqlProfile

	// Fields of oneof Connectivity:
	// Static Service IP connectivity.
	StaticServiceIpConnectivity *StaticServiceIpConnectivity
	// Forward SSH tunnel connectivity.
	ForwardSshConnectivity *ForwardSshTunnelConnectivity
	// Private connectivity.
	PrivateConnectivity *PrivateConnectivity
	// contains filtered or unexported fields
}

func (ConnectionProfile_builder) Build 

func (b0 ConnectionProfile_builder) Build() *ConnectionProfile

type DestinationConfig 

type DestinationConfig struct {

	// Required. Destination connection profile resource.
	// Format: `projects/{project}/locations/{location}/connectionProfiles/{name}`
	DestinationConnectionProfile string `` /* 147-byte string literal not displayed */
	// Stream configuration that is specific to the data destination type.
	//
	// Types that are valid to be assigned to DestinationStreamConfig:
	//
	//	*DestinationConfig_GcsDestinationConfig
	//	*DestinationConfig_BigqueryDestinationConfig
	DestinationStreamConfig isDestinationConfig_DestinationStreamConfig `protobuf_oneof:"destination_stream_config"`
	// contains filtered or unexported fields
}

The configuration of the stream destination.

func (*DestinationConfig) ClearBigqueryDestinationConfig 

func (x *DestinationConfig) ClearBigqueryDestinationConfig()

func (*DestinationConfig) ClearDestinationStreamConfig 

func (x *DestinationConfig) ClearDestinationStreamConfig()

func (*DestinationConfig) ClearGcsDestinationConfig 

func (x *DestinationConfig) ClearGcsDestinationConfig()

func (*DestinationConfig) GetBigqueryDestinationConfig 

func (x *DestinationConfig) GetBigqueryDestinationConfig() *BigQueryDestinationConfig

func (*DestinationConfig) GetDestinationConnectionProfile 

func (x *DestinationConfig) GetDestinationConnectionProfile() string

func (*DestinationConfig) GetDestinationStreamConfig 

func (x *DestinationConfig) GetDestinationStreamConfig() isDestinationConfig_DestinationStreamConfig

func (*DestinationConfig) GetGcsDestinationConfig 

func (x *DestinationConfig) GetGcsDestinationConfig() *GcsDestinationConfig

func (*DestinationConfig) HasBigqueryDestinationConfig 

func (x *DestinationConfig) HasBigqueryDestinationConfig() bool

func (*DestinationConfig) HasDestinationStreamConfig 

func (x *DestinationConfig) HasDestinationStreamConfig() bool

func (*DestinationConfig) HasGcsDestinationConfig 

func (x *DestinationConfig) HasGcsDestinationConfig() bool

func (*DestinationConfig) ProtoMessage 

func (*DestinationConfig) ProtoMessage()

func (*DestinationConfig) ProtoReflect 

func (x *DestinationConfig) ProtoReflect() protoreflect.Message

func (*DestinationConfig) Reset 

func (x *DestinationConfig) Reset()

func (*DestinationConfig) SetBigqueryDestinationConfig 

func (x *DestinationConfig) SetBigqueryDestinationConfig(v *BigQueryDestinationConfig)

func (*DestinationConfig) SetDestinationConnectionProfile 

func (x *DestinationConfig) SetDestinationConnectionProfile(v string)

func (*DestinationConfig) SetGcsDestinationConfig 

func (x *DestinationConfig) SetGcsDestinationConfig(v *GcsDestinationConfig)

func (*DestinationConfig) String 

func (x *DestinationConfig) String() string

func (*DestinationConfig) WhichDestinationStreamConfig 

func (x *DestinationConfig) WhichDestinationStreamConfig() case_DestinationConfig_DestinationStreamConfig

type DestinationConfig_BigqueryDestinationConfig 

type DestinationConfig_BigqueryDestinationConfig struct {
	// BigQuery destination configuration.
	BigqueryDestinationConfig *BigQueryDestinationConfig `protobuf:"bytes,101,opt,name=bigquery_destination_config,json=bigqueryDestinationConfig,proto3,oneof"`
}

type 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"`
}

type DestinationConfig_builder 

type DestinationConfig_builder struct {

	// Required. Destination connection profile resource.
	// Format: `projects/{project}/locations/{location}/connectionProfiles/{name}`
	DestinationConnectionProfile string

	// Fields of oneof DestinationStreamConfig:
	// A configuration for how data should be loaded to Cloud Storage.
	GcsDestinationConfig *GcsDestinationConfig
	// BigQuery destination configuration.
	BigqueryDestinationConfig *BigQueryDestinationConfig
	// contains filtered or unexported fields
}

func (DestinationConfig_builder) Build 

func (b0 DestinationConfig_builder) Build() *DestinationConfig

type Error 

type Error struct {

	// A title that explains the reason for the error.
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	// A unique identifier for this specific error,
	// allowing it to be traced throughout the system in logs and API responses.
	ErrorUuid string `protobuf:"bytes,2,opt,name=error_uuid,json=errorUuid,proto3" json:"error_uuid,omitempty"`
	// A message containing more information about the error that occurred.
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// The time when the error occurred.
	ErrorTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=error_time,json=errorTime,proto3" json:"error_time,omitempty"`
	// Additional information about the error.
	Details map[string]string `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

Represent a user-facing Error.

func (*Error) ClearErrorTime 

func (x *Error) ClearErrorTime()

func (*Error) GetDetails 

func (x *Error) GetDetails() map[string]string

func (*Error) GetErrorTime 

func (x *Error) GetErrorTime() *timestamppb.Timestamp

func (*Error) GetErrorUuid 

func (x *Error) GetErrorUuid() string

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (*Error) GetReason 

func (x *Error) GetReason() string

func (*Error) HasErrorTime 

func (x *Error) HasErrorTime() bool

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

func (x *Error) ProtoReflect() protoreflect.Message

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) SetDetails 

func (x *Error) SetDetails(v map[string]string)

func (*Error) SetErrorTime 

func (x *Error) SetErrorTime(v *timestamppb.Timestamp)

func (*Error) SetErrorUuid 

func (x *Error) SetErrorUuid(v string)

func (*Error) SetMessage 

func (x *Error) SetMessage(v string)

func (*Error) SetReason 

func (x *Error) SetReason(v string)

func (*Error) String 

func (x *Error) String() string

type Error_builder 

type Error_builder struct {

	// A title that explains the reason for the error.
	Reason string
	// A unique identifier for this specific error,
	// allowing it to be traced throughout the system in logs and API responses.
	ErrorUuid string
	// A message containing more information about the error that occurred.
	Message string
	// The time when the error occurred.
	ErrorTime *timestamppb.Timestamp
	// Additional information about the error.
	Details map[string]string
	// contains filtered or unexported fields
}

func (Error_builder) Build 

func (b0 Error_builder) Build() *Error

type ForwardSshTunnelConnectivity 

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"`
	// contains filtered or unexported fields
}

Forward SSH Tunnel connectivity.

func (*ForwardSshTunnelConnectivity) GetHostname 

func (x *ForwardSshTunnelConnectivity) GetHostname() string

func (*ForwardSshTunnelConnectivity) GetPort 

func (x *ForwardSshTunnelConnectivity) GetPort() int32

func (*ForwardSshTunnelConnectivity) GetUsername 

func (x *ForwardSshTunnelConnectivity) GetUsername() string

func (*ForwardSshTunnelConnectivity) ProtoMessage 

func (*ForwardSshTunnelConnectivity) ProtoMessage()

func (*ForwardSshTunnelConnectivity) ProtoReflect 

func (x *ForwardSshTunnelConnectivity) ProtoReflect() protoreflect.Message

func (*ForwardSshTunnelConnectivity) Reset 

func (x *ForwardSshTunnelConnectivity) Reset()

func (*ForwardSshTunnelConnectivity) SetHostname 

func (x *ForwardSshTunnelConnectivity) SetHostname(v string)

func (*ForwardSshTunnelConnectivity) SetPort 

func (x *ForwardSshTunnelConnectivity) SetPort(v int32)

func (*ForwardSshTunnelConnectivity) SetUsername 

func (x *ForwardSshTunnelConnectivity) SetUsername(v string)

func (*ForwardSshTunnelConnectivity) String 

func (x *ForwardSshTunnelConnectivity) String() string

type ForwardSshTunnelConnectivity_builder 

type ForwardSshTunnelConnectivity_builder struct {

	// Required. Hostname for the SSH tunnel.
	Hostname string
	// Required. Username for the SSH tunnel.
	Username string
	// Port for the SSH tunnel, default value is 22.
	Port int32
	// contains filtered or unexported fields
}

func (ForwardSshTunnelConnectivity_builder) Build 

func (b0 ForwardSshTunnelConnectivity_builder) Build() *ForwardSshTunnelConnectivity

type 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.
	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 valid to be assigned 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) ClearAvroFileFormat 

func (x *GcsDestinationConfig) ClearAvroFileFormat()

func (*GcsDestinationConfig) ClearFileFormat 

func (x *GcsDestinationConfig) ClearFileFormat()

func (*GcsDestinationConfig) ClearFileRotationInterval 

func (x *GcsDestinationConfig) ClearFileRotationInterval()

func (*GcsDestinationConfig) ClearJsonFileFormat 

func (x *GcsDestinationConfig) ClearJsonFileFormat()

func (*GcsDestinationConfig) GetAvroFileFormat 

func (x *GcsDestinationConfig) GetAvroFileFormat() *AvroFileFormat

func (*GcsDestinationConfig) GetFileFormat 

func (x *GcsDestinationConfig) GetFileFormat() isGcsDestinationConfig_FileFormat

func (*GcsDestinationConfig) GetFileRotationInterval 

func (x *GcsDestinationConfig) GetFileRotationInterval() *durationpb.Duration

func (*GcsDestinationConfig) GetFileRotationMb 

func (x *GcsDestinationConfig) GetFileRotationMb() int32

func (*GcsDestinationConfig) GetJsonFileFormat 

func (x *GcsDestinationConfig) GetJsonFileFormat() *JsonFileFormat

func (*GcsDestinationConfig) GetPath 

func (x *GcsDestinationConfig) GetPath() string

func (*GcsDestinationConfig) HasAvroFileFormat 

func (x *GcsDestinationConfig) HasAvroFileFormat() bool

func (*GcsDestinationConfig) HasFileFormat 

func (x *GcsDestinationConfig) HasFileFormat() bool

func (*GcsDestinationConfig) HasFileRotationInterval 

func (x *GcsDestinationConfig) HasFileRotationInterval() bool

func (*GcsDestinationConfig) HasJsonFileFormat 

func (x *GcsDestinationConfig) HasJsonFileFormat() bool

func (*GcsDestinationConfig) ProtoMessage 

func (*GcsDestinationConfig) ProtoMessage()

func (*GcsDestinationConfig) ProtoReflect 

func (x *GcsDestinationConfig) ProtoReflect() protoreflect.Message

func (*GcsDestinationConfig) Reset 

func (x *GcsDestinationConfig) Reset()

func (*GcsDestinationConfig) SetAvroFileFormat 

func (x *GcsDestinationConfig) SetAvroFileFormat(v *AvroFileFormat)

func (*GcsDestinationConfig) SetFileRotationInterval 

func (x *GcsDestinationConfig) SetFileRotationInterval(v *durationpb.Duration)

func (*GcsDestinationConfig) SetFileRotationMb 

func (x *GcsDestinationConfig) SetFileRotationMb(v int32)

func (*GcsDestinationConfig) SetJsonFileFormat 

func (x *GcsDestinationConfig) SetJsonFileFormat(v *JsonFileFormat)

func (*GcsDestinationConfig) SetPath 

func (x *GcsDestinationConfig) SetPath(v string)

func (*GcsDestinationConfig) String 

func (x *GcsDestinationConfig) String() string

func (*GcsDestinationConfig) WhichFileFormat 

func (x *GcsDestinationConfig) WhichFileFormat() case_GcsDestinationConfig_FileFormat

type GcsDestinationConfig_AvroFileFormat 

type GcsDestinationConfig_AvroFileFormat struct {
	// AVRO file format configuration.
	AvroFileFormat *AvroFileFormat `protobuf:"bytes,100,opt,name=avro_file_format,json=avroFileFormat,proto3,oneof"`
}

type GcsDestinationConfig_JsonFileFormat 

type GcsDestinationConfig_JsonFileFormat struct {
	// JSON file format configuration.
	JsonFileFormat *JsonFileFormat `protobuf:"bytes,101,opt,name=json_file_format,json=jsonFileFormat,proto3,oneof"`
}

type GcsDestinationConfig_builder 

type GcsDestinationConfig_builder struct {

	// Path inside the Cloud Storage bucket to write data to.
	Path string
	// The maximum file size to be saved in the bucket.
	FileRotationMb int32
	// The maximum duration for which new events are added before a file is
	// closed and a new file is created.
	FileRotationInterval *durationpb.Duration

	// Fields of oneof FileFormat:
	// AVRO file format configuration.
	AvroFileFormat *AvroFileFormat
	// JSON file format configuration.
	JsonFileFormat *JsonFileFormat
	// contains filtered or unexported fields
}

func (GcsDestinationConfig_builder) Build 

func (b0 GcsDestinationConfig_builder) Build() *GcsDestinationConfig

type 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) GetBucket 

func (x *GcsProfile) GetBucket() string

func (*GcsProfile) GetRootPath 

func (x *GcsProfile) GetRootPath() string

func (*GcsProfile) ProtoMessage 

func (*GcsProfile) ProtoMessage()

func (*GcsProfile) ProtoReflect 

func (x *GcsProfile) ProtoReflect() protoreflect.Message

func (*GcsProfile) Reset 

func (x *GcsProfile) Reset()

func (*GcsProfile) SetBucket 

func (x *GcsProfile) SetBucket(v string)

func (*GcsProfile) SetRootPath 

func (x *GcsProfile) SetRootPath(v string)

func (*GcsProfile) String 

func (x *GcsProfile) String() string

type GcsProfile_builder 

type GcsProfile_builder struct {

	// Required. The Cloud Storage bucket name.
	Bucket string
	// The root path inside the Cloud Storage bucket.
	RootPath string
	// contains filtered or unexported fields
}

func (GcsProfile_builder) Build 

func (b0 GcsProfile_builder) Build() *GcsProfile

type JsonFileFormat 

type JsonFileFormat struct {

	// The schema file format along JSON data files.
	SchemaFileFormat JsonFileFormat_SchemaFileFormat `` /* 183-byte string literal not displayed */
	// Compression of the loaded JSON file.
	Compression JsonFileFormat_JsonCompression `` /* 146-byte string literal not displayed */
	// contains filtered or unexported fields
}

JSON file format configuration.

func (*JsonFileFormat) GetCompression 

func (x *JsonFileFormat) GetCompression() JsonFileFormat_JsonCompression

func (*JsonFileFormat) GetSchemaFileFormat 

func (x *JsonFileFormat) GetSchemaFileFormat() JsonFileFormat_SchemaFileFormat

func (*JsonFileFormat) ProtoMessage 

func (*JsonFileFormat) ProtoMessage()

func (*JsonFileFormat) ProtoReflect 

func (x *JsonFileFormat) ProtoReflect() protoreflect.Message

func (*JsonFileFormat) Reset 

func (x *JsonFileFormat) Reset()

func (*JsonFileFormat) SetCompression 

func (x *JsonFileFormat) SetCompression(v JsonFileFormat_JsonCompression)

func (*JsonFileFormat) SetSchemaFileFormat 

func (x *JsonFileFormat) SetSchemaFileFormat(v JsonFileFormat_SchemaFileFormat)

func (*JsonFileFormat) String 

func (x *JsonFileFormat) String() string

type JsonFileFormat_JsonCompression 

type JsonFileFormat_JsonCompression int32

Json file compression. 

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.EnumDescriptor

func (JsonFileFormat_JsonCompression) Enum 

func (x JsonFileFormat_JsonCompression) Enum() *JsonFileFormat_JsonCompression

func (JsonFileFormat_JsonCompression) Number 

func (x JsonFileFormat_JsonCompression) Number() protoreflect.EnumNumber

func (JsonFileFormat_JsonCompression) String 

func (x JsonFileFormat_JsonCompression) String() string

func (JsonFileFormat_JsonCompression) Type 

func (JsonFileFormat_JsonCompression) Type() protoreflect.EnumType

type JsonFileFormat_SchemaFileFormat 

type JsonFileFormat_SchemaFileFormat int32

Schema file format. 

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.EnumDescriptor

func (JsonFileFormat_SchemaFileFormat) Enum 

func (x JsonFileFormat_SchemaFileFormat) Enum() *JsonFileFormat_SchemaFileFormat

func (JsonFileFormat_SchemaFileFormat) Number 

func (x JsonFileFormat_SchemaFileFormat) Number() protoreflect.EnumNumber

func (JsonFileFormat_SchemaFileFormat) String 

func (x JsonFileFormat_SchemaFileFormat) String() string

func (JsonFileFormat_SchemaFileFormat) Type 

func (JsonFileFormat_SchemaFileFormat) Type() protoreflect.EnumType

type JsonFileFormat_builder 

type JsonFileFormat_builder struct {

	// The schema file format along JSON data files.
	SchemaFileFormat JsonFileFormat_SchemaFileFormat
	// Compression of the loaded JSON file.
	Compression JsonFileFormat_JsonCompression
	// contains filtered or unexported fields
}

func (JsonFileFormat_builder) Build 

func (b0 JsonFileFormat_builder) Build() *JsonFileFormat

type MysqlColumn 

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"`
	// contains filtered or unexported fields
}

MySQL Column.

func (*MysqlColumn) GetCollation 

func (x *MysqlColumn) GetCollation() string

func (*MysqlColumn) GetColumn 

func (x *MysqlColumn) GetColumn() string

func (*MysqlColumn) GetDataType 

func (x *MysqlColumn) GetDataType() string

func (*MysqlColumn) GetLength 

func (x *MysqlColumn) GetLength() int32

func (*MysqlColumn) GetNullable 

func (x *MysqlColumn) GetNullable() bool

func (*MysqlColumn) GetOrdinalPosition 

func (x *MysqlColumn) GetOrdinalPosition() int32

func (*MysqlColumn) GetPrimaryKey 

func (x *MysqlColumn) GetPrimaryKey() bool

func (*MysqlColumn) ProtoMessage 

func (*MysqlColumn) ProtoMessage()

func (*MysqlColumn) ProtoReflect 

func (x *MysqlColumn) ProtoReflect() protoreflect.Message

func (*MysqlColumn) Reset 

func (x *MysqlColumn) Reset()

func (*MysqlColumn) SetCollation 

func (x *MysqlColumn) SetCollation(v string)

func (*MysqlColumn) SetColumn 

func (x *MysqlColumn) SetColumn(v string)

func (*MysqlColumn) SetDataType 

func (x *MysqlColumn) SetDataType(v string)

func (*MysqlColumn) SetLength 

func (x *MysqlColumn) SetLength(v int32)

func (*MysqlColumn) SetNullable 

func (x *MysqlColumn) SetNullable(v bool)

func (*MysqlColumn) SetOrdinalPosition 

func (x *MysqlColumn) SetOrdinalPosition(v int32)

func (*MysqlColumn) SetPrimaryKey 

func (x *MysqlColumn) SetPrimaryKey(v bool)

func (*MysqlColumn) String 

func (x *MysqlColumn) String() string

type MysqlColumn_builder 

type MysqlColumn_builder struct {

	// Column name.
	Column string
	// 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
	// Column length.
	Length int32
	// Column collation.
	Collation string
	// Whether or not the column represents a primary key.
	PrimaryKey bool
	// Whether or not the column can accept a null value.
	Nullable bool
	// The ordinal position of the column in the table.
	OrdinalPosition int32
	// contains filtered or unexported fields
}

func (MysqlColumn_builder) Build 

func (b0 MysqlColumn_builder) Build() *MysqlColumn

type MysqlDatabase 

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) GetDatabase 

func (x *MysqlDatabase) GetDatabase() string

func (*MysqlDatabase) GetMysqlTables 

func (x *MysqlDatabase) GetMysqlTables() []*MysqlTable

func (*MysqlDatabase) ProtoMessage 

func (*MysqlDatabase) ProtoMessage()

func (*MysqlDatabase) ProtoReflect 

func (x *MysqlDatabase) ProtoReflect() protoreflect.Message

func (*MysqlDatabase) Reset 

func (x *MysqlDatabase) Reset()

func (*MysqlDatabase) SetDatabase 

func (x *MysqlDatabase) SetDatabase(v string)

func (*MysqlDatabase) SetMysqlTables 

func (x *MysqlDatabase) SetMysqlTables(v []*MysqlTable)

func (*MysqlDatabase) String 

func (x *MysqlDatabase) String() string

type MysqlDatabase_builder 

type MysqlDatabase_builder struct {

	// Database name.
	Database string
	// Tables in the database.
	MysqlTables []*MysqlTable
	// contains filtered or unexported fields
}

func (MysqlDatabase_builder) Build 

func (b0 MysqlDatabase_builder) Build() *MysqlDatabase

type MysqlProfile 

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"`
	// 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) ClearSslConfig 

func (x *MysqlProfile) ClearSslConfig()

func (*MysqlProfile) GetHostname 

func (x *MysqlProfile) GetHostname() string

func (*MysqlProfile) GetPort 

func (x *MysqlProfile) GetPort() int32

func (*MysqlProfile) GetSslConfig 

func (x *MysqlProfile) GetSslConfig() *MysqlSslConfig

func (*MysqlProfile) GetUsername 

func (x *MysqlProfile) GetUsername() string

func (*MysqlProfile) HasSslConfig 

func (x *MysqlProfile) HasSslConfig() bool

func (*MysqlProfile) ProtoMessage 

func (*MysqlProfile) ProtoMessage()

func (*MysqlProfile) ProtoReflect 

func (x *MysqlProfile) ProtoReflect() protoreflect.Message

func (*MysqlProfile) Reset 

func (x *MysqlProfile) Reset()

func (*MysqlProfile) SetHostname 

func (x *MysqlProfile) SetHostname(v string)

func (*MysqlProfile) SetPort 

func (x *MysqlProfile) SetPort(v int32)

func (*MysqlProfile) SetSslConfig 

func (x *MysqlProfile) SetSslConfig(v *MysqlSslConfig)

func (*MysqlProfile) SetUsername 

func (x *MysqlProfile) SetUsername(v string)

func (*MysqlProfile) String 

func (x *MysqlProfile) String() string

type MysqlProfile_builder 

type MysqlProfile_builder struct {

	// Required. Hostname for the MySQL connection.
	Hostname string
	// Port for the MySQL connection, default value is 3306.
	Port int32
	// Required. Username for the MySQL connection.
	Username string
	// SSL configuration for the MySQL connection.
	SslConfig *MysqlSslConfig
	// contains filtered or unexported fields
}

func (MysqlProfile_builder) Build 

func (b0 MysqlProfile_builder) Build() *MysqlProfile

type MysqlRdbms 

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) GetMysqlDatabases 

func (x *MysqlRdbms) GetMysqlDatabases() []*MysqlDatabase

func (*MysqlRdbms) ProtoMessage 

func (*MysqlRdbms) ProtoMessage()

func (*MysqlRdbms) ProtoReflect 

func (x *MysqlRdbms) ProtoReflect() protoreflect.Message

func (*MysqlRdbms) Reset 

func (x *MysqlRdbms) Reset()

func (*MysqlRdbms) SetMysqlDatabases 

func (x *MysqlRdbms) SetMysqlDatabases(v []*MysqlDatabase)

func (*MysqlRdbms) String 

func (x *MysqlRdbms) String() string

type MysqlRdbms_builder 

type MysqlRdbms_builder struct {

	// Mysql databases on the server
	MysqlDatabases []*MysqlDatabase
	// contains filtered or unexported fields
}

func (MysqlRdbms_builder) Build 

func (b0 MysqlRdbms_builder) Build() *MysqlRdbms

type MysqlSourceConfig 

type MysqlSourceConfig struct {

	// MySQL objects to retrieve from the source.
	IncludeObjects *MysqlRdbms `protobuf:"bytes,1,opt,name=include_objects,json=includeObjects,proto3" json:"include_objects,omitempty"`
	// MySQL objects to exclude from the stream.
	ExcludeObjects *MysqlRdbms `protobuf:"bytes,2,opt,name=exclude_objects,json=excludeObjects,proto3" json:"exclude_objects,omitempty"`
	// Maximum number of concurrent CDC tasks. The number should be non negative.
	// If not set (or set to 0), the system's default value will be used.
	MaxConcurrentCdcTasks int32 `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

MySQL source configuration

func (*MysqlSourceConfig) ClearExcludeObjects 

func (x *MysqlSourceConfig) ClearExcludeObjects()

func (*MysqlSourceConfig) ClearIncludeObjects 

func (x *MysqlSourceConfig) ClearIncludeObjects()

func (*MysqlSourceConfig) GetExcludeObjects 

func (x *MysqlSourceConfig) GetExcludeObjects() *MysqlRdbms

func (*MysqlSourceConfig) GetIncludeObjects 

func (x *MysqlSourceConfig) GetIncludeObjects() *MysqlRdbms

func (*MysqlSourceConfig) GetMaxConcurrentCdcTasks 

func (x *MysqlSourceConfig) GetMaxConcurrentCdcTasks() int32

func (*MysqlSourceConfig) HasExcludeObjects 

func (x *MysqlSourceConfig) HasExcludeObjects() bool

func (*MysqlSourceConfig) HasIncludeObjects 

func (x *MysqlSourceConfig) HasIncludeObjects() bool

func (*MysqlSourceConfig) ProtoMessage 

func (*MysqlSourceConfig) ProtoMessage()

func (*MysqlSourceConfig) ProtoReflect 

func (x *MysqlSourceConfig) ProtoReflect() protoreflect.Message

func (*MysqlSourceConfig) Reset 

func (x *MysqlSourceConfig) Reset()

func (*MysqlSourceConfig) SetExcludeObjects 

func (x *MysqlSourceConfig) SetExcludeObjects(v *MysqlRdbms)

func (*MysqlSourceConfig) SetIncludeObjects 

func (x *MysqlSourceConfig) SetIncludeObjects(v *MysqlRdbms)

func (*MysqlSourceConfig) SetMaxConcurrentCdcTasks 

func (x *MysqlSourceConfig) SetMaxConcurrentCdcTasks(v int32)

func (*MysqlSourceConfig) String 

func (x *MysqlSourceConfig) String() string

type MysqlSourceConfig_builder 

type MysqlSourceConfig_builder struct {

	// MySQL objects to retrieve from the source.
	IncludeObjects *MysqlRdbms
	// MySQL objects to exclude from the stream.
	ExcludeObjects *MysqlRdbms
	// Maximum number of concurrent CDC tasks. The number should be non negative.
	// If not set (or set to 0), the system's default value will be used.
	MaxConcurrentCdcTasks int32
	// contains filtered or unexported fields
}

func (MysqlSourceConfig_builder) Build 

func (b0 MysqlSourceConfig_builder) Build() *MysqlSourceConfig

type MysqlSslConfig 

type MysqlSslConfig struct {

	// 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"`
	// 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"`
	// 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) GetCaCertificateSet 

func (x *MysqlSslConfig) GetCaCertificateSet() bool

func (*MysqlSslConfig) GetClientCertificateSet 

func (x *MysqlSslConfig) GetClientCertificateSet() bool

func (*MysqlSslConfig) GetClientKeySet 

func (x *MysqlSslConfig) GetClientKeySet() bool

func (*MysqlSslConfig) ProtoMessage 

func (*MysqlSslConfig) ProtoMessage()

func (*MysqlSslConfig) ProtoReflect 

func (x *MysqlSslConfig) ProtoReflect() protoreflect.Message

func (*MysqlSslConfig) Reset 

func (x *MysqlSslConfig) Reset()

func (*MysqlSslConfig) SetCaCertificateSet 

func (x *MysqlSslConfig) SetCaCertificateSet(v bool)

func (*MysqlSslConfig) SetClientCertificateSet 

func (x *MysqlSslConfig) SetClientCertificateSet(v bool)

func (*MysqlSslConfig) SetClientKeySet 

func (x *MysqlSslConfig) SetClientKeySet(v bool)

func (*MysqlSslConfig) String 

func (x *MysqlSslConfig) String() string

type MysqlSslConfig_builder 

type MysqlSslConfig_builder struct {

	// Output only. Indicates whether the client_key field is set.
	ClientKeySet bool
	// Output only. Indicates whether the client_certificate field is set.
	ClientCertificateSet bool
	// Output only. Indicates whether the ca_certificate field is set.
	CaCertificateSet bool
	// contains filtered or unexported fields
}

func (MysqlSslConfig_builder) Build 

func (b0 MysqlSslConfig_builder) Build() *MysqlSslConfig

type MysqlTable 

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) GetMysqlColumns 

func (x *MysqlTable) GetMysqlColumns() []*MysqlColumn

func (*MysqlTable) GetTable 

func (x *MysqlTable) GetTable() string

func (*MysqlTable) ProtoMessage 

func (*MysqlTable) ProtoMessage()

func (*MysqlTable) ProtoReflect 

func (x *MysqlTable) ProtoReflect() protoreflect.Message

func (*MysqlTable) Reset 

func (x *MysqlTable) Reset()

func (*MysqlTable) SetMysqlColumns 

func (x *MysqlTable) SetMysqlColumns(v []*MysqlColumn)

func (*MysqlTable) SetTable 

func (x *MysqlTable) SetTable(v string)

func (*MysqlTable) String 

func (x *MysqlTable) String() string

type MysqlTable_builder 

type MysqlTable_builder struct {

	// Table name.
	Table string
	// MySQL columns in the database.
	// When unspecified as part of include/exclude objects, includes/excludes
	// everything.
	MysqlColumns []*MysqlColumn
	// contains filtered or unexported fields
}

func (MysqlTable_builder) Build 

func (b0 MysqlTable_builder) Build() *MysqlTable

type OracleColumn 

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) GetColumn 

func (x *OracleColumn) GetColumn() string

func (*OracleColumn) GetDataType 

func (x *OracleColumn) GetDataType() string

func (*OracleColumn) GetEncoding 

func (x *OracleColumn) GetEncoding() string

func (*OracleColumn) GetLength 

func (x *OracleColumn) GetLength() int32

func (*OracleColumn) GetNullable 

func (x *OracleColumn) GetNullable() bool

func (*OracleColumn) GetOrdinalPosition 

func (x *OracleColumn) GetOrdinalPosition() int32

func (*OracleColumn) GetPrecision 

func (x *OracleColumn) GetPrecision() int32

func (*OracleColumn) GetPrimaryKey 

func (x *OracleColumn) GetPrimaryKey() bool

func (*OracleColumn) GetScale 

func (x *OracleColumn) GetScale() int32

func (*OracleColumn) ProtoMessage 

func (*OracleColumn) ProtoMessage()

func (*OracleColumn) ProtoReflect 

func (x *OracleColumn) ProtoReflect() protoreflect.Message

func (*OracleColumn) Reset 

func (x *OracleColumn) Reset()

func (*OracleColumn) SetColumn 

func (x *OracleColumn) SetColumn(v string)

func (*OracleColumn) SetDataType 

func (x *OracleColumn) SetDataType(v string)

func (*OracleColumn) SetEncoding 

func (x *OracleColumn) SetEncoding(v string)

func (*OracleColumn) SetLength 

func (x *OracleColumn) SetLength(v int32)

func (*OracleColumn) SetNullable 

func (x *OracleColumn) SetNullable(v bool)

func (*OracleColumn) SetOrdinalPosition 

func (x *OracleColumn) SetOrdinalPosition(v int32)

func (*OracleColumn) SetPrecision 

func (x *OracleColumn) SetPrecision(v int32)

func (*OracleColumn) SetPrimaryKey 

func (x *OracleColumn) SetPrimaryKey(v bool)

func (*OracleColumn) SetScale 

func (x *OracleColumn) SetScale(v int32)

func (*OracleColumn) String 

func (x *OracleColumn) String() string

type OracleColumn_builder 

type OracleColumn_builder struct {

	// Column name.
	Column string
	// The Oracle data type.
	DataType string
	// Column length.
	Length int32
	// Column precision.
	Precision int32
	// Column scale.
	Scale int32
	// Column encoding.
	Encoding string
	// Whether or not the column represents a primary key.
	PrimaryKey bool
	// Whether or not the column can accept a null value.
	Nullable bool
	// The ordinal position of the column in the table.
	OrdinalPosition int32
	// contains filtered or unexported fields
}

func (OracleColumn_builder) Build 

func (b0 OracleColumn_builder) Build() *OracleColumn

type OracleProfile 

type OracleProfile struct {

	// Required. Hostname for the Oracle connection.
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Port for the Oracle connection, default value is 1521.
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Required. Username for the Oracle connection.
	Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	// Required. Database for the Oracle connection.
	DatabaseService string `protobuf:"bytes,5,opt,name=database_service,json=databaseService,proto3" json:"database_service,omitempty"`
	// Connection string attributes
	ConnectionAttributes map[string]string `` /* 195-byte string literal not displayed */
	// contains filtered or unexported fields
}

Oracle database profile.

func (*OracleProfile) GetConnectionAttributes 

func (x *OracleProfile) GetConnectionAttributes() map[string]string

func (*OracleProfile) GetDatabaseService 

func (x *OracleProfile) GetDatabaseService() string

func (*OracleProfile) GetHostname 

func (x *OracleProfile) GetHostname() string

func (*OracleProfile) GetPort 

func (x *OracleProfile) GetPort() int32

func (*OracleProfile) GetUsername 

func (x *OracleProfile) GetUsername() string

func (*OracleProfile) ProtoMessage 

func (*OracleProfile) ProtoMessage()

func (*OracleProfile) ProtoReflect 

func (x *OracleProfile) ProtoReflect() protoreflect.Message

func (*OracleProfile) Reset 

func (x *OracleProfile) Reset()

func (*OracleProfile) SetConnectionAttributes 

func (x *OracleProfile) SetConnectionAttributes(v map[string]string)

func (*OracleProfile) SetDatabaseService 

func (x *OracleProfile) SetDatabaseService(v string)

func (*OracleProfile) SetHostname 

func (x *OracleProfile) SetHostname(v string)

func (*OracleProfile) SetPort 

func (x *OracleProfile) SetPort(v int32)

func (*OracleProfile) SetUsername 

func (x *OracleProfile) SetUsername(v string)

func (*OracleProfile) String 

func (x *OracleProfile) String() string

type OracleProfile_builder 

type OracleProfile_builder struct {

	// Required. Hostname for the Oracle connection.
	Hostname string
	// Port for the Oracle connection, default value is 1521.
	Port int32
	// Required. Username for the Oracle connection.
	Username string
	// Required. Database for the Oracle connection.
	DatabaseService string
	// Connection string attributes
	ConnectionAttributes map[string]string
	// contains filtered or unexported fields
}

func (OracleProfile_builder) Build 

func (b0 OracleProfile_builder) Build() *OracleProfile

type OracleRdbms 

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) GetOracleSchemas 

func (x *OracleRdbms) GetOracleSchemas() []*OracleSchema

func (*OracleRdbms) ProtoMessage 

func (*OracleRdbms) ProtoMessage()

func (*OracleRdbms) ProtoReflect 

func (x *OracleRdbms) ProtoReflect() protoreflect.Message

func (*OracleRdbms) Reset 

func (x *OracleRdbms) Reset()

func (*OracleRdbms) SetOracleSchemas 

func (x *OracleRdbms) SetOracleSchemas(v []*OracleSchema)

func (*OracleRdbms) String 

func (x *OracleRdbms) String() string

type OracleRdbms_builder 

type OracleRdbms_builder struct {

	// Oracle schemas/databases in the database server.
	OracleSchemas []*OracleSchema
	// contains filtered or unexported fields
}

func (OracleRdbms_builder) Build 

func (b0 OracleRdbms_builder) Build() *OracleRdbms

type OracleSchema 

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) GetOracleTables 

func (x *OracleSchema) GetOracleTables() []*OracleTable

func (*OracleSchema) GetSchema 

func (x *OracleSchema) GetSchema() string

func (*OracleSchema) ProtoMessage 

func (*OracleSchema) ProtoMessage()

func (*OracleSchema) ProtoReflect 

func (x *OracleSchema) ProtoReflect() protoreflect.Message

func (*OracleSchema) Reset 

func (x *OracleSchema) Reset()

func (*OracleSchema) SetOracleTables 

func (x *OracleSchema) SetOracleTables(v []*OracleTable)

func (*OracleSchema) SetSchema 

func (x *OracleSchema) SetSchema(v string)

func (*OracleSchema) String 

func (x *OracleSchema) String() string

type OracleSchema_builder 

type OracleSchema_builder struct {

	// Schema name.
	Schema string
	// Tables in the schema.
	OracleTables []*OracleTable
	// contains filtered or unexported fields
}

func (OracleSchema_builder) Build 

func (b0 OracleSchema_builder) Build() *OracleSchema

type OracleSourceConfig 

type OracleSourceConfig struct {

	// Oracle objects to include in the stream.
	IncludeObjects *OracleRdbms `protobuf:"bytes,1,opt,name=include_objects,json=includeObjects,proto3" json:"include_objects,omitempty"`
	// Oracle objects to exclude from the stream.
	ExcludeObjects *OracleRdbms `protobuf:"bytes,2,opt,name=exclude_objects,json=excludeObjects,proto3" json:"exclude_objects,omitempty"`
	// Maximum number of concurrent CDC tasks. The number should be non negative.
	// If not set (or set to 0), the system's default value will be used.
	MaxConcurrentCdcTasks int32 `` /* 129-byte string literal not displayed */
	// The configuration for handle Oracle large objects.
	//
	// Types that are valid to be assigned to LargeObjectsHandling:
	//
	//	*OracleSourceConfig_DropLargeObjects_
	//	*OracleSourceConfig_StreamLargeObjects_
	LargeObjectsHandling isOracleSourceConfig_LargeObjectsHandling `protobuf_oneof:"large_objects_handling"`
	// contains filtered or unexported fields
}

Oracle data source configuration

func (*OracleSourceConfig) ClearDropLargeObjects 

func (x *OracleSourceConfig) ClearDropLargeObjects()

func (*OracleSourceConfig) ClearExcludeObjects 

func (x *OracleSourceConfig) ClearExcludeObjects()

func (*OracleSourceConfig) ClearIncludeObjects 

func (x *OracleSourceConfig) ClearIncludeObjects()

func (*OracleSourceConfig) ClearLargeObjectsHandling 

func (x *OracleSourceConfig) ClearLargeObjectsHandling()

func (*OracleSourceConfig) ClearStreamLargeObjects 

func (x *OracleSourceConfig) ClearStreamLargeObjects()

func (*OracleSourceConfig) GetDropLargeObjects 

func (x *OracleSourceConfig) GetDropLargeObjects() *OracleSourceConfig_DropLargeObjects

func (*OracleSourceConfig) GetExcludeObjects 

func (x *OracleSourceConfig) GetExcludeObjects() *OracleRdbms

func (*OracleSourceConfig) GetIncludeObjects 

func (x *OracleSourceConfig) GetIncludeObjects() *OracleRdbms

func (*OracleSourceConfig) GetLargeObjectsHandling 

func (x *OracleSourceConfig) GetLargeObjectsHandling() isOracleSourceConfig_LargeObjectsHandling

func (*OracleSourceConfig) GetMaxConcurrentCdcTasks 

func (x *OracleSourceConfig) GetMaxConcurrentCdcTasks() int32

func (*OracleSourceConfig) GetStreamLargeObjects 

func (x *OracleSourceConfig) GetStreamLargeObjects() *OracleSourceConfig_StreamLargeObjects

func (*OracleSourceConfig) HasDropLargeObjects 

func (x *OracleSourceConfig) HasDropLargeObjects() bool

func (*OracleSourceConfig) HasExcludeObjects 

func (x *OracleSourceConfig) HasExcludeObjects() bool

func (*OracleSourceConfig) HasIncludeObjects 

func (x *OracleSourceConfig) HasIncludeObjects() bool

func (*OracleSourceConfig) HasLargeObjectsHandling 

func (x *OracleSourceConfig) HasLargeObjectsHandling() bool

func (*OracleSourceConfig) HasStreamLargeObjects 

func (x *OracleSourceConfig) HasStreamLargeObjects() bool

func (*OracleSourceConfig) ProtoMessage 

func (*OracleSourceConfig) ProtoMessage()

func (*OracleSourceConfig) ProtoReflect 

func (x *OracleSourceConfig) ProtoReflect() protoreflect.Message

func (*OracleSourceConfig) Reset 

func (x *OracleSourceConfig) Reset()

func (*OracleSourceConfig) SetDropLargeObjects 

func (x *OracleSourceConfig) SetDropLargeObjects(v *OracleSourceConfig_DropLargeObjects)

func (*OracleSourceConfig) SetExcludeObjects 

func (x *OracleSourceConfig) SetExcludeObjects(v *OracleRdbms)

func (*OracleSourceConfig) SetIncludeObjects 

func (x *OracleSourceConfig) SetIncludeObjects(v *OracleRdbms)

func (*OracleSourceConfig) SetMaxConcurrentCdcTasks 

func (x *OracleSourceConfig) SetMaxConcurrentCdcTasks(v int32)

func (*OracleSourceConfig) SetStreamLargeObjects 

func (x *OracleSourceConfig) SetStreamLargeObjects(v *OracleSourceConfig_StreamLargeObjects)

func (*OracleSourceConfig) String 

func (x *OracleSourceConfig) String() string

func (*OracleSourceConfig) WhichLargeObjectsHandling 

func (x *OracleSourceConfig) WhichLargeObjectsHandling() case_OracleSourceConfig_LargeObjectsHandling

type OracleSourceConfig_DropLargeObjects 

type OracleSourceConfig_DropLargeObjects struct {
	// contains filtered or unexported fields
}

Configuration to drop large object values.

func (*OracleSourceConfig_DropLargeObjects) ProtoMessage 

func (*OracleSourceConfig_DropLargeObjects) ProtoMessage()

func (*OracleSourceConfig_DropLargeObjects) ProtoReflect 

func (x *OracleSourceConfig_DropLargeObjects) ProtoReflect() protoreflect.Message

func (*OracleSourceConfig_DropLargeObjects) Reset 

func (x *OracleSourceConfig_DropLargeObjects) Reset()

func (*OracleSourceConfig_DropLargeObjects) String 

func (x *OracleSourceConfig_DropLargeObjects) String() string

type OracleSourceConfig_DropLargeObjects_ 

type OracleSourceConfig_DropLargeObjects_ struct {
	// Drop large object values.
	DropLargeObjects *OracleSourceConfig_DropLargeObjects `protobuf:"bytes,100,opt,name=drop_large_objects,json=dropLargeObjects,proto3,oneof"`
}

type OracleSourceConfig_DropLargeObjects_builder 

type OracleSourceConfig_DropLargeObjects_builder struct {
	// contains filtered or unexported fields
}

func (OracleSourceConfig_DropLargeObjects_builder) Build 

func (b0 OracleSourceConfig_DropLargeObjects_builder) Build() *OracleSourceConfig_DropLargeObjects

type OracleSourceConfig_StreamLargeObjects 

type OracleSourceConfig_StreamLargeObjects struct {
	// contains filtered or unexported fields
}

Configuration to stream large object values.

func (*OracleSourceConfig_StreamLargeObjects) ProtoMessage 

func (*OracleSourceConfig_StreamLargeObjects) ProtoMessage()

func (*OracleSourceConfig_StreamLargeObjects) ProtoReflect 

func (x *OracleSourceConfig_StreamLargeObjects) ProtoReflect() protoreflect.Message

func (*OracleSourceConfig_StreamLargeObjects) Reset 

func (x *OracleSourceConfig_StreamLargeObjects) Reset()

func (*OracleSourceConfig_StreamLargeObjects) String 

func (x *OracleSourceConfig_StreamLargeObjects) String() string

type OracleSourceConfig_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"`
}

type OracleSourceConfig_StreamLargeObjects_builder 

type OracleSourceConfig_StreamLargeObjects_builder struct {
	// contains filtered or unexported fields
}

func (OracleSourceConfig_StreamLargeObjects_builder) Build 

func (b0 OracleSourceConfig_StreamLargeObjects_builder) Build() *OracleSourceConfig_StreamLargeObjects

type OracleSourceConfig_builder 

type OracleSourceConfig_builder struct {

	// Oracle objects to include in the stream.
	IncludeObjects *OracleRdbms
	// Oracle objects to exclude from the stream.
	ExcludeObjects *OracleRdbms
	// Maximum number of concurrent CDC tasks. The number should be non negative.
	// If not set (or set to 0), the system's default value will be used.
	MaxConcurrentCdcTasks int32

	// Fields of oneof LargeObjectsHandling:
	// Drop large object values.
	DropLargeObjects *OracleSourceConfig_DropLargeObjects
	// Stream large object values. NOTE: This feature is currently experimental.
	StreamLargeObjects *OracleSourceConfig_StreamLargeObjects
	// contains filtered or unexported fields
}

func (OracleSourceConfig_builder) Build 

func (b0 OracleSourceConfig_builder) Build() *OracleSourceConfig

type 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) GetOracleColumns 

func (x *OracleTable) GetOracleColumns() []*OracleColumn

func (*OracleTable) GetTable 

func (x *OracleTable) GetTable() string

func (*OracleTable) ProtoMessage 

func (*OracleTable) ProtoMessage()

func (*OracleTable) ProtoReflect 

func (x *OracleTable) ProtoReflect() protoreflect.Message

func (*OracleTable) Reset 

func (x *OracleTable) Reset()

func (*OracleTable) SetOracleColumns 

func (x *OracleTable) SetOracleColumns(v []*OracleColumn)

func (*OracleTable) SetTable 

func (x *OracleTable) SetTable(v string)

func (*OracleTable) String 

func (x *OracleTable) String() string

type OracleTable_builder 

type OracleTable_builder struct {

	// Table name.
	Table string
	// Oracle columns in the schema.
	// When unspecified as part of include/exclude objects, includes/excludes
	// everything.
	OracleColumns []*OracleColumn
	// contains filtered or unexported fields
}

func (OracleTable_builder) Build 

func (b0 OracleTable_builder) Build() *OracleTable

type PostgresqlColumn 

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) GetColumn 

func (x *PostgresqlColumn) GetColumn() string

func (*PostgresqlColumn) GetDataType 

func (x *PostgresqlColumn) GetDataType() string

func (*PostgresqlColumn) GetLength 

func (x *PostgresqlColumn) GetLength() int32

func (*PostgresqlColumn) GetNullable 

func (x *PostgresqlColumn) GetNullable() bool

func (*PostgresqlColumn) GetOrdinalPosition 

func (x *PostgresqlColumn) GetOrdinalPosition() int32

func (*PostgresqlColumn) GetPrecision 

func (x *PostgresqlColumn) GetPrecision() int32

func (*PostgresqlColumn) GetPrimaryKey 

func (x *PostgresqlColumn) GetPrimaryKey() bool

func (*PostgresqlColumn) GetScale 

func (x *PostgresqlColumn) GetScale() int32

func (*PostgresqlColumn) ProtoMessage 

func (*PostgresqlColumn) ProtoMessage()

func (*PostgresqlColumn) ProtoReflect 

func (x *PostgresqlColumn) ProtoReflect() protoreflect.Message

func (*PostgresqlColumn) Reset 

func (x *PostgresqlColumn) Reset()

func (*PostgresqlColumn) SetColumn 

func (x *PostgresqlColumn) SetColumn(v string)

func (*PostgresqlColumn) SetDataType 

func (x *PostgresqlColumn) SetDataType(v string)

func (*PostgresqlColumn) SetLength 

func (x *PostgresqlColumn) SetLength(v int32)

func (*PostgresqlColumn) SetNullable 

func (x *PostgresqlColumn) SetNullable(v bool)

func (*PostgresqlColumn) SetOrdinalPosition 

func (x *PostgresqlColumn) SetOrdinalPosition(v int32)

func (*PostgresqlColumn) SetPrecision 

func (x *PostgresqlColumn) SetPrecision(v int32)

func (*PostgresqlColumn) SetPrimaryKey 

func (x *PostgresqlColumn) SetPrimaryKey(v bool)

func (*PostgresqlColumn) SetScale 

func (x *PostgresqlColumn) SetScale(v int32)

func (*PostgresqlColumn) String 

func (x *PostgresqlColumn) String() string

type PostgresqlColumn_builder 

type PostgresqlColumn_builder struct {

	// Column name.
	Column string
	// The PostgreSQL data type.
	DataType string
	// Column length.
	Length int32
	// Column precision.
	Precision int32
	// Column scale.
	Scale int32
	// Whether or not the column represents a primary key.
	PrimaryKey bool
	// Whether or not the column can accept a null value.
	Nullable bool
	// The ordinal position of the column in the table.
	OrdinalPosition int32
	// contains filtered or unexported fields
}

func (PostgresqlColumn_builder) Build 

func (b0 PostgresqlColumn_builder) Build() *PostgresqlColumn

type PostgresqlProfile 

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. 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) GetDatabase 

func (x *PostgresqlProfile) GetDatabase() string

func (*PostgresqlProfile) GetHostname 

func (x *PostgresqlProfile) GetHostname() string

func (*PostgresqlProfile) GetPort 

func (x *PostgresqlProfile) GetPort() int32

func (*PostgresqlProfile) GetUsername 

func (x *PostgresqlProfile) GetUsername() string

func (*PostgresqlProfile) ProtoMessage 

func (*PostgresqlProfile) ProtoMessage()

func (*PostgresqlProfile) ProtoReflect 

func (x *PostgresqlProfile) ProtoReflect() protoreflect.Message

func (*PostgresqlProfile) Reset 

func (x *PostgresqlProfile) Reset()

func (*PostgresqlProfile) SetDatabase 

func (x *PostgresqlProfile) SetDatabase(v string)

func (*PostgresqlProfile) SetHostname 

func (x *PostgresqlProfile) SetHostname(v string)

func (*PostgresqlProfile) SetPort 

func (x *PostgresqlProfile) SetPort(v int32)

func (*PostgresqlProfile) SetUsername 

func (x *PostgresqlProfile) SetUsername(v string)

func (*PostgresqlProfile) String 

func (x *PostgresqlProfile) String() string

type PostgresqlProfile_builder 

type PostgresqlProfile_builder struct {

	// Required. Hostname for the PostgreSQL connection.
	Hostname string
	// Port for the PostgreSQL connection, default value is 5432.
	Port int32
	// Required. Username for the PostgreSQL connection.
	Username string
	// Required. Database for the PostgreSQL connection.
	Database string
	// contains filtered or unexported fields
}

func (PostgresqlProfile_builder) Build 

func (b0 PostgresqlProfile_builder) Build() *PostgresqlProfile

type PostgresqlRdbms 

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) GetPostgresqlSchemas 

func (x *PostgresqlRdbms) GetPostgresqlSchemas() []*PostgresqlSchema

func (*PostgresqlRdbms) ProtoMessage 

func (*PostgresqlRdbms) ProtoMessage()

func (*PostgresqlRdbms) ProtoReflect 

func (x *PostgresqlRdbms) ProtoReflect() protoreflect.Message

func (*PostgresqlRdbms) Reset 

func (x *PostgresqlRdbms) Reset()

func (*PostgresqlRdbms) SetPostgresqlSchemas 

func (x *PostgresqlRdbms) SetPostgresqlSchemas(v []*PostgresqlSchema)

func (*PostgresqlRdbms) String 

func (x *PostgresqlRdbms) String() string

type PostgresqlRdbms_builder 

type PostgresqlRdbms_builder struct {

	// PostgreSQL schemas in the database server.
	PostgresqlSchemas []*PostgresqlSchema
	// contains filtered or unexported fields
}

func (PostgresqlRdbms_builder) Build 

func (b0 PostgresqlRdbms_builder) Build() *PostgresqlRdbms

type PostgresqlSchema 

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) GetPostgresqlTables 

func (x *PostgresqlSchema) GetPostgresqlTables() []*PostgresqlTable

func (*PostgresqlSchema) GetSchema 

func (x *PostgresqlSchema) GetSchema() string

func (*PostgresqlSchema) ProtoMessage 

func (*PostgresqlSchema) ProtoMessage()

func (*PostgresqlSchema) ProtoReflect 

func (x *PostgresqlSchema) ProtoReflect() protoreflect.Message

func (*PostgresqlSchema) Reset 

func (x *PostgresqlSchema) Reset()

func (*PostgresqlSchema) SetPostgresqlTables 

func (x *PostgresqlSchema) SetPostgresqlTables(v []*PostgresqlTable)

func (*PostgresqlSchema) SetSchema 

func (x *PostgresqlSchema) SetSchema(v string)

func (*PostgresqlSchema) String 

func (x *PostgresqlSchema) String() string

type PostgresqlSchema_builder 

type PostgresqlSchema_builder struct {

	// Schema name.
	Schema string
	// Tables in the schema.
	PostgresqlTables []*PostgresqlTable
	// contains filtered or unexported fields
}

func (PostgresqlSchema_builder) Build 

func (b0 PostgresqlSchema_builder) Build() *PostgresqlSchema

type PostgresqlSourceConfig 

type PostgresqlSourceConfig struct {

	// PostgreSQL objects to include in the stream.
	IncludeObjects *PostgresqlRdbms `protobuf:"bytes,1,opt,name=include_objects,json=includeObjects,proto3" json:"include_objects,omitempty"`
	// PostgreSQL objects to exclude from the stream.
	ExcludeObjects *PostgresqlRdbms `protobuf:"bytes,2,opt,name=exclude_objects,json=excludeObjects,proto3" json:"exclude_objects,omitempty"`
	// Required. Immutable. The name of the logical replication slot that's configured with the
	// pgoutput plugin.
	ReplicationSlot string `protobuf:"bytes,3,opt,name=replication_slot,json=replicationSlot,proto3" json:"replication_slot,omitempty"`
	// Required. The name of the publication that includes the set of all tables that are
	// defined in the stream's include_objects.
	Publication string `protobuf:"bytes,4,opt,name=publication,proto3" json:"publication,omitempty"`
	// contains filtered or unexported fields
}

PostgreSQL data source configuration

func (*PostgresqlSourceConfig) ClearExcludeObjects 

func (x *PostgresqlSourceConfig) ClearExcludeObjects()

func (*PostgresqlSourceConfig) ClearIncludeObjects 

func (x *PostgresqlSourceConfig) ClearIncludeObjects()

func (*PostgresqlSourceConfig) GetExcludeObjects 

func (x *PostgresqlSourceConfig) GetExcludeObjects() *PostgresqlRdbms

func (*PostgresqlSourceConfig) GetIncludeObjects 

func (x *PostgresqlSourceConfig) GetIncludeObjects() *PostgresqlRdbms

func (*PostgresqlSourceConfig) GetPublication 

func (x *PostgresqlSourceConfig) GetPublication() string

func (*PostgresqlSourceConfig) GetReplicationSlot 

func (x *PostgresqlSourceConfig) GetReplicationSlot() string

func (*PostgresqlSourceConfig) HasExcludeObjects 

func (x *PostgresqlSourceConfig) HasExcludeObjects() bool

func (*PostgresqlSourceConfig) HasIncludeObjects 

func (x *PostgresqlSourceConfig) HasIncludeObjects() bool

func (*PostgresqlSourceConfig) ProtoMessage 

func (*PostgresqlSourceConfig) ProtoMessage()

func (*PostgresqlSourceConfig) ProtoReflect 

func (x *PostgresqlSourceConfig) ProtoReflect() protoreflect.Message

func (*PostgresqlSourceConfig) Reset 

func (x *PostgresqlSourceConfig) Reset()

func (*PostgresqlSourceConfig) SetExcludeObjects 

func (x *PostgresqlSourceConfig) SetExcludeObjects(v *PostgresqlRdbms)

func (*PostgresqlSourceConfig) SetIncludeObjects 

func (x *PostgresqlSourceConfig) SetIncludeObjects(v *PostgresqlRdbms)

func (*PostgresqlSourceConfig) SetPublication 

func (x *PostgresqlSourceConfig) SetPublication(v string)

func (*PostgresqlSourceConfig) SetReplicationSlot 

func (x *PostgresqlSourceConfig) SetReplicationSlot(v string)

func (*PostgresqlSourceConfig) String 

func (x *PostgresqlSourceConfig) String() string

type PostgresqlSourceConfig_builder 

type PostgresqlSourceConfig_builder struct {

	// PostgreSQL objects to include in the stream.
	IncludeObjects *PostgresqlRdbms
	// PostgreSQL objects to exclude from the stream.
	ExcludeObjects *PostgresqlRdbms
	// Required. Immutable. The name of the logical replication slot that's configured with the
	// pgoutput plugin.
	ReplicationSlot string
	// Required. The name of the publication that includes the set of all tables that are
	// defined in the stream's include_objects.
	Publication string
	// contains filtered or unexported fields
}

func (PostgresqlSourceConfig_builder) Build 

func (b0 PostgresqlSourceConfig_builder) Build() *PostgresqlSourceConfig

type PostgresqlTable 

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) GetPostgresqlColumns 

func (x *PostgresqlTable) GetPostgresqlColumns() []*PostgresqlColumn

func (*PostgresqlTable) GetTable 

func (x *PostgresqlTable) GetTable() string

func (*PostgresqlTable) ProtoMessage 

func (*PostgresqlTable) ProtoMessage()

func (*PostgresqlTable) ProtoReflect 

func (x *PostgresqlTable) ProtoReflect() protoreflect.Message

func (*PostgresqlTable) Reset 

func (x *PostgresqlTable) Reset()

func (*PostgresqlTable) SetPostgresqlColumns 

func (x *PostgresqlTable) SetPostgresqlColumns(v []*PostgresqlColumn)

func (*PostgresqlTable) SetTable 

func (x *PostgresqlTable) SetTable(v string)

func (*PostgresqlTable) String 

func (x *PostgresqlTable) String() string

type PostgresqlTable_builder 

type PostgresqlTable_builder struct {

	// Table name.
	Table string
	// PostgreSQL columns in the schema.
	// When unspecified as part of include/exclude objects,
	// includes/excludes everything.
	PostgresqlColumns []*PostgresqlColumn
	// contains filtered or unexported fields
}

func (PostgresqlTable_builder) Build 

func (b0 PostgresqlTable_builder) Build() *PostgresqlTable

type PrivateConnection 

type PrivateConnection struct {

	// Output only. The resource's name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The create time of the resource.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The update time of the resource.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Labels.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Required. Display name.
	DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Output only. The state of the Private Connection.
	State PrivateConnection_State `` /* 127-byte string literal not displayed */
	// Output only. In case of error, the details of the error in a user-friendly format.
	Error *Error `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"`
	// VPC Peering Config.
	VpcPeeringConfig *VpcPeeringConfig `protobuf:"bytes,100,opt,name=vpc_peering_config,json=vpcPeeringConfig,proto3" json:"vpc_peering_config,omitempty"`
	// contains filtered or unexported fields
}

The PrivateConnection resource is used to establish private connectivity between Datastream and a customer's network.

func (*PrivateConnection) ClearCreateTime 

func (x *PrivateConnection) ClearCreateTime()

func (*PrivateConnection) ClearError 

func (x *PrivateConnection) ClearError()

func (*PrivateConnection) ClearUpdateTime 

func (x *PrivateConnection) ClearUpdateTime()

func (*PrivateConnection) ClearVpcPeeringConfig 

func (x *PrivateConnection) ClearVpcPeeringConfig()

func (*PrivateConnection) GetCreateTime 

func (x *PrivateConnection) GetCreateTime() *timestamppb.Timestamp

func (*PrivateConnection) GetDisplayName 

func (x *PrivateConnection) GetDisplayName() string

func (*PrivateConnection) GetError 

func (x *PrivateConnection) GetError() *Error

func (*PrivateConnection) GetLabels 

func (x *PrivateConnection) GetLabels() map[string]string

func (*PrivateConnection) GetName 

func (x *PrivateConnection) GetName() string

func (*PrivateConnection) GetState 

func (x *PrivateConnection) GetState() PrivateConnection_State

func (*PrivateConnection) GetUpdateTime 

func (x *PrivateConnection) GetUpdateTime() *timestamppb.Timestamp

func (*PrivateConnection) GetVpcPeeringConfig 

func (x *PrivateConnection) GetVpcPeeringConfig() *VpcPeeringConfig

func (*PrivateConnection) HasCreateTime 

func (x *PrivateConnection) HasCreateTime() bool

func (*PrivateConnection) HasError 

func (x *PrivateConnection) HasError() bool

func (*PrivateConnection) HasUpdateTime 

func (x *PrivateConnection) HasUpdateTime() bool

func (*PrivateConnection) HasVpcPeeringConfig 

func (x *PrivateConnection) HasVpcPeeringConfig() bool

func (*PrivateConnection) ProtoMessage 

func (*PrivateConnection) ProtoMessage()

func (*PrivateConnection) ProtoReflect 

func (x *PrivateConnection) ProtoReflect() protoreflect.Message

func (*PrivateConnection) Reset 

func (x *PrivateConnection) Reset()

func (*PrivateConnection) SetCreateTime 

func (x *PrivateConnection) SetCreateTime(v *timestamppb.Timestamp)

func (*PrivateConnection) SetDisplayName 

func (x *PrivateConnection) SetDisplayName(v string)

func (*PrivateConnection) SetError 

func (x *PrivateConnection) SetError(v *Error)

func (*PrivateConnection) SetLabels 

func (x *PrivateConnection) SetLabels(v map[string]string)

func (*PrivateConnection) SetName 

func (x *PrivateConnection) SetName(v string)

func (*PrivateConnection) SetState 

func (x *PrivateConnection) SetState(v PrivateConnection_State)

func (*PrivateConnection) SetUpdateTime 

func (x *PrivateConnection) SetUpdateTime(v *timestamppb.Timestamp)

func (*PrivateConnection) SetVpcPeeringConfig 

func (x *PrivateConnection) SetVpcPeeringConfig(v *VpcPeeringConfig)

func (*PrivateConnection) String 

func (x *PrivateConnection) String() string

type PrivateConnectionCreatedEvent 

type PrivateConnectionCreatedEvent struct {

	// The data associated with the event.
	Data *PrivateConnectionEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a PrivateConnection is created.

func (*PrivateConnectionCreatedEvent) ClearData 

func (x *PrivateConnectionCreatedEvent) ClearData()

func (*PrivateConnectionCreatedEvent) GetData 

func (x *PrivateConnectionCreatedEvent) GetData() *PrivateConnectionEventData

func (*PrivateConnectionCreatedEvent) HasData 

func (x *PrivateConnectionCreatedEvent) HasData() bool

func (*PrivateConnectionCreatedEvent) ProtoMessage 

func (*PrivateConnectionCreatedEvent) ProtoMessage()

func (*PrivateConnectionCreatedEvent) ProtoReflect 

func (x *PrivateConnectionCreatedEvent) ProtoReflect() protoreflect.Message

func (*PrivateConnectionCreatedEvent) Reset 

func (x *PrivateConnectionCreatedEvent) Reset()

func (*PrivateConnectionCreatedEvent) SetData 

func (x *PrivateConnectionCreatedEvent) SetData(v *PrivateConnectionEventData)

func (*PrivateConnectionCreatedEvent) String 

func (x *PrivateConnectionCreatedEvent) String() string

type PrivateConnectionCreatedEvent_builder 

type PrivateConnectionCreatedEvent_builder struct {

	// The data associated with the event.
	Data *PrivateConnectionEventData
	// contains filtered or unexported fields
}

func (PrivateConnectionCreatedEvent_builder) Build 

func (b0 PrivateConnectionCreatedEvent_builder) Build() *PrivateConnectionCreatedEvent

type PrivateConnectionDeletedEvent 

type PrivateConnectionDeletedEvent struct {

	// The data associated with the event.
	Data *PrivateConnectionEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a PrivateConnection is deleted.

func (*PrivateConnectionDeletedEvent) ClearData 

func (x *PrivateConnectionDeletedEvent) ClearData()

func (*PrivateConnectionDeletedEvent) GetData 

func (x *PrivateConnectionDeletedEvent) GetData() *PrivateConnectionEventData

func (*PrivateConnectionDeletedEvent) HasData 

func (x *PrivateConnectionDeletedEvent) HasData() bool

func (*PrivateConnectionDeletedEvent) ProtoMessage 

func (*PrivateConnectionDeletedEvent) ProtoMessage()

func (*PrivateConnectionDeletedEvent) ProtoReflect 

func (x *PrivateConnectionDeletedEvent) ProtoReflect() protoreflect.Message

func (*PrivateConnectionDeletedEvent) Reset 

func (x *PrivateConnectionDeletedEvent) Reset()

func (*PrivateConnectionDeletedEvent) SetData 

func (x *PrivateConnectionDeletedEvent) SetData(v *PrivateConnectionEventData)

func (*PrivateConnectionDeletedEvent) String 

func (x *PrivateConnectionDeletedEvent) String() string

type PrivateConnectionDeletedEvent_builder 

type PrivateConnectionDeletedEvent_builder struct {

	// The data associated with the event.
	Data *PrivateConnectionEventData
	// contains filtered or unexported fields
}

func (PrivateConnectionDeletedEvent_builder) Build 

func (b0 PrivateConnectionDeletedEvent_builder) Build() *PrivateConnectionDeletedEvent

type PrivateConnectionEventData 

type PrivateConnectionEventData struct {

	// Optional. The PrivateConnection event payload. Unset for deletion events.
	Payload *PrivateConnection `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all PrivateConnection events.

func (*PrivateConnectionEventData) ClearPayload 

func (x *PrivateConnectionEventData) ClearPayload()

func (*PrivateConnectionEventData) GetPayload 

func (x *PrivateConnectionEventData) GetPayload() *PrivateConnection

func (*PrivateConnectionEventData) HasPayload 

func (x *PrivateConnectionEventData) HasPayload() bool

func (*PrivateConnectionEventData) ProtoMessage 

func (*PrivateConnectionEventData) ProtoMessage()

func (*PrivateConnectionEventData) ProtoReflect 

func (x *PrivateConnectionEventData) ProtoReflect() protoreflect.Message

func (*PrivateConnectionEventData) Reset 

func (x *PrivateConnectionEventData) Reset()

func (*PrivateConnectionEventData) SetPayload 

func (x *PrivateConnectionEventData) SetPayload(v *PrivateConnection)

func (*PrivateConnectionEventData) String 

func (x *PrivateConnectionEventData) String() string

type PrivateConnectionEventData_builder 

type PrivateConnectionEventData_builder struct {

	// Optional. The PrivateConnection event payload. Unset for deletion events.
	Payload *PrivateConnection
	// contains filtered or unexported fields
}

func (PrivateConnectionEventData_builder) Build 

func (b0 PrivateConnectionEventData_builder) Build() *PrivateConnectionEventData

type PrivateConnection_State 

type PrivateConnection_State int32

Private Connection state. 

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.EnumDescriptor

func (PrivateConnection_State) Enum 

func (x PrivateConnection_State) Enum() *PrivateConnection_State

func (PrivateConnection_State) Number 

func (x PrivateConnection_State) Number() protoreflect.EnumNumber

func (PrivateConnection_State) String 

func (x PrivateConnection_State) String() string

func (PrivateConnection_State) Type 

func (PrivateConnection_State) Type() protoreflect.EnumType

type PrivateConnection_builder 

type PrivateConnection_builder struct {

	// Output only. The resource's name.
	Name string
	// Output only. The create time of the resource.
	CreateTime *timestamppb.Timestamp
	// Output only. The update time of the resource.
	UpdateTime *timestamppb.Timestamp
	// Labels.
	Labels map[string]string
	// Required. Display name.
	DisplayName string
	// Output only. The state of the Private Connection.
	State PrivateConnection_State
	// Output only. In case of error, the details of the error in a user-friendly format.
	Error *Error
	// VPC Peering Config.
	VpcPeeringConfig *VpcPeeringConfig
	// contains filtered or unexported fields
}

func (PrivateConnection_builder) Build 

func (b0 PrivateConnection_builder) Build() *PrivateConnection

type PrivateConnectivity 

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) GetPrivateConnection 

func (x *PrivateConnectivity) GetPrivateConnection() string

func (*PrivateConnectivity) ProtoMessage 

func (*PrivateConnectivity) ProtoMessage()

func (*PrivateConnectivity) ProtoReflect 

func (x *PrivateConnectivity) ProtoReflect() protoreflect.Message

func (*PrivateConnectivity) Reset 

func (x *PrivateConnectivity) Reset()

func (*PrivateConnectivity) SetPrivateConnection 

func (x *PrivateConnectivity) SetPrivateConnection(v string)

func (*PrivateConnectivity) String 

func (x *PrivateConnectivity) String() string

type PrivateConnectivity_builder 

type PrivateConnectivity_builder struct {

	// Required. A reference to a private connection resource.
	// Format: `projects/{project}/locations/{location}/privateConnections/{name}`
	PrivateConnection string
	// contains filtered or unexported fields
}

func (PrivateConnectivity_builder) Build 

func (b0 PrivateConnectivity_builder) Build() *PrivateConnectivity

type Route 

type Route struct {

	// Output only. The resource's name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The create time of the resource.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The update time of the resource.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Labels.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Required. Display name.
	DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Required. Destination address for connection
	DestinationAddress string `protobuf:"bytes,6,opt,name=destination_address,json=destinationAddress,proto3" json:"destination_address,omitempty"`
	// Destination port for connection
	DestinationPort int32 `protobuf:"varint,7,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"`
	// contains filtered or unexported fields
}

The route resource is the child of the private connection resource, used for defining a route for a private connection.

func (*Route) ClearCreateTime 

func (x *Route) ClearCreateTime()

func (*Route) ClearUpdateTime 

func (x *Route) ClearUpdateTime()

func (*Route) GetCreateTime 

func (x *Route) GetCreateTime() *timestamppb.Timestamp

func (*Route) GetDestinationAddress 

func (x *Route) GetDestinationAddress() string

func (*Route) GetDestinationPort 

func (x *Route) GetDestinationPort() int32

func (*Route) GetDisplayName 

func (x *Route) GetDisplayName() string

func (*Route) GetLabels 

func (x *Route) GetLabels() map[string]string

func (*Route) GetName 

func (x *Route) GetName() string

func (*Route) GetUpdateTime 

func (x *Route) GetUpdateTime() *timestamppb.Timestamp

func (*Route) HasCreateTime 

func (x *Route) HasCreateTime() bool

func (*Route) HasUpdateTime 

func (x *Route) HasUpdateTime() bool

func (*Route) ProtoMessage 

func (*Route) ProtoMessage()

func (*Route) ProtoReflect 

func (x *Route) ProtoReflect() protoreflect.Message

func (*Route) Reset 

func (x *Route) Reset()

func (*Route) SetCreateTime 

func (x *Route) SetCreateTime(v *timestamppb.Timestamp)

func (*Route) SetDestinationAddress 

func (x *Route) SetDestinationAddress(v string)

func (*Route) SetDestinationPort 

func (x *Route) SetDestinationPort(v int32)

func (*Route) SetDisplayName 

func (x *Route) SetDisplayName(v string)

func (*Route) SetLabels 

func (x *Route) SetLabels(v map[string]string)

func (*Route) SetName 

func (x *Route) SetName(v string)

func (*Route) SetUpdateTime 

func (x *Route) SetUpdateTime(v *timestamppb.Timestamp)

func (*Route) String 

func (x *Route) String() string

type RouteCreatedEvent 

type RouteCreatedEvent struct {

	// The data associated with the event.
	Data *RouteEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Route is created.

func (*RouteCreatedEvent) ClearData 

func (x *RouteCreatedEvent) ClearData()

func (*RouteCreatedEvent) GetData 

func (x *RouteCreatedEvent) GetData() *RouteEventData

func (*RouteCreatedEvent) HasData 

func (x *RouteCreatedEvent) HasData() bool

func (*RouteCreatedEvent) ProtoMessage 

func (*RouteCreatedEvent) ProtoMessage()

func (*RouteCreatedEvent) ProtoReflect 

func (x *RouteCreatedEvent) ProtoReflect() protoreflect.Message

func (*RouteCreatedEvent) Reset 

func (x *RouteCreatedEvent) Reset()

func (*RouteCreatedEvent) SetData 

func (x *RouteCreatedEvent) SetData(v *RouteEventData)

func (*RouteCreatedEvent) String 

func (x *RouteCreatedEvent) String() string

type RouteCreatedEvent_builder 

type RouteCreatedEvent_builder struct {

	// The data associated with the event.
	Data *RouteEventData
	// contains filtered or unexported fields
}

func (RouteCreatedEvent_builder) Build 

func (b0 RouteCreatedEvent_builder) Build() *RouteCreatedEvent

type RouteDeletedEvent 

type RouteDeletedEvent struct {

	// The data associated with the event.
	Data *RouteEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Route is deleted.

func (*RouteDeletedEvent) ClearData 

func (x *RouteDeletedEvent) ClearData()

func (*RouteDeletedEvent) GetData 

func (x *RouteDeletedEvent) GetData() *RouteEventData

func (*RouteDeletedEvent) HasData 

func (x *RouteDeletedEvent) HasData() bool

func (*RouteDeletedEvent) ProtoMessage 

func (*RouteDeletedEvent) ProtoMessage()

func (*RouteDeletedEvent) ProtoReflect 

func (x *RouteDeletedEvent) ProtoReflect() protoreflect.Message

func (*RouteDeletedEvent) Reset 

func (x *RouteDeletedEvent) Reset()

func (*RouteDeletedEvent) SetData 

func (x *RouteDeletedEvent) SetData(v *RouteEventData)

func (*RouteDeletedEvent) String 

func (x *RouteDeletedEvent) String() string

type RouteDeletedEvent_builder 

type RouteDeletedEvent_builder struct {

	// The data associated with the event.
	Data *RouteEventData
	// contains filtered or unexported fields
}

func (RouteDeletedEvent_builder) Build 

func (b0 RouteDeletedEvent_builder) Build() *RouteDeletedEvent

type RouteEventData 

type RouteEventData struct {

	// Optional. The Route event payload. Unset for deletion events.
	Payload *Route `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Route events.

func (*RouteEventData) ClearPayload 

func (x *RouteEventData) ClearPayload()

func (*RouteEventData) GetPayload 

func (x *RouteEventData) GetPayload() *Route

func (*RouteEventData) HasPayload 

func (x *RouteEventData) HasPayload() bool

func (*RouteEventData) ProtoMessage 

func (*RouteEventData) ProtoMessage()

func (*RouteEventData) ProtoReflect 

func (x *RouteEventData) ProtoReflect() protoreflect.Message

func (*RouteEventData) Reset 

func (x *RouteEventData) Reset()

func (*RouteEventData) SetPayload 

func (x *RouteEventData) SetPayload(v *Route)

func (*RouteEventData) String 

func (x *RouteEventData) String() string

type RouteEventData_builder 

type RouteEventData_builder struct {

	// Optional. The Route event payload. Unset for deletion events.
	Payload *Route
	// contains filtered or unexported fields
}

func (RouteEventData_builder) Build 

func (b0 RouteEventData_builder) Build() *RouteEventData

type Route_builder 

type Route_builder struct {

	// Output only. The resource's name.
	Name string
	// Output only. The create time of the resource.
	CreateTime *timestamppb.Timestamp
	// Output only. The update time of the resource.
	UpdateTime *timestamppb.Timestamp
	// Labels.
	Labels map[string]string
	// Required. Display name.
	DisplayName string
	// Required. Destination address for connection
	DestinationAddress string
	// Destination port for connection
	DestinationPort int32
	// contains filtered or unexported fields
}

func (Route_builder) Build 

func (b0 Route_builder) Build() *Route

type SourceConfig 

type SourceConfig struct {

	// Required. Source connection profile resoource.
	// Format: `projects/{project}/locations/{location}/connectionProfiles/{name}`
	SourceConnectionProfile string `` /* 132-byte string literal not displayed */
	// Stream configuration that is specific to the data source type.
	//
	// Types that are valid to be assigned to SourceStreamConfig:
	//
	//	*SourceConfig_OracleSourceConfig
	//	*SourceConfig_MysqlSourceConfig
	//	*SourceConfig_PostgresqlSourceConfig
	SourceStreamConfig isSourceConfig_SourceStreamConfig `protobuf_oneof:"source_stream_config"`
	// contains filtered or unexported fields
}

The configuration of the stream source.

func (*SourceConfig) ClearMysqlSourceConfig 

func (x *SourceConfig) ClearMysqlSourceConfig()

func (*SourceConfig) ClearOracleSourceConfig 

func (x *SourceConfig) ClearOracleSourceConfig()

func (*SourceConfig) ClearPostgresqlSourceConfig 

func (x *SourceConfig) ClearPostgresqlSourceConfig()

func (*SourceConfig) ClearSourceStreamConfig 

func (x *SourceConfig) ClearSourceStreamConfig()

func (*SourceConfig) GetMysqlSourceConfig 

func (x *SourceConfig) GetMysqlSourceConfig() *MysqlSourceConfig

func (*SourceConfig) GetOracleSourceConfig 

func (x *SourceConfig) GetOracleSourceConfig() *OracleSourceConfig

func (*SourceConfig) GetPostgresqlSourceConfig 

func (x *SourceConfig) GetPostgresqlSourceConfig() *PostgresqlSourceConfig

func (*SourceConfig) GetSourceConnectionProfile 

func (x *SourceConfig) GetSourceConnectionProfile() string

func (*SourceConfig) GetSourceStreamConfig 

func (x *SourceConfig) GetSourceStreamConfig() isSourceConfig_SourceStreamConfig

func (*SourceConfig) HasMysqlSourceConfig 

func (x *SourceConfig) HasMysqlSourceConfig() bool

func (*SourceConfig) HasOracleSourceConfig 

func (x *SourceConfig) HasOracleSourceConfig() bool

func (*SourceConfig) HasPostgresqlSourceConfig 

func (x *SourceConfig) HasPostgresqlSourceConfig() bool

func (*SourceConfig) HasSourceStreamConfig 

func (x *SourceConfig) HasSourceStreamConfig() bool

func (*SourceConfig) ProtoMessage 

func (*SourceConfig) ProtoMessage()

func (*SourceConfig) ProtoReflect 

func (x *SourceConfig) ProtoReflect() protoreflect.Message

func (*SourceConfig) Reset 

func (x *SourceConfig) Reset()

func (*SourceConfig) SetMysqlSourceConfig 

func (x *SourceConfig) SetMysqlSourceConfig(v *MysqlSourceConfig)

func (*SourceConfig) SetOracleSourceConfig 

func (x *SourceConfig) SetOracleSourceConfig(v *OracleSourceConfig)

func (*SourceConfig) SetPostgresqlSourceConfig 

func (x *SourceConfig) SetPostgresqlSourceConfig(v *PostgresqlSourceConfig)

func (*SourceConfig) SetSourceConnectionProfile 

func (x *SourceConfig) SetSourceConnectionProfile(v string)

func (*SourceConfig) String 

func (x *SourceConfig) String() string

func (*SourceConfig) WhichSourceStreamConfig 

func (x *SourceConfig) WhichSourceStreamConfig() case_SourceConfig_SourceStreamConfig

type SourceConfig_MysqlSourceConfig 

type SourceConfig_MysqlSourceConfig struct {
	// MySQL data source configuration.
	MysqlSourceConfig *MysqlSourceConfig `protobuf:"bytes,101,opt,name=mysql_source_config,json=mysqlSourceConfig,proto3,oneof"`
}

type SourceConfig_OracleSourceConfig 

type SourceConfig_OracleSourceConfig struct {
	// Oracle data source configuration.
	OracleSourceConfig *OracleSourceConfig `protobuf:"bytes,100,opt,name=oracle_source_config,json=oracleSourceConfig,proto3,oneof"`
}

type SourceConfig_PostgresqlSourceConfig 

type SourceConfig_PostgresqlSourceConfig struct {
	// PostgreSQL data source configuration.
	PostgresqlSourceConfig *PostgresqlSourceConfig `protobuf:"bytes,102,opt,name=postgresql_source_config,json=postgresqlSourceConfig,proto3,oneof"`
}

type SourceConfig_builder 

type SourceConfig_builder struct {

	// Required. Source connection profile resoource.
	// Format: `projects/{project}/locations/{location}/connectionProfiles/{name}`
	SourceConnectionProfile string

	// Fields of oneof SourceStreamConfig:
	// Oracle data source configuration.
	OracleSourceConfig *OracleSourceConfig
	// MySQL data source configuration.
	MysqlSourceConfig *MysqlSourceConfig
	// PostgreSQL data source configuration.
	PostgresqlSourceConfig *PostgresqlSourceConfig
	// contains filtered or unexported fields
}

func (SourceConfig_builder) Build 

func (b0 SourceConfig_builder) Build() *SourceConfig

type StaticServiceIpConnectivity 

type StaticServiceIpConnectivity struct {
	// contains filtered or unexported fields
}

Static IP address connectivity.

func (*StaticServiceIpConnectivity) ProtoMessage 

func (*StaticServiceIpConnectivity) ProtoMessage()

func (*StaticServiceIpConnectivity) ProtoReflect 

func (x *StaticServiceIpConnectivity) ProtoReflect() protoreflect.Message

func (*StaticServiceIpConnectivity) Reset 

func (x *StaticServiceIpConnectivity) Reset()

func (*StaticServiceIpConnectivity) String 

func (x *StaticServiceIpConnectivity) String() string

type StaticServiceIpConnectivity_builder 

type StaticServiceIpConnectivity_builder struct {
	// contains filtered or unexported fields
}

func (StaticServiceIpConnectivity_builder) Build 

func (b0 StaticServiceIpConnectivity_builder) Build() *StaticServiceIpConnectivity

type Stream 

type Stream struct {

	// Output only. The stream's name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The creation time of the stream.
	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 stream.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Labels.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Required. Display name.
	DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Required. Source connection profile configuration.
	SourceConfig *SourceConfig `protobuf:"bytes,6,opt,name=source_config,json=sourceConfig,proto3" json:"source_config,omitempty"`
	// Required. Destination connection profile configuration.
	DestinationConfig *DestinationConfig `protobuf:"bytes,7,opt,name=destination_config,json=destinationConfig,proto3" json:"destination_config,omitempty"`
	// The state of the stream.
	State Stream_State `protobuf:"varint,8,opt,name=state,proto3,enum=google.events.cloud.datastream.v1.Stream_State" json:"state,omitempty"`
	// Stream backfill strategy.
	//
	// Types that are valid to be assigned to BackfillStrategy:
	//
	//	*Stream_BackfillAll
	//	*Stream_BackfillNone
	BackfillStrategy isStream_BackfillStrategy `protobuf_oneof:"backfill_strategy"`
	// Output only. Errors on the Stream.
	Errors []*Error `protobuf:"bytes,9,rep,name=errors,proto3" json:"errors,omitempty"`
	// Immutable. A reference to a KMS encryption key.
	// If provided, it will be used to encrypt the data.
	// If left blank, data will be encrypted using an internal Stream-specific
	// encryption key provisioned through KMS.
	CustomerManagedEncryptionKey *string `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

A resource representing streaming data from a source to a destination.

func (*Stream) ClearBackfillAll 

func (x *Stream) ClearBackfillAll()

func (*Stream) ClearBackfillNone 

func (x *Stream) ClearBackfillNone()

func (*Stream) ClearBackfillStrategy 

func (x *Stream) ClearBackfillStrategy()

func (*Stream) ClearCreateTime 

func (x *Stream) ClearCreateTime()

func (*Stream) ClearCustomerManagedEncryptionKey 

func (x *Stream) ClearCustomerManagedEncryptionKey()

func (*Stream) ClearDestinationConfig 

func (x *Stream) ClearDestinationConfig()

func (*Stream) ClearSourceConfig 

func (x *Stream) ClearSourceConfig()

func (*Stream) ClearUpdateTime 

func (x *Stream) ClearUpdateTime()

func (*Stream) GetBackfillAll 

func (x *Stream) GetBackfillAll() *Stream_BackfillAllStrategy

func (*Stream) GetBackfillNone 

func (x *Stream) GetBackfillNone() *Stream_BackfillNoneStrategy

func (*Stream) GetBackfillStrategy 

func (x *Stream) GetBackfillStrategy() isStream_BackfillStrategy

func (*Stream) GetCreateTime 

func (x *Stream) GetCreateTime() *timestamppb.Timestamp

func (*Stream) GetCustomerManagedEncryptionKey 

func (x *Stream) GetCustomerManagedEncryptionKey() string

func (*Stream) GetDestinationConfig 

func (x *Stream) GetDestinationConfig() *DestinationConfig

func (*Stream) GetDisplayName 

func (x *Stream) GetDisplayName() string

func (*Stream) GetErrors 

func (x *Stream) GetErrors() []*Error

func (*Stream) GetLabels 

func (x *Stream) GetLabels() map[string]string

func (*Stream) GetName 

func (x *Stream) GetName() string

func (*Stream) GetSourceConfig 

func (x *Stream) GetSourceConfig() *SourceConfig

func (*Stream) GetState 

func (x *Stream) GetState() Stream_State

func (*Stream) GetUpdateTime 

func (x *Stream) GetUpdateTime() *timestamppb.Timestamp

func (*Stream) HasBackfillAll 

func (x *Stream) HasBackfillAll() bool

func (*Stream) HasBackfillNone 

func (x *Stream) HasBackfillNone() bool

func (*Stream) HasBackfillStrategy 

func (x *Stream) HasBackfillStrategy() bool

func (*Stream) HasCreateTime 

func (x *Stream) HasCreateTime() bool

func (*Stream) HasCustomerManagedEncryptionKey 

func (x *Stream) HasCustomerManagedEncryptionKey() bool

func (*Stream) HasDestinationConfig 

func (x *Stream) HasDestinationConfig() bool

func (*Stream) HasSourceConfig 

func (x *Stream) HasSourceConfig() bool

func (*Stream) HasUpdateTime 

func (x *Stream) HasUpdateTime() bool

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect 

func (x *Stream) ProtoReflect() protoreflect.Message

func (*Stream) Reset 

func (x *Stream) Reset()

func (*Stream) SetBackfillAll 

func (x *Stream) SetBackfillAll(v *Stream_BackfillAllStrategy)

func (*Stream) SetBackfillNone 

func (x *Stream) SetBackfillNone(v *Stream_BackfillNoneStrategy)

func (*Stream) SetCreateTime 

func (x *Stream) SetCreateTime(v *timestamppb.Timestamp)

func (*Stream) SetCustomerManagedEncryptionKey 

func (x *Stream) SetCustomerManagedEncryptionKey(v string)

func (*Stream) SetDestinationConfig 

func (x *Stream) SetDestinationConfig(v *DestinationConfig)

func (*Stream) SetDisplayName 

func (x *Stream) SetDisplayName(v string)

func (*Stream) SetErrors 

func (x *Stream) SetErrors(v []*Error)

func (*Stream) SetLabels 

func (x *Stream) SetLabels(v map[string]string)

func (*Stream) SetName 

func (x *Stream) SetName(v string)

func (*Stream) SetSourceConfig 

func (x *Stream) SetSourceConfig(v *SourceConfig)

func (*Stream) SetState 

func (x *Stream) SetState(v Stream_State)

func (*Stream) SetUpdateTime 

func (x *Stream) SetUpdateTime(v *timestamppb.Timestamp)

func (*Stream) String 

func (x *Stream) String() string

func (*Stream) WhichBackfillStrategy 

func (x *Stream) WhichBackfillStrategy() case_Stream_BackfillStrategy

type StreamCreatedEvent 

type StreamCreatedEvent struct {

	// The data associated with the event.
	Data *StreamEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Stream is created.

func (*StreamCreatedEvent) ClearData 

func (x *StreamCreatedEvent) ClearData()

func (*StreamCreatedEvent) GetData 

func (x *StreamCreatedEvent) GetData() *StreamEventData

func (*StreamCreatedEvent) HasData 

func (x *StreamCreatedEvent) HasData() bool

func (*StreamCreatedEvent) ProtoMessage 

func (*StreamCreatedEvent) ProtoMessage()

func (*StreamCreatedEvent) ProtoReflect 

func (x *StreamCreatedEvent) ProtoReflect() protoreflect.Message

func (*StreamCreatedEvent) Reset 

func (x *StreamCreatedEvent) Reset()

func (*StreamCreatedEvent) SetData 

func (x *StreamCreatedEvent) SetData(v *StreamEventData)

func (*StreamCreatedEvent) String 

func (x *StreamCreatedEvent) String() string

type StreamCreatedEvent_builder 

type StreamCreatedEvent_builder struct {

	// The data associated with the event.
	Data *StreamEventData
	// contains filtered or unexported fields
}

func (StreamCreatedEvent_builder) Build 

func (b0 StreamCreatedEvent_builder) Build() *StreamCreatedEvent

type StreamDeletedEvent 

type StreamDeletedEvent struct {

	// The data associated with the event.
	Data *StreamEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Stream is deleted.

func (*StreamDeletedEvent) ClearData 

func (x *StreamDeletedEvent) ClearData()

func (*StreamDeletedEvent) GetData 

func (x *StreamDeletedEvent) GetData() *StreamEventData

func (*StreamDeletedEvent) HasData 

func (x *StreamDeletedEvent) HasData() bool

func (*StreamDeletedEvent) ProtoMessage 

func (*StreamDeletedEvent) ProtoMessage()

func (*StreamDeletedEvent) ProtoReflect 

func (x *StreamDeletedEvent) ProtoReflect() protoreflect.Message

func (*StreamDeletedEvent) Reset 

func (x *StreamDeletedEvent) Reset()

func (*StreamDeletedEvent) SetData 

func (x *StreamDeletedEvent) SetData(v *StreamEventData)

func (*StreamDeletedEvent) String 

func (x *StreamDeletedEvent) String() string

type StreamDeletedEvent_builder 

type StreamDeletedEvent_builder struct {

	// The data associated with the event.
	Data *StreamEventData
	// contains filtered or unexported fields
}

func (StreamDeletedEvent_builder) Build 

func (b0 StreamDeletedEvent_builder) Build() *StreamDeletedEvent

type StreamEventData 

type StreamEventData struct {

	// Optional. The Stream event payload. Unset for deletion events.
	Payload *Stream `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Stream events.

func (*StreamEventData) ClearPayload 

func (x *StreamEventData) ClearPayload()

func (*StreamEventData) GetPayload 

func (x *StreamEventData) GetPayload() *Stream

func (*StreamEventData) HasPayload 

func (x *StreamEventData) HasPayload() bool

func (*StreamEventData) ProtoMessage 

func (*StreamEventData) ProtoMessage()

func (*StreamEventData) ProtoReflect 

func (x *StreamEventData) ProtoReflect() protoreflect.Message

func (*StreamEventData) Reset 

func (x *StreamEventData) Reset()

func (*StreamEventData) SetPayload 

func (x *StreamEventData) SetPayload(v *Stream)

func (*StreamEventData) String 

func (x *StreamEventData) String() string

type StreamEventData_builder 

type StreamEventData_builder struct {

	// Optional. The Stream event payload. Unset for deletion events.
	Payload *Stream
	// contains filtered or unexported fields
}

func (StreamEventData_builder) Build 

func (b0 StreamEventData_builder) Build() *StreamEventData

type StreamUpdatedEvent 

type StreamUpdatedEvent struct {

	// The data associated with the event.
	Data *StreamEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Stream is updated.

func (*StreamUpdatedEvent) ClearData 

func (x *StreamUpdatedEvent) ClearData()

func (*StreamUpdatedEvent) GetData 

func (x *StreamUpdatedEvent) GetData() *StreamEventData

func (*StreamUpdatedEvent) HasData 

func (x *StreamUpdatedEvent) HasData() bool

func (*StreamUpdatedEvent) ProtoMessage 

func (*StreamUpdatedEvent) ProtoMessage()

func (*StreamUpdatedEvent) ProtoReflect 

func (x *StreamUpdatedEvent) ProtoReflect() protoreflect.Message

func (*StreamUpdatedEvent) Reset 

func (x *StreamUpdatedEvent) Reset()

func (*StreamUpdatedEvent) SetData 

func (x *StreamUpdatedEvent) SetData(v *StreamEventData)

func (*StreamUpdatedEvent) String 

func (x *StreamUpdatedEvent) String() string

type StreamUpdatedEvent_builder 

type StreamUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *StreamEventData
	// contains filtered or unexported fields
}

func (StreamUpdatedEvent_builder) Build 

func (b0 StreamUpdatedEvent_builder) Build() *StreamUpdatedEvent

type Stream_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"`
}

type Stream_BackfillAllStrategy 

type Stream_BackfillAllStrategy struct {

	// List of objects to exclude.
	//
	// Types that are valid to be assigned 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) ClearExcludedObjects 

func (x *Stream_BackfillAllStrategy) ClearExcludedObjects()

func (*Stream_BackfillAllStrategy) ClearMysqlExcludedObjects 

func (x *Stream_BackfillAllStrategy) ClearMysqlExcludedObjects()

func (*Stream_BackfillAllStrategy) ClearOracleExcludedObjects 

func (x *Stream_BackfillAllStrategy) ClearOracleExcludedObjects()

func (*Stream_BackfillAllStrategy) ClearPostgresqlExcludedObjects 

func (x *Stream_BackfillAllStrategy) ClearPostgresqlExcludedObjects()

func (*Stream_BackfillAllStrategy) GetExcludedObjects 

func (x *Stream_BackfillAllStrategy) GetExcludedObjects() isStream_BackfillAllStrategy_ExcludedObjects

func (*Stream_BackfillAllStrategy) GetMysqlExcludedObjects 

func (x *Stream_BackfillAllStrategy) GetMysqlExcludedObjects() *MysqlRdbms

func (*Stream_BackfillAllStrategy) GetOracleExcludedObjects 

func (x *Stream_BackfillAllStrategy) GetOracleExcludedObjects() *OracleRdbms

func (*Stream_BackfillAllStrategy) GetPostgresqlExcludedObjects 

func (x *Stream_BackfillAllStrategy) GetPostgresqlExcludedObjects() *PostgresqlRdbms

func (*Stream_BackfillAllStrategy) HasExcludedObjects 

func (x *Stream_BackfillAllStrategy) HasExcludedObjects() bool

func (*Stream_BackfillAllStrategy) HasMysqlExcludedObjects 

func (x *Stream_BackfillAllStrategy) HasMysqlExcludedObjects() bool

func (*Stream_BackfillAllStrategy) HasOracleExcludedObjects 

func (x *Stream_BackfillAllStrategy) HasOracleExcludedObjects() bool

func (*Stream_BackfillAllStrategy) HasPostgresqlExcludedObjects 

func (x *Stream_BackfillAllStrategy) HasPostgresqlExcludedObjects() bool

func (*Stream_BackfillAllStrategy) ProtoMessage 

func (*Stream_BackfillAllStrategy) ProtoMessage()

func (*Stream_BackfillAllStrategy) ProtoReflect 

func (x *Stream_BackfillAllStrategy) ProtoReflect() protoreflect.Message

func (*Stream_BackfillAllStrategy) Reset 

func (x *Stream_BackfillAllStrategy) Reset()

func (*Stream_BackfillAllStrategy) SetMysqlExcludedObjects 

func (x *Stream_BackfillAllStrategy) SetMysqlExcludedObjects(v *MysqlRdbms)

func (*Stream_BackfillAllStrategy) SetOracleExcludedObjects 

func (x *Stream_BackfillAllStrategy) SetOracleExcludedObjects(v *OracleRdbms)

func (*Stream_BackfillAllStrategy) SetPostgresqlExcludedObjects 

func (x *Stream_BackfillAllStrategy) SetPostgresqlExcludedObjects(v *PostgresqlRdbms)

func (*Stream_BackfillAllStrategy) String 

func (x *Stream_BackfillAllStrategy) String() string

func (*Stream_BackfillAllStrategy) WhichExcludedObjects 

func (x *Stream_BackfillAllStrategy) WhichExcludedObjects() case_Stream_BackfillAllStrategy_ExcludedObjects

type Stream_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"`
}

type 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"`
}

type 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"`
}

type Stream_BackfillAllStrategy_builder 

type Stream_BackfillAllStrategy_builder struct {

	// Fields of oneof ExcludedObjects:
	// Oracle data source objects to avoid backfilling.
	OracleExcludedObjects *OracleRdbms
	// MySQL data source objects to avoid backfilling.
	MysqlExcludedObjects *MysqlRdbms
	// PostgreSQL data source objects to avoid backfilling.
	PostgresqlExcludedObjects *PostgresqlRdbms
	// contains filtered or unexported fields
}

func (Stream_BackfillAllStrategy_builder) Build 

func (b0 Stream_BackfillAllStrategy_builder) Build() *Stream_BackfillAllStrategy

type 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"`
}

type 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) ProtoMessage 

func (*Stream_BackfillNoneStrategy) ProtoMessage()

func (*Stream_BackfillNoneStrategy) ProtoReflect 

func (x *Stream_BackfillNoneStrategy) ProtoReflect() protoreflect.Message

func (*Stream_BackfillNoneStrategy) Reset 

func (x *Stream_BackfillNoneStrategy) Reset()

func (*Stream_BackfillNoneStrategy) String 

func (x *Stream_BackfillNoneStrategy) String() string

type Stream_BackfillNoneStrategy_builder 

type Stream_BackfillNoneStrategy_builder struct {
	// contains filtered or unexported fields
}

func (Stream_BackfillNoneStrategy_builder) Build 

func (b0 Stream_BackfillNoneStrategy_builder) Build() *Stream_BackfillNoneStrategy

type Stream_State 

type Stream_State int32

Stream state. 

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.EnumDescriptor

func (Stream_State) Enum 

func (x Stream_State) Enum() *Stream_State

func (Stream_State) Number 

func (x Stream_State) Number() protoreflect.EnumNumber

func (Stream_State) String 

func (x Stream_State) String() string

func (Stream_State) Type 

func (Stream_State) Type() protoreflect.EnumType

type Stream_builder 

type Stream_builder struct {

	// Output only. The stream's name.
	Name string
	// Output only. The creation time of the stream.
	CreateTime *timestamppb.Timestamp
	// Output only. The last update time of the stream.
	UpdateTime *timestamppb.Timestamp
	// Labels.
	Labels map[string]string
	// Required. Display name.
	DisplayName string
	// Required. Source connection profile configuration.
	SourceConfig *SourceConfig
	// Required. Destination connection profile configuration.
	DestinationConfig *DestinationConfig
	// The state of the stream.
	State Stream_State

	// Fields of oneof BackfillStrategy:
	// Automatically backfill objects included in the stream source
	// configuration. Specific objects can be excluded.
	BackfillAll *Stream_BackfillAllStrategy
	// Do not automatically backfill any objects.
	BackfillNone *Stream_BackfillNoneStrategy
	// -- end of BackfillStrategy
	// Output only. Errors on the Stream.
	Errors []*Error
	// Immutable. A reference to a KMS encryption key.
	// If provided, it will be used to encrypt the data.
	// If left blank, data will be encrypted using an internal Stream-specific
	// encryption key provisioned through KMS.
	CustomerManagedEncryptionKey *string
	// contains filtered or unexported fields
}

func (Stream_builder) Build 

func (b0 Stream_builder) Build() *Stream

type VpcPeeringConfig 

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) GetSubnet 

func (x *VpcPeeringConfig) GetSubnet() string

func (*VpcPeeringConfig) GetVpc 

func (x *VpcPeeringConfig) GetVpc() string

func (*VpcPeeringConfig) ProtoMessage 

func (*VpcPeeringConfig) ProtoMessage()

func (*VpcPeeringConfig) ProtoReflect 

func (x *VpcPeeringConfig) ProtoReflect() protoreflect.Message

func (*VpcPeeringConfig) Reset 

func (x *VpcPeeringConfig) Reset()

func (*VpcPeeringConfig) SetSubnet 

func (x *VpcPeeringConfig) SetSubnet(v string)

func (*VpcPeeringConfig) SetVpc 

func (x *VpcPeeringConfig) SetVpc(v string)

func (*VpcPeeringConfig) String 

func (x *VpcPeeringConfig) String() string

type VpcPeeringConfig_builder 

type VpcPeeringConfig_builder struct {

	// Required. Fully qualified name of the VPC that Datastream will peer to.
	// Format: `projects/{project}/global/{networks}/{name}`
	Vpc string
	// Required. A free subnet for peering. (CIDR of /29)
	Subnet string
	// contains filtered or unexported fields
}

func (VpcPeeringConfig_builder) Build 

func (b0 VpcPeeringConfig_builder) Build() *VpcPeeringConfig

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.