Variables
Version_Type_name, Version_Type_value
var (
Version_Type_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "TYPE_PREVIEW",
2: "TYPE_GENERAL_AVAILABILITY",
}
Version_Type_value = map[string]int32{
"TYPE_UNSPECIFIED": 0,
"TYPE_PREVIEW": 1,
"TYPE_GENERAL_AVAILABILITY": 2,
}
)Enum value maps for Version_Type.
Accelerator_AcceleratorType_name, Accelerator_AcceleratorType_value
var (
Accelerator_AcceleratorType_name = map[int32]string{
0: "ACCELERATOR_TYPE_UNSPECIFIED",
1: "CDC",
2: "HEALTHCARE",
3: "CCAI_INSIGHTS",
}
Accelerator_AcceleratorType_value = map[string]int32{
"ACCELERATOR_TYPE_UNSPECIFIED": 0,
"CDC": 1,
"HEALTHCARE": 2,
"CCAI_INSIGHTS": 3,
}
)Enum value maps for Accelerator_AcceleratorType.
Accelerator_State_name, Accelerator_State_value
var (
Accelerator_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "ENABLED",
2: "DISABLED",
3: "UNKNOWN",
}
Accelerator_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"ENABLED": 1,
"DISABLED": 2,
"UNKNOWN": 3,
}
)Enum value maps for Accelerator_State.
Instance_Type_name, Instance_Type_value
var (
Instance_Type_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "BASIC",
2: "ENTERPRISE",
3: "DEVELOPER",
}
Instance_Type_value = map[string]int32{
"TYPE_UNSPECIFIED": 0,
"BASIC": 1,
"ENTERPRISE": 2,
"DEVELOPER": 3,
}
)Enum value maps for Instance_Type.
Instance_State_name, Instance_State_value
var (
Instance_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "CREATING",
2: "ACTIVE",
3: "FAILED",
4: "DELETING",
5: "UPGRADING",
6: "RESTARTING",
7: "UPDATING",
8: "AUTO_UPDATING",
9: "AUTO_UPGRADING",
10: "DISABLED",
}
Instance_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"CREATING": 1,
"ACTIVE": 2,
"FAILED": 3,
"DELETING": 4,
"UPGRADING": 5,
"RESTARTING": 6,
"UPDATING": 7,
"AUTO_UPDATING": 8,
"AUTO_UPGRADING": 9,
"DISABLED": 10,
}
)Enum value maps for Instance_State.
Instance_DisabledReason_name, Instance_DisabledReason_value
var (
Instance_DisabledReason_name = map[int32]string{
0: "DISABLED_REASON_UNSPECIFIED",
1: "KMS_KEY_ISSUE",
}
Instance_DisabledReason_value = map[string]int32{
"DISABLED_REASON_UNSPECIFIED": 0,
"KMS_KEY_ISSUE": 1,
}
)Enum value maps for Instance_DisabledReason.
File_google_cloud_datafusion_v1_datafusion_proto
var File_google_cloud_datafusion_v1_datafusion_proto protoreflect.FileDescriptorFunctions
func RegisterDataFusionServer
func RegisterDataFusionServer(s *grpc.Server, srv DataFusionServer)Accelerator
type Accelerator struct {
AcceleratorType Accelerator_AcceleratorType "" /* 167 byte string literal not displayed */
State Accelerator_State `protobuf:"varint,2,opt,name=state,proto3,enum=google.cloud.datafusion.v1.Accelerator_State" json:"state,omitempty"`
}Identifies Data Fusion accelerators for an instance.
func (*Accelerator) Descriptor
func (*Accelerator) Descriptor() ([]byte, []int)Deprecated: Use Accelerator.ProtoReflect.Descriptor instead.
func (*Accelerator) GetAcceleratorType
func (x *Accelerator) GetAcceleratorType() Accelerator_AcceleratorTypefunc (*Accelerator) GetState
func (x *Accelerator) GetState() Accelerator_Statefunc (*Accelerator) ProtoMessage
func (*Accelerator) ProtoMessage()func (*Accelerator) ProtoReflect
func (x *Accelerator) ProtoReflect() protoreflect.Messagefunc (*Accelerator) Reset
func (x *Accelerator) Reset()func (*Accelerator) String
func (x *Accelerator) String() stringAccelerator_AcceleratorType
type Accelerator_AcceleratorType int32Each type represents an Accelerator (Add-On) supported by Cloud Data Fusion service.
Accelerator_ACCELERATOR_TYPE_UNSPECIFIED, Accelerator_CDC, Accelerator_HEALTHCARE, Accelerator_CCAI_INSIGHTS
const (
// Default value, if unspecified.
Accelerator_ACCELERATOR_TYPE_UNSPECIFIED Accelerator_AcceleratorType = 0
// Change Data Capture accelerator for CDF.
Accelerator_CDC Accelerator_AcceleratorType = 1
// Cloud Healthcare accelerator for CDF. This accelerator is to enable Cloud
// Healthcare specific CDF plugins developed by Healthcare team.
Accelerator_HEALTHCARE Accelerator_AcceleratorType = 2
// Contact Center AI Insights
// This accelerator is used to enable import and export pipelines
// custom built to streamline CCAI Insights processing.
Accelerator_CCAI_INSIGHTS Accelerator_AcceleratorType = 3
)func (Accelerator_AcceleratorType) Descriptor
func (Accelerator_AcceleratorType) Descriptor() protoreflect.EnumDescriptorfunc (Accelerator_AcceleratorType) Enum
func (x Accelerator_AcceleratorType) Enum() *Accelerator_AcceleratorTypefunc (Accelerator_AcceleratorType) EnumDescriptor
func (Accelerator_AcceleratorType) EnumDescriptor() ([]byte, []int)Deprecated: Use Accelerator_AcceleratorType.Descriptor instead.
func (Accelerator_AcceleratorType) Number
func (x Accelerator_AcceleratorType) Number() protoreflect.EnumNumberfunc (Accelerator_AcceleratorType) String
func (x Accelerator_AcceleratorType) String() stringfunc (Accelerator_AcceleratorType) Type
func (Accelerator_AcceleratorType) Type() protoreflect.EnumTypeAccelerator_State
type Accelerator_State int32Different values possible for the state of an accelerator
Accelerator_STATE_UNSPECIFIED, Accelerator_ENABLED, Accelerator_DISABLED, Accelerator_UNKNOWN
const (
// Default value, do not use
Accelerator_STATE_UNSPECIFIED Accelerator_State = 0
// Indicates that the accelerator is enabled and available to use
Accelerator_ENABLED Accelerator_State = 1
// Indicates that the accelerator is disabled and not available to use
Accelerator_DISABLED Accelerator_State = 2
// Indicates that accelerator state is currently unknown.
// Requests for enable, disable could be retried while in this state
Accelerator_UNKNOWN Accelerator_State = 3
)func (Accelerator_State) Descriptor
func (Accelerator_State) Descriptor() protoreflect.EnumDescriptorfunc (Accelerator_State) Enum
func (x Accelerator_State) Enum() *Accelerator_Statefunc (Accelerator_State) EnumDescriptor
func (Accelerator_State) EnumDescriptor() ([]byte, []int)Deprecated: Use Accelerator_State.Descriptor instead.
func (Accelerator_State) Number
func (x Accelerator_State) Number() protoreflect.EnumNumberfunc (Accelerator_State) String
func (x Accelerator_State) String() stringfunc (Accelerator_State) Type
func (Accelerator_State) Type() protoreflect.EnumTypeCreateInstanceRequest
type CreateInstanceRequest struct {
// Required. The instance's project and location in the format
// projects/{project}/locations/{location}.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The name of the instance to create.
InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
// An instance resource.
Instance *Instance `protobuf:"bytes,3,opt,name=instance,proto3" json:"instance,omitempty"`
// contains filtered or unexported fields
}Request message for creating a Data Fusion instance.
func (*CreateInstanceRequest) Descriptor
func (*CreateInstanceRequest) Descriptor() ([]byte, []int)Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.
func (*CreateInstanceRequest) GetInstance
func (x *CreateInstanceRequest) GetInstance() *Instancefunc (*CreateInstanceRequest) GetInstanceId
func (x *CreateInstanceRequest) GetInstanceId() stringfunc (*CreateInstanceRequest) GetParent
func (x *CreateInstanceRequest) GetParent() stringfunc (*CreateInstanceRequest) ProtoMessage
func (*CreateInstanceRequest) ProtoMessage()func (*CreateInstanceRequest) ProtoReflect
func (x *CreateInstanceRequest) ProtoReflect() protoreflect.Messagefunc (*CreateInstanceRequest) Reset
func (x *CreateInstanceRequest) Reset()func (*CreateInstanceRequest) String
func (x *CreateInstanceRequest) String() stringCryptoKeyConfig
type CryptoKeyConfig struct {
// The name of the key which is used to encrypt/decrypt customer data. For key
// in Cloud KMS, the key should be in the format of
// `projects/*/locations/*/keyRings/*/cryptoKeys/*`.
KeyReference string `protobuf:"bytes,1,opt,name=key_reference,json=keyReference,proto3" json:"key_reference,omitempty"`
// contains filtered or unexported fields
}The crypto key configuration. This field is used by the Customer-managed encryption keys (CMEK) feature.
func (*CryptoKeyConfig) Descriptor
func (*CryptoKeyConfig) Descriptor() ([]byte, []int)Deprecated: Use CryptoKeyConfig.ProtoReflect.Descriptor instead.
func (*CryptoKeyConfig) GetKeyReference
func (x *CryptoKeyConfig) GetKeyReference() stringfunc (*CryptoKeyConfig) ProtoMessage
func (*CryptoKeyConfig) ProtoMessage()func (*CryptoKeyConfig) ProtoReflect
func (x *CryptoKeyConfig) ProtoReflect() protoreflect.Messagefunc (*CryptoKeyConfig) Reset
func (x *CryptoKeyConfig) Reset()func (*CryptoKeyConfig) String
func (x *CryptoKeyConfig) String() stringDataFusionClient
type DataFusionClient interface {
// Lists possible versions for Data Fusion instances in the specified project
// and location.
ListAvailableVersions(ctx context.Context, in *ListAvailableVersionsRequest, opts ...grpc.CallOption) (*ListAvailableVersionsResponse, error)
// Lists Data Fusion instances in the specified project and location.
ListInstances(ctx context.Context, in *ListInstancesRequest, opts ...grpc.CallOption) (*ListInstancesResponse, error)
// Gets details of a single Data Fusion instance.
GetInstance(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*Instance, error)
// Creates a new Data Fusion instance in the specified project and location.
CreateInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Deletes a single Date Fusion instance.
DeleteInstance(ctx context.Context, in *DeleteInstanceRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Updates a single Data Fusion instance.
UpdateInstance(ctx context.Context, in *UpdateInstanceRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Restart a single Data Fusion instance.
// At the end of an operation instance is fully restarted.
RestartInstance(ctx context.Context, in *RestartInstanceRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
}DataFusionClient is the client API for DataFusion service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDataFusionClient
func NewDataFusionClient(cc grpc.ClientConnInterface) DataFusionClientDataFusionServer
type DataFusionServer interface {
// Lists possible versions for Data Fusion instances in the specified project
// and location.
ListAvailableVersions(context.Context, *ListAvailableVersionsRequest) (*ListAvailableVersionsResponse, error)
// Lists Data Fusion instances in the specified project and location.
ListInstances(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)
// Gets details of a single Data Fusion instance.
GetInstance(context.Context, *GetInstanceRequest) (*Instance, error)
// Creates a new Data Fusion instance in the specified project and location.
CreateInstance(context.Context, *CreateInstanceRequest) (*longrunningpb.Operation, error)
// Deletes a single Date Fusion instance.
DeleteInstance(context.Context, *DeleteInstanceRequest) (*longrunningpb.Operation, error)
// Updates a single Data Fusion instance.
UpdateInstance(context.Context, *UpdateInstanceRequest) (*longrunningpb.Operation, error)
// Restart a single Data Fusion instance.
// At the end of an operation instance is fully restarted.
RestartInstance(context.Context, *RestartInstanceRequest) (*longrunningpb.Operation, error)
}DataFusionServer is the server API for DataFusion service.
DeleteInstanceRequest
type DeleteInstanceRequest struct {
// Required. The instance resource name in the format
// projects/{project}/locations/{location}/instances/{instance}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}Request message for deleting a Data Fusion instance.
func (*DeleteInstanceRequest) Descriptor
func (*DeleteInstanceRequest) Descriptor() ([]byte, []int)Deprecated: Use DeleteInstanceRequest.ProtoReflect.Descriptor instead.
func (*DeleteInstanceRequest) GetName
func (x *DeleteInstanceRequest) GetName() stringfunc (*DeleteInstanceRequest) ProtoMessage
func (*DeleteInstanceRequest) ProtoMessage()func (*DeleteInstanceRequest) ProtoReflect
func (x *DeleteInstanceRequest) ProtoReflect() protoreflect.Messagefunc (*DeleteInstanceRequest) Reset
func (x *DeleteInstanceRequest) Reset()func (*DeleteInstanceRequest) String
func (x *DeleteInstanceRequest) String() stringGetInstanceRequest
type GetInstanceRequest struct {
// Required. The instance resource name in the format
// projects/{project}/locations/{location}/instances/{instance}.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}Request message for getting details about a Data Fusion instance.
func (*GetInstanceRequest) Descriptor
func (*GetInstanceRequest) Descriptor() ([]byte, []int)Deprecated: Use GetInstanceRequest.ProtoReflect.Descriptor instead.
func (*GetInstanceRequest) GetName
func (x *GetInstanceRequest) GetName() stringfunc (*GetInstanceRequest) ProtoMessage
func (*GetInstanceRequest) ProtoMessage()func (*GetInstanceRequest) ProtoReflect
func (x *GetInstanceRequest) ProtoReflect() protoreflect.Messagefunc (*GetInstanceRequest) Reset
func (x *GetInstanceRequest) Reset()func (*GetInstanceRequest) String
func (x *GetInstanceRequest) String() stringInstance
type Instance struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
Type Instance_Type `protobuf:"varint,3,opt,name=type,proto3,enum=google.cloud.datafusion.v1.Instance_Type" json:"type,omitempty"`
EnableStackdriverLogging bool "" /* 136 byte string literal not displayed */
EnableStackdriverMonitoring bool "" /* 145 byte string literal not displayed */
PrivateInstance bool `protobuf:"varint,6,opt,name=private_instance,json=privateInstance,proto3" json:"private_instance,omitempty"`
NetworkConfig *NetworkConfig `protobuf:"bytes,7,opt,name=network_config,json=networkConfig,proto3" json:"network_config,omitempty"`
Labels map[string]string "" /* 153 byte string literal not displayed */
Options map[string]string "" /* 155 byte string literal not displayed */
CreateTime *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
State Instance_State `protobuf:"varint,12,opt,name=state,proto3,enum=google.cloud.datafusion.v1.Instance_State" json:"state,omitempty"`
StateMessage string `protobuf:"bytes,13,opt,name=state_message,json=stateMessage,proto3" json:"state_message,omitempty"`
ServiceEndpoint string `protobuf:"bytes,14,opt,name=service_endpoint,json=serviceEndpoint,proto3" json:"service_endpoint,omitempty"`
Zone string `protobuf:"bytes,15,opt,name=zone,proto3" json:"zone,omitempty"`
Version string `protobuf:"bytes,16,opt,name=version,proto3" json:"version,omitempty"`
ServiceAccount string `protobuf:"bytes,17,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
DisplayName string `protobuf:"bytes,18,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
AvailableVersion []*Version `protobuf:"bytes,19,rep,name=available_version,json=availableVersion,proto3" json:"available_version,omitempty"`
ApiEndpoint string `protobuf:"bytes,20,opt,name=api_endpoint,json=apiEndpoint,proto3" json:"api_endpoint,omitempty"`
GcsBucket string `protobuf:"bytes,21,opt,name=gcs_bucket,json=gcsBucket,proto3" json:"gcs_bucket,omitempty"`
Accelerators []*Accelerator `protobuf:"bytes,22,rep,name=accelerators,proto3" json:"accelerators,omitempty"`
P4ServiceAccount string `protobuf:"bytes,23,opt,name=p4_service_account,json=p4ServiceAccount,proto3" json:"p4_service_account,omitempty"`
TenantProjectId string `protobuf:"bytes,24,opt,name=tenant_project_id,json=tenantProjectId,proto3" json:"tenant_project_id,omitempty"`
DataprocServiceAccount string "" /* 130 byte string literal not displayed */
EnableRbac bool `protobuf:"varint,27,opt,name=enable_rbac,json=enableRbac,proto3" json:"enable_rbac,omitempty"`
CryptoKeyConfig *CryptoKeyConfig `protobuf:"bytes,28,opt,name=crypto_key_config,json=cryptoKeyConfig,proto3" json:"crypto_key_config,omitempty"`
DisabledReason []Instance_DisabledReason "" /* 168 byte string literal not displayed */
}Represents a Data Fusion instance.
func (*Instance) Descriptor
Deprecated: Use Instance.ProtoReflect.Descriptor instead.
func (*Instance) GetAccelerators
func (x *Instance) GetAccelerators() []*Acceleratorfunc (*Instance) GetApiEndpoint
func (*Instance) GetAvailableVersion
func (*Instance) GetCreateTime
func (x *Instance) GetCreateTime() *timestamppb.Timestampfunc (*Instance) GetCryptoKeyConfig
func (x *Instance) GetCryptoKeyConfig() *CryptoKeyConfigfunc (*Instance) GetDataprocServiceAccount
func (*Instance) GetDescription
func (*Instance) GetDisabledReason
func (x *Instance) GetDisabledReason() []Instance_DisabledReasonfunc (*Instance) GetDisplayName
func (*Instance) GetEnableRbac
func (*Instance) GetEnableStackdriverLogging
func (*Instance) GetEnableStackdriverMonitoring
func (*Instance) GetGcsBucket
func (*Instance) GetLabels
func (*Instance) GetName
func (*Instance) GetNetworkConfig
func (x *Instance) GetNetworkConfig() *NetworkConfigfunc (*Instance) GetOptions
func (*Instance) GetP4ServiceAccount
func (*Instance) GetPrivateInstance
func (*Instance) GetServiceAccount
Deprecated: Marked as deprecated in google/cloud/datafusion/v1/datafusion.proto.
func (*Instance) GetServiceEndpoint
func (*Instance) GetState
func (x *Instance) GetState() Instance_Statefunc (*Instance) GetStateMessage
func (*Instance) GetTenantProjectId
func (*Instance) GetType
func (x *Instance) GetType() Instance_Typefunc (*Instance) GetUpdateTime
func (x *Instance) GetUpdateTime() *timestamppb.Timestampfunc (*Instance) GetVersion
func (*Instance) GetZone
func (*Instance) ProtoMessage
func (*Instance) ProtoMessage()func (*Instance) ProtoReflect
func (x *Instance) ProtoReflect() protoreflect.Messagefunc (*Instance) Reset
func (x *Instance) Reset()func (*Instance) String
Instance_DisabledReason
type Instance_DisabledReason int32The reason for disabling the instance if the state is DISABLED.
Instance_DISABLED_REASON_UNSPECIFIED, Instance_KMS_KEY_ISSUE
const (
// This is an unknown reason for disabling.
Instance_DISABLED_REASON_UNSPECIFIED Instance_DisabledReason = 0
// The KMS key used by the instance is either revoked or denied access to
Instance_KMS_KEY_ISSUE Instance_DisabledReason = 1
)func (Instance_DisabledReason) Descriptor
func (Instance_DisabledReason) Descriptor() protoreflect.EnumDescriptorfunc (Instance_DisabledReason) Enum
func (x Instance_DisabledReason) Enum() *Instance_DisabledReasonfunc (Instance_DisabledReason) EnumDescriptor
func (Instance_DisabledReason) EnumDescriptor() ([]byte, []int)Deprecated: Use Instance_DisabledReason.Descriptor instead.
func (Instance_DisabledReason) Number
func (x Instance_DisabledReason) Number() protoreflect.EnumNumberfunc (Instance_DisabledReason) String
func (x Instance_DisabledReason) String() stringfunc (Instance_DisabledReason) Type
func (Instance_DisabledReason) Type() protoreflect.EnumTypeInstance_State
type Instance_State int32Represents the state of a Data Fusion instance
Instance_STATE_UNSPECIFIED, Instance_CREATING, Instance_ACTIVE, Instance_FAILED, Instance_DELETING, Instance_UPGRADING, Instance_RESTARTING, Instance_UPDATING, Instance_AUTO_UPDATING, Instance_AUTO_UPGRADING, Instance_DISABLED
const (
// Instance does not have a state yet
Instance_STATE_UNSPECIFIED Instance_State = 0
// Instance is being created
Instance_CREATING Instance_State = 1
// Instance is active and ready for requests. This corresponds to 'RUNNING'
// in datafusion.v1beta1.
Instance_ACTIVE Instance_State = 2
// Instance creation failed
Instance_FAILED Instance_State = 3
// Instance is being deleted
Instance_DELETING Instance_State = 4
// Instance is being upgraded
Instance_UPGRADING Instance_State = 5
// Instance is being restarted
Instance_RESTARTING Instance_State = 6
// Instance is being updated on customer request
Instance_UPDATING Instance_State = 7
// Instance is being auto-updated
Instance_AUTO_UPDATING Instance_State = 8
// Instance is being auto-upgraded
Instance_AUTO_UPGRADING Instance_State = 9
// Instance is disabled
Instance_DISABLED Instance_State = 10
)func (Instance_State) Descriptor
func (Instance_State) Descriptor() protoreflect.EnumDescriptorfunc (Instance_State) Enum
func (x Instance_State) Enum() *Instance_Statefunc (Instance_State) EnumDescriptor
func (Instance_State) EnumDescriptor() ([]byte, []int)Deprecated: Use Instance_State.Descriptor instead.
func (Instance_State) Number
func (x Instance_State) Number() protoreflect.EnumNumberfunc (Instance_State) String
func (x Instance_State) String() stringfunc (Instance_State) Type
func (Instance_State) Type() protoreflect.EnumTypeInstance_Type
type Instance_Type int32Represents the type of Data Fusion instance. Each type is configured with the default settings for processing and memory.
Instance_TYPE_UNSPECIFIED, Instance_BASIC, Instance_ENTERPRISE, Instance_DEVELOPER
const (
// No type specified. The instance creation will fail.
Instance_TYPE_UNSPECIFIED Instance_Type = 0
// Basic Data Fusion instance. In Basic type, the user will be able to
// create data pipelines using point and click UI. However, there are
// certain limitations, such as fewer number of concurrent pipelines, no
// support for streaming pipelines, etc.
Instance_BASIC Instance_Type = 1
// Enterprise Data Fusion instance. In Enterprise type, the user will have
// all features available, such as support for streaming pipelines, higher
// number of concurrent pipelines, etc.
Instance_ENTERPRISE Instance_Type = 2
// Developer Data Fusion instance. In Developer type, the user will have all
// features available but with restrictive capabilities. This is to help
// enterprises design and develop their data ingestion and integration
// pipelines at low cost.
Instance_DEVELOPER Instance_Type = 3
)func (Instance_Type) Descriptor
func (Instance_Type) Descriptor() protoreflect.EnumDescriptorfunc (Instance_Type) Enum
func (x Instance_Type) Enum() *Instance_Typefunc (Instance_Type) EnumDescriptor
func (Instance_Type) EnumDescriptor() ([]byte, []int)Deprecated: Use Instance_Type.Descriptor instead.
func (Instance_Type) Number
func (x Instance_Type) Number() protoreflect.EnumNumberfunc (Instance_Type) String
func (x Instance_Type) String() stringfunc (Instance_Type) Type
func (Instance_Type) Type() protoreflect.EnumTypeListAvailableVersionsRequest
type ListAvailableVersionsRequest struct {
// Required. The project and location for which to retrieve instance information
// in the format projects/{project}/locations/{location}.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of items to return.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// The next_page_token value to use if there are additional
// results to retrieve for this list request.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// Whether or not to return the latest patch of every available minor version.
// If true, only the latest patch will be returned. Ex. if allowed versions is
// [6.1.1, 6.1.2, 6.2.0] then response will be [6.1.2, 6.2.0]
LatestPatchOnly bool `protobuf:"varint,4,opt,name=latest_patch_only,json=latestPatchOnly,proto3" json:"latest_patch_only,omitempty"`
// contains filtered or unexported fields
}Request message for the list available versions request.
func (*ListAvailableVersionsRequest) Descriptor
func (*ListAvailableVersionsRequest) Descriptor() ([]byte, []int)Deprecated: Use ListAvailableVersionsRequest.ProtoReflect.Descriptor instead.
func (*ListAvailableVersionsRequest) GetLatestPatchOnly
func (x *ListAvailableVersionsRequest) GetLatestPatchOnly() boolfunc (*ListAvailableVersionsRequest) GetPageSize
func (x *ListAvailableVersionsRequest) GetPageSize() int32func (*ListAvailableVersionsRequest) GetPageToken
func (x *ListAvailableVersionsRequest) GetPageToken() stringfunc (*ListAvailableVersionsRequest) GetParent
func (x *ListAvailableVersionsRequest) GetParent() stringfunc (*ListAvailableVersionsRequest) ProtoMessage
func (*ListAvailableVersionsRequest) ProtoMessage()func (*ListAvailableVersionsRequest) ProtoReflect
func (x *ListAvailableVersionsRequest) ProtoReflect() protoreflect.Messagefunc (*ListAvailableVersionsRequest) Reset
func (x *ListAvailableVersionsRequest) Reset()func (*ListAvailableVersionsRequest) String
func (x *ListAvailableVersionsRequest) String() stringListAvailableVersionsResponse
type ListAvailableVersionsResponse struct {
// Represents a list of versions that are supported.
AvailableVersions []*Version `protobuf:"bytes,1,rep,name=available_versions,json=availableVersions,proto3" json:"available_versions,omitempty"`
// Token to retrieve the next page of results or empty if there are no more
// results in the list.
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 the list available versions request.
func (*ListAvailableVersionsResponse) Descriptor
func (*ListAvailableVersionsResponse) Descriptor() ([]byte, []int)Deprecated: Use ListAvailableVersionsResponse.ProtoReflect.Descriptor instead.
func (*ListAvailableVersionsResponse) GetAvailableVersions
func (x *ListAvailableVersionsResponse) GetAvailableVersions() []*Versionfunc (*ListAvailableVersionsResponse) GetNextPageToken
func (x *ListAvailableVersionsResponse) GetNextPageToken() stringfunc (*ListAvailableVersionsResponse) ProtoMessage
func (*ListAvailableVersionsResponse) ProtoMessage()func (*ListAvailableVersionsResponse) ProtoReflect
func (x *ListAvailableVersionsResponse) ProtoReflect() protoreflect.Messagefunc (*ListAvailableVersionsResponse) Reset
func (x *ListAvailableVersionsResponse) Reset()func (*ListAvailableVersionsResponse) String
func (x *ListAvailableVersionsResponse) String() stringListInstancesRequest
type ListInstancesRequest struct {
// Required. The project and location for which to retrieve instance information
// in the format projects/{project}/locations/{location}. If the location is
// specified as '-' (wildcard), then all regions available to the project
// are queried, and the results are aggregated.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of items to return.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// The next_page_token value to use if there are additional
// results to retrieve for this list request.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// List filter.
Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
// Sort results. Supported values are "name", "name desc", or "" (unsorted).
OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
// contains filtered or unexported fields
}Request message for listing Data Fusion instances.
func (*ListInstancesRequest) Descriptor
func (*ListInstancesRequest) Descriptor() ([]byte, []int)Deprecated: Use ListInstancesRequest.ProtoReflect.Descriptor instead.
func (*ListInstancesRequest) GetFilter
func (x *ListInstancesRequest) GetFilter() stringfunc (*ListInstancesRequest) GetOrderBy
func (x *ListInstancesRequest) GetOrderBy() stringfunc (*ListInstancesRequest) GetPageSize
func (x *ListInstancesRequest) GetPageSize() int32func (*ListInstancesRequest) GetPageToken
func (x *ListInstancesRequest) GetPageToken() stringfunc (*ListInstancesRequest) GetParent
func (x *ListInstancesRequest) GetParent() stringfunc (*ListInstancesRequest) ProtoMessage
func (*ListInstancesRequest) ProtoMessage()func (*ListInstancesRequest) ProtoReflect
func (x *ListInstancesRequest) ProtoReflect() protoreflect.Messagefunc (*ListInstancesRequest) Reset
func (x *ListInstancesRequest) Reset()func (*ListInstancesRequest) String
func (x *ListInstancesRequest) String() stringListInstancesResponse
type ListInstancesResponse struct {
// Represents a list of Data Fusion instances.
Instances []*Instance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
// Token to retrieve the next page of results or empty if there are no more
// results in the list.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Locations that could not be reached.
Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}Response message for the list instance request.
func (*ListInstancesResponse) Descriptor
func (*ListInstancesResponse) Descriptor() ([]byte, []int)Deprecated: Use ListInstancesResponse.ProtoReflect.Descriptor instead.
func (*ListInstancesResponse) GetInstances
func (x *ListInstancesResponse) GetInstances() []*Instancefunc (*ListInstancesResponse) GetNextPageToken
func (x *ListInstancesResponse) GetNextPageToken() stringfunc (*ListInstancesResponse) GetUnreachable
func (x *ListInstancesResponse) GetUnreachable() []stringfunc (*ListInstancesResponse) ProtoMessage
func (*ListInstancesResponse) ProtoMessage()func (*ListInstancesResponse) ProtoReflect
func (x *ListInstancesResponse) ProtoReflect() protoreflect.Messagefunc (*ListInstancesResponse) Reset
func (x *ListInstancesResponse) Reset()func (*ListInstancesResponse) String
func (x *ListInstancesResponse) String() stringNetworkConfig
type NetworkConfig struct {
// Name of the network in the customer project with which the Tenant Project
// will be peered for executing pipelines. In case of shared VPC where the
// network resides in another host project the network should specified in
// the form of projects/{host-project-id}/global/networks/{network}
Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
// The IP range in CIDR notation to use for the managed Data Fusion instance
// nodes. This range must not overlap with any other ranges used in the
// customer network.
IpAllocation string `protobuf:"bytes,2,opt,name=ip_allocation,json=ipAllocation,proto3" json:"ip_allocation,omitempty"`
// contains filtered or unexported fields
}Network configuration for a Data Fusion instance. These configurations are used for peering with the customer network. Configurations are optional when a public Data Fusion instance is to be created. However, providing these configurations allows several benefits, such as reduced network latency while accessing the customer resources from managed Data Fusion instance nodes, as well as access to the customer on-prem resources.
func (*NetworkConfig) Descriptor
func (*NetworkConfig) Descriptor() ([]byte, []int)Deprecated: Use NetworkConfig.ProtoReflect.Descriptor instead.
func (*NetworkConfig) GetIpAllocation
func (x *NetworkConfig) GetIpAllocation() stringfunc (*NetworkConfig) GetNetwork
func (x *NetworkConfig) GetNetwork() stringfunc (*NetworkConfig) ProtoMessage
func (*NetworkConfig) ProtoMessage()func (*NetworkConfig) ProtoReflect
func (x *NetworkConfig) ProtoReflect() protoreflect.Messagefunc (*NetworkConfig) Reset
func (x *NetworkConfig) Reset()func (*NetworkConfig) String
func (x *NetworkConfig) String() stringOperationMetadata
type OperationMetadata struct {
CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
StatusDetail string `protobuf:"bytes,5,opt,name=status_detail,json=statusDetail,proto3" json:"status_detail,omitempty"`
RequestedCancellation bool `protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
AdditionalStatus map[string]string "" /* 197 byte string literal not displayed */
}Represents the metadata of a long-running operation.
func (*OperationMetadata) Descriptor
func (*OperationMetadata) Descriptor() ([]byte, []int)Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.
func (*OperationMetadata) GetAdditionalStatus
func (x *OperationMetadata) GetAdditionalStatus() map[string]stringfunc (*OperationMetadata) GetApiVersion
func (x *OperationMetadata) GetApiVersion() stringfunc (*OperationMetadata) GetCreateTime
func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestampfunc (*OperationMetadata) GetEndTime
func (x *OperationMetadata) GetEndTime() *timestamppb.Timestampfunc (*OperationMetadata) GetRequestedCancellation
func (x *OperationMetadata) GetRequestedCancellation() boolfunc (*OperationMetadata) GetStatusDetail
func (x *OperationMetadata) GetStatusDetail() stringfunc (*OperationMetadata) GetTarget
func (x *OperationMetadata) GetTarget() stringfunc (*OperationMetadata) GetVerb
func (x *OperationMetadata) GetVerb() stringfunc (*OperationMetadata) ProtoMessage
func (*OperationMetadata) ProtoMessage()func (*OperationMetadata) ProtoReflect
func (x *OperationMetadata) ProtoReflect() protoreflect.Messagefunc (*OperationMetadata) Reset
func (x *OperationMetadata) Reset()func (*OperationMetadata) String
func (x *OperationMetadata) String() stringRestartInstanceRequest
type RestartInstanceRequest struct {
// Required. Name of the Data Fusion instance which need to be restarted in the form of
// projects/{project}/locations/{location}/instances/{instance}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}Request message for restarting a Data Fusion instance.
func (*RestartInstanceRequest) Descriptor
func (*RestartInstanceRequest) Descriptor() ([]byte, []int)Deprecated: Use RestartInstanceRequest.ProtoReflect.Descriptor instead.
func (*RestartInstanceRequest) GetName
func (x *RestartInstanceRequest) GetName() stringfunc (*RestartInstanceRequest) ProtoMessage
func (*RestartInstanceRequest) ProtoMessage()func (*RestartInstanceRequest) ProtoReflect
func (x *RestartInstanceRequest) ProtoReflect() protoreflect.Messagefunc (*RestartInstanceRequest) Reset
func (x *RestartInstanceRequest) Reset()func (*RestartInstanceRequest) String
func (x *RestartInstanceRequest) String() stringUnimplementedDataFusionServer
type UnimplementedDataFusionServer struct {
}UnimplementedDataFusionServer can be embedded to have forward compatible implementations.
func (*UnimplementedDataFusionServer) CreateInstance
func (*UnimplementedDataFusionServer) CreateInstance(context.Context, *CreateInstanceRequest) (*longrunningpb.Operation, error)func (*UnimplementedDataFusionServer) DeleteInstance
func (*UnimplementedDataFusionServer) DeleteInstance(context.Context, *DeleteInstanceRequest) (*longrunningpb.Operation, error)func (*UnimplementedDataFusionServer) GetInstance
func (*UnimplementedDataFusionServer) GetInstance(context.Context, *GetInstanceRequest) (*Instance, error)func (*UnimplementedDataFusionServer) ListAvailableVersions
func (*UnimplementedDataFusionServer) ListAvailableVersions(context.Context, *ListAvailableVersionsRequest) (*ListAvailableVersionsResponse, error)func (*UnimplementedDataFusionServer) ListInstances
func (*UnimplementedDataFusionServer) ListInstances(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)func (*UnimplementedDataFusionServer) RestartInstance
func (*UnimplementedDataFusionServer) RestartInstance(context.Context, *RestartInstanceRequest) (*longrunningpb.Operation, error)func (*UnimplementedDataFusionServer) UpdateInstance
func (*UnimplementedDataFusionServer) UpdateInstance(context.Context, *UpdateInstanceRequest) (*longrunningpb.Operation, error)UpdateInstanceRequest
type UpdateInstanceRequest struct {
// Required. The instance resource that replaces the resource on the server. Currently,
// Data Fusion only allows replacing labels, options, and stack driver
// settings. All other fields will be ignored.
Instance *Instance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
// Field mask is used to specify the fields that the update will overwrite
// in an instance resource. 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, all the supported fields (labels,
// options, and version currently) will be overwritten.
UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// contains filtered or unexported fields
}Request message for updating a Data Fusion instance. Data Fusion allows updating the labels, options, and stack driver settings. This is also used for CDF version upgrade.
func (*UpdateInstanceRequest) Descriptor
func (*UpdateInstanceRequest) Descriptor() ([]byte, []int)Deprecated: Use UpdateInstanceRequest.ProtoReflect.Descriptor instead.
func (*UpdateInstanceRequest) GetInstance
func (x *UpdateInstanceRequest) GetInstance() *Instancefunc (*UpdateInstanceRequest) GetUpdateMask
func (x *UpdateInstanceRequest) GetUpdateMask() *fieldmaskpb.FieldMaskfunc (*UpdateInstanceRequest) ProtoMessage
func (*UpdateInstanceRequest) ProtoMessage()func (*UpdateInstanceRequest) ProtoReflect
func (x *UpdateInstanceRequest) ProtoReflect() protoreflect.Messagefunc (*UpdateInstanceRequest) Reset
func (x *UpdateInstanceRequest) Reset()func (*UpdateInstanceRequest) String
func (x *UpdateInstanceRequest) String() stringVersion
type Version struct {
// The version number of the Data Fusion instance, such as '6.0.1.0'.
VersionNumber string `protobuf:"bytes,1,opt,name=version_number,json=versionNumber,proto3" json:"version_number,omitempty"`
// Whether this is currently the default version for Cloud Data Fusion
DefaultVersion bool `protobuf:"varint,2,opt,name=default_version,json=defaultVersion,proto3" json:"default_version,omitempty"`
// Represents a list of available feature names for a given version.
AvailableFeatures []string `protobuf:"bytes,3,rep,name=available_features,json=availableFeatures,proto3" json:"available_features,omitempty"`
// Type represents the release availability of the version
Type Version_Type `protobuf:"varint,4,opt,name=type,proto3,enum=google.cloud.datafusion.v1.Version_Type" json:"type,omitempty"`
// contains filtered or unexported fields
}The Data Fusion version. This proto message stores information about certain Data Fusion version, which is used for Data Fusion version upgrade.
func (*Version) Descriptor
Deprecated: Use Version.ProtoReflect.Descriptor instead.
func (*Version) GetAvailableFeatures
func (*Version) GetDefaultVersion
func (*Version) GetType
func (x *Version) GetType() Version_Typefunc (*Version) GetVersionNumber
func (*Version) ProtoMessage
func (*Version) ProtoMessage()func (*Version) ProtoReflect
func (x *Version) ProtoReflect() protoreflect.Messagefunc (*Version) Reset
func (x *Version) Reset()func (*Version) String
Version_Type
type Version_Type int32Each type represents the release availability of a CDF version
Version_TYPE_UNSPECIFIED, Version_TYPE_PREVIEW, Version_TYPE_GENERAL_AVAILABILITY
const (
// Version does not have availability yet
Version_TYPE_UNSPECIFIED Version_Type = 0
// Version is under development and not considered stable
Version_TYPE_PREVIEW Version_Type = 1
// Version is available for public use
Version_TYPE_GENERAL_AVAILABILITY Version_Type = 2
)func (Version_Type) Descriptor
func (Version_Type) Descriptor() protoreflect.EnumDescriptorfunc (Version_Type) Enum
func (x Version_Type) Enum() *Version_Typefunc (Version_Type) EnumDescriptor
func (Version_Type) EnumDescriptor() ([]byte, []int)Deprecated: Use Version_Type.Descriptor instead.
func (Version_Type) Number
func (x Version_Type) Number() protoreflect.EnumNumberfunc (Version_Type) String
func (x Version_Type) String() stringfunc (Version_Type) Type
func (Version_Type) Type() protoreflect.EnumType