dataplex

package
v0.0.0-...-7721543 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 7, 2022 License: Apache-2.0 Imports: 14 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DiscoveryEvent_EventType_name = map[int32]string{
		0: "EVENT_TYPE_UNSPECIFIED",
		1: "CONFIG",
		2: "ENTITY_CREATED",
		3: "ENTITY_UPDATED",
		4: "ENTITY_DELETED",
		5: "PARTITION_CREATED",
		6: "PARTITION_UPDATED",
		7: "PARTITION_DELETED",
	}
	DiscoveryEvent_EventType_value = map[string]int32{
		"EVENT_TYPE_UNSPECIFIED": 0,
		"CONFIG":                 1,
		"ENTITY_CREATED":         2,
		"ENTITY_UPDATED":         3,
		"ENTITY_DELETED":         4,
		"PARTITION_CREATED":      5,
		"PARTITION_UPDATED":      6,
		"PARTITION_DELETED":      7,
	}
)

Enum value maps for DiscoveryEvent_EventType.

View Source 
var (
	DiscoveryEvent_EntityType_name = map[int32]string{
		0: "ENTITY_TYPE_UNSPECIFIED",
		1: "TABLE",
		2: "FILESET",
	}
	DiscoveryEvent_EntityType_value = map[string]int32{
		"ENTITY_TYPE_UNSPECIFIED": 0,
		"TABLE":                   1,
		"FILESET":                 2,
	}
)

Enum value maps for DiscoveryEvent_EntityType.

View Source 
var (
	JobEvent_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "SPARK",
		2: "NOTEBOOK",
	}
	JobEvent_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"SPARK":            1,
		"NOTEBOOK":         2,
	}
)

Enum value maps for JobEvent_Type.

View Source 
var (
	JobEvent_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "SUCCEEDED",
		2: "FAILED",
		3: "CANCELLED",
		4: "ABORTED",
	}
	JobEvent_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"SUCCEEDED":         1,
		"FAILED":            2,
		"CANCELLED":         3,
		"ABORTED":           4,
	}
)

Enum value maps for JobEvent_State.

View Source 
var (
	JobEvent_Service_name = map[int32]string{
		0: "SERVICE_UNSPECIFIED",
		1: "DATAPROC",
	}
	JobEvent_Service_value = map[string]int32{
		"SERVICE_UNSPECIFIED": 0,
		"DATAPROC":            1,
	}
)

Enum value maps for JobEvent_Service.

View Source 
var (
	SessionEvent_EventType_name = map[int32]string{
		0: "EVENT_TYPE_UNSPECIFIED",
		1: "START",
		2: "STOP",
		3: "QUERY",
	}
	SessionEvent_EventType_value = map[string]int32{
		"EVENT_TYPE_UNSPECIFIED": 0,
		"START":                  1,
		"STOP":                   2,
		"QUERY":                  3,
	}
)

Enum value maps for SessionEvent_EventType.

View Source 
var (
	SessionEvent_QueryDetail_Engine_name = map[int32]string{
		0: "ENGINE_UNSPECIFIED",
		1: "SPARK_SQL",
		2: "BIGQUERY",
	}
	SessionEvent_QueryDetail_Engine_value = map[string]int32{
		"ENGINE_UNSPECIFIED": 0,
		"SPARK_SQL":          1,
		"BIGQUERY":           2,
	}
)

Enum value maps for SessionEvent_QueryDetail_Engine.

View Source 
var (
	StorageSystem_name = map[int32]string{
		0: "STORAGE_SYSTEM_UNSPECIFIED",
		1: "CLOUD_STORAGE",
		2: "BIGQUERY",
	}
	StorageSystem_value = map[string]int32{
		"STORAGE_SYSTEM_UNSPECIFIED": 0,
		"CLOUD_STORAGE":              1,
		"BIGQUERY":                   2,
	}
)

Enum value maps for StorageSystem.

View Source 
var (
	ListEntitiesRequest_EntityView_name = map[int32]string{
		0: "ENTITY_VIEW_UNSPECIFIED",
		1: "TABLES",
		2: "FILESETS",
	}
	ListEntitiesRequest_EntityView_value = map[string]int32{
		"ENTITY_VIEW_UNSPECIFIED": 0,
		"TABLES":                  1,
		"FILESETS":                2,
	}
)

Enum value maps for ListEntitiesRequest_EntityView.

View Source 
var (
	GetEntityRequest_EntityView_name = map[int32]string{
		0: "ENTITY_VIEW_UNSPECIFIED",
		1: "BASIC",
		2: "SCHEMA",
		4: "FULL",
	}
	GetEntityRequest_EntityView_value = map[string]int32{
		"ENTITY_VIEW_UNSPECIFIED": 0,
		"BASIC":                   1,
		"SCHEMA":                  2,
		"FULL":                    4,
	}
)

Enum value maps for GetEntityRequest_EntityView.

View Source 
var (
	Entity_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TABLE",
		2: "FILESET",
	}
	Entity_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"TABLE":            1,
		"FILESET":          2,
	}
)

Enum value maps for Entity_Type.

View Source 
var (
	Schema_Type_name = map[int32]string{
		0:   "TYPE_UNSPECIFIED",
		1:   "BOOLEAN",
		2:   "BYTE",
		3:   "INT16",
		4:   "INT32",
		5:   "INT64",
		6:   "FLOAT",
		7:   "DOUBLE",
		8:   "DECIMAL",
		9:   "STRING",
		10:  "BINARY",
		11:  "TIMESTAMP",
		12:  "DATE",
		13:  "TIME",
		14:  "RECORD",
		100: "NULL",
	}
	Schema_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"BOOLEAN":          1,
		"BYTE":             2,
		"INT16":            3,
		"INT32":            4,
		"INT64":            5,
		"FLOAT":            6,
		"DOUBLE":           7,
		"DECIMAL":          8,
		"STRING":           9,
		"BINARY":           10,
		"TIMESTAMP":        11,
		"DATE":             12,
		"TIME":             13,
		"RECORD":           14,
		"NULL":             100,
	}
)

Enum value maps for Schema_Type.

View Source 
var (
	Schema_Mode_name = map[int32]string{
		0: "MODE_UNSPECIFIED",
		1: "REQUIRED",
		2: "NULLABLE",
		3: "REPEATED",
	}
	Schema_Mode_value = map[string]int32{
		"MODE_UNSPECIFIED": 0,
		"REQUIRED":         1,
		"NULLABLE":         2,
		"REPEATED":         3,
	}
)

Enum value maps for Schema_Mode.

View Source 
var (
	Schema_PartitionStyle_name = map[int32]string{
		0: "PARTITION_STYLE_UNSPECIFIED",
		1: "HIVE_COMPATIBLE",
	}
	Schema_PartitionStyle_value = map[string]int32{
		"PARTITION_STYLE_UNSPECIFIED": 0,
		"HIVE_COMPATIBLE":             1,
	}
)

Enum value maps for Schema_PartitionStyle.

View Source 
var (
	StorageFormat_Format_name = map[int32]string{
		0:    "FORMAT_UNSPECIFIED",
		1:    "PARQUET",
		2:    "AVRO",
		3:    "ORC",
		100:  "CSV",
		101:  "JSON",
		200:  "IMAGE",
		201:  "AUDIO",
		202:  "VIDEO",
		203:  "TEXT",
		204:  "TFRECORD",
		1000: "OTHER",
		1001: "UNKNOWN",
	}
	StorageFormat_Format_value = map[string]int32{
		"FORMAT_UNSPECIFIED": 0,
		"PARQUET":            1,
		"AVRO":               2,
		"ORC":                3,
		"CSV":                100,
		"JSON":               101,
		"IMAGE":              200,
		"AUDIO":              201,
		"VIDEO":              202,
		"TEXT":               203,
		"TFRECORD":           204,
		"OTHER":              1000,
		"UNKNOWN":            1001,
	}
)

Enum value maps for StorageFormat_Format.

View Source 
var (
	StorageFormat_CompressionFormat_name = map[int32]string{
		0: "COMPRESSION_FORMAT_UNSPECIFIED",
		2: "GZIP",
		3: "BZIP2",
	}
	StorageFormat_CompressionFormat_value = map[string]int32{
		"COMPRESSION_FORMAT_UNSPECIFIED": 0,
		"GZIP":                           2,
		"BZIP2":                          3,
	}
)

Enum value maps for StorageFormat_CompressionFormat.

View Source 
var (
	State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "ACTIVE",
		2: "CREATING",
		3: "DELETING",
		4: "ACTION_REQUIRED",
	}
	State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"ACTIVE":            1,
		"CREATING":          2,
		"DELETING":          3,
		"ACTION_REQUIRED":   4,
	}
)

Enum value maps for State.

View Source 
var (
	Lake_MetastoreStatus_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "NONE",
		2: "READY",
		3: "UPDATING",
		4: "ERROR",
	}
	Lake_MetastoreStatus_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"NONE":              1,
		"READY":             2,
		"UPDATING":          3,
		"ERROR":             4,
	}
)

Enum value maps for Lake_MetastoreStatus_State.

View Source 
var (
	Zone_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "RAW",
		2: "CURATED",
	}
	Zone_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"RAW":              1,
		"CURATED":          2,
	}
)

Enum value maps for Zone_Type.

View Source 
var (
	Zone_ResourceSpec_LocationType_name = map[int32]string{
		0: "LOCATION_TYPE_UNSPECIFIED",
		1: "SINGLE_REGION",
		2: "MULTI_REGION",
	}
	Zone_ResourceSpec_LocationType_value = map[string]int32{
		"LOCATION_TYPE_UNSPECIFIED": 0,
		"SINGLE_REGION":             1,
		"MULTI_REGION":              2,
	}
)

Enum value maps for Zone_ResourceSpec_LocationType.

View Source 
var (
	Action_Category_name = map[int32]string{
		0: "CATEGORY_UNSPECIFIED",
		1: "RESOURCE_MANAGEMENT",
		2: "SECURITY_POLICY",
		3: "DATA_DISCOVERY",
	}
	Action_Category_value = map[string]int32{
		"CATEGORY_UNSPECIFIED": 0,
		"RESOURCE_MANAGEMENT":  1,
		"SECURITY_POLICY":      2,
		"DATA_DISCOVERY":       3,
	}
)

Enum value maps for Action_Category.

View Source 
var (
	Action_IncompatibleDataSchema_SchemaChange_name = map[int32]string{
		0: "SCHEMA_CHANGE_UNSPECIFIED",
		1: "INCOMPATIBLE",
		2: "MODIFIED",
	}
	Action_IncompatibleDataSchema_SchemaChange_value = map[string]int32{
		"SCHEMA_CHANGE_UNSPECIFIED": 0,
		"INCOMPATIBLE":              1,
		"MODIFIED":                  2,
	}
)

Enum value maps for Action_IncompatibleDataSchema_SchemaChange.

View Source 
var (
	Action_InvalidDataPartition_PartitionStructure_name = map[int32]string{
		0: "PARTITION_STRUCTURE_UNSPECIFIED",
		1: "CONSISTENT_KEYS",
		2: "HIVE_STYLE_KEYS",
	}
	Action_InvalidDataPartition_PartitionStructure_value = map[string]int32{
		"PARTITION_STRUCTURE_UNSPECIFIED": 0,
		"CONSISTENT_KEYS":                 1,
		"HIVE_STYLE_KEYS":                 2,
	}
)

Enum value maps for Action_InvalidDataPartition_PartitionStructure.

View Source 
var (
	Asset_SecurityStatus_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "READY",
		2: "APPLYING",
		3: "ERROR",
	}
	Asset_SecurityStatus_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"READY":             1,
		"APPLYING":          2,
		"ERROR":             3,
	}
)

Enum value maps for Asset_SecurityStatus_State.

View Source 
var (
	Asset_ResourceSpec_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "STORAGE_BUCKET",
		2: "BIGQUERY_DATASET",
	}
	Asset_ResourceSpec_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"STORAGE_BUCKET":   1,
		"BIGQUERY_DATASET": 2,
	}
)

Enum value maps for Asset_ResourceSpec_Type.

View Source 
var (
	Asset_ResourceStatus_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "READY",
		2: "ERROR",
	}
	Asset_ResourceStatus_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"READY":             1,
		"ERROR":             2,
	}
)

Enum value maps for Asset_ResourceStatus_State.

View Source 
var (
	Asset_DiscoveryStatus_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "SCHEDULED",
		2: "IN_PROGRESS",
		3: "PAUSED",
		5: "DISABLED",
	}
	Asset_DiscoveryStatus_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"SCHEDULED":         1,
		"IN_PROGRESS":       2,
		"PAUSED":            3,
		"DISABLED":          5,
	}
)

Enum value maps for Asset_DiscoveryStatus_State.

View Source 
var (
	Task_TriggerSpec_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "ON_DEMAND",
		2: "RECURRING",
	}
	Task_TriggerSpec_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"ON_DEMAND":        1,
		"RECURRING":        2,
	}
)

Enum value maps for Task_TriggerSpec_Type.

View Source 
var (
	Job_Service_name = map[int32]string{
		0: "SERVICE_UNSPECIFIED",
		1: "DATAPROC",
	}
	Job_Service_value = map[string]int32{
		"SERVICE_UNSPECIFIED": 0,
		"DATAPROC":            1,
	}
)

Enum value maps for Job_Service.

View Source 
var (
	Job_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "RUNNING",
		2: "CANCELLING",
		3: "CANCELLED",
		4: "SUCCEEDED",
		5: "FAILED",
		6: "ABORTED",
	}
	Job_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"RUNNING":           1,
		"CANCELLING":        2,
		"CANCELLED":         3,
		"SUCCEEDED":         4,
		"FAILED":            5,
		"ABORTED":           6,
	}
)

Enum value maps for Job_State.

View Source 
var File_google_cloud_dataplex_v1_logs_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_dataplex_v1_metadata_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_dataplex_v1_resources_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_dataplex_v1_service_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_dataplex_v1_tasks_proto protoreflect.FileDescriptor

Functions

func RegisterDataplexServiceServer 

func RegisterDataplexServiceServer(s *grpc.Server, srv DataplexServiceServer)

func RegisterMetadataServiceServer 

func RegisterMetadataServiceServer(s *grpc.Server, srv MetadataServiceServer)

Types

type Action 

type Action struct {

	// The category of issue associated with the action.
	Category Action_Category `protobuf:"varint,1,opt,name=category,proto3,enum=google.cloud.dataplex.v1.Action_Category" json:"category,omitempty"`
	// Detailed description of the issue requiring action.
	Issue string `protobuf:"bytes,2,opt,name=issue,proto3" json:"issue,omitempty"`
	// The time that the issue was detected.
	DetectTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=detect_time,json=detectTime,proto3" json:"detect_time,omitempty"`
	// Output only. The relative resource name of the action, of the form:
	// `projects/{project}/locations/{location}/lakes/{lake}/actions/{action}`
	// `projects/{project}/locations/{location}/lakes/{lake}/zones/{zone}/actions/{action}`
	// `projects/{project}/locations/{location}/lakes/{lake}/zones/{zone}/assets/{asset}/actions/{action}`.
	Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The relative resource name of the lake, of the form:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}`.
	Lake string `protobuf:"bytes,6,opt,name=lake,proto3" json:"lake,omitempty"`
	// Output only. The relative resource name of the zone, of the form:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}`.
	Zone string `protobuf:"bytes,7,opt,name=zone,proto3" json:"zone,omitempty"`
	// Output only. The relative resource name of the asset, of the form:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/assets/{asset_id}`.
	Asset string `protobuf:"bytes,8,opt,name=asset,proto3" json:"asset,omitempty"`
	// The list of data locations associated with this action. Cloud Storage
	// locations are represented as URI paths(E.g.
	// `gs://bucket/table1/year=2020/month=Jan/`). BigQuery locations refer to
	// resource names(E.g.
	// `bigquery.googleapis.com/projects/project-id/datasets/dataset-id`).
	DataLocations []string `protobuf:"bytes,9,rep,name=data_locations,json=dataLocations,proto3" json:"data_locations,omitempty"`
	// Additional details about the action based on the action category.
	//
	// Types that are assignable to Details:
	//	*Action_InvalidDataFormat_
	//	*Action_IncompatibleDataSchema_
	//	*Action_InvalidDataPartition_
	//	*Action_MissingData_
	//	*Action_MissingResource_
	//	*Action_UnauthorizedResource_
	//	*Action_FailedSecurityPolicyApply_
	//	*Action_InvalidDataOrganization_
	Details isAction_Details `protobuf_oneof:"details"`
	// contains filtered or unexported fields
}

Action represents an issue requiring administrator action for resolution.

func (*Action) Descriptor deprecated 

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

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetAsset 

func (x *Action) GetAsset() string

func (*Action) GetCategory 

func (x *Action) GetCategory() Action_Category

func (*Action) GetDataLocations 

func (x *Action) GetDataLocations() []string

func (*Action) GetDetails 

func (m *Action) GetDetails() isAction_Details

func (*Action) GetDetectTime 

func (x *Action) GetDetectTime() *timestamppb.Timestamp

func (*Action) GetFailedSecurityPolicyApply 

func (x *Action) GetFailedSecurityPolicyApply() *Action_FailedSecurityPolicyApply

func (*Action) GetIncompatibleDataSchema 

func (x *Action) GetIncompatibleDataSchema() *Action_IncompatibleDataSchema

func (*Action) GetInvalidDataFormat 

func (x *Action) GetInvalidDataFormat() *Action_InvalidDataFormat

func (*Action) GetInvalidDataOrganization 

func (x *Action) GetInvalidDataOrganization() *Action_InvalidDataOrganization

func (*Action) GetInvalidDataPartition 

func (x *Action) GetInvalidDataPartition() *Action_InvalidDataPartition

func (*Action) GetIssue 

func (x *Action) GetIssue() string

func (*Action) GetLake 

func (x *Action) GetLake() string

func (*Action) GetMissingData 

func (x *Action) GetMissingData() *Action_MissingData

func (*Action) GetMissingResource 

func (x *Action) GetMissingResource() *Action_MissingResource

func (*Action) GetName 

func (x *Action) GetName() string

func (*Action) GetUnauthorizedResource 

func (x *Action) GetUnauthorizedResource() *Action_UnauthorizedResource

func (*Action) GetZone 

func (x *Action) GetZone() string

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) ProtoReflect 

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

func (*Action) Reset 

func (x *Action) Reset()

func (*Action) String 

func (x *Action) String() string

type Action_Category 

type Action_Category int32

The category of issues. 

const (
	// Unspecified category.
	Action_CATEGORY_UNSPECIFIED Action_Category = 0
	// Resource management related issues.
	Action_RESOURCE_MANAGEMENT Action_Category = 1
	// Security policy related issues.
	Action_SECURITY_POLICY Action_Category = 2
	// Data and discovery related issues.
	Action_DATA_DISCOVERY Action_Category = 3
)

func (Action_Category) Descriptor 

func (Action_Category) Descriptor() protoreflect.EnumDescriptor

func (Action_Category) Enum 

func (x Action_Category) Enum() *Action_Category

func (Action_Category) EnumDescriptor deprecated 

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

Deprecated: Use Action_Category.Descriptor instead.

func (Action_Category) Number 

func (x Action_Category) Number() protoreflect.EnumNumber

func (Action_Category) String 

func (x Action_Category) String() string

func (Action_Category) Type 

func (Action_Category) Type() protoreflect.EnumType

type Action_FailedSecurityPolicyApply 

type Action_FailedSecurityPolicyApply struct {

	// Resource name of one of the assets with failing security policy
	// application. Populated for a lake or zone resource only.
	Asset string `protobuf:"bytes,1,opt,name=asset,proto3" json:"asset,omitempty"`
	// contains filtered or unexported fields
}

Failed to apply security policy to the managed resource(s) under a lake, zone or an asset. For a lake or zone resource, one or more underlying assets has a failure applying security policy to the associated managed resource.

func (*Action_FailedSecurityPolicyApply) Descriptor deprecated 

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

Deprecated: Use Action_FailedSecurityPolicyApply.ProtoReflect.Descriptor instead.

func (*Action_FailedSecurityPolicyApply) GetAsset 

func (x *Action_FailedSecurityPolicyApply) GetAsset() string

func (*Action_FailedSecurityPolicyApply) ProtoMessage 

func (*Action_FailedSecurityPolicyApply) ProtoMessage()

func (*Action_FailedSecurityPolicyApply) ProtoReflect 

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

func (*Action_FailedSecurityPolicyApply) Reset 

func (x *Action_FailedSecurityPolicyApply) Reset()

func (*Action_FailedSecurityPolicyApply) String 

func (x *Action_FailedSecurityPolicyApply) String() string

type Action_FailedSecurityPolicyApply_ 

type Action_FailedSecurityPolicyApply_ struct {
	// Details for issues related to applying security policy.
	FailedSecurityPolicyApply *Action_FailedSecurityPolicyApply `protobuf:"bytes,21,opt,name=failed_security_policy_apply,json=failedSecurityPolicyApply,proto3,oneof"`
}

type Action_IncompatibleDataSchema 

type Action_IncompatibleDataSchema struct {

	// The name of the table containing invalid data.
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// The existing and expected schema of the table. The schema is provided as
	// a JSON formatted structure listing columns and data types.
	ExistingSchema string `protobuf:"bytes,2,opt,name=existing_schema,json=existingSchema,proto3" json:"existing_schema,omitempty"`
	// The new and incompatible schema within the table. The schema is provided
	// as a JSON formatted structured listing columns and data types.
	NewSchema string `protobuf:"bytes,3,opt,name=new_schema,json=newSchema,proto3" json:"new_schema,omitempty"`
	// The list of data locations sampled and used for format/schema
	// inference.
	SampledDataLocations []string `protobuf:"bytes,4,rep,name=sampled_data_locations,json=sampledDataLocations,proto3" json:"sampled_data_locations,omitempty"`
	// Whether the action relates to a schema that is incompatible or modified.
	SchemaChange Action_IncompatibleDataSchema_SchemaChange `` /* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

Action details for incompatible schemas detected by discovery.

func (*Action_IncompatibleDataSchema) Descriptor deprecated 

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

Deprecated: Use Action_IncompatibleDataSchema.ProtoReflect.Descriptor instead.

func (*Action_IncompatibleDataSchema) GetExistingSchema 

func (x *Action_IncompatibleDataSchema) GetExistingSchema() string

func (*Action_IncompatibleDataSchema) GetNewSchema 

func (x *Action_IncompatibleDataSchema) GetNewSchema() string

func (*Action_IncompatibleDataSchema) GetSampledDataLocations 

func (x *Action_IncompatibleDataSchema) GetSampledDataLocations() []string

func (*Action_IncompatibleDataSchema) GetSchemaChange 

func (x *Action_IncompatibleDataSchema) GetSchemaChange() Action_IncompatibleDataSchema_SchemaChange

func (*Action_IncompatibleDataSchema) GetTable 

func (x *Action_IncompatibleDataSchema) GetTable() string

func (*Action_IncompatibleDataSchema) ProtoMessage 

func (*Action_IncompatibleDataSchema) ProtoMessage()

func (*Action_IncompatibleDataSchema) ProtoReflect 

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

func (*Action_IncompatibleDataSchema) Reset 

func (x *Action_IncompatibleDataSchema) Reset()

func (*Action_IncompatibleDataSchema) String 

func (x *Action_IncompatibleDataSchema) String() string

type Action_IncompatibleDataSchema_ 

type Action_IncompatibleDataSchema_ struct {
	// Details for issues related to incompatible schemas detected within data.
	IncompatibleDataSchema *Action_IncompatibleDataSchema `protobuf:"bytes,11,opt,name=incompatible_data_schema,json=incompatibleDataSchema,proto3,oneof"`
}

type Action_IncompatibleDataSchema_SchemaChange 

type Action_IncompatibleDataSchema_SchemaChange int32

Whether the action relates to a schema that is incompatible or modified. 

const (
	// Schema change unspecified.
	Action_IncompatibleDataSchema_SCHEMA_CHANGE_UNSPECIFIED Action_IncompatibleDataSchema_SchemaChange = 0
	// Newly discovered schema is incompatible with existing schema.
	Action_IncompatibleDataSchema_INCOMPATIBLE Action_IncompatibleDataSchema_SchemaChange = 1
	// Newly discovered schema has changed from existing schema for data in a
	// curated zone.
	Action_IncompatibleDataSchema_MODIFIED Action_IncompatibleDataSchema_SchemaChange = 2
)

func (Action_IncompatibleDataSchema_SchemaChange) Descriptor 

func (Action_IncompatibleDataSchema_SchemaChange) Descriptor() protoreflect.EnumDescriptor

func (Action_IncompatibleDataSchema_SchemaChange) Enum 

func (x Action_IncompatibleDataSchema_SchemaChange) Enum() *Action_IncompatibleDataSchema_SchemaChange

func (Action_IncompatibleDataSchema_SchemaChange) EnumDescriptor deprecated 

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

Deprecated: Use Action_IncompatibleDataSchema_SchemaChange.Descriptor instead.

func (Action_IncompatibleDataSchema_SchemaChange) Number 

func (x Action_IncompatibleDataSchema_SchemaChange) Number() protoreflect.EnumNumber

func (Action_IncompatibleDataSchema_SchemaChange) String 

func (x Action_IncompatibleDataSchema_SchemaChange) String() string

func (Action_IncompatibleDataSchema_SchemaChange) Type 

func (Action_IncompatibleDataSchema_SchemaChange) Type() protoreflect.EnumType

type Action_InvalidDataFormat 

type Action_InvalidDataFormat struct {

	// The list of data locations sampled and used for format/schema
	// inference.
	SampledDataLocations []string `protobuf:"bytes,1,rep,name=sampled_data_locations,json=sampledDataLocations,proto3" json:"sampled_data_locations,omitempty"`
	// The expected data format of the entity.
	ExpectedFormat string `protobuf:"bytes,2,opt,name=expected_format,json=expectedFormat,proto3" json:"expected_format,omitempty"`
	// The new unexpected data format within the entity.
	NewFormat string `protobuf:"bytes,3,opt,name=new_format,json=newFormat,proto3" json:"new_format,omitempty"`
	// contains filtered or unexported fields
}

Action details for invalid or unsupported data files detected by discovery.

func (*Action_InvalidDataFormat) Descriptor deprecated 

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

Deprecated: Use Action_InvalidDataFormat.ProtoReflect.Descriptor instead.

func (*Action_InvalidDataFormat) GetExpectedFormat 

func (x *Action_InvalidDataFormat) GetExpectedFormat() string

func (*Action_InvalidDataFormat) GetNewFormat 

func (x *Action_InvalidDataFormat) GetNewFormat() string

func (*Action_InvalidDataFormat) GetSampledDataLocations 

func (x *Action_InvalidDataFormat) GetSampledDataLocations() []string

func (*Action_InvalidDataFormat) ProtoMessage 

func (*Action_InvalidDataFormat) ProtoMessage()

func (*Action_InvalidDataFormat) ProtoReflect 

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

func (*Action_InvalidDataFormat) Reset 

func (x *Action_InvalidDataFormat) Reset()

func (*Action_InvalidDataFormat) String 

func (x *Action_InvalidDataFormat) String() string

type Action_InvalidDataFormat_ 

type Action_InvalidDataFormat_ struct {
	// Details for issues related to invalid or unsupported data formats.
	InvalidDataFormat *Action_InvalidDataFormat `protobuf:"bytes,10,opt,name=invalid_data_format,json=invalidDataFormat,proto3,oneof"`
}

type Action_InvalidDataOrganization 

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

Action details for invalid data arrangement.

func (*Action_InvalidDataOrganization) Descriptor deprecated 

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

Deprecated: Use Action_InvalidDataOrganization.ProtoReflect.Descriptor instead.

func (*Action_InvalidDataOrganization) ProtoMessage 

func (*Action_InvalidDataOrganization) ProtoMessage()

func (*Action_InvalidDataOrganization) ProtoReflect 

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

func (*Action_InvalidDataOrganization) Reset 

func (x *Action_InvalidDataOrganization) Reset()

func (*Action_InvalidDataOrganization) String 

func (x *Action_InvalidDataOrganization) String() string

type Action_InvalidDataOrganization_ 

type Action_InvalidDataOrganization_ struct {
	// Details for issues related to invalid data arrangement.
	InvalidDataOrganization *Action_InvalidDataOrganization `protobuf:"bytes,22,opt,name=invalid_data_organization,json=invalidDataOrganization,proto3,oneof"`
}

type Action_InvalidDataPartition 

type Action_InvalidDataPartition struct {

	// The issue type of InvalidDataPartition.
	ExpectedStructure Action_InvalidDataPartition_PartitionStructure `` /* 190-byte string literal not displayed */
	// contains filtered or unexported fields
}

Action details for invalid or unsupported partitions detected by discovery.

func (*Action_InvalidDataPartition) Descriptor deprecated 

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

Deprecated: Use Action_InvalidDataPartition.ProtoReflect.Descriptor instead.

func (*Action_InvalidDataPartition) GetExpectedStructure 

func (x *Action_InvalidDataPartition) GetExpectedStructure() Action_InvalidDataPartition_PartitionStructure

func (*Action_InvalidDataPartition) ProtoMessage 

func (*Action_InvalidDataPartition) ProtoMessage()

func (*Action_InvalidDataPartition) ProtoReflect 

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

func (*Action_InvalidDataPartition) Reset 

func (x *Action_InvalidDataPartition) Reset()

func (*Action_InvalidDataPartition) String 

func (x *Action_InvalidDataPartition) String() string

type Action_InvalidDataPartition_ 

type Action_InvalidDataPartition_ struct {
	// Details for issues related to invalid or unsupported data partition
	// structure.
	InvalidDataPartition *Action_InvalidDataPartition `protobuf:"bytes,12,opt,name=invalid_data_partition,json=invalidDataPartition,proto3,oneof"`
}

type Action_InvalidDataPartition_PartitionStructure 

type Action_InvalidDataPartition_PartitionStructure int32

The expected partition structure. 

const (
	// PartitionStructure unspecified.
	Action_InvalidDataPartition_PARTITION_STRUCTURE_UNSPECIFIED Action_InvalidDataPartition_PartitionStructure = 0
	// Consistent hive-style partition definition (both raw and curated zone).
	Action_InvalidDataPartition_CONSISTENT_KEYS Action_InvalidDataPartition_PartitionStructure = 1
	// Hive style partition definition (curated zone only).
	Action_InvalidDataPartition_HIVE_STYLE_KEYS Action_InvalidDataPartition_PartitionStructure = 2
)

func (Action_InvalidDataPartition_PartitionStructure) Descriptor 

func (Action_InvalidDataPartition_PartitionStructure) Descriptor() protoreflect.EnumDescriptor

func (Action_InvalidDataPartition_PartitionStructure) Enum 

func (x Action_InvalidDataPartition_PartitionStructure) Enum() *Action_InvalidDataPartition_PartitionStructure

func (Action_InvalidDataPartition_PartitionStructure) EnumDescriptor deprecated 

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

Deprecated: Use Action_InvalidDataPartition_PartitionStructure.Descriptor instead.

func (Action_InvalidDataPartition_PartitionStructure) Number 

func (x Action_InvalidDataPartition_PartitionStructure) Number() protoreflect.EnumNumber

func (Action_InvalidDataPartition_PartitionStructure) String 

func (x Action_InvalidDataPartition_PartitionStructure) String() string

func (Action_InvalidDataPartition_PartitionStructure) Type 

func (Action_InvalidDataPartition_PartitionStructure) Type() protoreflect.EnumType

type Action_MissingData 

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

Action details for absence of data detected by discovery.

func (*Action_MissingData) Descriptor deprecated 

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

Deprecated: Use Action_MissingData.ProtoReflect.Descriptor instead.

func (*Action_MissingData) ProtoMessage 

func (*Action_MissingData) ProtoMessage()

func (*Action_MissingData) ProtoReflect 

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

func (*Action_MissingData) Reset 

func (x *Action_MissingData) Reset()

func (*Action_MissingData) String 

func (x *Action_MissingData) String() string

type Action_MissingData_ 

type Action_MissingData_ struct {
	// Details for issues related to absence of data within managed resources.
	MissingData *Action_MissingData `protobuf:"bytes,13,opt,name=missing_data,json=missingData,proto3,oneof"`
}

type Action_MissingResource 

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

Action details for resource references in assets that cannot be located.

func (*Action_MissingResource) Descriptor deprecated 

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

Deprecated: Use Action_MissingResource.ProtoReflect.Descriptor instead.

func (*Action_MissingResource) ProtoMessage 

func (*Action_MissingResource) ProtoMessage()

func (*Action_MissingResource) ProtoReflect 

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

func (*Action_MissingResource) Reset 

func (x *Action_MissingResource) Reset()

func (*Action_MissingResource) String 

func (x *Action_MissingResource) String() string

type Action_MissingResource_ 

type Action_MissingResource_ struct {
	// Details for issues related to absence of a managed resource.
	MissingResource *Action_MissingResource `protobuf:"bytes,14,opt,name=missing_resource,json=missingResource,proto3,oneof"`
}

type Action_UnauthorizedResource 

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

Action details for unauthorized resource issues raised to indicate that the service account associated with the lake instance is not authorized to access or manage the resource associated with an asset.

func (*Action_UnauthorizedResource) Descriptor deprecated 

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

Deprecated: Use Action_UnauthorizedResource.ProtoReflect.Descriptor instead.

func (*Action_UnauthorizedResource) ProtoMessage 

func (*Action_UnauthorizedResource) ProtoMessage()

func (*Action_UnauthorizedResource) ProtoReflect 

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

func (*Action_UnauthorizedResource) Reset 

func (x *Action_UnauthorizedResource) Reset()

func (*Action_UnauthorizedResource) String 

func (x *Action_UnauthorizedResource) String() string

type Action_UnauthorizedResource_ 

type Action_UnauthorizedResource_ struct {
	// Details for issues related to lack of permissions to access data
	// resources.
	UnauthorizedResource *Action_UnauthorizedResource `protobuf:"bytes,15,opt,name=unauthorized_resource,json=unauthorizedResource,proto3,oneof"`
}

type Asset 

type Asset struct {

	// Output only. The relative resource name of the asset, of the form:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/assets/{asset_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. User friendly display name.
	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Output only. System generated globally unique ID for the asset. This ID will be
	// different if the asset is deleted and re-created with the same name.
	Uid string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"`
	// Output only. The time when the asset was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time when the asset was last updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Optional. User defined labels for the asset.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Optional. Description of the asset.
	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
	// Output only. Current state of the asset.
	State State `protobuf:"varint,8,opt,name=state,proto3,enum=google.cloud.dataplex.v1.State" json:"state,omitempty"`
	// Required. Specification of the resource that is referenced by this asset.
	ResourceSpec *Asset_ResourceSpec `protobuf:"bytes,100,opt,name=resource_spec,json=resourceSpec,proto3" json:"resource_spec,omitempty"`
	// Output only. Status of the resource referenced by this asset.
	ResourceStatus *Asset_ResourceStatus `protobuf:"bytes,101,opt,name=resource_status,json=resourceStatus,proto3" json:"resource_status,omitempty"`
	// Output only. Status of the security policy applied to resource referenced by this asset.
	SecurityStatus *Asset_SecurityStatus `protobuf:"bytes,103,opt,name=security_status,json=securityStatus,proto3" json:"security_status,omitempty"`
	// Optional. Specification of the discovery feature applied to data referenced by this
	// asset.
	// When this spec is left unset, the asset will use the spec set on the parent
	// zone.
	DiscoverySpec *Asset_DiscoverySpec `protobuf:"bytes,106,opt,name=discovery_spec,json=discoverySpec,proto3" json:"discovery_spec,omitempty"`
	// Output only. Status of the discovery feature applied to data referenced by this asset.
	DiscoveryStatus *Asset_DiscoveryStatus `protobuf:"bytes,107,opt,name=discovery_status,json=discoveryStatus,proto3" json:"discovery_status,omitempty"`
	// contains filtered or unexported fields
}

An asset represents a cloud resource that is being managed within a lake as a member of a zone.

func (*Asset) Descriptor deprecated 

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

Deprecated: Use Asset.ProtoReflect.Descriptor instead.

func (*Asset) GetCreateTime 

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

func (*Asset) GetDescription 

func (x *Asset) GetDescription() string

func (*Asset) GetDiscoverySpec 

func (x *Asset) GetDiscoverySpec() *Asset_DiscoverySpec

func (*Asset) GetDiscoveryStatus 

func (x *Asset) GetDiscoveryStatus() *Asset_DiscoveryStatus

func (*Asset) GetDisplayName 

func (x *Asset) GetDisplayName() string

func (*Asset) GetLabels 

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

func (*Asset) GetName 

func (x *Asset) GetName() string

func (*Asset) GetResourceSpec 

func (x *Asset) GetResourceSpec() *Asset_ResourceSpec

func (*Asset) GetResourceStatus 

func (x *Asset) GetResourceStatus() *Asset_ResourceStatus

func (*Asset) GetSecurityStatus 

func (x *Asset) GetSecurityStatus() *Asset_SecurityStatus

func (*Asset) GetState 

func (x *Asset) GetState() State

func (*Asset) GetUid 

func (x *Asset) GetUid() string

func (*Asset) GetUpdateTime 

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

func (*Asset) ProtoMessage 

func (*Asset) ProtoMessage()

func (*Asset) ProtoReflect 

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

func (*Asset) Reset 

func (x *Asset) Reset()

func (*Asset) String 

func (x *Asset) String() string

type AssetStatus 

type AssetStatus struct {

	// Last update time of the status.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Number of active assets.
	ActiveAssets int32 `protobuf:"varint,2,opt,name=active_assets,json=activeAssets,proto3" json:"active_assets,omitempty"`
	// Number of assets that are in process of updating the security policy on
	// attached resources.
	SecurityPolicyApplyingAssets int32 `` /* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

Aggregated status of the underlying assets of a lake or zone.

func (*AssetStatus) Descriptor deprecated 

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

Deprecated: Use AssetStatus.ProtoReflect.Descriptor instead.

func (*AssetStatus) GetActiveAssets 

func (x *AssetStatus) GetActiveAssets() int32

func (*AssetStatus) GetSecurityPolicyApplyingAssets 

func (x *AssetStatus) GetSecurityPolicyApplyingAssets() int32

func (*AssetStatus) GetUpdateTime 

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

func (*AssetStatus) ProtoMessage 

func (*AssetStatus) ProtoMessage()

func (*AssetStatus) ProtoReflect 

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

func (*AssetStatus) Reset 

func (x *AssetStatus) Reset()

func (*AssetStatus) String 

func (x *AssetStatus) String() string

type Asset_DiscoverySpec 

type Asset_DiscoverySpec struct {

	// Optional. Whether discovery is enabled.
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Optional. The list of patterns to apply for selecting data to include during
	// discovery if only a subset of the data should considered.  For Cloud
	// Storage bucket assets, these are interpreted as glob patterns used to
	// match object names. For BigQuery dataset assets, these are interpreted as
	// patterns to match table names.
	IncludePatterns []string `protobuf:"bytes,2,rep,name=include_patterns,json=includePatterns,proto3" json:"include_patterns,omitempty"`
	// Optional. The list of patterns to apply for selecting data to exclude during
	// discovery.  For Cloud Storage bucket assets, these are interpreted as
	// glob patterns used to match object names. For BigQuery dataset assets,
	// these are interpreted as patterns to match table names.
	ExcludePatterns []string `protobuf:"bytes,3,rep,name=exclude_patterns,json=excludePatterns,proto3" json:"exclude_patterns,omitempty"`
	// Optional. Configuration for CSV data.
	CsvOptions *Asset_DiscoverySpec_CsvOptions `protobuf:"bytes,4,opt,name=csv_options,json=csvOptions,proto3" json:"csv_options,omitempty"`
	// Optional. Configuration for Json data.
	JsonOptions *Asset_DiscoverySpec_JsonOptions `protobuf:"bytes,5,opt,name=json_options,json=jsonOptions,proto3" json:"json_options,omitempty"`
	// Determines when discovery is triggered.
	//
	// Types that are assignable to Trigger:
	//	*Asset_DiscoverySpec_Schedule
	Trigger isAsset_DiscoverySpec_Trigger `protobuf_oneof:"trigger"`
	// contains filtered or unexported fields
}

Settings to manage the metadata discovery and publishing for an asset.

func (*Asset_DiscoverySpec) Descriptor deprecated 

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

Deprecated: Use Asset_DiscoverySpec.ProtoReflect.Descriptor instead.

func (*Asset_DiscoverySpec) GetCsvOptions 

func (x *Asset_DiscoverySpec) GetCsvOptions() *Asset_DiscoverySpec_CsvOptions

func (*Asset_DiscoverySpec) GetEnabled 

func (x *Asset_DiscoverySpec) GetEnabled() bool

func (*Asset_DiscoverySpec) GetExcludePatterns 

func (x *Asset_DiscoverySpec) GetExcludePatterns() []string

func (*Asset_DiscoverySpec) GetIncludePatterns 

func (x *Asset_DiscoverySpec) GetIncludePatterns() []string

func (*Asset_DiscoverySpec) GetJsonOptions 

func (x *Asset_DiscoverySpec) GetJsonOptions() *Asset_DiscoverySpec_JsonOptions

func (*Asset_DiscoverySpec) GetSchedule 

func (x *Asset_DiscoverySpec) GetSchedule() string

func (*Asset_DiscoverySpec) GetTrigger 

func (m *Asset_DiscoverySpec) GetTrigger() isAsset_DiscoverySpec_Trigger

func (*Asset_DiscoverySpec) ProtoMessage 

func (*Asset_DiscoverySpec) ProtoMessage()

func (*Asset_DiscoverySpec) ProtoReflect 

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

func (*Asset_DiscoverySpec) Reset 

func (x *Asset_DiscoverySpec) Reset()

func (*Asset_DiscoverySpec) String 

func (x *Asset_DiscoverySpec) String() string

type Asset_DiscoverySpec_CsvOptions 

type Asset_DiscoverySpec_CsvOptions struct {

	// Optional. The number of rows to interpret as header rows that should be skipped
	// when reading data rows.
	HeaderRows int32 `protobuf:"varint,1,opt,name=header_rows,json=headerRows,proto3" json:"header_rows,omitempty"`
	// Optional. The delimiter being used to separate values. This defaults to ','.
	Delimiter string `protobuf:"bytes,2,opt,name=delimiter,proto3" json:"delimiter,omitempty"`
	// Optional. The character encoding of the data. The default is UTF-8.
	Encoding string `protobuf:"bytes,3,opt,name=encoding,proto3" json:"encoding,omitempty"`
	// Optional. Whether to disable the inference of data type for CSV data.
	// If true, all columns will be registered as strings.
	DisableTypeInference bool `protobuf:"varint,4,opt,name=disable_type_inference,json=disableTypeInference,proto3" json:"disable_type_inference,omitempty"`
	// contains filtered or unexported fields
}

Describe CSV and similar semi-structured data formats.

func (*Asset_DiscoverySpec_CsvOptions) Descriptor deprecated 

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

Deprecated: Use Asset_DiscoverySpec_CsvOptions.ProtoReflect.Descriptor instead.

func (*Asset_DiscoverySpec_CsvOptions) GetDelimiter 

func (x *Asset_DiscoverySpec_CsvOptions) GetDelimiter() string

func (*Asset_DiscoverySpec_CsvOptions) GetDisableTypeInference 

func (x *Asset_DiscoverySpec_CsvOptions) GetDisableTypeInference() bool

func (*Asset_DiscoverySpec_CsvOptions) GetEncoding 

func (x *Asset_DiscoverySpec_CsvOptions) GetEncoding() string

func (*Asset_DiscoverySpec_CsvOptions) GetHeaderRows 

func (x *Asset_DiscoverySpec_CsvOptions) GetHeaderRows() int32

func (*Asset_DiscoverySpec_CsvOptions) ProtoMessage 

func (*Asset_DiscoverySpec_CsvOptions) ProtoMessage()

func (*Asset_DiscoverySpec_CsvOptions) ProtoReflect 

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

func (*Asset_DiscoverySpec_CsvOptions) Reset 

func (x *Asset_DiscoverySpec_CsvOptions) Reset()

func (*Asset_DiscoverySpec_CsvOptions) String 

func (x *Asset_DiscoverySpec_CsvOptions) String() string

type Asset_DiscoverySpec_JsonOptions 

type Asset_DiscoverySpec_JsonOptions struct {

	// Optional. The character encoding of the data. The default is UTF-8.
	Encoding string `protobuf:"bytes,1,opt,name=encoding,proto3" json:"encoding,omitempty"`
	// Optional. Whether to disable the inference of data type for Json data.
	// If true, all columns will be registered as their primitive types
	// (strings, number or boolean).
	DisableTypeInference bool `protobuf:"varint,2,opt,name=disable_type_inference,json=disableTypeInference,proto3" json:"disable_type_inference,omitempty"`
	// contains filtered or unexported fields
}

Describe JSON data format.

func (*Asset_DiscoverySpec_JsonOptions) Descriptor deprecated 

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

Deprecated: Use Asset_DiscoverySpec_JsonOptions.ProtoReflect.Descriptor instead.

func (*Asset_DiscoverySpec_JsonOptions) GetDisableTypeInference 

func (x *Asset_DiscoverySpec_JsonOptions) GetDisableTypeInference() bool

func (*Asset_DiscoverySpec_JsonOptions) GetEncoding 

func (x *Asset_DiscoverySpec_JsonOptions) GetEncoding() string

func (*Asset_DiscoverySpec_JsonOptions) ProtoMessage 

func (*Asset_DiscoverySpec_JsonOptions) ProtoMessage()

func (*Asset_DiscoverySpec_JsonOptions) ProtoReflect 

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

func (*Asset_DiscoverySpec_JsonOptions) Reset 

func (x *Asset_DiscoverySpec_JsonOptions) Reset()

func (*Asset_DiscoverySpec_JsonOptions) String 

func (x *Asset_DiscoverySpec_JsonOptions) String() string

type Asset_DiscoverySpec_Schedule 

type Asset_DiscoverySpec_Schedule struct {
	// Optional. Cron schedule (https://en.wikipedia.org/wiki/Cron) for running
	// discovery periodically. Successive discovery runs must be scheduled at
	// least 60 minutes apart.
	// The default value is to run discovery every 60 minutes.
	// To explicitly set a timezone to the cron tab, apply a prefix in the
	// cron tab: "CRON_TZ=${IANA_TIME_ZONE}" or TZ=${IANA_TIME_ZONE}".
	// The ${IANA_TIME_ZONE} may only be a valid string from IANA time zone
	// database. For example, "CRON_TZ=America/New_York 1 * * * *", or
	// "TZ=America/New_York 1 * * * *".
	Schedule string `protobuf:"bytes,10,opt,name=schedule,proto3,oneof"`
}

type Asset_DiscoveryStatus 

type Asset_DiscoveryStatus struct {

	// The current status of the discovery feature.
	State Asset_DiscoveryStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.dataplex.v1.Asset_DiscoveryStatus_State" json:"state,omitempty"`
	// Additional information about the current state.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Last update time of the status.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// The start time of the last discovery run.
	LastRunTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_run_time,json=lastRunTime,proto3" json:"last_run_time,omitempty"`
	// Data Stats of the asset reported by discovery.
	Stats *Asset_DiscoveryStatus_Stats `protobuf:"bytes,6,opt,name=stats,proto3" json:"stats,omitempty"`
	// The duration of the last discovery run.
	LastRunDuration *durationpb.Duration `protobuf:"bytes,7,opt,name=last_run_duration,json=lastRunDuration,proto3" json:"last_run_duration,omitempty"`
	// contains filtered or unexported fields
}

Status of discovery for an asset.

func (*Asset_DiscoveryStatus) Descriptor deprecated 

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

Deprecated: Use Asset_DiscoveryStatus.ProtoReflect.Descriptor instead.

func (*Asset_DiscoveryStatus) GetLastRunDuration 

func (x *Asset_DiscoveryStatus) GetLastRunDuration() *durationpb.Duration

func (*Asset_DiscoveryStatus) GetLastRunTime 

func (x *Asset_DiscoveryStatus) GetLastRunTime() *timestamppb.Timestamp

func (*Asset_DiscoveryStatus) GetMessage 

func (x *Asset_DiscoveryStatus) GetMessage() string

func (*Asset_DiscoveryStatus) GetState 

func (x *Asset_DiscoveryStatus) GetState() Asset_DiscoveryStatus_State

func (*Asset_DiscoveryStatus) GetStats 

func (x *Asset_DiscoveryStatus) GetStats() *Asset_DiscoveryStatus_Stats

func (*Asset_DiscoveryStatus) GetUpdateTime 

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

func (*Asset_DiscoveryStatus) ProtoMessage 

func (*Asset_DiscoveryStatus) ProtoMessage()

func (*Asset_DiscoveryStatus) ProtoReflect 

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

func (*Asset_DiscoveryStatus) Reset 

func (x *Asset_DiscoveryStatus) Reset()

func (*Asset_DiscoveryStatus) String 

func (x *Asset_DiscoveryStatus) String() string

type Asset_DiscoveryStatus_State 

type Asset_DiscoveryStatus_State int32

Current state of discovery. 

const (
	// State is unspecified.
	Asset_DiscoveryStatus_STATE_UNSPECIFIED Asset_DiscoveryStatus_State = 0
	// Discovery for the asset is scheduled.
	Asset_DiscoveryStatus_SCHEDULED Asset_DiscoveryStatus_State = 1
	// Discovery for the asset is running.
	Asset_DiscoveryStatus_IN_PROGRESS Asset_DiscoveryStatus_State = 2
	// Discovery for the asset is currently paused (e.g. due to a lack
	// of available resources). It will be automatically resumed.
	Asset_DiscoveryStatus_PAUSED Asset_DiscoveryStatus_State = 3
	// Discovery for the asset is disabled.
	Asset_DiscoveryStatus_DISABLED Asset_DiscoveryStatus_State = 5
)

func (Asset_DiscoveryStatus_State) Descriptor 

func (Asset_DiscoveryStatus_State) Descriptor() protoreflect.EnumDescriptor

func (Asset_DiscoveryStatus_State) Enum 

func (x Asset_DiscoveryStatus_State) Enum() *Asset_DiscoveryStatus_State

func (Asset_DiscoveryStatus_State) EnumDescriptor deprecated 

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

Deprecated: Use Asset_DiscoveryStatus_State.Descriptor instead.

func (Asset_DiscoveryStatus_State) Number 

func (x Asset_DiscoveryStatus_State) Number() protoreflect.EnumNumber

func (Asset_DiscoveryStatus_State) String 

func (x Asset_DiscoveryStatus_State) String() string

func (Asset_DiscoveryStatus_State) Type 

func (Asset_DiscoveryStatus_State) Type() protoreflect.EnumType

type Asset_DiscoveryStatus_Stats 

type Asset_DiscoveryStatus_Stats struct {

	// The count of data items within the referenced resource.
	DataItems int64 `protobuf:"varint,1,opt,name=data_items,json=dataItems,proto3" json:"data_items,omitempty"`
	// The number of stored data bytes within the referenced resource.
	DataSize int64 `protobuf:"varint,2,opt,name=data_size,json=dataSize,proto3" json:"data_size,omitempty"`
	// The count of table entities within the referenced resource.
	Tables int64 `protobuf:"varint,3,opt,name=tables,proto3" json:"tables,omitempty"`
	// The count of fileset entities within the referenced resource.
	Filesets int64 `protobuf:"varint,4,opt,name=filesets,proto3" json:"filesets,omitempty"`
	// contains filtered or unexported fields
}

The aggregated data statistics for the asset reported by discovery.

func (*Asset_DiscoveryStatus_Stats) Descriptor deprecated 

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

Deprecated: Use Asset_DiscoveryStatus_Stats.ProtoReflect.Descriptor instead.

func (*Asset_DiscoveryStatus_Stats) GetDataItems 

func (x *Asset_DiscoveryStatus_Stats) GetDataItems() int64

func (*Asset_DiscoveryStatus_Stats) GetDataSize 

func (x *Asset_DiscoveryStatus_Stats) GetDataSize() int64

func (*Asset_DiscoveryStatus_Stats) GetFilesets 

func (x *Asset_DiscoveryStatus_Stats) GetFilesets() int64

func (*Asset_DiscoveryStatus_Stats) GetTables 

func (x *Asset_DiscoveryStatus_Stats) GetTables() int64

func (*Asset_DiscoveryStatus_Stats) ProtoMessage 

func (*Asset_DiscoveryStatus_Stats) ProtoMessage()

func (*Asset_DiscoveryStatus_Stats) ProtoReflect 

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

func (*Asset_DiscoveryStatus_Stats) Reset 

func (x *Asset_DiscoveryStatus_Stats) Reset()

func (*Asset_DiscoveryStatus_Stats) String 

func (x *Asset_DiscoveryStatus_Stats) String() string

type Asset_ResourceSpec 

type Asset_ResourceSpec struct {

	// Immutable. Relative name of the cloud resource that contains the data that is
	// being managed within a lake. For example:
	//   `projects/{project_number}/buckets/{bucket_id}`
	//   `projects/{project_number}/datasets/{dataset_id}`
	// If the creation policy indicates ATTACH behavior, then an existing
	// resource must be provided.
	// If the policy indicates CREATE behavior, new resource will be created
	// with the given name.However if it is empty, then the resource will be
	// created using {asset_id}-{UUID} template for name.
	// The location of the referenced resource must always match that of the
	// asset.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. Immutable. Type of resource.
	Type Asset_ResourceSpec_Type `protobuf:"varint,2,opt,name=type,proto3,enum=google.cloud.dataplex.v1.Asset_ResourceSpec_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

Identifies the cloud resource that is referenced by this asset.

func (*Asset_ResourceSpec) Descriptor deprecated 

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

Deprecated: Use Asset_ResourceSpec.ProtoReflect.Descriptor instead.

func (*Asset_ResourceSpec) GetName 

func (x *Asset_ResourceSpec) GetName() string

func (*Asset_ResourceSpec) GetType 

func (x *Asset_ResourceSpec) GetType() Asset_ResourceSpec_Type

func (*Asset_ResourceSpec) ProtoMessage 

func (*Asset_ResourceSpec) ProtoMessage()

func (*Asset_ResourceSpec) ProtoReflect 

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

func (*Asset_ResourceSpec) Reset 

func (x *Asset_ResourceSpec) Reset()

func (*Asset_ResourceSpec) String 

func (x *Asset_ResourceSpec) String() string

type Asset_ResourceSpec_Type 

type Asset_ResourceSpec_Type int32

Type of resource. 

const (
	// Type not specified.
	Asset_ResourceSpec_TYPE_UNSPECIFIED Asset_ResourceSpec_Type = 0
	// Cloud Storage bucket.
	Asset_ResourceSpec_STORAGE_BUCKET Asset_ResourceSpec_Type = 1
	// BigQuery dataset.
	Asset_ResourceSpec_BIGQUERY_DATASET Asset_ResourceSpec_Type = 2
)

func (Asset_ResourceSpec_Type) Descriptor 

func (Asset_ResourceSpec_Type) Descriptor() protoreflect.EnumDescriptor

func (Asset_ResourceSpec_Type) Enum 

func (x Asset_ResourceSpec_Type) Enum() *Asset_ResourceSpec_Type

func (Asset_ResourceSpec_Type) EnumDescriptor deprecated 

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

Deprecated: Use Asset_ResourceSpec_Type.Descriptor instead.

func (Asset_ResourceSpec_Type) Number 

func (x Asset_ResourceSpec_Type) Number() protoreflect.EnumNumber

func (Asset_ResourceSpec_Type) String 

func (x Asset_ResourceSpec_Type) String() string

func (Asset_ResourceSpec_Type) Type 

func (Asset_ResourceSpec_Type) Type() protoreflect.EnumType

type Asset_ResourceStatus 

type Asset_ResourceStatus struct {

	// The current state of the managed resource.
	State Asset_ResourceStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.dataplex.v1.Asset_ResourceStatus_State" json:"state,omitempty"`
	// Additional information about the current state.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Last update time of the status.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

Status of the resource referenced by an asset.

func (*Asset_ResourceStatus) Descriptor deprecated 

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

Deprecated: Use Asset_ResourceStatus.ProtoReflect.Descriptor instead.

func (*Asset_ResourceStatus) GetMessage 

func (x *Asset_ResourceStatus) GetMessage() string

func (*Asset_ResourceStatus) GetState 

func (x *Asset_ResourceStatus) GetState() Asset_ResourceStatus_State

func (*Asset_ResourceStatus) GetUpdateTime 

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

func (*Asset_ResourceStatus) ProtoMessage 

func (*Asset_ResourceStatus) ProtoMessage()

func (*Asset_ResourceStatus) ProtoReflect 

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

func (*Asset_ResourceStatus) Reset 

func (x *Asset_ResourceStatus) Reset()

func (*Asset_ResourceStatus) String 

func (x *Asset_ResourceStatus) String() string

type Asset_ResourceStatus_State 

type Asset_ResourceStatus_State int32

The state of a resource. 

const (
	// State unspecified.
	Asset_ResourceStatus_STATE_UNSPECIFIED Asset_ResourceStatus_State = 0
	// Resource does not have any errors.
	Asset_ResourceStatus_READY Asset_ResourceStatus_State = 1
	// Resource has errors.
	Asset_ResourceStatus_ERROR Asset_ResourceStatus_State = 2
)

func (Asset_ResourceStatus_State) Descriptor 

func (Asset_ResourceStatus_State) Descriptor() protoreflect.EnumDescriptor

func (Asset_ResourceStatus_State) Enum 

func (x Asset_ResourceStatus_State) Enum() *Asset_ResourceStatus_State

func (Asset_ResourceStatus_State) EnumDescriptor deprecated 

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

Deprecated: Use Asset_ResourceStatus_State.Descriptor instead.

func (Asset_ResourceStatus_State) Number 

func (x Asset_ResourceStatus_State) Number() protoreflect.EnumNumber

func (Asset_ResourceStatus_State) String 

func (x Asset_ResourceStatus_State) String() string

func (Asset_ResourceStatus_State) Type 

func (Asset_ResourceStatus_State) Type() protoreflect.EnumType

type Asset_SecurityStatus 

type Asset_SecurityStatus struct {

	// The current state of the security policy applied to the attached
	// resource.
	State Asset_SecurityStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.dataplex.v1.Asset_SecurityStatus_State" json:"state,omitempty"`
	// Additional information about the current state.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Last update time of the status.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

Security policy status of the asset. Data security policy, i.e., readers, writers & owners, should be specified in the lake/zone/asset IAM policy.

func (*Asset_SecurityStatus) Descriptor deprecated 

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

Deprecated: Use Asset_SecurityStatus.ProtoReflect.Descriptor instead.

func (*Asset_SecurityStatus) GetMessage 

func (x *Asset_SecurityStatus) GetMessage() string

func (*Asset_SecurityStatus) GetState 

func (x *Asset_SecurityStatus) GetState() Asset_SecurityStatus_State

func (*Asset_SecurityStatus) GetUpdateTime 

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

func (*Asset_SecurityStatus) ProtoMessage 

func (*Asset_SecurityStatus) ProtoMessage()

func (*Asset_SecurityStatus) ProtoReflect 

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

func (*Asset_SecurityStatus) Reset 

func (x *Asset_SecurityStatus) Reset()

func (*Asset_SecurityStatus) String 

func (x *Asset_SecurityStatus) String() string

type Asset_SecurityStatus_State 

type Asset_SecurityStatus_State int32

The state of the security policy. 

const (
	// State unspecified.
	Asset_SecurityStatus_STATE_UNSPECIFIED Asset_SecurityStatus_State = 0
	// Security policy has been successfully applied to the attached resource.
	Asset_SecurityStatus_READY Asset_SecurityStatus_State = 1
	// Security policy is in the process of being applied to the attached
	// resource.
	Asset_SecurityStatus_APPLYING Asset_SecurityStatus_State = 2
	// Security policy could not be applied to the attached resource due to
	// errors.
	Asset_SecurityStatus_ERROR Asset_SecurityStatus_State = 3
)

func (Asset_SecurityStatus_State) Descriptor 

func (Asset_SecurityStatus_State) Descriptor() protoreflect.EnumDescriptor

func (Asset_SecurityStatus_State) Enum 

func (x Asset_SecurityStatus_State) Enum() *Asset_SecurityStatus_State

func (Asset_SecurityStatus_State) EnumDescriptor deprecated 

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

Deprecated: Use Asset_SecurityStatus_State.Descriptor instead.

func (Asset_SecurityStatus_State) Number 

func (x Asset_SecurityStatus_State) Number() protoreflect.EnumNumber

func (Asset_SecurityStatus_State) String 

func (x Asset_SecurityStatus_State) String() string

func (Asset_SecurityStatus_State) Type 

func (Asset_SecurityStatus_State) Type() protoreflect.EnumType

type CancelJobRequest 

type CancelJobRequest struct {

	// Required. The resource name of the job:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/task/{task_id}/job/{job_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Cancel task jobs.

func (*CancelJobRequest) Descriptor deprecated 

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

Deprecated: Use CancelJobRequest.ProtoReflect.Descriptor instead.

func (*CancelJobRequest) GetName 

func (x *CancelJobRequest) GetName() string

func (*CancelJobRequest) ProtoMessage 

func (*CancelJobRequest) ProtoMessage()

func (*CancelJobRequest) ProtoReflect 

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

func (*CancelJobRequest) Reset 

func (x *CancelJobRequest) Reset()

func (*CancelJobRequest) String 

func (x *CancelJobRequest) String() string

type CreateAssetRequest 

type CreateAssetRequest struct {

	// Required. The resource name of the parent zone:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Asset identifier.
	// This ID will be used to generate names such as table names when publishing
	// metadata to Hive Metastore and BigQuery.
	// * Must contain only lowercase letters, numbers and hyphens.
	// * Must start with a letter.
	// * Must end with a number or a letter.
	// * Must be between 1-63 characters.
	// * Must be unique within the zone.
	AssetId string `protobuf:"bytes,2,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"`
	// Required. Asset resource.
	Asset *Asset `protobuf:"bytes,3,opt,name=asset,proto3" json:"asset,omitempty"`
	// Optional. Only validate the request, but do not perform mutations.
	// The default is false.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

Create asset request.

func (*CreateAssetRequest) Descriptor deprecated 

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

Deprecated: Use CreateAssetRequest.ProtoReflect.Descriptor instead.

func (*CreateAssetRequest) GetAsset 

func (x *CreateAssetRequest) GetAsset() *Asset

func (*CreateAssetRequest) GetAssetId 

func (x *CreateAssetRequest) GetAssetId() string

func (*CreateAssetRequest) GetParent 

func (x *CreateAssetRequest) GetParent() string

func (*CreateAssetRequest) GetValidateOnly 

func (x *CreateAssetRequest) GetValidateOnly() bool

func (*CreateAssetRequest) ProtoMessage 

func (*CreateAssetRequest) ProtoMessage()

func (*CreateAssetRequest) ProtoReflect 

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

func (*CreateAssetRequest) Reset 

func (x *CreateAssetRequest) Reset()

func (*CreateAssetRequest) String 

func (x *CreateAssetRequest) String() string

type CreateLakeRequest 

type CreateLakeRequest struct {

	// Required. The resource name of the lake location, of the form:
	// `projects/{project_number}/locations/{location_id}`
	// where `location_id` refers to a GCP region.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Lake identifier.
	// This ID will be used to generate names such as database and dataset names
	// when publishing metadata to Hive Metastore and BigQuery.
	// * Must contain only lowercase letters, numbers and hyphens.
	// * Must start with a letter.
	// * Must end with a number or a letter.
	// * Must be between 1-63 characters.
	// * Must be unique within the customer project / location.
	LakeId string `protobuf:"bytes,2,opt,name=lake_id,json=lakeId,proto3" json:"lake_id,omitempty"`
	// Required. Lake resource
	Lake *Lake `protobuf:"bytes,3,opt,name=lake,proto3" json:"lake,omitempty"`
	// Optional. Only validate the request, but do not perform mutations.
	// The default is false.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

Create lake request.

func (*CreateLakeRequest) Descriptor deprecated 

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

Deprecated: Use CreateLakeRequest.ProtoReflect.Descriptor instead.

func (*CreateLakeRequest) GetLake 

func (x *CreateLakeRequest) GetLake() *Lake

func (*CreateLakeRequest) GetLakeId 

func (x *CreateLakeRequest) GetLakeId() string

func (*CreateLakeRequest) GetParent 

func (x *CreateLakeRequest) GetParent() string

func (*CreateLakeRequest) GetValidateOnly 

func (x *CreateLakeRequest) GetValidateOnly() bool

func (*CreateLakeRequest) ProtoMessage 

func (*CreateLakeRequest) ProtoMessage()

func (*CreateLakeRequest) ProtoReflect 

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

func (*CreateLakeRequest) Reset 

func (x *CreateLakeRequest) Reset()

func (*CreateLakeRequest) String 

func (x *CreateLakeRequest) String() string

type CreateTaskRequest 

type CreateTaskRequest struct {

	// Required. The resource name of the parent lake:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Task identifier.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Required. Task resource.
	Task *Task `protobuf:"bytes,3,opt,name=task,proto3" json:"task,omitempty"`
	// Optional. Only validate the request, but do not perform mutations.
	// The default is false.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

Create task request.

func (*CreateTaskRequest) Descriptor deprecated 

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

Deprecated: Use CreateTaskRequest.ProtoReflect.Descriptor instead.

func (*CreateTaskRequest) GetParent 

func (x *CreateTaskRequest) GetParent() string

func (*CreateTaskRequest) GetTask 

func (x *CreateTaskRequest) GetTask() *Task

func (*CreateTaskRequest) GetTaskId 

func (x *CreateTaskRequest) GetTaskId() string

func (*CreateTaskRequest) GetValidateOnly 

func (x *CreateTaskRequest) GetValidateOnly() bool

func (*CreateTaskRequest) ProtoMessage 

func (*CreateTaskRequest) ProtoMessage()

func (*CreateTaskRequest) ProtoReflect 

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

func (*CreateTaskRequest) Reset 

func (x *CreateTaskRequest) Reset()

func (*CreateTaskRequest) String 

func (x *CreateTaskRequest) String() string

type CreateZoneRequest 

type CreateZoneRequest struct {

	// Required. The resource name of the parent lake:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Zone identifier.
	// This ID will be used to generate names such as database and dataset names
	// when publishing metadata to Hive Metastore and BigQuery.
	// * Must contain only lowercase letters, numbers and hyphens.
	// * Must start with a letter.
	// * Must end with a number or a letter.
	// * Must be between 1-63 characters.
	// * Must be unique across all lakes from all locations in a project.
	// * Must not be one of the reserved IDs (i.e. "default", "global-temp")
	ZoneId string `protobuf:"bytes,2,opt,name=zone_id,json=zoneId,proto3" json:"zone_id,omitempty"`
	// Required. Zone resource.
	Zone *Zone `protobuf:"bytes,3,opt,name=zone,proto3" json:"zone,omitempty"`
	// Optional. Only validate the request, but do not perform mutations.
	// The default is false.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

Create zone request.

func (*CreateZoneRequest) Descriptor deprecated 

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

Deprecated: Use CreateZoneRequest.ProtoReflect.Descriptor instead.

func (*CreateZoneRequest) GetParent 

func (x *CreateZoneRequest) GetParent() string

func (*CreateZoneRequest) GetValidateOnly 

func (x *CreateZoneRequest) GetValidateOnly() bool

func (*CreateZoneRequest) GetZone 

func (x *CreateZoneRequest) GetZone() *Zone

func (*CreateZoneRequest) GetZoneId 

func (x *CreateZoneRequest) GetZoneId() string

func (*CreateZoneRequest) ProtoMessage 

func (*CreateZoneRequest) ProtoMessage()

func (*CreateZoneRequest) ProtoReflect 

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

func (*CreateZoneRequest) Reset 

func (x *CreateZoneRequest) Reset()

func (*CreateZoneRequest) String 

func (x *CreateZoneRequest) String() string

type DataplexServiceClient 

type DataplexServiceClient interface {
	// Creates a lake resource.
	CreateLake(ctx context.Context, in *CreateLakeRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Updates a lake resource.
	UpdateLake(ctx context.Context, in *UpdateLakeRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Deletes a lake resource. All zones within the lake must be deleted before
	// the lake can be deleted.
	DeleteLake(ctx context.Context, in *DeleteLakeRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Lists lake resources in a project and location.
	ListLakes(ctx context.Context, in *ListLakesRequest, opts ...grpc.CallOption) (*ListLakesResponse, error)
	// Retrieves a lake resource.
	GetLake(ctx context.Context, in *GetLakeRequest, opts ...grpc.CallOption) (*Lake, error)
	// Lists action resources in a lake.
	ListLakeActions(ctx context.Context, in *ListLakeActionsRequest, opts ...grpc.CallOption) (*ListActionsResponse, error)
	// Creates a zone resource within a lake.
	CreateZone(ctx context.Context, in *CreateZoneRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Updates a zone resource.
	UpdateZone(ctx context.Context, in *UpdateZoneRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Deletes a zone resource. All assets within a zone must be deleted before
	// the zone can be deleted.
	DeleteZone(ctx context.Context, in *DeleteZoneRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Lists zone resources in a lake.
	ListZones(ctx context.Context, in *ListZonesRequest, opts ...grpc.CallOption) (*ListZonesResponse, error)
	// Retrieves a zone resource.
	GetZone(ctx context.Context, in *GetZoneRequest, opts ...grpc.CallOption) (*Zone, error)
	// Lists action resources in a zone.
	ListZoneActions(ctx context.Context, in *ListZoneActionsRequest, opts ...grpc.CallOption) (*ListActionsResponse, error)
	// Creates an asset resource.
	CreateAsset(ctx context.Context, in *CreateAssetRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Updates an asset resource.
	UpdateAsset(ctx context.Context, in *UpdateAssetRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Deletes an asset resource. The referenced storage resource is detached
	// (default) or deleted based on the associated Lifecycle policy.
	DeleteAsset(ctx context.Context, in *DeleteAssetRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Lists asset resources in a zone.
	ListAssets(ctx context.Context, in *ListAssetsRequest, opts ...grpc.CallOption) (*ListAssetsResponse, error)
	// Retrieves an asset resource.
	GetAsset(ctx context.Context, in *GetAssetRequest, opts ...grpc.CallOption) (*Asset, error)
	// Lists action resources in an asset.
	ListAssetActions(ctx context.Context, in *ListAssetActionsRequest, opts ...grpc.CallOption) (*ListActionsResponse, error)
	// Creates a task resource within a lake.
	CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Update the task resource.
	UpdateTask(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Delete the task resource.
	DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Lists tasks under the given lake.
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
	// Get task resource.
	GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*Task, error)
	// Lists Jobs under the given task.
	ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
	// Get job resource.
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)
	// Cancel jobs running for the task resource.
	CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DataplexServiceClient is the client API for DataplexService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDataplexServiceClient 

func NewDataplexServiceClient(cc grpc.ClientConnInterface) DataplexServiceClient

type DataplexServiceServer 

type DataplexServiceServer interface {
	// Creates a lake resource.
	CreateLake(context.Context, *CreateLakeRequest) (*longrunning.Operation, error)
	// Updates a lake resource.
	UpdateLake(context.Context, *UpdateLakeRequest) (*longrunning.Operation, error)
	// Deletes a lake resource. All zones within the lake must be deleted before
	// the lake can be deleted.
	DeleteLake(context.Context, *DeleteLakeRequest) (*longrunning.Operation, error)
	// Lists lake resources in a project and location.
	ListLakes(context.Context, *ListLakesRequest) (*ListLakesResponse, error)
	// Retrieves a lake resource.
	GetLake(context.Context, *GetLakeRequest) (*Lake, error)
	// Lists action resources in a lake.
	ListLakeActions(context.Context, *ListLakeActionsRequest) (*ListActionsResponse, error)
	// Creates a zone resource within a lake.
	CreateZone(context.Context, *CreateZoneRequest) (*longrunning.Operation, error)
	// Updates a zone resource.
	UpdateZone(context.Context, *UpdateZoneRequest) (*longrunning.Operation, error)
	// Deletes a zone resource. All assets within a zone must be deleted before
	// the zone can be deleted.
	DeleteZone(context.Context, *DeleteZoneRequest) (*longrunning.Operation, error)
	// Lists zone resources in a lake.
	ListZones(context.Context, *ListZonesRequest) (*ListZonesResponse, error)
	// Retrieves a zone resource.
	GetZone(context.Context, *GetZoneRequest) (*Zone, error)
	// Lists action resources in a zone.
	ListZoneActions(context.Context, *ListZoneActionsRequest) (*ListActionsResponse, error)
	// Creates an asset resource.
	CreateAsset(context.Context, *CreateAssetRequest) (*longrunning.Operation, error)
	// Updates an asset resource.
	UpdateAsset(context.Context, *UpdateAssetRequest) (*longrunning.Operation, error)
	// Deletes an asset resource. The referenced storage resource is detached
	// (default) or deleted based on the associated Lifecycle policy.
	DeleteAsset(context.Context, *DeleteAssetRequest) (*longrunning.Operation, error)
	// Lists asset resources in a zone.
	ListAssets(context.Context, *ListAssetsRequest) (*ListAssetsResponse, error)
	// Retrieves an asset resource.
	GetAsset(context.Context, *GetAssetRequest) (*Asset, error)
	// Lists action resources in an asset.
	ListAssetActions(context.Context, *ListAssetActionsRequest) (*ListActionsResponse, error)
	// Creates a task resource within a lake.
	CreateTask(context.Context, *CreateTaskRequest) (*longrunning.Operation, error)
	// Update the task resource.
	UpdateTask(context.Context, *UpdateTaskRequest) (*longrunning.Operation, error)
	// Delete the task resource.
	DeleteTask(context.Context, *DeleteTaskRequest) (*longrunning.Operation, error)
	// Lists tasks under the given lake.
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
	// Get task resource.
	GetTask(context.Context, *GetTaskRequest) (*Task, error)
	// Lists Jobs under the given task.
	ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
	// Get job resource.
	GetJob(context.Context, *GetJobRequest) (*Job, error)
	// Cancel jobs running for the task resource.
	CancelJob(context.Context, *CancelJobRequest) (*emptypb.Empty, error)
}

DataplexServiceServer is the server API for DataplexService service.

type DeleteAssetRequest 

type DeleteAssetRequest struct {

	// Required. The resource name of the asset:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/assets/{asset_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Delete asset request.

func (*DeleteAssetRequest) Descriptor deprecated 

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

Deprecated: Use DeleteAssetRequest.ProtoReflect.Descriptor instead.

func (*DeleteAssetRequest) GetName 

func (x *DeleteAssetRequest) GetName() string

func (*DeleteAssetRequest) ProtoMessage 

func (*DeleteAssetRequest) ProtoMessage()

func (*DeleteAssetRequest) ProtoReflect 

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

func (*DeleteAssetRequest) Reset 

func (x *DeleteAssetRequest) Reset()

func (*DeleteAssetRequest) String 

func (x *DeleteAssetRequest) String() string

type DeleteLakeRequest 

type DeleteLakeRequest struct {

	// Required. The resource name of the lake:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Delete lake request.

func (*DeleteLakeRequest) Descriptor deprecated 

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

Deprecated: Use DeleteLakeRequest.ProtoReflect.Descriptor instead.

func (*DeleteLakeRequest) GetName 

func (x *DeleteLakeRequest) GetName() string

func (*DeleteLakeRequest) ProtoMessage 

func (*DeleteLakeRequest) ProtoMessage()

func (*DeleteLakeRequest) ProtoReflect 

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

func (*DeleteLakeRequest) Reset 

func (x *DeleteLakeRequest) Reset()

func (*DeleteLakeRequest) String 

func (x *DeleteLakeRequest) String() string

type DeleteTaskRequest 

type DeleteTaskRequest struct {

	// Required. The resource name of the task:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/task/{task_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Delete task request.

func (*DeleteTaskRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskRequest) GetName 

func (x *DeleteTaskRequest) GetName() string

func (*DeleteTaskRequest) ProtoMessage 

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) ProtoReflect 

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

func (*DeleteTaskRequest) Reset 

func (x *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) String 

func (x *DeleteTaskRequest) String() string

type DeleteZoneRequest 

type DeleteZoneRequest struct {

	// Required. The resource name of the zone:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Delete zone request.

func (*DeleteZoneRequest) Descriptor deprecated 

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

Deprecated: Use DeleteZoneRequest.ProtoReflect.Descriptor instead.

func (*DeleteZoneRequest) GetName 

func (x *DeleteZoneRequest) GetName() string

func (*DeleteZoneRequest) ProtoMessage 

func (*DeleteZoneRequest) ProtoMessage()

func (*DeleteZoneRequest) ProtoReflect 

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

func (*DeleteZoneRequest) Reset 

func (x *DeleteZoneRequest) Reset()

func (*DeleteZoneRequest) String 

func (x *DeleteZoneRequest) String() string

type DiscoveryEvent 

type DiscoveryEvent struct {

	// The log message.
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// The id of the associated lake.
	LakeId string `protobuf:"bytes,2,opt,name=lake_id,json=lakeId,proto3" json:"lake_id,omitempty"`
	// The id of the associated zone.
	ZoneId string `protobuf:"bytes,3,opt,name=zone_id,json=zoneId,proto3" json:"zone_id,omitempty"`
	// The id of the associated asset.
	AssetId string `protobuf:"bytes,4,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"`
	// The data location associated with the event.
	DataLocation string `protobuf:"bytes,5,opt,name=data_location,json=dataLocation,proto3" json:"data_location,omitempty"`
	// The type of the event being logged.
	Type DiscoveryEvent_EventType `protobuf:"varint,10,opt,name=type,proto3,enum=google.cloud.dataplex.v1.DiscoveryEvent_EventType" json:"type,omitempty"`
	// Additional details about the event.
	//
	// Types that are assignable to Details:
	//	*DiscoveryEvent_Config
	//	*DiscoveryEvent_Entity
	//	*DiscoveryEvent_Partition
	//	*DiscoveryEvent_Action
	Details isDiscoveryEvent_Details `protobuf_oneof:"details"`
	// contains filtered or unexported fields
}

The payload associated with Discovery data processing.

func (*DiscoveryEvent) Descriptor deprecated 

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

Deprecated: Use DiscoveryEvent.ProtoReflect.Descriptor instead.

func (*DiscoveryEvent) GetAction 

func (x *DiscoveryEvent) GetAction() *DiscoveryEvent_ActionDetails

func (*DiscoveryEvent) GetAssetId 

func (x *DiscoveryEvent) GetAssetId() string

func (*DiscoveryEvent) GetConfig 

func (x *DiscoveryEvent) GetConfig() *DiscoveryEvent_ConfigDetails

func (*DiscoveryEvent) GetDataLocation 

func (x *DiscoveryEvent) GetDataLocation() string

func (*DiscoveryEvent) GetDetails 

func (m *DiscoveryEvent) GetDetails() isDiscoveryEvent_Details

func (*DiscoveryEvent) GetEntity 

func (x *DiscoveryEvent) GetEntity() *DiscoveryEvent_EntityDetails

func (*DiscoveryEvent) GetLakeId 

func (x *DiscoveryEvent) GetLakeId() string

func (*DiscoveryEvent) GetMessage 

func (x *DiscoveryEvent) GetMessage() string

func (*DiscoveryEvent) GetPartition 

func (x *DiscoveryEvent) GetPartition() *DiscoveryEvent_PartitionDetails

func (*DiscoveryEvent) GetType 

func (x *DiscoveryEvent) GetType() DiscoveryEvent_EventType

func (*DiscoveryEvent) GetZoneId 

func (x *DiscoveryEvent) GetZoneId() string

func (*DiscoveryEvent) ProtoMessage 

func (*DiscoveryEvent) ProtoMessage()

func (*DiscoveryEvent) ProtoReflect 

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

func (*DiscoveryEvent) Reset 

func (x *DiscoveryEvent) Reset()

func (*DiscoveryEvent) String 

func (x *DiscoveryEvent) String() string

type DiscoveryEvent_Action 

type DiscoveryEvent_Action struct {
	// Details about the action associated with the event.
	Action *DiscoveryEvent_ActionDetails `protobuf:"bytes,23,opt,name=action,proto3,oneof"`
}

type DiscoveryEvent_ActionDetails 

type DiscoveryEvent_ActionDetails struct {

	// The type of action.
	// Eg. IncompatibleDataSchema, InvalidDataFormat
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

Details about the action.

func (*DiscoveryEvent_ActionDetails) Descriptor deprecated 

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

Deprecated: Use DiscoveryEvent_ActionDetails.ProtoReflect.Descriptor instead.

func (*DiscoveryEvent_ActionDetails) GetType 

func (x *DiscoveryEvent_ActionDetails) GetType() string

func (*DiscoveryEvent_ActionDetails) ProtoMessage 

func (*DiscoveryEvent_ActionDetails) ProtoMessage()

func (*DiscoveryEvent_ActionDetails) ProtoReflect 

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

func (*DiscoveryEvent_ActionDetails) Reset 

func (x *DiscoveryEvent_ActionDetails) Reset()

func (*DiscoveryEvent_ActionDetails) String 

func (x *DiscoveryEvent_ActionDetails) String() string

type DiscoveryEvent_Config 

type DiscoveryEvent_Config struct {
	// Details about discovery configuration in effect.
	Config *DiscoveryEvent_ConfigDetails `protobuf:"bytes,20,opt,name=config,proto3,oneof"`
}

type DiscoveryEvent_ConfigDetails 

type DiscoveryEvent_ConfigDetails struct {

	// A list of discovery configuration parameters in effect.
	// The keys are the field paths within DiscoverySpec.
	// Eg. includePatterns, excludePatterns, csvOptions.disableTypeInference,
	// etc.
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

Details about configuration events.

func (*DiscoveryEvent_ConfigDetails) Descriptor deprecated 

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

Deprecated: Use DiscoveryEvent_ConfigDetails.ProtoReflect.Descriptor instead.

func (*DiscoveryEvent_ConfigDetails) GetParameters 

func (x *DiscoveryEvent_ConfigDetails) GetParameters() map[string]string

func (*DiscoveryEvent_ConfigDetails) ProtoMessage 

func (*DiscoveryEvent_ConfigDetails) ProtoMessage()

func (*DiscoveryEvent_ConfigDetails) ProtoReflect 

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

func (*DiscoveryEvent_ConfigDetails) Reset 

func (x *DiscoveryEvent_ConfigDetails) Reset()

func (*DiscoveryEvent_ConfigDetails) String 

func (x *DiscoveryEvent_ConfigDetails) String() string

type DiscoveryEvent_Entity 

type DiscoveryEvent_Entity struct {
	// Details about the entity associated with the event.
	Entity *DiscoveryEvent_EntityDetails `protobuf:"bytes,21,opt,name=entity,proto3,oneof"`
}

type DiscoveryEvent_EntityDetails 

type DiscoveryEvent_EntityDetails struct {

	// The name of the entity resource.
	// The name is the fully-qualified resource name.
	Entity string `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"`
	// The type of the entity resource.
	Type DiscoveryEvent_EntityType `protobuf:"varint,2,opt,name=type,proto3,enum=google.cloud.dataplex.v1.DiscoveryEvent_EntityType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

Details about the entity.

func (*DiscoveryEvent_EntityDetails) Descriptor deprecated 

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

Deprecated: Use DiscoveryEvent_EntityDetails.ProtoReflect.Descriptor instead.

func (*DiscoveryEvent_EntityDetails) GetEntity 

func (x *DiscoveryEvent_EntityDetails) GetEntity() string

func (*DiscoveryEvent_EntityDetails) GetType 

func (x *DiscoveryEvent_EntityDetails) GetType() DiscoveryEvent_EntityType

func (*DiscoveryEvent_EntityDetails) ProtoMessage 

func (*DiscoveryEvent_EntityDetails) ProtoMessage()

func (*DiscoveryEvent_EntityDetails) ProtoReflect 

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

func (*DiscoveryEvent_EntityDetails) Reset 

func (x *DiscoveryEvent_EntityDetails) Reset()

func (*DiscoveryEvent_EntityDetails) String 

func (x *DiscoveryEvent_EntityDetails) String() string

type DiscoveryEvent_EntityType 

type DiscoveryEvent_EntityType int32

The type of the entity. 

const (
	// An unspecified event type.
	DiscoveryEvent_ENTITY_TYPE_UNSPECIFIED DiscoveryEvent_EntityType = 0
	// Entities representing structured data.
	DiscoveryEvent_TABLE DiscoveryEvent_EntityType = 1
	// Entities representing unstructured data.
	DiscoveryEvent_FILESET DiscoveryEvent_EntityType = 2
)

func (DiscoveryEvent_EntityType) Descriptor 

func (DiscoveryEvent_EntityType) Descriptor() protoreflect.EnumDescriptor

func (DiscoveryEvent_EntityType) Enum 

func (x DiscoveryEvent_EntityType) Enum() *DiscoveryEvent_EntityType

func (DiscoveryEvent_EntityType) EnumDescriptor deprecated 

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

Deprecated: Use DiscoveryEvent_EntityType.Descriptor instead.

func (DiscoveryEvent_EntityType) Number 

func (x DiscoveryEvent_EntityType) Number() protoreflect.EnumNumber

func (DiscoveryEvent_EntityType) String 

func (x DiscoveryEvent_EntityType) String() string

func (DiscoveryEvent_EntityType) Type 

func (DiscoveryEvent_EntityType) Type() protoreflect.EnumType

type DiscoveryEvent_EventType 

type DiscoveryEvent_EventType int32

The type of the event. 

const (
	// An unspecified event type.
	DiscoveryEvent_EVENT_TYPE_UNSPECIFIED DiscoveryEvent_EventType = 0
	// An event representing discovery configuration in effect.
	DiscoveryEvent_CONFIG DiscoveryEvent_EventType = 1
	// An event representing a metadata entity being created.
	DiscoveryEvent_ENTITY_CREATED DiscoveryEvent_EventType = 2
	// An event representing a metadata entity being updated.
	DiscoveryEvent_ENTITY_UPDATED DiscoveryEvent_EventType = 3
	// An event representing a metadata entity being deleted.
	DiscoveryEvent_ENTITY_DELETED DiscoveryEvent_EventType = 4
	// An event representing a partition being created.
	DiscoveryEvent_PARTITION_CREATED DiscoveryEvent_EventType = 5
	// An event representing a partition being updated.
	DiscoveryEvent_PARTITION_UPDATED DiscoveryEvent_EventType = 6
	// An event representing a partition being deleted.
	DiscoveryEvent_PARTITION_DELETED DiscoveryEvent_EventType = 7
)

func (DiscoveryEvent_EventType) Descriptor 

func (DiscoveryEvent_EventType) Descriptor() protoreflect.EnumDescriptor

func (DiscoveryEvent_EventType) Enum 

func (x DiscoveryEvent_EventType) Enum() *DiscoveryEvent_EventType

func (DiscoveryEvent_EventType) EnumDescriptor deprecated 

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

Deprecated: Use DiscoveryEvent_EventType.Descriptor instead.

func (DiscoveryEvent_EventType) Number 

func (x DiscoveryEvent_EventType) Number() protoreflect.EnumNumber

func (DiscoveryEvent_EventType) String 

func (x DiscoveryEvent_EventType) String() string

func (DiscoveryEvent_EventType) Type 

func (DiscoveryEvent_EventType) Type() protoreflect.EnumType

type DiscoveryEvent_Partition 

type DiscoveryEvent_Partition struct {
	// Details about the partition associated with the event.
	Partition *DiscoveryEvent_PartitionDetails `protobuf:"bytes,22,opt,name=partition,proto3,oneof"`
}

type DiscoveryEvent_PartitionDetails 

type DiscoveryEvent_PartitionDetails struct {

	// The name to the partition resource.
	// The name is the fully-qualified resource name.
	Partition string `protobuf:"bytes,1,opt,name=partition,proto3" json:"partition,omitempty"`
	// The name to the containing entity resource.
	// The name is the fully-qualified resource name.
	Entity string `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	// The type of the containing entity resource.
	Type DiscoveryEvent_EntityType `protobuf:"varint,3,opt,name=type,proto3,enum=google.cloud.dataplex.v1.DiscoveryEvent_EntityType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

Details about the partition.

func (*DiscoveryEvent_PartitionDetails) Descriptor deprecated 

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

Deprecated: Use DiscoveryEvent_PartitionDetails.ProtoReflect.Descriptor instead.

func (*DiscoveryEvent_PartitionDetails) GetEntity 

func (x *DiscoveryEvent_PartitionDetails) GetEntity() string

func (*DiscoveryEvent_PartitionDetails) GetPartition 

func (x *DiscoveryEvent_PartitionDetails) GetPartition() string

func (*DiscoveryEvent_PartitionDetails) GetType 

func (x *DiscoveryEvent_PartitionDetails) GetType() DiscoveryEvent_EntityType

func (*DiscoveryEvent_PartitionDetails) ProtoMessage 

func (*DiscoveryEvent_PartitionDetails) ProtoMessage()

func (*DiscoveryEvent_PartitionDetails) ProtoReflect 

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

func (*DiscoveryEvent_PartitionDetails) Reset 

func (x *DiscoveryEvent_PartitionDetails) Reset()

func (*DiscoveryEvent_PartitionDetails) String 

func (x *DiscoveryEvent_PartitionDetails) String() string

type Entity 

type Entity struct {

	// Output only. The resource name of the entity, of the form:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/entities/{id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. User friendly display name.
	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Optional. User friendly longer description text.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Output only. The time when the entity was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time when the entity was last updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Required. A user-provided entity ID. It is mutable, and will be used as the
	// published table name. Specifying a new ID in an update entity
	// request will override the existing value.
	Id string `protobuf:"bytes,7,opt,name=id,proto3" json:"id,omitempty"`
	// Optional. The etag for this entity.
	// Required for update requests. It must match the server's etag.
	Etag string `protobuf:"bytes,8,opt,name=etag,proto3" json:"etag,omitempty"`
	// Required. The type of entity.
	Type Entity_Type `protobuf:"varint,10,opt,name=type,proto3,enum=google.cloud.dataplex.v1.Entity_Type" json:"type,omitempty"`
	// Required. The name of the asset associated with the storage location containing the
	// entity data.
	Asset string `protobuf:"bytes,11,opt,name=asset,proto3" json:"asset,omitempty"`
	// Required. Immutable. The storage path of the entity data.
	// For Cloud Storage data, this is the fully-qualified path to the entity,
	// such as `gs://bucket/path/to/data`. For BigQuery data, this is the name of
	// the table resource, such as
	// `projects/project_id/datasets/dataset_id/tables/table_id`.
	DataPath string `protobuf:"bytes,12,opt,name=data_path,json=dataPath,proto3" json:"data_path,omitempty"`
	// Optional. The set of items within the data path constituting the data in the entity,
	// represented as a glob path.
	// Example: `gs://bucket/path/to/data/**/*.csv`.
	DataPathPattern string `protobuf:"bytes,13,opt,name=data_path_pattern,json=dataPathPattern,proto3" json:"data_path_pattern,omitempty"`
	// Output only. The name of the associated Data Catalog entry.
	CatalogEntry string `protobuf:"bytes,14,opt,name=catalog_entry,json=catalogEntry,proto3" json:"catalog_entry,omitempty"`
	// Required. Identifies the storage system of the entity data.
	System StorageSystem `protobuf:"varint,15,opt,name=system,proto3,enum=google.cloud.dataplex.v1.StorageSystem" json:"system,omitempty"`
	// Required. Identifies the storage format of the entity data.
	// It does not apply to entities with data stored in BigQuery.
	Format *StorageFormat `protobuf:"bytes,16,opt,name=format,proto3" json:"format,omitempty"`
	// Output only. Metadata stores that the entity is compatible with.
	Compatibility *Entity_CompatibilityStatus `protobuf:"bytes,19,opt,name=compatibility,proto3" json:"compatibility,omitempty"`
	// Required. The description of the data structure and layout.
	// The schema is not included in list responses. It is only included in
	// `SCHEMA` and `FULL` entity views of a `GetEntity` response.
	Schema *Schema `protobuf:"bytes,50,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

Represents tables and fileset metadata contained within a zone.

func (*Entity) Descriptor deprecated 

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

Deprecated: Use Entity.ProtoReflect.Descriptor instead.

func (*Entity) GetAsset 

func (x *Entity) GetAsset() string

func (*Entity) GetCatalogEntry 

func (x *Entity) GetCatalogEntry() string

func (*Entity) GetCompatibility 

func (x *Entity) GetCompatibility() *Entity_CompatibilityStatus

func (*Entity) GetCreateTime 

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

func (*Entity) GetDataPath 

func (x *Entity) GetDataPath() string

func (*Entity) GetDataPathPattern 

func (x *Entity) GetDataPathPattern() string

func (*Entity) GetDescription 

func (x *Entity) GetDescription() string

func (*Entity) GetDisplayName 

func (x *Entity) GetDisplayName() string

func (*Entity) GetEtag 

func (x *Entity) GetEtag() string

func (*Entity) GetFormat 

func (x *Entity) GetFormat() *StorageFormat

func (*Entity) GetId 

func (x *Entity) GetId() string

func (*Entity) GetName 

func (x *Entity) GetName() string

func (*Entity) GetSchema 

func (x *Entity) GetSchema() *Schema

func (*Entity) GetSystem 

func (x *Entity) GetSystem() StorageSystem

func (*Entity) GetType 

func (x *Entity) GetType() Entity_Type

func (*Entity) GetUpdateTime 

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

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) ProtoReflect 

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

func (*Entity) Reset 

func (x *Entity) Reset()

func (*Entity) String 

func (x *Entity) String() string

type Entity_CompatibilityStatus 

type Entity_CompatibilityStatus struct {

	// Output only. Whether this entity is compatible with Hive Metastore.
	HiveMetastore *Entity_CompatibilityStatus_Compatibility `protobuf:"bytes,1,opt,name=hive_metastore,json=hiveMetastore,proto3" json:"hive_metastore,omitempty"`
	// Output only. Whether this entity is compatible with BigQuery.
	Bigquery *Entity_CompatibilityStatus_Compatibility `protobuf:"bytes,2,opt,name=bigquery,proto3" json:"bigquery,omitempty"`
	// contains filtered or unexported fields
}

Provides compatibility information for various metadata stores.

func (*Entity_CompatibilityStatus) Descriptor deprecated 

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

Deprecated: Use Entity_CompatibilityStatus.ProtoReflect.Descriptor instead.

func (*Entity_CompatibilityStatus) GetBigquery 

func (x *Entity_CompatibilityStatus) GetBigquery() *Entity_CompatibilityStatus_Compatibility

func (*Entity_CompatibilityStatus) GetHiveMetastore 

func (x *Entity_CompatibilityStatus) GetHiveMetastore() *Entity_CompatibilityStatus_Compatibility

func (*Entity_CompatibilityStatus) ProtoMessage 

func (*Entity_CompatibilityStatus) ProtoMessage()

func (*Entity_CompatibilityStatus) ProtoReflect 

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

func (*Entity_CompatibilityStatus) Reset 

func (x *Entity_CompatibilityStatus) Reset()

func (*Entity_CompatibilityStatus) String 

func (x *Entity_CompatibilityStatus) String() string

type Entity_CompatibilityStatus_Compatibility 

type Entity_CompatibilityStatus_Compatibility struct {

	// Output only. Whether the entity is compatible and can be represented in the metadata
	// store.
	Compatible bool `protobuf:"varint,1,opt,name=compatible,proto3" json:"compatible,omitempty"`
	// Output only. Provides additional detail if the entity is incompatible with the
	// metadata store.
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

Provides compatibility information for a specific metadata store.

func (*Entity_CompatibilityStatus_Compatibility) Descriptor deprecated 

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

Deprecated: Use Entity_CompatibilityStatus_Compatibility.ProtoReflect.Descriptor instead.

func (*Entity_CompatibilityStatus_Compatibility) GetCompatible 

func (x *Entity_CompatibilityStatus_Compatibility) GetCompatible() bool

func (*Entity_CompatibilityStatus_Compatibility) GetReason 

func (x *Entity_CompatibilityStatus_Compatibility) GetReason() string

func (*Entity_CompatibilityStatus_Compatibility) ProtoMessage 

func (*Entity_CompatibilityStatus_Compatibility) ProtoMessage()

func (*Entity_CompatibilityStatus_Compatibility) ProtoReflect 

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

func (*Entity_CompatibilityStatus_Compatibility) Reset 

func (x *Entity_CompatibilityStatus_Compatibility) Reset()

func (*Entity_CompatibilityStatus_Compatibility) String 

func (x *Entity_CompatibilityStatus_Compatibility) String() string

type Entity_Type 

type Entity_Type int32

The type of entity. 

const (
	// Type unspecified.
	Entity_TYPE_UNSPECIFIED Entity_Type = 0
	// Structured and semi-structured data.
	Entity_TABLE Entity_Type = 1
	// Unstructured data.
	Entity_FILESET Entity_Type = 2
)

func (Entity_Type) Descriptor 

func (Entity_Type) Descriptor() protoreflect.EnumDescriptor

func (Entity_Type) Enum 

func (x Entity_Type) Enum() *Entity_Type

func (Entity_Type) EnumDescriptor deprecated 

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

Deprecated: Use Entity_Type.Descriptor instead.

func (Entity_Type) Number 

func (x Entity_Type) Number() protoreflect.EnumNumber

func (Entity_Type) String 

func (x Entity_Type) String() string

func (Entity_Type) Type 

func (Entity_Type) Type() protoreflect.EnumType

type GetAssetRequest 

type GetAssetRequest struct {

	// Required. The resource name of the asset:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/assets/{asset_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Get asset request.

func (*GetAssetRequest) Descriptor deprecated 

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

Deprecated: Use GetAssetRequest.ProtoReflect.Descriptor instead.

func (*GetAssetRequest) GetName 

func (x *GetAssetRequest) GetName() string

func (*GetAssetRequest) ProtoMessage 

func (*GetAssetRequest) ProtoMessage()

func (*GetAssetRequest) ProtoReflect 

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

func (*GetAssetRequest) Reset 

func (x *GetAssetRequest) Reset()

func (*GetAssetRequest) String 

func (x *GetAssetRequest) String() string

type GetEntityRequest 

type GetEntityRequest struct {

	// Required. The resource name of the entity:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/entities/{entity_id}.`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. Used to select the subset of entity information to return.
	// Defaults to `BASIC`.
	View GetEntityRequest_EntityView `protobuf:"varint,2,opt,name=view,proto3,enum=google.cloud.dataplex.v1.GetEntityRequest_EntityView" json:"view,omitempty"`
	// contains filtered or unexported fields
}

Get metadata entity request.

func (*GetEntityRequest) Descriptor deprecated 

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

Deprecated: Use GetEntityRequest.ProtoReflect.Descriptor instead.

func (*GetEntityRequest) GetName 

func (x *GetEntityRequest) GetName() string

func (*GetEntityRequest) GetView 

func (x *GetEntityRequest) GetView() GetEntityRequest_EntityView

func (*GetEntityRequest) ProtoMessage 

func (*GetEntityRequest) ProtoMessage()

func (*GetEntityRequest) ProtoReflect 

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

func (*GetEntityRequest) Reset 

func (x *GetEntityRequest) Reset()

func (*GetEntityRequest) String 

func (x *GetEntityRequest) String() string

type GetEntityRequest_EntityView 

type GetEntityRequest_EntityView int32

Entity views for get entity partial result. 

const (
	// The API will default to the `BASIC` view.
	GetEntityRequest_ENTITY_VIEW_UNSPECIFIED GetEntityRequest_EntityView = 0
	// Minimal view that does not include the schema.
	GetEntityRequest_BASIC GetEntityRequest_EntityView = 1
	// Include basic information and schema.
	GetEntityRequest_SCHEMA GetEntityRequest_EntityView = 2
	// Include everything.
	GetEntityRequest_FULL GetEntityRequest_EntityView = 4
)

func (GetEntityRequest_EntityView) Descriptor 

func (GetEntityRequest_EntityView) Descriptor() protoreflect.EnumDescriptor

func (GetEntityRequest_EntityView) Enum 

func (x GetEntityRequest_EntityView) Enum() *GetEntityRequest_EntityView

func (GetEntityRequest_EntityView) EnumDescriptor deprecated 

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

Deprecated: Use GetEntityRequest_EntityView.Descriptor instead.

func (GetEntityRequest_EntityView) Number 

func (x GetEntityRequest_EntityView) Number() protoreflect.EnumNumber

func (GetEntityRequest_EntityView) String 

func (x GetEntityRequest_EntityView) String() string

func (GetEntityRequest_EntityView) Type 

func (GetEntityRequest_EntityView) Type() protoreflect.EnumType

type GetJobRequest 

type GetJobRequest struct {

	// Required. The resource name of the job:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/tasks/{task_id}/jobs/{job_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Get job request.

func (*GetJobRequest) Descriptor deprecated 

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetName 

func (x *GetJobRequest) GetName() string

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect 

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

func (*GetJobRequest) Reset 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (x *GetJobRequest) String() string

type GetLakeRequest 

type GetLakeRequest struct {

	// Required. The resource name of the lake:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Get lake request.

func (*GetLakeRequest) Descriptor deprecated 

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

Deprecated: Use GetLakeRequest.ProtoReflect.Descriptor instead.

func (*GetLakeRequest) GetName 

func (x *GetLakeRequest) GetName() string

func (*GetLakeRequest) ProtoMessage 

func (*GetLakeRequest) ProtoMessage()

func (*GetLakeRequest) ProtoReflect 

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

func (*GetLakeRequest) Reset 

func (x *GetLakeRequest) Reset()

func (*GetLakeRequest) String 

func (x *GetLakeRequest) String() string

type GetPartitionRequest 

type GetPartitionRequest struct {

	// Required. The resource name of the partition:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/entities/{entity_id}/partitions/{partition_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Get metadata partition request.

func (*GetPartitionRequest) Descriptor deprecated 

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

Deprecated: Use GetPartitionRequest.ProtoReflect.Descriptor instead.

func (*GetPartitionRequest) GetName 

func (x *GetPartitionRequest) GetName() string

func (*GetPartitionRequest) ProtoMessage 

func (*GetPartitionRequest) ProtoMessage()

func (*GetPartitionRequest) ProtoReflect 

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

func (*GetPartitionRequest) Reset 

func (x *GetPartitionRequest) Reset()

func (*GetPartitionRequest) String 

func (x *GetPartitionRequest) String() string

type GetTaskRequest 

type GetTaskRequest struct {

	// Required. The resource name of the task:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/tasks/{tasks_id}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Get task request.

func (*GetTaskRequest) Descriptor deprecated 

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

Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead.

func (*GetTaskRequest) GetName 

func (x *GetTaskRequest) GetName() string

func (*GetTaskRequest) ProtoMessage 

func (*GetTaskRequest) ProtoMessage()

func (*GetTaskRequest) ProtoReflect 

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

func (*GetTaskRequest) Reset 

func (x *GetTaskRequest) Reset()

func (*GetTaskRequest) String 

func (x *GetTaskRequest) String() string

type GetZoneRequest 

type GetZoneRequest struct {

	// Required. The resource name of the zone:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Get zone request.

func (*GetZoneRequest) Descriptor deprecated 

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

Deprecated: Use GetZoneRequest.ProtoReflect.Descriptor instead.

func (*GetZoneRequest) GetName 

func (x *GetZoneRequest) GetName() string

func (*GetZoneRequest) ProtoMessage 

func (*GetZoneRequest) ProtoMessage()

func (*GetZoneRequest) ProtoReflect 

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

func (*GetZoneRequest) Reset 

func (x *GetZoneRequest) Reset()

func (*GetZoneRequest) String 

func (x *GetZoneRequest) String() string

type Job 

type Job struct {

	// Output only. The relative resource name of the job, of the form:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/tasks/{task_id}/jobs/{job_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. System generated globally unique ID for the job.
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// Output only. The time when the job was started.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Output only. The time when the job ended.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Output only. Execution state for the job.
	State Job_State `protobuf:"varint,5,opt,name=state,proto3,enum=google.cloud.dataplex.v1.Job_State" json:"state,omitempty"`
	// Output only. The number of times the job has been retried (excluding the
	// initial attempt).
	RetryCount uint32 `protobuf:"varint,6,opt,name=retry_count,json=retryCount,proto3" json:"retry_count,omitempty"`
	// Output only. The underlying service running a job.
	Service Job_Service `protobuf:"varint,7,opt,name=service,proto3,enum=google.cloud.dataplex.v1.Job_Service" json:"service,omitempty"`
	// Output only. The full resource name for the job run under a particular service.
	ServiceJob string `protobuf:"bytes,8,opt,name=service_job,json=serviceJob,proto3" json:"service_job,omitempty"`
	// Output only. Additional information about the current state.
	Message string `protobuf:"bytes,9,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

A job represents an instance of a task.

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetEndTime 

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

func (*Job) GetMessage 

func (x *Job) GetMessage() string

func (*Job) GetName 

func (x *Job) GetName() string

func (*Job) GetRetryCount 

func (x *Job) GetRetryCount() uint32

func (*Job) GetService 

func (x *Job) GetService() Job_Service

func (*Job) GetServiceJob 

func (x *Job) GetServiceJob() string

func (*Job) GetStartTime 

func (x *Job) GetStartTime() *timestamppb.Timestamp

func (*Job) GetState 

func (x *Job) GetState() Job_State

func (*Job) GetUid 

func (x *Job) GetUid() string

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type JobEvent 

type JobEvent struct {

	// The log message.
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// The unique id identifying the job.
	JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// The time when the job started running.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The time when the job ended running.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// The job state on completion.
	State JobEvent_State `protobuf:"varint,5,opt,name=state,proto3,enum=google.cloud.dataplex.v1.JobEvent_State" json:"state,omitempty"`
	// The number of retries.
	Retries int32 `protobuf:"varint,6,opt,name=retries,proto3" json:"retries,omitempty"`
	// The type of the job.
	Type JobEvent_Type `protobuf:"varint,7,opt,name=type,proto3,enum=google.cloud.dataplex.v1.JobEvent_Type" json:"type,omitempty"`
	// The service used to execute the job.
	Service JobEvent_Service `protobuf:"varint,8,opt,name=service,proto3,enum=google.cloud.dataplex.v1.JobEvent_Service" json:"service,omitempty"`
	// The reference to the job within the service.
	ServiceJob string `protobuf:"bytes,9,opt,name=service_job,json=serviceJob,proto3" json:"service_job,omitempty"`
	// contains filtered or unexported fields
}

The payload associated with Job logs that contains events describing jobs that have run within a Lake.

func (*JobEvent) Descriptor deprecated 

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

Deprecated: Use JobEvent.ProtoReflect.Descriptor instead.

func (*JobEvent) GetEndTime 

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

func (*JobEvent) GetJobId 

func (x *JobEvent) GetJobId() string

func (*JobEvent) GetMessage 

func (x *JobEvent) GetMessage() string

func (*JobEvent) GetRetries 

func (x *JobEvent) GetRetries() int32

func (*JobEvent) GetService 

func (x *JobEvent) GetService() JobEvent_Service

func (*JobEvent) GetServiceJob 

func (x *JobEvent) GetServiceJob() string

func (*JobEvent) GetStartTime 

func (x *JobEvent) GetStartTime() *timestamppb.Timestamp

func (*JobEvent) GetState 

func (x *JobEvent) GetState() JobEvent_State

func (*JobEvent) GetType 

func (x *JobEvent) GetType() JobEvent_Type

func (*JobEvent) ProtoMessage 

func (*JobEvent) ProtoMessage()

func (*JobEvent) ProtoReflect 

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

func (*JobEvent) Reset 

func (x *JobEvent) Reset()

func (*JobEvent) String 

func (x *JobEvent) String() string

type JobEvent_Service 

type JobEvent_Service int32

The service used to execute the job. 

const (
	// Unspecified service.
	JobEvent_SERVICE_UNSPECIFIED JobEvent_Service = 0
	// Cloud Dataproc.
	JobEvent_DATAPROC JobEvent_Service = 1
)

func (JobEvent_Service) Descriptor 

func (JobEvent_Service) Descriptor() protoreflect.EnumDescriptor

func (JobEvent_Service) Enum 

func (x JobEvent_Service) Enum() *JobEvent_Service

func (JobEvent_Service) EnumDescriptor deprecated 

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

Deprecated: Use JobEvent_Service.Descriptor instead.

func (JobEvent_Service) Number 

func (x JobEvent_Service) Number() protoreflect.EnumNumber

func (JobEvent_Service) String 

func (x JobEvent_Service) String() string

func (JobEvent_Service) Type 

func (JobEvent_Service) Type() protoreflect.EnumType

type JobEvent_State 

type JobEvent_State int32

The completion status of the job. 

const (
	// Unspecified job state.
	JobEvent_STATE_UNSPECIFIED JobEvent_State = 0
	// Job successfully completed.
	JobEvent_SUCCEEDED JobEvent_State = 1
	// Job was unsuccessful.
	JobEvent_FAILED JobEvent_State = 2
	// Job was cancelled by the user.
	JobEvent_CANCELLED JobEvent_State = 3
	// Job was cancelled or aborted via the service executing the job.
	JobEvent_ABORTED JobEvent_State = 4
)

func (JobEvent_State) Descriptor 

func (JobEvent_State) Descriptor() protoreflect.EnumDescriptor

func (JobEvent_State) Enum 

func (x JobEvent_State) Enum() *JobEvent_State

func (JobEvent_State) EnumDescriptor deprecated 

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

Deprecated: Use JobEvent_State.Descriptor instead.

func (JobEvent_State) Number 

func (x JobEvent_State) Number() protoreflect.EnumNumber

func (JobEvent_State) String 

func (x JobEvent_State) String() string

func (JobEvent_State) Type 

func (JobEvent_State) Type() protoreflect.EnumType

type JobEvent_Type 

type JobEvent_Type int32

The type of the job. 

const (
	// Unspecified job type.
	JobEvent_TYPE_UNSPECIFIED JobEvent_Type = 0
	// Spark jobs.
	JobEvent_SPARK JobEvent_Type = 1
	// Notebook jobs.
	JobEvent_NOTEBOOK JobEvent_Type = 2
)

func (JobEvent_Type) Descriptor 

func (JobEvent_Type) Descriptor() protoreflect.EnumDescriptor

func (JobEvent_Type) Enum 

func (x JobEvent_Type) Enum() *JobEvent_Type

func (JobEvent_Type) EnumDescriptor deprecated 

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

Deprecated: Use JobEvent_Type.Descriptor instead.

func (JobEvent_Type) Number 

func (x JobEvent_Type) Number() protoreflect.EnumNumber

func (JobEvent_Type) String 

func (x JobEvent_Type) String() string

func (JobEvent_Type) Type 

func (JobEvent_Type) Type() protoreflect.EnumType

type Job_Service 

type Job_Service int32
const (
	// Service used to run the job is unspecified.
	Job_SERVICE_UNSPECIFIED Job_Service = 0
	// Dataproc service is used to run this job.
	Job_DATAPROC Job_Service = 1
)

func (Job_Service) Descriptor 

func (Job_Service) Descriptor() protoreflect.EnumDescriptor

func (Job_Service) Enum 

func (x Job_Service) Enum() *Job_Service

func (Job_Service) EnumDescriptor deprecated 

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

Deprecated: Use Job_Service.Descriptor instead.

func (Job_Service) Number 

func (x Job_Service) Number() protoreflect.EnumNumber

func (Job_Service) String 

func (x Job_Service) String() string

func (Job_Service) Type 

func (Job_Service) Type() protoreflect.EnumType

type Job_State 

type Job_State int32
const (
	// The job state is unknown.
	Job_STATE_UNSPECIFIED Job_State = 0
	// The job is running.
	Job_RUNNING Job_State = 1
	// The job is cancelling.
	Job_CANCELLING Job_State = 2
	// The job cancellation was successful.
	Job_CANCELLED Job_State = 3
	// The job completed successfully.
	Job_SUCCEEDED Job_State = 4
	// The job is no longer running due to an error.
	Job_FAILED Job_State = 5
	// The job was cancelled outside of Dataplex.
	Job_ABORTED Job_State = 6
)

func (Job_State) Descriptor 

func (Job_State) Descriptor() protoreflect.EnumDescriptor

func (Job_State) Enum 

func (x Job_State) Enum() *Job_State

func (Job_State) EnumDescriptor deprecated 

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

Deprecated: Use Job_State.Descriptor instead.

func (Job_State) Number 

func (x Job_State) Number() protoreflect.EnumNumber

func (Job_State) String 

func (x Job_State) String() string

func (Job_State) Type 

func (Job_State) Type() protoreflect.EnumType

type Lake 

type Lake struct {

	// Output only. The relative resource name of the lake, of the form:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. User friendly display name.
	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Output only. System generated globally unique ID for the lake. This ID will be
	// different if the lake is deleted and re-created with the same name.
	Uid string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"`
	// Output only. The time when the lake was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time when the lake was last updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Optional. User-defined labels for the lake.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Optional. Description of the lake.
	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
	// Output only. Current state of the lake.
	State State `protobuf:"varint,8,opt,name=state,proto3,enum=google.cloud.dataplex.v1.State" json:"state,omitempty"`
	// Output only. Service account associated with this lake. This service account must be
	// authorized to access or operate on resources managed by the lake.
	ServiceAccount string `protobuf:"bytes,9,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// Optional. Settings to manage lake and Dataproc Metastore service instance
	// association.
	Metastore *Lake_Metastore `protobuf:"bytes,102,opt,name=metastore,proto3" json:"metastore,omitempty"`
	// Output only. Aggregated status of the underlying assets of the lake.
	AssetStatus *AssetStatus `protobuf:"bytes,103,opt,name=asset_status,json=assetStatus,proto3" json:"asset_status,omitempty"`
	// Output only. Metastore status of the lake.
	MetastoreStatus *Lake_MetastoreStatus `protobuf:"bytes,104,opt,name=metastore_status,json=metastoreStatus,proto3" json:"metastore_status,omitempty"`
	// contains filtered or unexported fields
}

A lake is a centralized repository for managing enterprise data across the organization distributed across many cloud projects, and stored in a variety of storage services such as Google Cloud Storage and BigQuery. The resources attached to a lake are referred to as managed resources. Data within these managed resources can be structured or unstructured. A lake provides data admins with tools to organize, secure and manage their data at scale, and provides data scientists and data engineers an integrated experience to easily search, discover, analyze and transform data and associated metadata.

func (*Lake) Descriptor deprecated 

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

Deprecated: Use Lake.ProtoReflect.Descriptor instead.

func (*Lake) GetAssetStatus 

func (x *Lake) GetAssetStatus() *AssetStatus

func (*Lake) GetCreateTime 

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

func (*Lake) GetDescription 

func (x *Lake) GetDescription() string

func (*Lake) GetDisplayName 

func (x *Lake) GetDisplayName() string

func (*Lake) GetLabels 

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

func (*Lake) GetMetastore 

func (x *Lake) GetMetastore() *Lake_Metastore

func (*Lake) GetMetastoreStatus 

func (x *Lake) GetMetastoreStatus() *Lake_MetastoreStatus

func (*Lake) GetName 

func (x *Lake) GetName() string

func (*Lake) GetServiceAccount 

func (x *Lake) GetServiceAccount() string

func (*Lake) GetState 

func (x *Lake) GetState() State

func (*Lake) GetUid 

func (x *Lake) GetUid() string

func (*Lake) GetUpdateTime 

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

func (*Lake) ProtoMessage 

func (*Lake) ProtoMessage()

func (*Lake) ProtoReflect 

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

func (*Lake) Reset 

func (x *Lake) Reset()

func (*Lake) String 

func (x *Lake) String() string

type Lake_Metastore 

type Lake_Metastore struct {

	// Optional. A relative reference to the Dataproc Metastore
	// (https://cloud.google.com/dataproc-metastore/docs) service associated
	// with the lake:
	// `projects/{project_id}/locations/{location_id}/services/{service_id}`
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

Settings to manage association of Dataproc Metastore with a lake.

func (*Lake_Metastore) Descriptor deprecated 

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

Deprecated: Use Lake_Metastore.ProtoReflect.Descriptor instead.

func (*Lake_Metastore) GetService 

func (x *Lake_Metastore) GetService() string

func (*Lake_Metastore) ProtoMessage 

func (*Lake_Metastore) ProtoMessage()

func (*Lake_Metastore) ProtoReflect 

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

func (*Lake_Metastore) Reset 

func (x *Lake_Metastore) Reset()

func (*Lake_Metastore) String 

func (x *Lake_Metastore) String() string

type Lake_MetastoreStatus 

type Lake_MetastoreStatus struct {

	// Current state of association.
	State Lake_MetastoreStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.dataplex.v1.Lake_MetastoreStatus_State" json:"state,omitempty"`
	// Additional information about the current status.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Last update time of the metastore status of the lake.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// The URI of the endpoint used to access the Metastore service.
	Endpoint string `protobuf:"bytes,4,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

Status of Lake and Dataproc Metastore service instance association.

func (*Lake_MetastoreStatus) Descriptor deprecated 

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

Deprecated: Use Lake_MetastoreStatus.ProtoReflect.Descriptor instead.

func (*Lake_MetastoreStatus) GetEndpoint 

func (x *Lake_MetastoreStatus) GetEndpoint() string

func (*Lake_MetastoreStatus) GetMessage 

func (x *Lake_MetastoreStatus) GetMessage() string

func (*Lake_MetastoreStatus) GetState 

func (x *Lake_MetastoreStatus) GetState() Lake_MetastoreStatus_State

func (*Lake_MetastoreStatus) GetUpdateTime 

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

func (*Lake_MetastoreStatus) ProtoMessage 

func (*Lake_MetastoreStatus) ProtoMessage()

func (*Lake_MetastoreStatus) ProtoReflect 

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

func (*Lake_MetastoreStatus) Reset 

func (x *Lake_MetastoreStatus) Reset()

func (*Lake_MetastoreStatus) String 

func (x *Lake_MetastoreStatus) String() string

type Lake_MetastoreStatus_State 

type Lake_MetastoreStatus_State int32

Current state of association. 

const (
	// Unspecified.
	Lake_MetastoreStatus_STATE_UNSPECIFIED Lake_MetastoreStatus_State = 0
	// A Metastore service instance is not associated with the lake.
	Lake_MetastoreStatus_NONE Lake_MetastoreStatus_State = 1
	// A Metastore service instance is attached to the lake.
	Lake_MetastoreStatus_READY Lake_MetastoreStatus_State = 2
	// Attach/detach is in progress.
	Lake_MetastoreStatus_UPDATING Lake_MetastoreStatus_State = 3
	// Attach/detach could not be done due to errors.
	Lake_MetastoreStatus_ERROR Lake_MetastoreStatus_State = 4
)

func (Lake_MetastoreStatus_State) Descriptor 

func (Lake_MetastoreStatus_State) Descriptor() protoreflect.EnumDescriptor

func (Lake_MetastoreStatus_State) Enum 

func (x Lake_MetastoreStatus_State) Enum() *Lake_MetastoreStatus_State

func (Lake_MetastoreStatus_State) EnumDescriptor deprecated 

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

Deprecated: Use Lake_MetastoreStatus_State.Descriptor instead.

func (Lake_MetastoreStatus_State) Number 

func (x Lake_MetastoreStatus_State) Number() protoreflect.EnumNumber

func (Lake_MetastoreStatus_State) String 

func (x Lake_MetastoreStatus_State) String() string

func (Lake_MetastoreStatus_State) Type 

func (Lake_MetastoreStatus_State) Type() protoreflect.EnumType

type ListActionsResponse 

type ListActionsResponse struct {

	// Actions under the given parent lake/zone/asset.
	Actions []*Action `protobuf:"bytes,1,rep,name=actions,proto3" json:"actions,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
}

List actions response.

func (*ListActionsResponse) Descriptor deprecated 

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

Deprecated: Use ListActionsResponse.ProtoReflect.Descriptor instead.

func (*ListActionsResponse) GetActions 

func (x *ListActionsResponse) GetActions() []*Action

func (*ListActionsResponse) GetNextPageToken 

func (x *ListActionsResponse) GetNextPageToken() string

func (*ListActionsResponse) ProtoMessage 

func (*ListActionsResponse) ProtoMessage()

func (*ListActionsResponse) ProtoReflect 

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

func (*ListActionsResponse) Reset 

func (x *ListActionsResponse) Reset()

func (*ListActionsResponse) String 

func (x *ListActionsResponse) String() string

type ListAssetActionsRequest 

type ListAssetActionsRequest struct {

	// Required. The resource name of the parent asset:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/assets/{asset_id}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. Maximum number of actions to return. The service may return fewer than this
	// value. If unspecified, at most 10 actions will be returned. The maximum
	// value is 1000; values above 1000 will be coerced to 1000.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. Page token received from a previous `ListAssetActions` call. Provide this
	// to retrieve the subsequent page. When paginating, all other parameters
	// provided to `ListAssetActions` must match the call that provided the page
	// token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

List asset actions request.

func (*ListAssetActionsRequest) Descriptor deprecated 

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

Deprecated: Use ListAssetActionsRequest.ProtoReflect.Descriptor instead.

func (*ListAssetActionsRequest) GetPageSize 

func (x *ListAssetActionsRequest) GetPageSize() int32

func (*ListAssetActionsRequest) GetPageToken 

func (x *ListAssetActionsRequest) GetPageToken() string

func (*ListAssetActionsRequest) GetParent 

func (x *ListAssetActionsRequest) GetParent() string

func (*ListAssetActionsRequest) ProtoMessage 

func (*ListAssetActionsRequest) ProtoMessage()

func (*ListAssetActionsRequest) ProtoReflect 

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

func (*ListAssetActionsRequest) Reset 

func (x *ListAssetActionsRequest) Reset()

func (*ListAssetActionsRequest) String 

func (x *ListAssetActionsRequest) String() string

type ListAssetsRequest 

type ListAssetsRequest struct {

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

List assets request.

func (*ListAssetsRequest) Descriptor deprecated 

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

Deprecated: Use ListAssetsRequest.ProtoReflect.Descriptor instead.

func (*ListAssetsRequest) GetFilter 

func (x *ListAssetsRequest) GetFilter() string

func (*ListAssetsRequest) GetOrderBy 

func (x *ListAssetsRequest) GetOrderBy() string

func (*ListAssetsRequest) GetPageSize 

func (x *ListAssetsRequest) GetPageSize() int32

func (*ListAssetsRequest) GetPageToken 

func (x *ListAssetsRequest) GetPageToken() string

func (*ListAssetsRequest) GetParent 

func (x *ListAssetsRequest) GetParent() string

func (*ListAssetsRequest) ProtoMessage 

func (*ListAssetsRequest) ProtoMessage()

func (*ListAssetsRequest) ProtoReflect 

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

func (*ListAssetsRequest) Reset 

func (x *ListAssetsRequest) Reset()

func (*ListAssetsRequest) String 

func (x *ListAssetsRequest) String() string

type ListAssetsResponse 

type ListAssetsResponse struct {

	// Asset under the given parent zone.
	Assets []*Asset `protobuf:"bytes,1,rep,name=assets,proto3" json:"assets,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
}

List assets response.

func (*ListAssetsResponse) Descriptor deprecated 

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

Deprecated: Use ListAssetsResponse.ProtoReflect.Descriptor instead.

func (*ListAssetsResponse) GetAssets 

func (x *ListAssetsResponse) GetAssets() []*Asset

func (*ListAssetsResponse) GetNextPageToken 

func (x *ListAssetsResponse) GetNextPageToken() string

func (*ListAssetsResponse) ProtoMessage 

func (*ListAssetsResponse) ProtoMessage()

func (*ListAssetsResponse) ProtoReflect 

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

func (*ListAssetsResponse) Reset 

func (x *ListAssetsResponse) Reset()

func (*ListAssetsResponse) String 

func (x *ListAssetsResponse) String() string

type ListEntitiesRequest 

type ListEntitiesRequest struct {

	// Required. The resource name of the parent zone:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Specify the entity view to make a partial list request.
	View ListEntitiesRequest_EntityView `protobuf:"varint,2,opt,name=view,proto3,enum=google.cloud.dataplex.v1.ListEntitiesRequest_EntityView" json:"view,omitempty"`
	// Optional. Maximum number of entities to return. The service may return fewer than
	// this value. If unspecified, at most 10 entities will be returned. The
	// maximum value is 1000; values above 1000 are set to 1000.
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. Page token received from a previous `ListEntities` call. Provide
	// this to retrieve the subsequent page. When paginating, all other parameters
	// provided to `ListEntities` must match the call that provided the
	// page token.
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Optional. Filter request by name prefix.
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

List metadata entities request.

func (*ListEntitiesRequest) Descriptor deprecated 

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

Deprecated: Use ListEntitiesRequest.ProtoReflect.Descriptor instead.

func (*ListEntitiesRequest) GetFilter 

func (x *ListEntitiesRequest) GetFilter() string

func (*ListEntitiesRequest) GetPageSize 

func (x *ListEntitiesRequest) GetPageSize() int32

func (*ListEntitiesRequest) GetPageToken 

func (x *ListEntitiesRequest) GetPageToken() string

func (*ListEntitiesRequest) GetParent 

func (x *ListEntitiesRequest) GetParent() string

func (*ListEntitiesRequest) GetView 

func (x *ListEntitiesRequest) GetView() ListEntitiesRequest_EntityView

func (*ListEntitiesRequest) ProtoMessage 

func (*ListEntitiesRequest) ProtoMessage()

func (*ListEntitiesRequest) ProtoReflect 

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

func (*ListEntitiesRequest) Reset 

func (x *ListEntitiesRequest) Reset()

func (*ListEntitiesRequest) String 

func (x *ListEntitiesRequest) String() string

type ListEntitiesRequest_EntityView 

type ListEntitiesRequest_EntityView int32

Entity views. 

const (
	// The default unset value. The API will default to the FULL view.
	ListEntitiesRequest_ENTITY_VIEW_UNSPECIFIED ListEntitiesRequest_EntityView = 0
	// Only list table entities.
	ListEntitiesRequest_TABLES ListEntitiesRequest_EntityView = 1
	// Only list fileset entities.
	ListEntitiesRequest_FILESETS ListEntitiesRequest_EntityView = 2
)

func (ListEntitiesRequest_EntityView) Descriptor 

func (ListEntitiesRequest_EntityView) Descriptor() protoreflect.EnumDescriptor

func (ListEntitiesRequest_EntityView) Enum 

func (x ListEntitiesRequest_EntityView) Enum() *ListEntitiesRequest_EntityView

func (ListEntitiesRequest_EntityView) EnumDescriptor deprecated 

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

Deprecated: Use ListEntitiesRequest_EntityView.Descriptor instead.

func (ListEntitiesRequest_EntityView) Number 

func (x ListEntitiesRequest_EntityView) Number() protoreflect.EnumNumber

func (ListEntitiesRequest_EntityView) String 

func (x ListEntitiesRequest_EntityView) String() string

func (ListEntitiesRequest_EntityView) Type 

func (ListEntitiesRequest_EntityView) Type() protoreflect.EnumType

type ListEntitiesResponse 

type ListEntitiesResponse struct {

	// Entities in the specified parent zone.
	Entities []*Entity `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	// Token to retrieve the next page of results, or empty if there are no
	// remaining 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
}

List metadata entities response.

func (*ListEntitiesResponse) Descriptor deprecated 

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

Deprecated: Use ListEntitiesResponse.ProtoReflect.Descriptor instead.

func (*ListEntitiesResponse) GetEntities 

func (x *ListEntitiesResponse) GetEntities() []*Entity

func (*ListEntitiesResponse) GetNextPageToken 

func (x *ListEntitiesResponse) GetNextPageToken() string

func (*ListEntitiesResponse) ProtoMessage 

func (*ListEntitiesResponse) ProtoMessage()

func (*ListEntitiesResponse) ProtoReflect 

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

func (*ListEntitiesResponse) Reset 

func (x *ListEntitiesResponse) Reset()

func (*ListEntitiesResponse) String 

func (x *ListEntitiesResponse) String() string

type ListJobsRequest 

type ListJobsRequest struct {

	// Required. The resource name of the parent environment:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/tasks/{task_id}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. Maximum number of jobs to return. The service may return fewer than
	// this value. If unspecified, at most 10 jobs will be returned. The
	// maximum value is 1000; values above 1000 will be coerced to 1000.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. Page token received from a previous `ListJobs` call. Provide this to
	// retrieve the subsequent page. When paginating, all other parameters
	// provided to `ListJobs` must match the call that provided the page
	// token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

List jobs request.

func (*ListJobsRequest) Descriptor deprecated 

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

Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.

func (*ListJobsRequest) GetPageSize 

func (x *ListJobsRequest) GetPageSize() int32

func (*ListJobsRequest) GetPageToken 

func (x *ListJobsRequest) GetPageToken() string

func (*ListJobsRequest) GetParent 

func (x *ListJobsRequest) GetParent() string

func (*ListJobsRequest) ProtoMessage 

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) ProtoReflect 

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

func (*ListJobsRequest) Reset 

func (x *ListJobsRequest) Reset()

func (*ListJobsRequest) String 

func (x *ListJobsRequest) String() string

type ListJobsResponse 

type ListJobsResponse struct {

	// Jobs under a given task.
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,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
}

List jobs response.

func (*ListJobsResponse) Descriptor deprecated 

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

Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.

func (*ListJobsResponse) GetJobs 

func (x *ListJobsResponse) GetJobs() []*Job

func (*ListJobsResponse) GetNextPageToken 

func (x *ListJobsResponse) GetNextPageToken() string

func (*ListJobsResponse) ProtoMessage 

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) ProtoReflect 

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

func (*ListJobsResponse) Reset 

func (x *ListJobsResponse) Reset()

func (*ListJobsResponse) String 

func (x *ListJobsResponse) String() string

type ListLakeActionsRequest 

type ListLakeActionsRequest struct {

	// Required. The resource name of the parent lake:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. Maximum number of actions to return. The service may return fewer than this
	// value. If unspecified, at most 10 actions will be returned. The maximum
	// value is 1000; values above 1000 will be coerced to 1000.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. Page token received from a previous `ListLakeActions` call. Provide this to
	// retrieve the subsequent page. When paginating, all other parameters
	// provided to `ListLakeActions` must match the call that provided the page
	// token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

List lake actions request.

func (*ListLakeActionsRequest) Descriptor deprecated 

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

Deprecated: Use ListLakeActionsRequest.ProtoReflect.Descriptor instead.

func (*ListLakeActionsRequest) GetPageSize 

func (x *ListLakeActionsRequest) GetPageSize() int32

func (*ListLakeActionsRequest) GetPageToken 

func (x *ListLakeActionsRequest) GetPageToken() string

func (*ListLakeActionsRequest) GetParent 

func (x *ListLakeActionsRequest) GetParent() string

func (*ListLakeActionsRequest) ProtoMessage 

func (*ListLakeActionsRequest) ProtoMessage()

func (*ListLakeActionsRequest) ProtoReflect 

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

func (*ListLakeActionsRequest) Reset 

func (x *ListLakeActionsRequest) Reset()

func (*ListLakeActionsRequest) String 

func (x *ListLakeActionsRequest) String() string

type ListLakesRequest 

type ListLakesRequest struct {

	// Required. The resource name of the lake location, of the form:
	// `projects/{project_number}/locations/{location_id}`
	// where `location_id` refers to a GCP region.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. Maximum number of Lakes to return. The service may return fewer than this
	// value. If unspecified, at most 10 lakes will be returned. The maximum
	// value is 1000; values above 1000 will be coerced to 1000.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. Page token received from a previous `ListLakes` call. Provide this to
	// retrieve the subsequent page. When paginating, all other parameters
	// provided to `ListLakes` must match the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Optional. Filter request.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// Optional. Order by fields for the result.
	OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

List lakes request.

func (*ListLakesRequest) Descriptor deprecated 

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

Deprecated: Use ListLakesRequest.ProtoReflect.Descriptor instead.

func (*ListLakesRequest) GetFilter 

func (x *ListLakesRequest) GetFilter() string

func (*ListLakesRequest) GetOrderBy 

func (x *ListLakesRequest) GetOrderBy() string

func (*ListLakesRequest) GetPageSize 

func (x *ListLakesRequest) GetPageSize() int32

func (*ListLakesRequest) GetPageToken 

func (x *ListLakesRequest) GetPageToken() string

func (*ListLakesRequest) GetParent 

func (x *ListLakesRequest) GetParent() string

func (*ListLakesRequest) ProtoMessage 

func (*ListLakesRequest) ProtoMessage()

func (*ListLakesRequest) ProtoReflect 

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

func (*ListLakesRequest) Reset 

func (x *ListLakesRequest) Reset()

func (*ListLakesRequest) String 

func (x *ListLakesRequest) String() string

type ListLakesResponse 

type ListLakesResponse struct {

	// Lakes under the given parent location.
	Lakes []*Lake `protobuf:"bytes,1,rep,name=lakes,proto3" json:"lakes,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.
	UnreachableLocations []string `protobuf:"bytes,3,rep,name=unreachable_locations,json=unreachableLocations,proto3" json:"unreachable_locations,omitempty"`
	// contains filtered or unexported fields
}

List lakes response.

func (*ListLakesResponse) Descriptor deprecated 

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

Deprecated: Use ListLakesResponse.ProtoReflect.Descriptor instead.

func (*ListLakesResponse) GetLakes 

func (x *ListLakesResponse) GetLakes() []*Lake

func (*ListLakesResponse) GetNextPageToken 

func (x *ListLakesResponse) GetNextPageToken() string

func (*ListLakesResponse) GetUnreachableLocations 

func (x *ListLakesResponse) GetUnreachableLocations() []string

func (*ListLakesResponse) ProtoMessage 

func (*ListLakesResponse) ProtoMessage()

func (*ListLakesResponse) ProtoReflect 

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

func (*ListLakesResponse) Reset 

func (x *ListLakesResponse) Reset()

func (*ListLakesResponse) String 

func (x *ListLakesResponse) String() string

type ListPartitionsRequest 

type ListPartitionsRequest struct {

	// Required. The resource name of the parent entity:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/entities/{entity_id}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. Maximum number of partitions to return. The service may return fewer than
	// this value. If unspecified, at most 10 partitions will be returned. The
	// maximum value is 1000; values above 1000 will be coerced to 1000.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. Page token received from a previous `ListPartitions` call. Provide
	// this to retrieve the subsequent page. When paginating, all other parameters
	// provided to `ListPartitions` must match the call that provided the
	// page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Optional. Filter request.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

List metadata partitions request.

func (*ListPartitionsRequest) Descriptor deprecated 

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

Deprecated: Use ListPartitionsRequest.ProtoReflect.Descriptor instead.

func (*ListPartitionsRequest) GetFilter 

func (x *ListPartitionsRequest) GetFilter() string

func (*ListPartitionsRequest) GetPageSize 

func (x *ListPartitionsRequest) GetPageSize() int32

func (*ListPartitionsRequest) GetPageToken 

func (x *ListPartitionsRequest) GetPageToken() string

func (*ListPartitionsRequest) GetParent 

func (x *ListPartitionsRequest) GetParent() string

func (*ListPartitionsRequest) ProtoMessage 

func (*ListPartitionsRequest) ProtoMessage()

func (*ListPartitionsRequest) ProtoReflect 

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

func (*ListPartitionsRequest) Reset 

func (x *ListPartitionsRequest) Reset()

func (*ListPartitionsRequest) String 

func (x *ListPartitionsRequest) String() string

type ListPartitionsResponse 

type ListPartitionsResponse struct {

	// Partitions under the specified parent entity.
	Partitions []*Partition `protobuf:"bytes,1,rep,name=partitions,proto3" json:"partitions,omitempty"`
	// Token to retrieve the next page of results, or empty if there are no
	// remaining 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
}

List metadata partitions response.

func (*ListPartitionsResponse) Descriptor deprecated 

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

Deprecated: Use ListPartitionsResponse.ProtoReflect.Descriptor instead.

func (*ListPartitionsResponse) GetNextPageToken 

func (x *ListPartitionsResponse) GetNextPageToken() string

func (*ListPartitionsResponse) GetPartitions 

func (x *ListPartitionsResponse) GetPartitions() []*Partition

func (*ListPartitionsResponse) ProtoMessage 

func (*ListPartitionsResponse) ProtoMessage()

func (*ListPartitionsResponse) ProtoReflect 

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

func (*ListPartitionsResponse) Reset 

func (x *ListPartitionsResponse) Reset()

func (*ListPartitionsResponse) String 

func (x *ListPartitionsResponse) String() string

type ListTasksRequest 

type ListTasksRequest struct {

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

List tasks request.

func (*ListTasksRequest) Descriptor deprecated 

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

Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.

func (*ListTasksRequest) GetFilter 

func (x *ListTasksRequest) GetFilter() string

func (*ListTasksRequest) GetOrderBy 

func (x *ListTasksRequest) GetOrderBy() string

func (*ListTasksRequest) GetPageSize 

func (x *ListTasksRequest) GetPageSize() int32

func (*ListTasksRequest) GetPageToken 

func (x *ListTasksRequest) GetPageToken() string

func (*ListTasksRequest) GetParent 

func (x *ListTasksRequest) GetParent() string

func (*ListTasksRequest) ProtoMessage 

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) ProtoReflect 

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

func (*ListTasksRequest) Reset 

func (x *ListTasksRequest) Reset()

func (*ListTasksRequest) String 

func (x *ListTasksRequest) String() string

type ListTasksResponse 

type ListTasksResponse struct {

	// Tasks under the given parent lake.
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,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.
	UnreachableLocations []string `protobuf:"bytes,3,rep,name=unreachable_locations,json=unreachableLocations,proto3" json:"unreachable_locations,omitempty"`
	// contains filtered or unexported fields
}

List tasks response.

func (*ListTasksResponse) Descriptor deprecated 

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

Deprecated: Use ListTasksResponse.ProtoReflect.Descriptor instead.

func (*ListTasksResponse) GetNextPageToken 

func (x *ListTasksResponse) GetNextPageToken() string

func (*ListTasksResponse) GetTasks 

func (x *ListTasksResponse) GetTasks() []*Task

func (*ListTasksResponse) GetUnreachableLocations 

func (x *ListTasksResponse) GetUnreachableLocations() []string

func (*ListTasksResponse) ProtoMessage 

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) ProtoReflect 

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

func (*ListTasksResponse) Reset 

func (x *ListTasksResponse) Reset()

func (*ListTasksResponse) String 

func (x *ListTasksResponse) String() string

type ListZoneActionsRequest 

type ListZoneActionsRequest struct {

	// Required. The resource name of the parent zone:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. Maximum number of actions to return. The service may return fewer than this
	// value. If unspecified, at most 10 actions will be returned. The maximum
	// value is 1000; values above 1000 will be coerced to 1000.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. Page token received from a previous `ListZoneActions` call. Provide this to
	// retrieve the subsequent page. When paginating, all other parameters
	// provided to `ListZoneActions` must match the call that provided the page
	// token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

List zone actions request.

func (*ListZoneActionsRequest) Descriptor deprecated 

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

Deprecated: Use ListZoneActionsRequest.ProtoReflect.Descriptor instead.

func (*ListZoneActionsRequest) GetPageSize 

func (x *ListZoneActionsRequest) GetPageSize() int32

func (*ListZoneActionsRequest) GetPageToken 

func (x *ListZoneActionsRequest) GetPageToken() string

func (*ListZoneActionsRequest) GetParent 

func (x *ListZoneActionsRequest) GetParent() string

func (*ListZoneActionsRequest) ProtoMessage 

func (*ListZoneActionsRequest) ProtoMessage()

func (*ListZoneActionsRequest) ProtoReflect 

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

func (*ListZoneActionsRequest) Reset 

func (x *ListZoneActionsRequest) Reset()

func (*ListZoneActionsRequest) String 

func (x *ListZoneActionsRequest) String() string

type ListZonesRequest 

type ListZonesRequest struct {

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

List zones request.

func (*ListZonesRequest) Descriptor deprecated 

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

Deprecated: Use ListZonesRequest.ProtoReflect.Descriptor instead.

func (*ListZonesRequest) GetFilter 

func (x *ListZonesRequest) GetFilter() string

func (*ListZonesRequest) GetOrderBy 

func (x *ListZonesRequest) GetOrderBy() string

func (*ListZonesRequest) GetPageSize 

func (x *ListZonesRequest) GetPageSize() int32

func (*ListZonesRequest) GetPageToken 

func (x *ListZonesRequest) GetPageToken() string

func (*ListZonesRequest) GetParent 

func (x *ListZonesRequest) GetParent() string

func (*ListZonesRequest) ProtoMessage 

func (*ListZonesRequest) ProtoMessage()

func (*ListZonesRequest) ProtoReflect 

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

func (*ListZonesRequest) Reset 

func (x *ListZonesRequest) Reset()

func (*ListZonesRequest) String 

func (x *ListZonesRequest) String() string

type ListZonesResponse 

type ListZonesResponse struct {

	// Zones under the given parent lake.
	Zones []*Zone `protobuf:"bytes,1,rep,name=zones,proto3" json:"zones,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
}

List zones response.

func (*ListZonesResponse) Descriptor deprecated 

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

Deprecated: Use ListZonesResponse.ProtoReflect.Descriptor instead.

func (*ListZonesResponse) GetNextPageToken 

func (x *ListZonesResponse) GetNextPageToken() string

func (*ListZonesResponse) GetZones 

func (x *ListZonesResponse) GetZones() []*Zone

func (*ListZonesResponse) ProtoMessage 

func (*ListZonesResponse) ProtoMessage()

func (*ListZonesResponse) ProtoReflect 

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

func (*ListZonesResponse) Reset 

func (x *ListZonesResponse) Reset()

func (*ListZonesResponse) String 

func (x *ListZonesResponse) String() string

type MetadataServiceClient 

type MetadataServiceClient interface {
	// Get a metadata entity.
	GetEntity(ctx context.Context, in *GetEntityRequest, opts ...grpc.CallOption) (*Entity, error)
	// List metadata entities in a zone.
	ListEntities(ctx context.Context, in *ListEntitiesRequest, opts ...grpc.CallOption) (*ListEntitiesResponse, error)
	// Get a metadata partition of an entity.
	GetPartition(ctx context.Context, in *GetPartitionRequest, opts ...grpc.CallOption) (*Partition, error)
	// List metadata partitions of an entity.
	ListPartitions(ctx context.Context, in *ListPartitionsRequest, opts ...grpc.CallOption) (*ListPartitionsResponse, error)
}

MetadataServiceClient is the client API for MetadataService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMetadataServiceClient 

func NewMetadataServiceClient(cc grpc.ClientConnInterface) MetadataServiceClient

type MetadataServiceServer 

type MetadataServiceServer interface {
	// Get a metadata entity.
	GetEntity(context.Context, *GetEntityRequest) (*Entity, error)
	// List metadata entities in a zone.
	ListEntities(context.Context, *ListEntitiesRequest) (*ListEntitiesResponse, error)
	// Get a metadata partition of an entity.
	GetPartition(context.Context, *GetPartitionRequest) (*Partition, error)
	// List metadata partitions of an entity.
	ListPartitions(context.Context, *ListPartitionsRequest) (*ListPartitionsResponse, error)
}

MetadataServiceServer is the server API for MetadataService service.

type OperationMetadata 

type OperationMetadata struct {

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

Represents the metadata of a long-running operation.

func (*OperationMetadata) Descriptor deprecated 

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

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

func (*OperationMetadata) GetApiVersion 

func (x *OperationMetadata) GetApiVersion() string

func (*OperationMetadata) GetCreateTime 

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

func (*OperationMetadata) GetEndTime 

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

func (*OperationMetadata) GetRequestedCancellation 

func (x *OperationMetadata) GetRequestedCancellation() bool

func (*OperationMetadata) GetStatusMessage 

func (x *OperationMetadata) GetStatusMessage() string

func (*OperationMetadata) GetTarget 

func (x *OperationMetadata) GetTarget() string

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

type Partition 

type Partition struct {

	// Output only. The resource name of the partition, of the form:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/entities/{entity_id}/partitions/{partition_id}`.
	// {partition_id} is a generated unique ID.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. Immutable. The set of values representing the partition, which correspond to the
	// partition schema defined in the parent entity.
	Values []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// Required. Immutable. The location of the entity data within the partition, for example,
	// `gs://bucket/path/to/entity/key1=value1/key2=value2`.
	Location string `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"`
	// Optional. The etag for this partition.
	// Required for update requests. It must match the server's etag.
	Etag string `protobuf:"bytes,4,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

Represents partition metadata contained within entity instances.

func (*Partition) Descriptor deprecated 

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

Deprecated: Use Partition.ProtoReflect.Descriptor instead.

func (*Partition) GetEtag 

func (x *Partition) GetEtag() string

func (*Partition) GetLocation 

func (x *Partition) GetLocation() string

func (*Partition) GetName 

func (x *Partition) GetName() string

func (*Partition) GetValues 

func (x *Partition) GetValues() []string

func (*Partition) ProtoMessage 

func (*Partition) ProtoMessage()

func (*Partition) ProtoReflect 

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

func (*Partition) Reset 

func (x *Partition) Reset()

func (*Partition) String 

func (x *Partition) String() string

type Schema 

type Schema struct {

	// Required. Whether the schema is user-managed or managed by the service. User-managed
	// schemas are not automatically updated by discovery jobs.
	UserManaged bool `protobuf:"varint,1,opt,name=user_managed,json=userManaged,proto3" json:"user_managed,omitempty"`
	// Optional. The sequence of fields describing data in table entities.
	Fields []*Schema_SchemaField `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	// Optional. The sequence of fields describing the partition structure in entities.
	// If this field is empty, there are no partitions within the data.
	PartitionFields []*Schema_PartitionField `protobuf:"bytes,3,rep,name=partition_fields,json=partitionFields,proto3" json:"partition_fields,omitempty"`
	// Optional. The structure of paths containing partition data within the entity.
	PartitionStyle Schema_PartitionStyle `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

Schema information describing the structure and layout of the data.

func (*Schema) Descriptor deprecated 

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetFields 

func (x *Schema) GetFields() []*Schema_SchemaField

func (*Schema) GetPartitionFields 

func (x *Schema) GetPartitionFields() []*Schema_PartitionField

func (*Schema) GetPartitionStyle 

func (x *Schema) GetPartitionStyle() Schema_PartitionStyle

func (*Schema) GetUserManaged 

func (x *Schema) GetUserManaged() bool

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect 

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

func (*Schema) Reset 

func (x *Schema) Reset()

func (*Schema) String 

func (x *Schema) String() string

type Schema_Mode 

type Schema_Mode int32

Additional qualifiers to define field semantics. 

const (
	// Mode unspecified.
	Schema_MODE_UNSPECIFIED Schema_Mode = 0
	// The field has required semantics.
	Schema_REQUIRED Schema_Mode = 1
	// The field has optional semantics, and may be null.
	Schema_NULLABLE Schema_Mode = 2
	// The field has repeated (0 or more) semantics, and is a list of values.
	Schema_REPEATED Schema_Mode = 3
)

func (Schema_Mode) Descriptor 

func (Schema_Mode) Descriptor() protoreflect.EnumDescriptor

func (Schema_Mode) Enum 

func (x Schema_Mode) Enum() *Schema_Mode

func (Schema_Mode) EnumDescriptor deprecated 

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

Deprecated: Use Schema_Mode.Descriptor instead.

func (Schema_Mode) Number 

func (x Schema_Mode) Number() protoreflect.EnumNumber

func (Schema_Mode) String 

func (x Schema_Mode) String() string

func (Schema_Mode) Type 

func (Schema_Mode) Type() protoreflect.EnumType

type Schema_PartitionField 

type Schema_PartitionField struct {

	// Required. The name of the field.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The type of field.
	Type Schema_Type `protobuf:"varint,2,opt,name=type,proto3,enum=google.cloud.dataplex.v1.Schema_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

Represents a key field within the entity's partition structure.

func (*Schema_PartitionField) Descriptor deprecated 

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

Deprecated: Use Schema_PartitionField.ProtoReflect.Descriptor instead.

func (*Schema_PartitionField) GetName 

func (x *Schema_PartitionField) GetName() string

func (*Schema_PartitionField) GetType 

func (x *Schema_PartitionField) GetType() Schema_Type

func (*Schema_PartitionField) ProtoMessage 

func (*Schema_PartitionField) ProtoMessage()

func (*Schema_PartitionField) ProtoReflect 

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

func (*Schema_PartitionField) Reset 

func (x *Schema_PartitionField) Reset()

func (*Schema_PartitionField) String 

func (x *Schema_PartitionField) String() string

type Schema_PartitionStyle 

type Schema_PartitionStyle int32

The structure of paths within the entity, which represent partitions. 

const (
	// PartitionStyle unspecified
	Schema_PARTITION_STYLE_UNSPECIFIED Schema_PartitionStyle = 0
	// Partitions are hive-compatible.
	// Examples: `gs://bucket/path/to/table/dt=2019-10-31/lang=en`,
	// `gs://bucket/path/to/table/dt=2019-10-31/lang=en/late`.
	Schema_HIVE_COMPATIBLE Schema_PartitionStyle = 1
)

func (Schema_PartitionStyle) Descriptor 

func (Schema_PartitionStyle) Descriptor() protoreflect.EnumDescriptor

func (Schema_PartitionStyle) Enum 

func (x Schema_PartitionStyle) Enum() *Schema_PartitionStyle

func (Schema_PartitionStyle) EnumDescriptor deprecated 

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

Deprecated: Use Schema_PartitionStyle.Descriptor instead.

func (Schema_PartitionStyle) Number 

func (x Schema_PartitionStyle) Number() protoreflect.EnumNumber

func (Schema_PartitionStyle) String 

func (x Schema_PartitionStyle) String() string

func (Schema_PartitionStyle) Type 

func (Schema_PartitionStyle) Type() protoreflect.EnumType

type Schema_SchemaField 

type Schema_SchemaField struct {

	// Required. The name of the field.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. User friendly field description.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Required. The type of field.
	Type Schema_Type `protobuf:"varint,3,opt,name=type,proto3,enum=google.cloud.dataplex.v1.Schema_Type" json:"type,omitempty"`
	// Required. Additional field semantics.
	Mode Schema_Mode `protobuf:"varint,4,opt,name=mode,proto3,enum=google.cloud.dataplex.v1.Schema_Mode" json:"mode,omitempty"`
	// Optional. Any nested field for complex types.
	Fields []*Schema_SchemaField `protobuf:"bytes,10,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

Represents a column field within a table schema.

func (*Schema_SchemaField) Descriptor deprecated 

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

Deprecated: Use Schema_SchemaField.ProtoReflect.Descriptor instead.

func (*Schema_SchemaField) GetDescription 

func (x *Schema_SchemaField) GetDescription() string

func (*Schema_SchemaField) GetFields 

func (x *Schema_SchemaField) GetFields() []*Schema_SchemaField

func (*Schema_SchemaField) GetMode 

func (x *Schema_SchemaField) GetMode() Schema_Mode

func (*Schema_SchemaField) GetName 

func (x *Schema_SchemaField) GetName() string

func (*Schema_SchemaField) GetType 

func (x *Schema_SchemaField) GetType() Schema_Type

func (*Schema_SchemaField) ProtoMessage 

func (*Schema_SchemaField) ProtoMessage()

func (*Schema_SchemaField) ProtoReflect 

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

func (*Schema_SchemaField) Reset 

func (x *Schema_SchemaField) Reset()

func (*Schema_SchemaField) String 

func (x *Schema_SchemaField) String() string

type Schema_Type 

type Schema_Type int32

Type information for fields in schemas and partition schemas. 

const (
	// SchemaType unspecified.
	Schema_TYPE_UNSPECIFIED Schema_Type = 0
	// Boolean field.
	Schema_BOOLEAN Schema_Type = 1
	// Single byte numeric field.
	Schema_BYTE Schema_Type = 2
	// 16-bit numeric field.
	Schema_INT16 Schema_Type = 3
	// 32-bit numeric field.
	Schema_INT32 Schema_Type = 4
	// 64-bit numeric field.
	Schema_INT64 Schema_Type = 5
	// Floating point numeric field.
	Schema_FLOAT Schema_Type = 6
	// Double precision numeric field.
	Schema_DOUBLE Schema_Type = 7
	// Real value numeric field.
	Schema_DECIMAL Schema_Type = 8
	// Sequence of characters field.
	Schema_STRING Schema_Type = 9
	// Sequence of bytes field.
	Schema_BINARY Schema_Type = 10
	// Date and time field.
	Schema_TIMESTAMP Schema_Type = 11
	// Date field.
	Schema_DATE Schema_Type = 12
	// Time field.
	Schema_TIME Schema_Type = 13
	// Structured field. Nested fields that define the structure of the map.
	// If all nested fields are nullable, this field represents a union.
	Schema_RECORD Schema_Type = 14
	// Null field that does not have values.
	Schema_NULL Schema_Type = 100
)

func (Schema_Type) Descriptor 

func (Schema_Type) Descriptor() protoreflect.EnumDescriptor

func (Schema_Type) Enum 

func (x Schema_Type) Enum() *Schema_Type

func (Schema_Type) EnumDescriptor deprecated 

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

Deprecated: Use Schema_Type.Descriptor instead.

func (Schema_Type) Number 

func (x Schema_Type) Number() protoreflect.EnumNumber

func (Schema_Type) String 

func (x Schema_Type) String() string

func (Schema_Type) Type 

func (Schema_Type) Type() protoreflect.EnumType

type SessionEvent 

type SessionEvent struct {

	// The log message.
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// The information about the user that created the session.
	UserId string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// Unique identifier for the session.
	SessionId string `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// The type of the event.
	Type SessionEvent_EventType `protobuf:"varint,4,opt,name=type,proto3,enum=google.cloud.dataplex.v1.SessionEvent_EventType" json:"type,omitempty"`
	// Additional information about the Query metadata.
	//
	// Types that are assignable to Detail:
	//	*SessionEvent_Query
	Detail isSessionEvent_Detail `protobuf_oneof:"detail"`
	// contains filtered or unexported fields
}

These messages contain information about sessions within an environment. The monitored resource is 'Environment'.

func (*SessionEvent) Descriptor deprecated 

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

Deprecated: Use SessionEvent.ProtoReflect.Descriptor instead.

func (*SessionEvent) GetDetail 

func (m *SessionEvent) GetDetail() isSessionEvent_Detail

func (*SessionEvent) GetMessage 

func (x *SessionEvent) GetMessage() string

func (*SessionEvent) GetQuery 

func (x *SessionEvent) GetQuery() *SessionEvent_QueryDetail

func (*SessionEvent) GetSessionId 

func (x *SessionEvent) GetSessionId() string

func (*SessionEvent) GetType 

func (x *SessionEvent) GetType() SessionEvent_EventType

func (*SessionEvent) GetUserId 

func (x *SessionEvent) GetUserId() string

func (*SessionEvent) ProtoMessage 

func (*SessionEvent) ProtoMessage()

func (*SessionEvent) ProtoReflect 

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

func (*SessionEvent) Reset 

func (x *SessionEvent) Reset()

func (*SessionEvent) String 

func (x *SessionEvent) String() string

type SessionEvent_EventType 

type SessionEvent_EventType int32

The type of the event. 

const (
	// An unspecified event type.
	SessionEvent_EVENT_TYPE_UNSPECIFIED SessionEvent_EventType = 0
	// Event for start of a session.
	SessionEvent_START SessionEvent_EventType = 1
	// Event for stop of a session.
	SessionEvent_STOP SessionEvent_EventType = 2
	// Query events in the session.
	SessionEvent_QUERY SessionEvent_EventType = 3
)

func (SessionEvent_EventType) Descriptor 

func (SessionEvent_EventType) Descriptor() protoreflect.EnumDescriptor

func (SessionEvent_EventType) Enum 

func (x SessionEvent_EventType) Enum() *SessionEvent_EventType

func (SessionEvent_EventType) EnumDescriptor deprecated 

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

Deprecated: Use SessionEvent_EventType.Descriptor instead.

func (SessionEvent_EventType) Number 

func (x SessionEvent_EventType) Number() protoreflect.EnumNumber

func (SessionEvent_EventType) String 

func (x SessionEvent_EventType) String() string

func (SessionEvent_EventType) Type 

func (SessionEvent_EventType) Type() protoreflect.EnumType

type SessionEvent_Query 

type SessionEvent_Query struct {
	// The execution details of the query.
	Query *SessionEvent_QueryDetail `protobuf:"bytes,5,opt,name=query,proto3,oneof"`
}

type SessionEvent_QueryDetail 

type SessionEvent_QueryDetail struct {

	// The unique Query id identifying the query.
	QueryId string `protobuf:"bytes,1,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	// The query text executed.
	QueryText string `protobuf:"bytes,2,opt,name=query_text,json=queryText,proto3" json:"query_text,omitempty"`
	// Query Execution engine.
	Engine SessionEvent_QueryDetail_Engine `` /* 128-byte string literal not displayed */
	// Time taken for execution of the query.
	Duration *durationpb.Duration `protobuf:"bytes,4,opt,name=duration,proto3" json:"duration,omitempty"`
	// The size of results the query produced.
	ResultSizeBytes int64 `protobuf:"varint,5,opt,name=result_size_bytes,json=resultSizeBytes,proto3" json:"result_size_bytes,omitempty"`
	// The data processed by the query.
	DataProcessedBytes int64 `protobuf:"varint,6,opt,name=data_processed_bytes,json=dataProcessedBytes,proto3" json:"data_processed_bytes,omitempty"`
	// contains filtered or unexported fields
}

Execution details of the query.

func (*SessionEvent_QueryDetail) Descriptor deprecated 

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

Deprecated: Use SessionEvent_QueryDetail.ProtoReflect.Descriptor instead.

func (*SessionEvent_QueryDetail) GetDataProcessedBytes 

func (x *SessionEvent_QueryDetail) GetDataProcessedBytes() int64

func (*SessionEvent_QueryDetail) GetDuration 

func (x *SessionEvent_QueryDetail) GetDuration() *durationpb.Duration

func (*SessionEvent_QueryDetail) GetEngine 

func (x *SessionEvent_QueryDetail) GetEngine() SessionEvent_QueryDetail_Engine

func (*SessionEvent_QueryDetail) GetQueryId 

func (x *SessionEvent_QueryDetail) GetQueryId() string

func (*SessionEvent_QueryDetail) GetQueryText 

func (x *SessionEvent_QueryDetail) GetQueryText() string

func (*SessionEvent_QueryDetail) GetResultSizeBytes 

func (x *SessionEvent_QueryDetail) GetResultSizeBytes() int64

func (*SessionEvent_QueryDetail) ProtoMessage 

func (*SessionEvent_QueryDetail) ProtoMessage()

func (*SessionEvent_QueryDetail) ProtoReflect 

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

func (*SessionEvent_QueryDetail) Reset 

func (x *SessionEvent_QueryDetail) Reset()

func (*SessionEvent_QueryDetail) String 

func (x *SessionEvent_QueryDetail) String() string

type SessionEvent_QueryDetail_Engine 

type SessionEvent_QueryDetail_Engine int32

Query Execution engine. 

const (
	// An unspecified Engine type.
	SessionEvent_QueryDetail_ENGINE_UNSPECIFIED SessionEvent_QueryDetail_Engine = 0
	// Spark-sql engine is specified in Query.
	SessionEvent_QueryDetail_SPARK_SQL SessionEvent_QueryDetail_Engine = 1
	// BigQuery engine is specified in Query.
	SessionEvent_QueryDetail_BIGQUERY SessionEvent_QueryDetail_Engine = 2
)

func (SessionEvent_QueryDetail_Engine) Descriptor 

func (SessionEvent_QueryDetail_Engine) Descriptor() protoreflect.EnumDescriptor

func (SessionEvent_QueryDetail_Engine) Enum 

func (x SessionEvent_QueryDetail_Engine) Enum() *SessionEvent_QueryDetail_Engine

func (SessionEvent_QueryDetail_Engine) EnumDescriptor deprecated 

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

Deprecated: Use SessionEvent_QueryDetail_Engine.Descriptor instead.

func (SessionEvent_QueryDetail_Engine) Number 

func (x SessionEvent_QueryDetail_Engine) Number() protoreflect.EnumNumber

func (SessionEvent_QueryDetail_Engine) String 

func (x SessionEvent_QueryDetail_Engine) String() string

func (SessionEvent_QueryDetail_Engine) Type 

func (SessionEvent_QueryDetail_Engine) Type() protoreflect.EnumType

type State 

type State int32

State of a resource. 

const (
	// State is not specified.
	State_STATE_UNSPECIFIED State = 0
	// Resource is active, i.e., ready to use.
	State_ACTIVE State = 1
	// Resource is under creation.
	State_CREATING State = 2
	// Resource is under deletion.
	State_DELETING State = 3
	// Resource is active but has unresolved actions.
	State_ACTION_REQUIRED State = 4
)

func (State) Descriptor 

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum 

func (x State) Enum() *State

func (State) EnumDescriptor deprecated 

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

Deprecated: Use State.Descriptor instead.

func (State) Number 

func (x State) Number() protoreflect.EnumNumber

func (State) String 

func (x State) String() string

func (State) Type 

func (State) Type() protoreflect.EnumType

type StorageFormat 

type StorageFormat struct {

	// Output only. The data format associated with the stored data, which represents
	// content type values.
	Format StorageFormat_Format `protobuf:"varint,1,opt,name=format,proto3,enum=google.cloud.dataplex.v1.StorageFormat_Format" json:"format,omitempty"`
	// Optional. The compression type associated with the stored data.
	// If unspecified, the data is uncompressed.
	CompressionFormat StorageFormat_CompressionFormat `` /* 175-byte string literal not displayed */
	// Required. The mime type descriptor for the data. This field is valid for formats
	// other than `UNKNOWN` and `MIXED`.
	MimeType string `protobuf:"bytes,3,opt,name=mime_type,json=mimeType,proto3" json:"mime_type,omitempty"`
	// Additional format-specific options.
	//
	// Types that are assignable to Options:
	//	*StorageFormat_Csv
	//	*StorageFormat_Json
	Options isStorageFormat_Options `protobuf_oneof:"options"`
	// contains filtered or unexported fields
}

Describes the format of the data within its storage location.

func (*StorageFormat) Descriptor deprecated 

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

Deprecated: Use StorageFormat.ProtoReflect.Descriptor instead.

func (*StorageFormat) GetCompressionFormat 

func (x *StorageFormat) GetCompressionFormat() StorageFormat_CompressionFormat

func (*StorageFormat) GetCsv 

func (x *StorageFormat) GetCsv() *StorageFormat_CsvOptions

func (*StorageFormat) GetFormat 

func (x *StorageFormat) GetFormat() StorageFormat_Format

func (*StorageFormat) GetJson 

func (x *StorageFormat) GetJson() *StorageFormat_JsonOptions

func (*StorageFormat) GetMimeType 

func (x *StorageFormat) GetMimeType() string

func (*StorageFormat) GetOptions 

func (m *StorageFormat) GetOptions() isStorageFormat_Options

func (*StorageFormat) ProtoMessage 

func (*StorageFormat) ProtoMessage()

func (*StorageFormat) ProtoReflect 

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

func (*StorageFormat) Reset 

func (x *StorageFormat) Reset()

func (*StorageFormat) String 

func (x *StorageFormat) String() string

type StorageFormat_CompressionFormat 

type StorageFormat_CompressionFormat int32

The specific compressed file format of the data. 

const (
	// CompressionFormat unspecified. Implies uncompressed data.
	StorageFormat_COMPRESSION_FORMAT_UNSPECIFIED StorageFormat_CompressionFormat = 0
	// GZip compressed set of files.
	StorageFormat_GZIP StorageFormat_CompressionFormat = 2
	// BZip2 compressed set of files.
	StorageFormat_BZIP2 StorageFormat_CompressionFormat = 3
)

func (StorageFormat_CompressionFormat) Descriptor 

func (StorageFormat_CompressionFormat) Descriptor() protoreflect.EnumDescriptor

func (StorageFormat_CompressionFormat) Enum 

func (x StorageFormat_CompressionFormat) Enum() *StorageFormat_CompressionFormat

func (StorageFormat_CompressionFormat) EnumDescriptor deprecated 

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

Deprecated: Use StorageFormat_CompressionFormat.Descriptor instead.

func (StorageFormat_CompressionFormat) Number 

func (x StorageFormat_CompressionFormat) Number() protoreflect.EnumNumber

func (StorageFormat_CompressionFormat) String 

func (x StorageFormat_CompressionFormat) String() string

func (StorageFormat_CompressionFormat) Type 

func (StorageFormat_CompressionFormat) Type() protoreflect.EnumType

type StorageFormat_Csv 

type StorageFormat_Csv struct {
	// Optional. Additional information about CSV formatted data.
	Csv *StorageFormat_CsvOptions `protobuf:"bytes,10,opt,name=csv,proto3,oneof"`
}

type StorageFormat_CsvOptions 

type StorageFormat_CsvOptions struct {

	// Optional. The character encoding of the data. The default is UTF-8.
	Encoding string `protobuf:"bytes,1,opt,name=encoding,proto3" json:"encoding,omitempty"`
	// Optional. The number of rows to interpret as header rows that should be skipped
	// when reading data rows.
	HeaderRows int32 `protobuf:"varint,2,opt,name=header_rows,json=headerRows,proto3" json:"header_rows,omitempty"`
	// Optional. The delimiter used to separate values. Defaults to ','.
	Delimiter string `protobuf:"bytes,3,opt,name=delimiter,proto3" json:"delimiter,omitempty"`
	// Optional. The character used to quote column values. Defaults to empty,
	// implying unquoted data.
	Quote string `protobuf:"bytes,4,opt,name=quote,proto3" json:"quote,omitempty"`
	// contains filtered or unexported fields
}

Describes CSV and similar semi-structured data formats.

func (*StorageFormat_CsvOptions) Descriptor deprecated 

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

Deprecated: Use StorageFormat_CsvOptions.ProtoReflect.Descriptor instead.

func (*StorageFormat_CsvOptions) GetDelimiter 

func (x *StorageFormat_CsvOptions) GetDelimiter() string

func (*StorageFormat_CsvOptions) GetEncoding 

func (x *StorageFormat_CsvOptions) GetEncoding() string

func (*StorageFormat_CsvOptions) GetHeaderRows 

func (x *StorageFormat_CsvOptions) GetHeaderRows() int32

func (*StorageFormat_CsvOptions) GetQuote 

func (x *StorageFormat_CsvOptions) GetQuote() string

func (*StorageFormat_CsvOptions) ProtoMessage 

func (*StorageFormat_CsvOptions) ProtoMessage()

func (*StorageFormat_CsvOptions) ProtoReflect 

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

func (*StorageFormat_CsvOptions) Reset 

func (x *StorageFormat_CsvOptions) Reset()

func (*StorageFormat_CsvOptions) String 

func (x *StorageFormat_CsvOptions) String() string

type StorageFormat_Format 

type StorageFormat_Format int32

The specific file format of the data. 

const (
	// Format unspecified.
	StorageFormat_FORMAT_UNSPECIFIED StorageFormat_Format = 0
	// Parquet-formatted structured data.
	StorageFormat_PARQUET StorageFormat_Format = 1
	// Avro-formatted structured data.
	StorageFormat_AVRO StorageFormat_Format = 2
	// Orc-formatted structured data.
	StorageFormat_ORC StorageFormat_Format = 3
	// Csv-formatted semi-structured data.
	StorageFormat_CSV StorageFormat_Format = 100
	// Json-formatted semi-structured data.
	StorageFormat_JSON StorageFormat_Format = 101
	// Image data formats (such as jpg and png).
	StorageFormat_IMAGE StorageFormat_Format = 200
	// Audio data formats (such as mp3 and wav).
	StorageFormat_AUDIO StorageFormat_Format = 201
	// Video data formats (such as mp4 and mpg).
	StorageFormat_VIDEO StorageFormat_Format = 202
	// Textual data formats (such as txt and xml).
	StorageFormat_TEXT StorageFormat_Format = 203
	// TensorFlow record format.
	StorageFormat_TFRECORD StorageFormat_Format = 204
	// Data that doesn't match a specific format.
	StorageFormat_OTHER StorageFormat_Format = 1000
	// Data of an unknown format.
	StorageFormat_UNKNOWN StorageFormat_Format = 1001
)

func (StorageFormat_Format) Descriptor 

func (StorageFormat_Format) Descriptor() protoreflect.EnumDescriptor

func (StorageFormat_Format) Enum 

func (x StorageFormat_Format) Enum() *StorageFormat_Format

func (StorageFormat_Format) EnumDescriptor deprecated 

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

Deprecated: Use StorageFormat_Format.Descriptor instead.

func (StorageFormat_Format) Number 

func (x StorageFormat_Format) Number() protoreflect.EnumNumber

func (StorageFormat_Format) String 

func (x StorageFormat_Format) String() string

func (StorageFormat_Format) Type 

func (StorageFormat_Format) Type() protoreflect.EnumType

type StorageFormat_Json 

type StorageFormat_Json struct {
	// Optional. Additional information about CSV formatted data.
	Json *StorageFormat_JsonOptions `protobuf:"bytes,11,opt,name=json,proto3,oneof"`
}

type StorageFormat_JsonOptions 

type StorageFormat_JsonOptions struct {

	// Optional. The character encoding of the data. The default is UTF-8.
	Encoding string `protobuf:"bytes,1,opt,name=encoding,proto3" json:"encoding,omitempty"`
	// contains filtered or unexported fields
}

Describes JSON data format.

func (*StorageFormat_JsonOptions) Descriptor deprecated 

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

Deprecated: Use StorageFormat_JsonOptions.ProtoReflect.Descriptor instead.

func (*StorageFormat_JsonOptions) GetEncoding 

func (x *StorageFormat_JsonOptions) GetEncoding() string

func (*StorageFormat_JsonOptions) ProtoMessage 

func (*StorageFormat_JsonOptions) ProtoMessage()

func (*StorageFormat_JsonOptions) ProtoReflect 

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

func (*StorageFormat_JsonOptions) Reset 

func (x *StorageFormat_JsonOptions) Reset()

func (*StorageFormat_JsonOptions) String 

func (x *StorageFormat_JsonOptions) String() string

type StorageSystem 

type StorageSystem int32

Identifies the cloud system that manages the data storage. 

const (
	// Storage system unspecified.
	StorageSystem_STORAGE_SYSTEM_UNSPECIFIED StorageSystem = 0
	// The entity data is contained within a Cloud Storage bucket.
	StorageSystem_CLOUD_STORAGE StorageSystem = 1
	// The entity data is contained within a BigQuery dataset.
	StorageSystem_BIGQUERY StorageSystem = 2
)

func (StorageSystem) Descriptor 

func (StorageSystem) Descriptor() protoreflect.EnumDescriptor

func (StorageSystem) Enum 

func (x StorageSystem) Enum() *StorageSystem

func (StorageSystem) EnumDescriptor deprecated 

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

Deprecated: Use StorageSystem.Descriptor instead.

func (StorageSystem) Number 

func (x StorageSystem) Number() protoreflect.EnumNumber

func (StorageSystem) String 

func (x StorageSystem) String() string

func (StorageSystem) Type 

func (StorageSystem) Type() protoreflect.EnumType

type Task 

type Task struct {

	// Output only. The relative resource name of the task, of the form:
	// projects/{project_number}/locations/{location_id}/lakes/{lake_id}/
	// tasks/{task_id}.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. System generated globally unique ID for the task. This ID will be
	// different if the task is deleted and re-created with the same name.
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// Output only. The time when the task was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time when the task was last updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Optional. Description of the task.
	Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// Optional. User friendly display name.
	DisplayName string `protobuf:"bytes,6,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Output only. Current state of the task.
	State State `protobuf:"varint,7,opt,name=state,proto3,enum=google.cloud.dataplex.v1.State" json:"state,omitempty"`
	// Optional. User-defined labels for the task.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Required. Spec related to how often and when a task should be triggered.
	TriggerSpec *Task_TriggerSpec `protobuf:"bytes,100,opt,name=trigger_spec,json=triggerSpec,proto3" json:"trigger_spec,omitempty"`
	// Required. Spec related to how a task is executed.
	ExecutionSpec *Task_ExecutionSpec `protobuf:"bytes,101,opt,name=execution_spec,json=executionSpec,proto3" json:"execution_spec,omitempty"`
	// Task template specific user-specified config.
	//
	// Types that are assignable to Config:
	//	*Task_Spark
	Config isTask_Config `protobuf_oneof:"config"`
	// contains filtered or unexported fields
}

A task represents a user-visible job.

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetConfig 

func (m *Task) GetConfig() isTask_Config

func (*Task) GetCreateTime 

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

func (*Task) GetDescription 

func (x *Task) GetDescription() string

func (*Task) GetDisplayName 

func (x *Task) GetDisplayName() string

func (*Task) GetExecutionSpec 

func (x *Task) GetExecutionSpec() *Task_ExecutionSpec

func (*Task) GetLabels 

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

func (*Task) GetName 

func (x *Task) GetName() string

func (*Task) GetSpark 

func (x *Task) GetSpark() *Task_SparkTaskConfig

func (*Task) GetState 

func (x *Task) GetState() State

func (*Task) GetTriggerSpec 

func (x *Task) GetTriggerSpec() *Task_TriggerSpec

func (*Task) GetUid 

func (x *Task) GetUid() string

func (*Task) GetUpdateTime 

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

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type Task_ExecutionSpec 

type Task_ExecutionSpec struct {

	// Optional. The arguments to pass to the task.
	// The args can use placeholders of the format ${placeholder} as
	// part of key/value string. These will be interpolated before passing the
	// args to the driver. Currently supported placeholders:
	// - ${task_id}
	// - ${job_time}
	// To pass positional args, set the key as TASK_ARGS. The value should be a
	// comma-separated string of all the positional arguments. To use a
	// delimiter other than comma, refer to
	// https://cloud.google.com/sdk/gcloud/reference/topic/escaping. In case of
	// other keys being present in the args, then TASK_ARGS will be passed as
	// the last argument.
	Args map[string]string `` /* 149-byte string literal not displayed */
	// Required. Service account to use to execute a task.
	// If not provided, the default Compute service account for the project is
	// used.
	ServiceAccount string `protobuf:"bytes,5,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// Optional. The maximum duration after which the job execution is expired.
	MaxJobExecutionLifetime *durationpb.Duration `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

Execution related settings, like retry and service_account.

func (*Task_ExecutionSpec) Descriptor deprecated 

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

Deprecated: Use Task_ExecutionSpec.ProtoReflect.Descriptor instead.

func (*Task_ExecutionSpec) GetArgs 

func (x *Task_ExecutionSpec) GetArgs() map[string]string

func (*Task_ExecutionSpec) GetMaxJobExecutionLifetime 

func (x *Task_ExecutionSpec) GetMaxJobExecutionLifetime() *durationpb.Duration

func (*Task_ExecutionSpec) GetServiceAccount 

func (x *Task_ExecutionSpec) GetServiceAccount() string

func (*Task_ExecutionSpec) ProtoMessage 

func (*Task_ExecutionSpec) ProtoMessage()

func (*Task_ExecutionSpec) ProtoReflect 

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

func (*Task_ExecutionSpec) Reset 

func (x *Task_ExecutionSpec) Reset()

func (*Task_ExecutionSpec) String 

func (x *Task_ExecutionSpec) String() string

type Task_InfrastructureSpec 

type Task_InfrastructureSpec struct {

	// Hardware config.
	//
	// Types that are assignable to Resources:
	//	*Task_InfrastructureSpec_Batch
	Resources isTask_InfrastructureSpec_Resources `protobuf_oneof:"resources"`
	// Software config.
	//
	// Types that are assignable to Runtime:
	//	*Task_InfrastructureSpec_ContainerImage
	Runtime isTask_InfrastructureSpec_Runtime `protobuf_oneof:"runtime"`
	// Networking config.
	//
	// Types that are assignable to Network:
	//	*Task_InfrastructureSpec_VpcNetwork_
	Network isTask_InfrastructureSpec_Network `protobuf_oneof:"network"`
	// contains filtered or unexported fields
}

Configuration for the underlying infrastructure used to run workloads.

func (*Task_InfrastructureSpec) Descriptor deprecated 

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

Deprecated: Use Task_InfrastructureSpec.ProtoReflect.Descriptor instead.

func (*Task_InfrastructureSpec) GetBatch 

func (x *Task_InfrastructureSpec) GetBatch() *Task_InfrastructureSpec_BatchComputeResources

func (*Task_InfrastructureSpec) GetContainerImage 

func (x *Task_InfrastructureSpec) GetContainerImage() *Task_InfrastructureSpec_ContainerImageRuntime

func (*Task_InfrastructureSpec) GetNetwork 

func (m *Task_InfrastructureSpec) GetNetwork() isTask_InfrastructureSpec_Network

func (*Task_InfrastructureSpec) GetResources 

func (m *Task_InfrastructureSpec) GetResources() isTask_InfrastructureSpec_Resources

func (*Task_InfrastructureSpec) GetRuntime 

func (m *Task_InfrastructureSpec) GetRuntime() isTask_InfrastructureSpec_Runtime

func (*Task_InfrastructureSpec) GetVpcNetwork 

func (x *Task_InfrastructureSpec) GetVpcNetwork() *Task_InfrastructureSpec_VpcNetwork

func (*Task_InfrastructureSpec) ProtoMessage 

func (*Task_InfrastructureSpec) ProtoMessage()

func (*Task_InfrastructureSpec) ProtoReflect 

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

func (*Task_InfrastructureSpec) Reset 

func (x *Task_InfrastructureSpec) Reset()

func (*Task_InfrastructureSpec) String 

func (x *Task_InfrastructureSpec) String() string

type Task_InfrastructureSpec_Batch 

type Task_InfrastructureSpec_Batch struct {
	// Compute resources needed for a Task when using Dataproc Serverless.
	Batch *Task_InfrastructureSpec_BatchComputeResources `protobuf:"bytes,52,opt,name=batch,proto3,oneof"`
}

type Task_InfrastructureSpec_BatchComputeResources 

type Task_InfrastructureSpec_BatchComputeResources struct {

	// Optional. Total number of job executors.
	ExecutorsCount int32 `protobuf:"varint,1,opt,name=executors_count,json=executorsCount,proto3" json:"executors_count,omitempty"`
	// Optional. Max configurable executors.
	// If max_executors_count > executors_count, then auto-scaling is enabled.
	MaxExecutorsCount int32 `protobuf:"varint,2,opt,name=max_executors_count,json=maxExecutorsCount,proto3" json:"max_executors_count,omitempty"`
	// contains filtered or unexported fields
}

Batch compute resources associated with the task.

func (*Task_InfrastructureSpec_BatchComputeResources) Descriptor deprecated 

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

Deprecated: Use Task_InfrastructureSpec_BatchComputeResources.ProtoReflect.Descriptor instead.

func (*Task_InfrastructureSpec_BatchComputeResources) GetExecutorsCount 

func (x *Task_InfrastructureSpec_BatchComputeResources) GetExecutorsCount() int32

func (*Task_InfrastructureSpec_BatchComputeResources) GetMaxExecutorsCount 

func (x *Task_InfrastructureSpec_BatchComputeResources) GetMaxExecutorsCount() int32

func (*Task_InfrastructureSpec_BatchComputeResources) ProtoMessage 

func (*Task_InfrastructureSpec_BatchComputeResources) ProtoMessage()

func (*Task_InfrastructureSpec_BatchComputeResources) ProtoReflect 

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

func (*Task_InfrastructureSpec_BatchComputeResources) Reset 

func (x *Task_InfrastructureSpec_BatchComputeResources) Reset()

func (*Task_InfrastructureSpec_BatchComputeResources) String 

func (x *Task_InfrastructureSpec_BatchComputeResources) String() string

type Task_InfrastructureSpec_ContainerImage 

type Task_InfrastructureSpec_ContainerImage struct {
	// Container Image Runtime Configuration.
	ContainerImage *Task_InfrastructureSpec_ContainerImageRuntime `protobuf:"bytes,101,opt,name=container_image,json=containerImage,proto3,oneof"`
}

type Task_InfrastructureSpec_ContainerImageRuntime 

type Task_InfrastructureSpec_ContainerImageRuntime struct {

	// Optional. A list of Java JARS to add to the classpath.
	// Valid input includes Cloud Storage URIs to Jar binaries.
	// For example, `gs://bucket-name/my/path/to/file.jar`.
	JavaJars []string `protobuf:"bytes,2,rep,name=java_jars,json=javaJars,proto3" json:"java_jars,omitempty"`
	// Optional. A list of python packages to be installed.
	// Valid formats include Cloud Storage URI to a PIP installable library.
	// For example, `gs://bucket-name/my/path/to/lib.tar.gz`.
	PythonPackages []string `protobuf:"bytes,3,rep,name=python_packages,json=pythonPackages,proto3" json:"python_packages,omitempty"`
	// Optional. Override to common configuration of open source components installed on
	// the Dataproc cluster.
	// The properties to set on daemon config files.
	// Property keys are specified in `prefix:property` format, for example
	// `core:hadoop.tmp.dir`.
	// For more information, see [Cluster
	// properties](https://cloud.google.com/dataproc/docs/concepts/cluster-properties).
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

Container Image Runtime Configuration used with Batch execution.

func (*Task_InfrastructureSpec_ContainerImageRuntime) Descriptor deprecated 

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

Deprecated: Use Task_InfrastructureSpec_ContainerImageRuntime.ProtoReflect.Descriptor instead.

func (*Task_InfrastructureSpec_ContainerImageRuntime) GetJavaJars 

func (x *Task_InfrastructureSpec_ContainerImageRuntime) GetJavaJars() []string

func (*Task_InfrastructureSpec_ContainerImageRuntime) GetProperties 

func (x *Task_InfrastructureSpec_ContainerImageRuntime) GetProperties() map[string]string

func (*Task_InfrastructureSpec_ContainerImageRuntime) GetPythonPackages 

func (x *Task_InfrastructureSpec_ContainerImageRuntime) GetPythonPackages() []string

func (*Task_InfrastructureSpec_ContainerImageRuntime) ProtoMessage 

func (*Task_InfrastructureSpec_ContainerImageRuntime) ProtoMessage()

func (*Task_InfrastructureSpec_ContainerImageRuntime) ProtoReflect 

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

func (*Task_InfrastructureSpec_ContainerImageRuntime) Reset 

func (x *Task_InfrastructureSpec_ContainerImageRuntime) Reset()

func (*Task_InfrastructureSpec_ContainerImageRuntime) String 

func (x *Task_InfrastructureSpec_ContainerImageRuntime) String() string

type Task_InfrastructureSpec_VpcNetwork 

type Task_InfrastructureSpec_VpcNetwork struct {

	// The Cloud VPC network identifier.
	//
	// Types that are assignable to NetworkName:
	//	*Task_InfrastructureSpec_VpcNetwork_Network
	//	*Task_InfrastructureSpec_VpcNetwork_SubNetwork
	NetworkName isTask_InfrastructureSpec_VpcNetwork_NetworkName `protobuf_oneof:"network_name"`
	// Optional. List of network tags to apply to the job.
	NetworkTags []string `protobuf:"bytes,3,rep,name=network_tags,json=networkTags,proto3" json:"network_tags,omitempty"`
	// contains filtered or unexported fields
}

Cloud VPC Network used to run the infrastructure.

func (*Task_InfrastructureSpec_VpcNetwork) Descriptor deprecated 

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

Deprecated: Use Task_InfrastructureSpec_VpcNetwork.ProtoReflect.Descriptor instead.

func (*Task_InfrastructureSpec_VpcNetwork) GetNetwork 

func (x *Task_InfrastructureSpec_VpcNetwork) GetNetwork() string

func (*Task_InfrastructureSpec_VpcNetwork) GetNetworkName 

func (m *Task_InfrastructureSpec_VpcNetwork) GetNetworkName() isTask_InfrastructureSpec_VpcNetwork_NetworkName

func (*Task_InfrastructureSpec_VpcNetwork) GetNetworkTags 

func (x *Task_InfrastructureSpec_VpcNetwork) GetNetworkTags() []string

func (*Task_InfrastructureSpec_VpcNetwork) GetSubNetwork 

func (x *Task_InfrastructureSpec_VpcNetwork) GetSubNetwork() string

func (*Task_InfrastructureSpec_VpcNetwork) ProtoMessage 

func (*Task_InfrastructureSpec_VpcNetwork) ProtoMessage()

func (*Task_InfrastructureSpec_VpcNetwork) ProtoReflect 

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

func (*Task_InfrastructureSpec_VpcNetwork) Reset 

func (x *Task_InfrastructureSpec_VpcNetwork) Reset()

func (*Task_InfrastructureSpec_VpcNetwork) String 

func (x *Task_InfrastructureSpec_VpcNetwork) String() string

type Task_InfrastructureSpec_VpcNetwork_ 

type Task_InfrastructureSpec_VpcNetwork_ struct {
	// Vpc network.
	VpcNetwork *Task_InfrastructureSpec_VpcNetwork `protobuf:"bytes,150,opt,name=vpc_network,json=vpcNetwork,proto3,oneof"`
}

type Task_InfrastructureSpec_VpcNetwork_Network 

type Task_InfrastructureSpec_VpcNetwork_Network struct {
	// Optional. The Cloud VPC network in which the job is run. By default, the Cloud
	// VPC network named Default within the project is used.
	Network string `protobuf:"bytes,1,opt,name=network,proto3,oneof"`
}

type Task_InfrastructureSpec_VpcNetwork_SubNetwork 

type Task_InfrastructureSpec_VpcNetwork_SubNetwork struct {
	// Optional. The Cloud VPC sub-network in which the job is run.
	SubNetwork string `protobuf:"bytes,2,opt,name=sub_network,json=subNetwork,proto3,oneof"`
}

type Task_Spark 

type Task_Spark struct {
	// Config related to running custom Spark tasks.
	Spark *Task_SparkTaskConfig `protobuf:"bytes,300,opt,name=spark,proto3,oneof"`
}

type Task_SparkTaskConfig 

type Task_SparkTaskConfig struct {

	// Required. The specification of the main method to call to drive the
	// job. Specify either the jar file that contains the main class or the
	// main class name.
	//
	// Types that are assignable to Driver:
	//	*Task_SparkTaskConfig_MainJarFileUri
	//	*Task_SparkTaskConfig_MainClass
	//	*Task_SparkTaskConfig_PythonScriptFile
	//	*Task_SparkTaskConfig_SqlScriptFile
	//	*Task_SparkTaskConfig_SqlScript
	Driver isTask_SparkTaskConfig_Driver `protobuf_oneof:"driver"`
	// Optional. Cloud Storage URIs of files to be placed in the working directory of each
	// executor.
	FileUris []string `protobuf:"bytes,3,rep,name=file_uris,json=fileUris,proto3" json:"file_uris,omitempty"`
	// Optional. Cloud Storage URIs of archives to be extracted into the working directory
	// of each executor. Supported file types: .jar, .tar, .tar.gz, .tgz, and
	// .zip.
	ArchiveUris []string `protobuf:"bytes,4,rep,name=archive_uris,json=archiveUris,proto3" json:"archive_uris,omitempty"`
	// Optional. Infrastructure specification for the execution.
	InfrastructureSpec *Task_InfrastructureSpec `protobuf:"bytes,6,opt,name=infrastructure_spec,json=infrastructureSpec,proto3" json:"infrastructure_spec,omitempty"`
	// contains filtered or unexported fields
}

User-specified config for running a Spark task.

func (*Task_SparkTaskConfig) Descriptor deprecated 

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

Deprecated: Use Task_SparkTaskConfig.ProtoReflect.Descriptor instead.

func (*Task_SparkTaskConfig) GetArchiveUris 

func (x *Task_SparkTaskConfig) GetArchiveUris() []string

func (*Task_SparkTaskConfig) GetDriver 

func (m *Task_SparkTaskConfig) GetDriver() isTask_SparkTaskConfig_Driver

func (*Task_SparkTaskConfig) GetFileUris 

func (x *Task_SparkTaskConfig) GetFileUris() []string

func (*Task_SparkTaskConfig) GetInfrastructureSpec 

func (x *Task_SparkTaskConfig) GetInfrastructureSpec() *Task_InfrastructureSpec

func (*Task_SparkTaskConfig) GetMainClass 

func (x *Task_SparkTaskConfig) GetMainClass() string

func (*Task_SparkTaskConfig) GetMainJarFileUri 

func (x *Task_SparkTaskConfig) GetMainJarFileUri() string

func (*Task_SparkTaskConfig) GetPythonScriptFile 

func (x *Task_SparkTaskConfig) GetPythonScriptFile() string

func (*Task_SparkTaskConfig) GetSqlScript 

func (x *Task_SparkTaskConfig) GetSqlScript() string

func (*Task_SparkTaskConfig) GetSqlScriptFile 

func (x *Task_SparkTaskConfig) GetSqlScriptFile() string

func (*Task_SparkTaskConfig) ProtoMessage 

func (*Task_SparkTaskConfig) ProtoMessage()

func (*Task_SparkTaskConfig) ProtoReflect 

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

func (*Task_SparkTaskConfig) Reset 

func (x *Task_SparkTaskConfig) Reset()

func (*Task_SparkTaskConfig) String 

func (x *Task_SparkTaskConfig) String() string

type Task_SparkTaskConfig_MainClass 

type Task_SparkTaskConfig_MainClass struct {
	// The name of the driver's main class. The jar file that contains the
	// class must be in the default CLASSPATH or specified in
	// `jar_file_uris`.
	// The execution args are passed in as a sequence of named process
	// arguments (`--key=value`).
	MainClass string `protobuf:"bytes,101,opt,name=main_class,json=mainClass,proto3,oneof"`
}

type Task_SparkTaskConfig_MainJarFileUri 

type Task_SparkTaskConfig_MainJarFileUri struct {
	// The Cloud Storage URI of the jar file that contains the main class.
	// The execution args are passed in as a sequence of named process
	// arguments (`--key=value`).
	MainJarFileUri string `protobuf:"bytes,100,opt,name=main_jar_file_uri,json=mainJarFileUri,proto3,oneof"`
}

type Task_SparkTaskConfig_PythonScriptFile 

type Task_SparkTaskConfig_PythonScriptFile struct {
	// The Gcloud Storage URI of the main Python file to use as the driver.
	// Must be a .py file. The execution args are passed in as a sequence of
	// named process arguments (`--key=value`).
	PythonScriptFile string `protobuf:"bytes,102,opt,name=python_script_file,json=pythonScriptFile,proto3,oneof"`
}

type Task_SparkTaskConfig_SqlScript 

type Task_SparkTaskConfig_SqlScript struct {
	// The query text.
	// The execution args are used to declare a set of script variables
	// (`set key="value";`).
	SqlScript string `protobuf:"bytes,105,opt,name=sql_script,json=sqlScript,proto3,oneof"`
}

type Task_SparkTaskConfig_SqlScriptFile 

type Task_SparkTaskConfig_SqlScriptFile struct {
	// A reference to a query file. This can be the Cloud Storage URI of the
	// query file or it can the path to a SqlScript Content. The execution
	// args are used to declare a set of script variables
	// (`set key="value";`).
	SqlScriptFile string `protobuf:"bytes,104,opt,name=sql_script_file,json=sqlScriptFile,proto3,oneof"`
}

type Task_TriggerSpec 

type Task_TriggerSpec struct {

	// Required. Immutable. Trigger type of the user-specified Task.
	Type Task_TriggerSpec_Type `protobuf:"varint,5,opt,name=type,proto3,enum=google.cloud.dataplex.v1.Task_TriggerSpec_Type" json:"type,omitempty"`
	// Optional. The first run of the task will be after this time.
	// If not specified, the task will run shortly after being submitted if
	// ON_DEMAND and based on the schedule if RECURRING.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Optional. Prevent the task from executing.
	// This does not cancel already running tasks. It is intended to temporarily
	// disable RECURRING tasks.
	Disabled bool `protobuf:"varint,4,opt,name=disabled,proto3" json:"disabled,omitempty"`
	// Optional. Number of retry attempts before aborting.
	// Set to zero to never attempt to retry a failed task.
	MaxRetries int32 `protobuf:"varint,7,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	// Trigger only applies for `RECURRING` tasks.
	//
	// Types that are assignable to Trigger:
	//	*Task_TriggerSpec_Schedule
	Trigger isTask_TriggerSpec_Trigger `protobuf_oneof:"trigger"`
	// contains filtered or unexported fields
}

Task scheduling and trigger settings.

func (*Task_TriggerSpec) Descriptor deprecated 

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

Deprecated: Use Task_TriggerSpec.ProtoReflect.Descriptor instead.

func (*Task_TriggerSpec) GetDisabled 

func (x *Task_TriggerSpec) GetDisabled() bool

func (*Task_TriggerSpec) GetMaxRetries 

func (x *Task_TriggerSpec) GetMaxRetries() int32

func (*Task_TriggerSpec) GetSchedule 

func (x *Task_TriggerSpec) GetSchedule() string

func (*Task_TriggerSpec) GetStartTime 

func (x *Task_TriggerSpec) GetStartTime() *timestamppb.Timestamp

func (*Task_TriggerSpec) GetTrigger 

func (m *Task_TriggerSpec) GetTrigger() isTask_TriggerSpec_Trigger

func (*Task_TriggerSpec) GetType 

func (x *Task_TriggerSpec) GetType() Task_TriggerSpec_Type

func (*Task_TriggerSpec) ProtoMessage 

func (*Task_TriggerSpec) ProtoMessage()

func (*Task_TriggerSpec) ProtoReflect 

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

func (*Task_TriggerSpec) Reset 

func (x *Task_TriggerSpec) Reset()

func (*Task_TriggerSpec) String 

func (x *Task_TriggerSpec) String() string

type Task_TriggerSpec_Schedule 

type Task_TriggerSpec_Schedule struct {
	// Optional. Cron schedule (https://en.wikipedia.org/wiki/Cron) for running
	// tasks periodically.
	// To explicitly set a timezone to the cron tab, apply a prefix in the
	// cron tab: "CRON_TZ=${IANA_TIME_ZONE}" or "TZ=${IANA_TIME_ZONE}".
	// The ${IANA_TIME_ZONE} may only be a valid string from IANA time zone
	// database. For example, "CRON_TZ=America/New_York 1 * * * *", or
	// "TZ=America/New_York 1 * * * *".
	// This field is required for RECURRING tasks.
	Schedule string `protobuf:"bytes,100,opt,name=schedule,proto3,oneof"`
}

type Task_TriggerSpec_Type 

type Task_TriggerSpec_Type int32

Determines how often and when the job will run. 

const (
	// Unspecified trigger type.
	Task_TriggerSpec_TYPE_UNSPECIFIED Task_TriggerSpec_Type = 0
	// The task runs one-time shortly after Task Creation.
	Task_TriggerSpec_ON_DEMAND Task_TriggerSpec_Type = 1
	// The task is scheduled to run periodically.
	Task_TriggerSpec_RECURRING Task_TriggerSpec_Type = 2
)

func (Task_TriggerSpec_Type) Descriptor 

func (Task_TriggerSpec_Type) Descriptor() protoreflect.EnumDescriptor

func (Task_TriggerSpec_Type) Enum 

func (x Task_TriggerSpec_Type) Enum() *Task_TriggerSpec_Type

func (Task_TriggerSpec_Type) EnumDescriptor deprecated 

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

Deprecated: Use Task_TriggerSpec_Type.Descriptor instead.

func (Task_TriggerSpec_Type) Number 

func (x Task_TriggerSpec_Type) Number() protoreflect.EnumNumber

func (Task_TriggerSpec_Type) String 

func (x Task_TriggerSpec_Type) String() string

func (Task_TriggerSpec_Type) Type 

func (Task_TriggerSpec_Type) Type() protoreflect.EnumType

type UnimplementedDataplexServiceServer 

type UnimplementedDataplexServiceServer struct {
}

UnimplementedDataplexServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataplexServiceServer) CancelJob 

func (*UnimplementedDataplexServiceServer) CancelJob(context.Context, *CancelJobRequest) (*emptypb.Empty, error)

func (*UnimplementedDataplexServiceServer) CreateAsset 

func (*UnimplementedDataplexServiceServer) CreateAsset(context.Context, *CreateAssetRequest) (*longrunning.Operation, error)

func (*UnimplementedDataplexServiceServer) CreateLake 

func (*UnimplementedDataplexServiceServer) CreateLake(context.Context, *CreateLakeRequest) (*longrunning.Operation, error)

func (*UnimplementedDataplexServiceServer) CreateTask 

func (*UnimplementedDataplexServiceServer) CreateTask(context.Context, *CreateTaskRequest) (*longrunning.Operation, error)

func (*UnimplementedDataplexServiceServer) CreateZone 

func (*UnimplementedDataplexServiceServer) CreateZone(context.Context, *CreateZoneRequest) (*longrunning.Operation, error)

func (*UnimplementedDataplexServiceServer) DeleteAsset 

func (*UnimplementedDataplexServiceServer) DeleteAsset(context.Context, *DeleteAssetRequest) (*longrunning.Operation, error)

func (*UnimplementedDataplexServiceServer) DeleteLake 

func (*UnimplementedDataplexServiceServer) DeleteLake(context.Context, *DeleteLakeRequest) (*longrunning.Operation, error)

func (*UnimplementedDataplexServiceServer) DeleteTask 

func (*UnimplementedDataplexServiceServer) DeleteTask(context.Context, *DeleteTaskRequest) (*longrunning.Operation, error)

func (*UnimplementedDataplexServiceServer) DeleteZone 

func (*UnimplementedDataplexServiceServer) DeleteZone(context.Context, *DeleteZoneRequest) (*longrunning.Operation, error)

func (*UnimplementedDataplexServiceServer) GetAsset 

func (*UnimplementedDataplexServiceServer) GetAsset(context.Context, *GetAssetRequest) (*Asset, error)

func (*UnimplementedDataplexServiceServer) GetJob 

func (*UnimplementedDataplexServiceServer) GetJob(context.Context, *GetJobRequest) (*Job, error)

func (*UnimplementedDataplexServiceServer) GetLake 

func (*UnimplementedDataplexServiceServer) GetLake(context.Context, *GetLakeRequest) (*Lake, error)

func (*UnimplementedDataplexServiceServer) GetTask 

func (*UnimplementedDataplexServiceServer) GetTask(context.Context, *GetTaskRequest) (*Task, error)

func (*UnimplementedDataplexServiceServer) GetZone 

func (*UnimplementedDataplexServiceServer) GetZone(context.Context, *GetZoneRequest) (*Zone, error)

func (*UnimplementedDataplexServiceServer) ListAssetActions 

func (*UnimplementedDataplexServiceServer) ListAssetActions(context.Context, *ListAssetActionsRequest) (*ListActionsResponse, error)

func (*UnimplementedDataplexServiceServer) ListAssets 

func (*UnimplementedDataplexServiceServer) ListAssets(context.Context, *ListAssetsRequest) (*ListAssetsResponse, error)

func (*UnimplementedDataplexServiceServer) ListJobs 

func (*UnimplementedDataplexServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)

func (*UnimplementedDataplexServiceServer) ListLakeActions 

func (*UnimplementedDataplexServiceServer) ListLakeActions(context.Context, *ListLakeActionsRequest) (*ListActionsResponse, error)

func (*UnimplementedDataplexServiceServer) ListLakes 

func (*UnimplementedDataplexServiceServer) ListLakes(context.Context, *ListLakesRequest) (*ListLakesResponse, error)

func (*UnimplementedDataplexServiceServer) ListTasks 

func (*UnimplementedDataplexServiceServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)

func (*UnimplementedDataplexServiceServer) ListZoneActions 

func (*UnimplementedDataplexServiceServer) ListZoneActions(context.Context, *ListZoneActionsRequest) (*ListActionsResponse, error)

func (*UnimplementedDataplexServiceServer) ListZones 

func (*UnimplementedDataplexServiceServer) ListZones(context.Context, *ListZonesRequest) (*ListZonesResponse, error)

func (*UnimplementedDataplexServiceServer) UpdateAsset 

func (*UnimplementedDataplexServiceServer) UpdateAsset(context.Context, *UpdateAssetRequest) (*longrunning.Operation, error)

func (*UnimplementedDataplexServiceServer) UpdateLake 

func (*UnimplementedDataplexServiceServer) UpdateLake(context.Context, *UpdateLakeRequest) (*longrunning.Operation, error)

func (*UnimplementedDataplexServiceServer) UpdateTask 

func (*UnimplementedDataplexServiceServer) UpdateTask(context.Context, *UpdateTaskRequest) (*longrunning.Operation, error)

func (*UnimplementedDataplexServiceServer) UpdateZone 

func (*UnimplementedDataplexServiceServer) UpdateZone(context.Context, *UpdateZoneRequest) (*longrunning.Operation, error)

type UnimplementedMetadataServiceServer 

type UnimplementedMetadataServiceServer struct {
}

UnimplementedMetadataServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetadataServiceServer) GetEntity 

func (*UnimplementedMetadataServiceServer) GetEntity(context.Context, *GetEntityRequest) (*Entity, error)

func (*UnimplementedMetadataServiceServer) GetPartition 

func (*UnimplementedMetadataServiceServer) GetPartition(context.Context, *GetPartitionRequest) (*Partition, error)

func (*UnimplementedMetadataServiceServer) ListEntities 

func (*UnimplementedMetadataServiceServer) ListEntities(context.Context, *ListEntitiesRequest) (*ListEntitiesResponse, error)

func (*UnimplementedMetadataServiceServer) ListPartitions 

func (*UnimplementedMetadataServiceServer) ListPartitions(context.Context, *ListPartitionsRequest) (*ListPartitionsResponse, error)

type UpdateAssetRequest 

type UpdateAssetRequest struct {

	// Required. Mask of fields to update.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Required. Update description.
	// Only fields specified in `update_mask` are updated.
	Asset *Asset `protobuf:"bytes,2,opt,name=asset,proto3" json:"asset,omitempty"`
	// Optional. Only validate the request, but do not perform mutations.
	// The default is false.
	ValidateOnly bool `protobuf:"varint,3,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

Update asset request.

func (*UpdateAssetRequest) Descriptor deprecated 

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

Deprecated: Use UpdateAssetRequest.ProtoReflect.Descriptor instead.

func (*UpdateAssetRequest) GetAsset 

func (x *UpdateAssetRequest) GetAsset() *Asset

func (*UpdateAssetRequest) GetUpdateMask 

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

func (*UpdateAssetRequest) GetValidateOnly 

func (x *UpdateAssetRequest) GetValidateOnly() bool

func (*UpdateAssetRequest) ProtoMessage 

func (*UpdateAssetRequest) ProtoMessage()

func (*UpdateAssetRequest) ProtoReflect 

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

func (*UpdateAssetRequest) Reset 

func (x *UpdateAssetRequest) Reset()

func (*UpdateAssetRequest) String 

func (x *UpdateAssetRequest) String() string

type UpdateLakeRequest 

type UpdateLakeRequest struct {

	// Required. Mask of fields to update.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Required. Update description.
	// Only fields specified in `update_mask` are updated.
	Lake *Lake `protobuf:"bytes,2,opt,name=lake,proto3" json:"lake,omitempty"`
	// Optional. Only validate the request, but do not perform mutations.
	// The default is false.
	ValidateOnly bool `protobuf:"varint,3,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

Update lake request.

func (*UpdateLakeRequest) Descriptor deprecated 

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

Deprecated: Use UpdateLakeRequest.ProtoReflect.Descriptor instead.

func (*UpdateLakeRequest) GetLake 

func (x *UpdateLakeRequest) GetLake() *Lake

func (*UpdateLakeRequest) GetUpdateMask 

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

func (*UpdateLakeRequest) GetValidateOnly 

func (x *UpdateLakeRequest) GetValidateOnly() bool

func (*UpdateLakeRequest) ProtoMessage 

func (*UpdateLakeRequest) ProtoMessage()

func (*UpdateLakeRequest) ProtoReflect 

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

func (*UpdateLakeRequest) Reset 

func (x *UpdateLakeRequest) Reset()

func (*UpdateLakeRequest) String 

func (x *UpdateLakeRequest) String() string

type UpdateTaskRequest 

type UpdateTaskRequest struct {

	// Required. Mask of fields to update.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Required. Update description.
	// Only fields specified in `update_mask` are updated.
	Task *Task `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	// Optional. Only validate the request, but do not perform mutations.
	// The default is false.
	ValidateOnly bool `protobuf:"varint,3,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

Update task request.

func (*UpdateTaskRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTaskRequest.ProtoReflect.Descriptor instead.

func (*UpdateTaskRequest) GetTask 

func (x *UpdateTaskRequest) GetTask() *Task

func (*UpdateTaskRequest) GetUpdateMask 

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

func (*UpdateTaskRequest) GetValidateOnly 

func (x *UpdateTaskRequest) GetValidateOnly() bool

func (*UpdateTaskRequest) ProtoMessage 

func (*UpdateTaskRequest) ProtoMessage()

func (*UpdateTaskRequest) ProtoReflect 

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

func (*UpdateTaskRequest) Reset 

func (x *UpdateTaskRequest) Reset()

func (*UpdateTaskRequest) String 

func (x *UpdateTaskRequest) String() string

type UpdateZoneRequest 

type UpdateZoneRequest struct {

	// Required. Mask of fields to update.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Required. Update description.
	// Only fields specified in `update_mask` are updated.
	Zone *Zone `protobuf:"bytes,2,opt,name=zone,proto3" json:"zone,omitempty"`
	// Optional. Only validate the request, but do not perform mutations.
	// The default is false.
	ValidateOnly bool `protobuf:"varint,3,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

Update zone request.

func (*UpdateZoneRequest) Descriptor deprecated 

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

Deprecated: Use UpdateZoneRequest.ProtoReflect.Descriptor instead.

func (*UpdateZoneRequest) GetUpdateMask 

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

func (*UpdateZoneRequest) GetValidateOnly 

func (x *UpdateZoneRequest) GetValidateOnly() bool

func (*UpdateZoneRequest) GetZone 

func (x *UpdateZoneRequest) GetZone() *Zone

func (*UpdateZoneRequest) ProtoMessage 

func (*UpdateZoneRequest) ProtoMessage()

func (*UpdateZoneRequest) ProtoReflect 

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

func (*UpdateZoneRequest) Reset 

func (x *UpdateZoneRequest) Reset()

func (*UpdateZoneRequest) String 

func (x *UpdateZoneRequest) String() string

type Zone 

type Zone struct {

	// Output only. The relative resource name of the zone, of the form:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. User friendly display name.
	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Output only. System generated globally unique ID for the zone. This ID will be
	// different if the zone is deleted and re-created with the same name.
	Uid string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"`
	// Output only. The time when the zone was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time when the zone was last updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Optional. User defined labels for the zone.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Optional. Description of the zone.
	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
	// Output only. Current state of the zone.
	State State `protobuf:"varint,8,opt,name=state,proto3,enum=google.cloud.dataplex.v1.State" json:"state,omitempty"`
	// Required. Immutable. The type of the zone.
	Type Zone_Type `protobuf:"varint,9,opt,name=type,proto3,enum=google.cloud.dataplex.v1.Zone_Type" json:"type,omitempty"`
	// Optional. Specification of the discovery feature applied to data in this zone.
	DiscoverySpec *Zone_DiscoverySpec `protobuf:"bytes,103,opt,name=discovery_spec,json=discoverySpec,proto3" json:"discovery_spec,omitempty"`
	// Required. Specification of the resources that are referenced by the assets within
	// this zone.
	ResourceSpec *Zone_ResourceSpec `protobuf:"bytes,104,opt,name=resource_spec,json=resourceSpec,proto3" json:"resource_spec,omitempty"`
	// Output only. Aggregated status of the underlying assets of the zone.
	AssetStatus *AssetStatus `protobuf:"bytes,105,opt,name=asset_status,json=assetStatus,proto3" json:"asset_status,omitempty"`
	// contains filtered or unexported fields
}

A zone represents a logical group of related assets within a lake. A zone can be used to map to organizational structure or represent stages of data readiness from raw to curated. It provides managing behavior that is shared or inherited by all contained assets.

func (*Zone) Descriptor deprecated 

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

Deprecated: Use Zone.ProtoReflect.Descriptor instead.

func (*Zone) GetAssetStatus 

func (x *Zone) GetAssetStatus() *AssetStatus

func (*Zone) GetCreateTime 

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

func (*Zone) GetDescription 

func (x *Zone) GetDescription() string

func (*Zone) GetDiscoverySpec 

func (x *Zone) GetDiscoverySpec() *Zone_DiscoverySpec

func (*Zone) GetDisplayName 

func (x *Zone) GetDisplayName() string

func (*Zone) GetLabels 

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

func (*Zone) GetName 

func (x *Zone) GetName() string

func (*Zone) GetResourceSpec 

func (x *Zone) GetResourceSpec() *Zone_ResourceSpec

func (*Zone) GetState 

func (x *Zone) GetState() State

func (*Zone) GetType 

func (x *Zone) GetType() Zone_Type

func (*Zone) GetUid 

func (x *Zone) GetUid() string

func (*Zone) GetUpdateTime 

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

func (*Zone) ProtoMessage 

func (*Zone) ProtoMessage()

func (*Zone) ProtoReflect 

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

func (*Zone) Reset 

func (x *Zone) Reset()

func (*Zone) String 

func (x *Zone) String() string

type Zone_DiscoverySpec 

type Zone_DiscoverySpec struct {

	// Required. Whether discovery is enabled.
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Optional. The list of patterns to apply for selecting data to include during
	// discovery if only a subset of the data should considered. For Cloud
	// Storage bucket assets, these are interpreted as glob patterns used to
	// match object names. For BigQuery dataset assets, these are
	// interpreted as patterns to match table names.
	IncludePatterns []string `protobuf:"bytes,2,rep,name=include_patterns,json=includePatterns,proto3" json:"include_patterns,omitempty"`
	// Optional. The list of patterns to apply for selecting data to exclude during
	// discovery.  For Cloud Storage bucket assets, these are interpreted as
	// glob patterns used to match object names. For BigQuery dataset assets,
	// these are interpreted as patterns to match table names.
	ExcludePatterns []string `protobuf:"bytes,3,rep,name=exclude_patterns,json=excludePatterns,proto3" json:"exclude_patterns,omitempty"`
	// Optional. Configuration for CSV data.
	CsvOptions *Zone_DiscoverySpec_CsvOptions `protobuf:"bytes,4,opt,name=csv_options,json=csvOptions,proto3" json:"csv_options,omitempty"`
	// Optional. Configuration for Json data.
	JsonOptions *Zone_DiscoverySpec_JsonOptions `protobuf:"bytes,5,opt,name=json_options,json=jsonOptions,proto3" json:"json_options,omitempty"`
	// Determines when discovery is triggered.
	//
	// Types that are assignable to Trigger:
	//	*Zone_DiscoverySpec_Schedule
	Trigger isZone_DiscoverySpec_Trigger `protobuf_oneof:"trigger"`
	// contains filtered or unexported fields
}

Settings to manage the metadata discovery and publishing in a zone.

func (*Zone_DiscoverySpec) Descriptor deprecated 

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

Deprecated: Use Zone_DiscoverySpec.ProtoReflect.Descriptor instead.

func (*Zone_DiscoverySpec) GetCsvOptions 

func (x *Zone_DiscoverySpec) GetCsvOptions() *Zone_DiscoverySpec_CsvOptions

func (*Zone_DiscoverySpec) GetEnabled 

func (x *Zone_DiscoverySpec) GetEnabled() bool

func (*Zone_DiscoverySpec) GetExcludePatterns 

func (x *Zone_DiscoverySpec) GetExcludePatterns() []string

func (*Zone_DiscoverySpec) GetIncludePatterns 

func (x *Zone_DiscoverySpec) GetIncludePatterns() []string

func (*Zone_DiscoverySpec) GetJsonOptions 

func (x *Zone_DiscoverySpec) GetJsonOptions() *Zone_DiscoverySpec_JsonOptions

func (*Zone_DiscoverySpec) GetSchedule 

func (x *Zone_DiscoverySpec) GetSchedule() string

func (*Zone_DiscoverySpec) GetTrigger 

func (m *Zone_DiscoverySpec) GetTrigger() isZone_DiscoverySpec_Trigger

func (*Zone_DiscoverySpec) ProtoMessage 

func (*Zone_DiscoverySpec) ProtoMessage()

func (*Zone_DiscoverySpec) ProtoReflect 

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

func (*Zone_DiscoverySpec) Reset 

func (x *Zone_DiscoverySpec) Reset()

func (*Zone_DiscoverySpec) String 

func (x *Zone_DiscoverySpec) String() string

type Zone_DiscoverySpec_CsvOptions 

type Zone_DiscoverySpec_CsvOptions struct {

	// Optional. The number of rows to interpret as header rows that should be skipped
	// when reading data rows.
	HeaderRows int32 `protobuf:"varint,1,opt,name=header_rows,json=headerRows,proto3" json:"header_rows,omitempty"`
	// Optional. The delimiter being used to separate values. This defaults to ','.
	Delimiter string `protobuf:"bytes,2,opt,name=delimiter,proto3" json:"delimiter,omitempty"`
	// Optional. The character encoding of the data. The default is UTF-8.
	Encoding string `protobuf:"bytes,3,opt,name=encoding,proto3" json:"encoding,omitempty"`
	// Optional. Whether to disable the inference of data type for CSV data.
	// If true, all columns will be registered as strings.
	DisableTypeInference bool `protobuf:"varint,4,opt,name=disable_type_inference,json=disableTypeInference,proto3" json:"disable_type_inference,omitempty"`
	// contains filtered or unexported fields
}

Describe CSV and similar semi-structured data formats.

func (*Zone_DiscoverySpec_CsvOptions) Descriptor deprecated 

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

Deprecated: Use Zone_DiscoverySpec_CsvOptions.ProtoReflect.Descriptor instead.

func (*Zone_DiscoverySpec_CsvOptions) GetDelimiter 

func (x *Zone_DiscoverySpec_CsvOptions) GetDelimiter() string

func (*Zone_DiscoverySpec_CsvOptions) GetDisableTypeInference 

func (x *Zone_DiscoverySpec_CsvOptions) GetDisableTypeInference() bool

func (*Zone_DiscoverySpec_CsvOptions) GetEncoding 

func (x *Zone_DiscoverySpec_CsvOptions) GetEncoding() string

func (*Zone_DiscoverySpec_CsvOptions) GetHeaderRows 

func (x *Zone_DiscoverySpec_CsvOptions) GetHeaderRows() int32

func (*Zone_DiscoverySpec_CsvOptions) ProtoMessage 

func (*Zone_DiscoverySpec_CsvOptions) ProtoMessage()

func (*Zone_DiscoverySpec_CsvOptions) ProtoReflect 

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

func (*Zone_DiscoverySpec_CsvOptions) Reset 

func (x *Zone_DiscoverySpec_CsvOptions) Reset()

func (*Zone_DiscoverySpec_CsvOptions) String 

func (x *Zone_DiscoverySpec_CsvOptions) String() string

type Zone_DiscoverySpec_JsonOptions 

type Zone_DiscoverySpec_JsonOptions struct {

	// Optional. The character encoding of the data. The default is UTF-8.
	Encoding string `protobuf:"bytes,1,opt,name=encoding,proto3" json:"encoding,omitempty"`
	// Optional. Whether to disable the inference of data type for Json data.
	// If true, all columns will be registered as their primitive types
	// (strings, number or boolean).
	DisableTypeInference bool `protobuf:"varint,2,opt,name=disable_type_inference,json=disableTypeInference,proto3" json:"disable_type_inference,omitempty"`
	// contains filtered or unexported fields
}

Describe JSON data format.

func (*Zone_DiscoverySpec_JsonOptions) Descriptor deprecated 

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

Deprecated: Use Zone_DiscoverySpec_JsonOptions.ProtoReflect.Descriptor instead.

func (*Zone_DiscoverySpec_JsonOptions) GetDisableTypeInference 

func (x *Zone_DiscoverySpec_JsonOptions) GetDisableTypeInference() bool

func (*Zone_DiscoverySpec_JsonOptions) GetEncoding 

func (x *Zone_DiscoverySpec_JsonOptions) GetEncoding() string

func (*Zone_DiscoverySpec_JsonOptions) ProtoMessage 

func (*Zone_DiscoverySpec_JsonOptions) ProtoMessage()

func (*Zone_DiscoverySpec_JsonOptions) ProtoReflect 

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

func (*Zone_DiscoverySpec_JsonOptions) Reset 

func (x *Zone_DiscoverySpec_JsonOptions) Reset()

func (*Zone_DiscoverySpec_JsonOptions) String 

func (x *Zone_DiscoverySpec_JsonOptions) String() string

type Zone_DiscoverySpec_Schedule 

type Zone_DiscoverySpec_Schedule struct {
	// Optional. Cron schedule (https://en.wikipedia.org/wiki/Cron) for running
	// discovery periodically. Successive discovery runs must be scheduled at
	// least 60 minutes apart.
	// The default value is to run discovery every 60 minutes.
	// To explicitly set a timezone to the cron tab, apply a prefix in the
	// cron tab: "CRON_TZ=${IANA_TIME_ZONE}" or TZ=${IANA_TIME_ZONE}".
	// The ${IANA_TIME_ZONE} may only be a valid string from IANA time zone
	// database. For example, "CRON_TZ=America/New_York 1 * * * *", or
	// "TZ=America/New_York 1 * * * *".
	Schedule string `protobuf:"bytes,10,opt,name=schedule,proto3,oneof"`
}

type Zone_ResourceSpec 

type Zone_ResourceSpec struct {

	// Required. Immutable. The location type of the resources that are allowed to be attached to the
	// assets within this zone.
	LocationType Zone_ResourceSpec_LocationType `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

Settings for resources attached as assets within a zone.

func (*Zone_ResourceSpec) Descriptor deprecated 

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

Deprecated: Use Zone_ResourceSpec.ProtoReflect.Descriptor instead.

func (*Zone_ResourceSpec) GetLocationType 

func (x *Zone_ResourceSpec) GetLocationType() Zone_ResourceSpec_LocationType

func (*Zone_ResourceSpec) ProtoMessage 

func (*Zone_ResourceSpec) ProtoMessage()

func (*Zone_ResourceSpec) ProtoReflect 

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

func (*Zone_ResourceSpec) Reset 

func (x *Zone_ResourceSpec) Reset()

func (*Zone_ResourceSpec) String 

func (x *Zone_ResourceSpec) String() string

type Zone_ResourceSpec_LocationType 

type Zone_ResourceSpec_LocationType int32

Location type of the resources attached to a zone. 

const (
	// Unspecified location type.
	Zone_ResourceSpec_LOCATION_TYPE_UNSPECIFIED Zone_ResourceSpec_LocationType = 0
	// Resources that are associated with a single region.
	Zone_ResourceSpec_SINGLE_REGION Zone_ResourceSpec_LocationType = 1
	// Resources that are associated with a multi-region location.
	Zone_ResourceSpec_MULTI_REGION Zone_ResourceSpec_LocationType = 2
)

func (Zone_ResourceSpec_LocationType) Descriptor 

func (Zone_ResourceSpec_LocationType) Descriptor() protoreflect.EnumDescriptor

func (Zone_ResourceSpec_LocationType) Enum 

func (x Zone_ResourceSpec_LocationType) Enum() *Zone_ResourceSpec_LocationType

func (Zone_ResourceSpec_LocationType) EnumDescriptor deprecated 

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

Deprecated: Use Zone_ResourceSpec_LocationType.Descriptor instead.

func (Zone_ResourceSpec_LocationType) Number 

func (x Zone_ResourceSpec_LocationType) Number() protoreflect.EnumNumber

func (Zone_ResourceSpec_LocationType) String 

func (x Zone_ResourceSpec_LocationType) String() string

func (Zone_ResourceSpec_LocationType) Type 

func (Zone_ResourceSpec_LocationType) Type() protoreflect.EnumType

type Zone_Type 

type Zone_Type int32

Type of zone. 

const (
	// Zone type not specified.
	Zone_TYPE_UNSPECIFIED Zone_Type = 0
	// A zone that contains data that needs further processing before it is
	// considered generally ready for consumption and analytics workloads.
	Zone_RAW Zone_Type = 1
	// A zone that contains data that is considered to be ready for broader
	// consumption and analytics workloads. Curated structured data stored in
	// Cloud Storage must conform to certain file formats (parquet, avro and
	// orc) and organized in a hive-compatible directory layout.
	Zone_CURATED Zone_Type = 2
)

func (Zone_Type) Descriptor 

func (Zone_Type) Descriptor() protoreflect.EnumDescriptor

func (Zone_Type) Enum 

func (x Zone_Type) Enum() *Zone_Type

func (Zone_Type) EnumDescriptor deprecated 

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

Deprecated: Use Zone_Type.Descriptor instead.

func (Zone_Type) Number 

func (x Zone_Type) Number() protoreflect.EnumNumber

func (Zone_Type) String 

func (x Zone_Type) String() string

func (Zone_Type) Type 

func (Zone_Type) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.