Package cloud.google.com/go/dataplex/apiv1/dataplexpb (v1.3.0)

Version 1.3.0

• 1.16.0 (latest)
• 1.15.1
• 1.14.3
• 1.13.0
• 1.12.0
• 1.11.2
• 1.10.2
• 1.9.1
• 1.8.1
• 1.7.1
• 1.6.0
• 1.5.2
• 1.4.0
• 1.3.0
• 1.2.0
• 1.1.0
• 1.0.0
• 0.4.0
• 0.3.0
• 0.2.0
• 0.1.0

Note: To get more information about this package, such as access to older versions, view this package on pkg.go.dev.

Variables

Content_SqlScript_QueryEngine_name, Content_SqlScript_QueryEngine_value

var (
	Content_SqlScript_QueryEngine_name = map[int32]string{
		0: "QUERY_ENGINE_UNSPECIFIED",
		2: "SPARK",
	}
	Content_SqlScript_QueryEngine_value = map[string]int32{
		"QUERY_ENGINE_UNSPECIFIED": 0,
		"SPARK":                    2,
	}
)

Enum value maps for Content_SqlScript_QueryEngine.

Content_Notebook_KernelType_name, Content_Notebook_KernelType_value

var (
	Content_Notebook_KernelType_name = map[int32]string{
		0: "KERNEL_TYPE_UNSPECIFIED",
		1: "PYTHON3",
	}
	Content_Notebook_KernelType_value = map[string]int32{
		"KERNEL_TYPE_UNSPECIFIED": 0,
		"PYTHON3":                 1,
	}
)

Enum value maps for Content_Notebook_KernelType.

GetContentRequest_ContentView_name, GetContentRequest_ContentView_value

var (
	GetContentRequest_ContentView_name = map[int32]string{
		0: "CONTENT_VIEW_UNSPECIFIED",
		1: "BASIC",
		2: "FULL",
	}
	GetContentRequest_ContentView_value = map[string]int32{
		"CONTENT_VIEW_UNSPECIFIED": 0,
		"BASIC":                    1,
		"FULL":                     2,
	}
)

Enum value maps for GetContentRequest_ContentView.

DiscoveryEvent_EventType_name, DiscoveryEvent_EventType_value

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.

DiscoveryEvent_EntityType_name, DiscoveryEvent_EntityType_value

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.

JobEvent_Type_name, JobEvent_Type_value

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.

JobEvent_State_name, JobEvent_State_value

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.

JobEvent_Service_name, JobEvent_Service_value

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.

SessionEvent_EventType_name, SessionEvent_EventType_value

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

Enum value maps for SessionEvent_EventType.

SessionEvent_QueryDetail_Engine_name, SessionEvent_QueryDetail_Engine_value

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.

StorageSystem_name, StorageSystem_value

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.

ListEntitiesRequest_EntityView_name, ListEntitiesRequest_EntityView_value

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.

GetEntityRequest_EntityView_name, GetEntityRequest_EntityView_value

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.

Entity_Type_name, Entity_Type_value

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.

Schema_Type_name, Schema_Type_value

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.

Schema_Mode_name, Schema_Mode_value

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.

Schema_PartitionStyle_name, Schema_PartitionStyle_value

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.

StorageFormat_Format_name, StorageFormat_Format_value

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.

StorageFormat_CompressionFormat_name, StorageFormat_CompressionFormat_value

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.

State_name, State_value

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.

Lake_MetastoreStatus_State_name, Lake_MetastoreStatus_State_value

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.

Zone_Type_name, Zone_Type_value

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.

Zone_ResourceSpec_LocationType_name, Zone_ResourceSpec_LocationType_value

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.

Action_Category_name, Action_Category_value

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.

Action_IncompatibleDataSchema_SchemaChange_name, Action_IncompatibleDataSchema_SchemaChange_value

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.

Action_InvalidDataPartition_PartitionStructure_name, Action_InvalidDataPartition_PartitionStructure_value

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.

Asset_SecurityStatus_State_name, Asset_SecurityStatus_State_value

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.

Asset_ResourceSpec_Type_name, Asset_ResourceSpec_Type_value

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.

Asset_ResourceStatus_State_name, Asset_ResourceStatus_State_value

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.

Asset_DiscoveryStatus_State_name, Asset_DiscoveryStatus_State_value

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.

Task_TriggerSpec_Type_name, Task_TriggerSpec_Type_value

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.

Job_Service_name, Job_Service_value

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.

Job_State_name, Job_State_value

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.

File_google_cloud_dataplex_v1_analyze_proto

var File_google_cloud_dataplex_v1_analyze_proto protoreflect.FileDescriptor

File_google_cloud_dataplex_v1_content_proto

var File_google_cloud_dataplex_v1_content_proto protoreflect.FileDescriptor

File_google_cloud_dataplex_v1_logs_proto

var File_google_cloud_dataplex_v1_logs_proto protoreflect.FileDescriptor

File_google_cloud_dataplex_v1_metadata_proto

var File_google_cloud_dataplex_v1_metadata_proto protoreflect.FileDescriptor

File_google_cloud_dataplex_v1_resources_proto

var File_google_cloud_dataplex_v1_resources_proto protoreflect.FileDescriptor

File_google_cloud_dataplex_v1_service_proto

var File_google_cloud_dataplex_v1_service_proto protoreflect.FileDescriptor

File_google_cloud_dataplex_v1_tasks_proto

var File_google_cloud_dataplex_v1_tasks_proto protoreflect.FileDescriptor

Functions

func RegisterContentServiceServer

func RegisterContentServiceServer(s *grpc.Server, srv ContentServiceServer)

func RegisterDataplexServiceServer

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

func RegisterMetadataServiceServer

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

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 *timestamp.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

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

Action_Category

type Action_Category int32

The category of issues.

Action_CATEGORY_UNSPECIFIED, Action_RESOURCE_MANAGEMENT, Action_SECURITY_POLICY, Action_DATA_DISCOVERY

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

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

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

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

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"`
}

Action_IncompatibleDataSchema

type Action_IncompatibleDataSchema struct {
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`

	ExistingSchema string `protobuf:"bytes,2,opt,name=existing_schema,json=existingSchema,proto3" json:"existing_schema,omitempty"`

	NewSchema string `protobuf:"bytes,3,opt,name=new_schema,json=newSchema,proto3" json:"new_schema,omitempty"`

	SampledDataLocations []string `protobuf:"bytes,4,rep,name=sampled_data_locations,json=sampledDataLocations,proto3" json:"sampled_data_locations,omitempty"`

	SchemaChange Action_IncompatibleDataSchema_SchemaChange "" /* 171 byte string literal not displayed */

}

Action details for incompatible schemas detected by discovery.

func (*Action_IncompatibleDataSchema) Descriptor

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

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"`
}

Action_IncompatibleDataSchema_SchemaChange

type Action_IncompatibleDataSchema_SchemaChange int32

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

Action_IncompatibleDataSchema_SCHEMA_CHANGE_UNSPECIFIED, Action_IncompatibleDataSchema_INCOMPATIBLE, Action_IncompatibleDataSchema_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

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

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

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

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"`
}

Action_InvalidDataOrganization

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

Action details for invalid data arrangement.

func (*Action_InvalidDataOrganization) Descriptor

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

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"`
}

Action_InvalidDataPartition

type Action_InvalidDataPartition struct {
	ExpectedStructure Action_InvalidDataPartition_PartitionStructure "" /* 190 byte string literal not displayed */

}

Action details for invalid or unsupported partitions detected by discovery.

func (*Action_InvalidDataPartition) Descriptor

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

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"`
}

Action_InvalidDataPartition_PartitionStructure

type Action_InvalidDataPartition_PartitionStructure int32

The expected partition structure.

Action_InvalidDataPartition_PARTITION_STRUCTURE_UNSPECIFIED, Action_InvalidDataPartition_CONSISTENT_KEYS, Action_InvalidDataPartition_HIVE_STYLE_KEYS

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

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

Action_MissingData

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

Action details for absence of data detected by discovery.

func (*Action_MissingData) Descriptor

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

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"`
}

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

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

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"`
}

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

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

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"`
}

Asset

type Asset struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`

	Uid string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"`

	CreateTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`

	State State `protobuf:"varint,8,opt,name=state,proto3,enum=google.cloud.dataplex.v1.State" json:"state,omitempty"`

	ResourceSpec *Asset_ResourceSpec `protobuf:"bytes,100,opt,name=resource_spec,json=resourceSpec,proto3" json:"resource_spec,omitempty"`

	ResourceStatus *Asset_ResourceStatus `protobuf:"bytes,101,opt,name=resource_status,json=resourceStatus,proto3" json:"resource_status,omitempty"`

	SecurityStatus *Asset_SecurityStatus `protobuf:"bytes,103,opt,name=security_status,json=securityStatus,proto3" json:"security_status,omitempty"`

	DiscoverySpec *Asset_DiscoverySpec `protobuf:"bytes,106,opt,name=discovery_spec,json=discoverySpec,proto3" json:"discovery_spec,omitempty"`

	DiscoveryStatus *Asset_DiscoveryStatus `protobuf:"bytes,107,opt,name=discovery_status,json=discoveryStatus,proto3" json:"discovery_status,omitempty"`

}

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

func (*Asset) Descriptor

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

Deprecated: Use Asset.ProtoReflect.Descriptor instead.

func (*Asset) GetCreateTime

func (x *Asset) GetCreateTime() *timestamp.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() *timestamp.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

AssetStatus

type AssetStatus struct {
	UpdateTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	ActiveAssets int32 `protobuf:"varint,2,opt,name=active_assets,json=activeAssets,proto3" json:"active_assets,omitempty"`

	SecurityPolicyApplyingAssets int32 "" /* 150 byte string literal not displayed */

}

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

func (*AssetStatus) Descriptor

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

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

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

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

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

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

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

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"`
}

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 *timestamp.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// The start time of the last discovery run.
	LastRunTime *timestamp.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 *duration.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

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

Deprecated: Use Asset_DiscoveryStatus.ProtoReflect.Descriptor instead.

func (*Asset_DiscoveryStatus) GetLastRunDuration

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

func (*Asset_DiscoveryStatus) GetLastRunTime

func (x *Asset_DiscoveryStatus) GetLastRunTime() *timestamp.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() *timestamp.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

Asset_DiscoveryStatus_State

type Asset_DiscoveryStatus_State int32

Current state of discovery.

Asset_DiscoveryStatus_STATE_UNSPECIFIED, Asset_DiscoveryStatus_SCHEDULED, Asset_DiscoveryStatus_IN_PROGRESS, Asset_DiscoveryStatus_PAUSED, Asset_DiscoveryStatus_DISABLED

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

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

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

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

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}`
	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

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

Asset_ResourceSpec_Type

type Asset_ResourceSpec_Type int32

Type of resource.

Asset_ResourceSpec_TYPE_UNSPECIFIED, Asset_ResourceSpec_STORAGE_BUCKET, Asset_ResourceSpec_BIGQUERY_DATASET

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

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

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 *timestamp.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

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

Asset_ResourceStatus_State

type Asset_ResourceStatus_State int32

The state of a resource.

Asset_ResourceStatus_STATE_UNSPECIFIED, Asset_ResourceStatus_READY, Asset_ResourceStatus_ERROR

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

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

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 *timestamp.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

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

Asset_SecurityStatus_State

type Asset_SecurityStatus_State int32

The state of the security policy.

Asset_SecurityStatus_STATE_UNSPECIFIED, Asset_SecurityStatus_READY, Asset_SecurityStatus_APPLYING, Asset_SecurityStatus_ERROR

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

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

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

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

Content

type Content struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`

	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`

	CreateTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`

	Data isContent_Data `protobuf_oneof:"data"`

	Content isContent_Content `protobuf_oneof:"content"`

}

Content represents a user-visible notebook or a sql script

func (*Content) Descriptor

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

Deprecated: Use Content.ProtoReflect.Descriptor instead.

func (*Content) GetContent

func (m *Content) GetContent() isContent_Content

func (*Content) GetCreateTime

func (x *Content) GetCreateTime() *timestamp.Timestamp

func (*Content) GetData

func (m *Content) GetData() isContent_Data

func (*Content) GetDataText

func (x *Content) GetDataText() string

func (*Content) GetDescription

func (x *Content) GetDescription() string

func (*Content) GetLabels

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

func (*Content) GetName

func (x *Content) GetName() string

func (*Content) GetNotebook

func (x *Content) GetNotebook() *Content_Notebook

func (*Content) GetPath

func (x *Content) GetPath() string

func (*Content) GetSqlScript

func (x *Content) GetSqlScript() *Content_SqlScript

func (*Content) GetUid

func (x *Content) GetUid() string

func (*Content) GetUpdateTime

func (x *Content) GetUpdateTime() *timestamp.Timestamp

func (*Content) ProtoMessage

func (*Content) ProtoMessage()

func (*Content) ProtoReflect

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

func (*Content) Reset

func (x *Content) Reset()

func (*Content) String

func (x *Content) String() string

ContentServiceClient

type ContentServiceClient interface {
	// Create a content.
	CreateContent(ctx context.Context, in *CreateContentRequest, opts ...grpc.CallOption) (*Content, error)
	// Update a content. Only supports full resource update.
	UpdateContent(ctx context.Context, in *UpdateContentRequest, opts ...grpc.CallOption) (*Content, error)
	// Delete a content.
	DeleteContent(ctx context.Context, in *DeleteContentRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Get a content resource.
	GetContent(ctx context.Context, in *GetContentRequest, opts ...grpc.CallOption) (*Content, error)
	// Gets the access control policy for a contentitem resource. A `NOT_FOUND`
	// error is returned if the resource does not exist. An empty policy is
	// returned if the resource exists but does not have a policy set on it.
	//
	// Caller must have Google IAM `dataplex.content.getIamPolicy` permission
	// on the resource.
	GetIamPolicy(ctx context.Context, in *v1.GetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error)
	// Sets the access control policy on the specified contentitem resource.
	// Replaces any existing policy.
	//
	// Caller must have Google IAM `dataplex.content.setIamPolicy` permission
	// on the resource.
	SetIamPolicy(ctx context.Context, in *v1.SetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error)
	// Returns the caller's permissions on a resource.
	// If the resource does not exist, an empty set of
	// permissions is returned (a `NOT_FOUND` error is not returned).
	//
	// A caller is not required to have Google IAM permission to make this
	// request.
	//
	// Note: This operation is designed to be used for building permission-aware
	// UIs and command-line tools, not for authorization checking. This operation
	// may "fail open" without warning.
	TestIamPermissions(ctx context.Context, in *v1.TestIamPermissionsRequest, opts ...grpc.CallOption) (*v1.TestIamPermissionsResponse, error)
	// List content.
	ListContent(ctx context.Context, in *ListContentRequest, opts ...grpc.CallOption) (*ListContentResponse, error)
}

ContentServiceClient is the client API for ContentService service.

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

func NewContentServiceClient

func NewContentServiceClient(cc grpc.ClientConnInterface) ContentServiceClient

ContentServiceServer

type ContentServiceServer interface {
	// Create a content.
	CreateContent(context.Context, *CreateContentRequest) (*Content, error)
	// Update a content. Only supports full resource update.
	UpdateContent(context.Context, *UpdateContentRequest) (*Content, error)
	// Delete a content.
	DeleteContent(context.Context, *DeleteContentRequest) (*empty.Empty, error)
	// Get a content resource.
	GetContent(context.Context, *GetContentRequest) (*Content, error)
	// Gets the access control policy for a contentitem resource. A `NOT_FOUND`
	// error is returned if the resource does not exist. An empty policy is
	// returned if the resource exists but does not have a policy set on it.
	//
	// Caller must have Google IAM `dataplex.content.getIamPolicy` permission
	// on the resource.
	GetIamPolicy(context.Context, *v1.GetIamPolicyRequest) (*v1.Policy, error)
	// Sets the access control policy on the specified contentitem resource.
	// Replaces any existing policy.
	//
	// Caller must have Google IAM `dataplex.content.setIamPolicy` permission
	// on the resource.
	SetIamPolicy(context.Context, *v1.SetIamPolicyRequest) (*v1.Policy, error)
	// Returns the caller's permissions on a resource.
	// If the resource does not exist, an empty set of
	// permissions is returned (a `NOT_FOUND` error is not returned).
	//
	// A caller is not required to have Google IAM permission to make this
	// request.
	//
	// Note: This operation is designed to be used for building permission-aware
	// UIs and command-line tools, not for authorization checking. This operation
	// may "fail open" without warning.
	TestIamPermissions(context.Context, *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error)
	// List content.
	ListContent(context.Context, *ListContentRequest) (*ListContentResponse, error)
}

ContentServiceServer is the server API for ContentService service.

Content_DataText

type Content_DataText struct {
	// Required. Content data in string format.
	DataText string `protobuf:"bytes,9,opt,name=data_text,json=dataText,proto3,oneof"`
}

Content_Notebook

type Content_Notebook struct {
	KernelType Content_Notebook_KernelType "" /* 150 byte string literal not displayed */

}

Configuration for Notebook content.

func (*Content_Notebook) Descriptor

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

Deprecated: Use Content_Notebook.ProtoReflect.Descriptor instead.

func (*Content_Notebook) GetKernelType

func (x *Content_Notebook) GetKernelType() Content_Notebook_KernelType

func (*Content_Notebook) ProtoMessage

func (*Content_Notebook) ProtoMessage()

func (*Content_Notebook) ProtoReflect

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

func (*Content_Notebook) Reset

func (x *Content_Notebook) Reset()

func (*Content_Notebook) String

func (x *Content_Notebook) String() string

Content_Notebook_

type Content_Notebook_ struct {
	// Notebook related configurations.
	Notebook *Content_Notebook `protobuf:"bytes,101,opt,name=notebook,proto3,oneof"`
}

Content_Notebook_KernelType

type Content_Notebook_KernelType int32

Kernel Type of the Jupyter notebook.

Content_Notebook_KERNEL_TYPE_UNSPECIFIED, Content_Notebook_PYTHON3

const (
	// Kernel Type unspecified.
	Content_Notebook_KERNEL_TYPE_UNSPECIFIED Content_Notebook_KernelType = 0
	// Python 3 Kernel.
	Content_Notebook_PYTHON3 Content_Notebook_KernelType = 1
)

func (Content_Notebook_KernelType) Descriptor

func (Content_Notebook_KernelType) Descriptor() protoreflect.EnumDescriptor

func (Content_Notebook_KernelType) Enum

func (x Content_Notebook_KernelType) Enum() *Content_Notebook_KernelType

func (Content_Notebook_KernelType) EnumDescriptor

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

Deprecated: Use Content_Notebook_KernelType.Descriptor instead.

func (Content_Notebook_KernelType) Number

func (x Content_Notebook_KernelType) Number() protoreflect.EnumNumber

func (Content_Notebook_KernelType) String

func (x Content_Notebook_KernelType) String() string

func (Content_Notebook_KernelType) Type

func (Content_Notebook_KernelType) Type() protoreflect.EnumType

Content_SqlScript

type Content_SqlScript struct {

	// Required. Query Engine to be used for the Sql Query.
	Engine Content_SqlScript_QueryEngine `protobuf:"varint,1,opt,name=engine,proto3,enum=google.cloud.dataplex.v1.Content_SqlScript_QueryEngine" json:"engine,omitempty"`
	// contains filtered or unexported fields
}

Configuration for the Sql Script content.

func (*Content_SqlScript) Descriptor

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

Deprecated: Use Content_SqlScript.ProtoReflect.Descriptor instead.

func (*Content_SqlScript) GetEngine

func (x *Content_SqlScript) GetEngine() Content_SqlScript_QueryEngine

func (*Content_SqlScript) ProtoMessage

func (*Content_SqlScript) ProtoMessage()

func (*Content_SqlScript) ProtoReflect

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

func (*Content_SqlScript) Reset

func (x *Content_SqlScript) Reset()

func (*Content_SqlScript) String

func (x *Content_SqlScript) String() string

Content_SqlScript_

type Content_SqlScript_ struct {
	// Sql Script related configurations.
	SqlScript *Content_SqlScript `protobuf:"bytes,100,opt,name=sql_script,json=sqlScript,proto3,oneof"`
}

Content_SqlScript_QueryEngine

type Content_SqlScript_QueryEngine int32

Query Engine Type of the SQL Script.

Content_SqlScript_QUERY_ENGINE_UNSPECIFIED, Content_SqlScript_SPARK

const (
	// Value was unspecified.
	Content_SqlScript_QUERY_ENGINE_UNSPECIFIED Content_SqlScript_QueryEngine = 0
	// Spark SQL Query.
	Content_SqlScript_SPARK Content_SqlScript_QueryEngine = 2
)

func (Content_SqlScript_QueryEngine) Descriptor

func (Content_SqlScript_QueryEngine) Descriptor() protoreflect.EnumDescriptor

func (Content_SqlScript_QueryEngine) Enum

func (x Content_SqlScript_QueryEngine) Enum() *Content_SqlScript_QueryEngine

func (Content_SqlScript_QueryEngine) EnumDescriptor

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

Deprecated: Use Content_SqlScript_QueryEngine.Descriptor instead.

func (Content_SqlScript_QueryEngine) Number

func (x Content_SqlScript_QueryEngine) Number() protoreflect.EnumNumber

func (Content_SqlScript_QueryEngine) String

func (x Content_SqlScript_QueryEngine) String() string

func (Content_SqlScript_QueryEngine) Type

func (Content_SqlScript_QueryEngine) Type() protoreflect.EnumType

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

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

CreateContentRequest

type CreateContentRequest struct {

	// Required. The resource name of the parent lake:
	// projects/{project_id}/locations/{location_id}/lakes/{lake_id}
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Content resource.
	Content *Content `protobuf:"bytes,2,opt,name=content,proto3" json:"content,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
}

Create content request.

func (*CreateContentRequest) Descriptor

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

Deprecated: Use CreateContentRequest.ProtoReflect.Descriptor instead.

func (*CreateContentRequest) GetContent

func (x *CreateContentRequest) GetContent() *Content

func (*CreateContentRequest) GetParent

func (x *CreateContentRequest) GetParent() string

func (*CreateContentRequest) GetValidateOnly

func (x *CreateContentRequest) GetValidateOnly() bool

func (*CreateContentRequest) ProtoMessage

func (*CreateContentRequest) ProtoMessage()

func (*CreateContentRequest) ProtoReflect

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

func (*CreateContentRequest) Reset

func (x *CreateContentRequest) Reset()

func (*CreateContentRequest) String

func (x *CreateContentRequest) String() string

CreateEntityRequest

type CreateEntityRequest 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. Entity resource.
	Entity *Entity `protobuf:"bytes,3,opt,name=entity,proto3" json:"entity,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 a metadata entity request.

func (*CreateEntityRequest) Descriptor

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

Deprecated: Use CreateEntityRequest.ProtoReflect.Descriptor instead.

func (*CreateEntityRequest) GetEntity

func (x *CreateEntityRequest) GetEntity() *Entity

func (*CreateEntityRequest) GetParent

func (x *CreateEntityRequest) GetParent() string

func (*CreateEntityRequest) GetValidateOnly

func (x *CreateEntityRequest) GetValidateOnly() bool

func (*CreateEntityRequest) ProtoMessage

func (*CreateEntityRequest) ProtoMessage()

func (*CreateEntityRequest) ProtoReflect

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

func (*CreateEntityRequest) Reset

func (x *CreateEntityRequest) Reset()

func (*CreateEntityRequest) String

func (x *CreateEntityRequest) String() string

CreateEnvironmentRequest

type CreateEnvironmentRequest struct {

	// Required. The resource name of the parent lake:
	// `projects/{project_id}/locations/{location_id}/lakes/{lake_id}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Environment identifier.
	// * Must contain only lowercase letters, numbers and hyphens.
	// * Must start with a letter.
	// * Must be between 1-63 characters.
	// * Must end with a number or a letter.
	// * Must be unique within the lake.
	EnvironmentId string `protobuf:"bytes,2,opt,name=environment_id,json=environmentId,proto3" json:"environment_id,omitempty"`
	// Required. Environment resource.
	Environment *Environment `protobuf:"bytes,3,opt,name=environment,proto3" json:"environment,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 environment request.

func (*CreateEnvironmentRequest) Descriptor

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

Deprecated: Use CreateEnvironmentRequest.ProtoReflect.Descriptor instead.

func (*CreateEnvironmentRequest) GetEnvironment

func (x *CreateEnvironmentRequest) GetEnvironment() *Environment

func (*CreateEnvironmentRequest) GetEnvironmentId

func (x *CreateEnvironmentRequest) GetEnvironmentId() string

func (*CreateEnvironmentRequest) GetParent

func (x *CreateEnvironmentRequest) GetParent() string

func (*CreateEnvironmentRequest) GetValidateOnly

func (x *CreateEnvironmentRequest) GetValidateOnly() bool

func (*CreateEnvironmentRequest) ProtoMessage

func (*CreateEnvironmentRequest) ProtoMessage()

func (*CreateEnvironmentRequest) ProtoReflect

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

func (*CreateEnvironmentRequest) Reset

func (x *CreateEnvironmentRequest) Reset()

func (*CreateEnvironmentRequest) String

func (x *CreateEnvironmentRequest) String() string

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

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

CreatePartitionRequest

type CreatePartitionRequest struct {

	// Required. The resource name of the parent zone:
	// `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"`
	// Required. Partition resource.
	Partition *Partition `protobuf:"bytes,3,opt,name=partition,proto3" json:"partition,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 metadata partition request.

func (*CreatePartitionRequest) Descriptor

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

Deprecated: Use CreatePartitionRequest.ProtoReflect.Descriptor instead.

func (*CreatePartitionRequest) GetParent

func (x *CreatePartitionRequest) GetParent() string

func (*CreatePartitionRequest) GetPartition

func (x *CreatePartitionRequest) GetPartition() *Partition

func (*CreatePartitionRequest) GetValidateOnly

func (x *CreatePartitionRequest) GetValidateOnly() bool

func (*CreatePartitionRequest) ProtoMessage

func (*CreatePartitionRequest) ProtoMessage()

func (*CreatePartitionRequest) ProtoReflect

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

func (*CreatePartitionRequest) Reset

func (x *CreatePartitionRequest) Reset()

func (*CreatePartitionRequest) String

func (x *CreatePartitionRequest) String() string

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

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

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

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

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) (*empty.Empty, error)
	// Create an environment resource.
	CreateEnvironment(ctx context.Context, in *CreateEnvironmentRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Update the environment resource.
	UpdateEnvironment(ctx context.Context, in *UpdateEnvironmentRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Delete the environment resource. All the child resources must have been
	// deleted before environment deletion can be initiated.
	DeleteEnvironment(ctx context.Context, in *DeleteEnvironmentRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Lists environments under the given lake.
	ListEnvironments(ctx context.Context, in *ListEnvironmentsRequest, opts ...grpc.CallOption) (*ListEnvironmentsResponse, error)
	// Get environment resource.
	GetEnvironment(ctx context.Context, in *GetEnvironmentRequest, opts ...grpc.CallOption) (*Environment, error)
	// Lists session resources in an environment.
	ListSessions(ctx context.Context, in *ListSessionsRequest, opts ...grpc.CallOption) (*ListSessionsResponse, 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

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) (*empty.Empty, error)
	// Create an environment resource.
	CreateEnvironment(context.Context, *CreateEnvironmentRequest) (*longrunning.Operation, error)
	// Update the environment resource.
	UpdateEnvironment(context.Context, *UpdateEnvironmentRequest) (*longrunning.Operation, error)
	// Delete the environment resource. All the child resources must have been
	// deleted before environment deletion can be initiated.
	DeleteEnvironment(context.Context, *DeleteEnvironmentRequest) (*longrunning.Operation, error)
	// Lists environments under the given lake.
	ListEnvironments(context.Context, *ListEnvironmentsRequest) (*ListEnvironmentsResponse, error)
	// Get environment resource.
	GetEnvironment(context.Context, *GetEnvironmentRequest) (*Environment, error)
	// Lists session resources in an environment.
	ListSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, error)
}

DataplexServiceServer is the server API for DataplexService service.

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

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

DeleteContentRequest

type DeleteContentRequest struct {

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

Delete content request.

func (*DeleteContentRequest) Descriptor

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

Deprecated: Use DeleteContentRequest.ProtoReflect.Descriptor instead.

func (*DeleteContentRequest) GetName

func (x *DeleteContentRequest) GetName() string

func (*DeleteContentRequest) ProtoMessage

func (*DeleteContentRequest) ProtoMessage()

func (*DeleteContentRequest) ProtoReflect

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

func (*DeleteContentRequest) Reset

func (x *DeleteContentRequest) Reset()

func (*DeleteContentRequest) String

func (x *DeleteContentRequest) String() string

DeleteEntityRequest

type DeleteEntityRequest 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"`
	// Required. The etag associated with the entity, which can be retrieved with a
	// [GetEntity][] request.
	Etag string `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

Delete a metadata entity request.

func (*DeleteEntityRequest) Descriptor

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

Deprecated: Use DeleteEntityRequest.ProtoReflect.Descriptor instead.

func (*DeleteEntityRequest) GetEtag

func (x *DeleteEntityRequest) GetEtag() string

func (*DeleteEntityRequest) GetName

func (x *DeleteEntityRequest) GetName() string

func (*DeleteEntityRequest) ProtoMessage

func (*DeleteEntityRequest) ProtoMessage()

func (*DeleteEntityRequest) ProtoReflect

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

func (*DeleteEntityRequest) Reset

func (x *DeleteEntityRequest) Reset()

func (*DeleteEntityRequest) String

func (x *DeleteEntityRequest) String() string

DeleteEnvironmentRequest

type DeleteEnvironmentRequest struct {

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

Delete environment request.

func (*DeleteEnvironmentRequest) Descriptor

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

Deprecated: Use DeleteEnvironmentRequest.ProtoReflect.Descriptor instead.

func (*DeleteEnvironmentRequest) GetName

func (x *DeleteEnvironmentRequest) GetName() string

func (*DeleteEnvironmentRequest) ProtoMessage

func (*DeleteEnvironmentRequest) ProtoMessage()

func (*DeleteEnvironmentRequest) ProtoReflect

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

func (*DeleteEnvironmentRequest) Reset

func (x *DeleteEnvironmentRequest) Reset()

func (*DeleteEnvironmentRequest) String

func (x *DeleteEnvironmentRequest) String() string

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

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

DeletePartitionRequest

type DeletePartitionRequest struct {

	// Required. The resource name of the partition.
	// format:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/entities/{entity_id}/partitions/{partition_value_path}`.
	// The {partition_value_path} segment consists of an ordered sequence of
	// partition values separated by "/". All values must be provided.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. The etag associated with the partition.
	//
	// Deprecated: Do not use.
	Etag string `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

Delete metadata partition request.

func (*DeletePartitionRequest) Descriptor

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

Deprecated: Use DeletePartitionRequest.ProtoReflect.Descriptor instead.

func (*DeletePartitionRequest) GetEtag

func (x *DeletePartitionRequest) GetEtag() string

Deprecated: Do not use.

func (*DeletePartitionRequest) GetName

func (x *DeletePartitionRequest) GetName() string

func (*DeletePartitionRequest) ProtoMessage

func (*DeletePartitionRequest) ProtoMessage()

func (*DeletePartitionRequest) ProtoReflect

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

func (*DeletePartitionRequest) Reset

func (x *DeletePartitionRequest) Reset()

func (*DeletePartitionRequest) String

func (x *DeletePartitionRequest) String() string

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

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

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

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

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

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

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"`
}

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

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

DiscoveryEvent_Config

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

DiscoveryEvent_ConfigDetails

type DiscoveryEvent_ConfigDetails struct {
	Parameters map[string]string "" /* 161 byte string literal not displayed */

}

Details about configuration events.

func (*DiscoveryEvent_ConfigDetails) Descriptor

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

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"`
}

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

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

DiscoveryEvent_EntityType

type DiscoveryEvent_EntityType int32

The type of the entity.

DiscoveryEvent_ENTITY_TYPE_UNSPECIFIED, DiscoveryEvent_TABLE, DiscoveryEvent_FILESET

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

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

DiscoveryEvent_EventType

type DiscoveryEvent_EventType int32

The type of the event.

DiscoveryEvent_EVENT_TYPE_UNSPECIFIED, DiscoveryEvent_CONFIG, DiscoveryEvent_ENTITY_CREATED, DiscoveryEvent_ENTITY_UPDATED, DiscoveryEvent_ENTITY_DELETED, DiscoveryEvent_PARTITION_CREATED, DiscoveryEvent_PARTITION_UPDATED, DiscoveryEvent_PARTITION_DELETED

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

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

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"`
}

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"`
	// The locations of the data items (e.g., a Cloud Storage objects) sampled
	// for metadata inference.
	SampledDataLocations []string `protobuf:"bytes,4,rep,name=sampled_data_locations,json=sampledDataLocations,proto3" json:"sampled_data_locations,omitempty"`
	// contains filtered or unexported fields
}

Details about the partition.

func (*DiscoveryEvent_PartitionDetails) Descriptor

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

func (x *DiscoveryEvent_PartitionDetails) GetSampledDataLocations() []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

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. Display name must be shorter than or equal to 256 characters.
	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Optional. User friendly longer description text. Must be shorter than or equal to
	// 1024 characters.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Output only. The time when the entity was created.
	CreateTime *timestamp.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 *timestamp.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.
	// The ID must contain only letters (a-z, A-Z), numbers (0-9), and
	// underscores. Must begin with a letter and consist of 256 or fewer
	// characters.
	Id string `protobuf:"bytes,7,opt,name=id,proto3" json:"id,omitempty"`
	// Optional. The etag associated with the entity, which can be retrieved with a
	// [GetEntity][] request. Required for update and delete requests.
	Etag string `protobuf:"bytes,8,opt,name=etag,proto3" json:"etag,omitempty"`
	// Required. Immutable. 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. Immutable. The ID of the asset associated with the storage location containing the
	// entity data. The entity must be with in the same zone with the asset.
	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. Immutable. 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

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

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

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

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

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

Entity_Type

type Entity_Type int32

The type of entity.

Entity_TYPE_UNSPECIFIED, Entity_TABLE, Entity_FILESET

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

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

Environment

type Environment struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`

	Uid string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"`

	CreateTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`

	State State `protobuf:"varint,8,opt,name=state,proto3,enum=google.cloud.dataplex.v1.State" json:"state,omitempty"`

	InfrastructureSpec *Environment_InfrastructureSpec `protobuf:"bytes,100,opt,name=infrastructure_spec,json=infrastructureSpec,proto3" json:"infrastructure_spec,omitempty"`

	SessionSpec *Environment_SessionSpec `protobuf:"bytes,101,opt,name=session_spec,json=sessionSpec,proto3" json:"session_spec,omitempty"`

	SessionStatus *Environment_SessionStatus `protobuf:"bytes,102,opt,name=session_status,json=sessionStatus,proto3" json:"session_status,omitempty"`

	Endpoints *Environment_Endpoints `protobuf:"bytes,200,opt,name=endpoints,proto3" json:"endpoints,omitempty"`

}

Environment represents a user-visible compute infrastructure for analytics within a lake.

func (*Environment) Descriptor

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

Deprecated: Use Environment.ProtoReflect.Descriptor instead.

func (*Environment) GetCreateTime

func (x *Environment) GetCreateTime() *timestamp.Timestamp

func (*Environment) GetDescription

func (x *Environment) GetDescription() string

func (*Environment) GetDisplayName

func (x *Environment) GetDisplayName() string

func (*Environment) GetEndpoints

func (x *Environment) GetEndpoints() *Environment_Endpoints

func (*Environment) GetInfrastructureSpec

func (x *Environment) GetInfrastructureSpec() *Environment_InfrastructureSpec

func (*Environment) GetLabels

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

func (*Environment) GetName

func (x *Environment) GetName() string

func (*Environment) GetSessionSpec

func (x *Environment) GetSessionSpec() *Environment_SessionSpec

func (*Environment) GetSessionStatus

func (x *Environment) GetSessionStatus() *Environment_SessionStatus

func (*Environment) GetState

func (x *Environment) GetState() State

func (*Environment) GetUid

func (x *Environment) GetUid() string

func (*Environment) GetUpdateTime

func (x *Environment) GetUpdateTime() *timestamp.Timestamp

func (*Environment) ProtoMessage

func (*Environment) ProtoMessage()

func (*Environment) ProtoReflect

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

func (*Environment) Reset

func (x *Environment) Reset()

func (*Environment) String

func (x *Environment) String() string

Environment_Endpoints

type Environment_Endpoints struct {

	// Output only. URI to serve notebook APIs
	Notebooks string `protobuf:"bytes,1,opt,name=notebooks,proto3" json:"notebooks,omitempty"`
	// Output only. URI to serve SQL APIs
	Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	// contains filtered or unexported fields
}

func (*Environment_Endpoints) Descriptor

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

Deprecated: Use Environment_Endpoints.ProtoReflect.Descriptor instead.

func (*Environment_Endpoints) GetNotebooks

func (x *Environment_Endpoints) GetNotebooks() string

func (*Environment_Endpoints) GetSql

func (x *Environment_Endpoints) GetSql() string

func (*Environment_Endpoints) ProtoMessage

func (*Environment_Endpoints) ProtoMessage()

func (*Environment_Endpoints) ProtoReflect

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

func (*Environment_Endpoints) Reset

func (x *Environment_Endpoints) Reset()

func (*Environment_Endpoints) String

func (x *Environment_Endpoints) String() string

Environment_InfrastructureSpec

type Environment_InfrastructureSpec struct {

	// Hardware config
	//
	// Types that are assignable to Resources:
	//
	//	*Environment_InfrastructureSpec_Compute
	Resources isEnvironment_InfrastructureSpec_Resources `protobuf_oneof:"resources"`
	// Software config
	//
	// Types that are assignable to Runtime:
	//
	//	*Environment_InfrastructureSpec_OsImage
	Runtime isEnvironment_InfrastructureSpec_Runtime `protobuf_oneof:"runtime"`
	// contains filtered or unexported fields
}

Configuration for the underlying infrastructure used to run workloads.

func (*Environment_InfrastructureSpec) Descriptor

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

Deprecated: Use Environment_InfrastructureSpec.ProtoReflect.Descriptor instead.

func (*Environment_InfrastructureSpec) GetCompute

func (x *Environment_InfrastructureSpec) GetCompute() *Environment_InfrastructureSpec_ComputeResources

func (*Environment_InfrastructureSpec) GetOsImage

func (x *Environment_InfrastructureSpec) GetOsImage() *Environment_InfrastructureSpec_OsImageRuntime

func (*Environment_InfrastructureSpec) GetResources

func (m *Environment_InfrastructureSpec) GetResources() isEnvironment_InfrastructureSpec_Resources

func (*Environment_InfrastructureSpec) GetRuntime

func (m *Environment_InfrastructureSpec) GetRuntime() isEnvironment_InfrastructureSpec_Runtime

func (*Environment_InfrastructureSpec) ProtoMessage

func (*Environment_InfrastructureSpec) ProtoMessage()

func (*Environment_InfrastructureSpec) ProtoReflect

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

func (*Environment_InfrastructureSpec) Reset

func (x *Environment_InfrastructureSpec) Reset()

func (*Environment_InfrastructureSpec) String

func (x *Environment_InfrastructureSpec) String() string

Environment_InfrastructureSpec_Compute

type Environment_InfrastructureSpec_Compute struct {
	// Optional. Compute resources needed for analyze interactive workloads.
	Compute *Environment_InfrastructureSpec_ComputeResources `protobuf:"bytes,50,opt,name=compute,proto3,oneof"`
}

Environment_InfrastructureSpec_ComputeResources

type Environment_InfrastructureSpec_ComputeResources struct {

	// Optional. Size in GB of the disk. Default is 100 GB.
	DiskSizeGb int32 `protobuf:"varint,1,opt,name=disk_size_gb,json=diskSizeGb,proto3" json:"disk_size_gb,omitempty"`
	// Optional. Total number of nodes in the sessions created for this environment.
	NodeCount int32 `protobuf:"varint,2,opt,name=node_count,json=nodeCount,proto3" json:"node_count,omitempty"`
	// Optional. Max configurable nodes.
	// If max_node_count > node_count, then auto-scaling is enabled.
	MaxNodeCount int32 `protobuf:"varint,3,opt,name=max_node_count,json=maxNodeCount,proto3" json:"max_node_count,omitempty"`
	// contains filtered or unexported fields
}

Compute resources associated with the analyze interactive workloads.

func (*Environment_InfrastructureSpec_ComputeResources) Descriptor

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

Deprecated: Use Environment_InfrastructureSpec_ComputeResources.ProtoReflect.Descriptor instead.

func (*Environment_InfrastructureSpec_ComputeResources) GetDiskSizeGb

func (x *Environment_InfrastructureSpec_ComputeResources) GetDiskSizeGb() int32

func (*Environment_InfrastructureSpec_ComputeResources) GetMaxNodeCount

func (x *Environment_InfrastructureSpec_ComputeResources) GetMaxNodeCount() int32

func (*Environment_InfrastructureSpec_ComputeResources) GetNodeCount

func (x *Environment_InfrastructureSpec_ComputeResources) GetNodeCount() int32

func (*Environment_InfrastructureSpec_ComputeResources) ProtoMessage

func (*Environment_InfrastructureSpec_ComputeResources) ProtoMessage()

func (*Environment_InfrastructureSpec_ComputeResources) ProtoReflect

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

func (*Environment_InfrastructureSpec_ComputeResources) Reset

func (x *Environment_InfrastructureSpec_ComputeResources) Reset()

func (*Environment_InfrastructureSpec_ComputeResources) String

func (x *Environment_InfrastructureSpec_ComputeResources) String() string

Environment_InfrastructureSpec_OsImage

type Environment_InfrastructureSpec_OsImage struct {
	// Required. Software Runtime Configuration for analyze interactive workloads.
	OsImage *Environment_InfrastructureSpec_OsImageRuntime `protobuf:"bytes,100,opt,name=os_image,json=osImage,proto3,oneof"`
}

Environment_InfrastructureSpec_OsImageRuntime

type Environment_InfrastructureSpec_OsImageRuntime struct {
	ImageVersion string `protobuf:"bytes,1,opt,name=image_version,json=imageVersion,proto3" json:"image_version,omitempty"`

	JavaLibraries []string `protobuf:"bytes,2,rep,name=java_libraries,json=javaLibraries,proto3" json:"java_libraries,omitempty"`

	PythonPackages []string `protobuf:"bytes,3,rep,name=python_packages,json=pythonPackages,proto3" json:"python_packages,omitempty"`

	Properties map[string]string "" /* 161 byte string literal not displayed */

}

Software Runtime Configuration to run Analyze.

func (*Environment_InfrastructureSpec_OsImageRuntime) Descriptor

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

Deprecated: Use Environment_InfrastructureSpec_OsImageRuntime.ProtoReflect.Descriptor instead.

func (*Environment_InfrastructureSpec_OsImageRuntime) GetImageVersion

func (x *Environment_InfrastructureSpec_OsImageRuntime) GetImageVersion() string

func (*Environment_InfrastructureSpec_OsImageRuntime) GetJavaLibraries

func (x *Environment_InfrastructureSpec_OsImageRuntime) GetJavaLibraries() []string

func (*Environment_InfrastructureSpec_OsImageRuntime) GetProperties

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

func (*Environment_InfrastructureSpec_OsImageRuntime) GetPythonPackages

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

func (*Environment_InfrastructureSpec_OsImageRuntime) ProtoMessage

func (*Environment_InfrastructureSpec_OsImageRuntime) ProtoMessage()

func (*Environment_InfrastructureSpec_OsImageRuntime) ProtoReflect

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

func (*Environment_InfrastructureSpec_OsImageRuntime) Reset

func (x *Environment_InfrastructureSpec_OsImageRuntime) Reset()

func (*Environment_InfrastructureSpec_OsImageRuntime) String

func (x *Environment_InfrastructureSpec_OsImageRuntime) String() string

Environment_SessionSpec

type Environment_SessionSpec struct {

	// Optional. The idle time configuration of the session. The session will be
	// auto-terminated at the end of this period.
	MaxIdleDuration *duration.Duration `protobuf:"bytes,1,opt,name=max_idle_duration,json=maxIdleDuration,proto3" json:"max_idle_duration,omitempty"`
	// Optional. If True, this causes sessions to be pre-created and available for faster
	// startup to enable interactive exploration use-cases. This defaults to
	// False to avoid additional billed charges.
	// These can only be set to True for the environment with name set to
	// "default", and with default configuration.
	EnableFastStartup bool `protobuf:"varint,2,opt,name=enable_fast_startup,json=enableFastStartup,proto3" json:"enable_fast_startup,omitempty"`
	// contains filtered or unexported fields
}

func (*Environment_SessionSpec) Descriptor

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

Deprecated: Use Environment_SessionSpec.ProtoReflect.Descriptor instead.

func (*Environment_SessionSpec) GetEnableFastStartup

func (x *Environment_SessionSpec) GetEnableFastStartup() bool

func (*Environment_SessionSpec) GetMaxIdleDuration

func (x *Environment_SessionSpec) GetMaxIdleDuration() *duration.Duration

func (*Environment_SessionSpec) ProtoMessage

func (*Environment_SessionSpec) ProtoMessage()

func (*Environment_SessionSpec) ProtoReflect

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

func (*Environment_SessionSpec) Reset

func (x *Environment_SessionSpec) Reset()

func (*Environment_SessionSpec) String

func (x *Environment_SessionSpec) String() string

Environment_SessionStatus

type Environment_SessionStatus struct {

	// Output only. Queries over sessions to mark whether the environment is currently
	// active or not
	Active bool `protobuf:"varint,1,opt,name=active,proto3" json:"active,omitempty"`
	// contains filtered or unexported fields
}

func (*Environment_SessionStatus) Descriptor

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

Deprecated: Use Environment_SessionStatus.ProtoReflect.Descriptor instead.

func (*Environment_SessionStatus) GetActive

func (x *Environment_SessionStatus) GetActive() bool

func (*Environment_SessionStatus) ProtoMessage

func (*Environment_SessionStatus) ProtoMessage()

func (*Environment_SessionStatus) ProtoReflect

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

func (*Environment_SessionStatus) Reset

func (x *Environment_SessionStatus) Reset()

func (*Environment_SessionStatus) String

func (x *Environment_SessionStatus) String() string

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

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

GetContentRequest

type GetContentRequest struct {

	// Required. The resource name of the content:
	// projects/{project_id}/locations/{location_id}/lakes/{lake_id}/content/{content_id}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. Specify content view to make a partial request.
	View GetContentRequest_ContentView `protobuf:"varint,2,opt,name=view,proto3,enum=google.cloud.dataplex.v1.GetContentRequest_ContentView" json:"view,omitempty"`
	// contains filtered or unexported fields
}

Get content request.

func (*GetContentRequest) Descriptor

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

Deprecated: Use GetContentRequest.ProtoReflect.Descriptor instead.

func (*GetContentRequest) GetName

func (x *GetContentRequest) GetName() string

func (*GetContentRequest) GetView

func (x *GetContentRequest) GetView() GetContentRequest_ContentView

func (*GetContentRequest) ProtoMessage

func (*GetContentRequest) ProtoMessage()

func (*GetContentRequest) ProtoReflect

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

func (*GetContentRequest) Reset

func (x *GetContentRequest) Reset()

func (*GetContentRequest) String

func (x *GetContentRequest) String() string

GetContentRequest_ContentView

type GetContentRequest_ContentView int32

Specifies whether the request should return the full or the partial representation.

GetContentRequest_CONTENT_VIEW_UNSPECIFIED, GetContentRequest_BASIC, GetContentRequest_FULL

const (
	// Content view not specified. Defaults to BASIC.
	// The API will default to the BASIC view.
	GetContentRequest_CONTENT_VIEW_UNSPECIFIED GetContentRequest_ContentView = 0
	// Will not return the `data_text` field.
	GetContentRequest_BASIC GetContentRequest_ContentView = 1
	// Returns the complete proto.
	GetContentRequest_FULL GetContentRequest_ContentView = 2
)

func (GetContentRequest_ContentView) Descriptor

func (GetContentRequest_ContentView) Descriptor() protoreflect.EnumDescriptor

func (GetContentRequest_ContentView) Enum

func (x GetContentRequest_ContentView) Enum() *GetContentRequest_ContentView

func (GetContentRequest_ContentView) EnumDescriptor

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

Deprecated: Use GetContentRequest_ContentView.Descriptor instead.

func (GetContentRequest_ContentView) Number

func (x GetContentRequest_ContentView) Number() protoreflect.EnumNumber

func (GetContentRequest_ContentView) String

func (x GetContentRequest_ContentView) String() string

func (GetContentRequest_ContentView) Type

func (GetContentRequest_ContentView) Type() protoreflect.EnumType

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

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

GetEntityRequest_EntityView

type GetEntityRequest_EntityView int32

Entity views for get entity partial result.

GetEntityRequest_ENTITY_VIEW_UNSPECIFIED, GetEntityRequest_BASIC, GetEntityRequest_SCHEMA, GetEntityRequest_FULL

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. Currently, this is the same as the SCHEMA view.
	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

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

GetEnvironmentRequest

type GetEnvironmentRequest struct {

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

Get environment request.

func (*GetEnvironmentRequest) Descriptor

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

Deprecated: Use GetEnvironmentRequest.ProtoReflect.Descriptor instead.

func (*GetEnvironmentRequest) GetName

func (x *GetEnvironmentRequest) GetName() string

func (*GetEnvironmentRequest) ProtoMessage

func (*GetEnvironmentRequest) ProtoMessage()

func (*GetEnvironmentRequest) ProtoReflect

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

func (*GetEnvironmentRequest) Reset

func (x *GetEnvironmentRequest) Reset()

func (*GetEnvironmentRequest) String

func (x *GetEnvironmentRequest) String() string

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

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

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

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

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_value_path}`.
	// The {partition_value_path} segment consists of an ordered sequence of
	// partition values separated by "/". All values must be provided.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Get metadata partition request.

func (*GetPartitionRequest) Descriptor

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

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

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

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

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

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 *timestamp.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Output only. The time when the job ended.
	EndTime *timestamp.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

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetEndTime

func (x *Job) GetEndTime() *timestamp.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() *timestamp.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

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 *timestamp.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The time when the job ended running.
	EndTime *timestamp.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

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

Deprecated: Use JobEvent.ProtoReflect.Descriptor instead.

func (*JobEvent) GetEndTime

func (x *JobEvent) GetEndTime() *timestamp.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() *timestamp.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

JobEvent_Service

type JobEvent_Service int32

The service used to execute the job.

JobEvent_SERVICE_UNSPECIFIED, JobEvent_DATAPROC

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

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

JobEvent_State

type JobEvent_State int32

The completion status of the job.

JobEvent_STATE_UNSPECIFIED, JobEvent_SUCCEEDED, JobEvent_FAILED, JobEvent_CANCELLED, JobEvent_ABORTED

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

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

JobEvent_Type

type JobEvent_Type int32

The type of the job.

JobEvent_TYPE_UNSPECIFIED, JobEvent_SPARK, JobEvent_NOTEBOOK

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

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

Job_Service

type Job_Service int32

Job_SERVICE_UNSPECIFIED, Job_DATAPROC

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

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

Job_State

type Job_State int32

Job_STATE_UNSPECIFIED, Job_RUNNING, Job_CANCELLING, Job_CANCELLED, Job_SUCCEEDED, Job_FAILED, Job_ABORTED

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

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

Lake

type Lake struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`

	Uid string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"`

	CreateTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`

	State State `protobuf:"varint,8,opt,name=state,proto3,enum=google.cloud.dataplex.v1.State" json:"state,omitempty"`

	ServiceAccount string `protobuf:"bytes,9,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`

	Metastore *Lake_Metastore `protobuf:"bytes,102,opt,name=metastore,proto3" json:"metastore,omitempty"`

	AssetStatus *AssetStatus `protobuf:"bytes,103,opt,name=asset_status,json=assetStatus,proto3" json:"asset_status,omitempty"`

	MetastoreStatus *Lake_MetastoreStatus `protobuf:"bytes,104,opt,name=metastore_status,json=metastoreStatus,proto3" json:"metastore_status,omitempty"`

}

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

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

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

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

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 *timestamp.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

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

Lake_MetastoreStatus_State

type Lake_MetastoreStatus_State int32

Current state of association.

Lake_MetastoreStatus_STATE_UNSPECIFIED, Lake_MetastoreStatus_NONE, Lake_MetastoreStatus_READY, Lake_MetastoreStatus_UPDATING, Lake_MetastoreStatus_ERROR

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

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

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

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

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

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

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

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

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

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

ListContentRequest

type ListContentRequest struct {

	// Required. The resource name of the parent lake:
	// projects/{project_id}/locations/{location_id}/lakes/{lake_id}
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. Maximum number of content to return. The service may return fewer than
	// this value. If unspecified, at most 10 content 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 `ListContent` call. Provide this
	// to retrieve the subsequent page. When paginating, all other parameters
	// provided to `ListContent` 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. Filters are case-sensitive.
	// The following formats are supported:
	//
	// labels.key1 = "value1"
	// labels:key1
	// type = "NOTEBOOK"
	// type = "SQL_SCRIPT"
	//
	// These restrictions can be coinjoined with AND, OR and NOT conjunctions.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

List content request. Returns the BASIC Content view.

func (*ListContentRequest) Descriptor

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

Deprecated: Use ListContentRequest.ProtoReflect.Descriptor instead.

func (*ListContentRequest) GetFilter

func (x *ListContentRequest) GetFilter() string

func (*ListContentRequest) GetPageSize

func (x *ListContentRequest) GetPageSize() int32

func (*ListContentRequest) GetPageToken

func (x *ListContentRequest) GetPageToken() string

func (*ListContentRequest) GetParent

func (x *ListContentRequest) GetParent() string

func (*ListContentRequest) ProtoMessage

func (*ListContentRequest) ProtoMessage()

func (*ListContentRequest) ProtoReflect

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

func (*ListContentRequest) Reset

func (x *ListContentRequest) Reset()

func (*ListContentRequest) String

func (x *ListContentRequest) String() string

ListContentResponse

type ListContentResponse struct {

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

func (*ListContentResponse) Descriptor

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

Deprecated: Use ListContentResponse.ProtoReflect.Descriptor instead.

func (*ListContentResponse) GetContent

func (x *ListContentResponse) GetContent() []*Content

func (*ListContentResponse) GetNextPageToken

func (x *ListContentResponse) GetNextPageToken() string

func (*ListContentResponse) ProtoMessage

func (*ListContentResponse) ProtoMessage()

func (*ListContentResponse) ProtoReflect

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

func (*ListContentResponse) Reset

func (x *ListContentResponse) Reset()

func (*ListContentResponse) String

func (x *ListContentResponse) String() string

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, 100 entities will be returned by default. The
	// maximum value is 500; larger values will will be truncated to 500.
	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. The following filter parameters can be added to the URL to limit the
	// entities returned by the API:
	//
	// - Entity ID: ?filter="id=entityID"
	// - Asset ID: ?filter="asset=assetID"
	// - Data path ?filter="data_path=gs://my-bucket"
	// - Is HIVE compatible: ?filter="hive_compatible=true"
	// - Is BigQuery compatible: ?filter="bigquery_compatible=true"
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

List metadata entities request.

func (*ListEntitiesRequest) Descriptor

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

ListEntitiesRequest_EntityView

type ListEntitiesRequest_EntityView int32

Entity views.

ListEntitiesRequest_ENTITY_VIEW_UNSPECIFIED, ListEntitiesRequest_TABLES, ListEntitiesRequest_FILESETS

const (
	// The default unset value. Return both table and fileset entities
	// if unspecified.
	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

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

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

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

ListEnvironmentsRequest

type ListEnvironmentsRequest struct {

	// Required. The resource name of the parent lake:
	// `projects/{project_id}/locations/{location_id}/lakes/{lake_id}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. Maximum number of environments to return. The service may return fewer than
	// this value. If unspecified, at most 10 environments 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 `ListEnvironments` call. Provide this
	// to retrieve the subsequent page. When paginating, all other parameters
	// provided to `ListEnvironments` 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 environments request.

func (*ListEnvironmentsRequest) Descriptor

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

Deprecated: Use ListEnvironmentsRequest.ProtoReflect.Descriptor instead.

func (*ListEnvironmentsRequest) GetFilter

func (x *ListEnvironmentsRequest) GetFilter() string

func (*ListEnvironmentsRequest) GetOrderBy

func (x *ListEnvironmentsRequest) GetOrderBy() string

func (*ListEnvironmentsRequest) GetPageSize

func (x *ListEnvironmentsRequest) GetPageSize() int32

func (*ListEnvironmentsRequest) GetPageToken

func (x *ListEnvironmentsRequest) GetPageToken() string

func (*ListEnvironmentsRequest) GetParent

func (x *ListEnvironmentsRequest) GetParent() string

func (*ListEnvironmentsRequest) ProtoMessage

func (*ListEnvironmentsRequest) ProtoMessage()

func (*ListEnvironmentsRequest) ProtoReflect

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

func (*ListEnvironmentsRequest) Reset

func (x *ListEnvironmentsRequest) Reset()

func (*ListEnvironmentsRequest) String

func (x *ListEnvironmentsRequest) String() string

ListEnvironmentsResponse

type ListEnvironmentsResponse struct {

	// Environments under the given parent lake.
	Environments []*Environment `protobuf:"bytes,1,rep,name=environments,proto3" json:"environments,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 environments response.

func (*ListEnvironmentsResponse) Descriptor

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

Deprecated: Use ListEnvironmentsResponse.ProtoReflect.Descriptor instead.

func (*ListEnvironmentsResponse) GetEnvironments

func (x *ListEnvironmentsResponse) GetEnvironments() []*Environment

func (*ListEnvironmentsResponse) GetNextPageToken

func (x *ListEnvironmentsResponse) GetNextPageToken() string

func (*ListEnvironmentsResponse) ProtoMessage

func (*ListEnvironmentsResponse) ProtoMessage()

func (*ListEnvironmentsResponse) ProtoReflect

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

func (*ListEnvironmentsResponse) Reset

func (x *ListEnvironmentsResponse) Reset()

func (*ListEnvironmentsResponse) String

func (x *ListEnvironmentsResponse) String() string

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

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

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

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

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

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

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

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

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

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

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, 100 partitions will be returned by default. The
	// maximum page size is 500; larger values will will be truncated to 500.
	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 the partitions returned to the caller using a key value pair
	// expression. Supported operators and syntax:
	//
	// - logic operators: AND, OR
	// - comparison operators: <,>, >=, <= ,="," !="//" -="" like="" operators:="" -="" the="" right="" hand="" of="" a="" like="" operator="" supports="" "."="" and="" "*"="" for="" wildcard="" searches,="" for="" example="" "value1="" like="" ".*oo.*"="" -="" parenthetical="" grouping:="" (="" )="" sample="" filter="" expression:="" `?filter="key1 < value1 OR key2 > value2" **notes:**="" -="" keys="" to="" the="" left="" of="" operators="" are="" case="" insensitive.="" -="" partition="" results="" are="" sorted="" first="" by="" creation="" time,="" then="" by="" lexicographic="" order.="" -="" up="" to="" 20="" key="" value="" filter="" pairs="" are="" allowed,="" but="" due="" to="" performance="" considerations,="" only="" the="" first="" 10="" will="" be="" used="" as="" a="" filter.="" filter="">string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

List metadata partitions request.

func (*ListPartitionsRequest) Descriptor

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

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

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

ListSessionsRequest

type ListSessionsRequest struct {

	// Required. The resource name of the parent environment:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/environment/{environment_id}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. Maximum number of sessions to return. The service may return fewer than
	// this value. If unspecified, at most 10 sessions 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 `ListSessions` call. Provide this to
	// retrieve the subsequent page. When paginating, all other parameters
	// provided to `ListSessions` 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. The following `mode` filter is supported to return only the
	// sessions belonging to the requester when the mode is USER and return
	// sessions of all the users when the mode is ADMIN. When no filter is sent
	// default to USER mode.
	// NOTE: When the mode is ADMIN, the requester should have
	// `dataplex.environments.listAllSessions` permission to list all sessions,
	// in absence of the permission, the request fails.
	//
	// mode = ADMIN | USER
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

List sessions request.

func (*ListSessionsRequest) Descriptor

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

Deprecated: Use ListSessionsRequest.ProtoReflect.Descriptor instead.

func (*ListSessionsRequest) GetFilter

func (x *ListSessionsRequest) GetFilter() string

func (*ListSessionsRequest) GetPageSize

func (x *ListSessionsRequest) GetPageSize() int32

func (*ListSessionsRequest) GetPageToken

func (x *ListSessionsRequest) GetPageToken() string

func (*ListSessionsRequest) GetParent

func (x *ListSessionsRequest) GetParent() string

func (*ListSessionsRequest) ProtoMessage

func (*ListSessionsRequest) ProtoMessage()

func (*ListSessionsRequest) ProtoReflect

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

func (*ListSessionsRequest) Reset

func (x *ListSessionsRequest) Reset()

func (*ListSessionsRequest) String

func (x *ListSessionsRequest) String() string

ListSessionsResponse

type ListSessionsResponse struct {

	// Sessions under a given environment.
	Sessions []*Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,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 sessions response.

func (*ListSessionsResponse) Descriptor

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

Deprecated: Use ListSessionsResponse.ProtoReflect.Descriptor instead.

func (*ListSessionsResponse) GetNextPageToken

func (x *ListSessionsResponse) GetNextPageToken() string

func (*ListSessionsResponse) GetSessions

func (x *ListSessionsResponse) GetSessions() []*Session

func (*ListSessionsResponse) ProtoMessage

func (*ListSessionsResponse) ProtoMessage()

func (*ListSessionsResponse) ProtoReflect

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

func (*ListSessionsResponse) Reset

func (x *ListSessionsResponse) Reset()

func (*ListSessionsResponse) String

func (x *ListSessionsResponse) String() string

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

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

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

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

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

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

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

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

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

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

MetadataServiceClient

type MetadataServiceClient interface {
	// Create a metadata entity.
	CreateEntity(ctx context.Context, in *CreateEntityRequest, opts ...grpc.CallOption) (*Entity, error)
	// Update a metadata entity. Only supports full resource update.
	UpdateEntity(ctx context.Context, in *UpdateEntityRequest, opts ...grpc.CallOption) (*Entity, error)
	// Delete a metadata entity.
	DeleteEntity(ctx context.Context, in *DeleteEntityRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// 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)
	// Create a metadata partition.
	CreatePartition(ctx context.Context, in *CreatePartitionRequest, opts ...grpc.CallOption) (*Partition, error)
	// Delete a metadata partition.
	DeletePartition(ctx context.Context, in *DeletePartitionRequest, opts ...grpc.CallOption) (*empty.Empty, 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

MetadataServiceServer

type MetadataServiceServer interface {
	// Create a metadata entity.
	CreateEntity(context.Context, *CreateEntityRequest) (*Entity, error)
	// Update a metadata entity. Only supports full resource update.
	UpdateEntity(context.Context, *UpdateEntityRequest) (*Entity, error)
	// Delete a metadata entity.
	DeleteEntity(context.Context, *DeleteEntityRequest) (*empty.Empty, error)
	// Get a metadata entity.
	GetEntity(context.Context, *GetEntityRequest) (*Entity, error)
	// List metadata entities in a zone.
	ListEntities(context.Context, *ListEntitiesRequest) (*ListEntitiesResponse, error)
	// Create a metadata partition.
	CreatePartition(context.Context, *CreatePartitionRequest) (*Partition, error)
	// Delete a metadata partition.
	DeletePartition(context.Context, *DeletePartitionRequest) (*empty.Empty, 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.

OperationMetadata

type OperationMetadata struct {

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

Represents the metadata of a long-running operation.

func (*OperationMetadata) Descriptor

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

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

func (*OperationMetadata) GetApiVersion

func (x *OperationMetadata) GetApiVersion() string

func (*OperationMetadata) GetCreateTime

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

func (*OperationMetadata) GetEndTime

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

func (*OperationMetadata) GetRequestedCancellation

func (x *OperationMetadata) GetRequestedCancellation() bool

func (*OperationMetadata) GetStatusMessage

func (x *OperationMetadata) GetStatusMessage() string

func (*OperationMetadata) GetTarget

func (x *OperationMetadata) GetTarget() string

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

Partition

type Partition struct {

	// Output only. Partition values used in the HTTP URL must be
	// double encoded. For example, `url_encode(url_encode(value))` can be used
	// to encode "US:CA/CA#Sunnyvale so that the request URL ends
	// with "/partitions/US%253ACA/CA%2523Sunnyvale".
	// The name field in the response retains the encoded format.
	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`.
	// Or `projects/

Represents partition metadata contained within entity instances.

func (*Partition) Descriptor

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

Deprecated: Use Partition.ProtoReflect.Descriptor instead.

func (*Partition) GetEtag

func (x *Partition) GetEtag() string

Deprecated: Do not use.

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

Schema

type Schema struct {
	UserManaged bool `protobuf:"varint,1,opt,name=user_managed,json=userManaged,proto3" json:"user_managed,omitempty"`

	Fields []*Schema_SchemaField `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`

	PartitionFields []*Schema_PartitionField `protobuf:"bytes,3,rep,name=partition_fields,json=partitionFields,proto3" json:"partition_fields,omitempty"`

	PartitionStyle Schema_PartitionStyle "" /* 156 byte string literal not displayed */

}

Schema information describing the structure and layout of the data.

func (*Schema) Descriptor

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

Schema_Mode

type Schema_Mode int32

Additional qualifiers to define field semantics.

Schema_MODE_UNSPECIFIED, Schema_REQUIRED, Schema_NULLABLE, Schema_REPEATED

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

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

Schema_PartitionField

type Schema_PartitionField struct {

	// Required. Partition field name must consist of letters, numbers, and underscores
	// only, with a maximum of length of 256 characters,
	// and must begin with a letter or underscore..
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. Immutable. 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. You could have up to 20 partition fields, but only the first 10 partitions have the filtering ability due to performance consideration. Note: Partition fields are immutable.

func (*Schema_PartitionField) Descriptor

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

Schema_PartitionStyle

type Schema_PartitionStyle int32

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

Schema_PARTITION_STYLE_UNSPECIFIED, Schema_HIVE_COMPATIBLE

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

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

Schema_SchemaField

type Schema_SchemaField struct {

	// Required. The name of the field. Must contain only letters, numbers and
	// underscores, with a maximum length of 767 characters,
	// and must begin with a letter or underscore.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. User friendly field description. Must be less than or equal to 1024
	// characters.
	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

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

Schema_Type

type Schema_Type int32

Type information for fields in schemas and partition schemas.

Schema_TYPE_UNSPECIFIED, Schema_BOOLEAN, Schema_BYTE, Schema_INT16, Schema_INT32, Schema_INT64, Schema_FLOAT, Schema_DOUBLE, Schema_DECIMAL, Schema_STRING, Schema_BINARY, Schema_TIMESTAMP, Schema_DATE, Schema_TIME, Schema_RECORD, Schema_NULL

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

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

Session

type Session struct {

	// Output only. The relative resource name of the content, of the form:
	// projects/{project_id}/locations/{location_id}/lakes/{lake_id}/environment/{environment_id}/sessions/{session_id}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. Email of user running the session.
	UserId string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// Output only. Session start time.
	CreateTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	State      State                `protobuf:"varint,4,opt,name=state,proto3,enum=google.cloud.dataplex.v1.State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

Represents an active analyze session running for a user.

func (*Session) Descriptor

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

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetCreateTime

func (x *Session) GetCreateTime() *timestamp.Timestamp

func (*Session) GetName

func (x *Session) GetName() string

func (*Session) GetState

func (x *Session) GetState() State

func (*Session) GetUserId

func (x *Session) GetUserId() string

func (*Session) ProtoMessage

func (*Session) ProtoMessage()

func (*Session) ProtoReflect

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

func (*Session) Reset

func (x *Session) Reset()

func (*Session) String

func (x *Session) String() string

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. It will be the
	// email address of the user.
	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"`
	// The status of the event.
	EventSucceeded bool `protobuf:"varint,6,opt,name=event_succeeded,json=eventSucceeded,proto3" json:"event_succeeded,omitempty"`
	// If the session is associated with an Environment with fast startup enabled,
	// and was pre-created before being assigned to a user.
	FastStartupEnabled bool `protobuf:"varint,7,opt,name=fast_startup_enabled,json=fastStartupEnabled,proto3" json:"fast_startup_enabled,omitempty"`
	// The idle duration of a warm pooled session before it is assigned to user.
	UnassignedDuration *duration.Duration `protobuf:"bytes,8,opt,name=unassigned_duration,json=unassignedDuration,proto3" json:"unassigned_duration,omitempty"`
	// contains filtered or unexported fields
}

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

func (*SessionEvent) Descriptor

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

Deprecated: Use SessionEvent.ProtoReflect.Descriptor instead.

func (*SessionEvent) GetDetail

func (m *SessionEvent) GetDetail() isSessionEvent_Detail

func (*SessionEvent) GetEventSucceeded

func (x *SessionEvent) GetEventSucceeded() bool

func (*SessionEvent) GetFastStartupEnabled

func (x *SessionEvent) GetFastStartupEnabled() bool

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

func (x *SessionEvent) GetUnassignedDuration() *duration.Duration

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

SessionEvent_EventType

type SessionEvent_EventType int32

The type of the event.

SessionEvent_EVENT_TYPE_UNSPECIFIED, SessionEvent_START, SessionEvent_STOP, SessionEvent_QUERY, SessionEvent_CREATE

const (
	// An unspecified event type.
	SessionEvent_EVENT_TYPE_UNSPECIFIED SessionEvent_EventType = 0
	// Event when the session is assigned to a user.
	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
	// Event for creation of a cluster. It is not yet assigned to a user.
	// This comes before START in the sequence
	SessionEvent_CREATE SessionEvent_EventType = 4
)

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

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

SessionEvent_Query

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

SessionEvent_QueryDetail

type SessionEvent_QueryDetail struct {
	QueryId string `protobuf:"bytes,1,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`

	QueryText string `protobuf:"bytes,2,opt,name=query_text,json=queryText,proto3" json:"query_text,omitempty"`

	Engine SessionEvent_QueryDetail_Engine "" /* 128 byte string literal not displayed */

	Duration *duration.Duration `protobuf:"bytes,4,opt,name=duration,proto3" json:"duration,omitempty"`

	ResultSizeBytes int64 `protobuf:"varint,5,opt,name=result_size_bytes,json=resultSizeBytes,proto3" json:"result_size_bytes,omitempty"`

	DataProcessedBytes int64 `protobuf:"varint,6,opt,name=data_processed_bytes,json=dataProcessedBytes,proto3" json:"data_processed_bytes,omitempty"`

}

Execution details of the query.

func (*SessionEvent_QueryDetail) Descriptor

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() *duration.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

SessionEvent_QueryDetail_Engine

type SessionEvent_QueryDetail_Engine int32

Query Execution engine.

SessionEvent_QueryDetail_ENGINE_UNSPECIFIED, SessionEvent_QueryDetail_SPARK_SQL, SessionEvent_QueryDetail_BIGQUERY

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

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

State

type State int32

State of a resource.

State_STATE_UNSPECIFIED, State_ACTIVE, State_CREATING, State_DELETING, State_ACTION_REQUIRED

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

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

StorageFormat

type StorageFormat struct {
	Format StorageFormat_Format `protobuf:"varint,1,opt,name=format,proto3,enum=google.cloud.dataplex.v1.StorageFormat_Format" json:"format,omitempty"`

	CompressionFormat StorageFormat_CompressionFormat "" /* 175 byte string literal not displayed */

	MimeType string `protobuf:"bytes,3,opt,name=mime_type,json=mimeType,proto3" json:"mime_type,omitempty"`

	Options isStorageFormat_Options `protobuf_oneof:"options"`

}

Describes the format of the data within its storage location.

func (*StorageFormat) Descriptor

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

StorageFormat_CompressionFormat

type StorageFormat_CompressionFormat int32

The specific compressed file format of the data.

StorageFormat_COMPRESSION_FORMAT_UNSPECIFIED, StorageFormat_GZIP, StorageFormat_BZIP2

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

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

StorageFormat_Csv

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

StorageFormat_CsvOptions

type StorageFormat_CsvOptions struct {

	// Optional. The character encoding of the data. Accepts "US-ASCII", "UTF-8", and
	// "ISO-8859-1". Defaults to UTF-8 if unspecified.
	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. Defaults to 0.
	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. Accepts '"'
	// (double quotation mark) or ”' (single quotation mark). Defaults to
	// '"' (double quotation mark) if unspecified.
	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

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

StorageFormat_Format

type StorageFormat_Format int32

The specific file format of the data.

StorageFormat_FORMAT_UNSPECIFIED, StorageFormat_PARQUET, StorageFormat_AVRO, StorageFormat_ORC, StorageFormat_CSV, StorageFormat_JSON, StorageFormat_IMAGE, StorageFormat_AUDIO, StorageFormat_VIDEO, StorageFormat_TEXT, StorageFormat_TFRECORD, StorageFormat_OTHER, StorageFormat_UNKNOWN

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

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

StorageFormat_Json

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

StorageFormat_JsonOptions

type StorageFormat_JsonOptions struct {

	// Optional. The character encoding of the data. Accepts "US-ASCII", "UTF-8" and
	// "ISO-8859-1". Defaults to UTF-8 if not specified.
	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

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

StorageSystem

type StorageSystem int32

Identifies the cloud system that manages the data storage.

StorageSystem_STORAGE_SYSTEM_UNSPECIFIED, StorageSystem_CLOUD_STORAGE, StorageSystem_BIGQUERY

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

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

Task

type Task struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`

	CreateTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`

	DisplayName string `protobuf:"bytes,6,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`

	State State `protobuf:"varint,7,opt,name=state,proto3,enum=google.cloud.dataplex.v1.State" json:"state,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	TriggerSpec *Task_TriggerSpec `protobuf:"bytes,100,opt,name=trigger_spec,json=triggerSpec,proto3" json:"trigger_spec,omitempty"`

	ExecutionSpec *Task_ExecutionSpec `protobuf:"bytes,101,opt,name=execution_spec,json=executionSpec,proto3" json:"execution_spec,omitempty"`

	ExecutionStatus *Task_ExecutionStatus `protobuf:"bytes,201,opt,name=execution_status,json=executionStatus,proto3" json:"execution_status,omitempty"`

	Config isTask_Config `protobuf_oneof:"config"`

}

A task represents a user-visible job.

func (*Task) Descriptor

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

func (x *Task) GetExecutionStatus() *Task_ExecutionStatus

func (*Task) GetLabels

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

func (*Task) GetName

func (x *Task) GetName() string

func (*Task) GetNotebook

func (x *Task) GetNotebook() *Task_NotebookTaskConfig

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

Task_ExecutionSpec

type Task_ExecutionSpec struct {
	Args map[string]string "" /* 149 byte string literal not displayed */

	ServiceAccount string `protobuf:"bytes,5,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`

	Project string `protobuf:"bytes,7,opt,name=project,proto3" json:"project,omitempty"`

	MaxJobExecutionLifetime *duration.Duration "" /* 134 byte string literal not displayed */

	KmsKey string `protobuf:"bytes,9,opt,name=kms_key,json=kmsKey,proto3" json:"kms_key,omitempty"`

}

Execution related settings, like retry and service_account.

func (*Task_ExecutionSpec) Descriptor

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

func (x *Task_ExecutionSpec) GetKmsKey() string

func (*Task_ExecutionSpec) GetMaxJobExecutionLifetime

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

func (*Task_ExecutionSpec) GetProject

func (x *Task_ExecutionSpec) GetProject() string

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

Task_ExecutionStatus

type Task_ExecutionStatus struct {

	// Output only. Last update time of the status.
	UpdateTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Output only. latest job execution
	LatestJob *Job `protobuf:"bytes,9,opt,name=latest_job,json=latestJob,proto3" json:"latest_job,omitempty"`
	// contains filtered or unexported fields
}

Status of the task execution (e.g. Jobs).

func (*Task_ExecutionStatus) Descriptor

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

Deprecated: Use Task_ExecutionStatus.ProtoReflect.Descriptor instead.

func (*Task_ExecutionStatus) GetLatestJob

func (x *Task_ExecutionStatus) GetLatestJob() *Job

func (*Task_ExecutionStatus) GetUpdateTime

func (x *Task_ExecutionStatus) GetUpdateTime() *timestamp.Timestamp

func (*Task_ExecutionStatus) ProtoMessage

func (*Task_ExecutionStatus) ProtoMessage()

func (*Task_ExecutionStatus) ProtoReflect

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

func (*Task_ExecutionStatus) Reset

func (x *Task_ExecutionStatus) Reset()

func (*Task_ExecutionStatus) String

func (x *Task_ExecutionStatus) String() string

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

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

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"`
}

Task_InfrastructureSpec_BatchComputeResources

type Task_InfrastructureSpec_BatchComputeResources struct {

	// Optional. Total number of job executors.
	// Executor Count should be between 2 and 100. [Default=2]
	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.
	// Max Executor Count should be between 2 and 1000. [Default=1000]
	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

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

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"`
}

Task_InfrastructureSpec_ContainerImageRuntime

type Task_InfrastructureSpec_ContainerImageRuntime struct {
	Image string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`

	JavaJars []string `protobuf:"bytes,2,rep,name=java_jars,json=javaJars,proto3" json:"java_jars,omitempty"`

	PythonPackages []string `protobuf:"bytes,3,rep,name=python_packages,json=pythonPackages,proto3" json:"python_packages,omitempty"`

	Properties map[string]string "" /* 161 byte string literal not displayed */

}

Container Image Runtime Configuration used with Batch execution.

func (*Task_InfrastructureSpec_ContainerImageRuntime) Descriptor

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

Deprecated: Use Task_InfrastructureSpec_ContainerImageRuntime.ProtoReflect.Descriptor instead.

func (*Task_InfrastructureSpec_ContainerImageRuntime) GetImage

func (x *Task_InfrastructureSpec_ContainerImageRuntime) GetImage() string

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

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

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

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"`
}

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"`
}

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"`
}

Task_Notebook

type Task_Notebook struct {
	// Config related to running scheduled Notebooks.
	Notebook *Task_NotebookTaskConfig `protobuf:"bytes,302,opt,name=notebook,proto3,oneof"`
}

Task_NotebookTaskConfig

type Task_NotebookTaskConfig struct {

	// Required. Path to input notebook. This can be the Cloud Storage URI of the notebook
	// file or the path to a Notebook Content. The execution args are accessible
	// as environment variables
	// (`TASK_key=value`).
	Notebook string `protobuf:"bytes,4,opt,name=notebook,proto3" json:"notebook,omitempty"`
	// Optional. Infrastructure specification for the execution.
	InfrastructureSpec *Task_InfrastructureSpec `protobuf:"bytes,3,opt,name=infrastructure_spec,json=infrastructureSpec,proto3" json:"infrastructure_spec,omitempty"`
	// Optional. Cloud Storage URIs of files to be placed in the working directory of each
	// executor.
	FileUris []string `protobuf:"bytes,5,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,6,rep,name=archive_uris,json=archiveUris,proto3" json:"archive_uris,omitempty"`
	// contains filtered or unexported fields
}

Config for running scheduled notebooks.

func (*Task_NotebookTaskConfig) Descriptor

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

Deprecated: Use Task_NotebookTaskConfig.ProtoReflect.Descriptor instead.

func (*Task_NotebookTaskConfig) GetArchiveUris

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

func (*Task_NotebookTaskConfig) GetFileUris

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

func (*Task_NotebookTaskConfig) GetInfrastructureSpec

func (x *Task_NotebookTaskConfig) GetInfrastructureSpec() *Task_InfrastructureSpec

func (*Task_NotebookTaskConfig) GetNotebook

func (x *Task_NotebookTaskConfig) GetNotebook() string

func (*Task_NotebookTaskConfig) ProtoMessage

func (*Task_NotebookTaskConfig) ProtoMessage()

func (*Task_NotebookTaskConfig) ProtoReflect

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

func (*Task_NotebookTaskConfig) Reset

func (x *Task_NotebookTaskConfig) Reset()

func (*Task_NotebookTaskConfig) String

func (x *Task_NotebookTaskConfig) String() string

Task_Spark

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

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

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

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"`
}

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"`
}

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"`
}

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"`
}

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"`
}

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 *timestamp.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

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

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"`
}

Task_TriggerSpec_Type

type Task_TriggerSpec_Type int32

Determines how often and when the job will run.

Task_TriggerSpec_TYPE_UNSPECIFIED, Task_TriggerSpec_ON_DEMAND, Task_TriggerSpec_RECURRING

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

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

UnimplementedContentServiceServer

type UnimplementedContentServiceServer struct {
}

UnimplementedContentServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedContentServiceServer) CreateContent

func (*UnimplementedContentServiceServer) CreateContent(context.Context, *CreateContentRequest) (*Content, error)

func (*UnimplementedContentServiceServer) DeleteContent

func (*UnimplementedContentServiceServer) DeleteContent(context.Context, *DeleteContentRequest) (*empty.Empty, error)

func (*UnimplementedContentServiceServer) GetContent

func (*UnimplementedContentServiceServer) GetContent(context.Context, *GetContentRequest) (*Content, error)

func (*UnimplementedContentServiceServer) GetIamPolicy

func (*UnimplementedContentServiceServer) GetIamPolicy(context.Context, *v1.GetIamPolicyRequest) (*v1.Policy, error)

func (*UnimplementedContentServiceServer) ListContent

func (*UnimplementedContentServiceServer) ListContent(context.Context, *ListContentRequest) (*ListContentResponse, error)

func (*UnimplementedContentServiceServer) SetIamPolicy

func (*UnimplementedContentServiceServer) SetIamPolicy(context.Context, *v1.SetIamPolicyRequest) (*v1.Policy, error)

func (*UnimplementedContentServiceServer) TestIamPermissions

func (*UnimplementedContentServiceServer) TestIamPermissions(context.Context, *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error)

func (*UnimplementedContentServiceServer) UpdateContent

func (*UnimplementedContentServiceServer) UpdateContent(context.Context, *UpdateContentRequest) (*Content, error)

UnimplementedDataplexServiceServer

type UnimplementedDataplexServiceServer struct {
}

UnimplementedDataplexServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataplexServiceServer) CancelJob

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

func (*UnimplementedDataplexServiceServer) CreateAsset

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

func (*UnimplementedDataplexServiceServer) CreateEnvironment

func (*UnimplementedDataplexServiceServer) CreateEnvironment(context.Context, *CreateEnvironmentRequest) (*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) DeleteEnvironment

func (*UnimplementedDataplexServiceServer) DeleteEnvironment(context.Context, *DeleteEnvironmentRequest) (*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) GetEnvironment

func (*UnimplementedDataplexServiceServer) GetEnvironment(context.Context, *GetEnvironmentRequest) (*Environment, 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) ListEnvironments

func (*UnimplementedDataplexServiceServer) ListEnvironments(context.Context, *ListEnvironmentsRequest) (*ListEnvironmentsResponse, 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) ListSessions

func (*UnimplementedDataplexServiceServer) ListSessions(context.Context, *ListSessionsRequest) (*ListSessionsResponse, 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) UpdateEnvironment

func (*UnimplementedDataplexServiceServer) UpdateEnvironment(context.Context, *UpdateEnvironmentRequest) (*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)

UnimplementedMetadataServiceServer

type UnimplementedMetadataServiceServer struct {
}

UnimplementedMetadataServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetadataServiceServer) CreateEntity

func (*UnimplementedMetadataServiceServer) CreateEntity(context.Context, *CreateEntityRequest) (*Entity, error)

func (*UnimplementedMetadataServiceServer) CreatePartition

func (*UnimplementedMetadataServiceServer) CreatePartition(context.Context, *CreatePartitionRequest) (*Partition, error)

func (*UnimplementedMetadataServiceServer) DeleteEntity

func (*UnimplementedMetadataServiceServer) DeleteEntity(context.Context, *DeleteEntityRequest) (*empty.Empty, error)

func (*UnimplementedMetadataServiceServer) DeletePartition

func (*UnimplementedMetadataServiceServer) DeletePartition(context.Context, *DeletePartitionRequest) (*empty.Empty, error)

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)

func (*UnimplementedMetadataServiceServer) UpdateEntity

func (*UnimplementedMetadataServiceServer) UpdateEntity(context.Context, *UpdateEntityRequest) (*Entity, error)

UpdateAssetRequest

type UpdateAssetRequest struct {

	// Required. Mask of fields to update.
	UpdateMask *field_mask.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

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() *field_mask.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

UpdateContentRequest

type UpdateContentRequest struct {

	// Required. Mask of fields to update.
	UpdateMask *field_mask.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.
	Content *Content `protobuf:"bytes,2,opt,name=content,proto3" json:"content,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 content request.

func (*UpdateContentRequest) Descriptor

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

Deprecated: Use UpdateContentRequest.ProtoReflect.Descriptor instead.

func (*UpdateContentRequest) GetContent

func (x *UpdateContentRequest) GetContent() *Content

func (*UpdateContentRequest) GetUpdateMask

func (x *UpdateContentRequest) GetUpdateMask() *field_mask.FieldMask

func (*UpdateContentRequest) GetValidateOnly

func (x *UpdateContentRequest) GetValidateOnly() bool

func (*UpdateContentRequest) ProtoMessage

func (*UpdateContentRequest) ProtoMessage()

func (*UpdateContentRequest) ProtoReflect

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

func (*UpdateContentRequest) Reset

func (x *UpdateContentRequest) Reset()

func (*UpdateContentRequest) String

func (x *UpdateContentRequest) String() string

UpdateEntityRequest

type UpdateEntityRequest struct {

	// Required. Update description.
	Entity *Entity `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,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 a metadata entity request. The exiting entity will be fully replaced by the entity in the request. The entity ID is mutable. To modify the ID, use the current entity ID in the request URL and specify the new ID in the request body.

func (*UpdateEntityRequest) Descriptor

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

Deprecated: Use UpdateEntityRequest.ProtoReflect.Descriptor instead.

func (*UpdateEntityRequest) GetEntity

func (x *UpdateEntityRequest) GetEntity() *Entity

func (*UpdateEntityRequest) GetValidateOnly

func (x *UpdateEntityRequest) GetValidateOnly() bool

func (*UpdateEntityRequest) ProtoMessage

func (*UpdateEntityRequest) ProtoMessage()

func (*UpdateEntityRequest) ProtoReflect

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

func (*UpdateEntityRequest) Reset

func (x *UpdateEntityRequest) Reset()

func (*UpdateEntityRequest) String

func (x *UpdateEntityRequest) String() string

UpdateEnvironmentRequest

type UpdateEnvironmentRequest struct {

	// Required. Mask of fields to update.
	UpdateMask *field_mask.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.
	Environment *Environment `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,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 environment request.

func (*UpdateEnvironmentRequest) Descriptor

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

Deprecated: Use UpdateEnvironmentRequest.ProtoReflect.Descriptor instead.

func (*UpdateEnvironmentRequest) GetEnvironment

func (x *UpdateEnvironmentRequest) GetEnvironment() *Environment

func (*UpdateEnvironmentRequest) GetUpdateMask

func (x *UpdateEnvironmentRequest) GetUpdateMask() *field_mask.FieldMask

func (*UpdateEnvironmentRequest) GetValidateOnly

func (x *UpdateEnvironmentRequest) GetValidateOnly() bool

func (*UpdateEnvironmentRequest) ProtoMessage

func (*UpdateEnvironmentRequest) ProtoMessage()

func (*UpdateEnvironmentRequest) ProtoReflect

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

func (*UpdateEnvironmentRequest) Reset

func (x *UpdateEnvironmentRequest) Reset()

func (*UpdateEnvironmentRequest) String

func (x *UpdateEnvironmentRequest) String() string

UpdateLakeRequest

type UpdateLakeRequest struct {

	// Required. Mask of fields to update.
	UpdateMask *field_mask.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

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() *field_mask.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

UpdateTaskRequest

type UpdateTaskRequest struct {

	// Required. Mask of fields to update.
	UpdateMask *field_mask.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

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() *field_mask.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

UpdateZoneRequest

type UpdateZoneRequest struct {

	// Required. Mask of fields to update.
	UpdateMask *field_mask.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

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

Deprecated: Use UpdateZoneRequest.ProtoReflect.Descriptor instead.

func (*UpdateZoneRequest) GetUpdateMask

func (x *UpdateZoneRequest) GetUpdateMask() *field_mask.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

Zone

type Zone struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`

	Uid string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"`

	CreateTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`

	State State `protobuf:"varint,8,opt,name=state,proto3,enum=google.cloud.dataplex.v1.State" json:"state,omitempty"`

	Type Zone_Type `protobuf:"varint,9,opt,name=type,proto3,enum=google.cloud.dataplex.v1.Zone_Type" json:"type,omitempty"`

	DiscoverySpec *Zone_DiscoverySpec `protobuf:"bytes,103,opt,name=discovery_spec,json=discoverySpec,proto3" json:"discovery_spec,omitempty"`

	ResourceSpec *Zone_ResourceSpec `protobuf:"bytes,104,opt,name=resource_spec,json=resourceSpec,proto3" json:"resource_spec,omitempty"`

	AssetStatus *AssetStatus `protobuf:"bytes,105,opt,name=asset_status,json=assetStatus,proto3" json:"asset_status,omitempty"`

}

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

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

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

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

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

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

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

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

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"`
}

Zone_ResourceSpec

type Zone_ResourceSpec struct {
	LocationType Zone_ResourceSpec_LocationType "" /* 159 byte string literal not displayed */

}

Settings for resources attached as assets within a zone.

func (*Zone_ResourceSpec) Descriptor

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

Zone_ResourceSpec_LocationType

type Zone_ResourceSpec_LocationType int32

Location type of the resources attached to a zone.

Zone_ResourceSpec_LOCATION_TYPE_UNSPECIFIED, Zone_ResourceSpec_SINGLE_REGION, Zone_ResourceSpec_MULTI_REGION

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

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

Zone_Type

type Zone_Type int32

Type of zone.

Zone_TYPE_UNSPECIFIED, Zone_RAW, Zone_CURATED

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

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