Package cloud.google.com/go/datastream/apiv1/datastreampb (v1.9.1)

Variables

PrivateConnection_State_name, PrivateConnection_State_value

var (
	PrivateConnection_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "CREATING",
		2: "CREATED",
		3: "FAILED",
		4: "DELETING",
		5: "FAILED_TO_DELETE",
	}
	PrivateConnection_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"CREATING":          1,
		"CREATED":           2,
		"FAILED":            3,
		"DELETING":          4,
		"FAILED_TO_DELETE":  5,
	}
)

Enum value maps for PrivateConnection_State.

JsonFileFormat_SchemaFileFormat_name, JsonFileFormat_SchemaFileFormat_value

var (
	JsonFileFormat_SchemaFileFormat_name = map[int32]string{
		0: "SCHEMA_FILE_FORMAT_UNSPECIFIED",
		1: "NO_SCHEMA_FILE",
		2: "AVRO_SCHEMA_FILE",
	}
	JsonFileFormat_SchemaFileFormat_value = map[string]int32{
		"SCHEMA_FILE_FORMAT_UNSPECIFIED": 0,
		"NO_SCHEMA_FILE":                 1,
		"AVRO_SCHEMA_FILE":               2,
	}
)

Enum value maps for JsonFileFormat_SchemaFileFormat.

JsonFileFormat_JsonCompression_name, JsonFileFormat_JsonCompression_value

var (
	JsonFileFormat_JsonCompression_name = map[int32]string{
		0: "JSON_COMPRESSION_UNSPECIFIED",
		1: "NO_COMPRESSION",
		2: "GZIP",
	}
	JsonFileFormat_JsonCompression_value = map[string]int32{
		"JSON_COMPRESSION_UNSPECIFIED": 0,
		"NO_COMPRESSION":               1,
		"GZIP":                         2,
	}
)

Enum value maps for JsonFileFormat_JsonCompression.

Stream_State_name, Stream_State_value

var (
	Stream_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "NOT_STARTED",
		2: "RUNNING",
		3: "PAUSED",
		4: "MAINTENANCE",
		5: "FAILED",
		6: "FAILED_PERMANENTLY",
		7: "STARTING",
		8: "DRAINING",
	}
	Stream_State_value = map[string]int32{
		"STATE_UNSPECIFIED":  0,
		"NOT_STARTED":        1,
		"RUNNING":            2,
		"PAUSED":             3,
		"MAINTENANCE":        4,
		"FAILED":             5,
		"FAILED_PERMANENTLY": 6,
		"STARTING":           7,
		"DRAINING":           8,
	}
)

Enum value maps for Stream_State.

BackfillJob_State_name, BackfillJob_State_value

var (
	BackfillJob_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "NOT_STARTED",
		2: "PENDING",
		3: "ACTIVE",
		4: "STOPPED",
		5: "FAILED",
		6: "COMPLETED",
		7: "UNSUPPORTED",
	}
	BackfillJob_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"NOT_STARTED":       1,
		"PENDING":           2,
		"ACTIVE":            3,
		"STOPPED":           4,
		"FAILED":            5,
		"COMPLETED":         6,
		"UNSUPPORTED":       7,
	}
)

Enum value maps for BackfillJob_State.

BackfillJob_Trigger_name, BackfillJob_Trigger_value

var (
	BackfillJob_Trigger_name = map[int32]string{
		0: "TRIGGER_UNSPECIFIED",
		1: "AUTOMATIC",
		2: "MANUAL",
	}
	BackfillJob_Trigger_value = map[string]int32{
		"TRIGGER_UNSPECIFIED": 0,
		"AUTOMATIC":           1,
		"MANUAL":              2,
	}
)

Enum value maps for BackfillJob_Trigger.

Validation_State_name, Validation_State_value

var (
	Validation_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "NOT_EXECUTED",
		2: "FAILED",
		3: "PASSED",
	}
	Validation_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"NOT_EXECUTED":      1,
		"FAILED":            2,
		"PASSED":            3,
	}
)

Enum value maps for Validation_State.

ValidationMessage_Level_name, ValidationMessage_Level_value

var (
	ValidationMessage_Level_name = map[int32]string{
		0: "LEVEL_UNSPECIFIED",
		1: "WARNING",
		2: "ERROR",
	}
	ValidationMessage_Level_value = map[string]int32{
		"LEVEL_UNSPECIFIED": 0,
		"WARNING":           1,
		"ERROR":             2,
	}
)

Enum value maps for ValidationMessage_Level.

File_google_cloud_datastream_v1_datastream_proto

var File_google_cloud_datastream_v1_datastream_proto protoreflect.FileDescriptor

File_google_cloud_datastream_v1_datastream_resources_proto

var File_google_cloud_datastream_v1_datastream_resources_proto protoreflect.FileDescriptor

Functions

func RegisterDatastreamServer

func RegisterDatastreamServer(s *grpc.Server, srv DatastreamServer)

AvroFileFormat

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

AVRO file format configuration.

func (*AvroFileFormat) Descriptor

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

Deprecated: Use AvroFileFormat.ProtoReflect.Descriptor instead.

func (*AvroFileFormat) ProtoMessage

func (*AvroFileFormat) ProtoMessage()

func (*AvroFileFormat) ProtoReflect

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

func (*AvroFileFormat) Reset

func (x *AvroFileFormat) Reset()

func (*AvroFileFormat) String

func (x *AvroFileFormat) String() string

BackfillJob

type BackfillJob struct {

	// Backfill job state.
	State BackfillJob_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.datastream.v1.BackfillJob_State" json:"state,omitempty"`
	// Backfill job's triggering reason.
	Trigger BackfillJob_Trigger `protobuf:"varint,2,opt,name=trigger,proto3,enum=google.cloud.datastream.v1.BackfillJob_Trigger" json:"trigger,omitempty"`
	// Output only. Backfill job's start time.
	LastStartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_start_time,json=lastStartTime,proto3" json:"last_start_time,omitempty"`
	// Output only. Backfill job's end time.
	LastEndTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_end_time,json=lastEndTime,proto3" json:"last_end_time,omitempty"`
	// Output only. Errors which caused the backfill job to fail.
	Errors []*Error `protobuf:"bytes,5,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

Represents a backfill job on a specific stream object.

func (*BackfillJob) Descriptor

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

Deprecated: Use BackfillJob.ProtoReflect.Descriptor instead.

func (*BackfillJob) GetErrors

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

func (*BackfillJob) GetLastEndTime

func (x *BackfillJob) GetLastEndTime() *timestamppb.Timestamp

func (*BackfillJob) GetLastStartTime

func (x *BackfillJob) GetLastStartTime() *timestamppb.Timestamp

func (*BackfillJob) GetState

func (x *BackfillJob) GetState() BackfillJob_State

func (*BackfillJob) GetTrigger

func (x *BackfillJob) GetTrigger() BackfillJob_Trigger

func (*BackfillJob) ProtoMessage

func (*BackfillJob) ProtoMessage()

func (*BackfillJob) ProtoReflect

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

func (*BackfillJob) Reset

func (x *BackfillJob) Reset()

func (*BackfillJob) String

func (x *BackfillJob) String() string

BackfillJob_State

type BackfillJob_State int32

State of the stream object's backfill job.

BackfillJob_STATE_UNSPECIFIED, BackfillJob_NOT_STARTED, BackfillJob_PENDING, BackfillJob_ACTIVE, BackfillJob_STOPPED, BackfillJob_FAILED, BackfillJob_COMPLETED, BackfillJob_UNSUPPORTED

const (
	// Default value.
	BackfillJob_STATE_UNSPECIFIED BackfillJob_State = 0
	// Backfill job was never started for the stream object (stream has backfill
	// strategy defined as manual or object was explicitly excluded from
	// automatic backfill).
	BackfillJob_NOT_STARTED BackfillJob_State = 1
	// Backfill job will start pending available resources.
	BackfillJob_PENDING BackfillJob_State = 2
	// Backfill job is running.
	BackfillJob_ACTIVE BackfillJob_State = 3
	// Backfill job stopped (next job run will start from beginning).
	BackfillJob_STOPPED BackfillJob_State = 4
	// Backfill job failed (due to an error).
	BackfillJob_FAILED BackfillJob_State = 5
	// Backfill completed successfully.
	BackfillJob_COMPLETED BackfillJob_State = 6
	// Backfill job failed since the table structure is currently unsupported
	// for backfill.
	BackfillJob_UNSUPPORTED BackfillJob_State = 7
)

func (BackfillJob_State) Descriptor

func (BackfillJob_State) Enum

func (BackfillJob_State) EnumDescriptor

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

Deprecated: Use BackfillJob_State.Descriptor instead.

func (BackfillJob_State) Number

func (BackfillJob_State) String

func (x BackfillJob_State) String() string

func (BackfillJob_State) Type

BackfillJob_Trigger

type BackfillJob_Trigger int32

Triggering reason for a backfill job.

BackfillJob_TRIGGER_UNSPECIFIED, BackfillJob_AUTOMATIC, BackfillJob_MANUAL

const (
	// Default value.
	BackfillJob_TRIGGER_UNSPECIFIED BackfillJob_Trigger = 0
	// Object backfill job was triggered automatically according to the stream's
	// backfill strategy.
	BackfillJob_AUTOMATIC BackfillJob_Trigger = 1
	// Object backfill job was triggered manually using the dedicated API.
	BackfillJob_MANUAL BackfillJob_Trigger = 2
)

func (BackfillJob_Trigger) Descriptor

func (BackfillJob_Trigger) Enum

func (BackfillJob_Trigger) EnumDescriptor

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

Deprecated: Use BackfillJob_Trigger.Descriptor instead.

func (BackfillJob_Trigger) Number

func (BackfillJob_Trigger) String

func (x BackfillJob_Trigger) String() string

func (BackfillJob_Trigger) 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
}

BigQuery destination configuration

func (*BigQueryDestinationConfig) Descriptor

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

Deprecated: Use BigQueryDestinationConfig.ProtoReflect.Descriptor instead.

func (*BigQueryDestinationConfig) GetDataFreshness

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

func (*BigQueryDestinationConfig) GetDatasetConfig

func (m *BigQueryDestinationConfig) GetDatasetConfig() isBigQueryDestinationConfig_DatasetConfig

func (*BigQueryDestinationConfig) GetSingleTargetDataset

func (*BigQueryDestinationConfig) GetSourceHierarchyDatasets

func (*BigQueryDestinationConfig) ProtoMessage

func (*BigQueryDestinationConfig) ProtoMessage()

func (*BigQueryDestinationConfig) ProtoReflect

func (*BigQueryDestinationConfig) Reset

func (x *BigQueryDestinationConfig) Reset()

func (*BigQueryDestinationConfig) String

func (x *BigQueryDestinationConfig) String() string

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: Use BigQueryDestinationConfig_SingleTargetDataset.ProtoReflect.Descriptor instead.

func (*BigQueryDestinationConfig_SingleTargetDataset) GetDatasetId

func (*BigQueryDestinationConfig_SingleTargetDataset) ProtoMessage

func (*BigQueryDestinationConfig_SingleTargetDataset) ProtoReflect

func (*BigQueryDestinationConfig_SingleTargetDataset) Reset

func (*BigQueryDestinationConfig_SingleTargetDataset) String

BigQueryDestinationConfig_SingleTargetDataset_

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

BigQueryDestinationConfig_SourceHierarchyDatasets

type BigQueryDestinationConfig_SourceHierarchyDatasets struct {

	// The dataset template to use for dynamic dataset creation.
	DatasetTemplate *BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate `protobuf:"bytes,2,opt,name=dataset_template,json=datasetTemplate,proto3" json:"dataset_template,omitempty"`
	// contains filtered or unexported fields
}

Destination datasets are created so that hierarchy of the destination data objects matches the source hierarchy.

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) Descriptor

Deprecated: Use BigQueryDestinationConfig_SourceHierarchyDatasets.ProtoReflect.Descriptor instead.

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) GetDatasetTemplate

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) ProtoMessage

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) ProtoReflect

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) Reset

func (*BigQueryDestinationConfig_SourceHierarchyDatasets) String

BigQueryDestinationConfig_SourceHierarchyDatasets_

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

BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate

type BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate struct {

	// Required. The geographic location where the dataset should reside. See
	// https://cloud.google.com/bigquery/docs/locations for supported
	// locations.
	Location string `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// If supplied, every created dataset will have its name prefixed by the
	// provided value. The prefix and name will be separated by an underscore.
	// i.e. 

Dataset template used for dynamic dataset creation.

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) Descriptor

Deprecated: Use BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate.ProtoReflect.Descriptor instead.

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetDatasetIdPrefix

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetKmsKeyName

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) GetLocation

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) ProtoMessage

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) ProtoReflect

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) Reset

func (*BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate) String

BigQueryProfile

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

BigQuery warehouse profile.

func (*BigQueryProfile) Descriptor

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

Deprecated: Use BigQueryProfile.ProtoReflect.Descriptor instead.

func (*BigQueryProfile) ProtoMessage

func (*BigQueryProfile) ProtoMessage()

func (*BigQueryProfile) ProtoReflect

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

func (*BigQueryProfile) Reset

func (x *BigQueryProfile) Reset()

func (*BigQueryProfile) String

func (x *BigQueryProfile) String() string

ConnectionProfile

type ConnectionProfile struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`

	Profile isConnectionProfile_Profile `protobuf_oneof:"profile"`

	Connectivity isConnectionProfile_Connectivity `protobuf_oneof:"connectivity"`

}

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

func (*ConnectionProfile) Descriptor

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

Deprecated: Use ConnectionProfile.ProtoReflect.Descriptor instead.

func (*ConnectionProfile) GetBigqueryProfile

func (x *ConnectionProfile) GetBigqueryProfile() *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

ConnectionProfile_BigqueryProfile

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

ConnectionProfile_ForwardSshConnectivity

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

ConnectionProfile_GcsProfile

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

ConnectionProfile_MysqlProfile

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

ConnectionProfile_OracleProfile

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

ConnectionProfile_PostgresqlProfile

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

ConnectionProfile_PrivateConnectivity

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

ConnectionProfile_StaticServiceIpConnectivity

type ConnectionProfile_StaticServiceIpConnectivity struct {
	// Static Service IP connectivity.
	StaticServiceIpConnectivity *StaticServiceIpConnectivity `protobuf:"bytes,200,opt,name=static_service_ip_connectivity,json=staticServiceIpConnectivity,proto3,oneof"`
}

CreateConnectionProfileRequest

type CreateConnectionProfileRequest struct {

	// Required. The parent that owns the collection of ConnectionProfiles.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The connection profile identifier.
	ConnectionProfileId string `protobuf:"bytes,2,opt,name=connection_profile_id,json=connectionProfileId,proto3" json:"connection_profile_id,omitempty"`
	// Required. The connection profile resource to create.
	ConnectionProfile *ConnectionProfile `protobuf:"bytes,3,opt,name=connection_profile,json=connectionProfile,proto3" json:"connection_profile,omitempty"`
	// Optional. A request ID to identify requests. Specify a unique request ID
	// so that if you must retry your request, the server will know to ignore
	// the request if it has already been completed. The server will guarantee
	// that for at least 60 minutes since the first request.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request ID,
	// the server can check if original operation with the same request ID was
	// received, and if so, will ignore the second request. This prevents clients
	// from accidentally creating duplicate commitments.
	//
	// The request ID must be a valid UUID with the exception that zero UUID is
	// not supported (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Optional. Only validate the connection profile, but don't create any
	// resources. The default is false.
	ValidateOnly bool `protobuf:"varint,5,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// Optional. Create the connection profile without validating it.
	Force bool `protobuf:"varint,6,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

Request message for creating a connection profile.

func (*CreateConnectionProfileRequest) Descriptor

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

Deprecated: Use CreateConnectionProfileRequest.ProtoReflect.Descriptor instead.

func (*CreateConnectionProfileRequest) GetConnectionProfile

func (x *CreateConnectionProfileRequest) GetConnectionProfile() *ConnectionProfile

func (*CreateConnectionProfileRequest) GetConnectionProfileId

func (x *CreateConnectionProfileRequest) GetConnectionProfileId() string

func (*CreateConnectionProfileRequest) GetForce

func (x *CreateConnectionProfileRequest) GetForce() bool

func (*CreateConnectionProfileRequest) GetParent

func (x *CreateConnectionProfileRequest) GetParent() string

func (*CreateConnectionProfileRequest) GetRequestId

func (x *CreateConnectionProfileRequest) GetRequestId() string

func (*CreateConnectionProfileRequest) GetValidateOnly

func (x *CreateConnectionProfileRequest) GetValidateOnly() bool

func (*CreateConnectionProfileRequest) ProtoMessage

func (*CreateConnectionProfileRequest) ProtoMessage()

func (*CreateConnectionProfileRequest) ProtoReflect

func (*CreateConnectionProfileRequest) Reset

func (x *CreateConnectionProfileRequest) Reset()

func (*CreateConnectionProfileRequest) String

CreatePrivateConnectionRequest

type CreatePrivateConnectionRequest struct {

	// Required. The parent that owns the collection of PrivateConnections.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The private connectivity identifier.
	PrivateConnectionId string `protobuf:"bytes,2,opt,name=private_connection_id,json=privateConnectionId,proto3" json:"private_connection_id,omitempty"`
	// Required. The Private Connectivity resource to create.
	PrivateConnection *PrivateConnection `protobuf:"bytes,3,opt,name=private_connection,json=privateConnection,proto3" json:"private_connection,omitempty"`
	// Optional. A request ID to identify requests. Specify a unique request ID
	// so that if you must retry your request, the server will know to ignore
	// the request if it has already been completed. The server will guarantee
	// that for at least 60 minutes since the first request.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request ID,
	// the server can check if original operation with the same request ID was
	// received, and if so, will ignore the second request. This prevents clients
	// from accidentally creating duplicate commitments.
	//
	// The request ID must be a valid UUID with the exception that zero UUID is
	// not supported (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Optional. If set to true, will skip validations.
	Force bool `protobuf:"varint,6,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

Request for creating a private connection.

func (*CreatePrivateConnectionRequest) Descriptor

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

Deprecated: Use CreatePrivateConnectionRequest.ProtoReflect.Descriptor instead.

func (*CreatePrivateConnectionRequest) GetForce

func (x *CreatePrivateConnectionRequest) GetForce() bool

func (*CreatePrivateConnectionRequest) GetParent

func (x *CreatePrivateConnectionRequest) GetParent() string

func (*CreatePrivateConnectionRequest) GetPrivateConnection

func (x *CreatePrivateConnectionRequest) GetPrivateConnection() *PrivateConnection

func (*CreatePrivateConnectionRequest) GetPrivateConnectionId

func (x *CreatePrivateConnectionRequest) GetPrivateConnectionId() string

func (*CreatePrivateConnectionRequest) GetRequestId

func (x *CreatePrivateConnectionRequest) GetRequestId() string

func (*CreatePrivateConnectionRequest) ProtoMessage

func (*CreatePrivateConnectionRequest) ProtoMessage()

func (*CreatePrivateConnectionRequest) ProtoReflect

func (*CreatePrivateConnectionRequest) Reset

func (x *CreatePrivateConnectionRequest) Reset()

func (*CreatePrivateConnectionRequest) String

CreateRouteRequest

type CreateRouteRequest struct {

	// Required. The parent that owns the collection of Routes.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The Route identifier.
	RouteId string `protobuf:"bytes,2,opt,name=route_id,json=routeId,proto3" json:"route_id,omitempty"`
	// Required. The Route resource to create.
	Route *Route `protobuf:"bytes,3,opt,name=route,proto3" json:"route,omitempty"`
	// Optional. A request ID to identify requests. Specify a unique request ID
	// so that if you must retry your request, the server will know to ignore
	// the request if it has already been completed. The server will guarantee
	// that for at least 60 minutes since the first request.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request ID,
	// the server can check if original operation with the same request ID was
	// received, and if so, will ignore the second request. This prevents clients
	// from accidentally creating duplicate commitments.
	//
	// The request ID must be a valid UUID with the exception that zero UUID is
	// not supported (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

Route creation request.

func (*CreateRouteRequest) Descriptor

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

Deprecated: Use CreateRouteRequest.ProtoReflect.Descriptor instead.

func (*CreateRouteRequest) GetParent

func (x *CreateRouteRequest) GetParent() string

func (*CreateRouteRequest) GetRequestId

func (x *CreateRouteRequest) GetRequestId() string

func (*CreateRouteRequest) GetRoute

func (x *CreateRouteRequest) GetRoute() *Route

func (*CreateRouteRequest) GetRouteId

func (x *CreateRouteRequest) GetRouteId() string

func (*CreateRouteRequest) ProtoMessage

func (*CreateRouteRequest) ProtoMessage()

func (*CreateRouteRequest) ProtoReflect

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

func (*CreateRouteRequest) Reset

func (x *CreateRouteRequest) Reset()

func (*CreateRouteRequest) String

func (x *CreateRouteRequest) String() string

CreateStreamRequest

type CreateStreamRequest struct {

	// Required. The parent that owns the collection of streams.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The stream identifier.
	StreamId string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// Required. The stream resource to create.
	Stream *Stream `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"`
	// Optional. A request ID to identify requests. Specify a unique request ID
	// so that if you must retry your request, the server will know to ignore
	// the request if it has already been completed. The server will guarantee
	// that for at least 60 minutes since the first request.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request ID,
	// the server can check if original operation with the same request ID was
	// received, and if so, will ignore the second request. This prevents clients
	// from accidentally creating duplicate commitments.
	//
	// The request ID must be a valid UUID with the exception that zero UUID is
	// not supported (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Optional. Only validate the stream, but don't create any resources.
	// The default is false.
	ValidateOnly bool `protobuf:"varint,5,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// Optional. Create the stream without validating it.
	Force bool `protobuf:"varint,6,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

Request message for creating a stream.

func (*CreateStreamRequest) Descriptor

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

Deprecated: Use CreateStreamRequest.ProtoReflect.Descriptor instead.

func (*CreateStreamRequest) GetForce

func (x *CreateStreamRequest) GetForce() bool

func (*CreateStreamRequest) GetParent

func (x *CreateStreamRequest) GetParent() string

func (*CreateStreamRequest) GetRequestId

func (x *CreateStreamRequest) GetRequestId() string

func (*CreateStreamRequest) GetStream

func (x *CreateStreamRequest) GetStream() *Stream

func (*CreateStreamRequest) GetStreamId

func (x *CreateStreamRequest) GetStreamId() string

func (*CreateStreamRequest) GetValidateOnly

func (x *CreateStreamRequest) GetValidateOnly() bool

func (*CreateStreamRequest) ProtoMessage

func (*CreateStreamRequest) ProtoMessage()

func (*CreateStreamRequest) ProtoReflect

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

func (*CreateStreamRequest) Reset

func (x *CreateStreamRequest) Reset()

func (*CreateStreamRequest) String

func (x *CreateStreamRequest) String() string

DatastreamClient

type DatastreamClient interface {
	// Use this method to list connection profiles created in a project and
	// location.
	ListConnectionProfiles(ctx context.Context, in *ListConnectionProfilesRequest, opts ...grpc.CallOption) (*ListConnectionProfilesResponse, error)
	// Use this method to get details about a connection profile.
	GetConnectionProfile(ctx context.Context, in *GetConnectionProfileRequest, opts ...grpc.CallOption) (*ConnectionProfile, error)
	// Use this method to create a connection profile in a project and location.
	CreateConnectionProfile(ctx context.Context, in *CreateConnectionProfileRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Use this method to update the parameters of a connection profile.
	UpdateConnectionProfile(ctx context.Context, in *UpdateConnectionProfileRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Use this method to delete a connection profile.
	DeleteConnectionProfile(ctx context.Context, in *DeleteConnectionProfileRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Use this method to discover a connection profile.
	// The discover API call exposes the data objects and metadata belonging to
	// the profile. Typically, a request returns children data objects of a
	// parent data object that's optionally supplied in the request.
	DiscoverConnectionProfile(ctx context.Context, in *DiscoverConnectionProfileRequest, opts ...grpc.CallOption) (*DiscoverConnectionProfileResponse, error)
	// Use this method to list streams in a project and location.
	ListStreams(ctx context.Context, in *ListStreamsRequest, opts ...grpc.CallOption) (*ListStreamsResponse, error)
	// Use this method to get details about a stream.
	GetStream(ctx context.Context, in *GetStreamRequest, opts ...grpc.CallOption) (*Stream, error)
	// Use this method to create a stream.
	CreateStream(ctx context.Context, in *CreateStreamRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Use this method to update the configuration of a stream.
	UpdateStream(ctx context.Context, in *UpdateStreamRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Use this method to delete a stream.
	DeleteStream(ctx context.Context, in *DeleteStreamRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Use this method to get details about a stream object.
	GetStreamObject(ctx context.Context, in *GetStreamObjectRequest, opts ...grpc.CallOption) (*StreamObject, error)
	// Use this method to look up a stream object by its source object identifier.
	LookupStreamObject(ctx context.Context, in *LookupStreamObjectRequest, opts ...grpc.CallOption) (*StreamObject, error)
	// Use this method to list the objects of a specific stream.
	ListStreamObjects(ctx context.Context, in *ListStreamObjectsRequest, opts ...grpc.CallOption) (*ListStreamObjectsResponse, error)
	// Use this method to start a backfill job for the specified stream object.
	StartBackfillJob(ctx context.Context, in *StartBackfillJobRequest, opts ...grpc.CallOption) (*StartBackfillJobResponse, error)
	// Use this method to stop a backfill job for the specified stream object.
	StopBackfillJob(ctx context.Context, in *StopBackfillJobRequest, opts ...grpc.CallOption) (*StopBackfillJobResponse, error)
	// The FetchStaticIps API call exposes the static IP addresses used by
	// Datastream.
	FetchStaticIps(ctx context.Context, in *FetchStaticIpsRequest, opts ...grpc.CallOption) (*FetchStaticIpsResponse, error)
	// Use this method to create a private connectivity configuration.
	CreatePrivateConnection(ctx context.Context, in *CreatePrivateConnectionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Use this method to get details about a private connectivity configuration.
	GetPrivateConnection(ctx context.Context, in *GetPrivateConnectionRequest, opts ...grpc.CallOption) (*PrivateConnection, error)
	// Use this method to list private connectivity configurations in a project
	// and location.
	ListPrivateConnections(ctx context.Context, in *ListPrivateConnectionsRequest, opts ...grpc.CallOption) (*ListPrivateConnectionsResponse, error)
	// Use this method to delete a private connectivity configuration.
	DeletePrivateConnection(ctx context.Context, in *DeletePrivateConnectionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Use this method to create a route for a private connectivity configuration
	// in a project and location.
	CreateRoute(ctx context.Context, in *CreateRouteRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Use this method to get details about a route.
	GetRoute(ctx context.Context, in *GetRouteRequest, opts ...grpc.CallOption) (*Route, error)
	// Use this method to list routes created for a private connectivity
	// configuration in a project and location.
	ListRoutes(ctx context.Context, in *ListRoutesRequest, opts ...grpc.CallOption) (*ListRoutesResponse, error)
	// Use this method to delete a route.
	DeleteRoute(ctx context.Context, in *DeleteRouteRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
}

DatastreamClient is the client API for Datastream service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDatastreamClient

func NewDatastreamClient(cc grpc.ClientConnInterface) DatastreamClient

DatastreamServer

type DatastreamServer interface {
	// Use this method to list connection profiles created in a project and
	// location.
	ListConnectionProfiles(context.Context, *ListConnectionProfilesRequest) (*ListConnectionProfilesResponse, error)
	// Use this method to get details about a connection profile.
	GetConnectionProfile(context.Context, *GetConnectionProfileRequest) (*ConnectionProfile, error)
	// Use this method to create a connection profile in a project and location.
	CreateConnectionProfile(context.Context, *CreateConnectionProfileRequest) (*longrunningpb.Operation, error)
	// Use this method to update the parameters of a connection profile.
	UpdateConnectionProfile(context.Context, *UpdateConnectionProfileRequest) (*longrunningpb.Operation, error)
	// Use this method to delete a connection profile.
	DeleteConnectionProfile(context.Context, *DeleteConnectionProfileRequest) (*longrunningpb.Operation, error)
	// Use this method to discover a connection profile.
	// The discover API call exposes the data objects and metadata belonging to
	// the profile. Typically, a request returns children data objects of a
	// parent data object that's optionally supplied in the request.
	DiscoverConnectionProfile(context.Context, *DiscoverConnectionProfileRequest) (*DiscoverConnectionProfileResponse, error)
	// Use this method to list streams in a project and location.
	ListStreams(context.Context, *ListStreamsRequest) (*ListStreamsResponse, error)
	// Use this method to get details about a stream.
	GetStream(context.Context, *GetStreamRequest) (*Stream, error)
	// Use this method to create a stream.
	CreateStream(context.Context, *CreateStreamRequest) (*longrunningpb.Operation, error)
	// Use this method to update the configuration of a stream.
	UpdateStream(context.Context, *UpdateStreamRequest) (*longrunningpb.Operation, error)
	// Use this method to delete a stream.
	DeleteStream(context.Context, *DeleteStreamRequest) (*longrunningpb.Operation, error)
	// Use this method to get details about a stream object.
	GetStreamObject(context.Context, *GetStreamObjectRequest) (*StreamObject, error)
	// Use this method to look up a stream object by its source object identifier.
	LookupStreamObject(context.Context, *LookupStreamObjectRequest) (*StreamObject, error)
	// Use this method to list the objects of a specific stream.
	ListStreamObjects(context.Context, *ListStreamObjectsRequest) (*ListStreamObjectsResponse, error)
	// Use this method to start a backfill job for the specified stream object.
	StartBackfillJob(context.Context, *StartBackfillJobRequest) (*StartBackfillJobResponse, error)
	// Use this method to stop a backfill job for the specified stream object.
	StopBackfillJob(context.Context, *StopBackfillJobRequest) (*StopBackfillJobResponse, error)
	// The FetchStaticIps API call exposes the static IP addresses used by
	// Datastream.
	FetchStaticIps(context.Context, *FetchStaticIpsRequest) (*FetchStaticIpsResponse, error)
	// Use this method to create a private connectivity configuration.
	CreatePrivateConnection(context.Context, *CreatePrivateConnectionRequest) (*longrunningpb.Operation, error)
	// Use this method to get details about a private connectivity configuration.
	GetPrivateConnection(context.Context, *GetPrivateConnectionRequest) (*PrivateConnection, error)
	// Use this method to list private connectivity configurations in a project
	// and location.
	ListPrivateConnections(context.Context, *ListPrivateConnectionsRequest) (*ListPrivateConnectionsResponse, error)
	// Use this method to delete a private connectivity configuration.
	DeletePrivateConnection(context.Context, *DeletePrivateConnectionRequest) (*longrunningpb.Operation, error)
	// Use this method to create a route for a private connectivity configuration
	// in a project and location.
	CreateRoute(context.Context, *CreateRouteRequest) (*longrunningpb.Operation, error)
	// Use this method to get details about a route.
	GetRoute(context.Context, *GetRouteRequest) (*Route, error)
	// Use this method to list routes created for a private connectivity
	// configuration in a project and location.
	ListRoutes(context.Context, *ListRoutesRequest) (*ListRoutesResponse, error)
	// Use this method to delete a route.
	DeleteRoute(context.Context, *DeleteRouteRequest) (*longrunningpb.Operation, error)
}

DatastreamServer is the server API for Datastream service.

DeleteConnectionProfileRequest

type DeleteConnectionProfileRequest struct {

	// Required. The name of the connection profile resource to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. A request ID to identify requests. Specify a unique request ID
	// so that if you must retry your request, the server will know to ignore
	// the request if it has already been completed. The server will guarantee
	// that for at least 60 minutes after the first request.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request ID,
	// the server can check if original operation with the same request ID was
	// received, and if so, will ignore the second request. This prevents clients
	// from accidentally creating duplicate commitments.
	//
	// The request ID must be a valid UUID with the exception that zero UUID is
	// not supported (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for deleting a connection profile.

func (*DeleteConnectionProfileRequest) Descriptor

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

Deprecated: Use DeleteConnectionProfileRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectionProfileRequest) GetName

func (*DeleteConnectionProfileRequest) GetRequestId

func (x *DeleteConnectionProfileRequest) GetRequestId() string

func (*DeleteConnectionProfileRequest) ProtoMessage

func (*DeleteConnectionProfileRequest) ProtoMessage()

func (*DeleteConnectionProfileRequest) ProtoReflect

func (*DeleteConnectionProfileRequest) Reset

func (x *DeleteConnectionProfileRequest) Reset()

func (*DeleteConnectionProfileRequest) String

DeletePrivateConnectionRequest

type DeletePrivateConnectionRequest struct {

	// Required. The name of the private connectivity configuration to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. A request ID to identify requests. Specify a unique request ID
	// so that if you must retry your request, the server will know to ignore
	// the request if it has already been completed. The server will guarantee
	// that for at least 60 minutes after the first request.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request ID,
	// the server can check if original operation with the same request ID was
	// received, and if so, will ignore the second request. This prevents clients
	// from accidentally creating duplicate commitments.
	//
	// The request ID must be a valid UUID with the exception that zero UUID is
	// not supported (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Optional. If set to true, any child routes that belong to this
	// PrivateConnection will also be deleted.
	Force bool `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

Request to delete a private connection.

func (*DeletePrivateConnectionRequest) Descriptor

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

Deprecated: Use DeletePrivateConnectionRequest.ProtoReflect.Descriptor instead.

func (*DeletePrivateConnectionRequest) GetForce

func (x *DeletePrivateConnectionRequest) GetForce() bool

func (*DeletePrivateConnectionRequest) GetName

func (*DeletePrivateConnectionRequest) GetRequestId

func (x *DeletePrivateConnectionRequest) GetRequestId() string

func (*DeletePrivateConnectionRequest) ProtoMessage

func (*DeletePrivateConnectionRequest) ProtoMessage()

func (*DeletePrivateConnectionRequest) ProtoReflect

func (*DeletePrivateConnectionRequest) Reset

func (x *DeletePrivateConnectionRequest) Reset()

func (*DeletePrivateConnectionRequest) String

DeleteRouteRequest

type DeleteRouteRequest struct {

	// Required. The name of the Route resource to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. A request ID to identify requests. Specify a unique request ID
	// so that if you must retry your request, the server will know to ignore
	// the request if it has already been completed. The server will guarantee
	// that for at least 60 minutes after the first request.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request ID,
	// the server can check if original operation with the same request ID was
	// received, and if so, will ignore the second request. This prevents clients
	// from accidentally creating duplicate commitments.
	//
	// The request ID must be a valid UUID with the exception that zero UUID is
	// not supported (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

Route deletion request.

func (*DeleteRouteRequest) Descriptor

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

Deprecated: Use DeleteRouteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRouteRequest) GetName

func (x *DeleteRouteRequest) GetName() string

func (*DeleteRouteRequest) GetRequestId

func (x *DeleteRouteRequest) GetRequestId() string

func (*DeleteRouteRequest) ProtoMessage

func (*DeleteRouteRequest) ProtoMessage()

func (*DeleteRouteRequest) ProtoReflect

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

func (*DeleteRouteRequest) Reset

func (x *DeleteRouteRequest) Reset()

func (*DeleteRouteRequest) String

func (x *DeleteRouteRequest) String() string

DeleteStreamRequest

type DeleteStreamRequest struct {

	// Required. The name of the stream resource to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. A request ID to identify requests. Specify a unique request ID
	// so that if you must retry your request, the server will know to ignore
	// the request if it has already been completed. The server will guarantee
	// that for at least 60 minutes after the first request.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request ID,
	// the server can check if original operation with the same request ID was
	// received, and if so, will ignore the second request. This prevents clients
	// from accidentally creating duplicate commitments.
	//
	// The request ID must be a valid UUID with the exception that zero UUID is
	// not supported (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for deleting a stream.

func (*DeleteStreamRequest) Descriptor

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

Deprecated: Use DeleteStreamRequest.ProtoReflect.Descriptor instead.

func (*DeleteStreamRequest) GetName

func (x *DeleteStreamRequest) GetName() string

func (*DeleteStreamRequest) GetRequestId

func (x *DeleteStreamRequest) GetRequestId() string

func (*DeleteStreamRequest) ProtoMessage

func (*DeleteStreamRequest) ProtoMessage()

func (*DeleteStreamRequest) ProtoReflect

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

func (*DeleteStreamRequest) Reset

func (x *DeleteStreamRequest) Reset()

func (*DeleteStreamRequest) String

func (x *DeleteStreamRequest) String() string

DestinationConfig

type DestinationConfig struct {
	DestinationConnectionProfile string "" /* 147 byte string literal not displayed */

	DestinationStreamConfig isDestinationConfig_DestinationStreamConfig `protobuf_oneof:"destination_stream_config"`

}

The configuration of the stream destination.

func (*DestinationConfig) Descriptor

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

Deprecated: Use DestinationConfig.ProtoReflect.Descriptor instead.

func (*DestinationConfig) GetBigqueryDestinationConfig

func (x *DestinationConfig) GetBigqueryDestinationConfig() *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

DestinationConfig_BigqueryDestinationConfig

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

DestinationConfig_GcsDestinationConfig

type DestinationConfig_GcsDestinationConfig struct {
	// A configuration for how data should be loaded to Cloud Storage.
	GcsDestinationConfig *GcsDestinationConfig `protobuf:"bytes,100,opt,name=gcs_destination_config,json=gcsDestinationConfig,proto3,oneof"`
}

DiscoverConnectionProfileRequest

type DiscoverConnectionProfileRequest struct {

	// Required. The parent resource of the connection profile type. Must be in
	// the format `projects/*/locations/*`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The connection profile on which to run discover.
	//
	// Types that are assignable to Target:
	//	*DiscoverConnectionProfileRequest_ConnectionProfile
	//	*DiscoverConnectionProfileRequest_ConnectionProfileName
	Target isDiscoverConnectionProfileRequest_Target `protobuf_oneof:"target"`
	// The depth of the retrieved hierarchy of data objects.
	//
	// Types that are assignable to Hierarchy:
	//	*DiscoverConnectionProfileRequest_FullHierarchy
	//	*DiscoverConnectionProfileRequest_HierarchyDepth
	Hierarchy isDiscoverConnectionProfileRequest_Hierarchy `protobuf_oneof:"hierarchy"`
	// The data object to populate with child data objects and metadata.
	//
	// Types that are assignable to DataObject:
	//	*DiscoverConnectionProfileRequest_OracleRdbms
	//	*DiscoverConnectionProfileRequest_MysqlRdbms
	//	*DiscoverConnectionProfileRequest_PostgresqlRdbms
	DataObject isDiscoverConnectionProfileRequest_DataObject `protobuf_oneof:"data_object"`
	// contains filtered or unexported fields
}

Request message for 'discover' ConnectionProfile request.

func (*DiscoverConnectionProfileRequest) Descriptor

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

Deprecated: Use DiscoverConnectionProfileRequest.ProtoReflect.Descriptor instead.

func (*DiscoverConnectionProfileRequest) GetConnectionProfile

func (x *DiscoverConnectionProfileRequest) GetConnectionProfile() *ConnectionProfile

func (*DiscoverConnectionProfileRequest) GetConnectionProfileName

func (x *DiscoverConnectionProfileRequest) GetConnectionProfileName() string

func (*DiscoverConnectionProfileRequest) GetDataObject

func (m *DiscoverConnectionProfileRequest) GetDataObject() isDiscoverConnectionProfileRequest_DataObject

func (*DiscoverConnectionProfileRequest) GetFullHierarchy

func (x *DiscoverConnectionProfileRequest) GetFullHierarchy() bool

func (*DiscoverConnectionProfileRequest) GetHierarchy

func (m *DiscoverConnectionProfileRequest) GetHierarchy() isDiscoverConnectionProfileRequest_Hierarchy

func (*DiscoverConnectionProfileRequest) GetHierarchyDepth

func (x *DiscoverConnectionProfileRequest) GetHierarchyDepth() int32

func (*DiscoverConnectionProfileRequest) GetMysqlRdbms

func (x *DiscoverConnectionProfileRequest) GetMysqlRdbms() *MysqlRdbms

func (*DiscoverConnectionProfileRequest) GetOracleRdbms

func (x *DiscoverConnectionProfileRequest) GetOracleRdbms() *OracleRdbms

func (*DiscoverConnectionProfileRequest) GetParent

func (*DiscoverConnectionProfileRequest) GetPostgresqlRdbms

func (x *DiscoverConnectionProfileRequest) GetPostgresqlRdbms() *PostgresqlRdbms

func (*DiscoverConnectionProfileRequest) GetTarget

func (m *DiscoverConnectionProfileRequest) GetTarget() isDiscoverConnectionProfileRequest_Target

func (*DiscoverConnectionProfileRequest) ProtoMessage

func (*DiscoverConnectionProfileRequest) ProtoMessage()

func (*DiscoverConnectionProfileRequest) ProtoReflect

func (*DiscoverConnectionProfileRequest) Reset

func (*DiscoverConnectionProfileRequest) String

DiscoverConnectionProfileRequest_ConnectionProfile

type DiscoverConnectionProfileRequest_ConnectionProfile struct {
	// An ad-hoc connection profile configuration.
	ConnectionProfile *ConnectionProfile `protobuf:"bytes,200,opt,name=connection_profile,json=connectionProfile,proto3,oneof"`
}

DiscoverConnectionProfileRequest_ConnectionProfileName

type DiscoverConnectionProfileRequest_ConnectionProfileName struct {
	// A reference to an existing connection profile.
	ConnectionProfileName string `protobuf:"bytes,201,opt,name=connection_profile_name,json=connectionProfileName,proto3,oneof"`
}

DiscoverConnectionProfileRequest_FullHierarchy

type DiscoverConnectionProfileRequest_FullHierarchy struct {
	// Whether to retrieve the full hierarchy of data objects (TRUE) or only the
	// current level (FALSE).
	FullHierarchy bool `protobuf:"varint,3,opt,name=full_hierarchy,json=fullHierarchy,proto3,oneof"`
}

DiscoverConnectionProfileRequest_HierarchyDepth

type DiscoverConnectionProfileRequest_HierarchyDepth struct {
	// The number of hierarchy levels below the current level to be retrieved.
	HierarchyDepth int32 `protobuf:"varint,4,opt,name=hierarchy_depth,json=hierarchyDepth,proto3,oneof"`
}

DiscoverConnectionProfileRequest_MysqlRdbms

type DiscoverConnectionProfileRequest_MysqlRdbms struct {
	// MySQL RDBMS to enrich with child data objects and metadata.
	MysqlRdbms *MysqlRdbms `protobuf:"bytes,101,opt,name=mysql_rdbms,json=mysqlRdbms,proto3,oneof"`
}

DiscoverConnectionProfileRequest_OracleRdbms

type DiscoverConnectionProfileRequest_OracleRdbms struct {
	// Oracle RDBMS to enrich with child data objects and metadata.
	OracleRdbms *OracleRdbms `protobuf:"bytes,100,opt,name=oracle_rdbms,json=oracleRdbms,proto3,oneof"`
}

DiscoverConnectionProfileRequest_PostgresqlRdbms

type DiscoverConnectionProfileRequest_PostgresqlRdbms struct {
	// PostgreSQL RDBMS to enrich with child data objects and metadata.
	PostgresqlRdbms *PostgresqlRdbms `protobuf:"bytes,102,opt,name=postgresql_rdbms,json=postgresqlRdbms,proto3,oneof"`
}

DiscoverConnectionProfileResponse

type DiscoverConnectionProfileResponse struct {

	// The data object that has been enriched by the discover API call.
	//
	// Types that are assignable to DataObject:
	//	*DiscoverConnectionProfileResponse_OracleRdbms
	//	*DiscoverConnectionProfileResponse_MysqlRdbms
	//	*DiscoverConnectionProfileResponse_PostgresqlRdbms
	DataObject isDiscoverConnectionProfileResponse_DataObject `protobuf_oneof:"data_object"`
	// contains filtered or unexported fields
}

Response from a discover request.

func (*DiscoverConnectionProfileResponse) Descriptor

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

Deprecated: Use DiscoverConnectionProfileResponse.ProtoReflect.Descriptor instead.

func (*DiscoverConnectionProfileResponse) GetDataObject

func (m *DiscoverConnectionProfileResponse) GetDataObject() isDiscoverConnectionProfileResponse_DataObject

func (*DiscoverConnectionProfileResponse) GetMysqlRdbms

func (x *DiscoverConnectionProfileResponse) GetMysqlRdbms() *MysqlRdbms

func (*DiscoverConnectionProfileResponse) GetOracleRdbms

func (x *DiscoverConnectionProfileResponse) GetOracleRdbms() *OracleRdbms

func (*DiscoverConnectionProfileResponse) GetPostgresqlRdbms

func (x *DiscoverConnectionProfileResponse) GetPostgresqlRdbms() *PostgresqlRdbms

func (*DiscoverConnectionProfileResponse) ProtoMessage

func (*DiscoverConnectionProfileResponse) ProtoMessage()

func (*DiscoverConnectionProfileResponse) ProtoReflect

func (*DiscoverConnectionProfileResponse) Reset

func (*DiscoverConnectionProfileResponse) String

DiscoverConnectionProfileResponse_MysqlRdbms

type DiscoverConnectionProfileResponse_MysqlRdbms struct {
	// Enriched MySQL RDBMS object.
	MysqlRdbms *MysqlRdbms `protobuf:"bytes,101,opt,name=mysql_rdbms,json=mysqlRdbms,proto3,oneof"`
}

DiscoverConnectionProfileResponse_OracleRdbms

type DiscoverConnectionProfileResponse_OracleRdbms struct {
	// Enriched Oracle RDBMS object.
	OracleRdbms *OracleRdbms `protobuf:"bytes,100,opt,name=oracle_rdbms,json=oracleRdbms,proto3,oneof"`
}

DiscoverConnectionProfileResponse_PostgresqlRdbms

type DiscoverConnectionProfileResponse_PostgresqlRdbms struct {
	// Enriched PostgreSQL RDBMS object.
	PostgresqlRdbms *PostgresqlRdbms `protobuf:"bytes,102,opt,name=postgresql_rdbms,json=postgresqlRdbms,proto3,oneof"`
}

Error

type Error struct {
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`

	ErrorUuid string `protobuf:"bytes,2,opt,name=error_uuid,json=errorUuid,proto3" json:"error_uuid,omitempty"`

	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`

	ErrorTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=error_time,json=errorTime,proto3" json:"error_time,omitempty"`

	Details map[string]string "" /* 155 byte string literal not displayed */

}

Represent a user-facing Error.

func (*Error) Descriptor

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

FetchStaticIpsRequest

type FetchStaticIpsRequest struct {

	// Required. The resource name for the location for which static IPs should be
	// returned. Must be in the format `projects/*/locations/*`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Maximum number of Ips to return, will likely not be specified.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token, received from a previous `ListStaticIps` call.
	// will likely not be specified.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Request message for 'FetchStaticIps' request.

func (*FetchStaticIpsRequest) Descriptor

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

Deprecated: Use FetchStaticIpsRequest.ProtoReflect.Descriptor instead.

func (*FetchStaticIpsRequest) GetName

func (x *FetchStaticIpsRequest) GetName() string

func (*FetchStaticIpsRequest) GetPageSize

func (x *FetchStaticIpsRequest) GetPageSize() int32

func (*FetchStaticIpsRequest) GetPageToken

func (x *FetchStaticIpsRequest) GetPageToken() string

func (*FetchStaticIpsRequest) ProtoMessage

func (*FetchStaticIpsRequest) ProtoMessage()

func (*FetchStaticIpsRequest) ProtoReflect

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

func (*FetchStaticIpsRequest) Reset

func (x *FetchStaticIpsRequest) Reset()

func (*FetchStaticIpsRequest) String

func (x *FetchStaticIpsRequest) String() string

FetchStaticIpsResponse

type FetchStaticIpsResponse struct {

	// list of static ips by account
	StaticIps []string `protobuf:"bytes,1,rep,name=static_ips,json=staticIps,proto3" json:"static_ips,omitempty"`
	// A token that can be sent as `page_token` to retrieve the next page.
	// If this field is omitted, there are no subsequent pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response message for a 'FetchStaticIps' response.

func (*FetchStaticIpsResponse) Descriptor

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

Deprecated: Use FetchStaticIpsResponse.ProtoReflect.Descriptor instead.

func (*FetchStaticIpsResponse) GetNextPageToken

func (x *FetchStaticIpsResponse) GetNextPageToken() string

func (*FetchStaticIpsResponse) GetStaticIps

func (x *FetchStaticIpsResponse) GetStaticIps() []string

func (*FetchStaticIpsResponse) ProtoMessage

func (*FetchStaticIpsResponse) ProtoMessage()

func (*FetchStaticIpsResponse) ProtoReflect

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

func (*FetchStaticIpsResponse) Reset

func (x *FetchStaticIpsResponse) Reset()

func (*FetchStaticIpsResponse) String

func (x *FetchStaticIpsResponse) String() string

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"`
	// Types that are assignable to AuthenticationMethod:
	//	*ForwardSshTunnelConnectivity_Password
	//	*ForwardSshTunnelConnectivity_PrivateKey
	AuthenticationMethod isForwardSshTunnelConnectivity_AuthenticationMethod `protobuf_oneof:"authentication_method"`
	// contains filtered or unexported fields
}

Forward SSH Tunnel connectivity.

func (*ForwardSshTunnelConnectivity) Descriptor

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

Deprecated: Use ForwardSshTunnelConnectivity.ProtoReflect.Descriptor instead.

func (*ForwardSshTunnelConnectivity) GetAuthenticationMethod

func (m *ForwardSshTunnelConnectivity) GetAuthenticationMethod() isForwardSshTunnelConnectivity_AuthenticationMethod

func (*ForwardSshTunnelConnectivity) GetHostname

func (x *ForwardSshTunnelConnectivity) GetHostname() string

func (*ForwardSshTunnelConnectivity) GetPassword

func (x *ForwardSshTunnelConnectivity) GetPassword() string

func (*ForwardSshTunnelConnectivity) GetPort

func (x *ForwardSshTunnelConnectivity) GetPort() int32

func (*ForwardSshTunnelConnectivity) GetPrivateKey

func (x *ForwardSshTunnelConnectivity) GetPrivateKey() string

func (*ForwardSshTunnelConnectivity) GetUsername

func (x *ForwardSshTunnelConnectivity) GetUsername() string

func (*ForwardSshTunnelConnectivity) ProtoMessage

func (*ForwardSshTunnelConnectivity) ProtoMessage()

func (*ForwardSshTunnelConnectivity) ProtoReflect

func (*ForwardSshTunnelConnectivity) Reset

func (x *ForwardSshTunnelConnectivity) Reset()

func (*ForwardSshTunnelConnectivity) String

ForwardSshTunnelConnectivity_Password

type ForwardSshTunnelConnectivity_Password struct {
	// Input only. SSH password.
	Password string `protobuf:"bytes,100,opt,name=password,proto3,oneof"`
}

ForwardSshTunnelConnectivity_PrivateKey

type ForwardSshTunnelConnectivity_PrivateKey struct {
	// Input only. SSH private key.
	PrivateKey string `protobuf:"bytes,101,opt,name=private_key,json=privateKey,proto3,oneof"`
}

GcsDestinationConfig

type GcsDestinationConfig struct {

	// Path inside the Cloud Storage bucket to write data to.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// The maximum file size to be saved in the bucket.
	FileRotationMb int32 `protobuf:"varint,2,opt,name=file_rotation_mb,json=fileRotationMb,proto3" json:"file_rotation_mb,omitempty"`
	// The maximum duration for which new events are added before a file is
	// closed and a new file is created. Values within the range of 15-60 seconds
	// are allowed.
	FileRotationInterval *durationpb.Duration `protobuf:"bytes,3,opt,name=file_rotation_interval,json=fileRotationInterval,proto3" json:"file_rotation_interval,omitempty"`
	// File Format that the data should be written in.
	//
	// Types that are assignable to FileFormat:
	//	*GcsDestinationConfig_AvroFileFormat
	//	*GcsDestinationConfig_JsonFileFormat
	FileFormat isGcsDestinationConfig_FileFormat `protobuf_oneof:"file_format"`
	// contains filtered or unexported fields
}

Google Cloud Storage destination configuration

func (*GcsDestinationConfig) Descriptor

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

Deprecated: Use GcsDestinationConfig.ProtoReflect.Descriptor instead.

func (*GcsDestinationConfig) GetAvroFileFormat

func (x *GcsDestinationConfig) GetAvroFileFormat() *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

GcsDestinationConfig_AvroFileFormat

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

GcsDestinationConfig_JsonFileFormat

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

GcsProfile

type GcsProfile struct {

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

Cloud Storage bucket profile.

func (*GcsProfile) Descriptor

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

Deprecated: Use GcsProfile.ProtoReflect.Descriptor instead.

func (*GcsProfile) GetBucket

func (x *GcsProfile) GetBucket() 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

GetConnectionProfileRequest

type GetConnectionProfileRequest struct {

	// Required. The name of the connection profile resource to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request message for getting a connection profile.

func (*GetConnectionProfileRequest) Descriptor

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

Deprecated: Use GetConnectionProfileRequest.ProtoReflect.Descriptor instead.

func (*GetConnectionProfileRequest) GetName

func (x *GetConnectionProfileRequest) GetName() string

func (*GetConnectionProfileRequest) ProtoMessage

func (*GetConnectionProfileRequest) ProtoMessage()

func (*GetConnectionProfileRequest) ProtoReflect

func (*GetConnectionProfileRequest) Reset

func (x *GetConnectionProfileRequest) Reset()

func (*GetConnectionProfileRequest) String

func (x *GetConnectionProfileRequest) String() string

GetPrivateConnectionRequest

type GetPrivateConnectionRequest struct {

	// Required. The name of the  private connectivity configuration to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request to get a private connection configuration.

func (*GetPrivateConnectionRequest) Descriptor

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

Deprecated: Use GetPrivateConnectionRequest.ProtoReflect.Descriptor instead.

func (*GetPrivateConnectionRequest) GetName

func (x *GetPrivateConnectionRequest) GetName() string

func (*GetPrivateConnectionRequest) ProtoMessage

func (*GetPrivateConnectionRequest) ProtoMessage()

func (*GetPrivateConnectionRequest) ProtoReflect

func (*GetPrivateConnectionRequest) Reset

func (x *GetPrivateConnectionRequest) Reset()

func (*GetPrivateConnectionRequest) String

func (x *GetPrivateConnectionRequest) String() string

GetRouteRequest

type GetRouteRequest struct {

	// Required. The name of the Route resource to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Route get request.

func (*GetRouteRequest) Descriptor

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

Deprecated: Use GetRouteRequest.ProtoReflect.Descriptor instead.

func (*GetRouteRequest) GetName

func (x *GetRouteRequest) GetName() string

func (*GetRouteRequest) ProtoMessage

func (*GetRouteRequest) ProtoMessage()

func (*GetRouteRequest) ProtoReflect

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

func (*GetRouteRequest) Reset

func (x *GetRouteRequest) Reset()

func (*GetRouteRequest) String

func (x *GetRouteRequest) String() string

GetStreamObjectRequest

type GetStreamObjectRequest struct {

	// Required. The name of the stream object resource to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for fetching a specific stream object.

func (*GetStreamObjectRequest) Descriptor

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

Deprecated: Use GetStreamObjectRequest.ProtoReflect.Descriptor instead.

func (*GetStreamObjectRequest) GetName

func (x *GetStreamObjectRequest) GetName() string

func (*GetStreamObjectRequest) ProtoMessage

func (*GetStreamObjectRequest) ProtoMessage()

func (*GetStreamObjectRequest) ProtoReflect

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

func (*GetStreamObjectRequest) Reset

func (x *GetStreamObjectRequest) Reset()

func (*GetStreamObjectRequest) String

func (x *GetStreamObjectRequest) String() string

GetStreamRequest

type GetStreamRequest struct {

	// Required. The name of the stream resource to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request message for getting a stream.

func (*GetStreamRequest) Descriptor

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

Deprecated: Use GetStreamRequest.ProtoReflect.Descriptor instead.

func (*GetStreamRequest) GetName

func (x *GetStreamRequest) GetName() string

func (*GetStreamRequest) ProtoMessage

func (*GetStreamRequest) ProtoMessage()

func (*GetStreamRequest) ProtoReflect

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

func (*GetStreamRequest) Reset

func (x *GetStreamRequest) Reset()

func (*GetStreamRequest) String

func (x *GetStreamRequest) String() string

JsonFileFormat

type JsonFileFormat struct {
	SchemaFileFormat JsonFileFormat_SchemaFileFormat "" /* 176 byte string literal not displayed */

	Compression JsonFileFormat_JsonCompression "" /* 139 byte string literal not displayed */

}

JSON file format configuration.

func (*JsonFileFormat) Descriptor

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

Deprecated: Use JsonFileFormat.ProtoReflect.Descriptor instead.

func (*JsonFileFormat) GetCompression

func (x *JsonFileFormat) GetCompression() JsonFileFormat_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

JsonFileFormat_JsonCompression

type JsonFileFormat_JsonCompression int32

Json file compression.

JsonFileFormat_JSON_COMPRESSION_UNSPECIFIED, JsonFileFormat_NO_COMPRESSION, JsonFileFormat_GZIP

const (
	// Unspecified json file compression.
	JsonFileFormat_JSON_COMPRESSION_UNSPECIFIED JsonFileFormat_JsonCompression = 0
	// Do not compress JSON file.
	JsonFileFormat_NO_COMPRESSION JsonFileFormat_JsonCompression = 1
	// Gzip compression.
	JsonFileFormat_GZIP JsonFileFormat_JsonCompression = 2
)

func (JsonFileFormat_JsonCompression) Descriptor

func (JsonFileFormat_JsonCompression) Enum

func (JsonFileFormat_JsonCompression) EnumDescriptor

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

Deprecated: Use JsonFileFormat_JsonCompression.Descriptor instead.

func (JsonFileFormat_JsonCompression) Number

func (JsonFileFormat_JsonCompression) String

func (JsonFileFormat_JsonCompression) Type

JsonFileFormat_SchemaFileFormat

type JsonFileFormat_SchemaFileFormat int32

Schema file format.

JsonFileFormat_SCHEMA_FILE_FORMAT_UNSPECIFIED, JsonFileFormat_NO_SCHEMA_FILE, JsonFileFormat_AVRO_SCHEMA_FILE

const (
	// Unspecified schema file format.
	JsonFileFormat_SCHEMA_FILE_FORMAT_UNSPECIFIED JsonFileFormat_SchemaFileFormat = 0
	// Do not attach schema file.
	JsonFileFormat_NO_SCHEMA_FILE JsonFileFormat_SchemaFileFormat = 1
	// Avro schema format.
	JsonFileFormat_AVRO_SCHEMA_FILE JsonFileFormat_SchemaFileFormat = 2
)

func (JsonFileFormat_SchemaFileFormat) Descriptor

func (JsonFileFormat_SchemaFileFormat) Enum

func (JsonFileFormat_SchemaFileFormat) EnumDescriptor

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

Deprecated: Use JsonFileFormat_SchemaFileFormat.Descriptor instead.

func (JsonFileFormat_SchemaFileFormat) Number

func (JsonFileFormat_SchemaFileFormat) String

func (JsonFileFormat_SchemaFileFormat) Type

ListConnectionProfilesRequest

type ListConnectionProfilesRequest struct {

	// Required. The parent that owns the collection of connection profiles.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Maximum number of connection profiles to return.
	// If unspecified, at most 50 connection profiles will be returned.
	// The maximum value is 1000; values above 1000 will be coerced to 1000.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token received from a previous `ListConnectionProfiles` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListConnectionProfiles`
	// must match the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Filter request.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// Order by fields for the result.
	OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

Request message for listing connection profiles.

func (*ListConnectionProfilesRequest) Descriptor

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

Deprecated: Use ListConnectionProfilesRequest.ProtoReflect.Descriptor instead.

func (*ListConnectionProfilesRequest) GetFilter

func (x *ListConnectionProfilesRequest) GetFilter() string

func (*ListConnectionProfilesRequest) GetOrderBy

func (x *ListConnectionProfilesRequest) GetOrderBy() string

func (*ListConnectionProfilesRequest) GetPageSize

func (x *ListConnectionProfilesRequest) GetPageSize() int32

func (*ListConnectionProfilesRequest) GetPageToken

func (x *ListConnectionProfilesRequest) GetPageToken() string

func (*ListConnectionProfilesRequest) GetParent

func (x *ListConnectionProfilesRequest) GetParent() string

func (*ListConnectionProfilesRequest) ProtoMessage

func (*ListConnectionProfilesRequest) ProtoMessage()

func (*ListConnectionProfilesRequest) ProtoReflect

func (*ListConnectionProfilesRequest) Reset

func (x *ListConnectionProfilesRequest) Reset()

func (*ListConnectionProfilesRequest) String

ListConnectionProfilesResponse

type ListConnectionProfilesResponse struct {

	// List of connection profiles.
	ConnectionProfiles []*ConnectionProfile `protobuf:"bytes,1,rep,name=connection_profiles,json=connectionProfiles,proto3" json:"connection_profiles,omitempty"`
	// A token, which can be sent as `page_token` to retrieve the next page.
	// If this field is omitted, there are no subsequent pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Locations that could not be reached.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

Response message for listing connection profiles.

func (*ListConnectionProfilesResponse) Descriptor

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

Deprecated: Use ListConnectionProfilesResponse.ProtoReflect.Descriptor instead.

func (*ListConnectionProfilesResponse) GetConnectionProfiles

func (x *ListConnectionProfilesResponse) GetConnectionProfiles() []*ConnectionProfile

func (*ListConnectionProfilesResponse) GetNextPageToken

func (x *ListConnectionProfilesResponse) GetNextPageToken() string

func (*ListConnectionProfilesResponse) GetUnreachable

func (x *ListConnectionProfilesResponse) GetUnreachable() []string

func (*ListConnectionProfilesResponse) ProtoMessage

func (*ListConnectionProfilesResponse) ProtoMessage()

func (*ListConnectionProfilesResponse) ProtoReflect

func (*ListConnectionProfilesResponse) Reset

func (x *ListConnectionProfilesResponse) Reset()

func (*ListConnectionProfilesResponse) String

ListPrivateConnectionsRequest

type ListPrivateConnectionsRequest struct {

	// Required. The parent that owns the collection of private connectivity
	// configurations.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Maximum number of private connectivity configurations to return.
	// If unspecified, at most 50 private connectivity configurations that will be
	// returned. The maximum value is 1000; values above 1000 will be coerced to
	// 1000.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token received from a previous `ListPrivateConnections` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to
	// `ListPrivateConnections` must match the call that provided the page
	// token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Filter request.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// Order by fields for the result.
	OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

Request for listing private connections.

func (*ListPrivateConnectionsRequest) Descriptor

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

Deprecated: Use ListPrivateConnectionsRequest.ProtoReflect.Descriptor instead.

func (*ListPrivateConnectionsRequest) GetFilter

func (x *ListPrivateConnectionsRequest) GetFilter() string

func (*ListPrivateConnectionsRequest) GetOrderBy

func (x *ListPrivateConnectionsRequest) GetOrderBy() string

func (*ListPrivateConnectionsRequest) GetPageSize

func (x *ListPrivateConnectionsRequest) GetPageSize() int32

func (*ListPrivateConnectionsRequest) GetPageToken

func (x *ListPrivateConnectionsRequest) GetPageToken() string

func (*ListPrivateConnectionsRequest) GetParent

func (x *ListPrivateConnectionsRequest) GetParent() string

func (*ListPrivateConnectionsRequest) ProtoMessage

func (*ListPrivateConnectionsRequest) ProtoMessage()

func (*ListPrivateConnectionsRequest) ProtoReflect

func (*ListPrivateConnectionsRequest) Reset

func (x *ListPrivateConnectionsRequest) Reset()

func (*ListPrivateConnectionsRequest) String

ListPrivateConnectionsResponse

type ListPrivateConnectionsResponse struct {

	// List of private connectivity configurations.
	PrivateConnections []*PrivateConnection `protobuf:"bytes,1,rep,name=private_connections,json=privateConnections,proto3" json:"private_connections,omitempty"`
	// A token, which can be sent as `page_token` to retrieve the next page.
	// If this field is omitted, there are no subsequent pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Locations that could not be reached.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

Response containing a list of private connection configurations.

func (*ListPrivateConnectionsResponse) Descriptor

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

Deprecated: Use ListPrivateConnectionsResponse.ProtoReflect.Descriptor instead.

func (*ListPrivateConnectionsResponse) GetNextPageToken

func (x *ListPrivateConnectionsResponse) GetNextPageToken() string

func (*ListPrivateConnectionsResponse) GetPrivateConnections

func (x *ListPrivateConnectionsResponse) GetPrivateConnections() []*PrivateConnection

func (*ListPrivateConnectionsResponse) GetUnreachable

func (x *ListPrivateConnectionsResponse) GetUnreachable() []string

func (*ListPrivateConnectionsResponse) ProtoMessage

func (*ListPrivateConnectionsResponse) ProtoMessage()

func (*ListPrivateConnectionsResponse) ProtoReflect

func (*ListPrivateConnectionsResponse) Reset

func (x *ListPrivateConnectionsResponse) Reset()

func (*ListPrivateConnectionsResponse) String

ListRoutesRequest

type ListRoutesRequest struct {

	// Required. The parent that owns the collection of Routess.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Maximum number of Routes to return. The service may return
	// fewer than this value. If unspecified, at most 50 Routes
	// will be returned. The maximum value is 1000; values above 1000 will be
	// coerced to 1000.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token received from a previous `ListRoutes` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to
	// `ListRoutes` must match the call that provided the page
	// token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Filter request.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// Order by fields for the result.
	OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

Route list request.

func (*ListRoutesRequest) Descriptor

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

Deprecated: Use ListRoutesRequest.ProtoReflect.Descriptor instead.

func (*ListRoutesRequest) GetFilter

func (x *ListRoutesRequest) GetFilter() string

func (*ListRoutesRequest) GetOrderBy

func (x *ListRoutesRequest) GetOrderBy() string

func (*ListRoutesRequest) GetPageSize

func (x *ListRoutesRequest) GetPageSize() int32

func (*ListRoutesRequest) GetPageToken

func (x *ListRoutesRequest) GetPageToken() string

func (*ListRoutesRequest) GetParent

func (x *ListRoutesRequest) GetParent() string

func (*ListRoutesRequest) ProtoMessage

func (*ListRoutesRequest) ProtoMessage()

func (*ListRoutesRequest) ProtoReflect

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

func (*ListRoutesRequest) Reset

func (x *ListRoutesRequest) Reset()

func (*ListRoutesRequest) String

func (x *ListRoutesRequest) String() string

ListRoutesResponse

type ListRoutesResponse struct {

	// List of Routes.
	Routes []*Route `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
	// A token, which can be sent as `page_token` to retrieve the next page.
	// If this field is omitted, there are no subsequent pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Locations that could not be reached.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

Route list response.

func (*ListRoutesResponse) Descriptor

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

Deprecated: Use ListRoutesResponse.ProtoReflect.Descriptor instead.

func (*ListRoutesResponse) GetNextPageToken

func (x *ListRoutesResponse) GetNextPageToken() string

func (*ListRoutesResponse) GetRoutes

func (x *ListRoutesResponse) GetRoutes() []*Route

func (*ListRoutesResponse) GetUnreachable

func (x *ListRoutesResponse) GetUnreachable() []string

func (*ListRoutesResponse) ProtoMessage

func (*ListRoutesResponse) ProtoMessage()

func (*ListRoutesResponse) ProtoReflect

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

func (*ListRoutesResponse) Reset

func (x *ListRoutesResponse) Reset()

func (*ListRoutesResponse) String

func (x *ListRoutesResponse) String() string

ListStreamObjectsRequest

type ListStreamObjectsRequest struct {

	// Required. The parent stream that owns the collection of objects.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Maximum number of objects to return. Default is 50.
	// The maximum value is 1000; values above 1000 will be coerced to 1000.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token received from a previous `ListStreamObjectsRequest` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to
	// `ListStreamObjectsRequest` must match the call that provided the page
	// token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Request for listing all objects for a specific stream.

func (*ListStreamObjectsRequest) Descriptor

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

Deprecated: Use ListStreamObjectsRequest.ProtoReflect.Descriptor instead.

func (*ListStreamObjectsRequest) GetPageSize

func (x *ListStreamObjectsRequest) GetPageSize() int32

func (*ListStreamObjectsRequest) GetPageToken

func (x *ListStreamObjectsRequest) GetPageToken() string

func (*ListStreamObjectsRequest) GetParent

func (x *ListStreamObjectsRequest) GetParent() string

func (*ListStreamObjectsRequest) ProtoMessage

func (*ListStreamObjectsRequest) ProtoMessage()

func (*ListStreamObjectsRequest) ProtoReflect

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

func (*ListStreamObjectsRequest) Reset

func (x *ListStreamObjectsRequest) Reset()

func (*ListStreamObjectsRequest) String

func (x *ListStreamObjectsRequest) String() string

ListStreamObjectsResponse

type ListStreamObjectsResponse struct {

	// List of stream objects.
	StreamObjects []*StreamObject `protobuf:"bytes,1,rep,name=stream_objects,json=streamObjects,proto3" json:"stream_objects,omitempty"`
	// A token, which can be sent as `page_token` to retrieve the next page.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response containing the objects for a stream.

func (*ListStreamObjectsResponse) Descriptor

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

Deprecated: Use ListStreamObjectsResponse.ProtoReflect.Descriptor instead.

func (*ListStreamObjectsResponse) GetNextPageToken

func (x *ListStreamObjectsResponse) GetNextPageToken() string

func (*ListStreamObjectsResponse) GetStreamObjects

func (x *ListStreamObjectsResponse) GetStreamObjects() []*StreamObject

func (*ListStreamObjectsResponse) ProtoMessage

func (*ListStreamObjectsResponse) ProtoMessage()

func (*ListStreamObjectsResponse) ProtoReflect

func (*ListStreamObjectsResponse) Reset

func (x *ListStreamObjectsResponse) Reset()

func (*ListStreamObjectsResponse) String

func (x *ListStreamObjectsResponse) String() string

ListStreamsRequest

type ListStreamsRequest struct {

	// Required. The parent that owns the collection of streams.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Maximum number of streams to return.
	// If unspecified, at most 50 streams will  be returned. The maximum
	// value is 1000; values above 1000 will be coerced to 1000.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token received from a previous `ListStreams` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListStreams`
	// must match the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Filter request.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// Order by fields for the result.
	OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

Request message for listing streams.

func (*ListStreamsRequest) Descriptor

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

Deprecated: Use ListStreamsRequest.ProtoReflect.Descriptor instead.

func (*ListStreamsRequest) GetFilter

func (x *ListStreamsRequest) GetFilter() string

func (*ListStreamsRequest) GetOrderBy

func (x *ListStreamsRequest) GetOrderBy() string

func (*ListStreamsRequest) GetPageSize

func (x *ListStreamsRequest) GetPageSize() int32

func (*ListStreamsRequest) GetPageToken

func (x *ListStreamsRequest) GetPageToken() string

func (*ListStreamsRequest) GetParent

func (x *ListStreamsRequest) GetParent() string

func (*ListStreamsRequest) ProtoMessage

func (*ListStreamsRequest) ProtoMessage()

func (*ListStreamsRequest) ProtoReflect

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

func (*ListStreamsRequest) Reset

func (x *ListStreamsRequest) Reset()

func (*ListStreamsRequest) String

func (x *ListStreamsRequest) String() string

ListStreamsResponse

type ListStreamsResponse struct {

	// List of streams
	Streams []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	// A token, which can be sent as `page_token` to retrieve the next page.
	// If this field is omitted, there are no subsequent pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Locations that could not be reached.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

Response message for listing streams.

func (*ListStreamsResponse) Descriptor

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

Deprecated: Use ListStreamsResponse.ProtoReflect.Descriptor instead.

func (*ListStreamsResponse) GetNextPageToken

func (x *ListStreamsResponse) GetNextPageToken() string

func (*ListStreamsResponse) GetStreams

func (x *ListStreamsResponse) GetStreams() []*Stream

func (*ListStreamsResponse) GetUnreachable

func (x *ListStreamsResponse) GetUnreachable() []string

func (*ListStreamsResponse) ProtoMessage

func (*ListStreamsResponse) ProtoMessage()

func (*ListStreamsResponse) ProtoReflect

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

func (*ListStreamsResponse) Reset

func (x *ListStreamsResponse) Reset()

func (*ListStreamsResponse) String

func (x *ListStreamsResponse) String() string

LookupStreamObjectRequest

type LookupStreamObjectRequest struct {
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`

	SourceObjectIdentifier *SourceObjectIdentifier "" /* 129 byte string literal not displayed */

}

Request for looking up a specific stream object by its source object identifier.

func (*LookupStreamObjectRequest) Descriptor

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

Deprecated: Use LookupStreamObjectRequest.ProtoReflect.Descriptor instead.

func (*LookupStreamObjectRequest) GetParent

func (x *LookupStreamObjectRequest) GetParent() string

func (*LookupStreamObjectRequest) GetSourceObjectIdentifier

func (x *LookupStreamObjectRequest) GetSourceObjectIdentifier() *SourceObjectIdentifier

func (*LookupStreamObjectRequest) ProtoMessage

func (*LookupStreamObjectRequest) ProtoMessage()

func (*LookupStreamObjectRequest) ProtoReflect

func (*LookupStreamObjectRequest) Reset

func (x *LookupStreamObjectRequest) Reset()

func (*LookupStreamObjectRequest) String

func (x *LookupStreamObjectRequest) String() string

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

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

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

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

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"`
	// Required. Input only. Password for the MySQL connection.
	Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	// SSL configuration for the MySQL connection.
	SslConfig *MysqlSslConfig `protobuf:"bytes,5,opt,name=ssl_config,json=sslConfig,proto3" json:"ssl_config,omitempty"`
	// contains filtered or unexported fields
}

MySQL database profile.

func (*MysqlProfile) Descriptor

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

Deprecated: Use MysqlProfile.ProtoReflect.Descriptor instead.

func (*MysqlProfile) GetHostname

func (x *MysqlProfile) GetHostname() string

func (*MysqlProfile) GetPassword

func (x *MysqlProfile) GetPassword() 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

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

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

MysqlSourceConfig

type MysqlSourceConfig struct {
	IncludeObjects *MysqlRdbms `protobuf:"bytes,1,opt,name=include_objects,json=includeObjects,proto3" json:"include_objects,omitempty"`

	ExcludeObjects *MysqlRdbms `protobuf:"bytes,2,opt,name=exclude_objects,json=excludeObjects,proto3" json:"exclude_objects,omitempty"`

	MaxConcurrentCdcTasks int32 "" /* 129 byte string literal not displayed */

	MaxConcurrentBackfillTasks int32 "" /* 144 byte string literal not displayed */

}

MySQL source configuration

func (*MysqlSourceConfig) Descriptor

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

Deprecated: Use MysqlSourceConfig.ProtoReflect.Descriptor instead.

func (*MysqlSourceConfig) GetExcludeObjects

func (x *MysqlSourceConfig) GetExcludeObjects() *MysqlRdbms

func (*MysqlSourceConfig) GetIncludeObjects

func (x *MysqlSourceConfig) GetIncludeObjects() *MysqlRdbms

func (*MysqlSourceConfig) GetMaxConcurrentBackfillTasks

func (x *MysqlSourceConfig) GetMaxConcurrentBackfillTasks() int32

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

MysqlSslConfig

type MysqlSslConfig struct {

	// Input only. PEM-encoded private key associated with the Client Certificate.
	// If this field is used then the 'client_certificate' and the
	// 'ca_certificate' fields are mandatory.
	ClientKey string `protobuf:"bytes,1,opt,name=client_key,json=clientKey,proto3" json:"client_key,omitempty"`
	// Output only. Indicates whether the client_key field is set.
	ClientKeySet bool `protobuf:"varint,2,opt,name=client_key_set,json=clientKeySet,proto3" json:"client_key_set,omitempty"`
	// Input only. PEM-encoded certificate that will be used by the replica to
	// authenticate against the source database server. If this field is used
	// then the 'client_key' and the 'ca_certificate' fields are mandatory.
	ClientCertificate string `protobuf:"bytes,3,opt,name=client_certificate,json=clientCertificate,proto3" json:"client_certificate,omitempty"`
	// Output only. Indicates whether the client_certificate field is set.
	ClientCertificateSet bool `protobuf:"varint,4,opt,name=client_certificate_set,json=clientCertificateSet,proto3" json:"client_certificate_set,omitempty"`
	// Input only. PEM-encoded certificate of the CA that signed the source
	// database server's certificate.
	CaCertificate string `protobuf:"bytes,5,opt,name=ca_certificate,json=caCertificate,proto3" json:"ca_certificate,omitempty"`
	// Output only. Indicates whether the ca_certificate field is set.
	CaCertificateSet bool `protobuf:"varint,6,opt,name=ca_certificate_set,json=caCertificateSet,proto3" json:"ca_certificate_set,omitempty"`
	// contains filtered or unexported fields
}

MySQL SSL configuration information.

func (*MysqlSslConfig) Descriptor

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

Deprecated: Use MysqlSslConfig.ProtoReflect.Descriptor instead.

func (*MysqlSslConfig) GetCaCertificate

func (x *MysqlSslConfig) GetCaCertificate() string

func (*MysqlSslConfig) GetCaCertificateSet

func (x *MysqlSslConfig) GetCaCertificateSet() bool

func (*MysqlSslConfig) GetClientCertificate

func (x *MysqlSslConfig) GetClientCertificate() string

func (*MysqlSslConfig) GetClientCertificateSet

func (x *MysqlSslConfig) GetClientCertificateSet() bool

func (*MysqlSslConfig) GetClientKey

func (x *MysqlSslConfig) GetClientKey() string

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

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

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

OperationMetadata

type OperationMetadata struct {

	// Output only. The time the operation was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time the operation finished running.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Output only. Server-defined resource path for the target of the operation.
	Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// Output only. Name of the verb executed by the operation.
	Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
	// Output only. Human-readable status of the operation, if any.
	StatusMessage string `protobuf:"bytes,5,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	// Output only. Identifies whether the user has requested cancellation
	// of the operation. Operations that have successfully been cancelled
	// have [Operation.error][] value with a
	// [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
	// `Code.CANCELLED`.
	RequestedCancellation bool `protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
	// Output only. API version used to start the operation.
	ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	// Output only. Results of executed validations if there are any.
	ValidationResult *ValidationResult `protobuf:"bytes,8,opt,name=validation_result,json=validationResult,proto3" json:"validation_result,omitempty"`
	// contains filtered or unexported fields
}

Represents the metadata of the long-running operation.

func (*OperationMetadata) Descriptor

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

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

func (*OperationMetadata) GetApiVersion

func (x *OperationMetadata) GetApiVersion() string

func (*OperationMetadata) GetCreateTime

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

func (*OperationMetadata) GetEndTime

func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp

func (*OperationMetadata) GetRequestedCancellation

func (x *OperationMetadata) GetRequestedCancellation() bool

func (*OperationMetadata) GetStatusMessage

func (x *OperationMetadata) GetStatusMessage() string

func (*OperationMetadata) GetTarget

func (x *OperationMetadata) GetTarget() string

func (*OperationMetadata) GetValidationResult

func (x *OperationMetadata) GetValidationResult() *ValidationResult

func (*OperationMetadata) GetVerb

func (x *OperationMetadata) GetVerb() string

func (*OperationMetadata) ProtoMessage

func (*OperationMetadata) ProtoMessage()

func (*OperationMetadata) ProtoReflect

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

func (*OperationMetadata) Reset

func (x *OperationMetadata) Reset()

func (*OperationMetadata) String

func (x *OperationMetadata) String() string

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

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

OracleProfile

type OracleProfile struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`

	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`

	Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`

	Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`

	DatabaseService string `protobuf:"bytes,5,opt,name=database_service,json=databaseService,proto3" json:"database_service,omitempty"`

	ConnectionAttributes map[string]string "" /* 209 byte string literal not displayed */

}

Oracle database profile.

func (*OracleProfile) Descriptor

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

Deprecated: Use OracleProfile.ProtoReflect.Descriptor instead.

func (*OracleProfile) GetConnectionAttributes

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

func (*OracleProfile) GetDatabaseService

func (x *OracleProfile) GetDatabaseService() string

func (*OracleProfile) GetHostname

func (x *OracleProfile) GetHostname() string

func (*OracleProfile) GetPassword

func (x *OracleProfile) GetPassword() 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

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

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

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

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

OracleSourceConfig

type OracleSourceConfig struct {
	IncludeObjects *OracleRdbms `protobuf:"bytes,1,opt,name=include_objects,json=includeObjects,proto3" json:"include_objects,omitempty"`

	ExcludeObjects *OracleRdbms `protobuf:"bytes,2,opt,name=exclude_objects,json=excludeObjects,proto3" json:"exclude_objects,omitempty"`

	MaxConcurrentCdcTasks int32 "" /* 129 byte string literal not displayed */

	MaxConcurrentBackfillTasks int32 "" /* 144 byte string literal not displayed */

	LargeObjectsHandling isOracleSourceConfig_LargeObjectsHandling `protobuf_oneof:"large_objects_handling"`

}

Oracle data source configuration

func (*OracleSourceConfig) Descriptor

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

Deprecated: Use OracleSourceConfig.ProtoReflect.Descriptor instead.

func (*OracleSourceConfig) GetDropLargeObjects

func (x *OracleSourceConfig) GetDropLargeObjects() *OracleSourceConfig_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) GetMaxConcurrentBackfillTasks

func (x *OracleSourceConfig) GetMaxConcurrentBackfillTasks() int32

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

OracleSourceConfig_DropLargeObjects

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

Configuration to drop large object values.

func (*OracleSourceConfig_DropLargeObjects) Descriptor

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

Deprecated: Use OracleSourceConfig_DropLargeObjects.ProtoReflect.Descriptor instead.

func (*OracleSourceConfig_DropLargeObjects) ProtoMessage

func (*OracleSourceConfig_DropLargeObjects) ProtoMessage()

func (*OracleSourceConfig_DropLargeObjects) ProtoReflect

func (*OracleSourceConfig_DropLargeObjects) Reset

func (*OracleSourceConfig_DropLargeObjects) String

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

OracleSourceConfig_StreamLargeObjects

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

Configuration to stream large object values.

func (*OracleSourceConfig_StreamLargeObjects) Descriptor

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

Deprecated: Use OracleSourceConfig_StreamLargeObjects.ProtoReflect.Descriptor instead.

func (*OracleSourceConfig_StreamLargeObjects) ProtoMessage

func (*OracleSourceConfig_StreamLargeObjects) ProtoMessage()

func (*OracleSourceConfig_StreamLargeObjects) ProtoReflect

func (*OracleSourceConfig_StreamLargeObjects) Reset

func (*OracleSourceConfig_StreamLargeObjects) String

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

OracleTable

type OracleTable struct {

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

Oracle table.

func (*OracleTable) Descriptor

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

Deprecated: Use OracleTable.ProtoReflect.Descriptor instead.

func (*OracleTable) GetOracleColumns

func (x *OracleTable) GetOracleColumns() []*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

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

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

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. Password for the PostgreSQL connection.
	Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	// Required. Database for the PostgreSQL connection.
	Database string `protobuf:"bytes,5,opt,name=database,proto3" json:"database,omitempty"`
	// contains filtered or unexported fields
}

PostgreSQL database profile.

func (*PostgresqlProfile) Descriptor

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

Deprecated: Use PostgresqlProfile.ProtoReflect.Descriptor instead.

func (*PostgresqlProfile) GetDatabase

func (x *PostgresqlProfile) GetDatabase() string

func (*PostgresqlProfile) GetHostname

func (x *PostgresqlProfile) GetHostname() string

func (*PostgresqlProfile) GetPassword

func (x *PostgresqlProfile) GetPassword() 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

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

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

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

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

PostgresqlSourceConfig

type PostgresqlSourceConfig struct {
	IncludeObjects *PostgresqlRdbms `protobuf:"bytes,1,opt,name=include_objects,json=includeObjects,proto3" json:"include_objects,omitempty"`

	ExcludeObjects *PostgresqlRdbms `protobuf:"bytes,2,opt,name=exclude_objects,json=excludeObjects,proto3" json:"exclude_objects,omitempty"`

	ReplicationSlot string `protobuf:"bytes,3,opt,name=replication_slot,json=replicationSlot,proto3" json:"replication_slot,omitempty"`

	Publication string `protobuf:"bytes,4,opt,name=publication,proto3" json:"publication,omitempty"`

	MaxConcurrentBackfillTasks int32 "" /* 144 byte string literal not displayed */

}

PostgreSQL data source configuration

func (*PostgresqlSourceConfig) Descriptor

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

Deprecated: Use PostgresqlSourceConfig.ProtoReflect.Descriptor instead.

func (*PostgresqlSourceConfig) GetExcludeObjects

func (x *PostgresqlSourceConfig) GetExcludeObjects() *PostgresqlRdbms

func (*PostgresqlSourceConfig) GetIncludeObjects

func (x *PostgresqlSourceConfig) GetIncludeObjects() *PostgresqlRdbms

func (*PostgresqlSourceConfig) GetMaxConcurrentBackfillTasks

func (x *PostgresqlSourceConfig) GetMaxConcurrentBackfillTasks() int32

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

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

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

PrivateConnection

type PrivateConnection struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`

	State PrivateConnection_State `protobuf:"varint,6,opt,name=state,proto3,enum=google.cloud.datastream.v1.PrivateConnection_State" json:"state,omitempty"`

	Error *Error `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"`

	VpcPeeringConfig *VpcPeeringConfig `protobuf:"bytes,100,opt,name=vpc_peering_config,json=vpcPeeringConfig,proto3" json:"vpc_peering_config,omitempty"`

}

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

func (*PrivateConnection) Descriptor

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

Deprecated: Use PrivateConnection.ProtoReflect.Descriptor instead.

func (*PrivateConnection) GetCreateTime

func (x *PrivateConnection) GetCreateTime() *timestamppb.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 (*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

PrivateConnection_State

type PrivateConnection_State int32

Private Connection state.

PrivateConnection_STATE_UNSPECIFIED, PrivateConnection_CREATING, PrivateConnection_CREATED, PrivateConnection_FAILED, PrivateConnection_DELETING, PrivateConnection_FAILED_TO_DELETE

const (
	// Unspecified state.
	PrivateConnection_STATE_UNSPECIFIED PrivateConnection_State = 0
	// The private connection is in creation state - creating resources.
	PrivateConnection_CREATING PrivateConnection_State = 1
	// The private connection has been created with all of its resources.
	PrivateConnection_CREATED PrivateConnection_State = 2
	// The private connection creation has failed.
	PrivateConnection_FAILED PrivateConnection_State = 3
	// The private connection is being deleted.
	PrivateConnection_DELETING PrivateConnection_State = 4
	// Delete request has failed, resource is in invalid state.
	PrivateConnection_FAILED_TO_DELETE PrivateConnection_State = 5
)

func (PrivateConnection_State) Descriptor

func (PrivateConnection_State) Enum

func (PrivateConnection_State) EnumDescriptor

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

Deprecated: Use PrivateConnection_State.Descriptor instead.

func (PrivateConnection_State) Number

func (PrivateConnection_State) String

func (x PrivateConnection_State) String() string

func (PrivateConnection_State) 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

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

Route

type Route struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`

	DestinationAddress string `protobuf:"bytes,6,opt,name=destination_address,json=destinationAddress,proto3" json:"destination_address,omitempty"`

	DestinationPort int32 `protobuf:"varint,7,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"`

}

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

func (*Route) Descriptor

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

SourceConfig

type SourceConfig struct {
	SourceConnectionProfile string "" /* 132 byte string literal not displayed */

	SourceStreamConfig isSourceConfig_SourceStreamConfig `protobuf_oneof:"source_stream_config"`

}

The configuration of the stream source.

func (*SourceConfig) Descriptor

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

Deprecated: Use SourceConfig.ProtoReflect.Descriptor instead.

func (*SourceConfig) GetMysqlSourceConfig

func (x *SourceConfig) GetMysqlSourceConfig() *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

SourceConfig_MysqlSourceConfig

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

SourceConfig_OracleSourceConfig

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

SourceConfig_PostgresqlSourceConfig

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

SourceObjectIdentifier

type SourceObjectIdentifier struct {

	// The identifier for an object in the data source.
	//
	// Types that are assignable to SourceIdentifier:
	//	*SourceObjectIdentifier_OracleIdentifier
	//	*SourceObjectIdentifier_MysqlIdentifier
	//	*SourceObjectIdentifier_PostgresqlIdentifier
	SourceIdentifier isSourceObjectIdentifier_SourceIdentifier `protobuf_oneof:"source_identifier"`
	// contains filtered or unexported fields
}

Represents an identifier of an object in the data source.

func (*SourceObjectIdentifier) Descriptor

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

Deprecated: Use SourceObjectIdentifier.ProtoReflect.Descriptor instead.

func (*SourceObjectIdentifier) GetMysqlIdentifier

func (*SourceObjectIdentifier) GetOracleIdentifier

func (*SourceObjectIdentifier) GetPostgresqlIdentifier

func (*SourceObjectIdentifier) GetSourceIdentifier

func (m *SourceObjectIdentifier) GetSourceIdentifier() isSourceObjectIdentifier_SourceIdentifier

func (*SourceObjectIdentifier) ProtoMessage

func (*SourceObjectIdentifier) ProtoMessage()

func (*SourceObjectIdentifier) ProtoReflect

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

func (*SourceObjectIdentifier) Reset

func (x *SourceObjectIdentifier) Reset()

func (*SourceObjectIdentifier) String

func (x *SourceObjectIdentifier) String() string

SourceObjectIdentifier_MysqlIdentifier

type SourceObjectIdentifier_MysqlIdentifier struct {
	// Mysql data source object identifier.
	MysqlIdentifier *SourceObjectIdentifier_MysqlObjectIdentifier `protobuf:"bytes,2,opt,name=mysql_identifier,json=mysqlIdentifier,proto3,oneof"`
}

SourceObjectIdentifier_MysqlObjectIdentifier

type SourceObjectIdentifier_MysqlObjectIdentifier struct {

	// Required. The database name.
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// Required. The table name.
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

Mysql data source object identifier.

func (*SourceObjectIdentifier_MysqlObjectIdentifier) Descriptor

Deprecated: Use SourceObjectIdentifier_MysqlObjectIdentifier.ProtoReflect.Descriptor instead.

func (*SourceObjectIdentifier_MysqlObjectIdentifier) GetDatabase

func (*SourceObjectIdentifier_MysqlObjectIdentifier) GetTable

func (*SourceObjectIdentifier_MysqlObjectIdentifier) ProtoMessage

func (*SourceObjectIdentifier_MysqlObjectIdentifier) ProtoReflect

func (*SourceObjectIdentifier_MysqlObjectIdentifier) Reset

func (*SourceObjectIdentifier_MysqlObjectIdentifier) String

SourceObjectIdentifier_OracleIdentifier

type SourceObjectIdentifier_OracleIdentifier struct {
	// Oracle data source object identifier.
	OracleIdentifier *SourceObjectIdentifier_OracleObjectIdentifier `protobuf:"bytes,1,opt,name=oracle_identifier,json=oracleIdentifier,proto3,oneof"`
}

SourceObjectIdentifier_OracleObjectIdentifier

type SourceObjectIdentifier_OracleObjectIdentifier struct {

	// Required. The schema name.
	Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// Required. The table name.
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

Oracle data source object identifier.

func (*SourceObjectIdentifier_OracleObjectIdentifier) Descriptor

Deprecated: Use SourceObjectIdentifier_OracleObjectIdentifier.ProtoReflect.Descriptor instead.

func (*SourceObjectIdentifier_OracleObjectIdentifier) GetSchema

func (*SourceObjectIdentifier_OracleObjectIdentifier) GetTable

func (*SourceObjectIdentifier_OracleObjectIdentifier) ProtoMessage

func (*SourceObjectIdentifier_OracleObjectIdentifier) ProtoReflect

func (*SourceObjectIdentifier_OracleObjectIdentifier) Reset

func (*SourceObjectIdentifier_OracleObjectIdentifier) String

SourceObjectIdentifier_PostgresqlIdentifier

type SourceObjectIdentifier_PostgresqlIdentifier struct {
	// PostgreSQL data source object identifier.
	PostgresqlIdentifier *SourceObjectIdentifier_PostgresqlObjectIdentifier `protobuf:"bytes,3,opt,name=postgresql_identifier,json=postgresqlIdentifier,proto3,oneof"`
}

SourceObjectIdentifier_PostgresqlObjectIdentifier

type SourceObjectIdentifier_PostgresqlObjectIdentifier struct {

	// Required. The schema name.
	Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// Required. The table name.
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

PostgreSQL data source object identifier.

func (*SourceObjectIdentifier_PostgresqlObjectIdentifier) Descriptor

Deprecated: Use SourceObjectIdentifier_PostgresqlObjectIdentifier.ProtoReflect.Descriptor instead.

func (*SourceObjectIdentifier_PostgresqlObjectIdentifier) GetSchema

func (*SourceObjectIdentifier_PostgresqlObjectIdentifier) GetTable

func (*SourceObjectIdentifier_PostgresqlObjectIdentifier) ProtoMessage

func (*SourceObjectIdentifier_PostgresqlObjectIdentifier) ProtoReflect

func (*SourceObjectIdentifier_PostgresqlObjectIdentifier) Reset

func (*SourceObjectIdentifier_PostgresqlObjectIdentifier) String

StartBackfillJobRequest

type StartBackfillJobRequest struct {

	// Required. The name of the stream object resource to start a backfill job
	// for.
	Object string `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

Request for manually initiating a backfill job for a specific stream object.

func (*StartBackfillJobRequest) Descriptor

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

Deprecated: Use StartBackfillJobRequest.ProtoReflect.Descriptor instead.

func (*StartBackfillJobRequest) GetObject

func (x *StartBackfillJobRequest) GetObject() string

func (*StartBackfillJobRequest) ProtoMessage

func (*StartBackfillJobRequest) ProtoMessage()

func (*StartBackfillJobRequest) ProtoReflect

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

func (*StartBackfillJobRequest) Reset

func (x *StartBackfillJobRequest) Reset()

func (*StartBackfillJobRequest) String

func (x *StartBackfillJobRequest) String() string

StartBackfillJobResponse

type StartBackfillJobResponse struct {

	// The stream object resource a backfill job was started for.
	Object *StreamObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

Response for manually initiating a backfill job for a specific stream object.

func (*StartBackfillJobResponse) Descriptor

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

Deprecated: Use StartBackfillJobResponse.ProtoReflect.Descriptor instead.

func (*StartBackfillJobResponse) GetObject

func (x *StartBackfillJobResponse) GetObject() *StreamObject

func (*StartBackfillJobResponse) ProtoMessage

func (*StartBackfillJobResponse) ProtoMessage()

func (*StartBackfillJobResponse) ProtoReflect

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

func (*StartBackfillJobResponse) Reset

func (x *StartBackfillJobResponse) Reset()

func (*StartBackfillJobResponse) String

func (x *StartBackfillJobResponse) String() string

StaticServiceIpConnectivity

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

Static IP address connectivity. Used when the source database is configured to allow incoming connections from the Datastream public IP addresses for the region specified in the connection profile.

func (*StaticServiceIpConnectivity) Descriptor

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

Deprecated: Use StaticServiceIpConnectivity.ProtoReflect.Descriptor instead.

func (*StaticServiceIpConnectivity) ProtoMessage

func (*StaticServiceIpConnectivity) ProtoMessage()

func (*StaticServiceIpConnectivity) ProtoReflect

func (*StaticServiceIpConnectivity) Reset

func (x *StaticServiceIpConnectivity) Reset()

func (*StaticServiceIpConnectivity) String

func (x *StaticServiceIpConnectivity) String() string

StopBackfillJobRequest

type StopBackfillJobRequest struct {

	// Required. The name of the stream object resource to stop the backfill job
	// for.
	Object string `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

Request for manually stopping a running backfill job for a specific stream object.

func (*StopBackfillJobRequest) Descriptor

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

Deprecated: Use StopBackfillJobRequest.ProtoReflect.Descriptor instead.

func (*StopBackfillJobRequest) GetObject

func (x *StopBackfillJobRequest) GetObject() string

func (*StopBackfillJobRequest) ProtoMessage

func (*StopBackfillJobRequest) ProtoMessage()

func (*StopBackfillJobRequest) ProtoReflect

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

func (*StopBackfillJobRequest) Reset

func (x *StopBackfillJobRequest) Reset()

func (*StopBackfillJobRequest) String

func (x *StopBackfillJobRequest) String() string

StopBackfillJobResponse

type StopBackfillJobResponse struct {

	// The stream object resource the backfill job was stopped for.
	Object *StreamObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

Response for manually stop a backfill job for a specific stream object.

func (*StopBackfillJobResponse) Descriptor

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

Deprecated: Use StopBackfillJobResponse.ProtoReflect.Descriptor instead.

func (*StopBackfillJobResponse) GetObject

func (x *StopBackfillJobResponse) GetObject() *StreamObject

func (*StopBackfillJobResponse) ProtoMessage

func (*StopBackfillJobResponse) ProtoMessage()

func (*StopBackfillJobResponse) ProtoReflect

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

func (*StopBackfillJobResponse) Reset

func (x *StopBackfillJobResponse) Reset()

func (*StopBackfillJobResponse) String

func (x *StopBackfillJobResponse) String() string

Stream

type Stream struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`

	SourceConfig *SourceConfig `protobuf:"bytes,6,opt,name=source_config,json=sourceConfig,proto3" json:"source_config,omitempty"`

	DestinationConfig *DestinationConfig `protobuf:"bytes,7,opt,name=destination_config,json=destinationConfig,proto3" json:"destination_config,omitempty"`

	State Stream_State `protobuf:"varint,8,opt,name=state,proto3,enum=google.cloud.datastream.v1.Stream_State" json:"state,omitempty"`

	BackfillStrategy isStream_BackfillStrategy `protobuf_oneof:"backfill_strategy"`

	Errors []*Error `protobuf:"bytes,9,rep,name=errors,proto3" json:"errors,omitempty"`

	CustomerManagedEncryptionKey *string "" /* 156 byte string literal not displayed */

}

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

func (*Stream) Descriptor

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

StreamObject

type StreamObject struct {

	// Output only. The object resource's name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The creation time of the object.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The last update time of the object.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Required. Display name.
	DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Output only. Active errors on the object.
	Errors []*Error `protobuf:"bytes,6,rep,name=errors,proto3" json:"errors,omitempty"`
	// The latest backfill job that was initiated for the stream object.
	BackfillJob *BackfillJob `protobuf:"bytes,7,opt,name=backfill_job,json=backfillJob,proto3" json:"backfill_job,omitempty"`
	// The object identifier in the data source.
	SourceObject *SourceObjectIdentifier `protobuf:"bytes,8,opt,name=source_object,json=sourceObject,proto3" json:"source_object,omitempty"`
	// contains filtered or unexported fields
}

A specific stream object (e.g a specific DB table).

func (*StreamObject) Descriptor

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

Deprecated: Use StreamObject.ProtoReflect.Descriptor instead.

func (*StreamObject) GetBackfillJob

func (x *StreamObject) GetBackfillJob() *BackfillJob

func (*StreamObject) GetCreateTime

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

func (*StreamObject) GetDisplayName

func (x *StreamObject) GetDisplayName() string

func (*StreamObject) GetErrors

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

func (*StreamObject) GetName

func (x *StreamObject) GetName() string

func (*StreamObject) GetSourceObject

func (x *StreamObject) GetSourceObject() *SourceObjectIdentifier

func (*StreamObject) GetUpdateTime

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

func (*StreamObject) ProtoMessage

func (*StreamObject) ProtoMessage()

func (*StreamObject) ProtoReflect

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

func (*StreamObject) Reset

func (x *StreamObject) Reset()

func (*StreamObject) String

func (x *StreamObject) String() string

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

Stream_BackfillAllStrategy

type Stream_BackfillAllStrategy struct {

	// List of objects to exclude.
	//
	// Types that are assignable to ExcludedObjects:
	//	*Stream_BackfillAllStrategy_OracleExcludedObjects
	//	*Stream_BackfillAllStrategy_MysqlExcludedObjects
	//	*Stream_BackfillAllStrategy_PostgresqlExcludedObjects
	ExcludedObjects isStream_BackfillAllStrategy_ExcludedObjects `protobuf_oneof:"excluded_objects"`
	// contains filtered or unexported fields
}

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

func (*Stream_BackfillAllStrategy) Descriptor

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

Deprecated: Use Stream_BackfillAllStrategy.ProtoReflect.Descriptor instead.

func (*Stream_BackfillAllStrategy) GetExcludedObjects

func (m *Stream_BackfillAllStrategy) GetExcludedObjects() isStream_BackfillAllStrategy_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 (*Stream_BackfillAllStrategy) Reset

func (x *Stream_BackfillAllStrategy) Reset()

func (*Stream_BackfillAllStrategy) String

func (x *Stream_BackfillAllStrategy) String() string

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

Stream_BackfillAllStrategy_OracleExcludedObjects

type Stream_BackfillAllStrategy_OracleExcludedObjects struct {
	// Oracle data source objects to avoid backfilling.
	OracleExcludedObjects *OracleRdbms `protobuf:"bytes,1,opt,name=oracle_excluded_objects,json=oracleExcludedObjects,proto3,oneof"`
}

Stream_BackfillAllStrategy_PostgresqlExcludedObjects

type Stream_BackfillAllStrategy_PostgresqlExcludedObjects struct {
	// PostgreSQL data source objects to avoid backfilling.
	PostgresqlExcludedObjects *PostgresqlRdbms `protobuf:"bytes,3,opt,name=postgresql_excluded_objects,json=postgresqlExcludedObjects,proto3,oneof"`
}

Stream_BackfillNone

type Stream_BackfillNone struct {
	// Do not automatically backfill any objects.
	BackfillNone *Stream_BackfillNoneStrategy `protobuf:"bytes,102,opt,name=backfill_none,json=backfillNone,proto3,oneof"`
}

Stream_BackfillNoneStrategy

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

Backfill strategy to disable automatic backfill for the Stream's objects.

func (*Stream_BackfillNoneStrategy) Descriptor

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

Deprecated: Use Stream_BackfillNoneStrategy.ProtoReflect.Descriptor instead.

func (*Stream_BackfillNoneStrategy) ProtoMessage

func (*Stream_BackfillNoneStrategy) ProtoMessage()

func (*Stream_BackfillNoneStrategy) ProtoReflect

func (*Stream_BackfillNoneStrategy) Reset

func (x *Stream_BackfillNoneStrategy) Reset()

func (*Stream_BackfillNoneStrategy) String

func (x *Stream_BackfillNoneStrategy) String() string

Stream_State

type Stream_State int32

Stream state.

Stream_STATE_UNSPECIFIED, Stream_NOT_STARTED, Stream_RUNNING, Stream_PAUSED, Stream_MAINTENANCE, Stream_FAILED, Stream_FAILED_PERMANENTLY, Stream_STARTING, Stream_DRAINING

const (
	// Unspecified stream state.
	Stream_STATE_UNSPECIFIED Stream_State = 0
	// The stream has been created but has not yet started streaming data.
	Stream_NOT_STARTED Stream_State = 1
	// The stream is running.
	Stream_RUNNING Stream_State = 2
	// The stream is paused.
	Stream_PAUSED Stream_State = 3
	// The stream is in maintenance mode.
	//
	// Updates are rejected on the resource in this state.
	Stream_MAINTENANCE Stream_State = 4
	// The stream is experiencing an error that is preventing data from being
	// streamed.
	Stream_FAILED Stream_State = 5
	// The stream has experienced a terminal failure.
	Stream_FAILED_PERMANENTLY Stream_State = 6
	// The stream is starting, but not yet running.
	Stream_STARTING Stream_State = 7
	// The Stream is no longer reading new events, but still writing events in
	// the buffer.
	Stream_DRAINING Stream_State = 8
)

func (Stream_State) Descriptor

func (Stream_State) Enum

func (x Stream_State) Enum() *Stream_State

func (Stream_State) EnumDescriptor

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

Deprecated: Use Stream_State.Descriptor instead.

func (Stream_State) Number

func (Stream_State) String

func (x Stream_State) String() string

func (Stream_State) Type

UnimplementedDatastreamServer

type UnimplementedDatastreamServer struct {
}

UnimplementedDatastreamServer can be embedded to have forward compatible implementations.

func (*UnimplementedDatastreamServer) CreateConnectionProfile

func (*UnimplementedDatastreamServer) CreatePrivateConnection

func (*UnimplementedDatastreamServer) CreateRoute

func (*UnimplementedDatastreamServer) CreateStream

func (*UnimplementedDatastreamServer) DeleteConnectionProfile

func (*UnimplementedDatastreamServer) DeletePrivateConnection

func (*UnimplementedDatastreamServer) DeleteRoute

func (*UnimplementedDatastreamServer) DeleteStream

func (*UnimplementedDatastreamServer) DiscoverConnectionProfile

func (*UnimplementedDatastreamServer) FetchStaticIps

func (*UnimplementedDatastreamServer) GetConnectionProfile

func (*UnimplementedDatastreamServer) GetPrivateConnection

func (*UnimplementedDatastreamServer) GetRoute

func (*UnimplementedDatastreamServer) GetStream

func (*UnimplementedDatastreamServer) GetStreamObject

func (*UnimplementedDatastreamServer) ListConnectionProfiles

func (*UnimplementedDatastreamServer) ListPrivateConnections

func (*UnimplementedDatastreamServer) ListRoutes

func (*UnimplementedDatastreamServer) ListStreamObjects

func (*UnimplementedDatastreamServer) ListStreams

func (*UnimplementedDatastreamServer) LookupStreamObject

func (*UnimplementedDatastreamServer) StartBackfillJob

func (*UnimplementedDatastreamServer) StopBackfillJob

func (*UnimplementedDatastreamServer) UpdateConnectionProfile

func (*UnimplementedDatastreamServer) UpdateStream

UpdateConnectionProfileRequest

type UpdateConnectionProfileRequest struct {

	// Optional. Field mask is used to specify the fields to be overwritten in the
	// ConnectionProfile resource by the update.
	// The fields specified in the update_mask are relative to the resource, not
	// the full request. A field will be overwritten if it is in the mask. If the
	// user does not provide a mask then all fields will be overwritten.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Required. The connection profile to update.
	ConnectionProfile *ConnectionProfile `protobuf:"bytes,2,opt,name=connection_profile,json=connectionProfile,proto3" json:"connection_profile,omitempty"`
	// Optional. A request ID to identify requests. Specify a unique request ID
	// so that if you must retry your request, the server will know to ignore
	// the request if it has already been completed. The server will guarantee
	// that for at least 60 minutes since the first request.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request ID,
	// the server can check if original operation with the same request ID was
	// received, and if so, will ignore the second request. This prevents clients
	// from accidentally creating duplicate commitments.
	//
	// The request ID must be a valid UUID with the exception that zero UUID is
	// not supported (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Optional. Only validate the connection profile, but don't update any
	// resources. The default is false.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// Optional. Update the connection profile without validating it.
	Force bool `protobuf:"varint,5,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

Connection profile update message.

func (*UpdateConnectionProfileRequest) Descriptor

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

Deprecated: Use UpdateConnectionProfileRequest.ProtoReflect.Descriptor instead.

func (*UpdateConnectionProfileRequest) GetConnectionProfile

func (x *UpdateConnectionProfileRequest) GetConnectionProfile() *ConnectionProfile

func (*UpdateConnectionProfileRequest) GetForce

func (x *UpdateConnectionProfileRequest) GetForce() bool

func (*UpdateConnectionProfileRequest) GetRequestId

func (x *UpdateConnectionProfileRequest) GetRequestId() string

func (*UpdateConnectionProfileRequest) GetUpdateMask

func (*UpdateConnectionProfileRequest) GetValidateOnly

func (x *UpdateConnectionProfileRequest) GetValidateOnly() bool

func (*UpdateConnectionProfileRequest) ProtoMessage

func (*UpdateConnectionProfileRequest) ProtoMessage()

func (*UpdateConnectionProfileRequest) ProtoReflect

func (*UpdateConnectionProfileRequest) Reset

func (x *UpdateConnectionProfileRequest) Reset()

func (*UpdateConnectionProfileRequest) String

UpdateStreamRequest

type UpdateStreamRequest struct {

	// Optional. Field mask is used to specify the fields to be overwritten in the
	// stream resource by the update.
	// The fields specified in the update_mask are relative to the resource, not
	// the full request. A field will be overwritten if it is in the mask. If the
	// user does not provide a mask then all fields will be overwritten.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Required. The stream resource to update.
	Stream *Stream `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
	// Optional. A request ID to identify requests. Specify a unique request ID
	// so that if you must retry your request, the server will know to ignore
	// the request if it has already been completed. The server will guarantee
	// that for at least 60 minutes since the first request.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request ID,
	// the server can check if original operation with the same request ID was
	// received, and if so, will ignore the second request. This prevents clients
	// from accidentally creating duplicate commitments.
	//
	// The request ID must be a valid UUID with the exception that zero UUID is
	// not supported (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Optional. Only validate the stream with the changes, without actually
	// updating it. The default is false.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// Optional. Update the stream without validating it.
	Force bool `protobuf:"varint,5,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

Request message for updating a stream.

func (*UpdateStreamRequest) Descriptor

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

Deprecated: Use UpdateStreamRequest.ProtoReflect.Descriptor instead.

func (*UpdateStreamRequest) GetForce

func (x *UpdateStreamRequest) GetForce() bool

func (*UpdateStreamRequest) GetRequestId

func (x *UpdateStreamRequest) GetRequestId() string

func (*UpdateStreamRequest) GetStream

func (x *UpdateStreamRequest) GetStream() *Stream

func (*UpdateStreamRequest) GetUpdateMask

func (x *UpdateStreamRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateStreamRequest) GetValidateOnly

func (x *UpdateStreamRequest) GetValidateOnly() bool

func (*UpdateStreamRequest) ProtoMessage

func (*UpdateStreamRequest) ProtoMessage()

func (*UpdateStreamRequest) ProtoReflect

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

func (*UpdateStreamRequest) Reset

func (x *UpdateStreamRequest) Reset()

func (*UpdateStreamRequest) String

func (x *UpdateStreamRequest) String() string

Validation

type Validation struct {

	// A short description of the validation.
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	// Validation execution status.
	State Validation_State `protobuf:"varint,2,opt,name=state,proto3,enum=google.cloud.datastream.v1.Validation_State" json:"state,omitempty"`
	// Messages reflecting the validation results.
	Message []*ValidationMessage `protobuf:"bytes,3,rep,name=message,proto3" json:"message,omitempty"`
	// A custom code identifying this validation.
	Code string `protobuf:"bytes,4,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

A validation to perform on a stream.

func (*Validation) Descriptor

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

Deprecated: Use Validation.ProtoReflect.Descriptor instead.

func (*Validation) GetCode

func (x *Validation) GetCode() string

func (*Validation) GetDescription

func (x *Validation) GetDescription() string

func (*Validation) GetMessage

func (x *Validation) GetMessage() []*ValidationMessage

func (*Validation) GetState

func (x *Validation) GetState() Validation_State

func (*Validation) ProtoMessage

func (*Validation) ProtoMessage()

func (*Validation) ProtoReflect

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

func (*Validation) Reset

func (x *Validation) Reset()

func (*Validation) String

func (x *Validation) String() string

ValidationMessage

type ValidationMessage struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`

	Level ValidationMessage_Level `protobuf:"varint,2,opt,name=level,proto3,enum=google.cloud.datastream.v1.ValidationMessage_Level" json:"level,omitempty"`

	Metadata map[string]string "" /* 157 byte string literal not displayed */

	Code string `protobuf:"bytes,4,opt,name=code,proto3" json:"code,omitempty"`

}

Represent user-facing validation result message.

func (*ValidationMessage) Descriptor

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

Deprecated: Use ValidationMessage.ProtoReflect.Descriptor instead.

func (*ValidationMessage) GetCode

func (x *ValidationMessage) GetCode() string

func (*ValidationMessage) GetLevel

func (*ValidationMessage) GetMessage

func (x *ValidationMessage) GetMessage() string

func (*ValidationMessage) GetMetadata

func (x *ValidationMessage) GetMetadata() map[string]string

func (*ValidationMessage) ProtoMessage

func (*ValidationMessage) ProtoMessage()

func (*ValidationMessage) ProtoReflect

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

func (*ValidationMessage) Reset

func (x *ValidationMessage) Reset()

func (*ValidationMessage) String

func (x *ValidationMessage) String() string

ValidationMessage_Level

type ValidationMessage_Level int32

Validation message level.

ValidationMessage_LEVEL_UNSPECIFIED, ValidationMessage_WARNING, ValidationMessage_ERROR

const (
	// Unspecified level.
	ValidationMessage_LEVEL_UNSPECIFIED ValidationMessage_Level = 0
	// Potentially cause issues with the Stream.
	ValidationMessage_WARNING ValidationMessage_Level = 1
	// Definitely cause issues with the Stream.
	ValidationMessage_ERROR ValidationMessage_Level = 2
)

func (ValidationMessage_Level) Descriptor

func (ValidationMessage_Level) Enum

func (ValidationMessage_Level) EnumDescriptor

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

Deprecated: Use ValidationMessage_Level.Descriptor instead.

func (ValidationMessage_Level) Number

func (ValidationMessage_Level) String

func (x ValidationMessage_Level) String() string

func (ValidationMessage_Level) Type

ValidationResult

type ValidationResult struct {

	// A list of validations (includes both executed as well as not executed
	// validations).
	Validations []*Validation `protobuf:"bytes,1,rep,name=validations,proto3" json:"validations,omitempty"`
	// contains filtered or unexported fields
}

Contains the current validation results.

func (*ValidationResult) Descriptor

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

Deprecated: Use ValidationResult.ProtoReflect.Descriptor instead.

func (*ValidationResult) GetValidations

func (x *ValidationResult) GetValidations() []*Validation

func (*ValidationResult) ProtoMessage

func (*ValidationResult) ProtoMessage()

func (*ValidationResult) ProtoReflect

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

func (*ValidationResult) Reset

func (x *ValidationResult) Reset()

func (*ValidationResult) String

func (x *ValidationResult) String() string

Validation_State

type Validation_State int32

Validation execution state.

Validation_STATE_UNSPECIFIED, Validation_NOT_EXECUTED, Validation_FAILED, Validation_PASSED

const (
	// Unspecified state.
	Validation_STATE_UNSPECIFIED Validation_State = 0
	// Validation did not execute.
	Validation_NOT_EXECUTED Validation_State = 1
	// Validation failed.
	Validation_FAILED Validation_State = 2
	// Validation passed.
	Validation_PASSED Validation_State = 3
)

func (Validation_State) Descriptor

func (Validation_State) Enum

func (Validation_State) EnumDescriptor

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

Deprecated: Use Validation_State.Descriptor instead.

func (Validation_State) Number

func (Validation_State) String

func (x Validation_State) String() string

func (Validation_State) 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

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