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
.
FileDescriptor
Functions
func RegisterDataFusionServer
func
RegisterDataFusionServer
(
s
*
grpc
.
Server
,
srv
DataFusionServer
)
Accelerator
type
Accelerator
struct
{
// The type of an accelator for a CDF instance.
AcceleratorType
Accelerator_AcceleratorType
`protobuf:"varint,1,opt,name=accelerator_type,json=acceleratorType,proto3,enum=google.cloud.datafusion.v1.Accelerator_AcceleratorType" json:"accelerator_type,omitempty"`
// The state of the accelerator
State
Accelerator_State
`protobuf:"varint,2,opt,name=state,proto3,enum=google.cloud.datafusion.v1.Accelerator_State" json:"state,omitempty"`
// contains filtered or unexported fields
}
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_AcceleratorType
func (*Accelerator) GetState
func
(
x
*
Accelerator
)
GetState
()
Accelerator_State
func (*Accelerator) ProtoMessage
func
(
*
Accelerator
)
ProtoMessage
()
func (*Accelerator) ProtoReflect
func
(
x
*
Accelerator
)
ProtoReflect
()
protoreflect
.
Message
func (*Accelerator) Reset
func
(
x
*
Accelerator
)
Reset
()
func (*Accelerator) String
func
(
x
*
Accelerator
)
String
()
string
Accelerator_AcceleratorType
type
Accelerator_AcceleratorType
int32
Each 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
.
EnumDescriptor
func (Accelerator_AcceleratorType) Enum
func
(
x
Accelerator_AcceleratorType
)
Enum
()
*
Accelerator_AcceleratorType
func (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
.
EnumNumber
func (Accelerator_AcceleratorType) String
func
(
x
Accelerator_AcceleratorType
)
String
()
string
func (Accelerator_AcceleratorType) Type
func
(
Accelerator_AcceleratorType
)
Type
()
protoreflect
.
EnumType
Accelerator_State
type
Accelerator_State
int32
Different 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
.
EnumDescriptor
func (Accelerator_State) Enum
func
(
x
Accelerator_State
)
Enum
()
*
Accelerator_State
func (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
.
EnumNumber
func (Accelerator_State) String
func
(
x
Accelerator_State
)
String
()
string
func (Accelerator_State) Type
func
(
Accelerator_State
)
Type
()
protoreflect
.
EnumType
CreateInstanceRequest
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
()
*
Instance
func (*CreateInstanceRequest) GetInstanceId
func
(
x
*
CreateInstanceRequest
)
GetInstanceId
()
string
func (*CreateInstanceRequest) GetParent
func
(
x
*
CreateInstanceRequest
)
GetParent
()
string
func (*CreateInstanceRequest) ProtoMessage
func
(
*
CreateInstanceRequest
)
ProtoMessage
()
func (*CreateInstanceRequest) ProtoReflect
func
(
x
*
CreateInstanceRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*CreateInstanceRequest) Reset
func
(
x
*
CreateInstanceRequest
)
Reset
()
func (*CreateInstanceRequest) String
func
(
x
*
CreateInstanceRequest
)
String
()
string
CryptoKeyConfig
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
()
string
func (*CryptoKeyConfig) ProtoMessage
func
(
*
CryptoKeyConfig
)
ProtoMessage
()
func (*CryptoKeyConfig) ProtoReflect
func
(
x
*
CryptoKeyConfig
)
ProtoReflect
()
protoreflect
.
Message
func (*CryptoKeyConfig) Reset
func
(
x
*
CryptoKeyConfig
)
Reset
()
func (*CryptoKeyConfig) String
func
(
x
*
CryptoKeyConfig
)
String
()
string
DataFusionClient
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
)
DataFusionClient
DataFusionServer
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
()
string
func (*DeleteInstanceRequest) ProtoMessage
func
(
*
DeleteInstanceRequest
)
ProtoMessage
()
func (*DeleteInstanceRequest) ProtoReflect
func
(
x
*
DeleteInstanceRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*DeleteInstanceRequest) Reset
func
(
x
*
DeleteInstanceRequest
)
Reset
()
func (*DeleteInstanceRequest) String
func
(
x
*
DeleteInstanceRequest
)
String
()
string
GetInstanceRequest
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
()
string
func (*GetInstanceRequest) ProtoMessage
func
(
*
GetInstanceRequest
)
ProtoMessage
()
func (*GetInstanceRequest) ProtoReflect
func
(
x
*
GetInstanceRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*GetInstanceRequest) Reset
func
(
x
*
GetInstanceRequest
)
Reset
()
func (*GetInstanceRequest) String
func
(
x
*
GetInstanceRequest
)
String
()
string
Instance
type
Instance
struct
{
// Output only. The name of this instance is in the form of
// projects/{project}/locations/{location}/instances/{instance}.
Name
string
`protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// A description of this instance.
Description
string
`protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
// Required. Instance type.
Type
Instance_Type
`protobuf:"varint,3,opt,name=type,proto3,enum=google.cloud.datafusion.v1.Instance_Type" json:"type,omitempty"`
// Option to enable Stackdriver Logging.
EnableStackdriverLogging
bool
`protobuf:"varint,4,opt,name=enable_stackdriver_logging,json=enableStackdriverLogging,proto3" json:"enable_stackdriver_logging,omitempty"`
// Option to enable Stackdriver Monitoring.
EnableStackdriverMonitoring
bool
`protobuf:"varint,5,opt,name=enable_stackdriver_monitoring,json=enableStackdriverMonitoring,proto3" json:"enable_stackdriver_monitoring,omitempty"`
// Specifies whether the Data Fusion instance should be private. If set to
// true, all Data Fusion nodes will have private IP addresses and will not be
// able to access the public internet.
PrivateInstance
bool
`protobuf:"varint,6,opt,name=private_instance,json=privateInstance,proto3" json:"private_instance,omitempty"`
// Network configuration options. These are required when a private Data
// Fusion instance is to be created.
NetworkConfig
*
NetworkConfig
`protobuf:"bytes,7,opt,name=network_config,json=networkConfig,proto3" json:"network_config,omitempty"`
// The resource labels for instance to use to annotate any related underlying
// resources such as Compute Engine VMs. The character '=' is not allowed to
// be used within the labels.
Labels
map
[
string
]
string
`protobuf:"bytes,8,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// Map of additional options used to configure the behavior of
// Data Fusion instance.
Options
map
[
string
]
string
`protobuf:"bytes,9,rep,name=options,proto3" json:"options,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// Output only. The time the instance was created.
CreateTime
*
timestamppb
.
Timestamp
`protobuf:"bytes,10,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The time the instance was last updated.
UpdateTime
*
timestamppb
.
Timestamp
`protobuf:"bytes,11,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// Output only. The current state of this Data Fusion instance.
State
Instance_State
`protobuf:"varint,12,opt,name=state,proto3,enum=google.cloud.datafusion.v1.Instance_State" json:"state,omitempty"`
// Output only. Additional information about the current state of this Data
// Fusion instance if available.
StateMessage
string
`protobuf:"bytes,13,opt,name=state_message,json=stateMessage,proto3" json:"state_message,omitempty"`
// Output only. Endpoint on which the Data Fusion UI is accessible.
ServiceEndpoint
string
`protobuf:"bytes,14,opt,name=service_endpoint,json=serviceEndpoint,proto3" json:"service_endpoint,omitempty"`
// Name of the zone in which the Data Fusion instance will be created. Only
// DEVELOPER instances use this field.
Zone
string
`protobuf:"bytes,15,opt,name=zone,proto3" json:"zone,omitempty"`
// Current version of the Data Fusion. Only specifiable in Update.
Version
string
`protobuf:"bytes,16,opt,name=version,proto3" json:"version,omitempty"`
// Output only. Deprecated. Use tenant_project_id instead to extract the tenant project ID.
//
// Deprecated: Marked as deprecated in google/cloud/datafusion/v1/datafusion.proto.
ServiceAccount
string
`protobuf:"bytes,17,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
// Display name for an instance.
DisplayName
string
`protobuf:"bytes,18,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
// Available versions that the instance can be upgraded to using
// UpdateInstanceRequest.
AvailableVersion
[]
*
Version
`protobuf:"bytes,19,rep,name=available_version,json=availableVersion,proto3" json:"available_version,omitempty"`
// Output only. Endpoint on which the REST APIs is accessible.
ApiEndpoint
string
`protobuf:"bytes,20,opt,name=api_endpoint,json=apiEndpoint,proto3" json:"api_endpoint,omitempty"`
// Output only. Cloud Storage bucket generated by Data Fusion in the customer project.
GcsBucket
string
`protobuf:"bytes,21,opt,name=gcs_bucket,json=gcsBucket,proto3" json:"gcs_bucket,omitempty"`
// List of accelerators enabled for this CDF instance.
Accelerators
[]
*
Accelerator
`protobuf:"bytes,22,rep,name=accelerators,proto3" json:"accelerators,omitempty"`
// Output only. P4 service account for the customer project.
P4ServiceAccount
string
`protobuf:"bytes,23,opt,name=p4_service_account,json=p4ServiceAccount,proto3" json:"p4_service_account,omitempty"`
// Output only. The name of the tenant project.
TenantProjectId
string
`protobuf:"bytes,24,opt,name=tenant_project_id,json=tenantProjectId,proto3" json:"tenant_project_id,omitempty"`
// User-managed service account to set on Dataproc when Cloud Data Fusion
// creates Dataproc to run data processing pipelines.
//
// This allows users to have fine-grained access control on Dataproc's
// accesses to cloud resources.
DataprocServiceAccount
string
`protobuf:"bytes,25,opt,name=dataproc_service_account,json=dataprocServiceAccount,proto3" json:"dataproc_service_account,omitempty"`
// Option to enable granular role-based access control.
EnableRbac
bool
`protobuf:"varint,27,opt,name=enable_rbac,json=enableRbac,proto3" json:"enable_rbac,omitempty"`
// The crypto key configuration. This field is used by the Customer-Managed
// Encryption Keys (CMEK) feature.
CryptoKeyConfig
*
CryptoKeyConfig
`protobuf:"bytes,28,opt,name=crypto_key_config,json=cryptoKeyConfig,proto3" json:"crypto_key_config,omitempty"`
// Output only. If the instance state is DISABLED, the reason for disabling the instance.
DisabledReason
[]
Instance_DisabledReason
`protobuf:"varint,29,rep,packed,name=disabled_reason,json=disabledReason,proto3,enum=google.cloud.datafusion.v1.Instance_DisabledReason" json:"disabled_reason,omitempty"`
// contains filtered or unexported fields
}
Represents a Data Fusion instance.
func (*Instance) Descriptor
Deprecated: Use Instance.ProtoReflect.Descriptor instead.
func (*Instance) GetAccelerators
func
(
x
*
Instance
)
GetAccelerators
()
[]
*
Accelerator
func (*Instance) GetApiEndpoint
func (*Instance) GetAvailableVersion
func (*Instance) GetCreateTime
func
(
x
*
Instance
)
GetCreateTime
()
*
timestamppb
.
Timestamp
func (*Instance) GetCryptoKeyConfig
func
(
x
*
Instance
)
GetCryptoKeyConfig
()
*
CryptoKeyConfig
func (*Instance) GetDataprocServiceAccount
func (*Instance) GetDescription
func (*Instance) GetDisabledReason
func
(
x
*
Instance
)
GetDisabledReason
()
[]
Instance_DisabledReason
func (*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
()
*
NetworkConfig
func (*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_State
func (*Instance) GetStateMessage
func (*Instance) GetTenantProjectId
func (*Instance) GetType
func
(
x
*
Instance
)
GetType
()
Instance_Type
func (*Instance) GetUpdateTime
func
(
x
*
Instance
)
GetUpdateTime
()
*
timestamppb
.
Timestamp
func (*Instance) GetVersion
func (*Instance) GetZone
func (*Instance) ProtoMessage
func
(
*
Instance
)
ProtoMessage
()
func (*Instance) ProtoReflect
func
(
x
*
Instance
)
ProtoReflect
()
protoreflect
.
Message
func (*Instance) Reset
func
(
x
*
Instance
)
Reset
()
func (*Instance) String
Instance_DisabledReason
type
Instance_DisabledReason
int32
The 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
.
EnumDescriptor
func (Instance_DisabledReason) Enum
func
(
x
Instance_DisabledReason
)
Enum
()
*
Instance_DisabledReason
func (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
.
EnumNumber
func (Instance_DisabledReason) String
func
(
x
Instance_DisabledReason
)
String
()
string
func (Instance_DisabledReason) Type
func
(
Instance_DisabledReason
)
Type
()
protoreflect
.
EnumType
Instance_State
type
Instance_State
int32
Represents 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
.
EnumDescriptor
func (Instance_State) Enum
func
(
x
Instance_State
)
Enum
()
*
Instance_State
func (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
.
EnumNumber
func (Instance_State) String
func
(
x
Instance_State
)
String
()
string
func (Instance_State) Type
func
(
Instance_State
)
Type
()
protoreflect
.
EnumType
Instance_Type
type
Instance_Type
int32
Represents 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
.
EnumDescriptor
func (Instance_Type) Enum
func
(
x
Instance_Type
)
Enum
()
*
Instance_Type
func (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
.
EnumNumber
func (Instance_Type) String
func
(
x
Instance_Type
)
String
()
string
func (Instance_Type) Type
func
(
Instance_Type
)
Type
()
protoreflect
.
EnumType
ListAvailableVersionsRequest
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
()
bool
func (*ListAvailableVersionsRequest) GetPageSize
func
(
x
*
ListAvailableVersionsRequest
)
GetPageSize
()
int32
func (*ListAvailableVersionsRequest) GetPageToken
func
(
x
*
ListAvailableVersionsRequest
)
GetPageToken
()
string
func (*ListAvailableVersionsRequest) GetParent
func
(
x
*
ListAvailableVersionsRequest
)
GetParent
()
string
func (*ListAvailableVersionsRequest) ProtoMessage
func
(
*
ListAvailableVersionsRequest
)
ProtoMessage
()
func (*ListAvailableVersionsRequest) ProtoReflect
func
(
x
*
ListAvailableVersionsRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*ListAvailableVersionsRequest) Reset
func
(
x
*
ListAvailableVersionsRequest
)
Reset
()
func (*ListAvailableVersionsRequest) String
func
(
x
*
ListAvailableVersionsRequest
)
String
()
string
ListAvailableVersionsResponse
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
()
[]
*
Version
func (*ListAvailableVersionsResponse) GetNextPageToken
func
(
x
*
ListAvailableVersionsResponse
)
GetNextPageToken
()
string
func (*ListAvailableVersionsResponse) ProtoMessage
func
(
*
ListAvailableVersionsResponse
)
ProtoMessage
()
func (*ListAvailableVersionsResponse) ProtoReflect
func
(
x
*
ListAvailableVersionsResponse
)
ProtoReflect
()
protoreflect
.
Message
func (*ListAvailableVersionsResponse) Reset
func
(
x
*
ListAvailableVersionsResponse
)
Reset
()
func (*ListAvailableVersionsResponse) String
func
(
x
*
ListAvailableVersionsResponse
)
String
()
string
ListInstancesRequest
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
()
string
func (*ListInstancesRequest) GetOrderBy
func
(
x
*
ListInstancesRequest
)
GetOrderBy
()
string
func (*ListInstancesRequest) GetPageSize
func
(
x
*
ListInstancesRequest
)
GetPageSize
()
int32
func (*ListInstancesRequest) GetPageToken
func
(
x
*
ListInstancesRequest
)
GetPageToken
()
string
func (*ListInstancesRequest) GetParent
func
(
x
*
ListInstancesRequest
)
GetParent
()
string
func (*ListInstancesRequest) ProtoMessage
func
(
*
ListInstancesRequest
)
ProtoMessage
()
func (*ListInstancesRequest) ProtoReflect
func
(
x
*
ListInstancesRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*ListInstancesRequest) Reset
func
(
x
*
ListInstancesRequest
)
Reset
()
func (*ListInstancesRequest) String
func
(
x
*
ListInstancesRequest
)
String
()
string
ListInstancesResponse
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
()
[]
*
Instance
func (*ListInstancesResponse) GetNextPageToken
func
(
x
*
ListInstancesResponse
)
GetNextPageToken
()
string
func (*ListInstancesResponse) GetUnreachable
func
(
x
*
ListInstancesResponse
)
GetUnreachable
()
[]
string
func (*ListInstancesResponse) ProtoMessage
func
(
*
ListInstancesResponse
)
ProtoMessage
()
func (*ListInstancesResponse) ProtoReflect
func
(
x
*
ListInstancesResponse
)
ProtoReflect
()
protoreflect
.
Message
func (*ListInstancesResponse) Reset
func
(
x
*
ListInstancesResponse
)
Reset
()
func (*ListInstancesResponse) String
func
(
x
*
ListInstancesResponse
)
String
()
string
NetworkConfig
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
()
string
func (*NetworkConfig) GetNetwork
func
(
x
*
NetworkConfig
)
GetNetwork
()
string
func (*NetworkConfig) ProtoMessage
func
(
*
NetworkConfig
)
ProtoMessage
()
func (*NetworkConfig) ProtoReflect
func
(
x
*
NetworkConfig
)
ProtoReflect
()
protoreflect
.
Message
func (*NetworkConfig) Reset
func
(
x
*
NetworkConfig
)
Reset
()
func (*NetworkConfig) String
func
(
x
*
NetworkConfig
)
String
()
string
OperationMetadata
type
OperationMetadata
struct
{
// The time the operation was created.
CreateTime
*
timestamppb
.
Timestamp
`protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// The time the operation finished running.
EndTime
*
timestamppb
.
Timestamp
`protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
// Server-defined resource path for the target of the operation.
Target
string
`protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
// Name of the verb executed by the operation.
Verb
string
`protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
// Human-readable status of the operation if any.
StatusDetail
string
`protobuf:"bytes,5,opt,name=status_detail,json=statusDetail,proto3" json:"status_detail,omitempty"`
// 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"`
// API version used to start the operation.
ApiVersion
string
`protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
// Map to hold any additional status info for the operation
// If there is an accelerator being enabled/disabled/deleted, this will be
// populated with accelerator name as key and status as
// ENABLING, DISABLING or DELETING
AdditionalStatus
map
[
string
]
string
`protobuf:"bytes,8,rep,name=additional_status,json=additionalStatus,proto3" json:"additional_status,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// contains filtered or unexported fields
}
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
]
string
func (*OperationMetadata) GetApiVersion
func
(
x
*
OperationMetadata
)
GetApiVersion
()
string
func (*OperationMetadata) GetCreateTime
func
(
x
*
OperationMetadata
)
GetCreateTime
()
*
timestamppb
.
Timestamp
func (*OperationMetadata) GetEndTime
func
(
x
*
OperationMetadata
)
GetEndTime
()
*
timestamppb
.
Timestamp
func (*OperationMetadata) GetRequestedCancellation
func
(
x
*
OperationMetadata
)
GetRequestedCancellation
()
bool
func (*OperationMetadata) GetStatusDetail
func
(
x
*
OperationMetadata
)
GetStatusDetail
()
string
func (*OperationMetadata) GetTarget
func
(
x
*
OperationMetadata
)
GetTarget
()
string
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
RestartInstanceRequest
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
()
string
func (*RestartInstanceRequest) ProtoMessage
func
(
*
RestartInstanceRequest
)
ProtoMessage
()
func (*RestartInstanceRequest) ProtoReflect
func
(
x
*
RestartInstanceRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*RestartInstanceRequest) Reset
func
(
x
*
RestartInstanceRequest
)
Reset
()
func (*RestartInstanceRequest) String
func
(
x
*
RestartInstanceRequest
)
String
()
string
UnimplementedDataFusionServer
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
()
*
Instance
func (*UpdateInstanceRequest) GetUpdateMask
func
(
x
*
UpdateInstanceRequest
)
GetUpdateMask
()
*
fieldmaskpb
.
FieldMask
func (*UpdateInstanceRequest) ProtoMessage
func
(
*
UpdateInstanceRequest
)
ProtoMessage
()
func (*UpdateInstanceRequest) ProtoReflect
func
(
x
*
UpdateInstanceRequest
)
ProtoReflect
()
protoreflect
.
Message
func (*UpdateInstanceRequest) Reset
func
(
x
*
UpdateInstanceRequest
)
Reset
()
func (*UpdateInstanceRequest) String
func
(
x
*
UpdateInstanceRequest
)
String
()
string
Version
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_Type
func (*Version) GetVersionNumber
func (*Version) ProtoMessage
func
(
*
Version
)
ProtoMessage
()
func (*Version) ProtoReflect
func
(
x
*
Version
)
ProtoReflect
()
protoreflect
.
Message
func (*Version) Reset
func
(
x
*
Version
)
Reset
()
func (*Version) String
Version_Type
type
Version_Type
int32
Each 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
.
EnumDescriptor
func (Version_Type) Enum
func
(
x
Version_Type
)
Enum
()
*
Version_Type
func (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
.
EnumNumber
func (Version_Type) String
func
(
x
Version_Type
)
String
()
string
func (Version_Type) Type
func
(
Version_Type
)
Type
()
protoreflect
.
EnumType
