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

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 *timestamp.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamp.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() *timestamp.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() *timestamp.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 (*CreateConnectionProfileRequest) Reset

func (x *CreateConnectionProfileRequest) Reset()

func (*CreateConnectionProfileRequest) String

CreatePrivateConnectionRequest

type CreatePrivateConnectionRequest struct {

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

func (x *CreatePrivateConnectionRequest) Reset()

func (*CreatePrivateConnectionRequest) String

CreateRouteRequest

type CreateRouteRequest struct {

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

route creation request

func (*CreateRouteRequest) Descriptor

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

Deprecated: Use CreateRouteRequest.ProtoReflect.Descriptor instead.

func (*CreateRouteRequest) GetParent

func (x *CreateRouteRequest) GetParent() string

func (*CreateRouteRequest) GetRequestId

func (x *CreateRouteRequest) GetRequestId() string

func (*CreateRouteRequest) GetRoute

func (x *CreateRouteRequest) GetRoute() *Route

func (*CreateRouteRequest) GetRouteId

func (x *CreateRouteRequest) GetRouteId() string

func (*CreateRouteRequest) ProtoMessage

func (*CreateRouteRequest) ProtoMessage()

func (*CreateRouteRequest) ProtoReflect

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

func (*CreateRouteRequest) Reset

func (x *CreateRouteRequest) Reset()

func (*CreateRouteRequest) String

func (x *CreateRouteRequest) String() string

CreateStreamRequest

type CreateStreamRequest struct {

	// Required. The parent that owns the collection of streams.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The stream identifier.
	StreamId string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// Required. The stream resource to create.
	Stream *Stream `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"`
	// Optional. A request ID to identify requests. Specify a unique request ID
	// so that if you must retry your request, the server will know to ignore
	// the request if it has already been completed. The server will guarantee
	// that for at least 60 minutes since the first request.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request ID,
	// the server can check if original operation with the same request ID was
	// received, and if so, will ignore the second request. This prevents clients
	// from accidentally creating duplicate commitments.
	//
	// The request ID must be a valid UUID with the exception that zero UUID is
	// not supported (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Optional. Only validate the stream, but 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) (*longrunning.Operation, error)
	// Use this method to update the parameters of a connection profile.
	UpdateConnectionProfile(ctx context.Context, in *UpdateConnectionProfileRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Use this method to delete a connection profile..
	DeleteConnectionProfile(ctx context.Context, in *DeleteConnectionProfileRequest, opts ...grpc.CallOption) (*longrunning.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) (*longrunning.Operation, error)
	// Use this method to update the configuration of a stream.
	UpdateStream(ctx context.Context, in *UpdateStreamRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Use this method to delete a stream.
	DeleteStream(ctx context.Context, in *DeleteStreamRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Use this method to fetch any errors associated with a stream.
	FetchErrors(ctx context.Context, in *FetchErrorsRequest, opts ...grpc.CallOption) (*longrunning.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) (*longrunning.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) (*longrunning.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) (*longrunning.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) (*longrunning.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) (*longrunning.Operation, error)
	// Use this method to update the parameters of a connection profile.
	UpdateConnectionProfile(context.Context, *UpdateConnectionProfileRequest) (*longrunning.Operation, error)
	// Use this method to delete a connection profile..
	DeleteConnectionProfile(context.Context, *DeleteConnectionProfileRequest) (*longrunning.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) (*longrunning.Operation, error)
	// Use this method to update the configuration of a stream.
	UpdateStream(context.Context, *UpdateStreamRequest) (*longrunning.Operation, error)
	// Use this method to delete a stream.
	DeleteStream(context.Context, *DeleteStreamRequest) (*longrunning.Operation, error)
	// Use this method to fetch any errors associated with a stream.
	FetchErrors(context.Context, *FetchErrorsRequest) (*longrunning.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) (*longrunning.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) (*longrunning.Operation, error)
	// Use this method to create a route for a private connectivity in a project
	// and location.
	CreateRoute(context.Context, *CreateRouteRequest) (*longrunning.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) (*longrunning.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 (*DeleteConnectionProfileRequest) GetRequestId

func (x *DeleteConnectionProfileRequest) GetRequestId() string

func (*DeleteConnectionProfileRequest) ProtoMessage

func (*DeleteConnectionProfileRequest) ProtoMessage()

func (*DeleteConnectionProfileRequest) ProtoReflect

func (*DeleteConnectionProfileRequest) Reset

func (x *DeleteConnectionProfileRequest) Reset()

func (*DeleteConnectionProfileRequest) String

DeletePrivateConnectionRequest

type DeletePrivateConnectionRequest struct {

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

func (*DeletePrivateConnectionRequest) Descriptor

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

Deprecated: Use DeletePrivateConnectionRequest.ProtoReflect.Descriptor instead.

func (*DeletePrivateConnectionRequest) GetForce

func (x *DeletePrivateConnectionRequest) GetForce() bool

func (*DeletePrivateConnectionRequest) GetName

func (*DeletePrivateConnectionRequest) GetRequestId

func (x *DeletePrivateConnectionRequest) GetRequestId() string

func (*DeletePrivateConnectionRequest) ProtoMessage

func (*DeletePrivateConnectionRequest) ProtoMessage()

func (*DeletePrivateConnectionRequest) ProtoReflect

func (*DeletePrivateConnectionRequest) Reset

func (x *DeletePrivateConnectionRequest) Reset()

func (*DeletePrivateConnectionRequest) String

DeleteRouteRequest

type DeleteRouteRequest struct {

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

route deletion request

func (*DeleteRouteRequest) Descriptor

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

Deprecated: Use DeleteRouteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRouteRequest) GetName

func (x *DeleteRouteRequest) GetName() string

func (*DeleteRouteRequest) GetRequestId

func (x *DeleteRouteRequest) GetRequestId() string

func (*DeleteRouteRequest) ProtoMessage

func (*DeleteRouteRequest) ProtoMessage()

func (*DeleteRouteRequest) ProtoReflect

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

func (*DeleteRouteRequest) Reset

func (x *DeleteRouteRequest) Reset()

func (*DeleteRouteRequest) String

func (x *DeleteRouteRequest) String() string

DeleteStreamRequest

type DeleteStreamRequest struct {

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

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 (*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 (*DiscoverConnectionProfileRequest) Reset

func (*DiscoverConnectionProfileRequest) 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 (*DiscoverConnectionProfileResponse) Reset

func (*DiscoverConnectionProfileResponse) String

DiscoverConnectionProfileResponse_MysqlRdbms

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

DiscoverConnectionProfileResponse_OracleRdbms

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

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 *timestamp.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() *timestamp.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 (*ForwardSshTunnelConnectivity) Reset

func (x *ForwardSshTunnelConnectivity) Reset()

func (*ForwardSshTunnelConnectivity) String

ForwardSshTunnelConnectivity_Password

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

ForwardSshTunnelConnectivity_PrivateKey

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

GcsDestinationConfig

type GcsDestinationConfig struct {
	Path 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 *duration.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() *duration.Duration

func (*GcsDestinationConfig) GetFileRotationMb

func (x *GcsDestinationConfig) GetFileRotationMb() int32

func (*GcsDestinationConfig) GetGcsFileFormat

func (x *GcsDestinationConfig) GetGcsFileFormat() GcsFileFormat

Deprecated: Do not use.

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: Do not use.

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) 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 (GcsFileFormat) String (deprecated)

func (x GcsFileFormat) String() string

func (GcsFileFormat) Type (deprecated)

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 (*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 (*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) Enum

func (JsonFileFormat_JsonCompression) EnumDescriptor

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

Deprecated: Use JsonFileFormat_JsonCompression.Descriptor instead.

func (JsonFileFormat_JsonCompression) Number

func (JsonFileFormat_JsonCompression) String

func (JsonFileFormat_JsonCompression) Type

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 (*ListConnectionProfilesRequest) Reset

func (x *ListConnectionProfilesRequest) Reset()

func (*ListConnectionProfilesRequest) String

ListConnectionProfilesResponse

type ListConnectionProfilesResponse struct {

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

func (*ListConnectionProfilesResponse) Descriptor

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

Deprecated: Use ListConnectionProfilesResponse.ProtoReflect.Descriptor instead.

func (*ListConnectionProfilesResponse) GetConnectionProfiles

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

func (*ListConnectionProfilesResponse) GetNextPageToken

func (x *ListConnectionProfilesResponse) GetNextPageToken() string

func (*ListConnectionProfilesResponse) GetUnreachable

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

func (*ListConnectionProfilesResponse) ProtoMessage

func (*ListConnectionProfilesResponse) ProtoMessage()

func (*ListConnectionProfilesResponse) ProtoReflect

func (*ListConnectionProfilesResponse) Reset

func (x *ListConnectionProfilesResponse) Reset()

func (*ListConnectionProfilesResponse) String

ListPrivateConnectionsRequest

type ListPrivateConnectionsRequest struct {

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

func (*ListPrivateConnectionsRequest) Descriptor

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

Deprecated: Use ListPrivateConnectionsRequest.ProtoReflect.Descriptor instead.

func (*ListPrivateConnectionsRequest) GetFilter

func (x *ListPrivateConnectionsRequest) GetFilter() string

func (*ListPrivateConnectionsRequest) GetOrderBy

func (x *ListPrivateConnectionsRequest) GetOrderBy() string

func (*ListPrivateConnectionsRequest) GetPageSize

func (x *ListPrivateConnectionsRequest) GetPageSize() int32

func (*ListPrivateConnectionsRequest) GetPageToken

func (x *ListPrivateConnectionsRequest) GetPageToken() string

func (*ListPrivateConnectionsRequest) GetParent

func (x *ListPrivateConnectionsRequest) GetParent() string

func (*ListPrivateConnectionsRequest) ProtoMessage

func (*ListPrivateConnectionsRequest) ProtoMessage()

func (*ListPrivateConnectionsRequest) ProtoReflect

func (*ListPrivateConnectionsRequest) Reset

func (x *ListPrivateConnectionsRequest) Reset()

func (*ListPrivateConnectionsRequest) String

ListPrivateConnectionsResponse

type ListPrivateConnectionsResponse struct {

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

func (*ListPrivateConnectionsResponse) Descriptor

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

Deprecated: Use ListPrivateConnectionsResponse.ProtoReflect.Descriptor instead.

func (*ListPrivateConnectionsResponse) GetNextPageToken

func (x *ListPrivateConnectionsResponse) GetNextPageToken() string

func (*ListPrivateConnectionsResponse) GetPrivateConnections

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

func (*ListPrivateConnectionsResponse) GetUnreachable

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

func (*ListPrivateConnectionsResponse) ProtoMessage

func (*ListPrivateConnectionsResponse) ProtoMessage()

func (*ListPrivateConnectionsResponse) ProtoReflect

func (*ListPrivateConnectionsResponse) Reset

func (x *ListPrivateConnectionsResponse) Reset()

func (*ListPrivateConnectionsResponse) String

ListRoutesRequest

type ListRoutesRequest struct {

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

route list request

func (*ListRoutesRequest) Descriptor

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

Deprecated: Use ListRoutesRequest.ProtoReflect.Descriptor instead.

func (*ListRoutesRequest) GetFilter

func (x *ListRoutesRequest) GetFilter() string

func (*ListRoutesRequest) GetOrderBy

func (x *ListRoutesRequest) GetOrderBy() string

func (*ListRoutesRequest) GetPageSize

func (x *ListRoutesRequest) GetPageSize() int32

func (*ListRoutesRequest) GetPageToken

func (x *ListRoutesRequest) GetPageToken() string

func (*ListRoutesRequest) GetParent

func (x *ListRoutesRequest) GetParent() string

func (*ListRoutesRequest) ProtoMessage

func (*ListRoutesRequest) ProtoMessage()

func (*ListRoutesRequest) ProtoReflect

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

func (*ListRoutesRequest) Reset

func (x *ListRoutesRequest) Reset()

func (*ListRoutesRequest) String

func (x *ListRoutesRequest) String() string

ListRoutesResponse

type ListRoutesResponse struct {

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

route list response

func (*ListRoutesResponse) Descriptor

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

Deprecated: Use ListRoutesResponse.ProtoReflect.Descriptor instead.

func (*ListRoutesResponse) GetNextPageToken

func (x *ListRoutesResponse) GetNextPageToken() string

func (*ListRoutesResponse) GetRoutes

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

func (*ListRoutesResponse) GetUnreachable

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

func (*ListRoutesResponse) ProtoMessage

func (*ListRoutesResponse) ProtoMessage()

func (*ListRoutesResponse) ProtoReflect

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

func (*ListRoutesResponse) Reset

func (x *ListRoutesResponse) Reset()

func (*ListRoutesResponse) String

func (x *ListRoutesResponse) String() string

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 *timestamp.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time the operation finished running.
	EndTime *timestamp.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() *timestamp.Timestamp

func (*OperationMetadata) GetEndTime

func (x *OperationMetadata) GetEndTime() *timestamp.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 *timestamp.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamp.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() *timestamp.Timestamp

func (*PrivateConnection) GetDisplayName

func (x *PrivateConnection) GetDisplayName() string

func (*PrivateConnection) GetError

func (x *PrivateConnection) GetError() *Error

func (*PrivateConnection) GetLabels

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

func (*PrivateConnection) GetName

func (x *PrivateConnection) GetName() string

func (*PrivateConnection) GetState

func (*PrivateConnection) GetUpdateTime

func (x *PrivateConnection) GetUpdateTime() *timestamp.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) Enum

func (PrivateConnection_State) EnumDescriptor

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

Deprecated: Use PrivateConnection_State.Descriptor instead.

func (PrivateConnection_State) Number

func (PrivateConnection_State) String

func (x PrivateConnection_State) String() string

func (PrivateConnection_State) Type

PrivateConnectivity

type PrivateConnectivity struct {
	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 *timestamp.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamp.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() *timestamp.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() *timestamp.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) Enum

func (SchemaFileFormat) EnumDescriptor

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

Deprecated: Use SchemaFileFormat.Descriptor instead.

func (SchemaFileFormat) Number

func (SchemaFileFormat) String

func (x SchemaFileFormat) String() string

func (SchemaFileFormat) Type

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 (*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 *timestamp.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamp.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() *timestamp.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() *timestamp.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 (*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 (*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) Enum

func (x Stream_State) Enum() *Stream_State

func (Stream_State) EnumDescriptor

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

Deprecated: Use Stream_State.Descriptor instead.

func (Stream_State) Number

func (Stream_State) String

func (x Stream_State) String() string

func (Stream_State) Type

UnimplementedDatastreamServer

type UnimplementedDatastreamServer struct {
}

UnimplementedDatastreamServer can be embedded to have forward compatible implementations.

func (*UnimplementedDatastreamServer) CreateConnectionProfile

func (*UnimplementedDatastreamServer) CreatePrivateConnection

func (*UnimplementedDatastreamServer) CreateRoute

func (*UnimplementedDatastreamServer) CreateStream

func (*UnimplementedDatastreamServer) DeleteConnectionProfile

func (*UnimplementedDatastreamServer) DeletePrivateConnection

func (*UnimplementedDatastreamServer) DeleteRoute

func (*UnimplementedDatastreamServer) DeleteStream

func (*UnimplementedDatastreamServer) DiscoverConnectionProfile

func (*UnimplementedDatastreamServer) FetchErrors

func (*UnimplementedDatastreamServer) FetchStaticIps

func (*UnimplementedDatastreamServer) GetConnectionProfile

func (*UnimplementedDatastreamServer) GetPrivateConnection

func (*UnimplementedDatastreamServer) GetRoute

func (*UnimplementedDatastreamServer) GetStream

func (*UnimplementedDatastreamServer) ListConnectionProfiles

func (*UnimplementedDatastreamServer) ListPrivateConnections

func (*UnimplementedDatastreamServer) ListRoutes

func (*UnimplementedDatastreamServer) ListStreams

func (*UnimplementedDatastreamServer) UpdateConnectionProfile

func (*UnimplementedDatastreamServer) UpdateStream

UpdateConnectionProfileRequest

type UpdateConnectionProfileRequest struct {

	// Optional. Field mask is used to specify the fields to be overwritten in the
	// ConnectionProfile resource by the update.
	// The fields specified in the update_mask are relative to the resource, not
	// the full request. A field will be overwritten if it is in the mask. If the
	// user does not provide a mask then all fields will be overwritten.
	UpdateMask *field_mask.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 (*UpdateConnectionProfileRequest) ProtoMessage

func (*UpdateConnectionProfileRequest) ProtoMessage()

func (*UpdateConnectionProfileRequest) ProtoReflect

func (*UpdateConnectionProfileRequest) Reset

func (x *UpdateConnectionProfileRequest) Reset()

func (*UpdateConnectionProfileRequest) String

UpdateStreamRequest

type UpdateStreamRequest struct {

	// Optional. Field mask is used to specify the fields to be overwritten in the
	// stream resource by the update.
	// The fields specified in the update_mask are relative to the resource, not
	// the full request. A field will be overwritten if it is in the mask. If the
	// user does not provide a mask then all fields will be overwritten.
	UpdateMask *field_mask.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() *field_mask.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 (*ValidationMessage) GetMessage

func (x *ValidationMessage) GetMessage() string

func (*ValidationMessage) GetMetadata

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

func (*ValidationMessage) ProtoMessage

func (*ValidationMessage) ProtoMessage()

func (*ValidationMessage) ProtoReflect

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

func (*ValidationMessage) Reset

func (x *ValidationMessage) Reset()

func (*ValidationMessage) String

func (x *ValidationMessage) String() string

ValidationMessage_Level

type ValidationMessage_Level int32

Validation message level.

ValidationMessage_LEVEL_UNSPECIFIED, ValidationMessage_WARNING, ValidationMessage_ERROR

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

func (ValidationMessage_Level) Descriptor

func (ValidationMessage_Level) Enum

func (ValidationMessage_Level) EnumDescriptor

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

Deprecated: Use ValidationMessage_Level.Descriptor instead.

func (ValidationMessage_Level) Number

func (ValidationMessage_Level) String

func (x ValidationMessage_Level) String() string

func (ValidationMessage_Level) Type

ValidationResult

type ValidationResult struct {

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

Contains the current validation results.

func (*ValidationResult) Descriptor

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

Deprecated: Use ValidationResult.ProtoReflect.Descriptor instead.

func (*ValidationResult) GetValidations

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

func (*ValidationResult) ProtoMessage

func (*ValidationResult) ProtoMessage()

func (*ValidationResult) ProtoReflect

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

func (*ValidationResult) Reset

func (x *ValidationResult) Reset()

func (*ValidationResult) String

func (x *ValidationResult) String() string

Validation_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) Enum

func (Validation_Status) EnumDescriptor

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

Deprecated: Use Validation_Status.Descriptor instead.

func (Validation_Status) Number

func (Validation_Status) String

func (x Validation_Status) String() string

func (Validation_Status) Type

VpcPeeringConfig

type VpcPeeringConfig struct {

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

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

func (*VpcPeeringConfig) Descriptor

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