datastreamdata

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Sep 26, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package datastreamdata provides Datastream type definitions for CloudEvent data payloads.

Supported CloudEvent Types

  • google.cloud.datastream.connectionProfile.v1.created
  • google.cloud.datastream.connectionProfile.v1.updated
  • google.cloud.datastream.connectionProfile.v1.deleted
  • google.cloud.datastream.stream.v1.created
  • google.cloud.datastream.stream.v1.updated
  • google.cloud.datastream.stream.v1.deleted
  • google.cloud.datastream.privateConnection.v1.created
  • google.cloud.datastream.privateConnection.v1.deleted
  • google.cloud.datastream.route.v1.created
  • google.cloud.datastream.route.v1.deleted

Index

Constants

This section is empty.

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_cloud_datastream_v1_data_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) Descriptor deprecated 

func (*AvroFileFormat) Descriptor() ([]byte, []int)

Deprecated: Use AvroFileFormat.ProtoReflect.Descriptor instead.

func (*AvroFileFormat) ProtoMessage 

func (*AvroFileFormat) ProtoMessage()

func (*AvroFileFormat) ProtoReflect 

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

func (*AvroFileFormat) Reset 

func (x *AvroFileFormat) Reset()

func (*AvroFileFormat) String 

func (x *AvroFileFormat) String() string

type BigQueryDestinationConfig 

type BigQueryDestinationConfig struct {

	// Target dataset(s) configuration.
	//
	// Types that are assignable to DatasetConfig:
	//
	//	*BigQueryDestinationConfig_SingleTargetDataset_
	//	*BigQueryDestinationConfig_SourceHierarchyDatasets_
	DatasetConfig isBigQueryDestinationConfig_DatasetConfig `protobuf_oneof:"dataset_config"`
	// The guaranteed data freshness (in seconds) when querying tables created by
	// the stream. Editing this field will only affect new tables created in the
	// future, but existing tables will not be impacted. Lower values mean that
	// queries will return fresher data, but may result in higher cost.
	DataFreshness *durationpb.Duration `protobuf:"bytes,300,opt,name=data_freshness,json=dataFreshness,proto3" json:"data_freshness,omitempty"`
	// contains filtered or unexported fields
}

func (*BigQueryDestinationConfig) Descriptor deprecated 

func (*BigQueryDestinationConfig) Descriptor() ([]byte, []int)

Deprecated: Use BigQueryDestinationConfig.ProtoReflect.Descriptor instead.

func (*BigQueryDestinationConfig) GetDataFreshness 

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

func (*BigQueryDestinationConfig) GetDatasetConfig 

func (m *BigQueryDestinationConfig) GetDatasetConfig() isBigQueryDestinationConfig_DatasetConfig

func (*BigQueryDestinationConfig) GetSingleTargetDataset 

func (x *BigQueryDestinationConfig) GetSingleTargetDataset() *BigQueryDestinationConfig_SingleTargetDataset

func (*BigQueryDestinationConfig) GetSourceHierarchyDatasets 

func (x *BigQueryDestinationConfig) GetSourceHierarchyDatasets() *BigQueryDestinationConfig_SourceHierarchyDatasets

func (*BigQueryDestinationConfig) ProtoMessage 

func (*BigQueryDestinationConfig) ProtoMessage()

func (*BigQueryDestinationConfig) ProtoReflect 

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

func (*BigQueryDestinationConfig) Reset 

func (x *BigQueryDestinationConfig) Reset()

func (*BigQueryDestinationConfig) String 

func (x *BigQueryDestinationConfig) String() string

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) Descriptor deprecated 

func (*BigQueryDestinationConfig_SingleTargetDataset) Descriptor() ([]byte, []int)

Deprecated: Use BigQueryDestinationConfig_SingleTargetDataset.ProtoReflect.Descriptor instead.

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) 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_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) Descriptor deprecated 

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) Descriptor() ([]byte, []int)

Deprecated: Use BigQueryDestinationConfig_SourceHierarchyDatasets.ProtoReflect.Descriptor instead.

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) GetDatasetTemplate 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets) GetDatasetTemplate() *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate

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) 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) Descriptor deprecated 

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) Descriptor() ([]byte, []int)

Deprecated: Use BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate.ProtoReflect.Descriptor instead.

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetDatasetIdPrefix 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetDatasetIdPrefix() 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) String 

func (x *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) String() string

type BigQueryProfile 

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

BigQuery warehouse profile.

func (*BigQueryProfile) Descriptor deprecated 

func (*BigQueryProfile) Descriptor() ([]byte, []int)

Deprecated: Use BigQueryProfile.ProtoReflect.Descriptor instead.

func (*BigQueryProfile) ProtoMessage 

func (*BigQueryProfile) ProtoMessage()

func (*BigQueryProfile) ProtoReflect 

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

func (*BigQueryProfile) Reset 

func (x *BigQueryProfile) Reset()

func (*BigQueryProfile) String 

func (x *BigQueryProfile) String() string

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 `` /* 153-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 assignable 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 assignable 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) Descriptor deprecated 

func (*ConnectionProfile) Descriptor() ([]byte, []int)

Deprecated: Use ConnectionProfile.ProtoReflect.Descriptor instead.

func (*ConnectionProfile) GetBigqueryProfile 

func (x *ConnectionProfile) GetBigqueryProfile() *BigQueryProfile

func (*ConnectionProfile) GetConnectivity 

func (m *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 (m *ConnectionProfile) GetProfile() isConnectionProfile_Profile

func (*ConnectionProfile) GetStaticServiceIpConnectivity 

func (x *ConnectionProfile) GetStaticServiceIpConnectivity() *StaticServiceIpConnectivity

func (*ConnectionProfile) GetUpdateTime 

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

func (*ConnectionProfile) ProtoMessage 

func (*ConnectionProfile) ProtoMessage()

func (*ConnectionProfile) ProtoReflect 

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

func (*ConnectionProfile) Reset 

func (x *ConnectionProfile) Reset()

func (*ConnectionProfile) String 

func (x *ConnectionProfile) String() string

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) Descriptor deprecated 

func (*ConnectionProfileEventData) Descriptor() ([]byte, []int)

Deprecated: Use ConnectionProfileEventData.ProtoReflect.Descriptor instead.

func (*ConnectionProfileEventData) GetPayload 

func (x *ConnectionProfileEventData) GetPayload() *ConnectionProfile

func (*ConnectionProfileEventData) ProtoMessage 

func (*ConnectionProfileEventData) ProtoMessage()

func (*ConnectionProfileEventData) ProtoReflect 

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

func (*ConnectionProfileEventData) Reset 

func (x *ConnectionProfileEventData) Reset()

func (*ConnectionProfileEventData) String 

func (x *ConnectionProfileEventData) String() string

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 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 assignable 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) Descriptor deprecated 

func (*DestinationConfig) Descriptor() ([]byte, []int)

Deprecated: Use DestinationConfig.ProtoReflect.Descriptor instead.

func (*DestinationConfig) GetBigqueryDestinationConfig 

func (x *DestinationConfig) GetBigqueryDestinationConfig() *BigQueryDestinationConfig

func (*DestinationConfig) GetDestinationConnectionProfile 

func (x *DestinationConfig) GetDestinationConnectionProfile() string

func (*DestinationConfig) GetDestinationStreamConfig 

func (m *DestinationConfig) GetDestinationStreamConfig() isDestinationConfig_DestinationStreamConfig

func (*DestinationConfig) GetGcsDestinationConfig 

func (x *DestinationConfig) GetGcsDestinationConfig() *GcsDestinationConfig

func (*DestinationConfig) ProtoMessage 

func (*DestinationConfig) ProtoMessage()

func (*DestinationConfig) ProtoReflect 

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

func (*DestinationConfig) Reset 

func (x *DestinationConfig) Reset()

func (*DestinationConfig) String 

func (x *DestinationConfig) String() string

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 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 `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

Represent a user-facing Error.

func (*Error) Descriptor deprecated 

func (*Error) Descriptor() ([]byte, []int)

Deprecated: Use Error.ProtoReflect.Descriptor instead.

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

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

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) Descriptor deprecated 

func (*ForwardSshTunnelConnectivity) Descriptor() ([]byte, []int)

Deprecated: Use ForwardSshTunnelConnectivity.ProtoReflect.Descriptor instead.

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

func (x *ForwardSshTunnelConnectivity) String() string

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 assignable to FileFormat:
	//
	//	*GcsDestinationConfig_AvroFileFormat
	//	*GcsDestinationConfig_JsonFileFormat
	FileFormat isGcsDestinationConfig_FileFormat `protobuf_oneof:"file_format"`
	// contains filtered or unexported fields
}

Google Cloud Storage destination configuration

func (*GcsDestinationConfig) Descriptor deprecated 

func (*GcsDestinationConfig) Descriptor() ([]byte, []int)

Deprecated: Use GcsDestinationConfig.ProtoReflect.Descriptor instead.

func (*GcsDestinationConfig) GetAvroFileFormat 

func (x *GcsDestinationConfig) GetAvroFileFormat() *AvroFileFormat

func (*GcsDestinationConfig) GetFileFormat 

func (m *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) ProtoMessage 

func (*GcsDestinationConfig) ProtoMessage()

func (*GcsDestinationConfig) ProtoReflect 

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

func (*GcsDestinationConfig) Reset 

func (x *GcsDestinationConfig) Reset()

func (*GcsDestinationConfig) String 

func (x *GcsDestinationConfig) String() string

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 GcsProfile 

type GcsProfile struct {

	// Required. The Cloud Storage bucket name.
	Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// The root path inside the Cloud Storage bucket.
	RootPath string `protobuf:"bytes,2,opt,name=root_path,json=rootPath,proto3" json:"root_path,omitempty"`
	// contains filtered or unexported fields
}

Cloud Storage bucket profile.

func (*GcsProfile) Descriptor deprecated 

func (*GcsProfile) Descriptor() ([]byte, []int)

Deprecated: Use GcsProfile.ProtoReflect.Descriptor instead.

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

func (x *GcsProfile) String() string

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) Descriptor deprecated 

func (*JsonFileFormat) Descriptor() ([]byte, []int)

Deprecated: Use JsonFileFormat.ProtoReflect.Descriptor instead.

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) 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) EnumDescriptor deprecated 

func (JsonFileFormat_JsonCompression) EnumDescriptor() ([]byte, []int)

Deprecated: Use JsonFileFormat_JsonCompression.Descriptor instead.

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) EnumDescriptor deprecated 

func (JsonFileFormat_SchemaFileFormat) EnumDescriptor() ([]byte, []int)

Deprecated: Use JsonFileFormat_SchemaFileFormat.Descriptor instead.

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 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) Descriptor deprecated 

func (*MysqlColumn) Descriptor() ([]byte, []int)

Deprecated: Use MysqlColumn.ProtoReflect.Descriptor instead.

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

func (x *MysqlColumn) String() string

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) Descriptor deprecated 

func (*MysqlDatabase) Descriptor() ([]byte, []int)

Deprecated: Use MysqlDatabase.ProtoReflect.Descriptor instead.

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

func (x *MysqlDatabase) String() string

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) Descriptor deprecated 

func (*MysqlProfile) Descriptor() ([]byte, []int)

Deprecated: Use MysqlProfile.ProtoReflect.Descriptor instead.

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

func (*MysqlProfile) ProtoMessage()

func (*MysqlProfile) ProtoReflect 

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

func (*MysqlProfile) Reset 

func (x *MysqlProfile) Reset()

func (*MysqlProfile) String 

func (x *MysqlProfile) String() string

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) Descriptor deprecated 

func (*MysqlRdbms) Descriptor() ([]byte, []int)

Deprecated: Use MysqlRdbms.ProtoReflect.Descriptor instead.

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

func (x *MysqlRdbms) String() string

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) Descriptor deprecated 

func (*MysqlSourceConfig) Descriptor() ([]byte, []int)

Deprecated: Use MysqlSourceConfig.ProtoReflect.Descriptor instead.

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

func (*MysqlSourceConfig) ProtoMessage()

func (*MysqlSourceConfig) ProtoReflect 

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

func (*MysqlSourceConfig) Reset 

func (x *MysqlSourceConfig) Reset()

func (*MysqlSourceConfig) String 

func (x *MysqlSourceConfig) String() string

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) Descriptor deprecated 

func (*MysqlSslConfig) Descriptor() ([]byte, []int)

Deprecated: Use MysqlSslConfig.ProtoReflect.Descriptor instead.

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

func (x *MysqlSslConfig) String() string

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) Descriptor deprecated 

func (*MysqlTable) Descriptor() ([]byte, []int)

Deprecated: Use MysqlTable.ProtoReflect.Descriptor instead.

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

func (x *MysqlTable) String() string

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) Descriptor deprecated 

func (*OracleColumn) Descriptor() ([]byte, []int)

Deprecated: Use OracleColumn.ProtoReflect.Descriptor instead.

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

func (x *OracleColumn) String() string

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 `` /* 209-byte string literal not displayed */
	// contains filtered or unexported fields
}

Oracle database profile.

func (*OracleProfile) Descriptor deprecated 

func (*OracleProfile) Descriptor() ([]byte, []int)

Deprecated: Use OracleProfile.ProtoReflect.Descriptor instead.

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

func (x *OracleProfile) String() string

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) Descriptor deprecated 

func (*OracleRdbms) Descriptor() ([]byte, []int)

Deprecated: Use OracleRdbms.ProtoReflect.Descriptor instead.

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

func (x *OracleRdbms) String() string

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) Descriptor deprecated 

func (*OracleSchema) Descriptor() ([]byte, []int)

Deprecated: Use OracleSchema.ProtoReflect.Descriptor instead.

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

func (x *OracleSchema) String() string

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 assignable 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) Descriptor deprecated 

func (*OracleSourceConfig) Descriptor() ([]byte, []int)

Deprecated: Use OracleSourceConfig.ProtoReflect.Descriptor instead.

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 (m *OracleSourceConfig) GetLargeObjectsHandling() isOracleSourceConfig_LargeObjectsHandling

func (*OracleSourceConfig) GetMaxConcurrentCdcTasks 

func (x *OracleSourceConfig) GetMaxConcurrentCdcTasks() int32

func (*OracleSourceConfig) GetStreamLargeObjects 

func (x *OracleSourceConfig) GetStreamLargeObjects() *OracleSourceConfig_StreamLargeObjects

func (*OracleSourceConfig) ProtoMessage 

func (*OracleSourceConfig) ProtoMessage()

func (*OracleSourceConfig) ProtoReflect 

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

func (*OracleSourceConfig) Reset 

func (x *OracleSourceConfig) Reset()

func (*OracleSourceConfig) String 

func (x *OracleSourceConfig) String() string

type OracleSourceConfig_DropLargeObjects 

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

Configuration to drop large object values.

func (*OracleSourceConfig_DropLargeObjects) Descriptor deprecated 

func (*OracleSourceConfig_DropLargeObjects) Descriptor() ([]byte, []int)

Deprecated: Use OracleSourceConfig_DropLargeObjects.ProtoReflect.Descriptor instead.

func (*OracleSourceConfig_DropLargeObjects) ProtoMessage 

func (*OracleSourceConfig_DropLargeObjects) ProtoMessage()

func (*OracleSourceConfig_DropLargeObjects) ProtoReflect 

func (x *OracleSourceConfig_DropLargeObjects) ProtoReflect() protoreflect.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_StreamLargeObjects 

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

Configuration to stream large object values.

func (*OracleSourceConfig_StreamLargeObjects) Descriptor deprecated 

func (*OracleSourceConfig_StreamLargeObjects) Descriptor() ([]byte, []int)

Deprecated: Use OracleSourceConfig_StreamLargeObjects.ProtoReflect.Descriptor instead.

func (*OracleSourceConfig_StreamLargeObjects) ProtoMessage 

func (*OracleSourceConfig_StreamLargeObjects) ProtoMessage()

func (*OracleSourceConfig_StreamLargeObjects) ProtoReflect 

func (x *OracleSourceConfig_StreamLargeObjects) ProtoReflect() protoreflect.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 OracleTable 

type OracleTable struct {

	// Table name.
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// Oracle columns in the schema.
	// When unspecified as part of include/exclude objects, includes/excludes
	// everything.
	OracleColumns []*OracleColumn `protobuf:"bytes,2,rep,name=oracle_columns,json=oracleColumns,proto3" json:"oracle_columns,omitempty"`
	// contains filtered or unexported fields
}

Oracle table.

func (*OracleTable) Descriptor deprecated 

func (*OracleTable) Descriptor() ([]byte, []int)

Deprecated: Use OracleTable.ProtoReflect.Descriptor instead.

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

func (x *OracleTable) String() string

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) Descriptor deprecated 

func (*PostgresqlColumn) Descriptor() ([]byte, []int)

Deprecated: Use PostgresqlColumn.ProtoReflect.Descriptor instead.

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

func (x *PostgresqlColumn) String() string

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) Descriptor deprecated 

func (*PostgresqlProfile) Descriptor() ([]byte, []int)

Deprecated: Use PostgresqlProfile.ProtoReflect.Descriptor instead.

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

func (x *PostgresqlProfile) String() string

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) Descriptor deprecated 

func (*PostgresqlRdbms) Descriptor() ([]byte, []int)

Deprecated: Use PostgresqlRdbms.ProtoReflect.Descriptor instead.

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

func (x *PostgresqlRdbms) String() string

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) Descriptor deprecated 

func (*PostgresqlSchema) Descriptor() ([]byte, []int)

Deprecated: Use PostgresqlSchema.ProtoReflect.Descriptor instead.

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

func (x *PostgresqlSchema) String() string

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) Descriptor deprecated 

func (*PostgresqlSourceConfig) Descriptor() ([]byte, []int)

Deprecated: Use PostgresqlSourceConfig.ProtoReflect.Descriptor instead.

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

func (*PostgresqlSourceConfig) ProtoMessage()

func (*PostgresqlSourceConfig) ProtoReflect 

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

func (*PostgresqlSourceConfig) Reset 

func (x *PostgresqlSourceConfig) Reset()

func (*PostgresqlSourceConfig) String 

func (x *PostgresqlSourceConfig) String() string

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) Descriptor deprecated 

func (*PostgresqlTable) Descriptor() ([]byte, []int)

Deprecated: Use PostgresqlTable.ProtoReflect.Descriptor instead.

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

func (x *PostgresqlTable) String() string

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 `` /* 153-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) Descriptor deprecated 

func (*PrivateConnection) Descriptor() ([]byte, []int)

Deprecated: Use PrivateConnection.ProtoReflect.Descriptor instead.

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

func (*PrivateConnection) ProtoMessage()

func (*PrivateConnection) ProtoReflect 

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

func (*PrivateConnection) Reset 

func (x *PrivateConnection) Reset()

func (*PrivateConnection) String 

func (x *PrivateConnection) String() string

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) Descriptor deprecated 

func (*PrivateConnectionEventData) Descriptor() ([]byte, []int)

Deprecated: Use PrivateConnectionEventData.ProtoReflect.Descriptor instead.

func (*PrivateConnectionEventData) GetPayload 

func (x *PrivateConnectionEventData) GetPayload() *PrivateConnection

func (*PrivateConnectionEventData) ProtoMessage 

func (*PrivateConnectionEventData) ProtoMessage()

func (*PrivateConnectionEventData) ProtoReflect 

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

func (*PrivateConnectionEventData) Reset 

func (x *PrivateConnectionEventData) Reset()

func (*PrivateConnectionEventData) String 

func (x *PrivateConnectionEventData) String() string

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) EnumDescriptor deprecated 

func (PrivateConnection_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use PrivateConnection_State.Descriptor instead.

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 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) Descriptor deprecated 

func (*PrivateConnectivity) Descriptor() ([]byte, []int)

Deprecated: Use PrivateConnectivity.ProtoReflect.Descriptor instead.

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

func (x *PrivateConnectivity) String() string

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 `` /* 153-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) Descriptor deprecated 

func (*Route) Descriptor() ([]byte, []int)

Deprecated: Use Route.ProtoReflect.Descriptor instead.

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

func (*Route) ProtoMessage()

func (*Route) ProtoReflect 

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

func (*Route) Reset 

func (x *Route) Reset()

func (*Route) String 

func (x *Route) String() string

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) Descriptor deprecated 

func (*RouteEventData) Descriptor() ([]byte, []int)

Deprecated: Use RouteEventData.ProtoReflect.Descriptor instead.

func (*RouteEventData) GetPayload 

func (x *RouteEventData) GetPayload() *Route

func (*RouteEventData) ProtoMessage 

func (*RouteEventData) ProtoMessage()

func (*RouteEventData) ProtoReflect 

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

func (*RouteEventData) Reset 

func (x *RouteEventData) Reset()

func (*RouteEventData) String 

func (x *RouteEventData) String() string

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 assignable 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) Descriptor deprecated 

func (*SourceConfig) Descriptor() ([]byte, []int)

Deprecated: Use SourceConfig.ProtoReflect.Descriptor instead.

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 (m *SourceConfig) GetSourceStreamConfig() isSourceConfig_SourceStreamConfig

func (*SourceConfig) ProtoMessage 

func (*SourceConfig) ProtoMessage()

func (*SourceConfig) ProtoReflect 

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

func (*SourceConfig) Reset 

func (x *SourceConfig) Reset()

func (*SourceConfig) String 

func (x *SourceConfig) String() string

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 StaticServiceIpConnectivity 

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

Static IP address connectivity.

func (*StaticServiceIpConnectivity) Descriptor deprecated 

func (*StaticServiceIpConnectivity) Descriptor() ([]byte, []int)

Deprecated: Use StaticServiceIpConnectivity.ProtoReflect.Descriptor instead.

func (*StaticServiceIpConnectivity) ProtoMessage 

func (*StaticServiceIpConnectivity) ProtoMessage()

func (*StaticServiceIpConnectivity) ProtoReflect 

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

func (*StaticServiceIpConnectivity) Reset 

func (x *StaticServiceIpConnectivity) Reset()

func (*StaticServiceIpConnectivity) String 

func (x *StaticServiceIpConnectivity) String() string

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 `` /* 153-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 assignable 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) Descriptor deprecated 

func (*Stream) Descriptor() ([]byte, []int)

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetBackfillAll 

func (x *Stream) GetBackfillAll() *Stream_BackfillAllStrategy

func (*Stream) GetBackfillNone 

func (x *Stream) GetBackfillNone() *Stream_BackfillNoneStrategy

func (*Stream) GetBackfillStrategy 

func (m *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) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect 

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

func (*Stream) Reset 

func (x *Stream) Reset()

func (*Stream) String 

func (x *Stream) String() string

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) Descriptor deprecated 

func (*StreamEventData) Descriptor() ([]byte, []int)

Deprecated: Use StreamEventData.ProtoReflect.Descriptor instead.

func (*StreamEventData) GetPayload 

func (x *StreamEventData) GetPayload() *Stream

func (*StreamEventData) ProtoMessage 

func (*StreamEventData) ProtoMessage()

func (*StreamEventData) ProtoReflect 

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

func (*StreamEventData) Reset 

func (x *StreamEventData) Reset()

func (*StreamEventData) String 

func (x *StreamEventData) String() string

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 assignable to ExcludedObjects:
	//
	//	*Stream_BackfillAllStrategy_OracleExcludedObjects
	//	*Stream_BackfillAllStrategy_MysqlExcludedObjects
	//	*Stream_BackfillAllStrategy_PostgresqlExcludedObjects
	ExcludedObjects isStream_BackfillAllStrategy_ExcludedObjects `protobuf_oneof:"excluded_objects"`
	// contains filtered or unexported fields
}

Backfill strategy to automatically backfill the Stream's objects. Specific objects can be excluded.

func (*Stream_BackfillAllStrategy) Descriptor deprecated 

func (*Stream_BackfillAllStrategy) Descriptor() ([]byte, []int)

Deprecated: Use Stream_BackfillAllStrategy.ProtoReflect.Descriptor instead.

func (*Stream_BackfillAllStrategy) GetExcludedObjects 

func (m *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) 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) String 

func (x *Stream_BackfillAllStrategy) String() string

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_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) Descriptor deprecated 

func (*Stream_BackfillNoneStrategy) Descriptor() ([]byte, []int)

Deprecated: Use Stream_BackfillNoneStrategy.ProtoReflect.Descriptor instead.

func (*Stream_BackfillNoneStrategy) ProtoMessage 

func (*Stream_BackfillNoneStrategy) ProtoMessage()

func (*Stream_BackfillNoneStrategy) ProtoReflect 

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

func (*Stream_BackfillNoneStrategy) Reset 

func (x *Stream_BackfillNoneStrategy) Reset()

func (*Stream_BackfillNoneStrategy) String 

func (x *Stream_BackfillNoneStrategy) String() string

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) EnumDescriptor deprecated 

func (Stream_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use Stream_State.Descriptor instead.

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 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) Descriptor deprecated 

func (*VpcPeeringConfig) Descriptor() ([]byte, []int)

Deprecated: Use VpcPeeringConfig.ProtoReflect.Descriptor instead.

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

func (x *VpcPeeringConfig) String() string

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.