datastreampb

package
v1.15.1 Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2025 License: Apache-2.0 Imports: 13 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	Datastream_ListConnectionProfiles_FullMethodName    = "/google.cloud.datastream.v1alpha1.Datastream/ListConnectionProfiles"
	Datastream_GetConnectionProfile_FullMethodName      = "/google.cloud.datastream.v1alpha1.Datastream/GetConnectionProfile"
	Datastream_CreateConnectionProfile_FullMethodName   = "/google.cloud.datastream.v1alpha1.Datastream/CreateConnectionProfile"
	Datastream_UpdateConnectionProfile_FullMethodName   = "/google.cloud.datastream.v1alpha1.Datastream/UpdateConnectionProfile"
	Datastream_DeleteConnectionProfile_FullMethodName   = "/google.cloud.datastream.v1alpha1.Datastream/DeleteConnectionProfile"
	Datastream_DiscoverConnectionProfile_FullMethodName = "/google.cloud.datastream.v1alpha1.Datastream/DiscoverConnectionProfile"
	Datastream_ListStreams_FullMethodName               = "/google.cloud.datastream.v1alpha1.Datastream/ListStreams"
	Datastream_GetStream_FullMethodName                 = "/google.cloud.datastream.v1alpha1.Datastream/GetStream"
	Datastream_CreateStream_FullMethodName              = "/google.cloud.datastream.v1alpha1.Datastream/CreateStream"
	Datastream_UpdateStream_FullMethodName              = "/google.cloud.datastream.v1alpha1.Datastream/UpdateStream"
	Datastream_DeleteStream_FullMethodName              = "/google.cloud.datastream.v1alpha1.Datastream/DeleteStream"
	Datastream_FetchErrors_FullMethodName               = "/google.cloud.datastream.v1alpha1.Datastream/FetchErrors"
	Datastream_FetchStaticIps_FullMethodName            = "/google.cloud.datastream.v1alpha1.Datastream/FetchStaticIps"
	Datastream_CreatePrivateConnection_FullMethodName   = "/google.cloud.datastream.v1alpha1.Datastream/CreatePrivateConnection"
	Datastream_GetPrivateConnection_FullMethodName      = "/google.cloud.datastream.v1alpha1.Datastream/GetPrivateConnection"
	Datastream_ListPrivateConnections_FullMethodName    = "/google.cloud.datastream.v1alpha1.Datastream/ListPrivateConnections"
	Datastream_DeletePrivateConnection_FullMethodName   = "/google.cloud.datastream.v1alpha1.Datastream/DeletePrivateConnection"
	Datastream_CreateRoute_FullMethodName               = "/google.cloud.datastream.v1alpha1.Datastream/CreateRoute"
	Datastream_GetRoute_FullMethodName                  = "/google.cloud.datastream.v1alpha1.Datastream/GetRoute"
	Datastream_ListRoutes_FullMethodName                = "/google.cloud.datastream.v1alpha1.Datastream/ListRoutes"
	Datastream_DeleteRoute_FullMethodName               = "/google.cloud.datastream.v1alpha1.Datastream/DeleteRoute"
)

Variables

View Source 
var (
	GcsFileFormat_name = map[int32]string{
		0: "GCS_FILE_FORMAT_UNSPECIFIED",
		1: "AVRO",
	}
	GcsFileFormat_value = map[string]int32{
		"GCS_FILE_FORMAT_UNSPECIFIED": 0,
		"AVRO":                        1,
	}
)

Enum value maps for GcsFileFormat.

View Source 
var (
	SchemaFileFormat_name = map[int32]string{
		0: "SCHEMA_FILE_FORMAT_UNSPECIFIED",
		1: "NO_SCHEMA_FILE",
		2: "AVRO_SCHEMA_FILE",
	}
	SchemaFileFormat_value = map[string]int32{
		"SCHEMA_FILE_FORMAT_UNSPECIFIED": 0,
		"NO_SCHEMA_FILE":                 1,
		"AVRO_SCHEMA_FILE":               2,
	}
)

Enum value maps for SchemaFileFormat.

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

Enum value maps for PrivateConnection_State.

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

Enum value maps for JsonFileFormat_JsonCompression.

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

Enum value maps for Stream_State.

View Source 
var (
	Validation_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "NOT_EXECUTED",
		2: "FAILED",
		3: "PASSED",
	}
	Validation_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"NOT_EXECUTED":       1,
		"FAILED":             2,
		"PASSED":             3,
	}
)

Enum value maps for Validation_Status.

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

View Source 
var Datastream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "google.cloud.datastream.v1alpha1.Datastream",
	HandlerType: (*DatastreamServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListConnectionProfiles",
			Handler:    _Datastream_ListConnectionProfiles_Handler,
		},
		{
			MethodName: "GetConnectionProfile",
			Handler:    _Datastream_GetConnectionProfile_Handler,
		},
		{
			MethodName: "CreateConnectionProfile",
			Handler:    _Datastream_CreateConnectionProfile_Handler,
		},
		{
			MethodName: "UpdateConnectionProfile",
			Handler:    _Datastream_UpdateConnectionProfile_Handler,
		},
		{
			MethodName: "DeleteConnectionProfile",
			Handler:    _Datastream_DeleteConnectionProfile_Handler,
		},
		{
			MethodName: "DiscoverConnectionProfile",
			Handler:    _Datastream_DiscoverConnectionProfile_Handler,
		},
		{
			MethodName: "ListStreams",
			Handler:    _Datastream_ListStreams_Handler,
		},
		{
			MethodName: "GetStream",
			Handler:    _Datastream_GetStream_Handler,
		},
		{
			MethodName: "CreateStream",
			Handler:    _Datastream_CreateStream_Handler,
		},
		{
			MethodName: "UpdateStream",
			Handler:    _Datastream_UpdateStream_Handler,
		},
		{
			MethodName: "DeleteStream",
			Handler:    _Datastream_DeleteStream_Handler,
		},
		{
			MethodName: "FetchErrors",
			Handler:    _Datastream_FetchErrors_Handler,
		},
		{
			MethodName: "FetchStaticIps",
			Handler:    _Datastream_FetchStaticIps_Handler,
		},
		{
			MethodName: "CreatePrivateConnection",
			Handler:    _Datastream_CreatePrivateConnection_Handler,
		},
		{
			MethodName: "GetPrivateConnection",
			Handler:    _Datastream_GetPrivateConnection_Handler,
		},
		{
			MethodName: "ListPrivateConnections",
			Handler:    _Datastream_ListPrivateConnections_Handler,
		},
		{
			MethodName: "DeletePrivateConnection",
			Handler:    _Datastream_DeletePrivateConnection_Handler,
		},
		{
			MethodName: "CreateRoute",
			Handler:    _Datastream_CreateRoute_Handler,
		},
		{
			MethodName: "GetRoute",
			Handler:    _Datastream_GetRoute_Handler,
		},
		{
			MethodName: "ListRoutes",
			Handler:    _Datastream_ListRoutes_Handler,
		},
		{
			MethodName: "DeleteRoute",
			Handler:    _Datastream_DeleteRoute_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "google/cloud/datastream/v1alpha1/datastream.proto",
}

Datastream_ServiceDesc is the grpc.ServiceDesc for Datastream service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_google_cloud_datastream_v1alpha1_datastream_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_datastream_v1alpha1_datastream_resources_proto protoreflect.FileDescriptor

Functions

func RegisterDatastreamServer 

func RegisterDatastreamServer(s grpc.ServiceRegistrar, srv DatastreamServer)

Types

type AvroFileFormat 

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

AVRO file format configuration.

func (*AvroFileFormat) Descriptor deprecated 

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

Deprecated: Use AvroFileFormat.ProtoReflect.Descriptor instead.

func (*AvroFileFormat) ProtoMessage 

func (*AvroFileFormat) ProtoMessage()

func (*AvroFileFormat) ProtoReflect 

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

func (*AvroFileFormat) Reset 

func (x *AvroFileFormat) Reset()

func (*AvroFileFormat) String 

func (x *AvroFileFormat) String() string

type ConnectionProfile 

type ConnectionProfile struct {

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

func (*ConnectionProfile) Descriptor deprecated 

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

Deprecated: Use ConnectionProfile.ProtoReflect.Descriptor instead.

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

func (x *ConnectionProfile) GetNoConnectivity() *NoConnectivitySettings

func (*ConnectionProfile) GetOracleProfile 

func (x *ConnectionProfile) GetOracleProfile() *OracleProfile

func (*ConnectionProfile) GetPrivateConnectivity 

func (x *ConnectionProfile) GetPrivateConnectivity() *PrivateConnectivity

func (*ConnectionProfile) GetProfile 

func (m *ConnectionProfile) GetProfile() isConnectionProfile_Profile

func (*ConnectionProfile) GetStaticServiceIpConnectivity 

func (x *ConnectionProfile) GetStaticServiceIpConnectivity() *StaticServiceIpConnectivity

func (*ConnectionProfile) GetUpdateTime 

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

func (*ConnectionProfile) ProtoMessage 

func (*ConnectionProfile) ProtoMessage()

func (*ConnectionProfile) ProtoReflect 

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

func (*ConnectionProfile) Reset 

func (x *ConnectionProfile) Reset()

func (*ConnectionProfile) String 

func (x *ConnectionProfile) String() string

type ConnectionProfile_ForwardSshConnectivity 

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

type ConnectionProfile_GcsProfile 

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

type ConnectionProfile_MysqlProfile 

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

type ConnectionProfile_NoConnectivity 

type ConnectionProfile_NoConnectivity struct {
	// No connectivity option chosen.
	NoConnectivity *NoConnectivitySettings `protobuf:"bytes,200,opt,name=no_connectivity,json=noConnectivity,proto3,oneof"`
}

type ConnectionProfile_OracleProfile 

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

type ConnectionProfile_PrivateConnectivity 

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

type ConnectionProfile_StaticServiceIpConnectivity 

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

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

func (*CreateConnectionProfileRequest) Descriptor deprecated 

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

func (x *CreateConnectionProfileRequest) GetParent() string

func (*CreateConnectionProfileRequest) GetRequestId 

func (x *CreateConnectionProfileRequest) GetRequestId() string

func (*CreateConnectionProfileRequest) ProtoMessage 

func (*CreateConnectionProfileRequest) ProtoMessage()

func (*CreateConnectionProfileRequest) ProtoReflect 

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

func (*CreateConnectionProfileRequest) Reset 

func (x *CreateConnectionProfileRequest) Reset()

func (*CreateConnectionProfileRequest) String 

func (x *CreateConnectionProfileRequest) String() string

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

func (*CreatePrivateConnectionRequest) Descriptor deprecated 

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

Deprecated: Use CreatePrivateConnectionRequest.ProtoReflect.Descriptor instead.

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 (x *CreatePrivateConnectionRequest) ProtoReflect() protoreflect.Message

func (*CreatePrivateConnectionRequest) Reset 

func (x *CreatePrivateConnectionRequest) Reset()

func (*CreatePrivateConnectionRequest) String 

func (x *CreatePrivateConnectionRequest) String() string

type 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 deprecated 

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

type 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 do not 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
}

func (*CreateStreamRequest) Descriptor deprecated 

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

type 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 under 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 fetch any errors associated with a stream.
	FetchErrors(ctx context.Context, in *FetchErrorsRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// The FetchStaticIps API call exposes the static ips used by Datastream.
	// Typically, a request returns children data objects under
	// a parent data object that's optionally supplied in the request.
	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 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 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDatastreamClient 

func NewDatastreamClient(cc grpc.ClientConnInterface) DatastreamClient

type 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 under 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 fetch any errors associated with a stream.
	FetchErrors(context.Context, *FetchErrorsRequest) (*longrunningpb.Operation, error)
	// The FetchStaticIps API call exposes the static ips used by Datastream.
	// Typically, a request returns children data objects under
	// a parent data object that's optionally supplied in the request.
	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 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 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. All implementations should embed UnimplementedDatastreamServer for forward compatibility

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

func (*DeleteConnectionProfileRequest) Descriptor deprecated 

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

Deprecated: Use DeleteConnectionProfileRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectionProfileRequest) GetName 

func (x *DeleteConnectionProfileRequest) GetName() string

func (*DeleteConnectionProfileRequest) GetRequestId 

func (x *DeleteConnectionProfileRequest) GetRequestId() string

func (*DeleteConnectionProfileRequest) ProtoMessage 

func (*DeleteConnectionProfileRequest) ProtoMessage()

func (*DeleteConnectionProfileRequest) ProtoReflect 

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

func (*DeleteConnectionProfileRequest) Reset 

func (x *DeleteConnectionProfileRequest) Reset()

func (*DeleteConnectionProfileRequest) String 

func (x *DeleteConnectionProfileRequest) String() string

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

func (*DeletePrivateConnectionRequest) Descriptor deprecated 

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

Deprecated: Use DeletePrivateConnectionRequest.ProtoReflect.Descriptor instead.

func (*DeletePrivateConnectionRequest) GetForce 

func (x *DeletePrivateConnectionRequest) GetForce() bool

func (*DeletePrivateConnectionRequest) GetName 

func (x *DeletePrivateConnectionRequest) GetName() string

func (*DeletePrivateConnectionRequest) GetRequestId 

func (x *DeletePrivateConnectionRequest) GetRequestId() string

func (*DeletePrivateConnectionRequest) ProtoMessage 

func (*DeletePrivateConnectionRequest) ProtoMessage()

func (*DeletePrivateConnectionRequest) ProtoReflect 

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

func (*DeletePrivateConnectionRequest) Reset 

func (x *DeletePrivateConnectionRequest) Reset()

func (*DeletePrivateConnectionRequest) String 

func (x *DeletePrivateConnectionRequest) String() string

type 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 deprecated 

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

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

func (*DeleteStreamRequest) Descriptor deprecated 

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

type DestinationConfig 

type DestinationConfig struct {

	// Required. Destination connection profile identifier.
	DestinationConnectionProfileName string `` /* 161-byte string literal not displayed */
	// Stream configuration that is specific to the data destination type.
	//
	// Types that are assignable to DestinationStreamConfig:
	//
	//	*DestinationConfig_GcsDestinationConfig
	DestinationStreamConfig isDestinationConfig_DestinationStreamConfig `protobuf_oneof:"destination_stream_config"`
	// contains filtered or unexported fields
}

The configuration of the stream destination.

func (*DestinationConfig) Descriptor deprecated 

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

Deprecated: Use DestinationConfig.ProtoReflect.Descriptor instead.

func (*DestinationConfig) GetDestinationConnectionProfileName 

func (x *DestinationConfig) GetDestinationConnectionProfileName() string

func (*DestinationConfig) GetDestinationStreamConfig 

func (m *DestinationConfig) GetDestinationStreamConfig() isDestinationConfig_DestinationStreamConfig

func (*DestinationConfig) GetGcsDestinationConfig 

func (x *DestinationConfig) GetGcsDestinationConfig() *GcsDestinationConfig

func (*DestinationConfig) ProtoMessage 

func (*DestinationConfig) ProtoMessage()

func (*DestinationConfig) ProtoReflect 

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

func (*DestinationConfig) Reset 

func (x *DestinationConfig) Reset()

func (*DestinationConfig) String 

func (x *DestinationConfig) String() string

type DestinationConfig_GcsDestinationConfig 

type DestinationConfig_GcsDestinationConfig struct {
	GcsDestinationConfig *GcsDestinationConfig `protobuf:"bytes,100,opt,name=gcs_destination_config,json=gcsDestinationConfig,proto3,oneof"`
}

type DiscoverConnectionProfileRequest 

type DiscoverConnectionProfileRequest struct {

	// Required. The parent resource of the ConnectionProfile 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"`
	// Types that are assignable to Depth:
	//
	//	*DiscoverConnectionProfileRequest_Recursive
	//	*DiscoverConnectionProfileRequest_RecursionDepth
	Depth isDiscoverConnectionProfileRequest_Depth `protobuf_oneof:"depth"`
	// The data object to enrich with child data objects and metadata.
	//
	// Types that are assignable to DataObject:
	//
	//	*DiscoverConnectionProfileRequest_OracleRdbms
	//	*DiscoverConnectionProfileRequest_MysqlRdbms
	DataObject isDiscoverConnectionProfileRequest_DataObject `protobuf_oneof:"data_object"`
	// contains filtered or unexported fields
}

Request message for 'discover' ConnectionProfile request.

func (*DiscoverConnectionProfileRequest) Descriptor deprecated 

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

func (m *DiscoverConnectionProfileRequest) GetDepth() isDiscoverConnectionProfileRequest_Depth

func (*DiscoverConnectionProfileRequest) GetMysqlRdbms 

func (x *DiscoverConnectionProfileRequest) GetMysqlRdbms() *MysqlRdbms

func (*DiscoverConnectionProfileRequest) GetOracleRdbms 

func (x *DiscoverConnectionProfileRequest) GetOracleRdbms() *OracleRdbms

func (*DiscoverConnectionProfileRequest) GetParent 

func (x *DiscoverConnectionProfileRequest) GetParent() string

func (*DiscoverConnectionProfileRequest) GetRecursionDepth 

func (x *DiscoverConnectionProfileRequest) GetRecursionDepth() int32

func (*DiscoverConnectionProfileRequest) GetRecursive 

func (x *DiscoverConnectionProfileRequest) GetRecursive() bool

func (*DiscoverConnectionProfileRequest) GetTarget 

func (m *DiscoverConnectionProfileRequest) GetTarget() isDiscoverConnectionProfileRequest_Target

func (*DiscoverConnectionProfileRequest) ProtoMessage 

func (*DiscoverConnectionProfileRequest) ProtoMessage()

func (*DiscoverConnectionProfileRequest) ProtoReflect 

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

func (*DiscoverConnectionProfileRequest) Reset 

func (x *DiscoverConnectionProfileRequest) Reset()

func (*DiscoverConnectionProfileRequest) String 

func (x *DiscoverConnectionProfileRequest) String() string

type DiscoverConnectionProfileRequest_ConnectionProfile 

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

type DiscoverConnectionProfileRequest_ConnectionProfileName 

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

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

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

type DiscoverConnectionProfileRequest_RecursionDepth 

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

type DiscoverConnectionProfileRequest_Recursive 

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

type 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
	DataObject isDiscoverConnectionProfileResponse_DataObject `protobuf_oneof:"data_object"`
	// contains filtered or unexported fields
}

func (*DiscoverConnectionProfileResponse) Descriptor deprecated 

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

func (*DiscoverConnectionProfileResponse) ProtoMessage()

func (*DiscoverConnectionProfileResponse) ProtoReflect 

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

func (*DiscoverConnectionProfileResponse) Reset 

func (x *DiscoverConnectionProfileResponse) Reset()

func (*DiscoverConnectionProfileResponse) String 

func (x *DiscoverConnectionProfileResponse) String() string

type DiscoverConnectionProfileResponse_MysqlRdbms 

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

type DiscoverConnectionProfileResponse_OracleRdbms 

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

type Error 

type Error struct {

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

Represent a user-facing Error.

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetDetails 

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

func (*Error) GetErrorTime 

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

func (*Error) GetErrorUuid 

func (x *Error) GetErrorUuid() string

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (*Error) GetReason 

func (x *Error) GetReason() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type FetchErrorsRequest 

type FetchErrorsRequest struct {

	// Name of the Stream resource for which to fetch any errors.
	Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	// contains filtered or unexported fields
}

Request message for 'FetchErrors' request.

func (*FetchErrorsRequest) Descriptor deprecated 

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

Deprecated: Use FetchErrorsRequest.ProtoReflect.Descriptor instead.

func (*FetchErrorsRequest) GetStream 

func (x *FetchErrorsRequest) GetStream() string

func (*FetchErrorsRequest) ProtoMessage 

func (*FetchErrorsRequest) ProtoMessage()

func (*FetchErrorsRequest) ProtoReflect 

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

func (*FetchErrorsRequest) Reset 

func (x *FetchErrorsRequest) Reset()

func (*FetchErrorsRequest) String 

func (x *FetchErrorsRequest) String() string

type FetchErrorsResponse 

type FetchErrorsResponse struct {

	// The list of errors on the Stream.
	Errors []*Error `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

Response message for a 'FetchErrors' response.

func (*FetchErrorsResponse) Descriptor deprecated 

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

Deprecated: Use FetchErrorsResponse.ProtoReflect.Descriptor instead.

func (*FetchErrorsResponse) GetErrors 

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

func (*FetchErrorsResponse) ProtoMessage 

func (*FetchErrorsResponse) ProtoMessage()

func (*FetchErrorsResponse) ProtoReflect 

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

func (*FetchErrorsResponse) Reset 

func (x *FetchErrorsResponse) Reset()

func (*FetchErrorsResponse) String 

func (x *FetchErrorsResponse) String() string

type FetchStaticIpsRequest 

type FetchStaticIpsRequest struct {

	// Required. The name resource of the Response type. 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 deprecated 

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

type 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 deprecated 

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

type ForwardSshTunnelConnectivity 

type ForwardSshTunnelConnectivity struct {

	// Required. Hostname for the SSH tunnel.
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Required. Username for the SSH tunnel.
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// Port for the SSH tunnel, default value is 22.
	Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// 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 deprecated 

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 (x *ForwardSshTunnelConnectivity) ProtoReflect() protoreflect.Message

func (*ForwardSshTunnelConnectivity) Reset 

func (x *ForwardSshTunnelConnectivity) Reset()

func (*ForwardSshTunnelConnectivity) String 

func (x *ForwardSshTunnelConnectivity) String() string

type ForwardSshTunnelConnectivity_Password 

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

type ForwardSshTunnelConnectivity_PrivateKey 

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

type GcsDestinationConfig 

type GcsDestinationConfig struct {

	// Path inside the Cloud Storage bucket to write data to.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// File format that data should be written in.
	// Deprecated field - use file_format instead.
	//
	// Deprecated: Marked as deprecated in google/cloud/datastream/v1alpha1/datastream_resources.proto.
	GcsFileFormat GcsFileFormat `` /* 155-byte string literal not displayed */
	// The maximum file size to be saved in the bucket.
	FileRotationMb int32 `protobuf:"varint,3,opt,name=file_rotation_mb,json=fileRotationMb,proto3" json:"file_rotation_mb,omitempty"`
	// The maximum duration for which new events are added before a file is
	// closed and a new file is created.
	FileRotationInterval *durationpb.Duration `protobuf:"bytes,4,opt,name=file_rotation_interval,json=fileRotationInterval,proto3" json:"file_rotation_interval,omitempty"`
	// File Format that the data should be written in.
	//
	// Types that are assignable to FileFormat:
	//
	//	*GcsDestinationConfig_AvroFileFormat
	//	*GcsDestinationConfig_JsonFileFormat
	FileFormat isGcsDestinationConfig_FileFormat `protobuf_oneof:"file_format"`
	// contains filtered or unexported fields
}

Google Cloud Storage destination configuration

func (*GcsDestinationConfig) Descriptor deprecated 

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

Deprecated: Use GcsDestinationConfig.ProtoReflect.Descriptor instead.

func (*GcsDestinationConfig) GetAvroFileFormat 

func (x *GcsDestinationConfig) GetAvroFileFormat() *AvroFileFormat

func (*GcsDestinationConfig) GetFileFormat 

func (m *GcsDestinationConfig) GetFileFormat() isGcsDestinationConfig_FileFormat

func (*GcsDestinationConfig) GetFileRotationInterval 

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

func (*GcsDestinationConfig) GetFileRotationMb 

func (x *GcsDestinationConfig) GetFileRotationMb() int32

func (*GcsDestinationConfig) GetGcsFileFormat deprecated 

func (x *GcsDestinationConfig) GetGcsFileFormat() GcsFileFormat

Deprecated: Marked as deprecated in google/cloud/datastream/v1alpha1/datastream_resources.proto.

func (*GcsDestinationConfig) GetJsonFileFormat 

func (x *GcsDestinationConfig) GetJsonFileFormat() *JsonFileFormat

func (*GcsDestinationConfig) GetPath 

func (x *GcsDestinationConfig) GetPath() string

func (*GcsDestinationConfig) ProtoMessage 

func (*GcsDestinationConfig) ProtoMessage()

func (*GcsDestinationConfig) ProtoReflect 

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

func (*GcsDestinationConfig) Reset 

func (x *GcsDestinationConfig) Reset()

func (*GcsDestinationConfig) String 

func (x *GcsDestinationConfig) String() string

type GcsDestinationConfig_AvroFileFormat 

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

type GcsDestinationConfig_JsonFileFormat 

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

type GcsFileFormat deprecated 

type GcsFileFormat int32

File format in Cloud Storage.

Deprecated: Marked as deprecated in google/cloud/datastream/v1alpha1/datastream_resources.proto. 

const (
	// Unspecified Cloud Storage file format.
	GcsFileFormat_GCS_FILE_FORMAT_UNSPECIFIED GcsFileFormat = 0
	// Avro file format
	GcsFileFormat_AVRO GcsFileFormat = 1
)

func (GcsFileFormat) Descriptor 

func (GcsFileFormat) Descriptor() protoreflect.EnumDescriptor

func (GcsFileFormat) Enum 

func (x GcsFileFormat) Enum() *GcsFileFormat

func (GcsFileFormat) EnumDescriptor deprecated 

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

Deprecated: Use GcsFileFormat.Descriptor instead.

func (GcsFileFormat) Number 

func (x GcsFileFormat) Number() protoreflect.EnumNumber

func (GcsFileFormat) String 

func (x GcsFileFormat) String() string

func (GcsFileFormat) Type 

func (GcsFileFormat) Type() protoreflect.EnumType

type GcsProfile 

type GcsProfile struct {

	// Required. The full project and resource path for Cloud Storage bucket including the
	// name.
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// The root path inside the Cloud Storage bucket.
	RootPath string `protobuf:"bytes,2,opt,name=root_path,json=rootPath,proto3" json:"root_path,omitempty"`
	// contains filtered or unexported fields
}

Cloud Storage bucket profile.

func (*GcsProfile) Descriptor deprecated 

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

Deprecated: Use GcsProfile.ProtoReflect.Descriptor instead.

func (*GcsProfile) GetBucketName 

func (x *GcsProfile) GetBucketName() string

func (*GcsProfile) GetRootPath 

func (x *GcsProfile) GetRootPath() string

func (*GcsProfile) ProtoMessage 

func (*GcsProfile) ProtoMessage()

func (*GcsProfile) ProtoReflect 

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

func (*GcsProfile) Reset 

func (x *GcsProfile) Reset()

func (*GcsProfile) String 

func (x *GcsProfile) String() string

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

func (*GetConnectionProfileRequest) Descriptor deprecated 

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 (x *GetConnectionProfileRequest) ProtoReflect() protoreflect.Message

func (*GetConnectionProfileRequest) Reset 

func (x *GetConnectionProfileRequest) Reset()

func (*GetConnectionProfileRequest) String 

func (x *GetConnectionProfileRequest) String() string

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

func (*GetPrivateConnectionRequest) Descriptor deprecated 

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 (x *GetPrivateConnectionRequest) ProtoReflect() protoreflect.Message

func (*GetPrivateConnectionRequest) Reset 

func (x *GetPrivateConnectionRequest) Reset()

func (*GetPrivateConnectionRequest) String 

func (x *GetPrivateConnectionRequest) String() string

type 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 deprecated 

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

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

func (*GetStreamRequest) Descriptor deprecated 

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

type JsonFileFormat 

type JsonFileFormat struct {

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

JSON file format configuration.

func (*JsonFileFormat) Descriptor deprecated 

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

Deprecated: Use JsonFileFormat.ProtoReflect.Descriptor instead.

func (*JsonFileFormat) GetCompression 

func (x *JsonFileFormat) GetCompression() JsonFileFormat_JsonCompression

func (*JsonFileFormat) GetSchemaFileFormat 

func (x *JsonFileFormat) GetSchemaFileFormat() SchemaFileFormat

func (*JsonFileFormat) ProtoMessage 

func (*JsonFileFormat) ProtoMessage()

func (*JsonFileFormat) ProtoReflect 

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

func (*JsonFileFormat) Reset 

func (x *JsonFileFormat) Reset()

func (*JsonFileFormat) String 

func (x *JsonFileFormat) String() string

type JsonFileFormat_JsonCompression 

type JsonFileFormat_JsonCompression int32

Json file compression. 

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

func (JsonFileFormat_JsonCompression) Descriptor 

func (JsonFileFormat_JsonCompression) Descriptor() protoreflect.EnumDescriptor

func (JsonFileFormat_JsonCompression) Enum 

func (x JsonFileFormat_JsonCompression) Enum() *JsonFileFormat_JsonCompression

func (JsonFileFormat_JsonCompression) EnumDescriptor deprecated 

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

Deprecated: Use JsonFileFormat_JsonCompression.Descriptor instead.

func (JsonFileFormat_JsonCompression) Number 

func (x JsonFileFormat_JsonCompression) Number() protoreflect.EnumNumber

func (JsonFileFormat_JsonCompression) String 

func (x JsonFileFormat_JsonCompression) String() string

func (JsonFileFormat_JsonCompression) Type 

func (JsonFileFormat_JsonCompression) Type() protoreflect.EnumType

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

func (*ListConnectionProfilesRequest) Descriptor deprecated 

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 (x *ListConnectionProfilesRequest) ProtoReflect() protoreflect.Message

func (*ListConnectionProfilesRequest) Reset 

func (x *ListConnectionProfilesRequest) Reset()

func (*ListConnectionProfilesRequest) String 

func (x *ListConnectionProfilesRequest) String() string

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

func (*ListConnectionProfilesResponse) Descriptor deprecated 

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 (x *ListConnectionProfilesResponse) ProtoReflect() protoreflect.Message

func (*ListConnectionProfilesResponse) Reset 

func (x *ListConnectionProfilesResponse) Reset()

func (*ListConnectionProfilesResponse) String 

func (x *ListConnectionProfilesResponse) String() string

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

func (*ListPrivateConnectionsRequest) Descriptor deprecated 

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 (x *ListPrivateConnectionsRequest) ProtoReflect() protoreflect.Message

func (*ListPrivateConnectionsRequest) Reset 

func (x *ListPrivateConnectionsRequest) Reset()

func (*ListPrivateConnectionsRequest) String 

func (x *ListPrivateConnectionsRequest) String() string

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

func (*ListPrivateConnectionsResponse) Descriptor deprecated 

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 (x *ListPrivateConnectionsResponse) ProtoReflect() protoreflect.Message

func (*ListPrivateConnectionsResponse) Reset 

func (x *ListPrivateConnectionsResponse) Reset()

func (*ListPrivateConnectionsResponse) String 

func (x *ListPrivateConnectionsResponse) String() string

type 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 deprecated 

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

type 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 deprecated 

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

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

func (*ListStreamsRequest) Descriptor deprecated 

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

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

func (*ListStreamsResponse) Descriptor deprecated 

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

type MysqlColumn 

type MysqlColumn struct {

	// Column name.
	ColumnName string `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	// The MySQL data type. Full data types list can be found here:
	// https://dev.mysql.com/doc/refman/8.0/en/data-types.html
	DataType string `protobuf:"bytes,2,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty"`
	// Column length.
	Length int32 `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	// Column collation.
	Collation string `protobuf:"bytes,4,opt,name=collation,proto3" json:"collation,omitempty"`
	// Whether or not the column represents a primary key.
	PrimaryKey bool `protobuf:"varint,5,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	// Whether or not the column can accept a null value.
	Nullable bool `protobuf:"varint,6,opt,name=nullable,proto3" json:"nullable,omitempty"`
	// The ordinal position of the column in the table.
	OrdinalPosition int32 `protobuf:"varint,7,opt,name=ordinal_position,json=ordinalPosition,proto3" json:"ordinal_position,omitempty"`
	// contains filtered or unexported fields
}

MySQL Column.

func (*MysqlColumn) Descriptor deprecated 

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

Deprecated: Use MysqlColumn.ProtoReflect.Descriptor instead.

func (*MysqlColumn) GetCollation 

func (x *MysqlColumn) GetCollation() string

func (*MysqlColumn) GetColumnName 

func (x *MysqlColumn) GetColumnName() string

func (*MysqlColumn) GetDataType 

func (x *MysqlColumn) GetDataType() string

func (*MysqlColumn) GetLength 

func (x *MysqlColumn) GetLength() int32

func (*MysqlColumn) GetNullable 

func (x *MysqlColumn) GetNullable() bool

func (*MysqlColumn) GetOrdinalPosition 

func (x *MysqlColumn) GetOrdinalPosition() int32

func (*MysqlColumn) GetPrimaryKey 

func (x *MysqlColumn) GetPrimaryKey() bool

func (*MysqlColumn) ProtoMessage 

func (*MysqlColumn) ProtoMessage()

func (*MysqlColumn) ProtoReflect 

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

func (*MysqlColumn) Reset 

func (x *MysqlColumn) Reset()

func (*MysqlColumn) String 

func (x *MysqlColumn) String() string

type MysqlDatabase 

type MysqlDatabase struct {

	// Database name.
	DatabaseName string `protobuf:"bytes,1,opt,name=database_name,json=databaseName,proto3" json:"database_name,omitempty"`
	// Tables in the database.
	MysqlTables []*MysqlTable `protobuf:"bytes,2,rep,name=mysql_tables,json=mysqlTables,proto3" json:"mysql_tables,omitempty"`
	// contains filtered or unexported fields
}

MySQL database.

func (*MysqlDatabase) Descriptor deprecated 

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

Deprecated: Use MysqlDatabase.ProtoReflect.Descriptor instead.

func (*MysqlDatabase) GetDatabaseName 

func (x *MysqlDatabase) GetDatabaseName() string

func (*MysqlDatabase) GetMysqlTables 

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

func (*MysqlDatabase) ProtoMessage 

func (*MysqlDatabase) ProtoMessage()

func (*MysqlDatabase) ProtoReflect 

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

func (*MysqlDatabase) Reset 

func (x *MysqlDatabase) Reset()

func (*MysqlDatabase) String 

func (x *MysqlDatabase) String() string

type MysqlProfile 

type MysqlProfile struct {

	// Required. Hostname for the MySQL connection.
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Port for the MySQL connection, default value is 3306.
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Required. Username for the MySQL connection.
	Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	// 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 deprecated 

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

type MysqlRdbms 

type MysqlRdbms struct {

	// Mysql databases on the server
	MysqlDatabases []*MysqlDatabase `protobuf:"bytes,1,rep,name=mysql_databases,json=mysqlDatabases,proto3" json:"mysql_databases,omitempty"`
	// contains filtered or unexported fields
}

MySQL database structure

func (*MysqlRdbms) Descriptor deprecated 

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

Deprecated: Use MysqlRdbms.ProtoReflect.Descriptor instead.

func (*MysqlRdbms) GetMysqlDatabases 

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

func (*MysqlRdbms) ProtoMessage 

func (*MysqlRdbms) ProtoMessage()

func (*MysqlRdbms) ProtoReflect 

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

func (*MysqlRdbms) Reset 

func (x *MysqlRdbms) Reset()

func (*MysqlRdbms) String 

func (x *MysqlRdbms) String() string

type MysqlSourceConfig 

type MysqlSourceConfig struct {

	// MySQL objects to retrieve from the source.
	Allowlist *MysqlRdbms `protobuf:"bytes,1,opt,name=allowlist,proto3" json:"allowlist,omitempty"`
	// MySQL objects to exclude from the stream.
	Rejectlist *MysqlRdbms `protobuf:"bytes,2,opt,name=rejectlist,proto3" json:"rejectlist,omitempty"`
	// contains filtered or unexported fields
}

MySQL source configuration

func (*MysqlSourceConfig) Descriptor deprecated 

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

Deprecated: Use MysqlSourceConfig.ProtoReflect.Descriptor instead.

func (*MysqlSourceConfig) GetAllowlist 

func (x *MysqlSourceConfig) GetAllowlist() *MysqlRdbms

func (*MysqlSourceConfig) GetRejectlist 

func (x *MysqlSourceConfig) GetRejectlist() *MysqlRdbms

func (*MysqlSourceConfig) ProtoMessage 

func (*MysqlSourceConfig) ProtoMessage()

func (*MysqlSourceConfig) ProtoReflect 

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

func (*MysqlSourceConfig) Reset 

func (x *MysqlSourceConfig) Reset()

func (*MysqlSourceConfig) String 

func (x *MysqlSourceConfig) String() string

type MysqlSslConfig 

type MysqlSslConfig struct {

	// 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,11,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,12,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,13,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,14,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,15,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,16,opt,name=ca_certificate_set,json=caCertificateSet,proto3" json:"ca_certificate_set,omitempty"`
	// contains filtered or unexported fields
}

MySQL SSL configuration information.

func (*MysqlSslConfig) Descriptor deprecated 

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

Deprecated: Use MysqlSslConfig.ProtoReflect.Descriptor instead.

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

type MysqlTable 

type MysqlTable struct {

	// Table name.
	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// MySQL columns in the database.
	// When unspecified as part of include/exclude lists, includes/excludes
	// everything.
	MysqlColumns []*MysqlColumn `protobuf:"bytes,2,rep,name=mysql_columns,json=mysqlColumns,proto3" json:"mysql_columns,omitempty"`
	// contains filtered or unexported fields
}

MySQL table.

func (*MysqlTable) Descriptor deprecated 

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

Deprecated: Use MysqlTable.ProtoReflect.Descriptor instead.

func (*MysqlTable) GetMysqlColumns 

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

func (*MysqlTable) GetTableName 

func (x *MysqlTable) GetTableName() string

func (*MysqlTable) ProtoMessage 

func (*MysqlTable) ProtoMessage()

func (*MysqlTable) ProtoReflect 

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

func (*MysqlTable) Reset 

func (x *MysqlTable) Reset()

func (*MysqlTable) String 

func (x *MysqlTable) String() string

type NoConnectivitySettings 

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

No connectivity settings.

func (*NoConnectivitySettings) Descriptor deprecated 

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

Deprecated: Use NoConnectivitySettings.ProtoReflect.Descriptor instead.

func (*NoConnectivitySettings) ProtoMessage 

func (*NoConnectivitySettings) ProtoMessage()

func (*NoConnectivitySettings) ProtoReflect 

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

func (*NoConnectivitySettings) Reset 

func (x *NoConnectivitySettings) Reset()

func (*NoConnectivitySettings) String 

func (x *NoConnectivitySettings) String() string

type 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 deprecated 

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

type OracleColumn 

type OracleColumn struct {

	// Column name.
	ColumnName string `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	// The Oracle data type.
	DataType string `protobuf:"bytes,2,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty"`
	// Column length.
	Length int32 `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	// Column precision.
	Precision int32 `protobuf:"varint,4,opt,name=precision,proto3" json:"precision,omitempty"`
	// Column scale.
	Scale int32 `protobuf:"varint,5,opt,name=scale,proto3" json:"scale,omitempty"`
	// Column encoding.
	Encoding string `protobuf:"bytes,6,opt,name=encoding,proto3" json:"encoding,omitempty"`
	// Whether or not the column represents a primary key.
	PrimaryKey bool `protobuf:"varint,7,opt,name=primary_key,json=primaryKey,proto3" json:"primary_key,omitempty"`
	// Whether or not the column can accept a null value.
	Nullable bool `protobuf:"varint,8,opt,name=nullable,proto3" json:"nullable,omitempty"`
	// The ordinal position of the column in the table.
	OrdinalPosition int32 `protobuf:"varint,9,opt,name=ordinal_position,json=ordinalPosition,proto3" json:"ordinal_position,omitempty"`
	// contains filtered or unexported fields
}

Oracle Column.

func (*OracleColumn) Descriptor deprecated 

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

Deprecated: Use OracleColumn.ProtoReflect.Descriptor instead.

func (*OracleColumn) GetColumnName 

func (x *OracleColumn) GetColumnName() string

func (*OracleColumn) GetDataType 

func (x *OracleColumn) GetDataType() string

func (*OracleColumn) GetEncoding 

func (x *OracleColumn) GetEncoding() string

func (*OracleColumn) GetLength 

func (x *OracleColumn) GetLength() int32

func (*OracleColumn) GetNullable 

func (x *OracleColumn) GetNullable() bool

func (*OracleColumn) GetOrdinalPosition 

func (x *OracleColumn) GetOrdinalPosition() int32

func (*OracleColumn) GetPrecision 

func (x *OracleColumn) GetPrecision() int32

func (*OracleColumn) GetPrimaryKey 

func (x *OracleColumn) GetPrimaryKey() bool

func (*OracleColumn) GetScale 

func (x *OracleColumn) GetScale() int32

func (*OracleColumn) ProtoMessage 

func (*OracleColumn) ProtoMessage()

func (*OracleColumn) ProtoReflect 

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

func (*OracleColumn) Reset 

func (x *OracleColumn) Reset()

func (*OracleColumn) String 

func (x *OracleColumn) String() string

type OracleProfile 

type OracleProfile struct {

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

Oracle database profile.

func (*OracleProfile) Descriptor deprecated 

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

Deprecated: Use OracleProfile.ProtoReflect.Descriptor instead.

func (*OracleProfile) GetConnectionAttributes 

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

func (*OracleProfile) GetDatabaseService 

func (x *OracleProfile) GetDatabaseService() string

func (*OracleProfile) GetHostname 

func (x *OracleProfile) GetHostname() string

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

type OracleRdbms 

type OracleRdbms struct {

	// Oracle schemas/databases in the database server.
	OracleSchemas []*OracleSchema `protobuf:"bytes,1,rep,name=oracle_schemas,json=oracleSchemas,proto3" json:"oracle_schemas,omitempty"`
	// contains filtered or unexported fields
}

Oracle database structure.

func (*OracleRdbms) Descriptor deprecated 

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

Deprecated: Use OracleRdbms.ProtoReflect.Descriptor instead.

func (*OracleRdbms) GetOracleSchemas 

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

func (*OracleRdbms) ProtoMessage 

func (*OracleRdbms) ProtoMessage()

func (*OracleRdbms) ProtoReflect 

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

func (*OracleRdbms) Reset 

func (x *OracleRdbms) Reset()

func (*OracleRdbms) String 

func (x *OracleRdbms) String() string

type OracleSchema 

type OracleSchema struct {

	// Schema name.
	SchemaName string `protobuf:"bytes,1,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	// Tables in the schema.
	OracleTables []*OracleTable `protobuf:"bytes,2,rep,name=oracle_tables,json=oracleTables,proto3" json:"oracle_tables,omitempty"`
	// contains filtered or unexported fields
}

Oracle schema.

func (*OracleSchema) Descriptor deprecated 

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

Deprecated: Use OracleSchema.ProtoReflect.Descriptor instead.

func (*OracleSchema) GetOracleTables 

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

func (*OracleSchema) GetSchemaName 

func (x *OracleSchema) GetSchemaName() string

func (*OracleSchema) ProtoMessage 

func (*OracleSchema) ProtoMessage()

func (*OracleSchema) ProtoReflect 

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

func (*OracleSchema) Reset 

func (x *OracleSchema) Reset()

func (*OracleSchema) String 

func (x *OracleSchema) String() string

type OracleSourceConfig 

type OracleSourceConfig struct {

	// Oracle objects to include in the stream.
	Allowlist *OracleRdbms `protobuf:"bytes,1,opt,name=allowlist,proto3" json:"allowlist,omitempty"`
	// Oracle objects to exclude from the stream.
	Rejectlist *OracleRdbms `protobuf:"bytes,2,opt,name=rejectlist,proto3" json:"rejectlist,omitempty"`
	// contains filtered or unexported fields
}

Oracle data source configuration

func (*OracleSourceConfig) Descriptor deprecated 

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

Deprecated: Use OracleSourceConfig.ProtoReflect.Descriptor instead.

func (*OracleSourceConfig) GetAllowlist 

func (x *OracleSourceConfig) GetAllowlist() *OracleRdbms

func (*OracleSourceConfig) GetRejectlist 

func (x *OracleSourceConfig) GetRejectlist() *OracleRdbms

func (*OracleSourceConfig) ProtoMessage 

func (*OracleSourceConfig) ProtoMessage()

func (*OracleSourceConfig) ProtoReflect 

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

func (*OracleSourceConfig) Reset 

func (x *OracleSourceConfig) Reset()

func (*OracleSourceConfig) String 

func (x *OracleSourceConfig) String() string

type OracleTable 

type OracleTable struct {

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

Oracle table.

func (*OracleTable) Descriptor deprecated 

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

Deprecated: Use OracleTable.ProtoReflect.Descriptor instead.

func (*OracleTable) GetOracleColumns 

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

func (*OracleTable) GetTableName 

func (x *OracleTable) GetTableName() string

func (*OracleTable) ProtoMessage 

func (*OracleTable) ProtoMessage()

func (*OracleTable) ProtoReflect 

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

func (*OracleTable) Reset 

func (x *OracleTable) Reset()

func (*OracleTable) String 

func (x *OracleTable) String() string

type PrivateConnection 

type PrivateConnection struct {

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

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

func (*PrivateConnection) Descriptor deprecated 

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

Deprecated: Use PrivateConnection.ProtoReflect.Descriptor instead.

func (*PrivateConnection) GetCreateTime 

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

func (*PrivateConnection) GetDisplayName 

func (x *PrivateConnection) GetDisplayName() string

func (*PrivateConnection) GetError 

func (x *PrivateConnection) GetError() *Error

func (*PrivateConnection) GetLabels 

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

func (*PrivateConnection) GetName 

func (x *PrivateConnection) GetName() string

func (*PrivateConnection) GetState 

func (x *PrivateConnection) GetState() PrivateConnection_State

func (*PrivateConnection) GetUpdateTime 

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

func (*PrivateConnection) GetVpcPeeringConfig 

func (x *PrivateConnection) GetVpcPeeringConfig() *VpcPeeringConfig

func (*PrivateConnection) ProtoMessage 

func (*PrivateConnection) ProtoMessage()

func (*PrivateConnection) ProtoReflect 

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

func (*PrivateConnection) Reset 

func (x *PrivateConnection) Reset()

func (*PrivateConnection) String 

func (x *PrivateConnection) String() string

type PrivateConnection_State 

type PrivateConnection_State int32

Private Connection state. 

const (
	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 it's resources.
	PrivateConnection_CREATED PrivateConnection_State = 2
	// The private connection creation has failed.
	PrivateConnection_FAILED PrivateConnection_State = 3
)

func (PrivateConnection_State) Descriptor 

func (PrivateConnection_State) Descriptor() protoreflect.EnumDescriptor

func (PrivateConnection_State) Enum 

func (x PrivateConnection_State) Enum() *PrivateConnection_State

func (PrivateConnection_State) EnumDescriptor deprecated 

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

Deprecated: Use PrivateConnection_State.Descriptor instead.

func (PrivateConnection_State) Number 

func (x PrivateConnection_State) Number() protoreflect.EnumNumber

func (PrivateConnection_State) String 

func (x PrivateConnection_State) String() string

func (PrivateConnection_State) Type 

func (PrivateConnection_State) Type() protoreflect.EnumType

type PrivateConnectivity 

type PrivateConnectivity struct {
	PrivateConnectionName string `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

Private Connectivity

func (*PrivateConnectivity) Descriptor deprecated 

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

Deprecated: Use PrivateConnectivity.ProtoReflect.Descriptor instead.

func (*PrivateConnectivity) GetPrivateConnectionName 

func (x *PrivateConnectivity) GetPrivateConnectionName() string

func (*PrivateConnectivity) ProtoMessage 

func (*PrivateConnectivity) ProtoMessage()

func (*PrivateConnectivity) ProtoReflect 

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

func (*PrivateConnectivity) Reset 

func (x *PrivateConnectivity) Reset()

func (*PrivateConnectivity) String 

func (x *PrivateConnectivity) String() string

type Route 

type Route struct {

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

The Route resource is the child of the PrivateConnection resource. It used to define a route for a PrivateConnection setup.

func (*Route) Descriptor deprecated 

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

Deprecated: Use Route.ProtoReflect.Descriptor instead.

func (*Route) GetCreateTime 

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

func (*Route) GetDestinationAddress 

func (x *Route) GetDestinationAddress() string

func (*Route) GetDestinationPort 

func (x *Route) GetDestinationPort() int32

func (*Route) GetDisplayName 

func (x *Route) GetDisplayName() string

func (*Route) GetLabels 

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

func (*Route) GetName 

func (x *Route) GetName() string

func (*Route) GetUpdateTime 

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

func (*Route) ProtoMessage 

func (*Route) ProtoMessage()

func (*Route) ProtoReflect 

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

func (*Route) Reset 

func (x *Route) Reset()

func (*Route) String 

func (x *Route) String() string

type SchemaFileFormat 

type SchemaFileFormat int32

Schema file format. 

const (
	// Unspecified schema file format.
	SchemaFileFormat_SCHEMA_FILE_FORMAT_UNSPECIFIED SchemaFileFormat = 0
	// Do not attach schema file.
	SchemaFileFormat_NO_SCHEMA_FILE SchemaFileFormat = 1
	// Avro schema format.
	SchemaFileFormat_AVRO_SCHEMA_FILE SchemaFileFormat = 2
)

func (SchemaFileFormat) Descriptor 

func (SchemaFileFormat) Descriptor() protoreflect.EnumDescriptor

func (SchemaFileFormat) Enum 

func (x SchemaFileFormat) Enum() *SchemaFileFormat

func (SchemaFileFormat) EnumDescriptor deprecated 

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

Deprecated: Use SchemaFileFormat.Descriptor instead.

func (SchemaFileFormat) Number 

func (x SchemaFileFormat) Number() protoreflect.EnumNumber

func (SchemaFileFormat) String 

func (x SchemaFileFormat) String() string

func (SchemaFileFormat) Type 

func (SchemaFileFormat) Type() protoreflect.EnumType

type SourceConfig 

type SourceConfig struct {

	// Required. Source connection profile identifier.
	SourceConnectionProfileName string `` /* 146-byte string literal not displayed */
	// Stream configuration that is specific to the data source type.
	//
	// Types that are assignable to SourceStreamConfig:
	//
	//	*SourceConfig_OracleSourceConfig
	//	*SourceConfig_MysqlSourceConfig
	SourceStreamConfig isSourceConfig_SourceStreamConfig `protobuf_oneof:"source_stream_config"`
	// contains filtered or unexported fields
}

The configuration of the stream source.

func (*SourceConfig) Descriptor deprecated 

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

Deprecated: Use SourceConfig.ProtoReflect.Descriptor instead.

func (*SourceConfig) GetMysqlSourceConfig 

func (x *SourceConfig) GetMysqlSourceConfig() *MysqlSourceConfig

func (*SourceConfig) GetOracleSourceConfig 

func (x *SourceConfig) GetOracleSourceConfig() *OracleSourceConfig

func (*SourceConfig) GetSourceConnectionProfileName 

func (x *SourceConfig) GetSourceConnectionProfileName() string

func (*SourceConfig) GetSourceStreamConfig 

func (m *SourceConfig) GetSourceStreamConfig() isSourceConfig_SourceStreamConfig

func (*SourceConfig) ProtoMessage 

func (*SourceConfig) ProtoMessage()

func (*SourceConfig) ProtoReflect 

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

func (*SourceConfig) Reset 

func (x *SourceConfig) Reset()

func (*SourceConfig) String 

func (x *SourceConfig) String() string

type SourceConfig_MysqlSourceConfig 

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

type SourceConfig_OracleSourceConfig 

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

type StaticServiceIpConnectivity 

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

Static IP address connectivity.

func (*StaticServiceIpConnectivity) Descriptor deprecated 

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

Deprecated: Use StaticServiceIpConnectivity.ProtoReflect.Descriptor instead.

func (*StaticServiceIpConnectivity) ProtoMessage 

func (*StaticServiceIpConnectivity) ProtoMessage()

func (*StaticServiceIpConnectivity) ProtoReflect 

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

func (*StaticServiceIpConnectivity) Reset 

func (x *StaticServiceIpConnectivity) Reset()

func (*StaticServiceIpConnectivity) String 

func (x *StaticServiceIpConnectivity) String() string

type Stream 

type Stream struct {

	// Output only. The stream's name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The creation time of the stream.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The last update time of the stream.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Required. Display name.
	DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Required. Source connection profile configuration.
	SourceConfig *SourceConfig `protobuf:"bytes,6,opt,name=source_config,json=sourceConfig,proto3" json:"source_config,omitempty"`
	// Required. Destination connection profile configuration.
	DestinationConfig *DestinationConfig `protobuf:"bytes,7,opt,name=destination_config,json=destinationConfig,proto3" json:"destination_config,omitempty"`
	// The state of the stream.
	State Stream_State `protobuf:"varint,8,opt,name=state,proto3,enum=google.cloud.datastream.v1alpha1.Stream_State" json:"state,omitempty"`
	// Stream backfill strategy.
	//
	// Types that are assignable to BackfillStrategy:
	//
	//	*Stream_BackfillAll
	//	*Stream_BackfillNone
	BackfillStrategy isStream_BackfillStrategy `protobuf_oneof:"backfill_strategy"`
	// Output only. Errors on the Stream.
	Errors []*Error `protobuf:"bytes,9,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*Stream) Descriptor deprecated 

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetBackfillAll 

func (x *Stream) GetBackfillAll() *Stream_BackfillAllStrategy

func (*Stream) GetBackfillNone 

func (x *Stream) GetBackfillNone() *Stream_BackfillNoneStrategy

func (*Stream) GetBackfillStrategy 

func (m *Stream) GetBackfillStrategy() isStream_BackfillStrategy

func (*Stream) GetCreateTime 

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

func (*Stream) GetDestinationConfig 

func (x *Stream) GetDestinationConfig() *DestinationConfig

func (*Stream) GetDisplayName 

func (x *Stream) GetDisplayName() string

func (*Stream) GetErrors 

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

func (*Stream) GetLabels 

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

func (*Stream) GetName 

func (x *Stream) GetName() string

func (*Stream) GetSourceConfig 

func (x *Stream) GetSourceConfig() *SourceConfig

func (*Stream) GetState 

func (x *Stream) GetState() Stream_State

func (*Stream) GetUpdateTime 

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

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect 

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

func (*Stream) Reset 

func (x *Stream) Reset()

func (*Stream) String 

func (x *Stream) String() string

type Stream_BackfillAll 

type Stream_BackfillAll struct {
	// Automatically backfill objects included in the stream source
	// configuration. Specific objects can be excluded.
	BackfillAll *Stream_BackfillAllStrategy `protobuf:"bytes,101,opt,name=backfill_all,json=backfillAll,proto3,oneof"`
}

type Stream_BackfillAllStrategy 

type Stream_BackfillAllStrategy struct {

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

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

func (*Stream_BackfillAllStrategy) Descriptor deprecated 

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

Deprecated: Use Stream_BackfillAllStrategy.ProtoReflect.Descriptor instead.

func (*Stream_BackfillAllStrategy) GetExcludedObjects 

func (m *Stream_BackfillAllStrategy) GetExcludedObjects() isStream_BackfillAllStrategy_ExcludedObjects

func (*Stream_BackfillAllStrategy) GetMysqlExcludedObjects 

func (x *Stream_BackfillAllStrategy) GetMysqlExcludedObjects() *MysqlRdbms

func (*Stream_BackfillAllStrategy) GetOracleExcludedObjects 

func (x *Stream_BackfillAllStrategy) GetOracleExcludedObjects() *OracleRdbms

func (*Stream_BackfillAllStrategy) ProtoMessage 

func (*Stream_BackfillAllStrategy) ProtoMessage()

func (*Stream_BackfillAllStrategy) ProtoReflect 

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

func (*Stream_BackfillAllStrategy) Reset 

func (x *Stream_BackfillAllStrategy) Reset()

func (*Stream_BackfillAllStrategy) String 

func (x *Stream_BackfillAllStrategy) String() string

type Stream_BackfillAllStrategy_MysqlExcludedObjects 

type Stream_BackfillAllStrategy_MysqlExcludedObjects struct {
	// MySQL data source objects to avoid backfilling.
	MysqlExcludedObjects *MysqlRdbms `protobuf:"bytes,2,opt,name=mysql_excluded_objects,json=mysqlExcludedObjects,proto3,oneof"`
}

type Stream_BackfillAllStrategy_OracleExcludedObjects 

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

type Stream_BackfillNone 

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

type Stream_BackfillNoneStrategy 

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

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

func (*Stream_BackfillNoneStrategy) Descriptor deprecated 

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

Deprecated: Use Stream_BackfillNoneStrategy.ProtoReflect.Descriptor instead.

func (*Stream_BackfillNoneStrategy) ProtoMessage 

func (*Stream_BackfillNoneStrategy) ProtoMessage()

func (*Stream_BackfillNoneStrategy) ProtoReflect 

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

func (*Stream_BackfillNoneStrategy) Reset 

func (x *Stream_BackfillNoneStrategy) Reset()

func (*Stream_BackfillNoneStrategy) String 

func (x *Stream_BackfillNoneStrategy) String() string

type Stream_State 

type Stream_State int32

Stream state. 

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

func (Stream_State) Descriptor 

func (Stream_State) Descriptor() protoreflect.EnumDescriptor

func (Stream_State) Enum 

func (x Stream_State) Enum() *Stream_State

func (Stream_State) EnumDescriptor deprecated 

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

Deprecated: Use Stream_State.Descriptor instead.

func (Stream_State) Number 

func (x Stream_State) Number() protoreflect.EnumNumber

func (Stream_State) String 

func (x Stream_State) String() string

func (Stream_State) Type 

func (Stream_State) Type() protoreflect.EnumType

type UnimplementedDatastreamServer 

type UnimplementedDatastreamServer struct {
}

UnimplementedDatastreamServer should be embedded to have forward compatible implementations.

func (UnimplementedDatastreamServer) CreateConnectionProfile 

func (UnimplementedDatastreamServer) CreateConnectionProfile(context.Context, *CreateConnectionProfileRequest) (*longrunningpb.Operation, error)

func (UnimplementedDatastreamServer) CreatePrivateConnection 

func (UnimplementedDatastreamServer) CreatePrivateConnection(context.Context, *CreatePrivateConnectionRequest) (*longrunningpb.Operation, error)

func (UnimplementedDatastreamServer) CreateRoute 

func (UnimplementedDatastreamServer) CreateRoute(context.Context, *CreateRouteRequest) (*longrunningpb.Operation, error)

func (UnimplementedDatastreamServer) CreateStream 

func (UnimplementedDatastreamServer) CreateStream(context.Context, *CreateStreamRequest) (*longrunningpb.Operation, error)

func (UnimplementedDatastreamServer) DeleteConnectionProfile 

func (UnimplementedDatastreamServer) DeleteConnectionProfile(context.Context, *DeleteConnectionProfileRequest) (*longrunningpb.Operation, error)

func (UnimplementedDatastreamServer) DeletePrivateConnection 

func (UnimplementedDatastreamServer) DeletePrivateConnection(context.Context, *DeletePrivateConnectionRequest) (*longrunningpb.Operation, error)

func (UnimplementedDatastreamServer) DeleteRoute 

func (UnimplementedDatastreamServer) DeleteRoute(context.Context, *DeleteRouteRequest) (*longrunningpb.Operation, error)

func (UnimplementedDatastreamServer) DeleteStream 

func (UnimplementedDatastreamServer) DeleteStream(context.Context, *DeleteStreamRequest) (*longrunningpb.Operation, error)

func (UnimplementedDatastreamServer) DiscoverConnectionProfile 

func (UnimplementedDatastreamServer) DiscoverConnectionProfile(context.Context, *DiscoverConnectionProfileRequest) (*DiscoverConnectionProfileResponse, error)

func (UnimplementedDatastreamServer) FetchErrors 

func (UnimplementedDatastreamServer) FetchErrors(context.Context, *FetchErrorsRequest) (*longrunningpb.Operation, error)

func (UnimplementedDatastreamServer) FetchStaticIps 

func (UnimplementedDatastreamServer) FetchStaticIps(context.Context, *FetchStaticIpsRequest) (*FetchStaticIpsResponse, error)

func (UnimplementedDatastreamServer) GetConnectionProfile 

func (UnimplementedDatastreamServer) GetConnectionProfile(context.Context, *GetConnectionProfileRequest) (*ConnectionProfile, error)

func (UnimplementedDatastreamServer) GetPrivateConnection 

func (UnimplementedDatastreamServer) GetPrivateConnection(context.Context, *GetPrivateConnectionRequest) (*PrivateConnection, error)

func (UnimplementedDatastreamServer) GetRoute 

func (UnimplementedDatastreamServer) GetRoute(context.Context, *GetRouteRequest) (*Route, error)

func (UnimplementedDatastreamServer) GetStream 

func (UnimplementedDatastreamServer) GetStream(context.Context, *GetStreamRequest) (*Stream, error)

func (UnimplementedDatastreamServer) ListConnectionProfiles 

func (UnimplementedDatastreamServer) ListConnectionProfiles(context.Context, *ListConnectionProfilesRequest) (*ListConnectionProfilesResponse, error)

func (UnimplementedDatastreamServer) ListPrivateConnections 

func (UnimplementedDatastreamServer) ListPrivateConnections(context.Context, *ListPrivateConnectionsRequest) (*ListPrivateConnectionsResponse, error)

func (UnimplementedDatastreamServer) ListRoutes 

func (UnimplementedDatastreamServer) ListRoutes(context.Context, *ListRoutesRequest) (*ListRoutesResponse, error)

func (UnimplementedDatastreamServer) ListStreams 

func (UnimplementedDatastreamServer) ListStreams(context.Context, *ListStreamsRequest) (*ListStreamsResponse, error)

func (UnimplementedDatastreamServer) UpdateConnectionProfile 

func (UnimplementedDatastreamServer) UpdateConnectionProfile(context.Context, *UpdateConnectionProfileRequest) (*longrunningpb.Operation, error)

func (UnimplementedDatastreamServer) UpdateStream 

func (UnimplementedDatastreamServer) UpdateStream(context.Context, *UpdateStreamRequest) (*longrunningpb.Operation, error)

type UnsafeDatastreamServer added in v1.15.1 

type UnsafeDatastreamServer interface {
	// contains filtered or unexported methods
}

UnsafeDatastreamServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DatastreamServer will result in compilation errors.

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

func (*UpdateConnectionProfileRequest) Descriptor deprecated 

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

Deprecated: Use UpdateConnectionProfileRequest.ProtoReflect.Descriptor instead.

func (*UpdateConnectionProfileRequest) GetConnectionProfile 

func (x *UpdateConnectionProfileRequest) GetConnectionProfile() *ConnectionProfile

func (*UpdateConnectionProfileRequest) GetRequestId 

func (x *UpdateConnectionProfileRequest) GetRequestId() string

func (*UpdateConnectionProfileRequest) GetUpdateMask 

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

func (*UpdateConnectionProfileRequest) ProtoMessage 

func (*UpdateConnectionProfileRequest) ProtoMessage()

func (*UpdateConnectionProfileRequest) ProtoReflect 

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

func (*UpdateConnectionProfileRequest) Reset 

func (x *UpdateConnectionProfileRequest) Reset()

func (*UpdateConnectionProfileRequest) String 

func (x *UpdateConnectionProfileRequest) String() string

type 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. Execute the update without validating it.
	Force bool `protobuf:"varint,5,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateStreamRequest) Descriptor deprecated 

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

type 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.
	Status Validation_Status `protobuf:"varint,2,opt,name=status,proto3,enum=google.cloud.datastream.v1alpha1.Validation_Status" json:"status,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
}

func (*Validation) Descriptor deprecated 

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

func (x *Validation) GetStatus() Validation_Status

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

type ValidationMessage 

type ValidationMessage struct {

	// The result of the validation.
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// Message severity level (warning or error).
	Level ValidationMessage_Level `` /* 126-byte string literal not displayed */
	// Additional metadata related to the result.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// A custom code identifying this specific message.
	Code string `protobuf:"bytes,4,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

Represent user-facing validation result message.

func (*ValidationMessage) Descriptor deprecated 

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

Deprecated: Use ValidationMessage.ProtoReflect.Descriptor instead.

func (*ValidationMessage) GetCode 

func (x *ValidationMessage) GetCode() string

func (*ValidationMessage) GetLevel 

func (x *ValidationMessage) GetLevel() ValidationMessage_Level

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

type ValidationMessage_Level 

type ValidationMessage_Level int32

Validation message level. 

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

func (ValidationMessage_Level) Descriptor 

func (ValidationMessage_Level) Descriptor() protoreflect.EnumDescriptor

func (ValidationMessage_Level) Enum 

func (x ValidationMessage_Level) Enum() *ValidationMessage_Level

func (ValidationMessage_Level) EnumDescriptor deprecated 

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

Deprecated: Use ValidationMessage_Level.Descriptor instead.

func (ValidationMessage_Level) Number 

func (x ValidationMessage_Level) Number() protoreflect.EnumNumber

func (ValidationMessage_Level) String 

func (x ValidationMessage_Level) String() string

func (ValidationMessage_Level) Type 

func (ValidationMessage_Level) Type() protoreflect.EnumType

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 deprecated 

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

type Validation_Status 

type Validation_Status int32

Validation execution status. 

const (
	// Unspecified status.
	Validation_STATUS_UNSPECIFIED Validation_Status = 0
	// Validation did not execute.
	Validation_NOT_EXECUTED Validation_Status = 1
	// Validation failed.
	Validation_FAILED Validation_Status = 2
	// Validation passed.
	Validation_PASSED Validation_Status = 3
)

func (Validation_Status) Descriptor 

func (Validation_Status) Descriptor() protoreflect.EnumDescriptor

func (Validation_Status) Enum 

func (x Validation_Status) Enum() *Validation_Status

func (Validation_Status) EnumDescriptor deprecated 

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

Deprecated: Use Validation_Status.Descriptor instead.

func (Validation_Status) Number 

func (x Validation_Status) Number() protoreflect.EnumNumber

func (Validation_Status) String 

func (x Validation_Status) String() string

func (Validation_Status) Type 

func (Validation_Status) Type() protoreflect.EnumType

type VpcPeeringConfig 

type VpcPeeringConfig struct {

	// Required. fully qualified name of the VPC Datastream will peer to.
	VpcName string `protobuf:"bytes,1,opt,name=vpc_name,json=vpcName,proto3" json:"vpc_name,omitempty"`
	// Required. A free subnet for peering. (CIDR of /29)
	Subnet string `protobuf:"bytes,2,opt,name=subnet,proto3" json:"subnet,omitempty"`
	// contains filtered or unexported fields
}

The VPC Peering configuration is used to create VPC peering between Datastream and the consumer's VPC.

func (*VpcPeeringConfig) Descriptor deprecated 

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

Deprecated: Use VpcPeeringConfig.ProtoReflect.Descriptor instead.

func (*VpcPeeringConfig) GetSubnet 

func (x *VpcPeeringConfig) GetSubnet() string

func (*VpcPeeringConfig) GetVpcName 

func (x *VpcPeeringConfig) GetVpcName() string

func (*VpcPeeringConfig) ProtoMessage 

func (*VpcPeeringConfig) ProtoMessage()

func (*VpcPeeringConfig) ProtoReflect 

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

func (*VpcPeeringConfig) Reset 

func (x *VpcPeeringConfig) Reset()

func (*VpcPeeringConfig) String 

func (x *VpcPeeringConfig) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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