v1alpha1

package
v1.125.0 Latest Latest
Warning

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

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

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the datastream v1alpha1 API group. +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=github.com/GoogleCloudPlatform/k8s-config-connector/pkg/clients/generated/pkg/apis/datastream +k8s:defaulter-gen=TypeMeta +groupName=datastream.cnrm.cloud.google.com

Index

Constants

This section is empty.

Variables

View Source 
var (
	// SchemeGroupVersion is the group version used to register these objects.
	SchemeGroupVersion = schema.GroupVersion{Group: "datastream.cnrm.cloud.google.com", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme.
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}

	// AddToScheme is a global function that registers this API group & version to a scheme
	AddToScheme = SchemeBuilder.AddToScheme

	DatastreamConnectionProfileGVK = schema.GroupVersionKind{
		Group:   SchemeGroupVersion.Group,
		Version: SchemeGroupVersion.Version,
		Kind:    reflect.TypeOf(DatastreamConnectionProfile{}).Name(),
	}

	DatastreamPrivateConnectionGVK = schema.GroupVersionKind{
		Group:   SchemeGroupVersion.Group,
		Version: SchemeGroupVersion.Version,
		Kind:    reflect.TypeOf(DatastreamPrivateConnection{}).Name(),
	}

	DatastreamStreamGVK = schema.GroupVersionKind{
		Group:   SchemeGroupVersion.Group,
		Version: SchemeGroupVersion.Version,
		Kind:    reflect.TypeOf(DatastreamStream{}).Name(),
	}
)

Functions

This section is empty.

Types

type ConnectionprofileBigqueryProfile 

type ConnectionprofileBigqueryProfile struct {
}

func (*ConnectionprofileBigqueryProfile) DeepCopy 

func (in *ConnectionprofileBigqueryProfile) DeepCopy() *ConnectionprofileBigqueryProfile

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionprofileBigqueryProfile.

func (*ConnectionprofileBigqueryProfile) DeepCopyInto 

func (in *ConnectionprofileBigqueryProfile) DeepCopyInto(out *ConnectionprofileBigqueryProfile)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConnectionprofileCaCertificate 

type ConnectionprofileCaCertificate struct {
	/* Value of the field. Cannot be used if 'valueFrom' is specified. */
	// +optional
	Value *string `json:"value,omitempty"`

	/* Source for the field's value. Cannot be used if 'value' is specified. */
	// +optional
	ValueFrom *ConnectionprofileValueFrom `json:"valueFrom,omitempty"`
}

func (*ConnectionprofileCaCertificate) DeepCopy 

func (in *ConnectionprofileCaCertificate) DeepCopy() *ConnectionprofileCaCertificate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionprofileCaCertificate.

func (*ConnectionprofileCaCertificate) DeepCopyInto 

func (in *ConnectionprofileCaCertificate) DeepCopyInto(out *ConnectionprofileCaCertificate)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConnectionprofileClientCertificate 

type ConnectionprofileClientCertificate struct {
	/* Value of the field. Cannot be used if 'valueFrom' is specified. */
	// +optional
	Value *string `json:"value,omitempty"`

	/* Source for the field's value. Cannot be used if 'value' is specified. */
	// +optional
	ValueFrom *ConnectionprofileValueFrom `json:"valueFrom,omitempty"`
}

func (*ConnectionprofileClientCertificate) DeepCopy 

func (in *ConnectionprofileClientCertificate) DeepCopy() *ConnectionprofileClientCertificate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionprofileClientCertificate.

func (*ConnectionprofileClientCertificate) DeepCopyInto 

func (in *ConnectionprofileClientCertificate) DeepCopyInto(out *ConnectionprofileClientCertificate)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConnectionprofileClientKey 

type ConnectionprofileClientKey struct {
	/* Value of the field. Cannot be used if 'valueFrom' is specified. */
	// +optional
	Value *string `json:"value,omitempty"`

	/* Source for the field's value. Cannot be used if 'value' is specified. */
	// +optional
	ValueFrom *ConnectionprofileValueFrom `json:"valueFrom,omitempty"`
}

func (*ConnectionprofileClientKey) DeepCopy 

func (in *ConnectionprofileClientKey) DeepCopy() *ConnectionprofileClientKey

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionprofileClientKey.

func (*ConnectionprofileClientKey) DeepCopyInto 

func (in *ConnectionprofileClientKey) DeepCopyInto(out *ConnectionprofileClientKey)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConnectionprofileForwardSshConnectivity 

type ConnectionprofileForwardSshConnectivity struct {
	/* Hostname for the SSH tunnel. */
	Hostname string `json:"hostname"`

	/* Immutable. SSH password. */
	// +optional
	Password *ConnectionprofilePassword `json:"password,omitempty"`

	/* Port for the SSH tunnel. */
	// +optional
	Port *int64 `json:"port,omitempty"`

	/* Immutable. SSH private key. */
	// +optional
	PrivateKey *ConnectionprofilePrivateKey `json:"privateKey,omitempty"`

	/* Username for the SSH tunnel. */
	Username string `json:"username"`
}

func (*ConnectionprofileForwardSshConnectivity) DeepCopy 

func (in *ConnectionprofileForwardSshConnectivity) DeepCopy() *ConnectionprofileForwardSshConnectivity

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionprofileForwardSshConnectivity.

func (*ConnectionprofileForwardSshConnectivity) DeepCopyInto 

func (in *ConnectionprofileForwardSshConnectivity) DeepCopyInto(out *ConnectionprofileForwardSshConnectivity)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConnectionprofileGcsProfile 

type ConnectionprofileGcsProfile struct {
	/* The Cloud Storage bucket name. */
	Bucket string `json:"bucket"`

	/* The root path inside the Cloud Storage bucket. */
	// +optional
	RootPath *string `json:"rootPath,omitempty"`
}

func (*ConnectionprofileGcsProfile) DeepCopy 

func (in *ConnectionprofileGcsProfile) DeepCopy() *ConnectionprofileGcsProfile

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionprofileGcsProfile.

func (*ConnectionprofileGcsProfile) DeepCopyInto 

func (in *ConnectionprofileGcsProfile) DeepCopyInto(out *ConnectionprofileGcsProfile)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConnectionprofileMysqlProfile 

type ConnectionprofileMysqlProfile struct {
	/* Hostname for the MySQL connection. */
	Hostname string `json:"hostname"`

	/* Password for the MySQL connection. */
	Password ConnectionprofilePassword `json:"password"`

	/* Port for the MySQL connection. */
	// +optional
	Port *int64 `json:"port,omitempty"`

	/* SSL configuration for the MySQL connection. */
	// +optional
	SslConfig *ConnectionprofileSslConfig `json:"sslConfig,omitempty"`

	/* Username for the MySQL connection. */
	Username string `json:"username"`
}

func (*ConnectionprofileMysqlProfile) DeepCopy 

func (in *ConnectionprofileMysqlProfile) DeepCopy() *ConnectionprofileMysqlProfile

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionprofileMysqlProfile.

func (*ConnectionprofileMysqlProfile) DeepCopyInto 

func (in *ConnectionprofileMysqlProfile) DeepCopyInto(out *ConnectionprofileMysqlProfile)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConnectionprofileOracleProfile 

type ConnectionprofileOracleProfile struct {
	/* Connection string attributes. */
	// +optional
	ConnectionAttributes map[string]string `json:"connectionAttributes,omitempty"`

	/* Database for the Oracle connection. */
	DatabaseService string `json:"databaseService"`

	/* Hostname for the Oracle connection. */
	Hostname string `json:"hostname"`

	/* Password for the Oracle connection. */
	Password ConnectionprofilePassword `json:"password"`

	/* Port for the Oracle connection. */
	// +optional
	Port *int64 `json:"port,omitempty"`

	/* Username for the Oracle connection. */
	Username string `json:"username"`
}

func (*ConnectionprofileOracleProfile) DeepCopy 

func (in *ConnectionprofileOracleProfile) DeepCopy() *ConnectionprofileOracleProfile

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionprofileOracleProfile.

func (*ConnectionprofileOracleProfile) DeepCopyInto 

func (in *ConnectionprofileOracleProfile) DeepCopyInto(out *ConnectionprofileOracleProfile)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConnectionprofilePassword 

type ConnectionprofilePassword struct {
	/* Value of the field. Cannot be used if 'valueFrom' is specified. */
	// +optional
	Value *string `json:"value,omitempty"`

	/* Source for the field's value. Cannot be used if 'value' is specified. */
	// +optional
	ValueFrom *ConnectionprofileValueFrom `json:"valueFrom,omitempty"`
}

func (*ConnectionprofilePassword) DeepCopy 

func (in *ConnectionprofilePassword) DeepCopy() *ConnectionprofilePassword

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionprofilePassword.

func (*ConnectionprofilePassword) DeepCopyInto 

func (in *ConnectionprofilePassword) DeepCopyInto(out *ConnectionprofilePassword)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConnectionprofilePostgresqlProfile 

type ConnectionprofilePostgresqlProfile struct {
	/* Database for the PostgreSQL connection. */
	Database string `json:"database"`

	/* Hostname for the PostgreSQL connection. */
	Hostname string `json:"hostname"`

	/* Password for the PostgreSQL connection. */
	Password ConnectionprofilePassword `json:"password"`

	/* Port for the PostgreSQL connection. */
	// +optional
	Port *int64 `json:"port,omitempty"`

	/* Username for the PostgreSQL connection. */
	Username string `json:"username"`
}

func (*ConnectionprofilePostgresqlProfile) DeepCopy 

func (in *ConnectionprofilePostgresqlProfile) DeepCopy() *ConnectionprofilePostgresqlProfile

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionprofilePostgresqlProfile.

func (*ConnectionprofilePostgresqlProfile) DeepCopyInto 

func (in *ConnectionprofilePostgresqlProfile) DeepCopyInto(out *ConnectionprofilePostgresqlProfile)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConnectionprofilePrivateConnectivity 

type ConnectionprofilePrivateConnectivity struct {
	/* A reference to a private connection resource. Format: 'projects/{project}/locations/{location}/privateConnections/{name}'. */
	PrivateConnection string `json:"privateConnection"`
}

func (*ConnectionprofilePrivateConnectivity) DeepCopy 

func (in *ConnectionprofilePrivateConnectivity) DeepCopy() *ConnectionprofilePrivateConnectivity

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionprofilePrivateConnectivity.

func (*ConnectionprofilePrivateConnectivity) DeepCopyInto 

func (in *ConnectionprofilePrivateConnectivity) DeepCopyInto(out *ConnectionprofilePrivateConnectivity)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConnectionprofilePrivateKey 

type ConnectionprofilePrivateKey struct {
	/* Value of the field. Cannot be used if 'valueFrom' is specified. */
	// +optional
	Value *string `json:"value,omitempty"`

	/* Source for the field's value. Cannot be used if 'value' is specified. */
	// +optional
	ValueFrom *ConnectionprofileValueFrom `json:"valueFrom,omitempty"`
}

func (*ConnectionprofilePrivateKey) DeepCopy 

func (in *ConnectionprofilePrivateKey) DeepCopy() *ConnectionprofilePrivateKey

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionprofilePrivateKey.

func (*ConnectionprofilePrivateKey) DeepCopyInto 

func (in *ConnectionprofilePrivateKey) DeepCopyInto(out *ConnectionprofilePrivateKey)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConnectionprofileSslConfig 

type ConnectionprofileSslConfig struct {
	/* Immutable. PEM-encoded certificate of the CA that signed the source database
	server's certificate. */
	// +optional
	CaCertificate *ConnectionprofileCaCertificate `json:"caCertificate,omitempty"`

	/* Indicates whether the clientKey field is set. */
	// +optional
	CaCertificateSet *bool `json:"caCertificateSet,omitempty"`

	/* Immutable. PEM-encoded certificate that will be used by the replica to
	authenticate against the source database server. If this field
	is used then the 'clientKey' and the 'caCertificate' fields are
	mandatory. */
	// +optional
	ClientCertificate *ConnectionprofileClientCertificate `json:"clientCertificate,omitempty"`

	/* Indicates whether the clientCertificate field is set. */
	// +optional
	ClientCertificateSet *bool `json:"clientCertificateSet,omitempty"`

	/* Immutable. PEM-encoded private key associated with the Client Certificate.
	If this field is used then the 'client_certificate' and the
	'ca_certificate' fields are mandatory. */
	// +optional
	ClientKey *ConnectionprofileClientKey `json:"clientKey,omitempty"`

	/* Indicates whether the clientKey field is set. */
	// +optional
	ClientKeySet *bool `json:"clientKeySet,omitempty"`
}

func (*ConnectionprofileSslConfig) DeepCopy 

func (in *ConnectionprofileSslConfig) DeepCopy() *ConnectionprofileSslConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionprofileSslConfig.

func (*ConnectionprofileSslConfig) DeepCopyInto 

func (in *ConnectionprofileSslConfig) DeepCopyInto(out *ConnectionprofileSslConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConnectionprofileValueFrom 

type ConnectionprofileValueFrom struct {
	/* Reference to a value with the given key in the given Secret in the resource's namespace. */
	// +optional
	SecretKeyRef *v1alpha1.SecretKeyRef `json:"secretKeyRef,omitempty"`
}

func (*ConnectionprofileValueFrom) DeepCopy 

func (in *ConnectionprofileValueFrom) DeepCopy() *ConnectionprofileValueFrom

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionprofileValueFrom.

func (*ConnectionprofileValueFrom) DeepCopyInto 

func (in *ConnectionprofileValueFrom) DeepCopyInto(out *ConnectionprofileValueFrom)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DatastreamConnectionProfile 

type DatastreamConnectionProfile struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   DatastreamConnectionProfileSpec   `json:"spec,omitempty"`
	Status DatastreamConnectionProfileStatus `json:"status,omitempty"`
}

DatastreamConnectionProfile is the Schema for the datastream API +k8s:openapi-gen=true

func (*DatastreamConnectionProfile) DeepCopy 

func (in *DatastreamConnectionProfile) DeepCopy() *DatastreamConnectionProfile

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatastreamConnectionProfile.

func (*DatastreamConnectionProfile) DeepCopyInto 

func (in *DatastreamConnectionProfile) DeepCopyInto(out *DatastreamConnectionProfile)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DatastreamConnectionProfile) DeepCopyObject 

func (in *DatastreamConnectionProfile) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DatastreamConnectionProfileList 

type DatastreamConnectionProfileList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []DatastreamConnectionProfile `json:"items"`
}

DatastreamConnectionProfileList contains a list of DatastreamConnectionProfile

func (*DatastreamConnectionProfileList) DeepCopy 

func (in *DatastreamConnectionProfileList) DeepCopy() *DatastreamConnectionProfileList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatastreamConnectionProfileList.

func (*DatastreamConnectionProfileList) DeepCopyInto 

func (in *DatastreamConnectionProfileList) DeepCopyInto(out *DatastreamConnectionProfileList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DatastreamConnectionProfileList) DeepCopyObject 

func (in *DatastreamConnectionProfileList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DatastreamConnectionProfileSpec 

type DatastreamConnectionProfileSpec struct {
	/* BigQuery warehouse profile. */
	// +optional
	BigqueryProfile *ConnectionprofileBigqueryProfile `json:"bigqueryProfile,omitempty"`

	/* Display name. */
	DisplayName string `json:"displayName"`

	/* Forward SSH tunnel connectivity. */
	// +optional
	ForwardSshConnectivity *ConnectionprofileForwardSshConnectivity `json:"forwardSshConnectivity,omitempty"`

	/* Cloud Storage bucket profile. */
	// +optional
	GcsProfile *ConnectionprofileGcsProfile `json:"gcsProfile,omitempty"`

	/* Immutable. The name of the location this connection profile is located in. */
	Location string `json:"location"`

	/* MySQL database profile. */
	// +optional
	MysqlProfile *ConnectionprofileMysqlProfile `json:"mysqlProfile,omitempty"`

	/* Oracle database profile. */
	// +optional
	OracleProfile *ConnectionprofileOracleProfile `json:"oracleProfile,omitempty"`

	/* PostgreSQL database profile. */
	// +optional
	PostgresqlProfile *ConnectionprofilePostgresqlProfile `json:"postgresqlProfile,omitempty"`

	/* Private connectivity. */
	// +optional
	PrivateConnectivity *ConnectionprofilePrivateConnectivity `json:"privateConnectivity,omitempty"`

	/* The project that this resource belongs to. */
	ProjectRef v1alpha1.ResourceRef `json:"projectRef"`

	/* Immutable. Optional. The connectionProfileId of the resource. Used for creation and acquisition. When unset, the value of `metadata.name` is used as the default. */
	// +optional
	ResourceID *string `json:"resourceID,omitempty"`
}

func (*DatastreamConnectionProfileSpec) DeepCopy 

func (in *DatastreamConnectionProfileSpec) DeepCopy() *DatastreamConnectionProfileSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatastreamConnectionProfileSpec.

func (*DatastreamConnectionProfileSpec) DeepCopyInto 

func (in *DatastreamConnectionProfileSpec) DeepCopyInto(out *DatastreamConnectionProfileSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DatastreamConnectionProfileStatus 

type DatastreamConnectionProfileStatus struct {
	/* Conditions represent the latest available observations of the
	   DatastreamConnectionProfile's current state. */
	Conditions []v1alpha1.Condition `json:"conditions,omitempty"`
	/* The resource's name. */
	// +optional
	Name *string `json:"name,omitempty"`

	/* ObservedGeneration is the generation of the resource that was most recently observed by the Config Connector controller. If this is equal to metadata.generation, then that means that the current reported status reflects the most recent desired state of the resource. */
	// +optional
	ObservedGeneration *int64 `json:"observedGeneration,omitempty"`
}

func (*DatastreamConnectionProfileStatus) DeepCopy 

func (in *DatastreamConnectionProfileStatus) DeepCopy() *DatastreamConnectionProfileStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatastreamConnectionProfileStatus.

func (*DatastreamConnectionProfileStatus) DeepCopyInto 

func (in *DatastreamConnectionProfileStatus) DeepCopyInto(out *DatastreamConnectionProfileStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DatastreamPrivateConnection 

type DatastreamPrivateConnection struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   DatastreamPrivateConnectionSpec   `json:"spec,omitempty"`
	Status DatastreamPrivateConnectionStatus `json:"status,omitempty"`
}

DatastreamPrivateConnection is the Schema for the datastream API +k8s:openapi-gen=true

func (*DatastreamPrivateConnection) DeepCopy 

func (in *DatastreamPrivateConnection) DeepCopy() *DatastreamPrivateConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatastreamPrivateConnection.

func (*DatastreamPrivateConnection) DeepCopyInto 

func (in *DatastreamPrivateConnection) DeepCopyInto(out *DatastreamPrivateConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DatastreamPrivateConnection) DeepCopyObject 

func (in *DatastreamPrivateConnection) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DatastreamPrivateConnectionList 

type DatastreamPrivateConnectionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []DatastreamPrivateConnection `json:"items"`
}

DatastreamPrivateConnectionList contains a list of DatastreamPrivateConnection

func (*DatastreamPrivateConnectionList) DeepCopy 

func (in *DatastreamPrivateConnectionList) DeepCopy() *DatastreamPrivateConnectionList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatastreamPrivateConnectionList.

func (*DatastreamPrivateConnectionList) DeepCopyInto 

func (in *DatastreamPrivateConnectionList) DeepCopyInto(out *DatastreamPrivateConnectionList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DatastreamPrivateConnectionList) DeepCopyObject 

func (in *DatastreamPrivateConnectionList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DatastreamPrivateConnectionSpec 

type DatastreamPrivateConnectionSpec struct {
	/* Immutable. Display name. */
	DisplayName string `json:"displayName"`

	/* Immutable. The name of the location this private connection is located in. */
	Location string `json:"location"`

	/* The project that this resource belongs to. */
	ProjectRef v1alpha1.ResourceRef `json:"projectRef"`

	/* Immutable. Optional. The privateConnectionId of the resource. Used for creation and acquisition. When unset, the value of `metadata.name` is used as the default. */
	// +optional
	ResourceID *string `json:"resourceID,omitempty"`

	/* Immutable. The VPC Peering configuration is used to create VPC peering
	between Datastream and the consumer's VPC. */
	VpcPeeringConfig PrivateconnectionVpcPeeringConfig `json:"vpcPeeringConfig"`
}

func (*DatastreamPrivateConnectionSpec) DeepCopy 

func (in *DatastreamPrivateConnectionSpec) DeepCopy() *DatastreamPrivateConnectionSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatastreamPrivateConnectionSpec.

func (*DatastreamPrivateConnectionSpec) DeepCopyInto 

func (in *DatastreamPrivateConnectionSpec) DeepCopyInto(out *DatastreamPrivateConnectionSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DatastreamPrivateConnectionStatus 

type DatastreamPrivateConnectionStatus struct {
	/* Conditions represent the latest available observations of the
	   DatastreamPrivateConnection's current state. */
	Conditions []v1alpha1.Condition `json:"conditions,omitempty"`
	/* The PrivateConnection error in case of failure. */
	// +optional
	Error []PrivateconnectionErrorStatus `json:"error,omitempty"`

	/* The resource's name. */
	// +optional
	Name *string `json:"name,omitempty"`

	/* ObservedGeneration is the generation of the resource that was most recently observed by the Config Connector controller. If this is equal to metadata.generation, then that means that the current reported status reflects the most recent desired state of the resource. */
	// +optional
	ObservedGeneration *int64 `json:"observedGeneration,omitempty"`

	/* State of the PrivateConnection. */
	// +optional
	State *string `json:"state,omitempty"`
}

func (*DatastreamPrivateConnectionStatus) DeepCopy 

func (in *DatastreamPrivateConnectionStatus) DeepCopy() *DatastreamPrivateConnectionStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatastreamPrivateConnectionStatus.

func (*DatastreamPrivateConnectionStatus) DeepCopyInto 

func (in *DatastreamPrivateConnectionStatus) DeepCopyInto(out *DatastreamPrivateConnectionStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DatastreamStream 

type DatastreamStream struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   DatastreamStreamSpec   `json:"spec,omitempty"`
	Status DatastreamStreamStatus `json:"status,omitempty"`
}

DatastreamStream is the Schema for the datastream API +k8s:openapi-gen=true

func (*DatastreamStream) DeepCopy 

func (in *DatastreamStream) DeepCopy() *DatastreamStream

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatastreamStream.

func (*DatastreamStream) DeepCopyInto 

func (in *DatastreamStream) DeepCopyInto(out *DatastreamStream)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DatastreamStream) DeepCopyObject 

func (in *DatastreamStream) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DatastreamStreamList 

type DatastreamStreamList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []DatastreamStream `json:"items"`
}

DatastreamStreamList contains a list of DatastreamStream

func (*DatastreamStreamList) DeepCopy 

func (in *DatastreamStreamList) DeepCopy() *DatastreamStreamList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatastreamStreamList.

func (*DatastreamStreamList) DeepCopyInto 

func (in *DatastreamStreamList) DeepCopyInto(out *DatastreamStreamList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DatastreamStreamList) DeepCopyObject 

func (in *DatastreamStreamList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DatastreamStreamSpec 

type DatastreamStreamSpec struct {
	/* Backfill strategy to automatically backfill the Stream's objects. Specific objects can be excluded. */
	// +optional
	BackfillAll *StreamBackfillAll `json:"backfillAll,omitempty"`

	/* Backfill strategy to disable automatic backfill for the Stream's objects. */
	// +optional
	BackfillNone *StreamBackfillNone `json:"backfillNone,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. */
	// +optional
	CustomerManagedEncryptionKey *string `json:"customerManagedEncryptionKey,omitempty"`

	/* Desired state of the Stream. Set this field to 'RUNNING' to start the stream, and 'PAUSED' to pause the stream. */
	// +optional
	DesiredState *string `json:"desiredState,omitempty"`

	/* Destination connection profile configuration. */
	DestinationConfig StreamDestinationConfig `json:"destinationConfig"`

	/* Display name. */
	DisplayName string `json:"displayName"`

	/* Immutable. The name of the location this stream is located in. */
	Location string `json:"location"`

	/* The project that this resource belongs to. */
	ProjectRef v1alpha1.ResourceRef `json:"projectRef"`

	/* Immutable. Optional. The streamId of the resource. Used for creation and acquisition. When unset, the value of `metadata.name` is used as the default. */
	// +optional
	ResourceID *string `json:"resourceID,omitempty"`

	/* Source connection profile configuration. */
	SourceConfig StreamSourceConfig `json:"sourceConfig"`
}

func (*DatastreamStreamSpec) DeepCopy 

func (in *DatastreamStreamSpec) DeepCopy() *DatastreamStreamSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatastreamStreamSpec.

func (*DatastreamStreamSpec) DeepCopyInto 

func (in *DatastreamStreamSpec) DeepCopyInto(out *DatastreamStreamSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DatastreamStreamStatus 

type DatastreamStreamStatus struct {
	/* Conditions represent the latest available observations of the
	   DatastreamStream's current state. */
	Conditions []v1alpha1.Condition `json:"conditions,omitempty"`
	/* The stream's name. */
	// +optional
	Name *string `json:"name,omitempty"`

	/* ObservedGeneration is the generation of the resource that was most recently observed by the Config Connector controller. If this is equal to metadata.generation, then that means that the current reported status reflects the most recent desired state of the resource. */
	// +optional
	ObservedGeneration *int64 `json:"observedGeneration,omitempty"`

	/* The state of the stream. */
	// +optional
	State *string `json:"state,omitempty"`
}

func (*DatastreamStreamStatus) DeepCopy 

func (in *DatastreamStreamStatus) DeepCopy() *DatastreamStreamStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatastreamStreamStatus.

func (*DatastreamStreamStatus) DeepCopyInto 

func (in *DatastreamStreamStatus) DeepCopyInto(out *DatastreamStreamStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PrivateconnectionErrorStatus 

type PrivateconnectionErrorStatus struct {
	/* A list of messages that carry the error details. */
	// +optional
	Details map[string]string `json:"details,omitempty"`

	/* A message containing more information about the error that occurred. */
	// +optional
	Message *string `json:"message,omitempty"`
}

func (*PrivateconnectionErrorStatus) DeepCopy 

func (in *PrivateconnectionErrorStatus) DeepCopy() *PrivateconnectionErrorStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrivateconnectionErrorStatus.

func (*PrivateconnectionErrorStatus) DeepCopyInto 

func (in *PrivateconnectionErrorStatus) DeepCopyInto(out *PrivateconnectionErrorStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PrivateconnectionVpcPeeringConfig 

type PrivateconnectionVpcPeeringConfig struct {
	/* Immutable. A free subnet for peering. (CIDR of /29). */
	Subnet string `json:"subnet"`

	/* Immutable. Fully qualified name of the VPC that Datastream will peer to.
	Format: projects/{project}/global/{networks}/{name}. */
	Vpc string `json:"vpc"`
}

func (*PrivateconnectionVpcPeeringConfig) DeepCopy 

func (in *PrivateconnectionVpcPeeringConfig) DeepCopy() *PrivateconnectionVpcPeeringConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrivateconnectionVpcPeeringConfig.

func (*PrivateconnectionVpcPeeringConfig) DeepCopyInto 

func (in *PrivateconnectionVpcPeeringConfig) DeepCopyInto(out *PrivateconnectionVpcPeeringConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamAvroFileFormat 

type StreamAvroFileFormat struct {
}

func (*StreamAvroFileFormat) DeepCopy 

func (in *StreamAvroFileFormat) DeepCopy() *StreamAvroFileFormat

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamAvroFileFormat.

func (*StreamAvroFileFormat) DeepCopyInto 

func (in *StreamAvroFileFormat) DeepCopyInto(out *StreamAvroFileFormat)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamBackfillAll 

type StreamBackfillAll struct {
	/* MySQL data source objects to avoid backfilling. */
	// +optional
	MysqlExcludedObjects *StreamMysqlExcludedObjects `json:"mysqlExcludedObjects,omitempty"`

	/* PostgreSQL data source objects to avoid backfilling. */
	// +optional
	OracleExcludedObjects *StreamOracleExcludedObjects `json:"oracleExcludedObjects,omitempty"`

	/* PostgreSQL data source objects to avoid backfilling. */
	// +optional
	PostgresqlExcludedObjects *StreamPostgresqlExcludedObjects `json:"postgresqlExcludedObjects,omitempty"`
}

func (*StreamBackfillAll) DeepCopy 

func (in *StreamBackfillAll) DeepCopy() *StreamBackfillAll

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamBackfillAll.

func (*StreamBackfillAll) DeepCopyInto 

func (in *StreamBackfillAll) DeepCopyInto(out *StreamBackfillAll)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamBackfillNone 

type StreamBackfillNone struct {
}

func (*StreamBackfillNone) DeepCopy 

func (in *StreamBackfillNone) DeepCopy() *StreamBackfillNone

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamBackfillNone.

func (*StreamBackfillNone) DeepCopyInto 

func (in *StreamBackfillNone) DeepCopyInto(out *StreamBackfillNone)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamBigqueryDestinationConfig 

type StreamBigqueryDestinationConfig struct {
	/* 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.
	A duration in seconds with up to nine fractional digits, terminated by 's'. Example: "3.5s". Defaults to 900s. */
	// +optional
	DataFreshness *string `json:"dataFreshness,omitempty"`

	/* A single target dataset to which all data will be streamed. */
	// +optional
	SingleTargetDataset *StreamSingleTargetDataset `json:"singleTargetDataset,omitempty"`

	/* Destination datasets are created so that hierarchy of the destination data objects matches the source hierarchy. */
	// +optional
	SourceHierarchyDatasets *StreamSourceHierarchyDatasets `json:"sourceHierarchyDatasets,omitempty"`
}

func (*StreamBigqueryDestinationConfig) DeepCopy 

func (in *StreamBigqueryDestinationConfig) DeepCopy() *StreamBigqueryDestinationConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamBigqueryDestinationConfig.

func (*StreamBigqueryDestinationConfig) DeepCopyInto 

func (in *StreamBigqueryDestinationConfig) DeepCopyInto(out *StreamBigqueryDestinationConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamDatasetTemplate 

type StreamDatasetTemplate struct {
	/* 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. _. */
	// +optional
	DatasetIdPrefix *string `json:"datasetIdPrefix,omitempty"`

	/* Immutable. 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. */
	// +optional
	KmsKeyName *string `json:"kmsKeyName,omitempty"`

	/* The geographic location where the dataset should reside.
	See https://cloud.google.com/bigquery/docs/locations for supported locations. */
	Location string `json:"location"`
}

func (*StreamDatasetTemplate) DeepCopy 

func (in *StreamDatasetTemplate) DeepCopy() *StreamDatasetTemplate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamDatasetTemplate.

func (*StreamDatasetTemplate) DeepCopyInto 

func (in *StreamDatasetTemplate) DeepCopyInto(out *StreamDatasetTemplate)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamDestinationConfig 

type StreamDestinationConfig struct {
	/* A configuration for how data should be loaded to Cloud Storage. */
	// +optional
	BigqueryDestinationConfig *StreamBigqueryDestinationConfig `json:"bigqueryDestinationConfig,omitempty"`

	/* Immutable. Destination connection profile resource. Format: projects/{project}/locations/{location}/connectionProfiles/{name}. */
	DestinationConnectionProfile string `json:"destinationConnectionProfile"`

	/* A configuration for how data should be loaded to Cloud Storage. */
	// +optional
	GcsDestinationConfig *StreamGcsDestinationConfig `json:"gcsDestinationConfig,omitempty"`
}

func (*StreamDestinationConfig) DeepCopy 

func (in *StreamDestinationConfig) DeepCopy() *StreamDestinationConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamDestinationConfig.

func (*StreamDestinationConfig) DeepCopyInto 

func (in *StreamDestinationConfig) DeepCopyInto(out *StreamDestinationConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamDropLargeObjects 

type StreamDropLargeObjects struct {
}

func (*StreamDropLargeObjects) DeepCopy 

func (in *StreamDropLargeObjects) DeepCopy() *StreamDropLargeObjects

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamDropLargeObjects.

func (*StreamDropLargeObjects) DeepCopyInto 

func (in *StreamDropLargeObjects) DeepCopyInto(out *StreamDropLargeObjects)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamExcludeObjects 

type StreamExcludeObjects struct {
	/* PostgreSQL schemas on the server. */
	PostgresqlSchemas []StreamPostgresqlSchemas `json:"postgresqlSchemas"`
}

func (*StreamExcludeObjects) DeepCopy 

func (in *StreamExcludeObjects) DeepCopy() *StreamExcludeObjects

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamExcludeObjects.

func (*StreamExcludeObjects) DeepCopyInto 

func (in *StreamExcludeObjects) DeepCopyInto(out *StreamExcludeObjects)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamGcsDestinationConfig 

type StreamGcsDestinationConfig struct {
	/* AVRO file format configuration. */
	// +optional
	AvroFileFormat *StreamAvroFileFormat `json:"avroFileFormat,omitempty"`

	/* The maximum duration for which new events are added before a file is closed and a new file is created.
	A duration in seconds with up to nine fractional digits, terminated by 's'. Example: "3.5s". Defaults to 900s. */
	// +optional
	FileRotationInterval *string `json:"fileRotationInterval,omitempty"`

	/* The maximum file size to be saved in the bucket. */
	// +optional
	FileRotationMb *int64 `json:"fileRotationMb,omitempty"`

	/* JSON file format configuration. */
	// +optional
	JsonFileFormat *StreamJsonFileFormat `json:"jsonFileFormat,omitempty"`

	/* Path inside the Cloud Storage bucket to write data to. */
	// +optional
	Path *string `json:"path,omitempty"`
}

func (*StreamGcsDestinationConfig) DeepCopy 

func (in *StreamGcsDestinationConfig) DeepCopy() *StreamGcsDestinationConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamGcsDestinationConfig.

func (*StreamGcsDestinationConfig) DeepCopyInto 

func (in *StreamGcsDestinationConfig) DeepCopyInto(out *StreamGcsDestinationConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamIncludeObjects 

type StreamIncludeObjects struct {
	/* PostgreSQL schemas on the server. */
	PostgresqlSchemas []StreamPostgresqlSchemas `json:"postgresqlSchemas"`
}

func (*StreamIncludeObjects) DeepCopy 

func (in *StreamIncludeObjects) DeepCopy() *StreamIncludeObjects

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamIncludeObjects.

func (*StreamIncludeObjects) DeepCopyInto 

func (in *StreamIncludeObjects) DeepCopyInto(out *StreamIncludeObjects)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamJsonFileFormat 

type StreamJsonFileFormat struct {
	/* Compression of the loaded JSON file. Possible values: ["NO_COMPRESSION", "GZIP"]. */
	// +optional
	Compression *string `json:"compression,omitempty"`

	/* The schema file format along JSON data files. Possible values: ["NO_SCHEMA_FILE", "AVRO_SCHEMA_FILE"]. */
	// +optional
	SchemaFileFormat *string `json:"schemaFileFormat,omitempty"`
}

func (*StreamJsonFileFormat) DeepCopy 

func (in *StreamJsonFileFormat) DeepCopy() *StreamJsonFileFormat

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamJsonFileFormat.

func (*StreamJsonFileFormat) DeepCopyInto 

func (in *StreamJsonFileFormat) DeepCopyInto(out *StreamJsonFileFormat)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamMysqlColumns 

type StreamMysqlColumns struct {
	/* Column collation. */
	// +optional
	Collation *string `json:"collation,omitempty"`

	/* Column name. */
	// +optional
	Column *string `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. */
	// +optional
	DataType *string `json:"dataType,omitempty"`

	/* Column length. */
	// +optional
	Length *int64 `json:"length,omitempty"`

	/* Whether or not the column can accept a null value. */
	// +optional
	Nullable *bool `json:"nullable,omitempty"`

	/* The ordinal position of the column in the table. */
	// +optional
	OrdinalPosition *int64 `json:"ordinalPosition,omitempty"`

	/* Whether or not the column represents a primary key. */
	// +optional
	PrimaryKey *bool `json:"primaryKey,omitempty"`
}

func (*StreamMysqlColumns) DeepCopy 

func (in *StreamMysqlColumns) DeepCopy() *StreamMysqlColumns

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamMysqlColumns.

func (*StreamMysqlColumns) DeepCopyInto 

func (in *StreamMysqlColumns) DeepCopyInto(out *StreamMysqlColumns)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamMysqlDatabases 

type StreamMysqlDatabases struct {
	/* Database name. */
	Database string `json:"database"`

	/* Tables in the database. */
	// +optional
	MysqlTables []StreamMysqlTables `json:"mysqlTables,omitempty"`
}

func (*StreamMysqlDatabases) DeepCopy 

func (in *StreamMysqlDatabases) DeepCopy() *StreamMysqlDatabases

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamMysqlDatabases.

func (*StreamMysqlDatabases) DeepCopyInto 

func (in *StreamMysqlDatabases) DeepCopyInto(out *StreamMysqlDatabases)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamMysqlExcludedObjects 

type StreamMysqlExcludedObjects struct {
	/* MySQL databases on the server. */
	MysqlDatabases []StreamMysqlDatabases `json:"mysqlDatabases"`
}

func (*StreamMysqlExcludedObjects) DeepCopy 

func (in *StreamMysqlExcludedObjects) DeepCopy() *StreamMysqlExcludedObjects

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamMysqlExcludedObjects.

func (*StreamMysqlExcludedObjects) DeepCopyInto 

func (in *StreamMysqlExcludedObjects) DeepCopyInto(out *StreamMysqlExcludedObjects)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamMysqlSourceConfig 

type StreamMysqlSourceConfig struct {
	/* MySQL objects to exclude from the stream. */
	// +optional
	ExcludeObjects *StreamExcludeObjects `json:"excludeObjects,omitempty"`

	/* MySQL objects to retrieve from the source. */
	// +optional
	IncludeObjects *StreamIncludeObjects `json:"includeObjects,omitempty"`

	/* Maximum number of concurrent backfill tasks. The number should be non negative.
	If not set (or set to 0), the system's default value will be used. */
	// +optional
	MaxConcurrentBackfillTasks *int64 `json:"maxConcurrentBackfillTasks,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. */
	// +optional
	MaxConcurrentCdcTasks *int64 `json:"maxConcurrentCdcTasks,omitempty"`
}

func (*StreamMysqlSourceConfig) DeepCopy 

func (in *StreamMysqlSourceConfig) DeepCopy() *StreamMysqlSourceConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamMysqlSourceConfig.

func (*StreamMysqlSourceConfig) DeepCopyInto 

func (in *StreamMysqlSourceConfig) DeepCopyInto(out *StreamMysqlSourceConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamMysqlTables 

type StreamMysqlTables struct {
	/* MySQL columns in the schema. When unspecified as part of include/exclude objects, includes/excludes everything. */
	// +optional
	MysqlColumns []StreamMysqlColumns `json:"mysqlColumns,omitempty"`

	/* Table name. */
	Table string `json:"table"`
}

func (*StreamMysqlTables) DeepCopy 

func (in *StreamMysqlTables) DeepCopy() *StreamMysqlTables

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamMysqlTables.

func (*StreamMysqlTables) DeepCopyInto 

func (in *StreamMysqlTables) DeepCopyInto(out *StreamMysqlTables)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamOracleColumns 

type StreamOracleColumns struct {
	/* Column name. */
	// +optional
	Column *string `json:"column,omitempty"`

	/* The Oracle data type. Full data types list can be found here:
	https://docs.oracle.com/en/database/oracle/oracle-database/21/sqlrf/Data-Types.html. */
	// +optional
	DataType *string `json:"dataType,omitempty"`

	/* Column encoding. */
	// +optional
	Encoding *string `json:"encoding,omitempty"`

	/* Column length. */
	// +optional
	Length *int64 `json:"length,omitempty"`

	/* Whether or not the column can accept a null value. */
	// +optional
	Nullable *bool `json:"nullable,omitempty"`

	/* The ordinal position of the column in the table. */
	// +optional
	OrdinalPosition *int64 `json:"ordinalPosition,omitempty"`

	/* Column precision. */
	// +optional
	Precision *int64 `json:"precision,omitempty"`

	/* Whether or not the column represents a primary key. */
	// +optional
	PrimaryKey *bool `json:"primaryKey,omitempty"`

	/* Column scale. */
	// +optional
	Scale *int64 `json:"scale,omitempty"`
}

func (*StreamOracleColumns) DeepCopy 

func (in *StreamOracleColumns) DeepCopy() *StreamOracleColumns

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamOracleColumns.

func (*StreamOracleColumns) DeepCopyInto 

func (in *StreamOracleColumns) DeepCopyInto(out *StreamOracleColumns)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamOracleExcludedObjects 

type StreamOracleExcludedObjects struct {
	/* Oracle schemas/databases in the database server. */
	OracleSchemas []StreamOracleSchemas `json:"oracleSchemas"`
}

func (*StreamOracleExcludedObjects) DeepCopy 

func (in *StreamOracleExcludedObjects) DeepCopy() *StreamOracleExcludedObjects

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamOracleExcludedObjects.

func (*StreamOracleExcludedObjects) DeepCopyInto 

func (in *StreamOracleExcludedObjects) DeepCopyInto(out *StreamOracleExcludedObjects)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamOracleSchemas 

type StreamOracleSchemas struct {
	/* Tables in the database. */
	// +optional
	OracleTables []StreamOracleTables `json:"oracleTables,omitempty"`

	/* Schema name. */
	Schema string `json:"schema"`
}

func (*StreamOracleSchemas) DeepCopy 

func (in *StreamOracleSchemas) DeepCopy() *StreamOracleSchemas

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamOracleSchemas.

func (*StreamOracleSchemas) DeepCopyInto 

func (in *StreamOracleSchemas) DeepCopyInto(out *StreamOracleSchemas)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamOracleSourceConfig 

type StreamOracleSourceConfig struct {
	/* Configuration to drop large object values. */
	// +optional
	DropLargeObjects *StreamDropLargeObjects `json:"dropLargeObjects,omitempty"`

	/* Oracle objects to exclude from the stream. */
	// +optional
	ExcludeObjects *StreamExcludeObjects `json:"excludeObjects,omitempty"`

	/* Oracle objects to retrieve from the source. */
	// +optional
	IncludeObjects *StreamIncludeObjects `json:"includeObjects,omitempty"`

	/* Maximum number of concurrent backfill tasks. The number should be non negative.
	If not set (or set to 0), the system's default value will be used. */
	// +optional
	MaxConcurrentBackfillTasks *int64 `json:"maxConcurrentBackfillTasks,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. */
	// +optional
	MaxConcurrentCdcTasks *int64 `json:"maxConcurrentCdcTasks,omitempty"`

	/* Configuration to drop large object values. */
	// +optional
	StreamLargeObjects *StreamStreamLargeObjects `json:"streamLargeObjects,omitempty"`
}

func (*StreamOracleSourceConfig) DeepCopy 

func (in *StreamOracleSourceConfig) DeepCopy() *StreamOracleSourceConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamOracleSourceConfig.

func (*StreamOracleSourceConfig) DeepCopyInto 

func (in *StreamOracleSourceConfig) DeepCopyInto(out *StreamOracleSourceConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamOracleTables 

type StreamOracleTables struct {
	/* Oracle columns in the schema. When unspecified as part of include/exclude objects, includes/excludes everything. */
	// +optional
	OracleColumns []StreamOracleColumns `json:"oracleColumns,omitempty"`

	/* Table name. */
	Table string `json:"table"`
}

func (*StreamOracleTables) DeepCopy 

func (in *StreamOracleTables) DeepCopy() *StreamOracleTables

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamOracleTables.

func (*StreamOracleTables) DeepCopyInto 

func (in *StreamOracleTables) DeepCopyInto(out *StreamOracleTables)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamPostgresqlColumns 

type StreamPostgresqlColumns struct {
	/* Column name. */
	// +optional
	Column *string `json:"column,omitempty"`

	/* The PostgreSQL data type. Full data types list can be found here:
	https://www.postgresql.org/docs/current/datatype.html. */
	// +optional
	DataType *string `json:"dataType,omitempty"`

	/* Column length. */
	// +optional
	Length *int64 `json:"length,omitempty"`

	/* Whether or not the column can accept a null value. */
	// +optional
	Nullable *bool `json:"nullable,omitempty"`

	/* The ordinal position of the column in the table. */
	// +optional
	OrdinalPosition *int64 `json:"ordinalPosition,omitempty"`

	/* Column precision. */
	// +optional
	Precision *int64 `json:"precision,omitempty"`

	/* Whether or not the column represents a primary key. */
	// +optional
	PrimaryKey *bool `json:"primaryKey,omitempty"`

	/* Column scale. */
	// +optional
	Scale *int64 `json:"scale,omitempty"`
}

func (*StreamPostgresqlColumns) DeepCopy 

func (in *StreamPostgresqlColumns) DeepCopy() *StreamPostgresqlColumns

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamPostgresqlColumns.

func (*StreamPostgresqlColumns) DeepCopyInto 

func (in *StreamPostgresqlColumns) DeepCopyInto(out *StreamPostgresqlColumns)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamPostgresqlExcludedObjects 

type StreamPostgresqlExcludedObjects struct {
	/* PostgreSQL schemas on the server. */
	PostgresqlSchemas []StreamPostgresqlSchemas `json:"postgresqlSchemas"`
}

func (*StreamPostgresqlExcludedObjects) DeepCopy 

func (in *StreamPostgresqlExcludedObjects) DeepCopy() *StreamPostgresqlExcludedObjects

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamPostgresqlExcludedObjects.

func (*StreamPostgresqlExcludedObjects) DeepCopyInto 

func (in *StreamPostgresqlExcludedObjects) DeepCopyInto(out *StreamPostgresqlExcludedObjects)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamPostgresqlSchemas 

type StreamPostgresqlSchemas struct {
	/* Tables in the schema. */
	// +optional
	PostgresqlTables []StreamPostgresqlTables `json:"postgresqlTables,omitempty"`

	/* Database name. */
	Schema string `json:"schema"`
}

func (*StreamPostgresqlSchemas) DeepCopy 

func (in *StreamPostgresqlSchemas) DeepCopy() *StreamPostgresqlSchemas

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamPostgresqlSchemas.

func (*StreamPostgresqlSchemas) DeepCopyInto 

func (in *StreamPostgresqlSchemas) DeepCopyInto(out *StreamPostgresqlSchemas)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamPostgresqlSourceConfig 

type StreamPostgresqlSourceConfig struct {
	/* PostgreSQL objects to exclude from the stream. */
	// +optional
	ExcludeObjects *StreamExcludeObjects `json:"excludeObjects,omitempty"`

	/* PostgreSQL objects to retrieve from the source. */
	// +optional
	IncludeObjects *StreamIncludeObjects `json:"includeObjects,omitempty"`

	/* Maximum number of concurrent backfill tasks. The number should be non
	negative. If not set (or set to 0), the system's default value will be used. */
	// +optional
	MaxConcurrentBackfillTasks *int64 `json:"maxConcurrentBackfillTasks,omitempty"`

	/* The name of the publication that includes the set of all tables
	that are defined in the stream's include_objects. */
	Publication string `json:"publication"`

	/* The name of the logical replication slot that's configured with
	the pgoutput plugin. */
	ReplicationSlot string `json:"replicationSlot"`
}

func (*StreamPostgresqlSourceConfig) DeepCopy 

func (in *StreamPostgresqlSourceConfig) DeepCopy() *StreamPostgresqlSourceConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamPostgresqlSourceConfig.

func (*StreamPostgresqlSourceConfig) DeepCopyInto 

func (in *StreamPostgresqlSourceConfig) DeepCopyInto(out *StreamPostgresqlSourceConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamPostgresqlTables 

type StreamPostgresqlTables struct {
	/* PostgreSQL columns in the schema. When unspecified as part of include/exclude objects, includes/excludes everything. */
	// +optional
	PostgresqlColumns []StreamPostgresqlColumns `json:"postgresqlColumns,omitempty"`

	/* Table name. */
	Table string `json:"table"`
}

func (*StreamPostgresqlTables) DeepCopy 

func (in *StreamPostgresqlTables) DeepCopy() *StreamPostgresqlTables

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamPostgresqlTables.

func (*StreamPostgresqlTables) DeepCopyInto 

func (in *StreamPostgresqlTables) DeepCopyInto(out *StreamPostgresqlTables)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamSingleTargetDataset 

type StreamSingleTargetDataset struct {
	/* Dataset ID in the format projects/{project}/datasets/{dataset_id} or
	{project}:{dataset_id}. */
	DatasetId string `json:"datasetId"`
}

func (*StreamSingleTargetDataset) DeepCopy 

func (in *StreamSingleTargetDataset) DeepCopy() *StreamSingleTargetDataset

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamSingleTargetDataset.

func (*StreamSingleTargetDataset) DeepCopyInto 

func (in *StreamSingleTargetDataset) DeepCopyInto(out *StreamSingleTargetDataset)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamSourceConfig 

type StreamSourceConfig struct {
	/* MySQL data source configuration. */
	// +optional
	MysqlSourceConfig *StreamMysqlSourceConfig `json:"mysqlSourceConfig,omitempty"`

	/* MySQL data source configuration. */
	// +optional
	OracleSourceConfig *StreamOracleSourceConfig `json:"oracleSourceConfig,omitempty"`

	/* PostgreSQL data source configuration. */
	// +optional
	PostgresqlSourceConfig *StreamPostgresqlSourceConfig `json:"postgresqlSourceConfig,omitempty"`

	/* Immutable. Source connection profile resource. Format: projects/{project}/locations/{location}/connectionProfiles/{name}. */
	SourceConnectionProfile string `json:"sourceConnectionProfile"`
}

func (*StreamSourceConfig) DeepCopy 

func (in *StreamSourceConfig) DeepCopy() *StreamSourceConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamSourceConfig.

func (*StreamSourceConfig) DeepCopyInto 

func (in *StreamSourceConfig) DeepCopyInto(out *StreamSourceConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamSourceHierarchyDatasets 

type StreamSourceHierarchyDatasets struct {
	/* Dataset template used for dynamic dataset creation. */
	DatasetTemplate StreamDatasetTemplate `json:"datasetTemplate"`
}

func (*StreamSourceHierarchyDatasets) DeepCopy 

func (in *StreamSourceHierarchyDatasets) DeepCopy() *StreamSourceHierarchyDatasets

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamSourceHierarchyDatasets.

func (*StreamSourceHierarchyDatasets) DeepCopyInto 

func (in *StreamSourceHierarchyDatasets) DeepCopyInto(out *StreamSourceHierarchyDatasets)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamStreamLargeObjects 

type StreamStreamLargeObjects struct {
}

func (*StreamStreamLargeObjects) DeepCopy 

func (in *StreamStreamLargeObjects) DeepCopy() *StreamStreamLargeObjects

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamStreamLargeObjects.

func (*StreamStreamLargeObjects) DeepCopyInto 

func (in *StreamStreamLargeObjects) DeepCopyInto(out *StreamStreamLargeObjects)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

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.