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

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.

DataQualityRule_StatisticRangeExpectation_ColumnStatistic_name, DataQualityRule_StatisticRangeExpectation_ColumnStatistic_value

var (
	DataQualityRule_StatisticRangeExpectation_ColumnStatistic_name = map[int32]string{
		0: "STATISTIC_UNDEFINED",
		1: "MEAN",
		2: "MIN",
		3: "MAX",
	}
	DataQualityRule_StatisticRangeExpectation_ColumnStatistic_value = map[string]int32{
		"STATISTIC_UNDEFINED": 0,
		"MEAN":                1,
		"MIN":                 2,
		"MAX":                 3,
	}
)

Enum value maps for DataQualityRule_StatisticRangeExpectation_ColumnStatistic.

DataScanType_name, DataScanType_value

var (
	DataScanType_name = map[int32]string{
		0: "DATA_SCAN_TYPE_UNSPECIFIED",
		1: "DATA_QUALITY",
		2: "DATA_PROFILE",
	}
	DataScanType_value = map[string]int32{
		"DATA_SCAN_TYPE_UNSPECIFIED": 0,
		"DATA_QUALITY":               1,
		"DATA_PROFILE":               2,
	}
)

Enum value maps for DataScanType.

GetDataScanRequest_DataScanView_name, GetDataScanRequest_DataScanView_value

var (
	GetDataScanRequest_DataScanView_name = map[int32]string{
		0:  "DATA_SCAN_VIEW_UNSPECIFIED",
		1:  "BASIC",
		10: "FULL",
	}
	GetDataScanRequest_DataScanView_value = map[string]int32{
		"DATA_SCAN_VIEW_UNSPECIFIED": 0,
		"BASIC":                      1,
		"FULL":                       10,
	}
)

Enum value maps for GetDataScanRequest_DataScanView.

GetDataScanJobRequest_DataScanJobView_name, GetDataScanJobRequest_DataScanJobView_value

var (
	GetDataScanJobRequest_DataScanJobView_name = map[int32]string{
		0:  "DATA_SCAN_JOB_VIEW_UNSPECIFIED",
		1:  "BASIC",
		10: "FULL",
	}
	GetDataScanJobRequest_DataScanJobView_value = map[string]int32{
		"DATA_SCAN_JOB_VIEW_UNSPECIFIED": 0,
		"BASIC":                          1,
		"FULL":                           10,
	}
)

Enum value maps for GetDataScanJobRequest_DataScanJobView.

DataScanJob_State_name, DataScanJob_State_value

var (
	DataScanJob_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "RUNNING",
		2: "CANCELING",
		3: "CANCELLED",
		4: "SUCCEEDED",
		5: "FAILED",
		7: "PENDING",
	}
	DataScanJob_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"RUNNING":           1,
		"CANCELING":         2,
		"CANCELLED":         3,
		"SUCCEEDED":         4,
		"FAILED":            5,
		"PENDING":           7,
	}
)

Enum value maps for DataScanJob_State.

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.

DataScanEvent_ScanType_name, DataScanEvent_ScanType_value

var (
	DataScanEvent_ScanType_name = map[int32]string{
		0: "SCAN_TYPE_UNSPECIFIED",
		1: "DATA_PROFILE",
		2: "DATA_QUALITY",
	}
	DataScanEvent_ScanType_value = map[string]int32{
		"SCAN_TYPE_UNSPECIFIED": 0,
		"DATA_PROFILE":          1,
		"DATA_QUALITY":          2,
	}
)

Enum value maps for DataScanEvent_ScanType.

DataScanEvent_State_name, DataScanEvent_State_value

var (
	DataScanEvent_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "STARTED",
		2: "SUCCEEDED",
		3: "FAILED",
		4: "CANCELLED",
	}
	DataScanEvent_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"STARTED":           1,
		"SUCCEEDED":         2,
		"FAILED":            3,
		"CANCELLED":         4,
	}
)

Enum value maps for DataScanEvent_State.

DataScanEvent_Trigger_name, DataScanEvent_Trigger_value

var (
	DataScanEvent_Trigger_name = map[int32]string{
		0: "TRIGGER_UNSPECIFIED",
		1: "ON_DEMAND",
		2: "SCHEDULE",
	}
	DataScanEvent_Trigger_value = map[string]int32{
		"TRIGGER_UNSPECIFIED": 0,
		"ON_DEMAND":           1,
		"SCHEDULE":            2,
	}
)

Enum value maps for DataScanEvent_Trigger.

DataScanEvent_Scope_name, DataScanEvent_Scope_value

var (
	DataScanEvent_Scope_name = map[int32]string{
		0: "SCOPE_UNSPECIFIED",
		1: "FULL",
		2: "INCREMENTAL",
	}
	DataScanEvent_Scope_value = map[string]int32{
		"SCOPE_UNSPECIFIED": 0,
		"FULL":              1,
		"INCREMENTAL":       2,
	}
)

Enum value maps for DataScanEvent_Scope.

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_data_profile_proto

var File_google_cloud_dataplex_v1_data_profile_proto protoreflect.FileDescriptor

File_google_cloud_dataplex_v1_data_quality_proto

var File_google_cloud_dataplex_v1_data_quality_proto protoreflect.FileDescriptor

File_google_cloud_dataplex_v1_datascans_proto

var File_google_cloud_dataplex_v1_datascans_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_processing_proto

var File_google_cloud_dataplex_v1_processing_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 RegisterDataScanServiceServer

func RegisterDataScanServiceServer(s *grpc.Server, srv DataScanServiceServer)

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

Action represents an issue requiring administrator action for resolution.

func (*Action) Descriptor

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

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetAsset

func (x *Action) GetAsset() string

func (*Action) GetCategory

func (x *Action) GetCategory() Action_Category

func (*Action) GetDataLocations

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

func (*Action) GetDetails

func (m *Action) GetDetails() isAction_Details

func (*Action) GetDetectTime

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

func (*Action) GetFailedSecurityPolicyApply

func (x *Action) GetFailedSecurityPolicyApply() *Action_FailedSecurityPolicyApply

func (*Action) GetIncompatibleDataSchema

func (x *Action) GetIncompatibleDataSchema() *Action_IncompatibleDataSchema

func (*Action) GetInvalidDataFormat

func (x *Action) GetInvalidDataFormat() *Action_InvalidDataFormat

func (*Action) GetInvalidDataOrganization

func (x *Action) GetInvalidDataOrganization() *Action_InvalidDataOrganization

func (*Action) GetInvalidDataPartition

func (x *Action) GetInvalidDataPartition() *Action_InvalidDataPartition

func (*Action) GetIssue

func (x *Action) GetIssue() string

func (*Action) GetLake

func (x *Action) GetLake() string

func (*Action) GetMissingData

func (x *Action) GetMissingData() *Action_MissingData

func (*Action) GetMissingResource

func (x *Action) GetMissingResource() *Action_MissingResource

func (*Action) GetName

func (x *Action) GetName() string

func (*Action) GetUnauthorizedResource

func (x *Action) GetUnauthorizedResource() *Action_UnauthorizedResource

func (*Action) GetZone

func (x *Action) GetZone() string

func (*Action) ProtoMessage

func (*Action) ProtoMessage()

func (*Action) ProtoReflect

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

func (*Action) Reset

func (x *Action) Reset()

func (*Action) String

func (x *Action) String() string

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

func (x Action_Category) String() string

func (Action_Category) Type

Action_FailedSecurityPolicyApply

type Action_FailedSecurityPolicyApply struct {

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

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

func (*Action_FailedSecurityPolicyApply) Descriptor

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

Deprecated: Use Action_FailedSecurityPolicyApply.ProtoReflect.Descriptor instead.

func (*Action_FailedSecurityPolicyApply) GetAsset

func (*Action_FailedSecurityPolicyApply) ProtoMessage

func (*Action_FailedSecurityPolicyApply) ProtoMessage()

func (*Action_FailedSecurityPolicyApply) ProtoReflect

func (*Action_FailedSecurityPolicyApply) Reset

func (*Action_FailedSecurityPolicyApply) 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 (*Action_IncompatibleDataSchema) GetTable

func (x *Action_IncompatibleDataSchema) GetTable() string

func (*Action_IncompatibleDataSchema) ProtoMessage

func (*Action_IncompatibleDataSchema) ProtoMessage()

func (*Action_IncompatibleDataSchema) ProtoReflect

func (*Action_IncompatibleDataSchema) Reset

func (x *Action_IncompatibleDataSchema) Reset()

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

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

func (Action_IncompatibleDataSchema_SchemaChange) Type

Action_InvalidDataFormat

type Action_InvalidDataFormat struct {

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

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

func (*Action_InvalidDataFormat) Descriptor

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 (*Action_InvalidDataOrganization) Reset

func (x *Action_InvalidDataOrganization) Reset()

func (*Action_InvalidDataOrganization) 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 (*Action_InvalidDataPartition) ProtoMessage

func (*Action_InvalidDataPartition) ProtoMessage()

func (*Action_InvalidDataPartition) ProtoReflect

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

func (Action_InvalidDataPartition_PartitionStructure) EnumDescriptor

Deprecated: Use Action_InvalidDataPartition_PartitionStructure.Descriptor instead.

func (Action_InvalidDataPartition_PartitionStructure) Number

func (Action_InvalidDataPartition_PartitionStructure) String

func (Action_InvalidDataPartition_PartitionStructure) Type

Action_MissingData

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

Action details for absence of data detected by discovery.

func (*Action_MissingData) Descriptor

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 (*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 *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamppb.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() *timestamppb.Timestamp

func (*Asset) GetDescription

func (x *Asset) GetDescription() string

func (*Asset) GetDiscoverySpec

func (x *Asset) GetDiscoverySpec() *Asset_DiscoverySpec

func (*Asset) GetDiscoveryStatus

func (x *Asset) GetDiscoveryStatus() *Asset_DiscoveryStatus

func (*Asset) GetDisplayName

func (x *Asset) GetDisplayName() string

func (*Asset) GetLabels

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

func (*Asset) GetName

func (x *Asset) GetName() string

func (*Asset) GetResourceSpec

func (x *Asset) GetResourceSpec() *Asset_ResourceSpec

func (*Asset) GetResourceStatus

func (x *Asset) GetResourceStatus() *Asset_ResourceStatus

func (*Asset) GetSecurityStatus

func (x *Asset) GetSecurityStatus() *Asset_SecurityStatus

func (*Asset) GetState

func (x *Asset) GetState() State

func (*Asset) GetUid

func (x *Asset) GetUid() string

func (*Asset) GetUpdateTime

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

func (*Asset) ProtoMessage

func (*Asset) ProtoMessage()

func (*Asset) ProtoReflect

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

func (*Asset) Reset

func (x *Asset) Reset()

func (*Asset) String

func (x *Asset) String() string

AssetStatus

type AssetStatus struct {
	UpdateTime *timestamppb.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() *timestamppb.Timestamp

func (*AssetStatus) ProtoMessage

func (*AssetStatus) ProtoMessage()

func (*AssetStatus) ProtoReflect

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

func (*AssetStatus) Reset

func (x *AssetStatus) Reset()

func (*AssetStatus) String

func (x *AssetStatus) String() string

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 (*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 (*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 (*Asset_DiscoverySpec_CsvOptions) Reset

func (x *Asset_DiscoverySpec_CsvOptions) Reset()

func (*Asset_DiscoverySpec_CsvOptions) 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 (*Asset_DiscoverySpec_JsonOptions) Reset

func (*Asset_DiscoverySpec_JsonOptions) 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 *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// The start time of the last discovery run.
	LastRunTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_run_time,json=lastRunTime,proto3" json:"last_run_time,omitempty"`
	// Data Stats of the asset reported by discovery.
	Stats *Asset_DiscoveryStatus_Stats `protobuf:"bytes,6,opt,name=stats,proto3" json:"stats,omitempty"`
	// The duration of the last discovery run.
	LastRunDuration *durationpb.Duration `protobuf:"bytes,7,opt,name=last_run_duration,json=lastRunDuration,proto3" json:"last_run_duration,omitempty"`
	// contains filtered or unexported fields
}

Status of discovery for an asset.

func (*Asset_DiscoveryStatus) Descriptor

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

Deprecated: Use Asset_DiscoveryStatus.ProtoReflect.Descriptor instead.

func (*Asset_DiscoveryStatus) GetLastRunDuration

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

func (*Asset_DiscoveryStatus) GetLastRunTime

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

func (*Asset_DiscoveryStatus) GetMessage

func (x *Asset_DiscoveryStatus) GetMessage() string

func (*Asset_DiscoveryStatus) GetState

func (*Asset_DiscoveryStatus) GetStats

func (*Asset_DiscoveryStatus) GetUpdateTime

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

func (*Asset_DiscoveryStatus) ProtoMessage

func (*Asset_DiscoveryStatus) ProtoMessage()

func (*Asset_DiscoveryStatus) ProtoReflect

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

func (*Asset_DiscoveryStatus) Reset

func (x *Asset_DiscoveryStatus) Reset()

func (*Asset_DiscoveryStatus) String

func (x *Asset_DiscoveryStatus) String() string

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

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

func (Asset_DiscoveryStatus_State) Type

Asset_DiscoveryStatus_Stats

type Asset_DiscoveryStatus_Stats struct {

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

The aggregated data statistics for the asset reported by discovery.

func (*Asset_DiscoveryStatus_Stats) Descriptor

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

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

func (x Asset_ResourceSpec_Type) String() string

func (Asset_ResourceSpec_Type) Type

Asset_ResourceStatus

type Asset_ResourceStatus struct {

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

Status of the resource referenced by an asset.

func (*Asset_ResourceStatus) Descriptor

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 (*Asset_ResourceStatus) GetUpdateTime

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

func (*Asset_ResourceStatus) ProtoMessage

func (*Asset_ResourceStatus) ProtoMessage()

func (*Asset_ResourceStatus) ProtoReflect

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

func (*Asset_ResourceStatus) Reset

func (x *Asset_ResourceStatus) Reset()

func (*Asset_ResourceStatus) String

func (x *Asset_ResourceStatus) String() string

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

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

func (Asset_ResourceStatus_State) Type

Asset_SecurityStatus

type Asset_SecurityStatus struct {

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

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

func (*Asset_SecurityStatus) Descriptor

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 (*Asset_SecurityStatus) GetUpdateTime

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

func (*Asset_SecurityStatus) ProtoMessage

func (*Asset_SecurityStatus) ProtoMessage()

func (*Asset_SecurityStatus) ProtoReflect

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

func (*Asset_SecurityStatus) Reset

func (x *Asset_SecurityStatus) Reset()

func (*Asset_SecurityStatus) String

func (x *Asset_SecurityStatus) String() string

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

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

func (Asset_SecurityStatus_State) Type

CancelJobRequest

type CancelJobRequest struct {

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

Cancel task jobs.

func (*CancelJobRequest) Descriptor

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 *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamppb.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() *timestamppb.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() *timestamppb.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) (*emptypb.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) (*emptypb.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) Enum

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

func (Content_Notebook_KernelType) Type

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

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

func (Content_SqlScript_QueryEngine) Type

CreateAssetRequest

type CreateAssetRequest struct {

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

Create asset request.

func (*CreateAssetRequest) Descriptor

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

CreateDataScanRequest

type CreateDataScanRequest struct {

	// Required. The resource name of the parent location:
	// projects/{project}/locations/{location_id}
	// where `{project}` refers to a project_id or project_number and
	// `location_id` refers to a GCP region.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. DataScan resource.
	DataScan *DataScan `protobuf:"bytes,2,opt,name=data_scan,json=dataScan,proto3" json:"data_scan,omitempty"`
	// Required. DataScan identifier.
	// * 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.
	DataScanId string `protobuf:"bytes,3,opt,name=data_scan_id,json=dataScanId,proto3" json:"data_scan_id,omitempty"`
	// contains filtered or unexported fields
}

Create dataScan request.

func (*CreateDataScanRequest) Descriptor

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

Deprecated: Use CreateDataScanRequest.ProtoReflect.Descriptor instead.

func (*CreateDataScanRequest) GetDataScan

func (x *CreateDataScanRequest) GetDataScan() *DataScan

func (*CreateDataScanRequest) GetDataScanId

func (x *CreateDataScanRequest) GetDataScanId() string

func (*CreateDataScanRequest) GetParent

func (x *CreateDataScanRequest) GetParent() string

func (*CreateDataScanRequest) ProtoMessage

func (*CreateDataScanRequest) ProtoMessage()

func (*CreateDataScanRequest) ProtoReflect

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

func (*CreateDataScanRequest) Reset

func (x *CreateDataScanRequest) Reset()

func (*CreateDataScanRequest) String

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

DataProfileResult

type DataProfileResult struct {

	// The count of all rows in the sampled data.
	// Return 0, if zero rows.
	RowCount int64 `protobuf:"varint,3,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	// This represents the profile information per field.
	Profile *DataProfileResult_Profile `protobuf:"bytes,4,opt,name=profile,proto3" json:"profile,omitempty"`
	// The data scanned for this profile.
	ScannedData *ScannedData `protobuf:"bytes,5,opt,name=scanned_data,json=scannedData,proto3" json:"scanned_data,omitempty"`
	// contains filtered or unexported fields
}

DataProfileResult defines the output of DataProfileScan. Each field of the table will have field type specific profile result.

func (*DataProfileResult) Descriptor

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

Deprecated: Use DataProfileResult.ProtoReflect.Descriptor instead.

func (*DataProfileResult) GetProfile

func (*DataProfileResult) GetRowCount

func (x *DataProfileResult) GetRowCount() int64

func (*DataProfileResult) GetScannedData

func (x *DataProfileResult) GetScannedData() *ScannedData

func (*DataProfileResult) ProtoMessage

func (*DataProfileResult) ProtoMessage()

func (*DataProfileResult) ProtoReflect

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

func (*DataProfileResult) Reset

func (x *DataProfileResult) Reset()

func (*DataProfileResult) String

func (x *DataProfileResult) String() string

DataProfileResult_Profile

type DataProfileResult_Profile struct {

	// The sequence of fields describing data in table entities.
	Fields []*DataProfileResult_Profile_Field `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

Profile information describing the structure and layout of the data and contains the profile info.

func (*DataProfileResult_Profile) Descriptor

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

Deprecated: Use DataProfileResult_Profile.ProtoReflect.Descriptor instead.

func (*DataProfileResult_Profile) GetFields

func (*DataProfileResult_Profile) ProtoMessage

func (*DataProfileResult_Profile) ProtoMessage()

func (*DataProfileResult_Profile) ProtoReflect

func (*DataProfileResult_Profile) Reset

func (x *DataProfileResult_Profile) Reset()

func (*DataProfileResult_Profile) String

func (x *DataProfileResult_Profile) String() string

DataProfileResult_Profile_Field

type DataProfileResult_Profile_Field struct {

	// The name of the field.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The field data type. Possible values include:
	//
	// * STRING
	// * BYTE
	// * INT64
	// * INT32
	// * INT16
	// * DOUBLE
	// * FLOAT
	// * DECIMAL
	// * BOOLEAN
	// * BINARY
	// * TIMESTAMP
	// * DATE
	// * TIME
	// * NULL
	// * RECORD
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// The mode of the field. Its value will be:
	// REQUIRED, if it is a required field.
	// NULLABLE, if it is an optional field.
	// REPEATED, if it is a repeated field.
	Mode string `protobuf:"bytes,3,opt,name=mode,proto3" json:"mode,omitempty"`
	// The profile information for the corresponding field.
	Profile *DataProfileResult_Profile_Field_ProfileInfo `protobuf:"bytes,4,opt,name=profile,proto3" json:"profile,omitempty"`
	// contains filtered or unexported fields
}

Represents a column field within a table schema.

func (*DataProfileResult_Profile_Field) Descriptor

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

Deprecated: Use DataProfileResult_Profile_Field.ProtoReflect.Descriptor instead.

func (*DataProfileResult_Profile_Field) GetMode

func (*DataProfileResult_Profile_Field) GetName

func (*DataProfileResult_Profile_Field) GetProfile

func (*DataProfileResult_Profile_Field) GetType

func (*DataProfileResult_Profile_Field) ProtoMessage

func (*DataProfileResult_Profile_Field) ProtoMessage()

func (*DataProfileResult_Profile_Field) ProtoReflect

func (*DataProfileResult_Profile_Field) Reset

func (*DataProfileResult_Profile_Field) String

DataProfileResult_Profile_Field_ProfileInfo

type DataProfileResult_Profile_Field_ProfileInfo struct {

	// The ratio of null rows against the rows in the sampled data.
	NullRatio float64 `protobuf:"fixed64,2,opt,name=null_ratio,json=nullRatio,proto3" json:"null_ratio,omitempty"`
	// The ratio of rows that are distinct against the rows in the sampled
	// data.
	DistinctRatio float64 `protobuf:"fixed64,3,opt,name=distinct_ratio,json=distinctRatio,proto3" json:"distinct_ratio,omitempty"`
	// The array of top N values of the field in the sampled data.
	// Currently N is set as 10 or equal to distinct values in the field,
	// whichever is smaller. This will be optional for complex non-groupable
	// data-types such as JSON, ARRAY, JSON, STRUCT.
	TopNValues []*DataProfileResult_Profile_Field_ProfileInfo_TopNValue `protobuf:"bytes,4,rep,name=top_n_values,json=topNValues,proto3" json:"top_n_values,omitempty"`
	// The corresponding profile for specific field type.
	// Each field will have only one field type specific profile output.
	//
	// Types that are assignable to FieldInfo:
	//
	//	*DataProfileResult_Profile_Field_ProfileInfo_StringProfile
	//	*DataProfileResult_Profile_Field_ProfileInfo_IntegerProfile
	//	*DataProfileResult_Profile_Field_ProfileInfo_DoubleProfile
	FieldInfo isDataProfileResult_Profile_Field_ProfileInfo_FieldInfo `protobuf_oneof:"field_info"`
	// contains filtered or unexported fields
}

ProfileInfo defines the profile information for each schema field type.

func (*DataProfileResult_Profile_Field_ProfileInfo) Descriptor

Deprecated: Use DataProfileResult_Profile_Field_ProfileInfo.ProtoReflect.Descriptor instead.

func (*DataProfileResult_Profile_Field_ProfileInfo) GetDistinctRatio

func (*DataProfileResult_Profile_Field_ProfileInfo) GetDoubleProfile

func (*DataProfileResult_Profile_Field_ProfileInfo) GetFieldInfo

func (m *DataProfileResult_Profile_Field_ProfileInfo) GetFieldInfo() isDataProfileResult_Profile_Field_ProfileInfo_FieldInfo

func (*DataProfileResult_Profile_Field_ProfileInfo) GetIntegerProfile

func (*DataProfileResult_Profile_Field_ProfileInfo) GetNullRatio

func (*DataProfileResult_Profile_Field_ProfileInfo) GetStringProfile

func (*DataProfileResult_Profile_Field_ProfileInfo) GetTopNValues

func (*DataProfileResult_Profile_Field_ProfileInfo) ProtoMessage

func (*DataProfileResult_Profile_Field_ProfileInfo) ProtoReflect

func (*DataProfileResult_Profile_Field_ProfileInfo) Reset

func (*DataProfileResult_Profile_Field_ProfileInfo) String

DataProfileResult_Profile_Field_ProfileInfo_DoubleFieldInfo

type DataProfileResult_Profile_Field_ProfileInfo_DoubleFieldInfo struct {

	// The average of non-null values of double field in the sampled data.
	// Return NaN, if the field has a NaN. Optional if zero non-null rows.
	Average float64 `protobuf:"fixed64,1,opt,name=average,proto3" json:"average,omitempty"`
	// The standard deviation of non-null of double field in the sampled
	// data. Return NaN, if the field has a NaN. Optional if zero non-null
	// rows.
	StandardDeviation float64 `protobuf:"fixed64,3,opt,name=standard_deviation,json=standardDeviation,proto3" json:"standard_deviation,omitempty"`
	// The minimum value of a double field in the sampled data.
	// Return NaN, if the field has a NaN. Optional if zero non-null
	// rows.
	Min float64 `protobuf:"fixed64,4,opt,name=min,proto3" json:"min,omitempty"`
	// A quartile divide the numebr of data points into four parts, or
	// quarters, of more-or-less equal size. Three main quartiles used
	// are: The first quartile (Q1) splits off the lowest 25% of data from
	// the highest 75%. It is also known as the lower or 25th empirical
	// quartile, as 25% of the data is below this point. The second
	// quartile (Q2) is the median of a data set. So, 50% of the data lies
	// below this point. The third quartile (Q3) splits off the highest
	// 25% of data from the lowest 75%. It is known as the upper or 75th
	// empirical quartile, as 75% of the data lies below this point. So,
	// here the quartiles is provided as an ordered list of quartile
	// values, occurring in order Q1, median, Q3.
	Quartiles []float64 `protobuf:"fixed64,6,rep,packed,name=quartiles,proto3" json:"quartiles,omitempty"`
	// The maximum value of a double field in the sampled data.
	// Return NaN, if the field has a NaN. Optional if zero non-null
	// rows.
	Max float64 `protobuf:"fixed64,5,opt,name=max,proto3" json:"max,omitempty"`
	// contains filtered or unexported fields
}

DoubleFieldInfo defines output for any double type field.

func (*DataProfileResult_Profile_Field_ProfileInfo_DoubleFieldInfo) Descriptor

Deprecated: Use DataProfileResult_Profile_Field_ProfileInfo_DoubleFieldInfo.ProtoReflect.Descriptor instead.

func (*DataProfileResult_Profile_Field_ProfileInfo_DoubleFieldInfo) GetAverage

func (*DataProfileResult_Profile_Field_ProfileInfo_DoubleFieldInfo) GetMax

func (*DataProfileResult_Profile_Field_ProfileInfo_DoubleFieldInfo) GetMin

func (*DataProfileResult_Profile_Field_ProfileInfo_DoubleFieldInfo) GetQuartiles

func (*DataProfileResult_Profile_Field_ProfileInfo_DoubleFieldInfo) GetStandardDeviation

func (*DataProfileResult_Profile_Field_ProfileInfo_DoubleFieldInfo) ProtoMessage

func (*DataProfileResult_Profile_Field_ProfileInfo_DoubleFieldInfo) ProtoReflect

func (*DataProfileResult_Profile_Field_ProfileInfo_DoubleFieldInfo) Reset

func (*DataProfileResult_Profile_Field_ProfileInfo_DoubleFieldInfo) String

DataProfileResult_Profile_Field_ProfileInfo_DoubleProfile

type DataProfileResult_Profile_Field_ProfileInfo_DoubleProfile struct {
	// The corresponding double field profile.
	DoubleProfile *DataProfileResult_Profile_Field_ProfileInfo_DoubleFieldInfo `protobuf:"bytes,103,opt,name=double_profile,json=doubleProfile,proto3,oneof"`
}

DataProfileResult_Profile_Field_ProfileInfo_IntegerFieldInfo

type DataProfileResult_Profile_Field_ProfileInfo_IntegerFieldInfo struct {

	// The average of non-null values of integer field in the sampled
	// data. Return NaN, if the field has a NaN. Optional if zero non-null
	// rows.
	Average float64 `protobuf:"fixed64,1,opt,name=average,proto3" json:"average,omitempty"`
	// The standard deviation of non-null of integer field in the sampled
	// data. Return NaN, if the field has a NaN. Optional if zero non-null
	// rows.
	StandardDeviation float64 `protobuf:"fixed64,3,opt,name=standard_deviation,json=standardDeviation,proto3" json:"standard_deviation,omitempty"`
	// The minimum value of an integer field in the sampled data.
	// Return NaN, if the field has a NaN. Optional if zero non-null
	// rows.
	Min int64 `protobuf:"varint,4,opt,name=min,proto3" json:"min,omitempty"`
	// A quartile divide the number of data points into four parts, or
	// quarters, of more-or-less equal size. Three main quartiles used
	// are: The first quartile (Q1) splits off the lowest 25% of data from
	// the highest 75%. It is also known as the lower or 25th empirical
	// quartile, as 25% of the data is below this point. The second
	// quartile (Q2) is the median of a data set. So, 50% of the data lies
	// below this point. The third quartile (Q3) splits off the highest
	// 25% of data from the lowest 75%. It is known as the upper or 75th
	// empirical quartile, as 75% of the data lies below this point. So,
	// here the quartiles is provided as an ordered list of quartile
	// values, occurring in order Q1, median, Q3.
	Quartiles []int64 `protobuf:"varint,6,rep,packed,name=quartiles,proto3" json:"quartiles,omitempty"`
	// The maximum value of an integer field in the sampled data.
	// Return NaN, if the field has a NaN. Optional if zero non-null
	// rows.
	Max int64 `protobuf:"varint,5,opt,name=max,proto3" json:"max,omitempty"`
	// contains filtered or unexported fields
}

IntegerFieldInfo defines output for any integer type field.

func (*DataProfileResult_Profile_Field_ProfileInfo_IntegerFieldInfo) Descriptor

Deprecated: Use DataProfileResult_Profile_Field_ProfileInfo_IntegerFieldInfo.ProtoReflect.Descriptor instead.

func (*DataProfileResult_Profile_Field_ProfileInfo_IntegerFieldInfo) GetAverage

func (*DataProfileResult_Profile_Field_ProfileInfo_IntegerFieldInfo) GetMax

func (*DataProfileResult_Profile_Field_ProfileInfo_IntegerFieldInfo) GetMin

func (*DataProfileResult_Profile_Field_ProfileInfo_IntegerFieldInfo) GetQuartiles

func (*DataProfileResult_Profile_Field_ProfileInfo_IntegerFieldInfo) GetStandardDeviation

func (*DataProfileResult_Profile_Field_ProfileInfo_IntegerFieldInfo) ProtoMessage

func (*DataProfileResult_Profile_Field_ProfileInfo_IntegerFieldInfo) ProtoReflect

func (*DataProfileResult_Profile_Field_ProfileInfo_IntegerFieldInfo) Reset

func (*DataProfileResult_Profile_Field_ProfileInfo_IntegerFieldInfo) String

DataProfileResult_Profile_Field_ProfileInfo_IntegerProfile

type DataProfileResult_Profile_Field_ProfileInfo_IntegerProfile struct {
	// The corresponding integer field profile.
	IntegerProfile *DataProfileResult_Profile_Field_ProfileInfo_IntegerFieldInfo `protobuf:"bytes,102,opt,name=integer_profile,json=integerProfile,proto3,oneof"`
}

DataProfileResult_Profile_Field_ProfileInfo_StringFieldInfo

type DataProfileResult_Profile_Field_ProfileInfo_StringFieldInfo struct {

	// The minimum length of the string field in the sampled data.
	// Optional if zero non-null rows.
	MinLength int64 `protobuf:"varint,1,opt,name=min_length,json=minLength,proto3" json:"min_length,omitempty"`
	// The maximum length of a string field in the sampled data.
	// Optional if zero non-null rows.
	MaxLength int64 `protobuf:"varint,2,opt,name=max_length,json=maxLength,proto3" json:"max_length,omitempty"`
	// The average length of a string field in the sampled data.
	// Optional if zero non-null rows.
	AverageLength float64 `protobuf:"fixed64,3,opt,name=average_length,json=averageLength,proto3" json:"average_length,omitempty"`
	// contains filtered or unexported fields
}

StringFieldInfo defines output info for any string type field.

func (*DataProfileResult_Profile_Field_ProfileInfo_StringFieldInfo) Descriptor

Deprecated: Use DataProfileResult_Profile_Field_ProfileInfo_StringFieldInfo.ProtoReflect.Descriptor instead.

func (*DataProfileResult_Profile_Field_ProfileInfo_StringFieldInfo) GetAverageLength

func (*DataProfileResult_Profile_Field_ProfileInfo_StringFieldInfo) GetMaxLength

func (*DataProfileResult_Profile_Field_ProfileInfo_StringFieldInfo) GetMinLength

func (*DataProfileResult_Profile_Field_ProfileInfo_StringFieldInfo) ProtoMessage

func (*DataProfileResult_Profile_Field_ProfileInfo_StringFieldInfo) ProtoReflect

func (*DataProfileResult_Profile_Field_ProfileInfo_StringFieldInfo) Reset

func (*DataProfileResult_Profile_Field_ProfileInfo_StringFieldInfo) String

DataProfileResult_Profile_Field_ProfileInfo_StringProfile

type DataProfileResult_Profile_Field_ProfileInfo_StringProfile struct {
	// The corresponding string field profile.
	StringProfile *DataProfileResult_Profile_Field_ProfileInfo_StringFieldInfo `protobuf:"bytes,101,opt,name=string_profile,json=stringProfile,proto3,oneof"`
}

DataProfileResult_Profile_Field_ProfileInfo_TopNValue

type DataProfileResult_Profile_Field_ProfileInfo_TopNValue struct {

	// The value is the string value of the actual value from the field.
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// The frequency count of the corresponding value in the field.
	Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

The TopNValue defines the structure of output of top N values of a field.

func (*DataProfileResult_Profile_Field_ProfileInfo_TopNValue) Descriptor

Deprecated: Use DataProfileResult_Profile_Field_ProfileInfo_TopNValue.ProtoReflect.Descriptor instead.

func (*DataProfileResult_Profile_Field_ProfileInfo_TopNValue) GetCount

func (*DataProfileResult_Profile_Field_ProfileInfo_TopNValue) GetValue

func (*DataProfileResult_Profile_Field_ProfileInfo_TopNValue) ProtoMessage

func (*DataProfileResult_Profile_Field_ProfileInfo_TopNValue) ProtoReflect

func (*DataProfileResult_Profile_Field_ProfileInfo_TopNValue) Reset

func (*DataProfileResult_Profile_Field_ProfileInfo_TopNValue) String

DataProfileSpec

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

DataProfileScan related setting.

func (*DataProfileSpec) Descriptor

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

Deprecated: Use DataProfileSpec.ProtoReflect.Descriptor instead.

func (*DataProfileSpec) ProtoMessage

func (*DataProfileSpec) ProtoMessage()

func (*DataProfileSpec) ProtoReflect

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

func (*DataProfileSpec) Reset

func (x *DataProfileSpec) Reset()

func (*DataProfileSpec) String

func (x *DataProfileSpec) String() string

DataQualityDimensionResult

type DataQualityDimensionResult struct {

	// Whether the dimension passed or failed.
	Passed bool `protobuf:"varint,3,opt,name=passed,proto3" json:"passed,omitempty"`
	// contains filtered or unexported fields
}

DataQualityDimensionResult provides a more detailed, per-dimension level view of the results.

func (*DataQualityDimensionResult) Descriptor

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

Deprecated: Use DataQualityDimensionResult.ProtoReflect.Descriptor instead.

func (*DataQualityDimensionResult) GetPassed

func (x *DataQualityDimensionResult) GetPassed() bool

func (*DataQualityDimensionResult) ProtoMessage

func (*DataQualityDimensionResult) ProtoMessage()

func (*DataQualityDimensionResult) ProtoReflect

func (*DataQualityDimensionResult) Reset

func (x *DataQualityDimensionResult) Reset()

func (*DataQualityDimensionResult) String

func (x *DataQualityDimensionResult) String() string

DataQualityResult

type DataQualityResult struct {

	// Overall data quality result -- `true` if all rules passed.
	Passed bool `protobuf:"varint,5,opt,name=passed,proto3" json:"passed,omitempty"`
	// A list of results at the dimension-level.
	Dimensions []*DataQualityDimensionResult `protobuf:"bytes,2,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	// A list of all the rules in a job, and their results.
	Rules []*DataQualityRuleResult `protobuf:"bytes,3,rep,name=rules,proto3" json:"rules,omitempty"`
	// The count of rows processed.
	RowCount int64 `protobuf:"varint,4,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	// The data scanned for this result.
	ScannedData *ScannedData `protobuf:"bytes,7,opt,name=scanned_data,json=scannedData,proto3" json:"scanned_data,omitempty"`
	// contains filtered or unexported fields
}

The output of a DataQualityScan.

func (*DataQualityResult) Descriptor

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

Deprecated: Use DataQualityResult.ProtoReflect.Descriptor instead.

func (*DataQualityResult) GetDimensions

func (x *DataQualityResult) GetDimensions() []*DataQualityDimensionResult

func (*DataQualityResult) GetPassed

func (x *DataQualityResult) GetPassed() bool

func (*DataQualityResult) GetRowCount

func (x *DataQualityResult) GetRowCount() int64

func (*DataQualityResult) GetRules

func (x *DataQualityResult) GetRules() []*DataQualityRuleResult

func (*DataQualityResult) GetScannedData

func (x *DataQualityResult) GetScannedData() *ScannedData

func (*DataQualityResult) ProtoMessage

func (*DataQualityResult) ProtoMessage()

func (*DataQualityResult) ProtoReflect

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

func (*DataQualityResult) Reset

func (x *DataQualityResult) Reset()

func (*DataQualityResult) String

func (x *DataQualityResult) String() string

DataQualityRule

type DataQualityRule struct {

	// Types that are assignable to RuleType:
	//
	//	*DataQualityRule_RangeExpectation_
	//	*DataQualityRule_NonNullExpectation_
	//	*DataQualityRule_SetExpectation_
	//	*DataQualityRule_RegexExpectation_
	//	*DataQualityRule_UniquenessExpectation_
	//	*DataQualityRule_StatisticRangeExpectation_
	//	*DataQualityRule_RowConditionExpectation_
	//	*DataQualityRule_TableConditionExpectation_
	RuleType isDataQualityRule_RuleType `protobuf_oneof:"rule_type"`
	// Optional. The unnested column which this rule is evaluated against.
	Column string `protobuf:"bytes,500,opt,name=column,proto3" json:"column,omitempty"`
	// Optional. Rows with null values will automatically fail a rule, unless
	// ignore_null is true. In that case, such null rows are trivially considered
	// passing. Only applicable to ColumnMap rules.
	IgnoreNull bool `protobuf:"varint,501,opt,name=ignore_null,json=ignoreNull,proto3" json:"ignore_null,omitempty"`
	// Required. The dimension a rule belongs to. Results are also aggregated at
	// the dimension-level. Supported dimensions are ["COMPLETENESS", "ACCURACY",
	// "CONSISTENCY", "VALIDITY", "UNIQUENESS", "INTEGRITY"]
	Dimension string `protobuf:"bytes,502,opt,name=dimension,proto3" json:"dimension,omitempty"`
	// Optional. The minimum ratio of passing_rows / total_rows required to pass
	// this rule, with a range of [0.0, 1.0]
	//
	// 0 indicates default value (i.e. 1.0)
	Threshold float64 `protobuf:"fixed64,503,opt,name=threshold,proto3" json:"threshold,omitempty"`
	// contains filtered or unexported fields
}

A rule captures data quality intent about a data source.

func (*DataQualityRule) Descriptor

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

Deprecated: Use DataQualityRule.ProtoReflect.Descriptor instead.

func (*DataQualityRule) GetColumn

func (x *DataQualityRule) GetColumn() string

func (*DataQualityRule) GetDimension

func (x *DataQualityRule) GetDimension() string

func (*DataQualityRule) GetIgnoreNull

func (x *DataQualityRule) GetIgnoreNull() bool

func (*DataQualityRule) GetNonNullExpectation

func (x *DataQualityRule) GetNonNullExpectation() *DataQualityRule_NonNullExpectation

func (*DataQualityRule) GetRangeExpectation

func (x *DataQualityRule) GetRangeExpectation() *DataQualityRule_RangeExpectation

func (*DataQualityRule) GetRegexExpectation

func (x *DataQualityRule) GetRegexExpectation() *DataQualityRule_RegexExpectation

func (*DataQualityRule) GetRowConditionExpectation

func (x *DataQualityRule) GetRowConditionExpectation() *DataQualityRule_RowConditionExpectation

func (*DataQualityRule) GetRuleType

func (m *DataQualityRule) GetRuleType() isDataQualityRule_RuleType

func (*DataQualityRule) GetSetExpectation

func (x *DataQualityRule) GetSetExpectation() *DataQualityRule_SetExpectation

func (*DataQualityRule) GetStatisticRangeExpectation

func (x *DataQualityRule) GetStatisticRangeExpectation() *DataQualityRule_StatisticRangeExpectation

func (*DataQualityRule) GetTableConditionExpectation

func (x *DataQualityRule) GetTableConditionExpectation() *DataQualityRule_TableConditionExpectation

func (*DataQualityRule) GetThreshold

func (x *DataQualityRule) GetThreshold() float64

func (*DataQualityRule) GetUniquenessExpectation

func (x *DataQualityRule) GetUniquenessExpectation() *DataQualityRule_UniquenessExpectation

func (*DataQualityRule) ProtoMessage

func (*DataQualityRule) ProtoMessage()

func (*DataQualityRule) ProtoReflect

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

func (*DataQualityRule) Reset

func (x *DataQualityRule) Reset()

func (*DataQualityRule) String

func (x *DataQualityRule) String() string

DataQualityRuleResult

type DataQualityRuleResult struct {

	// The rule specified in the DataQualitySpec, as is.
	Rule *DataQualityRule `protobuf:"bytes,1,opt,name=rule,proto3" json:"rule,omitempty"`
	// Whether the rule passed or failed.
	Passed bool `protobuf:"varint,7,opt,name=passed,proto3" json:"passed,omitempty"`
	// The number of rows a rule was evaluated against.
	// This field is only valid for ColumnMap type rules.
	// Evaluated count can be configured to either
	// (1) include all rows (default) - with null rows automatically failing rule
	// evaluation  OR (2) exclude null rows from the evaluated_count, by setting
	// ignore_nulls = true
	EvaluatedCount int64 `protobuf:"varint,9,opt,name=evaluated_count,json=evaluatedCount,proto3" json:"evaluated_count,omitempty"`
	// The number of rows which passed a rule evaluation.
	// This field is only valid for ColumnMap type rules.
	PassedCount int64 `protobuf:"varint,8,opt,name=passed_count,json=passedCount,proto3" json:"passed_count,omitempty"`
	// The number of rows with null values in the specified column.
	NullCount int64 `protobuf:"varint,5,opt,name=null_count,json=nullCount,proto3" json:"null_count,omitempty"`
	// The ratio of passed_count / evaluated_count.
	// This field is only valid for ColumnMap type rules.
	PassRatio float64 `protobuf:"fixed64,6,opt,name=pass_ratio,json=passRatio,proto3" json:"pass_ratio,omitempty"`
	// The query to find rows that did not pass this rule.
	// Only applies to ColumnMap and RowCondition rules.
	FailingRowsQuery string `protobuf:"bytes,10,opt,name=failing_rows_query,json=failingRowsQuery,proto3" json:"failing_rows_query,omitempty"`
	// contains filtered or unexported fields
}

DataQualityRuleResult provides a more detailed, per-rule level view of the results.

func (*DataQualityRuleResult) Descriptor

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

Deprecated: Use DataQualityRuleResult.ProtoReflect.Descriptor instead.

func (*DataQualityRuleResult) GetEvaluatedCount

func (x *DataQualityRuleResult) GetEvaluatedCount() int64

func (*DataQualityRuleResult) GetFailingRowsQuery

func (x *DataQualityRuleResult) GetFailingRowsQuery() string

func (*DataQualityRuleResult) GetNullCount

func (x *DataQualityRuleResult) GetNullCount() int64

func (*DataQualityRuleResult) GetPassRatio

func (x *DataQualityRuleResult) GetPassRatio() float64

func (*DataQualityRuleResult) GetPassed

func (x *DataQualityRuleResult) GetPassed() bool

func (*DataQualityRuleResult) GetPassedCount

func (x *DataQualityRuleResult) GetPassedCount() int64

func (*DataQualityRuleResult) GetRule

func (x *DataQualityRuleResult) GetRule() *DataQualityRule

func (*DataQualityRuleResult) ProtoMessage

func (*DataQualityRuleResult) ProtoMessage()

func (*DataQualityRuleResult) ProtoReflect

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

func (*DataQualityRuleResult) Reset

func (x *DataQualityRuleResult) Reset()

func (*DataQualityRuleResult) String

func (x *DataQualityRuleResult) String() string

DataQualityRule_NonNullExpectation

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

Evaluates whether each column value is null.

func (*DataQualityRule_NonNullExpectation) Descriptor

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

Deprecated: Use DataQualityRule_NonNullExpectation.ProtoReflect.Descriptor instead.

func (*DataQualityRule_NonNullExpectation) ProtoMessage

func (*DataQualityRule_NonNullExpectation) ProtoMessage()

func (*DataQualityRule_NonNullExpectation) ProtoReflect

func (*DataQualityRule_NonNullExpectation) Reset

func (*DataQualityRule_NonNullExpectation) String

DataQualityRule_NonNullExpectation_

type DataQualityRule_NonNullExpectation_ struct {
	// ColumnMap rule which evaluates whether each column value is null.
	NonNullExpectation *DataQualityRule_NonNullExpectation `protobuf:"bytes,2,opt,name=non_null_expectation,json=nonNullExpectation,proto3,oneof"`
}

DataQualityRule_RangeExpectation

type DataQualityRule_RangeExpectation struct {

	// Optional. The minimum column value allowed for a row to pass this
	// validation. At least one of min_value and max_value need to be provided.
	MinValue string `protobuf:"bytes,1,opt,name=min_value,json=minValue,proto3" json:"min_value,omitempty"`
	// Optional. The maximum column value allowed for a row to pass this
	// validation. At least one of min_value and max_value need to be provided.
	MaxValue string `protobuf:"bytes,2,opt,name=max_value,json=maxValue,proto3" json:"max_value,omitempty"`
	// Optional. Whether each value needs to be strictly greater than ('>') the
	// minimum, or if equality is allowed. Only relevant if a min_value has been
	// defined. Default = false.
	StrictMinEnabled bool `protobuf:"varint,3,opt,name=strict_min_enabled,json=strictMinEnabled,proto3" json:"strict_min_enabled,omitempty"`
	// Optional. Whether each value needs to be strictly lesser than ('<') the="" maximum,="" or="" if="" equality="" is="" allowed.="" only="" relevant="" if="" a="" max_value="" has="" been="" defined.="" default="false." strictmaxenabled="">bool `protobuf:"varint,4,opt,name=strict_max_enabled,json=strictMaxEnabled,proto3" json:"strict_max_enabled,omitempty"`
	// contains filtered or unexported fields
}

Evaluates whether each column value lies between a specified range.

func (*DataQualityRule_RangeExpectation) Descriptor

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

Deprecated: Use DataQualityRule_RangeExpectation.ProtoReflect.Descriptor instead.

func (*DataQualityRule_RangeExpectation) GetMaxValue

func (x *DataQualityRule_RangeExpectation) GetMaxValue() string

func (*DataQualityRule_RangeExpectation) GetMinValue

func (x *DataQualityRule_RangeExpectation) GetMinValue() string

func (*DataQualityRule_RangeExpectation) GetStrictMaxEnabled

func (x *DataQualityRule_RangeExpectation) GetStrictMaxEnabled() bool

func (*DataQualityRule_RangeExpectation) GetStrictMinEnabled

func (x *DataQualityRule_RangeExpectation) GetStrictMinEnabled() bool

func (*DataQualityRule_RangeExpectation) ProtoMessage

func (*DataQualityRule_RangeExpectation) ProtoMessage()

func (*DataQualityRule_RangeExpectation) ProtoReflect

func (*DataQualityRule_RangeExpectation) Reset

func (*DataQualityRule_RangeExpectation) String

DataQualityRule_RangeExpectation_

type DataQualityRule_RangeExpectation_ struct {
	// ColumnMap rule which evaluates whether each column value lies between a
	// specified range.
	RangeExpectation *DataQualityRule_RangeExpectation `protobuf:"bytes,1,opt,name=range_expectation,json=rangeExpectation,proto3,oneof"`
}

DataQualityRule_RegexExpectation

type DataQualityRule_RegexExpectation struct {
	Regex string `protobuf:"bytes,1,opt,name=regex,proto3" json:"regex,omitempty"`
	// contains filtered or unexported fields
}

Evaluates whether each column value matches a specified regex.

func (*DataQualityRule_RegexExpectation) Descriptor

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

Deprecated: Use DataQualityRule_RegexExpectation.ProtoReflect.Descriptor instead.

func (*DataQualityRule_RegexExpectation) GetRegex

func (*DataQualityRule_RegexExpectation) ProtoMessage

func (*DataQualityRule_RegexExpectation) ProtoMessage()

func (*DataQualityRule_RegexExpectation) ProtoReflect

func (*DataQualityRule_RegexExpectation) Reset

func (*DataQualityRule_RegexExpectation) String

DataQualityRule_RegexExpectation_

type DataQualityRule_RegexExpectation_ struct {
	// ColumnMap rule which evaluates whether each column value matches a
	// specified regex.
	RegexExpectation *DataQualityRule_RegexExpectation `protobuf:"bytes,4,opt,name=regex_expectation,json=regexExpectation,proto3,oneof"`
}

DataQualityRule_RowConditionExpectation

type DataQualityRule_RowConditionExpectation struct {
	SqlExpression string `protobuf:"bytes,1,opt,name=sql_expression,json=sqlExpression,proto3" json:"sql_expression,omitempty"`
	// contains filtered or unexported fields
}

Evaluates whether each row passes the specified condition. The SQL expression needs to use BigQuery standard SQL syntax and should produce a boolean per row as the result. Example: col1 >= 0 AND col2 < 10

func (*DataQualityRule_RowConditionExpectation) Descriptor

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

Deprecated: Use DataQualityRule_RowConditionExpectation.ProtoReflect.Descriptor instead.

func (*DataQualityRule_RowConditionExpectation) GetSqlExpression

func (x *DataQualityRule_RowConditionExpectation) GetSqlExpression() string

func (*DataQualityRule_RowConditionExpectation) ProtoMessage

func (*DataQualityRule_RowConditionExpectation) ProtoReflect

func (*DataQualityRule_RowConditionExpectation) Reset

func (*DataQualityRule_RowConditionExpectation) String

DataQualityRule_RowConditionExpectation_

type DataQualityRule_RowConditionExpectation_ struct {
	// Table rule which evaluates whether each row passes the specified
	// condition.
	RowConditionExpectation *DataQualityRule_RowConditionExpectation `protobuf:"bytes,200,opt,name=row_condition_expectation,json=rowConditionExpectation,proto3,oneof"`
}

DataQualityRule_SetExpectation

type DataQualityRule_SetExpectation struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Evaluates whether each column value is contained by a specified set.

func (*DataQualityRule_SetExpectation) Descriptor

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

Deprecated: Use DataQualityRule_SetExpectation.ProtoReflect.Descriptor instead.

func (*DataQualityRule_SetExpectation) GetValues

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

func (*DataQualityRule_SetExpectation) ProtoMessage

func (*DataQualityRule_SetExpectation) ProtoMessage()

func (*DataQualityRule_SetExpectation) ProtoReflect

func (*DataQualityRule_SetExpectation) Reset

func (x *DataQualityRule_SetExpectation) Reset()

func (*DataQualityRule_SetExpectation) String

DataQualityRule_SetExpectation_

type DataQualityRule_SetExpectation_ struct {
	// ColumnMap rule which evaluates whether each column value is contained by
	// a specified set.
	SetExpectation *DataQualityRule_SetExpectation `protobuf:"bytes,3,opt,name=set_expectation,json=setExpectation,proto3,oneof"`
}

DataQualityRule_StatisticRangeExpectation

type DataQualityRule_StatisticRangeExpectation struct {
	Statistic DataQualityRule_StatisticRangeExpectation_ColumnStatistic "" /* 160 byte string literal not displayed */

	MinValue string `protobuf:"bytes,2,opt,name=min_value,json=minValue,proto3" json:"min_value,omitempty"`

	MaxValue string `protobuf:"bytes,3,opt,name=max_value,json=maxValue,proto3" json:"max_value,omitempty"`

	StrictMinEnabled bool `protobuf:"varint,4,opt,name=strict_min_enabled,json=strictMinEnabled,proto3" json:"strict_min_enabled,omitempty"`

	StrictMaxEnabled bool `protobuf:"varint,5,opt,name=strict_max_enabled,json=strictMaxEnabled,proto3" json:"strict_max_enabled,omitempty"`

}

Evaluates whether the column aggregate statistic lies between a specified range.

func (*DataQualityRule_StatisticRangeExpectation) Descriptor

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

Deprecated: Use DataQualityRule_StatisticRangeExpectation.ProtoReflect.Descriptor instead.

func (*DataQualityRule_StatisticRangeExpectation) GetMaxValue

func (*DataQualityRule_StatisticRangeExpectation) GetMinValue

func (*DataQualityRule_StatisticRangeExpectation) GetStatistic

func (*DataQualityRule_StatisticRangeExpectation) GetStrictMaxEnabled

func (x *DataQualityRule_StatisticRangeExpectation) GetStrictMaxEnabled() bool

func (*DataQualityRule_StatisticRangeExpectation) GetStrictMinEnabled

func (x *DataQualityRule_StatisticRangeExpectation) GetStrictMinEnabled() bool

func (*DataQualityRule_StatisticRangeExpectation) ProtoMessage

func (*DataQualityRule_StatisticRangeExpectation) ProtoReflect

func (*DataQualityRule_StatisticRangeExpectation) Reset

func (*DataQualityRule_StatisticRangeExpectation) String

DataQualityRule_StatisticRangeExpectation_

type DataQualityRule_StatisticRangeExpectation_ struct {
	// ColumnAggregate rule which evaluates whether the column aggregate
	// statistic lies between a specified range.
	StatisticRangeExpectation *DataQualityRule_StatisticRangeExpectation `protobuf:"bytes,101,opt,name=statistic_range_expectation,json=statisticRangeExpectation,proto3,oneof"`
}

DataQualityRule_StatisticRangeExpectation_ColumnStatistic

type DataQualityRule_StatisticRangeExpectation_ColumnStatistic int32

DataQualityRule_StatisticRangeExpectation_STATISTIC_UNDEFINED, DataQualityRule_StatisticRangeExpectation_MEAN, DataQualityRule_StatisticRangeExpectation_MIN, DataQualityRule_StatisticRangeExpectation_MAX

const (
	// Unspecified statistic type
	DataQualityRule_StatisticRangeExpectation_STATISTIC_UNDEFINED DataQualityRule_StatisticRangeExpectation_ColumnStatistic = 0
	// Evaluate the column mean
	DataQualityRule_StatisticRangeExpectation_MEAN DataQualityRule_StatisticRangeExpectation_ColumnStatistic = 1
	// Evaluate the column min
	DataQualityRule_StatisticRangeExpectation_MIN DataQualityRule_StatisticRangeExpectation_ColumnStatistic = 2
	// Evaluate the column max
	DataQualityRule_StatisticRangeExpectation_MAX DataQualityRule_StatisticRangeExpectation_ColumnStatistic = 3
)

func (DataQualityRule_StatisticRangeExpectation_ColumnStatistic) Descriptor

func (DataQualityRule_StatisticRangeExpectation_ColumnStatistic) Enum

func (DataQualityRule_StatisticRangeExpectation_ColumnStatistic) EnumDescriptor

Deprecated: Use DataQualityRule_StatisticRangeExpectation_ColumnStatistic.Descriptor instead.

func (DataQualityRule_StatisticRangeExpectation_ColumnStatistic) Number

func (DataQualityRule_StatisticRangeExpectation_ColumnStatistic) String

func (DataQualityRule_StatisticRangeExpectation_ColumnStatistic) Type

DataQualityRule_TableConditionExpectation

type DataQualityRule_TableConditionExpectation struct {
	SqlExpression string `protobuf:"bytes,1,opt,name=sql_expression,json=sqlExpression,proto3" json:"sql_expression,omitempty"`
	// contains filtered or unexported fields
}

Evaluates whether the provided expression is true. The SQL expression needs to use BigQuery standard SQL syntax and should produce a scalar boolean result. Example: MIN(col1) >= 0

func (*DataQualityRule_TableConditionExpectation) Descriptor

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

Deprecated: Use DataQualityRule_TableConditionExpectation.ProtoReflect.Descriptor instead.

func (*DataQualityRule_TableConditionExpectation) GetSqlExpression

func (x *DataQualityRule_TableConditionExpectation) GetSqlExpression() string

func (*DataQualityRule_TableConditionExpectation) ProtoMessage

func (*DataQualityRule_TableConditionExpectation) ProtoReflect

func (*DataQualityRule_TableConditionExpectation) Reset

func (*DataQualityRule_TableConditionExpectation) String

DataQualityRule_TableConditionExpectation_

type DataQualityRule_TableConditionExpectation_ struct {
	// Table rule which evaluates whether the provided expression is true.
	TableConditionExpectation *DataQualityRule_TableConditionExpectation `protobuf:"bytes,201,opt,name=table_condition_expectation,json=tableConditionExpectation,proto3,oneof"`
}

DataQualityRule_UniquenessExpectation

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

Evaluates whether the column has duplicates.

func (*DataQualityRule_UniquenessExpectation) Descriptor

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

Deprecated: Use DataQualityRule_UniquenessExpectation.ProtoReflect.Descriptor instead.

func (*DataQualityRule_UniquenessExpectation) ProtoMessage

func (*DataQualityRule_UniquenessExpectation) ProtoMessage()

func (*DataQualityRule_UniquenessExpectation) ProtoReflect

func (*DataQualityRule_UniquenessExpectation) Reset

func (*DataQualityRule_UniquenessExpectation) String

DataQualityRule_UniquenessExpectation_

type DataQualityRule_UniquenessExpectation_ struct {
	// ColumnAggregate rule which evaluates whether the column has duplicates.
	UniquenessExpectation *DataQualityRule_UniquenessExpectation `protobuf:"bytes,100,opt,name=uniqueness_expectation,json=uniquenessExpectation,proto3,oneof"`
}

DataQualitySpec

type DataQualitySpec struct {

	// The list of rules to evaluate against a data source. At least one rule is
	// required.
	Rules []*DataQualityRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

DataQualityScan related setting.

func (*DataQualitySpec) Descriptor

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

Deprecated: Use DataQualitySpec.ProtoReflect.Descriptor instead.

func (*DataQualitySpec) GetRules

func (x *DataQualitySpec) GetRules() []*DataQualityRule

func (*DataQualitySpec) ProtoMessage

func (*DataQualitySpec) ProtoMessage()

func (*DataQualitySpec) ProtoReflect

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

func (*DataQualitySpec) Reset

func (x *DataQualitySpec) Reset()

func (*DataQualitySpec) String

func (x *DataQualitySpec) String() string

DataScan

type DataScan 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"`

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

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

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

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

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

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

	Data *DataSource `protobuf:"bytes,9,opt,name=data,proto3" json:"data,omitempty"`

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

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

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

	Spec isDataScan_Spec `protobuf_oneof:"spec"`

	Result isDataScan_Result `protobuf_oneof:"result"`

}

Represents a user-visible job which provides the insights for the related data source. For examples:

  • Data Quality: generates queries based on the rules and run against the data to get data quality check results.
  • Data Profile: analyzes the data in table(s) and generates insights about the structure, content and relationships (such as null percent, cardinality, min/max/mean, etc).

func (*DataScan) Descriptor

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

Deprecated: Use DataScan.ProtoReflect.Descriptor instead.

func (*DataScan) GetCreateTime

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

func (*DataScan) GetData

func (x *DataScan) GetData() *DataSource

func (*DataScan) GetDataProfileResult

func (x *DataScan) GetDataProfileResult() *DataProfileResult

func (*DataScan) GetDataProfileSpec

func (x *DataScan) GetDataProfileSpec() *DataProfileSpec

func (*DataScan) GetDataQualityResult

func (x *DataScan) GetDataQualityResult() *DataQualityResult

func (*DataScan) GetDataQualitySpec

func (x *DataScan) GetDataQualitySpec() *DataQualitySpec

func (*DataScan) GetDescription

func (x *DataScan) GetDescription() string

func (*DataScan) GetDisplayName

func (x *DataScan) GetDisplayName() string

func (*DataScan) GetExecutionSpec

func (x *DataScan) GetExecutionSpec() *DataScan_ExecutionSpec

func (*DataScan) GetExecutionStatus

func (x *DataScan) GetExecutionStatus() *DataScan_ExecutionStatus

func (*DataScan) GetLabels

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

func (*DataScan) GetName

func (x *DataScan) GetName() string

func (*DataScan) GetResult

func (m *DataScan) GetResult() isDataScan_Result

func (*DataScan) GetSpec

func (m *DataScan) GetSpec() isDataScan_Spec

func (*DataScan) GetState

func (x *DataScan) GetState() State

func (*DataScan) GetType

func (x *DataScan) GetType() DataScanType

func (*DataScan) GetUid

func (x *DataScan) GetUid() string

func (*DataScan) GetUpdateTime

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

func (*DataScan) ProtoMessage

func (*DataScan) ProtoMessage()

func (*DataScan) ProtoReflect

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

func (*DataScan) Reset

func (x *DataScan) Reset()

func (*DataScan) String

func (x *DataScan) String() string

DataScanEvent

type DataScanEvent struct {

	// The data source of the data scan
	DataSource string `protobuf:"bytes,1,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
	// The identifier of the specific data scan job this log entry is for.
	JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// The time when the data scan job started to run.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The time when the data scan job finished.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// The type of the data scan.
	Type DataScanEvent_ScanType `protobuf:"varint,5,opt,name=type,proto3,enum=google.cloud.dataplex.v1.DataScanEvent_ScanType" json:"type,omitempty"`
	// The status of the data scan job.
	State DataScanEvent_State `protobuf:"varint,6,opt,name=state,proto3,enum=google.cloud.dataplex.v1.DataScanEvent_State" json:"state,omitempty"`
	// The message describing the data scan job event.
	Message string `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"`
	// A version identifier of the spec which was used to execute this job.
	SpecVersion string `protobuf:"bytes,8,opt,name=spec_version,json=specVersion,proto3" json:"spec_version,omitempty"`
	// The trigger type of the data scan job.
	Trigger DataScanEvent_Trigger `protobuf:"varint,9,opt,name=trigger,proto3,enum=google.cloud.dataplex.v1.DataScanEvent_Trigger" json:"trigger,omitempty"`
	// The scope of the data scan (e.g. full, incremental).
	Scope DataScanEvent_Scope `protobuf:"varint,10,opt,name=scope,proto3,enum=google.cloud.dataplex.v1.DataScanEvent_Scope" json:"scope,omitempty"`
	// The result of the data scan job.
	//
	// Types that are assignable to Result:
	//
	//	*DataScanEvent_DataProfile
	//	*DataScanEvent_DataQuality
	Result isDataScanEvent_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

These messages contain information about the execution of a datascan. The monitored resource is 'DataScan'

func (*DataScanEvent) Descriptor

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

Deprecated: Use DataScanEvent.ProtoReflect.Descriptor instead.

func (*DataScanEvent) GetDataProfile

func (x *DataScanEvent) GetDataProfile() *DataScanEvent_DataProfileResult

func (*DataScanEvent) GetDataQuality

func (x *DataScanEvent) GetDataQuality() *DataScanEvent_DataQualityResult

func (*DataScanEvent) GetDataSource

func (x *DataScanEvent) GetDataSource() string

func (*DataScanEvent) GetEndTime

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

func (*DataScanEvent) GetJobId

func (x *DataScanEvent) GetJobId() string

func (*DataScanEvent) GetMessage

func (x *DataScanEvent) GetMessage() string

func (*DataScanEvent) GetResult

func (m *DataScanEvent) GetResult() isDataScanEvent_Result

func (*DataScanEvent) GetScope

func (x *DataScanEvent) GetScope() DataScanEvent_Scope

func (*DataScanEvent) GetSpecVersion

func (x *DataScanEvent) GetSpecVersion() string

func (*DataScanEvent) GetStartTime

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

func (*DataScanEvent) GetState

func (x *DataScanEvent) GetState() DataScanEvent_State

func (*DataScanEvent) GetTrigger

func (x *DataScanEvent) GetTrigger() DataScanEvent_Trigger

func (*DataScanEvent) GetType

func (*DataScanEvent) ProtoMessage

func (*DataScanEvent) ProtoMessage()

func (*DataScanEvent) ProtoReflect

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

func (*DataScanEvent) Reset

func (x *DataScanEvent) Reset()

func (*DataScanEvent) String

func (x *DataScanEvent) String() string

DataScanEvent_DataProfile

type DataScanEvent_DataProfile struct {
	// Data profile result for data profile type data scan.
	DataProfile *DataScanEvent_DataProfileResult `protobuf:"bytes,101,opt,name=data_profile,json=dataProfile,proto3,oneof"`
}

DataScanEvent_DataProfileResult

type DataScanEvent_DataProfileResult struct {

	// The count of rows processed in the data scan job.
	RowCount int64 `protobuf:"varint,1,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	// contains filtered or unexported fields
}

Data profile result for data scan job.

func (*DataScanEvent_DataProfileResult) Descriptor

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

Deprecated: Use DataScanEvent_DataProfileResult.ProtoReflect.Descriptor instead.

func (*DataScanEvent_DataProfileResult) GetRowCount

func (x *DataScanEvent_DataProfileResult) GetRowCount() int64

func (*DataScanEvent_DataProfileResult) ProtoMessage

func (*DataScanEvent_DataProfileResult) ProtoMessage()

func (*DataScanEvent_DataProfileResult) ProtoReflect

func (*DataScanEvent_DataProfileResult) Reset

func (*DataScanEvent_DataProfileResult) String

DataScanEvent_DataQuality

type DataScanEvent_DataQuality struct {
	// Data quality result for data quality type data scan.
	DataQuality *DataScanEvent_DataQualityResult `protobuf:"bytes,102,opt,name=data_quality,json=dataQuality,proto3,oneof"`
}

DataScanEvent_DataQualityResult

type DataScanEvent_DataQualityResult struct {
	RowCount int64 `protobuf:"varint,1,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`

	Passed bool `protobuf:"varint,2,opt,name=passed,proto3" json:"passed,omitempty"`

	DimensionPassed map[string]bool "" /* 195 byte string literal not displayed */

}

Data quality result for data scan job.

func (*DataScanEvent_DataQualityResult) Descriptor

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

Deprecated: Use DataScanEvent_DataQualityResult.ProtoReflect.Descriptor instead.

func (*DataScanEvent_DataQualityResult) GetDimensionPassed

func (x *DataScanEvent_DataQualityResult) GetDimensionPassed() map[string]bool

func (*DataScanEvent_DataQualityResult) GetPassed

func (x *DataScanEvent_DataQualityResult) GetPassed() bool

func (*DataScanEvent_DataQualityResult) GetRowCount

func (x *DataScanEvent_DataQualityResult) GetRowCount() int64

func (*DataScanEvent_DataQualityResult) ProtoMessage

func (*DataScanEvent_DataQualityResult) ProtoMessage()

func (*DataScanEvent_DataQualityResult) ProtoReflect

func (*DataScanEvent_DataQualityResult) Reset

func (*DataScanEvent_DataQualityResult) String

DataScanEvent_ScanType

type DataScanEvent_ScanType int32

The type of the data scan.

DataScanEvent_SCAN_TYPE_UNSPECIFIED, DataScanEvent_DATA_PROFILE, DataScanEvent_DATA_QUALITY

const (
	// An unspecified data scan type.
	DataScanEvent_SCAN_TYPE_UNSPECIFIED DataScanEvent_ScanType = 0
	// Data scan for data profile.
	DataScanEvent_DATA_PROFILE DataScanEvent_ScanType = 1
	// Data scan for data quality.
	DataScanEvent_DATA_QUALITY DataScanEvent_ScanType = 2
)

func (DataScanEvent_ScanType) Descriptor

func (DataScanEvent_ScanType) Enum

func (DataScanEvent_ScanType) EnumDescriptor

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

Deprecated: Use DataScanEvent_ScanType.Descriptor instead.

func (DataScanEvent_ScanType) Number

func (DataScanEvent_ScanType) String

func (x DataScanEvent_ScanType) String() string

func (DataScanEvent_ScanType) Type

DataScanEvent_Scope

type DataScanEvent_Scope int32

The scope of job for the data scan.

DataScanEvent_SCOPE_UNSPECIFIED, DataScanEvent_FULL, DataScanEvent_INCREMENTAL

const (
	// An unspecified scope type.
	DataScanEvent_SCOPE_UNSPECIFIED DataScanEvent_Scope = 0
	// Data scan runs on all of the data.
	DataScanEvent_FULL DataScanEvent_Scope = 1
	// Data scan runs on incremental data.
	DataScanEvent_INCREMENTAL DataScanEvent_Scope = 2
)

func (DataScanEvent_Scope) Descriptor

func (DataScanEvent_Scope) Enum

func (DataScanEvent_Scope) EnumDescriptor

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

Deprecated: Use DataScanEvent_Scope.Descriptor instead.

func (DataScanEvent_Scope) Number

func (DataScanEvent_Scope) String

func (x DataScanEvent_Scope) String() string

func (DataScanEvent_Scope) Type

DataScanEvent_State

type DataScanEvent_State int32

The job state of the data scan.

DataScanEvent_STATE_UNSPECIFIED, DataScanEvent_STARTED, DataScanEvent_SUCCEEDED, DataScanEvent_FAILED, DataScanEvent_CANCELLED

const (
	// Unspecified job state.
	DataScanEvent_STATE_UNSPECIFIED DataScanEvent_State = 0
	// Data scan started.
	DataScanEvent_STARTED DataScanEvent_State = 1
	// Data scan successfully completed.
	DataScanEvent_SUCCEEDED DataScanEvent_State = 2
	// Data scan was unsuccessful.
	DataScanEvent_FAILED DataScanEvent_State = 3
	// Data scan was cancelled.
	DataScanEvent_CANCELLED DataScanEvent_State = 4
)

func (DataScanEvent_State) Descriptor

func (DataScanEvent_State) Enum

func (DataScanEvent_State) EnumDescriptor

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

Deprecated: Use DataScanEvent_State.Descriptor instead.

func (DataScanEvent_State) Number

func (DataScanEvent_State) String

func (x DataScanEvent_State) String() string

func (DataScanEvent_State) Type

DataScanEvent_Trigger

type DataScanEvent_Trigger int32

The trigger type for the data scan.

DataScanEvent_TRIGGER_UNSPECIFIED, DataScanEvent_ON_DEMAND, DataScanEvent_SCHEDULE

const (
	// An unspecified trigger type.
	DataScanEvent_TRIGGER_UNSPECIFIED DataScanEvent_Trigger = 0
	// Data scan triggers on demand.
	DataScanEvent_ON_DEMAND DataScanEvent_Trigger = 1
	// Data scan triggers as per schedule.
	DataScanEvent_SCHEDULE DataScanEvent_Trigger = 2
)

func (DataScanEvent_Trigger) Descriptor

func (DataScanEvent_Trigger) Enum

func (DataScanEvent_Trigger) EnumDescriptor

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

Deprecated: Use DataScanEvent_Trigger.Descriptor instead.

func (DataScanEvent_Trigger) Number

func (DataScanEvent_Trigger) String

func (x DataScanEvent_Trigger) String() string

func (DataScanEvent_Trigger) Type

DataScanJob

type DataScanJob struct {

	// Output only. The relative resource name of the DataScanJob, of the form:
	// projects/{project}/locations/{location_id}/dataScans/{datascan_id}/jobs/{job_id}.
	// where `{project}` refers to a project_id or project_number and
	// `location_id` refers to a GCP region.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. System generated globally unique ID for the DataScanJob.
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// Output only. The time when the DataScanJob was started.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Output only. The time when the DataScanJob ended.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Output only. Execution state for the DataScanJob.
	State DataScanJob_State `protobuf:"varint,5,opt,name=state,proto3,enum=google.cloud.dataplex.v1.DataScanJob_State" json:"state,omitempty"`
	// Output only. Additional information about the current state.
	Message string `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
	// Output only. The type of the parent DataScan.
	Type DataScanType `protobuf:"varint,7,opt,name=type,proto3,enum=google.cloud.dataplex.v1.DataScanType" json:"type,omitempty"`
	// Data Scan related setting.
	//
	// Types that are assignable to Spec:
	//
	//	*DataScanJob_DataQualitySpec
	//	*DataScanJob_DataProfileSpec
	Spec isDataScanJob_Spec `protobuf_oneof:"spec"`
	// The result of the data scan.
	//
	// Types that are assignable to Result:
	//
	//	*DataScanJob_DataQualityResult
	//	*DataScanJob_DataProfileResult
	Result isDataScanJob_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

A DataScanJob represents an instance of a data scan.

func (*DataScanJob) Descriptor

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

Deprecated: Use DataScanJob.ProtoReflect.Descriptor instead.

func (*DataScanJob) GetDataProfileResult

func (x *DataScanJob) GetDataProfileResult() *DataProfileResult

func (*DataScanJob) GetDataProfileSpec

func (x *DataScanJob) GetDataProfileSpec() *DataProfileSpec

func (*DataScanJob) GetDataQualityResult

func (x *DataScanJob) GetDataQualityResult() *DataQualityResult

func (*DataScanJob) GetDataQualitySpec

func (x *DataScanJob) GetDataQualitySpec() *DataQualitySpec

func (*DataScanJob) GetEndTime

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

func (*DataScanJob) GetMessage

func (x *DataScanJob) GetMessage() string

func (*DataScanJob) GetName

func (x *DataScanJob) GetName() string

func (*DataScanJob) GetResult

func (m *DataScanJob) GetResult() isDataScanJob_Result

func (*DataScanJob) GetSpec

func (m *DataScanJob) GetSpec() isDataScanJob_Spec

func (*DataScanJob) GetStartTime

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

func (*DataScanJob) GetState

func (x *DataScanJob) GetState() DataScanJob_State

func (*DataScanJob) GetType

func (x *DataScanJob) GetType() DataScanType

func (*DataScanJob) GetUid

func (x *DataScanJob) GetUid() string

func (*DataScanJob) ProtoMessage

func (*DataScanJob) ProtoMessage()

func (*DataScanJob) ProtoReflect

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

func (*DataScanJob) Reset

func (x *DataScanJob) Reset()

func (*DataScanJob) String

func (x *DataScanJob) String() string

DataScanJob_DataProfileResult

type DataScanJob_DataProfileResult struct {
	// Output only. The result of the data profile scan.
	DataProfileResult *DataProfileResult `protobuf:"bytes,201,opt,name=data_profile_result,json=dataProfileResult,proto3,oneof"`
}

DataScanJob_DataProfileSpec

type DataScanJob_DataProfileSpec struct {
	// Output only. DataProfileScan related setting.
	DataProfileSpec *DataProfileSpec `protobuf:"bytes,101,opt,name=data_profile_spec,json=dataProfileSpec,proto3,oneof"`
}

DataScanJob_DataQualityResult

type DataScanJob_DataQualityResult struct {
	// Output only. The result of the data quality scan.
	DataQualityResult *DataQualityResult `protobuf:"bytes,200,opt,name=data_quality_result,json=dataQualityResult,proto3,oneof"`
}

DataScanJob_DataQualitySpec

type DataScanJob_DataQualitySpec struct {
	// Output only. DataQualityScan related setting.
	DataQualitySpec *DataQualitySpec `protobuf:"bytes,100,opt,name=data_quality_spec,json=dataQualitySpec,proto3,oneof"`
}

DataScanJob_State

type DataScanJob_State int32

Execution state for the DataScanJob.

DataScanJob_STATE_UNSPECIFIED, DataScanJob_RUNNING, DataScanJob_CANCELING, DataScanJob_CANCELLED, DataScanJob_SUCCEEDED, DataScanJob_FAILED, DataScanJob_PENDING

const (
	// The DataScanJob state is unspecified.
	DataScanJob_STATE_UNSPECIFIED DataScanJob_State = 0
	// The DataScanJob is running.
	DataScanJob_RUNNING DataScanJob_State = 1
	// The DataScanJob is canceling.
	DataScanJob_CANCELING DataScanJob_State = 2
	// The DataScanJob cancellation was successful.
	DataScanJob_CANCELLED DataScanJob_State = 3
	// The DataScanJob completed successfully.
	DataScanJob_SUCCEEDED DataScanJob_State = 4
	// The DataScanJob is no longer running due to an error.
	DataScanJob_FAILED DataScanJob_State = 5
	// The DataScanJob has been created but not started to run yet.
	DataScanJob_PENDING DataScanJob_State = 7
)

func (DataScanJob_State) Descriptor

func (DataScanJob_State) Enum

func (DataScanJob_State) EnumDescriptor

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

Deprecated: Use DataScanJob_State.Descriptor instead.

func (DataScanJob_State) Number

func (DataScanJob_State) String

func (x DataScanJob_State) String() string

func (DataScanJob_State) Type

DataScanServiceClient

type DataScanServiceClient interface {
	// Creates a dataScan resource.
	CreateDataScan(ctx context.Context, in *CreateDataScanRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Update the dataScan resource.
	UpdateDataScan(ctx context.Context, in *UpdateDataScanRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Delete the dataScan resource.
	DeleteDataScan(ctx context.Context, in *DeleteDataScanRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Get dataScan resource.
	GetDataScan(ctx context.Context, in *GetDataScanRequest, opts ...grpc.CallOption) (*DataScan, error)
	// Lists dataScans.
	ListDataScans(ctx context.Context, in *ListDataScansRequest, opts ...grpc.CallOption) (*ListDataScansResponse, error)
	// Run an on demand execution of a DataScan.
	RunDataScan(ctx context.Context, in *RunDataScanRequest, opts ...grpc.CallOption) (*RunDataScanResponse, error)
	// Get DataScanJob resource.
	GetDataScanJob(ctx context.Context, in *GetDataScanJobRequest, opts ...grpc.CallOption) (*DataScanJob, error)
	// Lists DataScanJobs under the given dataScan.
	ListDataScanJobs(ctx context.Context, in *ListDataScanJobsRequest, opts ...grpc.CallOption) (*ListDataScanJobsResponse, error)
}

DataScanServiceClient is the client API for DataScanService service.

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

func NewDataScanServiceClient

func NewDataScanServiceClient(cc grpc.ClientConnInterface) DataScanServiceClient

DataScanServiceServer

type DataScanServiceServer interface {
	// Creates a dataScan resource.
	CreateDataScan(context.Context, *CreateDataScanRequest) (*longrunning.Operation, error)
	// Update the dataScan resource.
	UpdateDataScan(context.Context, *UpdateDataScanRequest) (*longrunning.Operation, error)
	// Delete the dataScan resource.
	DeleteDataScan(context.Context, *DeleteDataScanRequest) (*longrunning.Operation, error)
	// Get dataScan resource.
	GetDataScan(context.Context, *GetDataScanRequest) (*DataScan, error)
	// Lists dataScans.
	ListDataScans(context.Context, *ListDataScansRequest) (*ListDataScansResponse, error)
	// Run an on demand execution of a DataScan.
	RunDataScan(context.Context, *RunDataScanRequest) (*RunDataScanResponse, error)
	// Get DataScanJob resource.
	GetDataScanJob(context.Context, *GetDataScanJobRequest) (*DataScanJob, error)
	// Lists DataScanJobs under the given dataScan.
	ListDataScanJobs(context.Context, *ListDataScanJobsRequest) (*ListDataScanJobsResponse, error)
}

DataScanServiceServer is the server API for DataScanService service.

DataScanType

type DataScanType int32

The type of DataScan.

DataScanType_DATA_SCAN_TYPE_UNSPECIFIED, DataScanType_DATA_QUALITY, DataScanType_DATA_PROFILE

const (
	// The DataScan Type is unspecified.
	DataScanType_DATA_SCAN_TYPE_UNSPECIFIED DataScanType = 0
	// Data Quality Scan.
	DataScanType_DATA_QUALITY DataScanType = 1
	// Data Profile Scan.
	DataScanType_DATA_PROFILE DataScanType = 2
)

func (DataScanType) Descriptor

func (DataScanType) Enum

func (x DataScanType) Enum() *DataScanType

func (DataScanType) EnumDescriptor

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

Deprecated: Use DataScanType.Descriptor instead.

func (DataScanType) Number

func (DataScanType) String

func (x DataScanType) String() string

func (DataScanType) Type

DataScan_DataProfileResult

type DataScan_DataProfileResult struct {
	// Output only. The result of the data profile scan.
	DataProfileResult *DataProfileResult `protobuf:"bytes,201,opt,name=data_profile_result,json=dataProfileResult,proto3,oneof"`
}

DataScan_DataProfileSpec

type DataScan_DataProfileSpec struct {
	// DataProfileScan related setting.
	DataProfileSpec *DataProfileSpec `protobuf:"bytes,101,opt,name=data_profile_spec,json=dataProfileSpec,proto3,oneof"`
}

DataScan_DataQualityResult

type DataScan_DataQualityResult struct {
	// Output only. The result of the data quality scan.
	DataQualityResult *DataQualityResult `protobuf:"bytes,200,opt,name=data_quality_result,json=dataQualityResult,proto3,oneof"`
}

DataScan_DataQualitySpec

type DataScan_DataQualitySpec struct {
	// DataQualityScan related setting.
	DataQualitySpec *DataQualitySpec `protobuf:"bytes,100,opt,name=data_quality_spec,json=dataQualitySpec,proto3,oneof"`
}

DataScan_ExecutionSpec

type DataScan_ExecutionSpec struct {

	// Optional. Spec related to how often and when a scan should be triggered.
	// If not specified, the default is OnDemand, which means the scan will not
	// run until the user calls RunDataScan API.
	Trigger *Trigger `protobuf:"bytes,1,opt,name=trigger,proto3" json:"trigger,omitempty"`
	// If not specified, run a data scan on all data in the table.
	// The incremental is immutable, which means once the field is set,
	// it cannot be unset, and vice versa.
	//
	// Types that are assignable to Incremental:
	//
	//	*DataScan_ExecutionSpec_Field
	Incremental isDataScan_ExecutionSpec_Incremental `protobuf_oneof:"incremental"`
	// contains filtered or unexported fields
}

DataScan execution settings.

func (*DataScan_ExecutionSpec) Descriptor

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

Deprecated: Use DataScan_ExecutionSpec.ProtoReflect.Descriptor instead.

func (*DataScan_ExecutionSpec) GetField

func (x *DataScan_ExecutionSpec) GetField() string

func (*DataScan_ExecutionSpec) GetIncremental

func (m *DataScan_ExecutionSpec) GetIncremental() isDataScan_ExecutionSpec_Incremental

func (*DataScan_ExecutionSpec) GetTrigger

func (x *DataScan_ExecutionSpec) GetTrigger() *Trigger

func (*DataScan_ExecutionSpec) ProtoMessage

func (*DataScan_ExecutionSpec) ProtoMessage()

func (*DataScan_ExecutionSpec) ProtoReflect

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

func (*DataScan_ExecutionSpec) Reset

func (x *DataScan_ExecutionSpec) Reset()

func (*DataScan_ExecutionSpec) String

func (x *DataScan_ExecutionSpec) String() string

DataScan_ExecutionSpec_Field

type DataScan_ExecutionSpec_Field struct {
	// Immutable. The unnested field (Date or Timestamp) that contains values
	// that monotonically increase over time.
	Field string `protobuf:"bytes,100,opt,name=field,proto3,oneof"`
}

DataScan_ExecutionStatus

type DataScan_ExecutionStatus struct {

	// The time when the latest DataScanJob started.
	LatestJobStartTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=latest_job_start_time,json=latestJobStartTime,proto3" json:"latest_job_start_time,omitempty"`
	// The time when the latest DataScanJob ended.
	LatestJobEndTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=latest_job_end_time,json=latestJobEndTime,proto3" json:"latest_job_end_time,omitempty"`
	// contains filtered or unexported fields
}

Status of the data scan execution.

func (*DataScan_ExecutionStatus) Descriptor

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

Deprecated: Use DataScan_ExecutionStatus.ProtoReflect.Descriptor instead.

func (*DataScan_ExecutionStatus) GetLatestJobEndTime

func (x *DataScan_ExecutionStatus) GetLatestJobEndTime() *timestamppb.Timestamp

func (*DataScan_ExecutionStatus) GetLatestJobStartTime

func (x *DataScan_ExecutionStatus) GetLatestJobStartTime() *timestamppb.Timestamp

func (*DataScan_ExecutionStatus) ProtoMessage

func (*DataScan_ExecutionStatus) ProtoMessage()

func (*DataScan_ExecutionStatus) ProtoReflect

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

func (*DataScan_ExecutionStatus) Reset

func (x *DataScan_ExecutionStatus) Reset()

func (*DataScan_ExecutionStatus) String

func (x *DataScan_ExecutionStatus) String() string

DataSource

type DataSource struct {

	// The source is required and immutable which means once entity is set, it
	// cannot be change to others, and vice versa.
	//
	// Types that are assignable to Source:
	//
	//	*DataSource_Entity
	Source isDataSource_Source `protobuf_oneof:"source"`
	// contains filtered or unexported fields
}

The data source for DataScan.

func (*DataSource) Descriptor

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

Deprecated: Use DataSource.ProtoReflect.Descriptor instead.

func (*DataSource) GetEntity

func (x *DataSource) GetEntity() string

func (*DataSource) GetSource

func (m *DataSource) GetSource() isDataSource_Source

func (*DataSource) ProtoMessage

func (*DataSource) ProtoMessage()

func (*DataSource) ProtoReflect

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

func (*DataSource) Reset

func (x *DataSource) Reset()

func (*DataSource) String

func (x *DataSource) String() string

DataSource_Entity

type DataSource_Entity struct {
	// Immutable. The dataplex entity that contains the data for DataScan, of
	// the form:
	// `projects/{project_number}/locations/{location_id}/lakes/{lake_id}/zones/{zone_id}/entities/{entity_id}`.
	Entity string `protobuf:"bytes,100,opt,name=entity,proto3,oneof"`
}

DataplexServiceClient

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

DeleteDataScanRequest

type DeleteDataScanRequest struct {

	// Required. The resource name of the dataScan:
	// projects/{project}/locations/{location_id}/dataScans/{data_scan_id}
	// where `{project}` refers to a project_id or project_number and
	// `location_id` refers to a GCP region.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Delete dataScan request.

func (*DeleteDataScanRequest) Descriptor

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

Deprecated: Use DeleteDataScanRequest.ProtoReflect.Descriptor instead.

func (*DeleteDataScanRequest) GetName

func (x *DeleteDataScanRequest) GetName() string

func (*DeleteDataScanRequest) ProtoMessage

func (*DeleteDataScanRequest) ProtoMessage()

func (*DeleteDataScanRequest) ProtoReflect

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

func (*DeleteDataScanRequest) Reset

func (x *DeleteDataScanRequest) Reset()

func (*DeleteDataScanRequest) String

func (x *DeleteDataScanRequest) 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 (*DiscoveryEvent) GetAssetId

func (x *DiscoveryEvent) GetAssetId() string

func (*DiscoveryEvent) GetConfig

func (*DiscoveryEvent) GetDataLocation

func (x *DiscoveryEvent) GetDataLocation() string

func (*DiscoveryEvent) GetDetails

func (m *DiscoveryEvent) GetDetails() isDiscoveryEvent_Details

func (*DiscoveryEvent) GetEntity

func (*DiscoveryEvent) GetLakeId

func (x *DiscoveryEvent) GetLakeId() string

func (*DiscoveryEvent) GetMessage

func (x *DiscoveryEvent) GetMessage() string

func (*DiscoveryEvent) GetPartition

func (*DiscoveryEvent) GetType

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 (*DiscoveryEvent_ActionDetails) Reset

func (x *DiscoveryEvent_ActionDetails) Reset()

func (*DiscoveryEvent_ActionDetails) 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 (*DiscoveryEvent_ConfigDetails) Reset

func (x *DiscoveryEvent_ConfigDetails) Reset()

func (*DiscoveryEvent_ConfigDetails) 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 (*DiscoveryEvent_EntityDetails) ProtoMessage

func (*DiscoveryEvent_EntityDetails) ProtoMessage()

func (*DiscoveryEvent_EntityDetails) ProtoReflect

func (*DiscoveryEvent_EntityDetails) Reset

func (x *DiscoveryEvent_EntityDetails) Reset()

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

func (DiscoveryEvent_EntityType) EnumDescriptor

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

Deprecated: Use DiscoveryEvent_EntityType.Descriptor instead.

func (DiscoveryEvent_EntityType) Number

func (DiscoveryEvent_EntityType) String

func (x DiscoveryEvent_EntityType) String() string

func (DiscoveryEvent_EntityType) Type

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

func (DiscoveryEvent_EventType) EnumDescriptor

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

Deprecated: Use DiscoveryEvent_EventType.Descriptor instead.

func (DiscoveryEvent_EventType) Number

func (DiscoveryEvent_EventType) String

func (x DiscoveryEvent_EventType) String() string

func (DiscoveryEvent_EventType) Type

DiscoveryEvent_Partition

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

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

func (*DiscoveryEvent_PartitionDetails) ProtoMessage()

func (*DiscoveryEvent_PartitionDetails) ProtoReflect

func (*DiscoveryEvent_PartitionDetails) Reset

func (*DiscoveryEvent_PartitionDetails) 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 *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time when the entity was last updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Required. A user-provided entity ID. It is mutable, and will be used as the
	// published table name. Specifying a new ID in an update entity
	// request will override the existing value.
	// 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 *