Package cloud.google.com/go/datastream/apiv1alpha1/datastreampb (v1.10.5)

Version latest

• 1.10.5 (latest)
• 1.10.4

Alpha

This library is covered by the Pre-GA Offerings Terms of the Terms of Service. Pre-GA libraries might have limited support, and changes to pre-GA libraries might not be compatible with other pre-GA versions. For more information, see the launch stage descriptions.

Note: To get more information about this package, such as access to older versions, view this package on pkg.go.dev.

Variables

GcsFileFormat_name, GcsFileFormat_value

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.

SchemaFileFormat_name, SchemaFileFormat_value

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.

PrivateConnection_State_name, PrivateConnection_State_value

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.

JsonFileFormat_JsonCompression_name, JsonFileFormat_JsonCompression_value

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

Enum value maps for JsonFileFormat_JsonCompression.

Stream_State_name, Stream_State_value

var (
	Stream_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "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.

Validation_Status_name, Validation_Status_value

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.

ValidationMessage_Level_name, ValidationMessage_Level_value

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

Enum value maps for ValidationMessage_Level.

File_google_cloud_datastream_v1alpha1_datastream_proto

var File_google_cloud_datastream_v1alpha1_datastream_proto protoreflect.FileDescriptor

File_google_cloud_datastream_v1alpha1_datastream_resources_proto

var File_google_cloud_datastream_v1alpha1_datastream_resources_proto protoreflect.FileDescriptor

Functions

func RegisterDatastreamServer

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

AvroFileFormat

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

AVRO file format configuration.

func (*AvroFileFormat) Descriptor

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

Deprecated: Use AvroFileFormat.ProtoReflect.Descriptor instead.

func (*AvroFileFormat) ProtoMessage

func (*AvroFileFormat) ProtoMessage()

func (*AvroFileFormat) ProtoReflect

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

func (*AvroFileFormat) Reset

func (x *AvroFileFormat) Reset()

func (*AvroFileFormat) String

func (x *AvroFileFormat) String() string

ConnectionProfile

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

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

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

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

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

	Profile isConnectionProfile_Profile `protobuf_oneof:"profile"`

	Connectivity isConnectionProfile_Connectivity `protobuf_oneof:"connectivity"`

}

func (*ConnectionProfile) Descriptor

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

ConnectionProfile_ForwardSshConnectivity

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

ConnectionProfile_GcsProfile

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

ConnectionProfile_MysqlProfile

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

ConnectionProfile_NoConnectivity

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

ConnectionProfile_OracleProfile

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

ConnectionProfile_PrivateConnectivity

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

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

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

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

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

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

CreateRouteRequest

type CreateRouteRequest struct {

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

route creation request

func (*CreateRouteRequest) Descriptor

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

Deprecated: Use CreateRouteRequest.ProtoReflect.Descriptor instead.

func (*CreateRouteRequest) GetParent

func (x *CreateRouteRequest) GetParent() string

func (*CreateRouteRequest) GetRequestId

func (x *CreateRouteRequest) GetRequestId() string

func (*CreateRouteRequest) GetRoute

func (x *CreateRouteRequest) GetRoute() *Route

func (*CreateRouteRequest) GetRouteId

func (x *CreateRouteRequest) GetRouteId() string

func (*CreateRouteRequest) ProtoMessage

func (*CreateRouteRequest) ProtoMessage()

func (*CreateRouteRequest) ProtoReflect

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

func (*CreateRouteRequest) Reset

func (x *CreateRouteRequest) Reset()

func (*CreateRouteRequest) String

func (x *CreateRouteRequest) String() string

CreateStreamRequest

type CreateStreamRequest struct {

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

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

Deprecated: Use CreateStreamRequest.ProtoReflect.Descriptor instead.

func (*CreateStreamRequest) GetForce

func (x *CreateStreamRequest) GetForce() bool

func (*CreateStreamRequest) GetParent

func (x *CreateStreamRequest) GetParent() string

func (*CreateStreamRequest) GetRequestId

func (x *CreateStreamRequest) GetRequestId() string

func (*CreateStreamRequest) GetStream

func (x *CreateStreamRequest) GetStream() *Stream

func (*CreateStreamRequest) GetStreamId

func (x *CreateStreamRequest) GetStreamId() string

func (*CreateStreamRequest) GetValidateOnly

func (x *CreateStreamRequest) GetValidateOnly() bool

func (*CreateStreamRequest) ProtoMessage

func (*CreateStreamRequest) ProtoMessage()

func (*CreateStreamRequest) ProtoReflect

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

func (*CreateStreamRequest) Reset

func (x *CreateStreamRequest) Reset()

func (*CreateStreamRequest) String

func (x *CreateStreamRequest) String() string

DatastreamClient

type DatastreamClient interface {
	// Use this method to list connection profiles created in a project and
	// location.
	ListConnectionProfiles(ctx context.Context, in *ListConnectionProfilesRequest, opts ...grpc.CallOption) (*ListConnectionProfilesResponse, error)
	// Use this method to get details about a connection profile.
	GetConnectionProfile(ctx context.Context, in *GetConnectionProfileRequest, opts ...grpc.CallOption) (*ConnectionProfile, error)
	// Use this method to create a connection profile in a project and location.
	CreateConnectionProfile(ctx context.Context, in *CreateConnectionProfileRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Use this method to update the parameters of a connection profile.
	UpdateConnectionProfile(ctx context.Context, in *UpdateConnectionProfileRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Use this method to delete a connection profile..
	DeleteConnectionProfile(ctx context.Context, in *DeleteConnectionProfileRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Use this method to discover a connection profile.
	// The discover API call exposes the data objects and metadata belonging to
	// the profile. Typically, a request returns children data objects 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDatastreamClient

func NewDatastreamClient(cc grpc.ClientConnInterface) DatastreamClient

DatastreamServer

type DatastreamServer interface {
	// Use this method to list connection profiles created in a project and
	// location.
	ListConnectionProfiles(context.Context, *ListConnectionProfilesRequest) (*ListConnectionProfilesResponse, error)
	// Use this method to get details about a connection profile.
	GetConnectionProfile(context.Context, *GetConnectionProfileRequest) (*ConnectionProfile, error)
	// Use this method to create a connection profile in a project and location.
	CreateConnectionProfile(context.Context, *CreateConnectionProfileRequest) (*longrunningpb.Operation, error)
	// Use this method to update the parameters of a connection profile.
	UpdateConnectionProfile(context.Context, *UpdateConnectionProfileRequest) (*longrunningpb.Operation, error)
	// Use this method to delete a connection profile..
	DeleteConnectionProfile(context.Context, *DeleteConnectionProfileRequest) (*longrunningpb.Operation, error)
	// Use this method to discover a connection profile.
	// The discover API call exposes the data objects and metadata belonging to
	// the profile. Typically, a request returns children data objects 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.

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

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

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

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

DeleteRouteRequest

type DeleteRouteRequest struct {

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

route deletion request

func (*DeleteRouteRequest) Descriptor

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

Deprecated: Use DeleteRouteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRouteRequest) GetName

func (x *DeleteRouteRequest) GetName() string

func (*DeleteRouteRequest) GetRequestId

func (x *DeleteRouteRequest) GetRequestId() string

func (*DeleteRouteRequest) ProtoMessage

func (*DeleteRouteRequest) ProtoMessage()

func (*DeleteRouteRequest) ProtoReflect

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

func (*DeleteRouteRequest) Reset

func (x *DeleteRouteRequest) Reset()

func (*DeleteRouteRequest) String

func (x *DeleteRouteRequest) String() string

DeleteStreamRequest

type DeleteStreamRequest struct {

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

func (*DeleteStreamRequest) Descriptor

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

Deprecated: Use DeleteStreamRequest.ProtoReflect.Descriptor instead.

func (*DeleteStreamRequest) GetName

func (x *DeleteStreamRequest) GetName() string

func (*DeleteStreamRequest) GetRequestId

func (x *DeleteStreamRequest) GetRequestId() string

func (*DeleteStreamRequest) ProtoMessage

func (*DeleteStreamRequest) ProtoMessage()

func (*DeleteStreamRequest) ProtoReflect

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

func (*DeleteStreamRequest) Reset

func (x *DeleteStreamRequest) Reset()

func (*DeleteStreamRequest) String

func (x *DeleteStreamRequest) String() string

DestinationConfig

type DestinationConfig struct {
	DestinationConnectionProfileName string "" /* 161 byte string literal not displayed */

	DestinationStreamConfig isDestinationConfig_DestinationStreamConfig `protobuf_oneof:"destination_stream_config"`

}

The configuration of the stream destination.

func (*DestinationConfig) Descriptor

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

Deprecated: Use DestinationConfig.ProtoReflect.Descriptor instead.

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

DestinationConfig_GcsDestinationConfig

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

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

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

DiscoverConnectionProfileRequest_ConnectionProfile

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

DiscoverConnectionProfileRequest_ConnectionProfileName

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

DiscoverConnectionProfileRequest_MysqlRdbms

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

DiscoverConnectionProfileRequest_OracleRdbms

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

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

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

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

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

DiscoverConnectionProfileResponse_MysqlRdbms

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

DiscoverConnectionProfileResponse_OracleRdbms

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

Error

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

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

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

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

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

}

Represent a user-facing Error.

func (*Error) Descriptor

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetDetails

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

func (*Error) GetErrorTime

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

func (*Error) GetErrorUuid

func (x *Error) GetErrorUuid() string

func (*Error) GetMessage

func (x *Error) GetMessage() string

func (*Error) GetReason

func (x *Error) GetReason() string

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) ProtoReflect

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

func (*Error) Reset

func (x *Error) Reset()

func (*Error) String

func (x *Error) String() string

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

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

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

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

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

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

Deprecated: Use FetchStaticIpsRequest.ProtoReflect.Descriptor instead.

func (*FetchStaticIpsRequest) GetName

func (x *FetchStaticIpsRequest) GetName() string

func (*FetchStaticIpsRequest) GetPageSize

func (x *FetchStaticIpsRequest) GetPageSize() int32

func (*FetchStaticIpsRequest) GetPageToken

func (x *FetchStaticIpsRequest) GetPageToken() string

func (*FetchStaticIpsRequest) ProtoMessage

func (*FetchStaticIpsRequest) ProtoMessage()

func (*FetchStaticIpsRequest) ProtoReflect

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

func (*FetchStaticIpsRequest) Reset

func (x *FetchStaticIpsRequest) Reset()

func (*FetchStaticIpsRequest) String

func (x *FetchStaticIpsRequest) String() string

FetchStaticIpsResponse

type FetchStaticIpsResponse struct {

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

Response message for a 'FetchStaticIps' response.

func (*FetchStaticIpsResponse) Descriptor

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

Deprecated: Use FetchStaticIpsResponse.ProtoReflect.Descriptor instead.

func (*FetchStaticIpsResponse) GetNextPageToken

func (x *FetchStaticIpsResponse) GetNextPageToken() string

func (*FetchStaticIpsResponse) GetStaticIps

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

func (*FetchStaticIpsResponse) ProtoMessage

func (*FetchStaticIpsResponse) ProtoMessage()

func (*FetchStaticIpsResponse) ProtoReflect

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

func (*FetchStaticIpsResponse) Reset

func (x *FetchStaticIpsResponse) Reset()

func (*FetchStaticIpsResponse) String

func (x *FetchStaticIpsResponse) String() string

ForwardSshTunnelConnectivity

type ForwardSshTunnelConnectivity struct {

	// Required. Hostname for the SSH tunnel.
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Required. Username for the SSH tunnel.
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// Port for the SSH tunnel, default value is 22.
	Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// Types that are assignable to AuthenticationMethod:
	//
	//	*ForwardSshTunnelConnectivity_Password
	//	*ForwardSshTunnelConnectivity_PrivateKey
	AuthenticationMethod isForwardSshTunnelConnectivity_AuthenticationMethod `protobuf_oneof:"authentication_method"`
	// contains filtered or unexported fields
}

Forward SSH Tunnel connectivity.

func (*ForwardSshTunnelConnectivity) Descriptor

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

Deprecated: Use ForwardSshTunnelConnectivity.ProtoReflect.Descriptor instead.

func (*ForwardSshTunnelConnectivity) GetAuthenticationMethod

func (m *ForwardSshTunnelConnectivity) GetAuthenticationMethod() isForwardSshTunnelConnectivity_AuthenticationMethod

func (*ForwardSshTunnelConnectivity) GetHostname

func (x *ForwardSshTunnelConnectivity) GetHostname() string

func (*ForwardSshTunnelConnectivity) GetPassword

func (x *ForwardSshTunnelConnectivity) GetPassword() string

func (*ForwardSshTunnelConnectivity) GetPort

func (x *ForwardSshTunnelConnectivity) GetPort() int32

func (*ForwardSshTunnelConnectivity) GetPrivateKey

func (x *ForwardSshTunnelConnectivity) GetPrivateKey() string

func (*ForwardSshTunnelConnectivity) GetUsername

func (x *ForwardSshTunnelConnectivity) GetUsername() string

func (*ForwardSshTunnelConnectivity) ProtoMessage

func (*ForwardSshTunnelConnectivity) ProtoMessage()

func (*ForwardSshTunnelConnectivity) ProtoReflect

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

func (*ForwardSshTunnelConnectivity) Reset

func (x *ForwardSshTunnelConnectivity) Reset()

func (*ForwardSshTunnelConnectivity) String

func (x *ForwardSshTunnelConnectivity) String() string

ForwardSshTunnelConnectivity_Password

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

ForwardSshTunnelConnectivity_PrivateKey

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

GcsDestinationConfig

type GcsDestinationConfig struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`

	GcsFileFormat GcsFileFormat "" /* 155 byte string literal not displayed */

	FileRotationMb int32 `protobuf:"varint,3,opt,name=file_rotation_mb,json=fileRotationMb,proto3" json:"file_rotation_mb,omitempty"`

	FileRotationInterval *durationpb.Duration `protobuf:"bytes,4,opt,name=file_rotation_interval,json=fileRotationInterval,proto3" json:"file_rotation_interval,omitempty"`

	FileFormat isGcsDestinationConfig_FileFormat `protobuf_oneof:"file_format"`

}

Google Cloud Storage destination configuration

func (*GcsDestinationConfig) Descriptor

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

Deprecated: Use GcsDestinationConfig.ProtoReflect.Descriptor instead.

func (*GcsDestinationConfig) GetAvroFileFormat

func (x *GcsDestinationConfig) GetAvroFileFormat() *AvroFileFormat

func (*GcsDestinationConfig) GetFileFormat

func (m *GcsDestinationConfig) GetFileFormat() isGcsDestinationConfig_FileFormat

func (*GcsDestinationConfig) GetFileRotationInterval

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

func (*GcsDestinationConfig) GetFileRotationMb

func (x *GcsDestinationConfig) GetFileRotationMb() int32

func (*GcsDestinationConfig) GetGcsFileFormat

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

GcsDestinationConfig_AvroFileFormat

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

GcsDestinationConfig_JsonFileFormat

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

GcsFileFormat (deprecated)

type GcsFileFormat int32

File format in Cloud Storage.

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

GcsFileFormat_GCS_FILE_FORMAT_UNSPECIFIED, GcsFileFormat_AVRO (deprecated)

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

func (GcsFileFormat) Descriptor (deprecated)

func (GcsFileFormat) Descriptor() protoreflect.EnumDescriptor

func (GcsFileFormat) Enum (deprecated)

func (x GcsFileFormat) Enum() *GcsFileFormat

func (GcsFileFormat) EnumDescriptor (deprecated)

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

Deprecated: Use GcsFileFormat.Descriptor instead.

func (GcsFileFormat) Number (deprecated)

func (x GcsFileFormat) Number() protoreflect.EnumNumber

func (GcsFileFormat) String (deprecated)

func (x GcsFileFormat) String() string

func (GcsFileFormat) Type (deprecated)

func (GcsFileFormat) Type() protoreflect.EnumType

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

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

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

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

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

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

GetRouteRequest

type GetRouteRequest struct {

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

route get request

func (*GetRouteRequest) Descriptor

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

Deprecated: Use GetRouteRequest.ProtoReflect.Descriptor instead.

func (*GetRouteRequest) GetName

func (x *GetRouteRequest) GetName() string

func (*GetRouteRequest) ProtoMessage

func (*GetRouteRequest) ProtoMessage()

func (*GetRouteRequest) ProtoReflect

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

func (*GetRouteRequest) Reset

func (x *GetRouteRequest) Reset()

func (*GetRouteRequest) String

func (x *GetRouteRequest) String() string

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

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

Deprecated: Use GetStreamRequest.ProtoReflect.Descriptor instead.

func (*GetStreamRequest) GetName

func (x *GetStreamRequest) GetName() string

func (*GetStreamRequest) ProtoMessage

func (*GetStreamRequest) ProtoMessage()

func (*GetStreamRequest) ProtoReflect

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

func (*GetStreamRequest) Reset

func (x *GetStreamRequest) Reset()

func (*GetStreamRequest) String

func (x *GetStreamRequest) String() string

JsonFileFormat

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

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

}

JSON file format configuration.

func (*JsonFileFormat) Descriptor

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

Deprecated: Use JsonFileFormat.ProtoReflect.Descriptor instead.

func (*JsonFileFormat) GetCompression

func (x *JsonFileFormat) GetCompression() JsonFileFormat_JsonCompression

func (*JsonFileFormat) GetSchemaFileFormat

func (x *JsonFileFormat) GetSchemaFileFormat() SchemaFileFormat

func (*JsonFileFormat) ProtoMessage

func (*JsonFileFormat) ProtoMessage()

func (*JsonFileFormat) ProtoReflect

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

func (*JsonFileFormat) Reset

func (x *JsonFileFormat) Reset()

func (*JsonFileFormat) String

func (x *JsonFileFormat) String() string

JsonFileFormat_JsonCompression

type JsonFileFormat_JsonCompression int32

Json file compression.

JsonFileFormat_JSON_COMPRESSION_UNSPECIFIED, JsonFileFormat_NO_COMPRESSION, JsonFileFormat_GZIP

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

func (JsonFileFormat_JsonCompression) Descriptor

func (JsonFileFormat_JsonCompression) Descriptor() protoreflect.EnumDescriptor

func (JsonFileFormat_JsonCompression) Enum

func (x JsonFileFormat_JsonCompression) Enum() *JsonFileFormat_JsonCompression

func (JsonFileFormat_JsonCompression) EnumDescriptor

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

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

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

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

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

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

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

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

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

ListRoutesRequest

type ListRoutesRequest struct {

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

route list request

func (*ListRoutesRequest) Descriptor

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

Deprecated: Use ListRoutesRequest.ProtoReflect.Descriptor instead.

func (*ListRoutesRequest) GetFilter

func (x *ListRoutesRequest) GetFilter() string

func (*ListRoutesRequest) GetOrderBy

func (x *ListRoutesRequest) GetOrderBy() string

func (*ListRoutesRequest) GetPageSize

func (x *ListRoutesRequest) GetPageSize() int32

func (*ListRoutesRequest) GetPageToken

func (x *ListRoutesRequest) GetPageToken() string

func (*ListRoutesRequest) GetParent

func (x *ListRoutesRequest) GetParent() string

func (*ListRoutesRequest) ProtoMessage

func (*ListRoutesRequest) ProtoMessage()

func (*ListRoutesRequest) ProtoReflect

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

func (*ListRoutesRequest) Reset

func (x *ListRoutesRequest) Reset()

func (*ListRoutesRequest) String

func (x *ListRoutesRequest) String() string

ListRoutesResponse

type ListRoutesResponse struct {

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

route list response

func (*ListRoutesResponse) Descriptor

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

Deprecated: Use ListRoutesResponse.ProtoReflect.Descriptor instead.

func (*ListRoutesResponse) GetNextPageToken

func (x *ListRoutesResponse) GetNextPageToken() string

func (*ListRoutesResponse) GetRoutes

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

func (*ListRoutesResponse) GetUnreachable

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

func (*ListRoutesResponse) ProtoMessage

func (*ListRoutesResponse) ProtoMessage()

func (*ListRoutesResponse) ProtoReflect

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

func (*ListRoutesResponse) Reset

func (x *ListRoutesResponse) Reset()

func (*ListRoutesResponse) String

func (x *ListRoutesResponse) String() string

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

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

Deprecated: Use ListStreamsRequest.ProtoReflect.Descriptor instead.

func (*ListStreamsRequest) GetFilter

func (x *ListStreamsRequest) GetFilter() string

func (*ListStreamsRequest) GetOrderBy

func (x *ListStreamsRequest) GetOrderBy() string

func (*ListStreamsRequest) GetPageSize

func (x *ListStreamsRequest) GetPageSize() int32

func (*ListStreamsRequest) GetPageToken

func (x *ListStreamsRequest) GetPageToken() string

func (*ListStreamsRequest) GetParent

func (x *ListStreamsRequest) GetParent() string

func (*ListStreamsRequest) ProtoMessage

func (*ListStreamsRequest) ProtoMessage()

func (*ListStreamsRequest) ProtoReflect

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

func (*ListStreamsRequest) Reset

func (x *ListStreamsRequest) Reset()

func (*ListStreamsRequest) String

func (x *ListStreamsRequest) String() string

ListStreamsResponse

type ListStreamsResponse struct {

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

func (*ListStreamsResponse) Descriptor

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

Deprecated: Use ListStreamsResponse.ProtoReflect.Descriptor instead.

func (*ListStreamsResponse) GetNextPageToken

func (x *ListStreamsResponse) GetNextPageToken() string

func (*ListStreamsResponse) GetStreams

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

func (*ListStreamsResponse) GetUnreachable

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

func (*ListStreamsResponse) ProtoMessage

func (*ListStreamsResponse) ProtoMessage()

func (*ListStreamsResponse) ProtoReflect

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

func (*ListStreamsResponse) Reset

func (x *ListStreamsResponse) Reset()

func (*ListStreamsResponse) String

func (x *ListStreamsResponse) String() string

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

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

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

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

MysqlProfile

type MysqlProfile struct {

	// Required. Hostname for the MySQL connection.
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Port for the MySQL connection, default value is 3306.
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Required. Username for the MySQL connection.
	Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	// Required. Input only. Password for the MySQL connection.
	Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	// SSL configuration for the MySQL connection.
	SslConfig *MysqlSslConfig `protobuf:"bytes,5,opt,name=ssl_config,json=sslConfig,proto3" json:"ssl_config,omitempty"`
	// contains filtered or unexported fields
}

MySQL database profile.

func (*MysqlProfile) Descriptor

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

Deprecated: Use MysqlProfile.ProtoReflect.Descriptor instead.

func (*MysqlProfile) GetHostname

func (x *MysqlProfile) GetHostname() string

func (*MysqlProfile) GetPassword

func (x *MysqlProfile) GetPassword() string

func (*MysqlProfile) GetPort

func (x *MysqlProfile) GetPort() int32

func (*MysqlProfile) GetSslConfig

func (x *MysqlProfile) GetSslConfig() *MysqlSslConfig

func (*MysqlProfile) GetUsername

func (x *MysqlProfile) GetUsername() string

func (*MysqlProfile) ProtoMessage

func (*MysqlProfile) ProtoMessage()

func (*MysqlProfile) ProtoReflect

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

func (*MysqlProfile) Reset

func (x *MysqlProfile) Reset()

func (*MysqlProfile) String

func (x *MysqlProfile) String() string

MysqlRdbms

type MysqlRdbms struct {

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

MySQL database structure

func (*MysqlRdbms) Descriptor

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

Deprecated: Use MysqlRdbms.ProtoReflect.Descriptor instead.

func (*MysqlRdbms) GetMysqlDatabases

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

func (*MysqlRdbms) ProtoMessage

func (*MysqlRdbms) ProtoMessage()

func (*MysqlRdbms) ProtoReflect

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

func (*MysqlRdbms) Reset

func (x *MysqlRdbms) Reset()

func (*MysqlRdbms) String

func (x *MysqlRdbms) String() string

MysqlSourceConfig

type MysqlSourceConfig struct {

	// 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

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

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

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

Deprecated: Use MysqlSslConfig.ProtoReflect.Descriptor instead.

func (*MysqlSslConfig) GetCaCertificate

func (x *MysqlSslConfig) GetCaCertificate() string

func (*MysqlSslConfig) GetCaCertificateSet

func (x *MysqlSslConfig) GetCaCertificateSet() bool

func (*MysqlSslConfig) GetClientCertificate

func (x *MysqlSslConfig) GetClientCertificate() string

func (*MysqlSslConfig) GetClientCertificateSet

func (x *MysqlSslConfig) GetClientCertificateSet() bool

func (*MysqlSslConfig) GetClientKey

func (x *MysqlSslConfig) GetClientKey() string

func (*MysqlSslConfig) GetClientKeySet

func (x *MysqlSslConfig) GetClientKeySet() bool

func (*MysqlSslConfig) ProtoMessage

func (*MysqlSslConfig) ProtoMessage()

func (*MysqlSslConfig) ProtoReflect

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

func (*MysqlSslConfig) Reset

func (x *MysqlSslConfig) Reset()

func (*MysqlSslConfig) String

func (x *MysqlSslConfig) String() string

MysqlTable

type MysqlTable struct {

	// Table name.
	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

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

NoConnectivitySettings

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

No connectivity settings.

func (*NoConnectivitySettings) Descriptor

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

OperationMetadata

type OperationMetadata struct {

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

Represents the metadata of the long-running operation.

func (*OperationMetadata) Descriptor

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

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

func (*OperationMetadata) GetApiVersion

func (x *OperationMetadata) GetApiVersion() string

func (*OperationMetadata) GetCreateTime

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

func (*OperationMetadata) GetEndTime

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

func (*OperationMetadata) GetRequestedCancellation

func (x *OperationMetadata) GetRequestedCancellation() bool

func (*OperationMetadata) GetStatusMessage

func (x *OperationMetadata) GetStatusMessage() string

func (*OperationMetadata) GetTarget

func (x *OperationMetadata) GetTarget() string

func (*OperationMetadata) GetValidationResult

func (x *OperationMetadata) GetValidationResult() *ValidationResult

func (*OperationMetadata) GetVerb

func (x *OperationMetadata) GetVerb() string

func (*OperationMetadata) ProtoMessage

func (*OperationMetadata) ProtoMessage()

func (*OperationMetadata) ProtoReflect

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

func (*OperationMetadata) Reset

func (x *OperationMetadata) Reset()

func (*OperationMetadata) String

func (x *OperationMetadata) String() string

OracleColumn

type OracleColumn struct {

	// Column name.
	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

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

OracleProfile

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

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

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

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

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

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

}

Oracle database profile.

func (*OracleProfile) Descriptor

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

Deprecated: Use OracleProfile.ProtoReflect.Descriptor instead.

func (*OracleProfile) GetConnectionAttributes

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

func (*OracleProfile) GetDatabaseService

func (x *OracleProfile) GetDatabaseService() string

func (*OracleProfile) GetHostname

func (x *OracleProfile) GetHostname() string

func (*OracleProfile) GetPassword

func (x *OracleProfile) GetPassword() string

func (*OracleProfile) GetPort

func (x *OracleProfile) GetPort() int32

func (*OracleProfile) GetUsername

func (x *OracleProfile) GetUsername() string

func (*OracleProfile) ProtoMessage

func (*OracleProfile) ProtoMessage()

func (*OracleProfile) ProtoReflect

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

func (*OracleProfile) Reset

func (x *OracleProfile) Reset()

func (*OracleProfile) String

func (x *OracleProfile) String() string

OracleRdbms

type OracleRdbms struct {

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

Oracle database structure.

func (*OracleRdbms) Descriptor

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

Deprecated: Use OracleRdbms.ProtoReflect.Descriptor instead.

func (*OracleRdbms) GetOracleSchemas

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

func (*OracleRdbms) ProtoMessage

func (*OracleRdbms) ProtoMessage()

func (*OracleRdbms) ProtoReflect

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

func (*OracleRdbms) Reset

func (x *OracleRdbms) Reset()

func (*OracleRdbms) String

func (x *OracleRdbms) String() string

OracleSchema

type OracleSchema struct {

	// Schema name.
	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

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

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

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

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

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

PrivateConnection

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

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

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

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

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

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

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

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

}

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

func (*PrivateConnection) Descriptor

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

Deprecated: Use PrivateConnection.ProtoReflect.Descriptor instead.

func (*PrivateConnection) GetCreateTime

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

func (*PrivateConnection) GetDisplayName

func (x *PrivateConnection) GetDisplayName() string

func (*PrivateConnection) GetError

func (x *PrivateConnection) GetError() *Error

func (*PrivateConnection) GetLabels

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

func (*PrivateConnection) GetName

func (x *PrivateConnection) GetName() string

func (*PrivateConnection) GetState

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

PrivateConnection_State

type PrivateConnection_State int32

Private Connection state.

PrivateConnection_STATE_UNSPECIFIED, PrivateConnection_CREATING, PrivateConnection_CREATED, PrivateConnection_FAILED

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

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

PrivateConnectivity

type PrivateConnectivity struct {
	PrivateConnectionName string `protobuf:"bytes,1,opt,name=private_connection_name,json=privateConnectionName,proto3" json:"private_connection_name,omitempty"`
	// contains filtered or unexported fields
}

Private Connectivity

func (*PrivateConnectivity) Descriptor

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

Route

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

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

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

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

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

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

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

}

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

func (*Route) Descriptor

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

Deprecated: Use Route.ProtoReflect.Descriptor instead.

func (*Route) GetCreateTime

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

func (*Route) GetDestinationAddress

func (x *Route) GetDestinationAddress() string

func (*Route) GetDestinationPort

func (x *Route) GetDestinationPort() int32

func (*Route) GetDisplayName

func (x *Route) GetDisplayName() string

func (*Route) GetLabels

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

func (*Route) GetName

func (x *Route) GetName() string

func (*Route) GetUpdateTime

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

func (*Route) ProtoMessage

func (*Route) ProtoMessage()

func (*Route) ProtoReflect

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

func (*Route) Reset

func (x *Route) Reset()

func (*Route) String

func (x *Route) String() string

SchemaFileFormat

type SchemaFileFormat int32

Schema file format.

SchemaFileFormat_SCHEMA_FILE_FORMAT_UNSPECIFIED, SchemaFileFormat_NO_SCHEMA_FILE, SchemaFileFormat_AVRO_SCHEMA_FILE

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

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

SourceConfig

type SourceConfig struct {
	SourceConnectionProfileName string "" /* 146 byte string literal not displayed */

	SourceStreamConfig isSourceConfig_SourceStreamConfig `protobuf_oneof:"source_stream_config"`

}

The configuration of the stream source.

func (*SourceConfig) Descriptor

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

Deprecated: Use SourceConfig.ProtoReflect.Descriptor instead.

func (*SourceConfig) GetMysqlSourceConfig

func (x *SourceConfig) GetMysqlSourceConfig() *MysqlSourceConfig

func (*SourceConfig) GetOracleSourceConfig

func (x *SourceConfig) GetOracleSourceConfig() *OracleSourceConfig

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

SourceConfig_MysqlSourceConfig

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

SourceConfig_OracleSourceConfig

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

StaticServiceIpConnectivity

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

Static IP address connectivity.

func (*StaticServiceIpConnectivity) Descriptor

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

Stream

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

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

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

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

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

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

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

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

	BackfillStrategy isStream_BackfillStrategy `protobuf_oneof:"backfill_strategy"`

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

}

func (*Stream) Descriptor

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetBackfillAll

func (x *Stream) GetBackfillAll() *Stream_BackfillAllStrategy

func (*Stream) GetBackfillNone

func (x *Stream) GetBackfillNone() *Stream_BackfillNoneStrategy

func (*Stream) GetBackfillStrategy

func (m *Stream) GetBackfillStrategy() isStream_BackfillStrategy

func (*Stream) GetCreateTime

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

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

Stream_BackfillAll

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

Stream_BackfillAllStrategy

type Stream_BackfillAllStrategy struct {

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

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

func (*Stream_BackfillAllStrategy) Descriptor

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

Deprecated: Use Stream_BackfillAllStrategy.ProtoReflect.Descriptor instead.

func (*Stream_BackfillAllStrategy) GetExcludedObjects

func (m *Stream_BackfillAllStrategy) GetExcludedObjects() isStream_BackfillAllStrategy_ExcludedObjects

func (*Stream_BackfillAllStrategy) GetMysqlExcludedObjects

func (x *Stream_BackfillAllStrategy) GetMysqlExcludedObjects() *MysqlRdbms

func (*Stream_BackfillAllStrategy) GetOracleExcludedObjects

func (x *Stream_BackfillAllStrategy) GetOracleExcludedObjects() *OracleRdbms

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

Stream_BackfillAllStrategy_MysqlExcludedObjects

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

Stream_BackfillAllStrategy_OracleExcludedObjects

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

Stream_BackfillNone

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

Stream_BackfillNoneStrategy

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

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

func (*Stream_BackfillNoneStrategy) Descriptor

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

Deprecated: Use Stream_BackfillNoneStrategy.ProtoReflect.Descriptor instead.

func (*Stream_BackfillNoneStrategy) ProtoMessage

func (*Stream_BackfillNoneStrategy) ProtoMessage()

func (*Stream_BackfillNoneStrategy) ProtoReflect

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

Stream_State

type Stream_State int32

Stream state.

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

const (
	// Unspecified stream state.
	Stream_STATE_UNSPECIFIED Stream_State = 0
	// The stream has been created.
	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

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

UnimplementedDatastreamServer

type UnimplementedDatastreamServer struct {
}

UnimplementedDatastreamServer can 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)

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

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

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

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

Deprecated: Use UpdateStreamRequest.ProtoReflect.Descriptor instead.

func (*UpdateStreamRequest) GetForce

func (x *UpdateStreamRequest) GetForce() bool

func (*UpdateStreamRequest) GetRequestId

func (x *UpdateStreamRequest) GetRequestId() string

func (*UpdateStreamRequest) GetStream

func (x *UpdateStreamRequest) GetStream() *Stream

func (*UpdateStreamRequest) GetUpdateMask

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

func (*UpdateStreamRequest) GetValidateOnly

func (x *UpdateStreamRequest) GetValidateOnly() bool

func (*UpdateStreamRequest) ProtoMessage

func (*UpdateStreamRequest) ProtoMessage()

func (*UpdateStreamRequest) ProtoReflect

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

func (*UpdateStreamRequest) Reset

func (x *UpdateStreamRequest) Reset()

func (*UpdateStreamRequest) String

func (x *UpdateStreamRequest) String() string

Validation

type Validation struct {

	// A short description of the validation.
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	// Validation execution status.
	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

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

ValidationMessage

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

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

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

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

}

Represent user-facing validation result message.

func (*ValidationMessage) Descriptor

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

Deprecated: Use ValidationMessage.ProtoReflect.Descriptor instead.

func (*ValidationMessage) GetCode

func (x *ValidationMessage) GetCode() string

func (*ValidationMessage) GetLevel

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

ValidationMessage_Level

type ValidationMessage_Level int32

Validation message level.

ValidationMessage_LEVEL_UNSPECIFIED, ValidationMessage_WARNING, ValidationMessage_ERROR

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

func (ValidationMessage_Level) Descriptor

func (ValidationMessage_Level) Descriptor() protoreflect.EnumDescriptor

func (ValidationMessage_Level) Enum

func (x ValidationMessage_Level) Enum() *ValidationMessage_Level

func (ValidationMessage_Level) EnumDescriptor

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

ValidationResult

type ValidationResult struct {

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

Contains the current validation results.

func (*ValidationResult) Descriptor

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

Deprecated: Use ValidationResult.ProtoReflect.Descriptor instead.

func (*ValidationResult) GetValidations

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

func (*ValidationResult) ProtoMessage

func (*ValidationResult) ProtoMessage()

func (*ValidationResult) ProtoReflect

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

func (*ValidationResult) Reset

func (x *ValidationResult) Reset()

func (*ValidationResult) String

func (x *ValidationResult) String() string

Validation_Status

type Validation_Status int32

Validation execution status.

Validation_STATUS_UNSPECIFIED, Validation_NOT_EXECUTED, Validation_FAILED, Validation_PASSED

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

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

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

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