Package cloud.google.com/go/datafusion/apiv1/datafusionpb (v1.6.1)

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 
  
 { 
  
 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_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) Enum

func (Accelerator_AcceleratorType) EnumDescriptor

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

Deprecated: Use Accelerator_AcceleratorType.Descriptor instead.

func (Accelerator_AcceleratorType) Number

func (Accelerator_AcceleratorType) String

func (Accelerator_AcceleratorType) Type

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

func (Accelerator_State) EnumDescriptor

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

Deprecated: Use Accelerator_State.Descriptor instead.

func (Accelerator_State) Number

func (Accelerator_State) String

  func 
  
 ( 
 x 
  
  Accelerator_State 
 
 ) 
  
 String 
 () 
  
  string 
 
 

func (Accelerator_State) Type

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 (*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 (*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 
  
 { 
  
 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

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

Deprecated: Use Instance.ProtoReflect.Descriptor instead.

func (*Instance) GetAccelerators

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetAccelerators 
 () 
  
 [] 
 * 
  Accelerator 
 
 

func (*Instance) GetApiEndpoint

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetApiEndpoint 
 () 
  
  string 
 
 

func (*Instance) GetAvailableVersion

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetAvailableVersion 
 () 
  
 [] 
 * 
  Version 
 
 

func (*Instance) GetCreateTime

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

func (*Instance) GetCryptoKeyConfig

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetCryptoKeyConfig 
 () 
  
 * 
  CryptoKeyConfig 
 
 

func (*Instance) GetDataprocServiceAccount

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetDataprocServiceAccount 
 () 
  
  string 
 
 

func (*Instance) GetDescription

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetDescription 
 () 
  
  string 
 
 

func (*Instance) GetDisabledReason

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetDisabledReason 
 () 
  
 [] 
  Instance_DisabledReason 
 
 

func (*Instance) GetDisplayName

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetDisplayName 
 () 
  
  string 
 
 

func (*Instance) GetEnableRbac

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetEnableRbac 
 () 
  
  bool 
 
 

func (*Instance) GetEnableStackdriverLogging

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetEnableStackdriverLogging 
 () 
  
  bool 
 
 

func (*Instance) GetEnableStackdriverMonitoring

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetEnableStackdriverMonitoring 
 () 
  
  bool 
 
 

func (*Instance) GetGcsBucket

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetGcsBucket 
 () 
  
  string 
 
 

func (*Instance) GetLabels

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

func (*Instance) GetName

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetName 
 () 
  
  string 
 
 

func (*Instance) GetNetworkConfig

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetNetworkConfig 
 () 
  
 * 
  NetworkConfig 
 
 

func (*Instance) GetOptions

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetOptions 
 () 
  
 map 
 [ 
  string 
 
 ] 
  string 
 
 

func (*Instance) GetP4ServiceAccount

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetP4ServiceAccount 
 () 
  
  string 
 
 

func (*Instance) GetPrivateInstance

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetPrivateInstance 
 () 
  
  bool 
 
 

func (*Instance) GetServiceAccount

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetServiceAccount 
 () 
  
  string 
 
 

Deprecated: Marked as deprecated in google/cloud/datafusion/v1/datafusion.proto.

func (*Instance) GetServiceEndpoint

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetServiceEndpoint 
 () 
  
  string 
 
 

func (*Instance) GetState

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetState 
 () 
  
  Instance_State 
 
 

func (*Instance) GetStateMessage

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetStateMessage 
 () 
  
  string 
 
 

func (*Instance) GetTenantProjectId

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetTenantProjectId 
 () 
  
  string 
 
 

func (*Instance) GetType

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetType 
 () 
  
  Instance_Type 
 
 

func (*Instance) GetUpdateTime

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

func (*Instance) GetVersion

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetVersion 
 () 
  
  string 
 
 

func (*Instance) GetZone

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 GetZone 
 () 
  
  string 
 
 

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

  func 
  
 ( 
 x 
  
 * 
  Instance 
 
 ) 
  
 String 
 () 
  
  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) Enum

func (Instance_DisabledReason) EnumDescriptor

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

Deprecated: Use Instance_DisabledReason.Descriptor instead.

func (Instance_DisabledReason) Number

func (Instance_DisabledReason) String

func (Instance_DisabledReason) Type

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

func (Instance_State) EnumDescriptor

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

Deprecated: Use Instance_State.Descriptor instead.

func (Instance_State) Number

func (Instance_State) String

  func 
  
 ( 
 x 
  
  Instance_State 
 
 ) 
  
 String 
 () 
  
  string 
 
 

func (Instance_State) Type

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) 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 (Instance_Type) String

  func 
  
 ( 
 x 
  
  Instance_Type 
 
 ) 
  
 String 
 () 
  
  string 
 
 

func (Instance_Type) Type

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 (*ListAvailableVersionsRequest) ProtoMessage

  func 
  
 ( 
 * 
  ListAvailableVersionsRequest 
 
 ) 
  
 ProtoMessage 
 () 
 

func (*ListAvailableVersionsRequest) ProtoReflect

func (*ListAvailableVersionsRequest) Reset

  func 
  
 ( 
 x 
  
 * 
  ListAvailableVersionsRequest 
 
 ) 
  
 Reset 
 () 
 

func (*ListAvailableVersionsRequest) 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 (*ListAvailableVersionsResponse) Reset

  func 
  
 ( 
 x 
  
 * 
  ListAvailableVersionsResponse 
 
 ) 
  
 Reset 
 () 
 

func (*ListAvailableVersionsResponse) 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 (*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 (*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 
 
 
  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 
 () 
  
 ([] 
  byte 
 
 , 
  
 [] 
  int 
 
 ) 
 

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

  func 
  
 ( 
 x 
  
 * 
  OperationMetadata 
 
 ) 
  
 GetAdditionalStatus 
 () 
  
 map 
 [ 
  string 
 
 ] 
  string 
 
 
  func 
  
 ( 
 x 
  
 * 
  OperationMetadata 
 
 ) 
  
 GetApiVersion 
 () 
  
  string 
 
 
  func 
  
 ( 
 x 
  
 * 
  OperationMetadata 
 
 ) 
  
 GetCreateTime 
 () 
  
 * 
  timestamppb 
 
 . 
  Timestamp 
 
 
  func 
  
 ( 
 x 
  
 * 
  OperationMetadata 
 
 ) 
  
 GetEndTime 
 () 
  
 * 
  timestamppb 
 
 . 
  Timestamp 
 
 
  func 
  
 ( 
 x 
  
 * 
  OperationMetadata 
 
 ) 
  
 GetRequestedCancellation 
 () 
  
  bool 
 
 
  func 
  
 ( 
 x 
  
 * 
  OperationMetadata 
 
 ) 
  
 GetStatusDetail 
 () 
  
  string 
 
 
  func 
  
 ( 
 x 
  
 * 
  OperationMetadata 
 
 ) 
  
 GetTarget 
 () 
  
  string 
 
 
  func 
  
 ( 
 x 
  
 * 
  OperationMetadata 
 
 ) 
  
 GetVerb 
 () 
  
  string 
 
 
  func 
  
 ( 
 * 
  OperationMetadata 
 
 ) 
  
 ProtoMessage 
 () 
 
  func 
  
 ( 
 x 
  
 * 
  OperationMetadata 
 
 ) 
  
 ProtoReflect 
 () 
  
  protoreflect 
 
 . 
  Message 
 
 
  func 
  
 ( 
 x 
  
 * 
  OperationMetadata 
 
 ) 
  
 Reset 
 () 
 
  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 (*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) DeleteInstance

func (*UnimplementedDataFusionServer) GetInstance

func (*UnimplementedDataFusionServer) ListAvailableVersions

func (*UnimplementedDataFusionServer) ListInstances

func (*UnimplementedDataFusionServer) RestartInstance

func (*UnimplementedDataFusionServer) UpdateInstance

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

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

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetAvailableFeatures

  func 
  
 ( 
 x 
  
 * 
  Version 
 
 ) 
  
 GetAvailableFeatures 
 () 
  
 [] 
  string 
 
 

func (*Version) GetDefaultVersion

  func 
  
 ( 
 x 
  
 * 
  Version 
 
 ) 
  
 GetDefaultVersion 
 () 
  
  bool 
 
 

func (*Version) GetType

  func 
  
 ( 
 x 
  
 * 
  Version 
 
 ) 
  
 GetType 
 () 
  
  Version_Type 
 
 

func (*Version) GetVersionNumber

  func 
  
 ( 
 x 
  
 * 
  Version 
 
 ) 
  
 GetVersionNumber 
 () 
  
  string 
 
 

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

  func 
  
 ( 
 x 
  
 * 
  Version 
 
 ) 
  
 String 
 () 
  
  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) 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 (Version_Type) String

  func 
  
 ( 
 x 
  
  Version_Type 
 
 ) 
  
 String 
 () 
  
  string 
 
 

func (Version_Type) Type

Create a Mobile Website
View Site in Mobile | Classic
Share by: