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.FileDescriptorFile_google_cloud_dataplex_v1_content_proto
var File_google_cloud_dataplex_v1_content_proto protoreflect.FileDescriptorFile_google_cloud_dataplex_v1_data_profile_proto
var File_google_cloud_dataplex_v1_data_profile_proto protoreflect.FileDescriptorFile_google_cloud_dataplex_v1_data_quality_proto
var File_google_cloud_dataplex_v1_data_quality_proto protoreflect.FileDescriptorFile_google_cloud_dataplex_v1_datascans_proto
var File_google_cloud_dataplex_v1_datascans_proto protoreflect.FileDescriptorFile_google_cloud_dataplex_v1_logs_proto
var File_google_cloud_dataplex_v1_logs_proto protoreflect.FileDescriptorFile_google_cloud_dataplex_v1_metadata_proto
var File_google_cloud_dataplex_v1_metadata_proto protoreflect.FileDescriptorFile_google_cloud_dataplex_v1_processing_proto
var File_google_cloud_dataplex_v1_processing_proto protoreflect.FileDescriptorFile_google_cloud_dataplex_v1_resources_proto
var File_google_cloud_dataplex_v1_resources_proto protoreflect.FileDescriptorFile_google_cloud_dataplex_v1_service_proto
var File_google_cloud_dataplex_v1_service_proto protoreflect.FileDescriptorFile_google_cloud_dataplex_v1_tasks_proto
var File_google_cloud_dataplex_v1_tasks_proto protoreflect.FileDescriptorFunctions
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
Deprecated: Use Action.ProtoReflect.Descriptor instead.
func (*Action) GetAsset
func (*Action) GetCategory
func (x *Action) GetCategory() Action_Categoryfunc (*Action) GetDataLocations
func (*Action) GetDetails
func (m *Action) GetDetails() isAction_Detailsfunc (*Action) GetDetectTime
func (x *Action) GetDetectTime() *timestamppb.Timestampfunc (*Action) GetFailedSecurityPolicyApply
func (x *Action) GetFailedSecurityPolicyApply() *Action_FailedSecurityPolicyApplyfunc (*Action) GetIncompatibleDataSchema
func (x *Action) GetIncompatibleDataSchema() *Action_IncompatibleDataSchemafunc (*Action) GetInvalidDataFormat
func (x *Action) GetInvalidDataFormat() *Action_InvalidDataFormatfunc (*Action) GetInvalidDataOrganization
func (x *Action) GetInvalidDataOrganization() *Action_InvalidDataOrganizationfunc (*Action) GetInvalidDataPartition
func (x *Action) GetInvalidDataPartition() *Action_InvalidDataPartitionfunc (*Action) GetIssue
func (*Action) GetLake
func (*Action) GetMissingData
func (x *Action) GetMissingData() *Action_MissingDatafunc (*Action) GetMissingResource
func (x *Action) GetMissingResource() *Action_MissingResourcefunc (*Action) GetName
func (*Action) GetUnauthorizedResource
func (x *Action) GetUnauthorizedResource() *Action_UnauthorizedResourcefunc (*Action) GetZone
func (*Action) ProtoMessage
func (*Action) ProtoMessage()func (*Action) ProtoReflect
func (x *Action) ProtoReflect() protoreflect.Messagefunc (*Action) Reset
func (x *Action) Reset()func (*Action) String
Action_Category
type Action_Category int32The category of issues.
Action_CATEGORY_UNSPECIFIED, Action_RESOURCE_MANAGEMENT, Action_SECURITY_POLICY, Action_DATA_DISCOVERY
const (
// Unspecified category.
Action_CATEGORY_UNSPECIFIED Action_Category = 0
// Resource management related issues.
Action_RESOURCE_MANAGEMENT Action_Category = 1
// Security policy related issues.
Action_SECURITY_POLICY Action_Category = 2
// Data and discovery related issues.
Action_DATA_DISCOVERY Action_Category = 3
)func (Action_Category) Descriptor
func (Action_Category) Descriptor() protoreflect.EnumDescriptorfunc (Action_Category) Enum
func (x Action_Category) Enum() *Action_Categoryfunc (Action_Category) EnumDescriptor
func (Action_Category) EnumDescriptor() ([]byte, []int)Deprecated: Use Action_Category.Descriptor instead.
func (Action_Category) Number
func (x Action_Category) Number() protoreflect.EnumNumberfunc (Action_Category) String
func (x Action_Category) String() stringfunc (Action_Category) Type
func (Action_Category) Type() protoreflect.EnumTypeAction_FailedSecurityPolicyApply
type Action_FailedSecurityPolicyApply struct {
// Resource name of one of the assets with failing security policy
// application. Populated for a lake or zone resource only.
Asset string `protobuf:"bytes,1,opt,name=asset,proto3" json:"asset,omitempty"`
// contains filtered or unexported fields
}Failed to apply security policy to the managed resource(s) under a lake, zone or an asset. For a lake or zone resource, one or more underlying assets has a failure applying security policy to the associated managed resource.
func (*Action_FailedSecurityPolicyApply) Descriptor
func (*Action_FailedSecurityPolicyApply) Descriptor() ([]byte, []int)Deprecated: Use Action_FailedSecurityPolicyApply.ProtoReflect.Descriptor instead.
func (*Action_FailedSecurityPolicyApply) GetAsset
func (x *Action_FailedSecurityPolicyApply) GetAsset() stringfunc (*Action_FailedSecurityPolicyApply) ProtoMessage
func (*Action_FailedSecurityPolicyApply) ProtoMessage()func (*Action_FailedSecurityPolicyApply) ProtoReflect
func (x *Action_FailedSecurityPolicyApply) ProtoReflect() protoreflect.Messagefunc (*Action_FailedSecurityPolicyApply) Reset
func (x *Action_FailedSecurityPolicyApply) Reset()func (*Action_FailedSecurityPolicyApply) String
func (x *Action_FailedSecurityPolicyApply) String() stringAction_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() stringfunc (*Action_IncompatibleDataSchema) GetNewSchema
func (x *Action_IncompatibleDataSchema) GetNewSchema() stringfunc (*Action_IncompatibleDataSchema) GetSampledDataLocations
func (x *Action_IncompatibleDataSchema) GetSampledDataLocations() []stringfunc (*Action_IncompatibleDataSchema) GetSchemaChange
func (x *Action_IncompatibleDataSchema) GetSchemaChange() Action_IncompatibleDataSchema_SchemaChangefunc (*Action_IncompatibleDataSchema) GetTable
func (x *Action_IncompatibleDataSchema) GetTable() stringfunc (*Action_IncompatibleDataSchema) ProtoMessage
func (*Action_IncompatibleDataSchema) ProtoMessage()func (*Action_IncompatibleDataSchema) ProtoReflect
func (x *Action_IncompatibleDataSchema) ProtoReflect() protoreflect.Messagefunc (*Action_IncompatibleDataSchema) Reset
func (x *Action_IncompatibleDataSchema) Reset()func (*Action_IncompatibleDataSchema) String
func (x *Action_IncompatibleDataSchema) String() stringAction_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 int32Whether the action relates to a schema that is incompatible or modified.
Action_IncompatibleDataSchema_SCHEMA_CHANGE_UNSPECIFIED, Action_IncompatibleDataSchema_INCOMPATIBLE, Action_IncompatibleDataSchema_MODIFIED
const (
// Schema change unspecified.
Action_IncompatibleDataSchema_SCHEMA_CHANGE_UNSPECIFIED Action_IncompatibleDataSchema_SchemaChange = 0
// Newly discovered schema is incompatible with existing schema.
Action_IncompatibleDataSchema_INCOMPATIBLE Action_IncompatibleDataSchema_SchemaChange = 1
// Newly discovered schema has changed from existing schema for data in a
// curated zone.
Action_IncompatibleDataSchema_MODIFIED Action_IncompatibleDataSchema_SchemaChange = 2
)func (Action_IncompatibleDataSchema_SchemaChange) Descriptor
func (Action_IncompatibleDataSchema_SchemaChange) Descriptor() protoreflect.EnumDescriptorfunc (Action_IncompatibleDataSchema_SchemaChange) Enum
func (x Action_IncompatibleDataSchema_SchemaChange) Enum() *Action_IncompatibleDataSchema_SchemaChangefunc (Action_IncompatibleDataSchema_SchemaChange) EnumDescriptor
func (Action_IncompatibleDataSchema_SchemaChange) EnumDescriptor() ([]byte, []int)Deprecated: Use Action_IncompatibleDataSchema_SchemaChange.Descriptor instead.
func (Action_IncompatibleDataSchema_SchemaChange) Number
func (x Action_IncompatibleDataSchema_SchemaChange) Number() protoreflect.EnumNumberfunc (Action_IncompatibleDataSchema_SchemaChange) String
func (x Action_IncompatibleDataSchema_SchemaChange) String() stringfunc (Action_IncompatibleDataSchema_SchemaChange) Type
func (Action_IncompatibleDataSchema_SchemaChange) Type() protoreflect.EnumTypeAction_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() stringfunc (*Action_InvalidDataFormat) GetNewFormat
func (x *Action_InvalidDataFormat) GetNewFormat() stringfunc (*Action_InvalidDataFormat) GetSampledDataLocations
func (x *Action_InvalidDataFormat) GetSampledDataLocations() []stringfunc (*Action_InvalidDataFormat) ProtoMessage
func (*Action_InvalidDataFormat) ProtoMessage()func (*Action_InvalidDataFormat) ProtoReflect
func (x *Action_InvalidDataFormat) ProtoReflect() protoreflect.Messagefunc (*Action_InvalidDataFormat) Reset
func (x *Action_InvalidDataFormat) Reset()func (*Action_InvalidDataFormat) String
func (x *Action_InvalidDataFormat) String() stringAction_InvalidDataFormat_
type Action_InvalidDataFormat_ struct {
// Details for issues related to invalid or unsupported data formats.
InvalidDataFormat *Action_InvalidDataFormat `protobuf:"bytes,10,opt,name=invalid_data_format,json=invalidDataFormat,proto3,oneof"`
}Action_InvalidDataOrganization
type Action_InvalidDataOrganization struct {
// contains filtered or unexported fields
}Action details for invalid data arrangement.
func (*Action_InvalidDataOrganization) Descriptor
func (*Action_InvalidDataOrganization) Descriptor() ([]byte, []int)Deprecated: Use Action_InvalidDataOrganization.ProtoReflect.Descriptor instead.
func (*Action_InvalidDataOrganization) ProtoMessage
func (*Action_InvalidDataOrganization) ProtoMessage()func (*Action_InvalidDataOrganization) ProtoReflect
func (x *Action_InvalidDataOrganization) ProtoReflect() protoreflect.Messagefunc (*Action_InvalidDataOrganization) Reset
func (x *Action_InvalidDataOrganization) Reset()func (*Action_InvalidDataOrganization) String
func (x *Action_InvalidDataOrganization) String() stringAction_InvalidDataOrganization_
type Action_InvalidDataOrganization_ struct {
// Details for issues related to invalid data arrangement.
InvalidDataOrganization *Action_InvalidDataOrganization `protobuf:"bytes,22,opt,name=invalid_data_organization,json=invalidDataOrganization,proto3,oneof"`
}Action_InvalidDataPartition
type Action_InvalidDataPartition struct {
ExpectedStructure Action_InvalidDataPartition_PartitionStructure "" /* 190 byte string literal not displayed */
}Action details for invalid or unsupported partitions detected by discovery.
func (*Action_InvalidDataPartition) Descriptor
func (*Action_InvalidDataPartition) Descriptor() ([]byte, []int)Deprecated: Use Action_InvalidDataPartition.ProtoReflect.Descriptor instead.
func (*Action_InvalidDataPartition) GetExpectedStructure
func (x *Action_InvalidDataPartition) GetExpectedStructure() Action_InvalidDataPartition_PartitionStructurefunc (*Action_InvalidDataPartition) ProtoMessage
func (*Action_InvalidDataPartition) ProtoMessage()func (*Action_InvalidDataPartition) ProtoReflect
func (x *Action_InvalidDataPartition) ProtoReflect() protoreflect.Messagefunc (*Action_InvalidDataPartition) Reset
func (x *Action_InvalidDataPartition) Reset()func (*Action_InvalidDataPartition) String
func (x *Action_InvalidDataPartition) String() stringAction_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 int32The expected partition structure.
Action_InvalidDataPartition_PARTITION_STRUCTURE_UNSPECIFIED, Action_InvalidDataPartition_CONSISTENT_KEYS, Action_InvalidDataPartition_HIVE_STYLE_KEYS
const (
// PartitionStructure unspecified.
Action_InvalidDataPartition_PARTITION_STRUCTURE_UNSPECIFIED Action_InvalidDataPartition_PartitionStructure = 0
// Consistent hive-style partition definition (both raw and curated zone).
Action_InvalidDataPartition_CONSISTENT_KEYS Action_InvalidDataPartition_PartitionStructure = 1
// Hive style partition definition (curated zone only).
Action_InvalidDataPartition_HIVE_STYLE_KEYS Action_InvalidDataPartition_PartitionStructure = 2
)func (Action_InvalidDataPartition_PartitionStructure) Descriptor
func (Action_InvalidDataPartition_PartitionStructure) Descriptor() protoreflect.EnumDescriptorfunc (Action_InvalidDataPartition_PartitionStructure) Enum
func (x Action_InvalidDataPartition_PartitionStructure) Enum() *Action_InvalidDataPartition_PartitionStructurefunc (Action_InvalidDataPartition_PartitionStructure) EnumDescriptor
func (Action_InvalidDataPartition_PartitionStructure) EnumDescriptor() ([]byte, []int)Deprecated: Use Action_InvalidDataPartition_PartitionStructure.Descriptor instead.
func (Action_InvalidDataPartition_PartitionStructure) Number
func (x Action_InvalidDataPartition_PartitionStructure) Number() protoreflect.EnumNumberfunc (Action_InvalidDataPartition_PartitionStructure) String
func (x Action_InvalidDataPartition_PartitionStructure) String() stringfunc (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.Messagefunc (*Action_MissingData) Reset
func (x *Action_MissingData) Reset()func (*Action_MissingData) String
func (x *Action_MissingData) String() stringAction_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.Messagefunc (*Action_MissingResource) Reset
func (x *Action_MissingResource) Reset()func (*Action_MissingResource) String
func (x *Action_MissingResource) String() stringAction_MissingResource_
type Action_MissingResource_ struct {
// Details for issues related to absence of a managed resource.
MissingResource *Action_MissingResource `protobuf:"bytes,14,opt,name=missing_resource,json=missingResource,proto3,oneof"`
}Action_UnauthorizedResource
type Action_UnauthorizedResource struct {
// contains filtered or unexported fields
}Action details for unauthorized resource issues raised to indicate that the service account associated with the lake instance is not authorized to access or manage the resource associated with an asset.
func (*Action_UnauthorizedResource) Descriptor
func (*Action_UnauthorizedResource) Descriptor() ([]byte, []int)Deprecated: Use Action_UnauthorizedResource.ProtoReflect.Descriptor instead.
func (*Action_UnauthorizedResource) ProtoMessage
func (*Action_UnauthorizedResource) ProtoMessage()func (*Action_UnauthorizedResource) ProtoReflect
func (x *Action_UnauthorizedResource) ProtoReflect() protoreflect.Messagefunc (*Action_UnauthorizedResource) Reset
func (x *Action_UnauthorizedResource) Reset()func (*Action_UnauthorizedResource) String
func (x *Action_UnauthorizedResource) String() stringAction_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
Deprecated: Use Asset.ProtoReflect.Descriptor instead.
func (*Asset) GetCreateTime
func (x *Asset) GetCreateTime() *timestamppb.Timestampfunc (*Asset) GetDescription
func (*Asset) GetDiscoverySpec
func (x *Asset) GetDiscoverySpec() *Asset_DiscoverySpecfunc (*Asset) GetDiscoveryStatus
func (x *Asset) GetDiscoveryStatus() *Asset_DiscoveryStatusfunc (*Asset) GetDisplayName
func (*Asset) GetLabels
func (*Asset) GetName
func (*Asset) GetResourceSpec
func (x *Asset) GetResourceSpec() *Asset_ResourceSpecfunc (*Asset) GetResourceStatus
func (x *Asset) GetResourceStatus() *Asset_ResourceStatusfunc (*Asset) GetSecurityStatus
func (x *Asset) GetSecurityStatus() *Asset_SecurityStatusfunc (*Asset) GetState
func (*Asset) GetUid
func (*Asset) GetUpdateTime
func (x *Asset) GetUpdateTime() *timestamppb.Timestampfunc (*Asset) ProtoMessage
func (*Asset) ProtoMessage()func (*Asset) ProtoReflect
func (x *Asset) ProtoReflect() protoreflect.Messagefunc (*Asset) Reset
func (x *Asset) Reset()func (*Asset) 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() int32func (*AssetStatus) GetSecurityPolicyApplyingAssets
func (x *AssetStatus) GetSecurityPolicyApplyingAssets() int32func (*AssetStatus) GetUpdateTime
func (x *AssetStatus) GetUpdateTime() *timestamppb.Timestampfunc (*AssetStatus) ProtoMessage
func (*AssetStatus) ProtoMessage()func (*AssetStatus) ProtoReflect
func (x *AssetStatus) ProtoReflect() protoreflect.Messagefunc (*AssetStatus) Reset
func (x *AssetStatus) Reset()func (*AssetStatus) String
func (x *AssetStatus) String() stringAsset_DiscoverySpec
type Asset_DiscoverySpec struct {
// Optional. Whether discovery is enabled.
Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
// Optional. The list of patterns to apply for selecting data to include
// during discovery if only a subset of the data should considered. For
// Cloud Storage bucket assets, these are interpreted as glob patterns used
// to match object names. For BigQuery dataset assets, these are interpreted
// as patterns to match table names.
IncludePatterns []string `protobuf:"bytes,2,rep,name=include_patterns,json=includePatterns,proto3" json:"include_patterns,omitempty"`
// Optional. The list of patterns to apply for selecting data to exclude
// during discovery. For Cloud Storage bucket assets, these are interpreted
// as glob patterns used to match object names. For BigQuery dataset assets,
// these are interpreted as patterns to match table names.
ExcludePatterns []string `protobuf:"bytes,3,rep,name=exclude_patterns,json=excludePatterns,proto3" json:"exclude_patterns,omitempty"`
// Optional. Configuration for CSV data.
CsvOptions *Asset_DiscoverySpec_CsvOptions `protobuf:"bytes,4,opt,name=csv_options,json=csvOptions,proto3" json:"csv_options,omitempty"`
// Optional. Configuration for Json data.
JsonOptions *Asset_DiscoverySpec_JsonOptions `protobuf:"bytes,5,opt,name=json_options,json=jsonOptions,proto3" json:"json_options,omitempty"`
// Determines when discovery is triggered.
//
// Types that are assignable to Trigger:
//
// *Asset_DiscoverySpec_Schedule
Trigger isAsset_DiscoverySpec_Trigger `protobuf_oneof:"trigger"`
// contains filtered or unexported fields
}Settings to manage the metadata discovery and publishing for an asset.
func (*Asset_DiscoverySpec) Descriptor
func (*Asset_DiscoverySpec) Descriptor() ([]byte, []int)Deprecated: Use Asset_DiscoverySpec.ProtoReflect.Descriptor instead.
func (*Asset_DiscoverySpec) GetCsvOptions
func (x *Asset_DiscoverySpec) GetCsvOptions() *Asset_DiscoverySpec_CsvOptionsfunc (*Asset_DiscoverySpec) GetEnabled
func (x *Asset_DiscoverySpec) GetEnabled() boolfunc (*Asset_DiscoverySpec) GetExcludePatterns
func (x *Asset_DiscoverySpec) GetExcludePatterns() []stringfunc (*Asset_DiscoverySpec) GetIncludePatterns
func (x *Asset_DiscoverySpec) GetIncludePatterns() []stringfunc (*Asset_DiscoverySpec) GetJsonOptions
func (x *Asset_DiscoverySpec) GetJsonOptions() *Asset_DiscoverySpec_JsonOptionsfunc (*Asset_DiscoverySpec) GetSchedule
func (x *Asset_DiscoverySpec) GetSchedule() stringfunc (*Asset_DiscoverySpec) GetTrigger
func (m *Asset_DiscoverySpec) GetTrigger() isAsset_DiscoverySpec_Triggerfunc (*Asset_DiscoverySpec) ProtoMessage
func (*Asset_DiscoverySpec) ProtoMessage()func (*Asset_DiscoverySpec) ProtoReflect
func (x *Asset_DiscoverySpec) ProtoReflect() protoreflect.Messagefunc (*Asset_DiscoverySpec) Reset
func (x *Asset_DiscoverySpec) Reset()func (*Asset_DiscoverySpec) String
func (x *Asset_DiscoverySpec) String() stringAsset_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() stringfunc (*Asset_DiscoverySpec_CsvOptions) GetDisableTypeInference
func (x *Asset_DiscoverySpec_CsvOptions) GetDisableTypeInference() boolfunc (*Asset_DiscoverySpec_CsvOptions) GetEncoding
func (x *Asset_DiscoverySpec_CsvOptions) GetEncoding() stringfunc (*Asset_DiscoverySpec_CsvOptions) GetHeaderRows
func (x *Asset_DiscoverySpec_CsvOptions) GetHeaderRows() int32func (*Asset_DiscoverySpec_CsvOptions) ProtoMessage
func (*Asset_DiscoverySpec_CsvOptions) ProtoMessage()func (*Asset_DiscoverySpec_CsvOptions) ProtoReflect
func (x *Asset_DiscoverySpec_CsvOptions) ProtoReflect() protoreflect.Messagefunc (*Asset_DiscoverySpec_CsvOptions) Reset
func (x *Asset_DiscoverySpec_CsvOptions) Reset()func (*Asset_DiscoverySpec_CsvOptions) String
func (x *Asset_DiscoverySpec_CsvOptions) String() stringAsset_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() boolfunc (*Asset_DiscoverySpec_JsonOptions) GetEncoding
func (x *Asset_DiscoverySpec_JsonOptions) GetEncoding() stringfunc (*Asset_DiscoverySpec_JsonOptions) ProtoMessage
func (*Asset_DiscoverySpec_JsonOptions) ProtoMessage()func (*Asset_DiscoverySpec_JsonOptions) ProtoReflect
func (x *Asset_DiscoverySpec_JsonOptions) ProtoReflect() protoreflect.Messagefunc (*Asset_DiscoverySpec_JsonOptions) Reset
func (x *Asset_DiscoverySpec_JsonOptions) Reset()func (*Asset_DiscoverySpec_JsonOptions) String
func (x *Asset_DiscoverySpec_JsonOptions) String() stringAsset_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.Durationfunc (*Asset_DiscoveryStatus) GetLastRunTime
func (x *Asset_DiscoveryStatus) GetLastRunTime() *timestamppb.Timestampfunc (*Asset_DiscoveryStatus) GetMessage
func (x *Asset_DiscoveryStatus) GetMessage() stringfunc (*Asset_DiscoveryStatus) GetState
func (x *Asset_DiscoveryStatus) GetState() Asset_DiscoveryStatus_Statefunc (*Asset_DiscoveryStatus) GetStats
func (x *Asset_DiscoveryStatus) GetStats() *Asset_DiscoveryStatus_Statsfunc (*Asset_DiscoveryStatus) GetUpdateTime
func (x *Asset_DiscoveryStatus) GetUpdateTime() *timestamppb.Timestampfunc (*Asset_DiscoveryStatus) ProtoMessage
func (*Asset_DiscoveryStatus) ProtoMessage()func (*Asset_DiscoveryStatus) ProtoReflect
func (x *Asset_DiscoveryStatus) ProtoReflect() protoreflect.Messagefunc (*Asset_DiscoveryStatus) Reset
func (x *Asset_DiscoveryStatus) Reset()func (*Asset_DiscoveryStatus) String
func (x *Asset_DiscoveryStatus) String() stringAsset_DiscoveryStatus_State
type Asset_DiscoveryStatus_State int32Current state of discovery.
Asset_DiscoveryStatus_STATE_UNSPECIFIED, Asset_DiscoveryStatus_SCHEDULED, Asset_DiscoveryStatus_IN_PROGRESS, Asset_DiscoveryStatus_PAUSED, Asset_DiscoveryStatus_DISABLED
const (
// State is unspecified.
Asset_DiscoveryStatus_STATE_UNSPECIFIED Asset_DiscoveryStatus_State = 0
// Discovery for the asset is scheduled.
Asset_DiscoveryStatus_SCHEDULED Asset_DiscoveryStatus_State = 1
// Discovery for the asset is running.
Asset_DiscoveryStatus_IN_PROGRESS Asset_DiscoveryStatus_State = 2
// Discovery for the asset is currently paused (e.g. due to a lack
// of available resources). It will be automatically resumed.
Asset_DiscoveryStatus_PAUSED Asset_DiscoveryStatus_State = 3
// Discovery for the asset is disabled.
Asset_DiscoveryStatus_DISABLED Asset_DiscoveryStatus_State = 5
)func (Asset_DiscoveryStatus_State) Descriptor
func (Asset_DiscoveryStatus_State) Descriptor() protoreflect.EnumDescriptorfunc (Asset_DiscoveryStatus_State) Enum
func (x Asset_DiscoveryStatus_State) Enum() *Asset_DiscoveryStatus_Statefunc (Asset_DiscoveryStatus_State) EnumDescriptor
func (Asset_DiscoveryStatus_State) EnumDescriptor() ([]byte, []int)Deprecated: Use Asset_DiscoveryStatus_State.Descriptor instead.
func (Asset_DiscoveryStatus_State) Number
func (x Asset_DiscoveryStatus_State) Number() protoreflect.EnumNumberfunc (Asset_DiscoveryStatus_State) String
func (x Asset_DiscoveryStatus_State) String() stringfunc (Asset_DiscoveryStatus_State) Type
func (Asset_DiscoveryStatus_State) Type() protoreflect.EnumTypeAsset_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() int64func (*Asset_DiscoveryStatus_Stats) GetDataSize
func (x *Asset_DiscoveryStatus_Stats) GetDataSize() int64func (*Asset_DiscoveryStatus_Stats) GetFilesets
func (x *Asset_DiscoveryStatus_Stats) GetFilesets() int64func (*Asset_DiscoveryStatus_Stats) GetTables
func (x *Asset_DiscoveryStatus_Stats) GetTables() int64func (*Asset_DiscoveryStatus_Stats) ProtoMessage
func (*Asset_DiscoveryStatus_Stats) ProtoMessage()func (*Asset_DiscoveryStatus_Stats) ProtoReflect
func (x *Asset_DiscoveryStatus_Stats) ProtoReflect() protoreflect.Messagefunc (*Asset_DiscoveryStatus_Stats) Reset
func (x *Asset_DiscoveryStatus_Stats) Reset()func (*Asset_DiscoveryStatus_Stats) String
func (x *Asset_DiscoveryStatus_Stats) String() stringAsset_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() stringfunc (*Asset_ResourceSpec) GetType
func (x *Asset_ResourceSpec) GetType() Asset_ResourceSpec_Typefunc (*Asset_ResourceSpec) ProtoMessage
func (*Asset_ResourceSpec) ProtoMessage()func (*Asset_ResourceSpec) ProtoReflect
func (x *Asset_ResourceSpec) ProtoReflect() protoreflect.Messagefunc (*Asset_ResourceSpec) Reset
func (x *Asset_ResourceSpec) Reset()func (*Asset_ResourceSpec) String
func (x *Asset_ResourceSpec) String() stringAsset_ResourceSpec_Type
type Asset_ResourceSpec_Type int32Type of resource.
Asset_ResourceSpec_TYPE_UNSPECIFIED, Asset_ResourceSpec_STORAGE_BUCKET, Asset_ResourceSpec_BIGQUERY_DATASET
const (
// Type not specified.
Asset_ResourceSpec_TYPE_UNSPECIFIED Asset_ResourceSpec_Type = 0
// Cloud Storage bucket.
Asset_ResourceSpec_STORAGE_BUCKET Asset_ResourceSpec_Type = 1
// BigQuery dataset.
Asset_ResourceSpec_BIGQUERY_DATASET Asset_ResourceSpec_Type = 2
)func (Asset_ResourceSpec_Type) Descriptor
func (Asset_ResourceSpec_Type) Descriptor() protoreflect.EnumDescriptorfunc (Asset_ResourceSpec_Type) Enum
func (x Asset_ResourceSpec_Type) Enum() *Asset_ResourceSpec_Typefunc (Asset_ResourceSpec_Type) EnumDescriptor
func (Asset_ResourceSpec_Type) EnumDescriptor() ([]byte, []int)Deprecated: Use Asset_ResourceSpec_Type.Descriptor instead.
func (Asset_ResourceSpec_Type) Number
func (x Asset_ResourceSpec_Type) Number() protoreflect.EnumNumberfunc (Asset_ResourceSpec_Type) String
func (x Asset_ResourceSpec_Type) String() stringfunc (Asset_ResourceSpec_Type) Type
func (Asset_ResourceSpec_Type) Type() protoreflect.EnumTypeAsset_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() stringfunc (*Asset_ResourceStatus) GetState
func (x *Asset_ResourceStatus) GetState() Asset_ResourceStatus_Statefunc (*Asset_ResourceStatus) GetUpdateTime
func (x *Asset_ResourceStatus) GetUpdateTime() *timestamppb.Timestampfunc (*Asset_ResourceStatus) ProtoMessage
func (*Asset_ResourceStatus) ProtoMessage()func (*Asset_ResourceStatus) ProtoReflect
func (x *Asset_ResourceStatus) ProtoReflect() protoreflect.Messagefunc (*Asset_ResourceStatus) Reset
func (x *Asset_ResourceStatus) Reset()func (*Asset_ResourceStatus) String
func (x *Asset_ResourceStatus) String() stringAsset_ResourceStatus_State
type Asset_ResourceStatus_State int32The state of a resource.
Asset_ResourceStatus_STATE_UNSPECIFIED, Asset_ResourceStatus_READY, Asset_ResourceStatus_ERROR
const (
// State unspecified.
Asset_ResourceStatus_STATE_UNSPECIFIED Asset_ResourceStatus_State = 0
// Resource does not have any errors.
Asset_ResourceStatus_READY Asset_ResourceStatus_State = 1
// Resource has errors.
Asset_ResourceStatus_ERROR Asset_ResourceStatus_State = 2
)func (Asset_ResourceStatus_State) Descriptor
func (Asset_ResourceStatus_State) Descriptor() protoreflect.EnumDescriptorfunc (Asset_ResourceStatus_State) Enum
func (x Asset_ResourceStatus_State) Enum() *Asset_ResourceStatus_Statefunc (Asset_ResourceStatus_State) EnumDescriptor
func (Asset_ResourceStatus_State) EnumDescriptor() ([]byte, []int)Deprecated: Use Asset_ResourceStatus_State.Descriptor instead.
func (Asset_ResourceStatus_State) Number
func (x Asset_ResourceStatus_State) Number() protoreflect.EnumNumberfunc (Asset_ResourceStatus_State) String
func (x Asset_ResourceStatus_State) String() stringfunc (Asset_ResourceStatus_State) Type
func (Asset_ResourceStatus_State) Type() protoreflect.EnumTypeAsset_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() stringfunc (*Asset_SecurityStatus) GetState
func (x *Asset_SecurityStatus) GetState() Asset_SecurityStatus_Statefunc (*Asset_SecurityStatus) GetUpdateTime
func (x *Asset_SecurityStatus) GetUpdateTime() *timestamppb.Timestampfunc (*Asset_SecurityStatus) ProtoMessage
func (*Asset_SecurityStatus) ProtoMessage()func (*Asset_SecurityStatus) ProtoReflect
func (x *Asset_SecurityStatus) ProtoReflect() protoreflect.Messagefunc (*Asset_SecurityStatus) Reset
func (x *Asset_SecurityStatus) Reset()func (*Asset_SecurityStatus) String
func (x *Asset_SecurityStatus) String() stringAsset_SecurityStatus_State
type Asset_SecurityStatus_State int32The state of the security policy.
Asset_SecurityStatus_STATE_UNSPECIFIED, Asset_SecurityStatus_READY, Asset_SecurityStatus_APPLYING, Asset_SecurityStatus_ERROR
const (
// State unspecified.
Asset_SecurityStatus_STATE_UNSPECIFIED Asset_SecurityStatus_State = 0
// Security policy has been successfully applied to the attached resource.
Asset_SecurityStatus_READY Asset_SecurityStatus_State = 1
// Security policy is in the process of being applied to the attached
// resource.
Asset_SecurityStatus_APPLYING Asset_SecurityStatus_State = 2
// Security policy could not be applied to the attached resource due to
// errors.
Asset_SecurityStatus_ERROR Asset_SecurityStatus_State = 3
)func (Asset_SecurityStatus_State) Descriptor
func (Asset_SecurityStatus_State) Descriptor() protoreflect.EnumDescriptorfunc (Asset_SecurityStatus_State) Enum
func (x Asset_SecurityStatus_State) Enum() *Asset_SecurityStatus_Statefunc (Asset_SecurityStatus_State) EnumDescriptor
func (Asset_SecurityStatus_State) EnumDescriptor() ([]byte, []int)Deprecated: Use Asset_SecurityStatus_State.Descriptor instead.
func (Asset_SecurityStatus_State) Number
func (x Asset_SecurityStatus_State) Number() protoreflect.EnumNumberfunc (Asset_SecurityStatus_State) String
func (x Asset_SecurityStatus_State) String() stringfunc (Asset_SecurityStatus_State) Type
func (Asset_SecurityStatus_State) Type() protoreflect.EnumTypeCancelJobRequest
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() stringfunc (*CancelJobRequest) ProtoMessage
func (*CancelJobRequest) ProtoMessage()func (*CancelJobRequest) ProtoReflect
func (x *CancelJobRequest) ProtoReflect() protoreflect.Messagefunc (*CancelJobRequest) Reset
func (x *CancelJobRequest) Reset()func (*CancelJobRequest) String
func (x *CancelJobRequest) String() stringContent
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
Deprecated: Use Content.ProtoReflect.Descriptor instead.
func (*Content) GetContent
func (m *Content) GetContent() isContent_Contentfunc (*Content) GetCreateTime
func (x *Content) GetCreateTime() *timestamppb.Timestampfunc (*Content) GetData
func (m *Content) GetData() isContent_Datafunc (*Content) GetDataText
func (*Content) GetDescription
func (*Content) GetLabels
func (*Content) GetName
func (*Content) GetNotebook
func (x *Content) GetNotebook() *Content_Notebookfunc (*Content) GetPath
func (*Content) GetSqlScript
func (x *Content) GetSqlScript() *Content_SqlScriptfunc (*Content) GetUid
func (*Content) GetUpdateTime
func (x *Content) GetUpdateTime() *timestamppb.Timestampfunc (*Content) ProtoMessage
func (*Content) ProtoMessage()func (*Content) ProtoReflect
func (x *Content) ProtoReflect() protoreflect.Messagefunc (*Content) Reset
func (x *Content) Reset()func (*Content) 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) ContentServiceClientContentServiceServer
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_KernelTypefunc (*Content_Notebook) ProtoMessage
func (*Content_Notebook) ProtoMessage()func (*Content_Notebook) ProtoReflect
func (x *Content_Notebook) ProtoReflect() protoreflect.Message