Documentation ¶
Index ¶
- Variables
- func RegisterDataprocMetastoreServer(s *grpc.Server, srv DataprocMetastoreServer)
- type CreateMetadataImportRequest
- func (*CreateMetadataImportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateMetadataImportRequest) GetMetadataImport() *MetadataImport
- func (x *CreateMetadataImportRequest) GetMetadataImportId() string
- func (x *CreateMetadataImportRequest) GetParent() string
- func (x *CreateMetadataImportRequest) GetRequestId() string
- func (*CreateMetadataImportRequest) ProtoMessage()
- func (x *CreateMetadataImportRequest) ProtoReflect() protoreflect.Message
- func (x *CreateMetadataImportRequest) Reset()
- func (x *CreateMetadataImportRequest) String() string
- type CreateServiceRequest
- func (*CreateServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateServiceRequest) GetParent() string
- func (x *CreateServiceRequest) GetRequestId() string
- func (x *CreateServiceRequest) GetService() *Service
- func (x *CreateServiceRequest) GetServiceId() string
- func (*CreateServiceRequest) ProtoMessage()
- func (x *CreateServiceRequest) ProtoReflect() protoreflect.Message
- func (x *CreateServiceRequest) Reset()
- func (x *CreateServiceRequest) String() string
- type DatabaseDumpSpec
- type DatabaseDumpSpec_Type
- func (DatabaseDumpSpec_Type) Descriptor() protoreflect.EnumDescriptor
- func (x DatabaseDumpSpec_Type) Enum() *DatabaseDumpSpec_Type
- func (DatabaseDumpSpec_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x DatabaseDumpSpec_Type) Number() protoreflect.EnumNumber
- func (x DatabaseDumpSpec_Type) String() string
- func (DatabaseDumpSpec_Type) Type() protoreflect.EnumType
- type DataprocMetastoreClient
- type DataprocMetastoreServer
- type DeleteServiceRequest
- func (*DeleteServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteServiceRequest) GetName() string
- func (x *DeleteServiceRequest) GetRequestId() string
- func (*DeleteServiceRequest) ProtoMessage()
- func (x *DeleteServiceRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteServiceRequest) Reset()
- func (x *DeleteServiceRequest) String() string
- type ExportMetadataRequest
- func (*ExportMetadataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExportMetadataRequest) GetDatabaseDumpType() DatabaseDumpSpec_Type
- func (m *ExportMetadataRequest) GetDestination() isExportMetadataRequest_Destination
- func (x *ExportMetadataRequest) GetDestinationGcsFolder() string
- func (x *ExportMetadataRequest) GetRequestId() string
- func (x *ExportMetadataRequest) GetService() string
- func (*ExportMetadataRequest) ProtoMessage()
- func (x *ExportMetadataRequest) ProtoReflect() protoreflect.Message
- func (x *ExportMetadataRequest) Reset()
- func (x *ExportMetadataRequest) String() string
- type ExportMetadataRequest_DestinationGcsFolder
- type GetMetadataImportRequest
- func (*GetMetadataImportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetMetadataImportRequest) GetName() string
- func (*GetMetadataImportRequest) ProtoMessage()
- func (x *GetMetadataImportRequest) ProtoReflect() protoreflect.Message
- func (x *GetMetadataImportRequest) Reset()
- func (x *GetMetadataImportRequest) String() string
- type GetServiceRequest
- type HiveMetastoreConfig
- func (*HiveMetastoreConfig) Descriptor() ([]byte, []int)deprecated
- func (x *HiveMetastoreConfig) GetConfigOverrides() map[string]string
- func (x *HiveMetastoreConfig) GetKerberosConfig() *KerberosConfig
- func (x *HiveMetastoreConfig) GetVersion() string
- func (*HiveMetastoreConfig) ProtoMessage()
- func (x *HiveMetastoreConfig) ProtoReflect() protoreflect.Message
- func (x *HiveMetastoreConfig) Reset()
- func (x *HiveMetastoreConfig) String() string
- type KerberosConfig
- func (*KerberosConfig) Descriptor() ([]byte, []int)deprecated
- func (x *KerberosConfig) GetKeytab() *Secret
- func (x *KerberosConfig) GetKrb5ConfigGcsUri() string
- func (x *KerberosConfig) GetPrincipal() string
- func (*KerberosConfig) ProtoMessage()
- func (x *KerberosConfig) ProtoReflect() protoreflect.Message
- func (x *KerberosConfig) Reset()
- func (x *KerberosConfig) String() string
- type ListMetadataImportsRequest
- func (*ListMetadataImportsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListMetadataImportsRequest) GetFilter() string
- func (x *ListMetadataImportsRequest) GetOrderBy() string
- func (x *ListMetadataImportsRequest) GetPageSize() int32
- func (x *ListMetadataImportsRequest) GetPageToken() string
- func (x *ListMetadataImportsRequest) GetParent() string
- func (*ListMetadataImportsRequest) ProtoMessage()
- func (x *ListMetadataImportsRequest) ProtoReflect() protoreflect.Message
- func (x *ListMetadataImportsRequest) Reset()
- func (x *ListMetadataImportsRequest) String() string
- type ListMetadataImportsResponse
- func (*ListMetadataImportsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListMetadataImportsResponse) GetMetadataImports() []*MetadataImport
- func (x *ListMetadataImportsResponse) GetNextPageToken() string
- func (x *ListMetadataImportsResponse) GetUnreachable() []string
- func (*ListMetadataImportsResponse) ProtoMessage()
- func (x *ListMetadataImportsResponse) ProtoReflect() protoreflect.Message
- func (x *ListMetadataImportsResponse) Reset()
- func (x *ListMetadataImportsResponse) String() string
- type ListServicesRequest
- func (*ListServicesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListServicesRequest) GetFilter() string
- func (x *ListServicesRequest) GetOrderBy() string
- func (x *ListServicesRequest) GetPageSize() int32
- func (x *ListServicesRequest) GetPageToken() string
- func (x *ListServicesRequest) GetParent() string
- func (*ListServicesRequest) ProtoMessage()
- func (x *ListServicesRequest) ProtoReflect() protoreflect.Message
- func (x *ListServicesRequest) Reset()
- func (x *ListServicesRequest) String() string
- type ListServicesResponse
- func (*ListServicesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListServicesResponse) GetNextPageToken() string
- func (x *ListServicesResponse) GetServices() []*Service
- func (x *ListServicesResponse) GetUnreachable() []string
- func (*ListServicesResponse) ProtoMessage()
- func (x *ListServicesResponse) ProtoReflect() protoreflect.Message
- func (x *ListServicesResponse) Reset()
- func (x *ListServicesResponse) String() string
- type LocationMetadata
- func (*LocationMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *LocationMetadata) GetSupportedHiveMetastoreVersions() []*LocationMetadata_HiveMetastoreVersion
- func (*LocationMetadata) ProtoMessage()
- func (x *LocationMetadata) ProtoReflect() protoreflect.Message
- func (x *LocationMetadata) Reset()
- func (x *LocationMetadata) String() string
- type LocationMetadata_HiveMetastoreVersion
- func (*LocationMetadata_HiveMetastoreVersion) Descriptor() ([]byte, []int)deprecated
- func (x *LocationMetadata_HiveMetastoreVersion) GetIsDefault() bool
- func (x *LocationMetadata_HiveMetastoreVersion) GetVersion() string
- func (*LocationMetadata_HiveMetastoreVersion) ProtoMessage()
- func (x *LocationMetadata_HiveMetastoreVersion) ProtoReflect() protoreflect.Message
- func (x *LocationMetadata_HiveMetastoreVersion) Reset()
- func (x *LocationMetadata_HiveMetastoreVersion) String() string
- type MaintenanceWindow
- func (*MaintenanceWindow) Descriptor() ([]byte, []int)deprecated
- func (x *MaintenanceWindow) GetDayOfWeek() dayofweek.DayOfWeek
- func (x *MaintenanceWindow) GetHourOfDay() *wrapperspb.Int32Value
- func (*MaintenanceWindow) ProtoMessage()
- func (x *MaintenanceWindow) ProtoReflect() protoreflect.Message
- func (x *MaintenanceWindow) Reset()
- func (x *MaintenanceWindow) String() string
- type MetadataExport
- func (*MetadataExport) Descriptor() ([]byte, []int)deprecated
- func (x *MetadataExport) GetDatabaseDumpType() DatabaseDumpSpec_Type
- func (m *MetadataExport) GetDestination() isMetadataExport_Destination
- func (x *MetadataExport) GetDestinationGcsUri() string
- func (x *MetadataExport) GetEndTime() *timestamppb.Timestamp
- func (x *MetadataExport) GetStartTime() *timestamppb.Timestamp
- func (x *MetadataExport) GetState() MetadataExport_State
- func (*MetadataExport) ProtoMessage()
- func (x *MetadataExport) ProtoReflect() protoreflect.Message
- func (x *MetadataExport) Reset()
- func (x *MetadataExport) String() string
- type MetadataExport_DestinationGcsUri
- type MetadataExport_State
- func (MetadataExport_State) Descriptor() protoreflect.EnumDescriptor
- func (x MetadataExport_State) Enum() *MetadataExport_State
- func (MetadataExport_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x MetadataExport_State) Number() protoreflect.EnumNumber
- func (x MetadataExport_State) String() string
- func (MetadataExport_State) Type() protoreflect.EnumType
- type MetadataImport
- func (*MetadataImport) Descriptor() ([]byte, []int)deprecated
- func (x *MetadataImport) GetCreateTime() *timestamppb.Timestamp
- func (x *MetadataImport) GetDatabaseDump() *MetadataImport_DatabaseDump
- func (x *MetadataImport) GetDescription() string
- func (m *MetadataImport) GetMetadata() isMetadataImport_Metadata
- func (x *MetadataImport) GetName() string
- func (x *MetadataImport) GetState() MetadataImport_State
- func (x *MetadataImport) GetUpdateTime() *timestamppb.Timestamp
- func (*MetadataImport) ProtoMessage()
- func (x *MetadataImport) ProtoReflect() protoreflect.Message
- func (x *MetadataImport) Reset()
- func (x *MetadataImport) String() string
- type MetadataImport_DatabaseDump
- func (*MetadataImport_DatabaseDump) Descriptor() ([]byte, []int)deprecated
- func (x *MetadataImport_DatabaseDump) GetDatabaseType() MetadataImport_DatabaseDump_DatabaseTypedeprecated
- func (x *MetadataImport_DatabaseDump) GetGcsUri() string
- func (x *MetadataImport_DatabaseDump) GetType() DatabaseDumpSpec_Type
- func (*MetadataImport_DatabaseDump) ProtoMessage()
- func (x *MetadataImport_DatabaseDump) ProtoReflect() protoreflect.Message
- func (x *MetadataImport_DatabaseDump) Reset()
- func (x *MetadataImport_DatabaseDump) String() string
- type MetadataImport_DatabaseDump_
- type MetadataImport_DatabaseDump_DatabaseType
- func (MetadataImport_DatabaseDump_DatabaseType) Descriptor() protoreflect.EnumDescriptor
- func (x MetadataImport_DatabaseDump_DatabaseType) Enum() *MetadataImport_DatabaseDump_DatabaseType
- func (MetadataImport_DatabaseDump_DatabaseType) EnumDescriptor() ([]byte, []int)deprecated
- func (x MetadataImport_DatabaseDump_DatabaseType) Number() protoreflect.EnumNumber
- func (x MetadataImport_DatabaseDump_DatabaseType) String() string
- func (MetadataImport_DatabaseDump_DatabaseType) Type() protoreflect.EnumType
- type MetadataImport_State
- func (MetadataImport_State) Descriptor() protoreflect.EnumDescriptor
- func (x MetadataImport_State) Enum() *MetadataImport_State
- func (MetadataImport_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x MetadataImport_State) Number() protoreflect.EnumNumber
- func (x MetadataImport_State) String() string
- func (MetadataImport_State) Type() protoreflect.EnumType
- type MetadataManagementActivity
- func (*MetadataManagementActivity) Descriptor() ([]byte, []int)deprecated
- func (x *MetadataManagementActivity) GetMetadataExports() []*MetadataExport
- func (*MetadataManagementActivity) ProtoMessage()
- func (x *MetadataManagementActivity) ProtoReflect() protoreflect.Message
- func (x *MetadataManagementActivity) Reset()
- func (x *MetadataManagementActivity) String() string
- type OperationMetadata
- func (*OperationMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *OperationMetadata) GetApiVersion() string
- func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp
- func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp
- func (x *OperationMetadata) GetRequestedCancellation() bool
- func (x *OperationMetadata) GetStatusMessage() string
- func (x *OperationMetadata) GetTarget() string
- func (x *OperationMetadata) GetVerb() string
- func (*OperationMetadata) ProtoMessage()
- func (x *OperationMetadata) ProtoReflect() protoreflect.Message
- func (x *OperationMetadata) Reset()
- func (x *OperationMetadata) String() string
- type Secret
- type Secret_CloudSecret
- type Service
- func (*Service) Descriptor() ([]byte, []int)deprecated
- func (x *Service) GetArtifactGcsUri() string
- func (x *Service) GetCreateTime() *timestamppb.Timestamp
- func (x *Service) GetEndpointUri() string
- func (x *Service) GetHiveMetastoreConfig() *HiveMetastoreConfig
- func (x *Service) GetLabels() map[string]string
- func (x *Service) GetMaintenanceWindow() *MaintenanceWindow
- func (x *Service) GetMetadataManagementActivity() *MetadataManagementActivity
- func (m *Service) GetMetastoreConfig() isService_MetastoreConfig
- func (x *Service) GetName() string
- func (x *Service) GetNetwork() string
- func (x *Service) GetPort() int32
- func (x *Service) GetReleaseChannel() Service_ReleaseChannel
- func (x *Service) GetState() Service_State
- func (x *Service) GetStateMessage() string
- func (x *Service) GetTier() Service_Tier
- func (x *Service) GetUid() string
- func (x *Service) GetUpdateTime() *timestamppb.Timestamp
- func (*Service) ProtoMessage()
- func (x *Service) ProtoReflect() protoreflect.Message
- func (x *Service) Reset()
- func (x *Service) String() string
- type Service_HiveMetastoreConfig
- type Service_ReleaseChannel
- func (Service_ReleaseChannel) Descriptor() protoreflect.EnumDescriptor
- func (x Service_ReleaseChannel) Enum() *Service_ReleaseChannel
- func (Service_ReleaseChannel) EnumDescriptor() ([]byte, []int)deprecated
- func (x Service_ReleaseChannel) Number() protoreflect.EnumNumber
- func (x Service_ReleaseChannel) String() string
- func (Service_ReleaseChannel) Type() protoreflect.EnumType
- type Service_State
- func (Service_State) Descriptor() protoreflect.EnumDescriptor
- func (x Service_State) Enum() *Service_State
- func (Service_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x Service_State) Number() protoreflect.EnumNumber
- func (x Service_State) String() string
- func (Service_State) Type() protoreflect.EnumType
- type Service_Tier
- func (Service_Tier) Descriptor() protoreflect.EnumDescriptor
- func (x Service_Tier) Enum() *Service_Tier
- func (Service_Tier) EnumDescriptor() ([]byte, []int)deprecated
- func (x Service_Tier) Number() protoreflect.EnumNumber
- func (x Service_Tier) String() string
- func (Service_Tier) Type() protoreflect.EnumType
- type UnimplementedDataprocMetastoreServer
- func (*UnimplementedDataprocMetastoreServer) CreateMetadataImport(context.Context, *CreateMetadataImportRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataprocMetastoreServer) CreateService(context.Context, *CreateServiceRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataprocMetastoreServer) DeleteService(context.Context, *DeleteServiceRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataprocMetastoreServer) ExportMetadata(context.Context, *ExportMetadataRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataprocMetastoreServer) GetMetadataImport(context.Context, *GetMetadataImportRequest) (*MetadataImport, error)
- func (*UnimplementedDataprocMetastoreServer) GetService(context.Context, *GetServiceRequest) (*Service, error)
- func (*UnimplementedDataprocMetastoreServer) ListMetadataImports(context.Context, *ListMetadataImportsRequest) (*ListMetadataImportsResponse, error)
- func (*UnimplementedDataprocMetastoreServer) ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
- func (*UnimplementedDataprocMetastoreServer) UpdateMetadataImport(context.Context, *UpdateMetadataImportRequest) (*longrunning.Operation, error)
- func (*UnimplementedDataprocMetastoreServer) UpdateService(context.Context, *UpdateServiceRequest) (*longrunning.Operation, error)
- type UpdateMetadataImportRequest
- func (*UpdateMetadataImportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateMetadataImportRequest) GetMetadataImport() *MetadataImport
- func (x *UpdateMetadataImportRequest) GetRequestId() string
- func (x *UpdateMetadataImportRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateMetadataImportRequest) ProtoMessage()
- func (x *UpdateMetadataImportRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateMetadataImportRequest) Reset()
- func (x *UpdateMetadataImportRequest) String() string
- type UpdateServiceRequest
- func (*UpdateServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateServiceRequest) GetRequestId() string
- func (x *UpdateServiceRequest) GetService() *Service
- func (x *UpdateServiceRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateServiceRequest) ProtoMessage()
- func (x *UpdateServiceRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateServiceRequest) Reset()
- func (x *UpdateServiceRequest) String() string
Constants ¶
This section is empty.
Variables ¶
var ( Service_State_name = map[int32]string{ 0: "STATE_UNSPECIFIED", 1: "CREATING", 2: "ACTIVE", 3: "SUSPENDING", 4: "SUSPENDED", 5: "UPDATING", 6: "DELETING", 7: "ERROR", } Service_State_value = map[string]int32{ "STATE_UNSPECIFIED": 0, "CREATING": 1, "ACTIVE": 2, "SUSPENDING": 3, "SUSPENDED": 4, "UPDATING": 5, "DELETING": 6, "ERROR": 7, } )
Enum value maps for Service_State.
var ( Service_Tier_name = map[int32]string{ 0: "TIER_UNSPECIFIED", 1: "DEVELOPER", 3: "ENTERPRISE", } Service_Tier_value = map[string]int32{ "TIER_UNSPECIFIED": 0, "DEVELOPER": 1, "ENTERPRISE": 3, } )
Enum value maps for Service_Tier.
var ( Service_ReleaseChannel_name = map[int32]string{ 0: "RELEASE_CHANNEL_UNSPECIFIED", 1: "CANARY", 2: "STABLE", } Service_ReleaseChannel_value = map[string]int32{ "RELEASE_CHANNEL_UNSPECIFIED": 0, "CANARY": 1, "STABLE": 2, } )
Enum value maps for Service_ReleaseChannel.
var ( MetadataImport_State_name = map[int32]string{ 0: "STATE_UNSPECIFIED", 1: "RUNNING", 2: "SUCCEEDED", 3: "UPDATING", 4: "FAILED", } MetadataImport_State_value = map[string]int32{ "STATE_UNSPECIFIED": 0, "RUNNING": 1, "SUCCEEDED": 2, "UPDATING": 3, "FAILED": 4, } )
Enum value maps for MetadataImport_State.
var ( MetadataImport_DatabaseDump_DatabaseType_name = map[int32]string{ 0: "DATABASE_TYPE_UNSPECIFIED", 1: "MYSQL", } MetadataImport_DatabaseDump_DatabaseType_value = map[string]int32{ "DATABASE_TYPE_UNSPECIFIED": 0, "MYSQL": 1, } )
Enum value maps for MetadataImport_DatabaseDump_DatabaseType.
var ( MetadataExport_State_name = map[int32]string{ 0: "STATE_UNSPECIFIED", 1: "RUNNING", 2: "SUCCEEDED", 3: "FAILED", 4: "CANCELLED", } MetadataExport_State_value = map[string]int32{ "STATE_UNSPECIFIED": 0, "RUNNING": 1, "SUCCEEDED": 2, "FAILED": 3, "CANCELLED": 4, } )
Enum value maps for MetadataExport_State.
var ( DatabaseDumpSpec_Type_name = map[int32]string{ 0: "TYPE_UNSPECIFIED", 1: "MYSQL", } DatabaseDumpSpec_Type_value = map[string]int32{ "TYPE_UNSPECIFIED": 0, "MYSQL": 1, } )
Enum value maps for DatabaseDumpSpec_Type.
var File_google_cloud_metastore_v1_metastore_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDataprocMetastoreServer ¶
func RegisterDataprocMetastoreServer(s *grpc.Server, srv DataprocMetastoreServer)
Types ¶
type CreateMetadataImportRequest ¶
type CreateMetadataImportRequest struct { // Required. The relative resource name of the service in which to create a metastore // import, in the following form: // // `projects/{project_number}/locations/{location_id}/services/{service_id}`. Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // Required. The ID of the metadata import, which is used as the final component of the // metadata import's name. // // This value must be between 1 and 64 characters long, begin with a letter, // end with a letter or number, and consist of alpha-numeric ASCII characters // or hyphens. MetadataImportId string `protobuf:"bytes,2,opt,name=metadata_import_id,json=metadataImportId,proto3" json:"metadata_import_id,omitempty"` // Required. The metadata import to create. The `name` field is ignored. The ID of the // created metadata import must be provided in the request's // `metadata_import_id` field. MetadataImport *MetadataImport `protobuf:"bytes,3,opt,name=metadata_import,json=metadataImport,proto3" json:"metadata_import,omitempty"` // Optional. A request ID. Specify a unique request ID to allow the server to ignore the // request if it has completed. The server will ignore subsequent requests // that provide a duplicate request ID for at least 60 minutes after the first // request. // // For example, if an initial request times out, followed by another request // with the same request ID, the server ignores the second request to prevent // the creation of duplicate commitments. // // The request ID must be a valid // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier#Format) // A zero UUID (00000000-0000-0000-0000-000000000000) is not supported. RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
Request message for [DataprocMetastore.CreateMetadataImport][google.cloud.metastore.v1.DataprocMetastore.CreateMetadataImport].
func (*CreateMetadataImportRequest) Descriptor
deprecated
func (*CreateMetadataImportRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateMetadataImportRequest.ProtoReflect.Descriptor instead.
func (*CreateMetadataImportRequest) GetMetadataImport ¶
func (x *CreateMetadataImportRequest) GetMetadataImport() *MetadataImport
func (*CreateMetadataImportRequest) GetMetadataImportId ¶
func (x *CreateMetadataImportRequest) GetMetadataImportId() string
func (*CreateMetadataImportRequest) GetParent ¶
func (x *CreateMetadataImportRequest) GetParent() string
func (*CreateMetadataImportRequest) GetRequestId ¶
func (x *CreateMetadataImportRequest) GetRequestId() string
func (*CreateMetadataImportRequest) ProtoMessage ¶
func (*CreateMetadataImportRequest) ProtoMessage()
func (*CreateMetadataImportRequest) ProtoReflect ¶
func (x *CreateMetadataImportRequest) ProtoReflect() protoreflect.Message
func (*CreateMetadataImportRequest) Reset ¶
func (x *CreateMetadataImportRequest) Reset()
func (*CreateMetadataImportRequest) String ¶
func (x *CreateMetadataImportRequest) String() string
type CreateServiceRequest ¶
type CreateServiceRequest struct { // Required. The relative resource name of the location in which to create a metastore // service, in the following form: // // `projects/{project_number}/locations/{location_id}`. Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // Required. The ID of the metastore service, which is used as the final // component of the metastore service's name. // // This value must be between 2 and 63 characters long inclusive, begin with a // letter, end with a letter or number, and consist of alpha-numeric // ASCII characters or hyphens. ServiceId string `protobuf:"bytes,2,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"` // Required. The Metastore service to create. The `name` field is // ignored. The ID of the created metastore service must be provided in // the request's `service_id` field. Service *Service `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"` // Optional. A request ID. Specify a unique request ID to allow the server to ignore the // request if it has completed. The server will ignore subsequent requests // that provide a duplicate request ID for at least 60 minutes after the first // request. // // For example, if an initial request times out, followed by another request // with the same request ID, the server ignores the second request to prevent // the creation of duplicate commitments. // // The request ID must be a valid // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier#Format) // A zero UUID (00000000-0000-0000-0000-000000000000) is not supported. RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
Request message for [DataprocMetastore.CreateService][google.cloud.metastore.v1.DataprocMetastore.CreateService].
func (*CreateServiceRequest) Descriptor
deprecated
func (*CreateServiceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateServiceRequest.ProtoReflect.Descriptor instead.
func (*CreateServiceRequest) GetParent ¶
func (x *CreateServiceRequest) GetParent() string
func (*CreateServiceRequest) GetRequestId ¶
func (x *CreateServiceRequest) GetRequestId() string
func (*CreateServiceRequest) GetService ¶
func (x *CreateServiceRequest) GetService() *Service
func (*CreateServiceRequest) GetServiceId ¶
func (x *CreateServiceRequest) GetServiceId() string
func (*CreateServiceRequest) ProtoMessage ¶
func (*CreateServiceRequest) ProtoMessage()
func (*CreateServiceRequest) ProtoReflect ¶
func (x *CreateServiceRequest) ProtoReflect() protoreflect.Message
func (*CreateServiceRequest) Reset ¶
func (x *CreateServiceRequest) Reset()
func (*CreateServiceRequest) String ¶
func (x *CreateServiceRequest) String() string
type DatabaseDumpSpec ¶
type DatabaseDumpSpec struct {
// contains filtered or unexported fields
}
The specification of database dump to import from or export to.
func (*DatabaseDumpSpec) Descriptor
deprecated
func (*DatabaseDumpSpec) Descriptor() ([]byte, []int)
Deprecated: Use DatabaseDumpSpec.ProtoReflect.Descriptor instead.
func (*DatabaseDumpSpec) ProtoMessage ¶
func (*DatabaseDumpSpec) ProtoMessage()
func (*DatabaseDumpSpec) ProtoReflect ¶
func (x *DatabaseDumpSpec) ProtoReflect() protoreflect.Message
func (*DatabaseDumpSpec) Reset ¶
func (x *DatabaseDumpSpec) Reset()
func (*DatabaseDumpSpec) String ¶
func (x *DatabaseDumpSpec) String() string
type DatabaseDumpSpec_Type ¶
type DatabaseDumpSpec_Type int32
The type of the database dump.
const ( // The type of the database dump is unknown. DatabaseDumpSpec_TYPE_UNSPECIFIED DatabaseDumpSpec_Type = 0 // Database dump is a MySQL dump file. DatabaseDumpSpec_MYSQL DatabaseDumpSpec_Type = 1 )
func (DatabaseDumpSpec_Type) Descriptor ¶
func (DatabaseDumpSpec_Type) Descriptor() protoreflect.EnumDescriptor
func (DatabaseDumpSpec_Type) Enum ¶
func (x DatabaseDumpSpec_Type) Enum() *DatabaseDumpSpec_Type
func (DatabaseDumpSpec_Type) EnumDescriptor
deprecated
func (DatabaseDumpSpec_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use DatabaseDumpSpec_Type.Descriptor instead.
func (DatabaseDumpSpec_Type) Number ¶
func (x DatabaseDumpSpec_Type) Number() protoreflect.EnumNumber
func (DatabaseDumpSpec_Type) String ¶
func (x DatabaseDumpSpec_Type) String() string
func (DatabaseDumpSpec_Type) Type ¶
func (DatabaseDumpSpec_Type) Type() protoreflect.EnumType
type DataprocMetastoreClient ¶
type DataprocMetastoreClient interface { // Lists services in a project and location. ListServices(ctx context.Context, in *ListServicesRequest, opts ...grpc.CallOption) (*ListServicesResponse, error) // Gets the details of a single service. GetService(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*Service, error) // Creates a metastore service in a project and location. CreateService(ctx context.Context, in *CreateServiceRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Updates the parameters of a single service. UpdateService(ctx context.Context, in *UpdateServiceRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Deletes a single service. DeleteService(ctx context.Context, in *DeleteServiceRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Lists imports in a service. ListMetadataImports(ctx context.Context, in *ListMetadataImportsRequest, opts ...grpc.CallOption) (*ListMetadataImportsResponse, error) // Gets details of a single import. GetMetadataImport(ctx context.Context, in *GetMetadataImportRequest, opts ...grpc.CallOption) (*MetadataImport, error) // Creates a new MetadataImport in a given project and location. CreateMetadataImport(ctx context.Context, in *CreateMetadataImportRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Updates a single import. // Only the description field of MetadataImport is supported to be updated. UpdateMetadataImport(ctx context.Context, in *UpdateMetadataImportRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Exports metadata from a service. ExportMetadata(ctx context.Context, in *ExportMetadataRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) }
DataprocMetastoreClient is the client API for DataprocMetastore service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDataprocMetastoreClient ¶
func NewDataprocMetastoreClient(cc grpc.ClientConnInterface) DataprocMetastoreClient
type DataprocMetastoreServer ¶
type DataprocMetastoreServer interface { // Lists services in a project and location. ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error) // Gets the details of a single service. GetService(context.Context, *GetServiceRequest) (*Service, error) // Creates a metastore service in a project and location. CreateService(context.Context, *CreateServiceRequest) (*longrunning.Operation, error) // Updates the parameters of a single service. UpdateService(context.Context, *UpdateServiceRequest) (*longrunning.Operation, error) // Deletes a single service. DeleteService(context.Context, *DeleteServiceRequest) (*longrunning.Operation, error) // Lists imports in a service. ListMetadataImports(context.Context, *ListMetadataImportsRequest) (*ListMetadataImportsResponse, error) // Gets details of a single import. GetMetadataImport(context.Context, *GetMetadataImportRequest) (*MetadataImport, error) // Creates a new MetadataImport in a given project and location. CreateMetadataImport(context.Context, *CreateMetadataImportRequest) (*longrunning.Operation, error) // Updates a single import. // Only the description field of MetadataImport is supported to be updated. UpdateMetadataImport(context.Context, *UpdateMetadataImportRequest) (*longrunning.Operation, error) // Exports metadata from a service. ExportMetadata(context.Context, *ExportMetadataRequest) (*longrunning.Operation, error) }
DataprocMetastoreServer is the server API for DataprocMetastore service.
type DeleteServiceRequest ¶
type DeleteServiceRequest struct { // Required. The relative resource name of the metastore service to delete, in the // following form: // // `projects/{project_number}/locations/{location_id}/services/{service_id}`. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Optional. A request ID. Specify a unique request ID to allow the server to ignore the // request if it has completed. The server will ignore subsequent requests // that provide a duplicate request ID for at least 60 minutes after the first // request. // // For example, if an initial request times out, followed by another request // with the same request ID, the server ignores the second request to prevent // the creation of duplicate commitments. // // The request ID must be a valid // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier#Format) // A zero UUID (00000000-0000-0000-0000-000000000000) is not supported. RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
Request message for [DataprocMetastore.DeleteService][google.cloud.metastore.v1.DataprocMetastore.DeleteService].
func (*DeleteServiceRequest) Descriptor
deprecated
func (*DeleteServiceRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteServiceRequest.ProtoReflect.Descriptor instead.
func (*DeleteServiceRequest) GetName ¶
func (x *DeleteServiceRequest) GetName() string
func (*DeleteServiceRequest) GetRequestId ¶
func (x *DeleteServiceRequest) GetRequestId() string
func (*DeleteServiceRequest) ProtoMessage ¶
func (*DeleteServiceRequest) ProtoMessage()
func (*DeleteServiceRequest) ProtoReflect ¶
func (x *DeleteServiceRequest) ProtoReflect() protoreflect.Message
func (*DeleteServiceRequest) Reset ¶
func (x *DeleteServiceRequest) Reset()
func (*DeleteServiceRequest) String ¶
func (x *DeleteServiceRequest) String() string
type ExportMetadataRequest ¶
type ExportMetadataRequest struct { // Required. Destination that metadata is exported to. // // Types that are assignable to Destination: // *ExportMetadataRequest_DestinationGcsFolder Destination isExportMetadataRequest_Destination `protobuf_oneof:"destination"` // Required. The relative resource name of the metastore service to run export, in the // following form: // // `projects/{project_id}/locations/{location_id}/services/{service_id}`. Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` // Optional. A request ID. Specify a unique request ID to allow the server to ignore the // request if it has completed. The server will ignore subsequent requests // that provide a duplicate request ID for at least 60 minutes after the first // request. // // For example, if an initial request times out, followed by another request // with the same request ID, the server ignores the second request to prevent // the creation of duplicate commitments. // // The request ID must be a valid // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier#Format). // A zero UUID (00000000-0000-0000-0000-000000000000) is not supported. RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // Optional. The type of the database dump. If unspecified, defaults to `MYSQL`. DatabaseDumpType DatabaseDumpSpec_Type `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
Request message for [DataprocMetastore.ExportMetadata][google.cloud.metastore.v1.DataprocMetastore.ExportMetadata].
func (*ExportMetadataRequest) Descriptor
deprecated
func (*ExportMetadataRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExportMetadataRequest.ProtoReflect.Descriptor instead.
func (*ExportMetadataRequest) GetDatabaseDumpType ¶
func (x *ExportMetadataRequest) GetDatabaseDumpType() DatabaseDumpSpec_Type
func (*ExportMetadataRequest) GetDestination ¶
func (m *ExportMetadataRequest) GetDestination() isExportMetadataRequest_Destination
func (*ExportMetadataRequest) GetDestinationGcsFolder ¶
func (x *ExportMetadataRequest) GetDestinationGcsFolder() string
func (*ExportMetadataRequest) GetRequestId ¶
func (x *ExportMetadataRequest) GetRequestId() string
func (*ExportMetadataRequest) GetService ¶
func (x *ExportMetadataRequest) GetService() string
func (*ExportMetadataRequest) ProtoMessage ¶
func (*ExportMetadataRequest) ProtoMessage()
func (*ExportMetadataRequest) ProtoReflect ¶
func (x *ExportMetadataRequest) ProtoReflect() protoreflect.Message
func (*ExportMetadataRequest) Reset ¶
func (x *ExportMetadataRequest) Reset()
func (*ExportMetadataRequest) String ¶
func (x *ExportMetadataRequest) String() string
type ExportMetadataRequest_DestinationGcsFolder ¶
type ExportMetadataRequest_DestinationGcsFolder struct { // A Cloud Storage URI of a folder, in the format // `gs://<bucket_name>/<path_inside_bucket>`. A sub-folder // `<export_folder>` containing exported files will be created below it. DestinationGcsFolder string `protobuf:"bytes,2,opt,name=destination_gcs_folder,json=destinationGcsFolder,proto3,oneof"` }
type GetMetadataImportRequest ¶
type GetMetadataImportRequest struct { // Required. The relative resource name of the metadata import to retrieve, in the // following form: // // `projects/{project_number}/locations/{location_id}/services/{service_id}/metadataImports/{import_id}`. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Request message for [DataprocMetastore.GetMetadataImport][google.cloud.metastore.v1.DataprocMetastore.GetMetadataImport].
func (*GetMetadataImportRequest) Descriptor
deprecated
func (*GetMetadataImportRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMetadataImportRequest.ProtoReflect.Descriptor instead.
func (*GetMetadataImportRequest) GetName ¶
func (x *GetMetadataImportRequest) GetName() string
func (*GetMetadataImportRequest) ProtoMessage ¶
func (*GetMetadataImportRequest) ProtoMessage()
func (*GetMetadataImportRequest) ProtoReflect ¶
func (x *GetMetadataImportRequest) ProtoReflect() protoreflect.Message
func (*GetMetadataImportRequest) Reset ¶
func (x *GetMetadataImportRequest) Reset()
func (*GetMetadataImportRequest) String ¶
func (x *GetMetadataImportRequest) String() string
type GetServiceRequest ¶
type GetServiceRequest struct { // Required. The relative resource name of the metastore service to retrieve, in the // following form: // // `projects/{project_number}/locations/{location_id}/services/{service_id}`. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Request message for [DataprocMetastore.GetService][google.cloud.metastore.v1.DataprocMetastore.GetService].
func (*GetServiceRequest) Descriptor
deprecated
func (*GetServiceRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetServiceRequest.ProtoReflect.Descriptor instead.
func (*GetServiceRequest) GetName ¶
func (x *GetServiceRequest) GetName() string
func (*GetServiceRequest) ProtoMessage ¶
func (*GetServiceRequest) ProtoMessage()
func (*GetServiceRequest) ProtoReflect ¶
func (x *GetServiceRequest) ProtoReflect() protoreflect.Message
func (*GetServiceRequest) Reset ¶
func (x *GetServiceRequest) Reset()
func (*GetServiceRequest) String ¶
func (x *GetServiceRequest) String() string
type HiveMetastoreConfig ¶
type HiveMetastoreConfig struct { // Immutable. The Hive metastore schema version. Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // A mapping of Hive metastore configuration key-value pairs to apply to the // Hive metastore (configured in `hive-site.xml`). The mappings // override system defaults (some keys cannot be overridden). ConfigOverrides map[string]string `` /* 194-byte string literal not displayed */ // Information used to configure the Hive metastore service as a service // principal in a Kerberos realm. To disable Kerberos, use the `UpdateService` // method and specify this field's path // (`hive_metastore_config.kerberos_config`) in the request's `update_mask` // while omitting this field from the request's `service`. KerberosConfig *KerberosConfig `protobuf:"bytes,3,opt,name=kerberos_config,json=kerberosConfig,proto3" json:"kerberos_config,omitempty"` // contains filtered or unexported fields }
Specifies configuration information specific to running Hive metastore software as the metastore service.
func (*HiveMetastoreConfig) Descriptor
deprecated
func (*HiveMetastoreConfig) Descriptor() ([]byte, []int)
Deprecated: Use HiveMetastoreConfig.ProtoReflect.Descriptor instead.
func (*HiveMetastoreConfig) GetConfigOverrides ¶
func (x *HiveMetastoreConfig) GetConfigOverrides() map[string]string
func (*HiveMetastoreConfig) GetKerberosConfig ¶
func (x *HiveMetastoreConfig) GetKerberosConfig() *KerberosConfig
func (*HiveMetastoreConfig) GetVersion ¶
func (x *HiveMetastoreConfig) GetVersion() string
func (*HiveMetastoreConfig) ProtoMessage ¶
func (*HiveMetastoreConfig) ProtoMessage()
func (*HiveMetastoreConfig) ProtoReflect ¶
func (x *HiveMetastoreConfig) ProtoReflect() protoreflect.Message
func (*HiveMetastoreConfig) Reset ¶
func (x *HiveMetastoreConfig) Reset()
func (*HiveMetastoreConfig) String ¶
func (x *HiveMetastoreConfig) String() string
type KerberosConfig ¶
type KerberosConfig struct { // A Kerberos keytab file that can be used to authenticate a service principal // with a Kerberos Key Distribution Center (KDC). Keytab *Secret `protobuf:"bytes,1,opt,name=keytab,proto3" json:"keytab,omitempty"` // A Kerberos principal that exists in the both the keytab the KDC // to authenticate as. A typical principal is of the form // `primary/instance@REALM`, but there is no exact format. Principal string `protobuf:"bytes,2,opt,name=principal,proto3" json:"principal,omitempty"` // A Cloud Storage URI that specifies the path to a // krb5.conf file. It is of the form `gs://{bucket_name}/path/to/krb5.conf`, // although the file does not need to be named krb5.conf explicitly. Krb5ConfigGcsUri string `protobuf:"bytes,3,opt,name=krb5_config_gcs_uri,json=krb5ConfigGcsUri,proto3" json:"krb5_config_gcs_uri,omitempty"` // contains filtered or unexported fields }
Configuration information for a Kerberos principal.
func (*KerberosConfig) Descriptor
deprecated
func (*KerberosConfig) Descriptor() ([]byte, []int)
Deprecated: Use KerberosConfig.ProtoReflect.Descriptor instead.
func (*KerberosConfig) GetKeytab ¶
func (x *KerberosConfig) GetKeytab() *Secret
func (*KerberosConfig) GetKrb5ConfigGcsUri ¶
func (x *KerberosConfig) GetKrb5ConfigGcsUri() string
func (*KerberosConfig) GetPrincipal ¶
func (x *KerberosConfig) GetPrincipal() string
func (*KerberosConfig) ProtoMessage ¶
func (*KerberosConfig) ProtoMessage()
func (*KerberosConfig) ProtoReflect ¶
func (x *KerberosConfig) ProtoReflect() protoreflect.Message
func (*KerberosConfig) Reset ¶
func (x *KerberosConfig) Reset()
func (*KerberosConfig) String ¶
func (x *KerberosConfig) String() string
type ListMetadataImportsRequest ¶
type ListMetadataImportsRequest struct { // Required. The relative resource name of the service whose metadata imports to // list, in the following form: // // `projects/{project_number}/locations/{location_id}/services/{service_id}/metadataImports`. Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // Optional. The maximum number of imports to return. The response may contain less // than the maximum number. If unspecified, no more than 500 imports are // returned. The maximum value is 1000; values above 1000 are changed to 1000. PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // Optional. A page token, received from a previous [DataprocMetastore.ListServices][google.cloud.metastore.v1.DataprocMetastore.ListServices] // call. Provide this token to retrieve the subsequent page. // // To retrieve the first page, supply an empty page token. // // When paginating, other parameters provided to // [DataprocMetastore.ListServices][google.cloud.metastore.v1.DataprocMetastore.ListServices] must match the call that provided the // page token. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // Optional. The filter to apply to list results. Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"` // Optional. Specify the ordering of results as described in [Sorting // Order](https://cloud.google.com/apis/design/design_patterns#sorting_order). // If not specified, the results will be sorted in the default order. OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"` // contains filtered or unexported fields }
Request message for [DataprocMetastore.ListMetadataImports][google.cloud.metastore.v1.DataprocMetastore.ListMetadataImports].
func (*ListMetadataImportsRequest) Descriptor
deprecated
func (*ListMetadataImportsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListMetadataImportsRequest.ProtoReflect.Descriptor instead.
func (*ListMetadataImportsRequest) GetFilter ¶
func (x *ListMetadataImportsRequest) GetFilter() string
func (*ListMetadataImportsRequest) GetOrderBy ¶
func (x *ListMetadataImportsRequest) GetOrderBy() string
func (*ListMetadataImportsRequest) GetPageSize ¶
func (x *ListMetadataImportsRequest) GetPageSize() int32
func (*ListMetadataImportsRequest) GetPageToken ¶
func (x *ListMetadataImportsRequest) GetPageToken() string
func (*ListMetadataImportsRequest) GetParent ¶
func (x *ListMetadataImportsRequest) GetParent() string
func (*ListMetadataImportsRequest) ProtoMessage ¶
func (*ListMetadataImportsRequest) ProtoMessage()
func (*ListMetadataImportsRequest) ProtoReflect ¶
func (x *ListMetadataImportsRequest) ProtoReflect() protoreflect.Message
func (*ListMetadataImportsRequest) Reset ¶
func (x *ListMetadataImportsRequest) Reset()
func (*ListMetadataImportsRequest) String ¶
func (x *ListMetadataImportsRequest) String() string
type ListMetadataImportsResponse ¶
type ListMetadataImportsResponse struct { // The imports in the specified service. MetadataImports []*MetadataImport `protobuf:"bytes,1,rep,name=metadata_imports,json=metadataImports,proto3" json:"metadata_imports,omitempty"` // A token that can be sent as `page_token` to retrieve the next page. If this // field is omitted, there are no subsequent pages. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // Locations that could not be reached. Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"` // contains filtered or unexported fields }
Response message for [DataprocMetastore.ListMetadataImports][google.cloud.metastore.v1.DataprocMetastore.ListMetadataImports].
func (*ListMetadataImportsResponse) Descriptor
deprecated
func (*ListMetadataImportsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListMetadataImportsResponse.ProtoReflect.Descriptor instead.
func (*ListMetadataImportsResponse) GetMetadataImports ¶
func (x *ListMetadataImportsResponse) GetMetadataImports() []*MetadataImport
func (*ListMetadataImportsResponse) GetNextPageToken ¶
func (x *ListMetadataImportsResponse) GetNextPageToken() string
func (*ListMetadataImportsResponse) GetUnreachable ¶
func (x *ListMetadataImportsResponse) GetUnreachable() []string
func (*ListMetadataImportsResponse) ProtoMessage ¶
func (*ListMetadataImportsResponse) ProtoMessage()
func (*ListMetadataImportsResponse) ProtoReflect ¶
func (x *ListMetadataImportsResponse) ProtoReflect() protoreflect.Message
func (*ListMetadataImportsResponse) Reset ¶
func (x *ListMetadataImportsResponse) Reset()
func (*ListMetadataImportsResponse) String ¶
func (x *ListMetadataImportsResponse) String() string
type ListServicesRequest ¶
type ListServicesRequest struct { // Required. The relative resource name of the location of metastore services to // list, in the following form: // // `projects/{project_number}/locations/{location_id}`. Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // Optional. The maximum number of services to return. The response may contain less // than the maximum number. If unspecified, no more than 500 services are // returned. The maximum value is 1000; values above 1000 are changed to 1000. PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // Optional. A page token, received from a previous [DataprocMetastore.ListServices][google.cloud.metastore.v1.DataprocMetastore.ListServices] // call. Provide this token to retrieve the subsequent page. // // To retrieve the first page, supply an empty page token. // // When paginating, other parameters provided to // [DataprocMetastore.ListServices][google.cloud.metastore.v1.DataprocMetastore.ListServices] must match the call that provided the // page token. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // Optional. The filter to apply to list results. Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"` // Optional. Specify the ordering of results as described in [Sorting // Order](https://cloud.google.com/apis/design/design_patterns#sorting_order). // If not specified, the results will be sorted in the default order. OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"` // contains filtered or unexported fields }
Request message for [DataprocMetastore.ListServices][google.cloud.metastore.v1.DataprocMetastore.ListServices].
func (*ListServicesRequest) Descriptor
deprecated
func (*ListServicesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListServicesRequest.ProtoReflect.Descriptor instead.
func (*ListServicesRequest) GetFilter ¶
func (x *ListServicesRequest) GetFilter() string
func (*ListServicesRequest) GetOrderBy ¶
func (x *ListServicesRequest) GetOrderBy() string
func (*ListServicesRequest) GetPageSize ¶
func (x *ListServicesRequest) GetPageSize() int32
func (*ListServicesRequest) GetPageToken ¶
func (x *ListServicesRequest) GetPageToken() string
func (*ListServicesRequest) GetParent ¶
func (x *ListServicesRequest) GetParent() string
func (*ListServicesRequest) ProtoMessage ¶
func (*ListServicesRequest) ProtoMessage()
func (*ListServicesRequest) ProtoReflect ¶
func (x *ListServicesRequest) ProtoReflect() protoreflect.Message
func (*ListServicesRequest) Reset ¶
func (x *ListServicesRequest) Reset()
func (*ListServicesRequest) String ¶
func (x *ListServicesRequest) String() string
type ListServicesResponse ¶
type ListServicesResponse struct { // The services in the specified location. Services []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"` // A token that can be sent as `page_token` to retrieve the next page. If this // field is omitted, there are no subsequent pages. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // Locations that could not be reached. Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"` // contains filtered or unexported fields }
Response message for [DataprocMetastore.ListServices][google.cloud.metastore.v1.DataprocMetastore.ListServices].
func (*ListServicesResponse) Descriptor
deprecated
func (*ListServicesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListServicesResponse.ProtoReflect.Descriptor instead.
func (*ListServicesResponse) GetNextPageToken ¶
func (x *ListServicesResponse) GetNextPageToken() string
func (*ListServicesResponse) GetServices ¶
func (x *ListServicesResponse) GetServices() []*Service
func (*ListServicesResponse) GetUnreachable ¶
func (x *ListServicesResponse) GetUnreachable() []string
func (*ListServicesResponse) ProtoMessage ¶
func (*ListServicesResponse) ProtoMessage()
func (*ListServicesResponse) ProtoReflect ¶
func (x *ListServicesResponse) ProtoReflect() protoreflect.Message
func (*ListServicesResponse) Reset ¶
func (x *ListServicesResponse) Reset()
func (*ListServicesResponse) String ¶
func (x *ListServicesResponse) String() string
type LocationMetadata ¶
type LocationMetadata struct { // The versions of Hive Metastore that can be used when creating a new // metastore service in this location. The server guarantees that exactly one // `HiveMetastoreVersion` in the list will set `is_default`. SupportedHiveMetastoreVersions []*LocationMetadata_HiveMetastoreVersion `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
Metadata about the service in a location.
func (*LocationMetadata) Descriptor
deprecated
func (*LocationMetadata) Descriptor() ([]byte, []int)
Deprecated: Use LocationMetadata.ProtoReflect.Descriptor instead.
func (*LocationMetadata) GetSupportedHiveMetastoreVersions ¶
func (x *LocationMetadata) GetSupportedHiveMetastoreVersions() []*LocationMetadata_HiveMetastoreVersion
func (*LocationMetadata) ProtoMessage ¶
func (*LocationMetadata) ProtoMessage()
func (*LocationMetadata) ProtoReflect ¶
func (x *LocationMetadata) ProtoReflect() protoreflect.Message
func (*LocationMetadata) Reset ¶
func (x *LocationMetadata) Reset()
func (*LocationMetadata) String ¶
func (x *LocationMetadata) String() string
type LocationMetadata_HiveMetastoreVersion ¶
type LocationMetadata_HiveMetastoreVersion struct { // The semantic version of the Hive Metastore software. Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // Whether `version` will be chosen by the server if a metastore service is // created with a `HiveMetastoreConfig` that omits the `version`. IsDefault bool `protobuf:"varint,2,opt,name=is_default,json=isDefault,proto3" json:"is_default,omitempty"` // contains filtered or unexported fields }
A specification of a supported version of the Hive Metastore software.
func (*LocationMetadata_HiveMetastoreVersion) Descriptor
deprecated
func (*LocationMetadata_HiveMetastoreVersion) Descriptor() ([]byte, []int)
Deprecated: Use LocationMetadata_HiveMetastoreVersion.ProtoReflect.Descriptor instead.
func (*LocationMetadata_HiveMetastoreVersion) GetIsDefault ¶
func (x *LocationMetadata_HiveMetastoreVersion) GetIsDefault() bool
func (*LocationMetadata_HiveMetastoreVersion) GetVersion ¶
func (x *LocationMetadata_HiveMetastoreVersion) GetVersion() string
func (*LocationMetadata_HiveMetastoreVersion) ProtoMessage ¶
func (*LocationMetadata_HiveMetastoreVersion) ProtoMessage()
func (*LocationMetadata_HiveMetastoreVersion) ProtoReflect ¶
func (x *LocationMetadata_HiveMetastoreVersion) ProtoReflect() protoreflect.Message
func (*LocationMetadata_HiveMetastoreVersion) Reset ¶
func (x *LocationMetadata_HiveMetastoreVersion) Reset()
func (*LocationMetadata_HiveMetastoreVersion) String ¶
func (x *LocationMetadata_HiveMetastoreVersion) String() string
type MaintenanceWindow ¶
type MaintenanceWindow struct { // The hour of day (0-23) when the window starts. HourOfDay *wrapperspb.Int32Value `protobuf:"bytes,1,opt,name=hour_of_day,json=hourOfDay,proto3" json:"hour_of_day,omitempty"` // The day of week, when the window starts. DayOfWeek dayofweek.DayOfWeek `protobuf:"varint,2,opt,name=day_of_week,json=dayOfWeek,proto3,enum=google.type.DayOfWeek" json:"day_of_week,omitempty"` // contains filtered or unexported fields }
Maintenance window. This specifies when Dataproc Metastore may perform system maintenance operation to the service.
func (*MaintenanceWindow) Descriptor
deprecated
func (*MaintenanceWindow) Descriptor() ([]byte, []int)
Deprecated: Use MaintenanceWindow.ProtoReflect.Descriptor instead.
func (*MaintenanceWindow) GetDayOfWeek ¶
func (x *MaintenanceWindow) GetDayOfWeek() dayofweek.DayOfWeek
func (*MaintenanceWindow) GetHourOfDay ¶
func (x *MaintenanceWindow) GetHourOfDay() *wrapperspb.Int32Value
func (*MaintenanceWindow) ProtoMessage ¶
func (*MaintenanceWindow) ProtoMessage()
func (*MaintenanceWindow) ProtoReflect ¶
func (x *MaintenanceWindow) ProtoReflect() protoreflect.Message
func (*MaintenanceWindow) Reset ¶
func (x *MaintenanceWindow) Reset()
func (*MaintenanceWindow) String ¶
func (x *MaintenanceWindow) String() string
type MetadataExport ¶
type MetadataExport struct { // Types that are assignable to Destination: // *MetadataExport_DestinationGcsUri Destination isMetadataExport_Destination `protobuf_oneof:"destination"` // Output only. The time when the export started. StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` // Output only. The time when the export ended. EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` // Output only. The current state of the export. State MetadataExport_State `protobuf:"varint,3,opt,name=state,proto3,enum=google.cloud.metastore.v1.MetadataExport_State" json:"state,omitempty"` // Output only. The type of the database dump. DatabaseDumpType DatabaseDumpSpec_Type `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
The details of a metadata export operation.
func (*MetadataExport) Descriptor
deprecated
func (*MetadataExport) Descriptor() ([]byte, []int)
Deprecated: Use MetadataExport.ProtoReflect.Descriptor instead.
func (*MetadataExport) GetDatabaseDumpType ¶
func (x *MetadataExport) GetDatabaseDumpType() DatabaseDumpSpec_Type
func (*MetadataExport) GetDestination ¶
func (m *MetadataExport) GetDestination() isMetadataExport_Destination
func (*MetadataExport) GetDestinationGcsUri ¶
func (x *MetadataExport) GetDestinationGcsUri() string
func (*MetadataExport) GetEndTime ¶
func (x *MetadataExport) GetEndTime() *timestamppb.Timestamp
func (*MetadataExport) GetStartTime ¶
func (x *MetadataExport) GetStartTime() *timestamppb.Timestamp
func (*MetadataExport) GetState ¶
func (x *MetadataExport) GetState() MetadataExport_State
func (*MetadataExport) ProtoMessage ¶
func (*MetadataExport) ProtoMessage()
func (*MetadataExport) ProtoReflect ¶
func (x *MetadataExport) ProtoReflect() protoreflect.Message
func (*MetadataExport) Reset ¶
func (x *MetadataExport) Reset()
func (*MetadataExport) String ¶
func (x *MetadataExport) String() string
type MetadataExport_DestinationGcsUri ¶
type MetadataExport_DestinationGcsUri struct { // Output only. A Cloud Storage URI of a folder that metadata are exported to, in the // form of `gs://<bucket_name>/<path_inside_bucket>/<export_folder>`, where // `<export_folder>` is automatically generated. DestinationGcsUri string `protobuf:"bytes,4,opt,name=destination_gcs_uri,json=destinationGcsUri,proto3,oneof"` }
type MetadataExport_State ¶
type MetadataExport_State int32
The current state of the metadata export.
const ( // The state of the metadata export is unknown. MetadataExport_STATE_UNSPECIFIED MetadataExport_State = 0 // The metadata export is running. MetadataExport_RUNNING MetadataExport_State = 1 // The metadata export completed successfully. MetadataExport_SUCCEEDED MetadataExport_State = 2 // The metadata export failed. MetadataExport_FAILED MetadataExport_State = 3 // The metadata export is cancelled. MetadataExport_CANCELLED MetadataExport_State = 4 )
func (MetadataExport_State) Descriptor ¶
func (MetadataExport_State) Descriptor() protoreflect.EnumDescriptor
func (MetadataExport_State) Enum ¶
func (x MetadataExport_State) Enum() *MetadataExport_State
func (MetadataExport_State) EnumDescriptor
deprecated
func (MetadataExport_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use MetadataExport_State.Descriptor instead.
func (MetadataExport_State) Number ¶
func (x MetadataExport_State) Number() protoreflect.EnumNumber
func (MetadataExport_State) String ¶
func (x MetadataExport_State) String() string
func (MetadataExport_State) Type ¶
func (MetadataExport_State) Type() protoreflect.EnumType
type MetadataImport ¶
type MetadataImport struct { // The metadata to be imported. // // Types that are assignable to Metadata: // *MetadataImport_DatabaseDump_ Metadata isMetadataImport_Metadata `protobuf_oneof:"metadata"` // Immutable. The relative resource name of the metadata import, of the form: // // `projects/{project_number}/locations/{location_id}/services/{service_id}/metadataImports/{metadata_import_id}`. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The description of the metadata import. Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` // Output only. The time when the metadata import was created. CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Output only. The time when the metadata import was last updated. UpdateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"` // Output only. The current state of the metadata import. State MetadataImport_State `protobuf:"varint,5,opt,name=state,proto3,enum=google.cloud.metastore.v1.MetadataImport_State" json:"state,omitempty"` // contains filtered or unexported fields }
A metastore resource that imports metadata.
func (*MetadataImport) Descriptor
deprecated
func (*MetadataImport) Descriptor() ([]byte, []int)
Deprecated: Use MetadataImport.ProtoReflect.Descriptor instead.
func (*MetadataImport) GetCreateTime ¶
func (x *MetadataImport) GetCreateTime() *timestamppb.Timestamp
func (*MetadataImport) GetDatabaseDump ¶
func (x *MetadataImport) GetDatabaseDump() *MetadataImport_DatabaseDump
func (*MetadataImport) GetDescription ¶
func (x *MetadataImport) GetDescription() string
func (*MetadataImport) GetMetadata ¶
func (m *MetadataImport) GetMetadata() isMetadataImport_Metadata
func (*MetadataImport) GetName ¶
func (x *MetadataImport) GetName() string
func (*MetadataImport) GetState ¶
func (x *MetadataImport) GetState() MetadataImport_State
func (*MetadataImport) GetUpdateTime ¶
func (x *MetadataImport) GetUpdateTime() *timestamppb.Timestamp
func (*MetadataImport) ProtoMessage ¶
func (*MetadataImport) ProtoMessage()
func (*MetadataImport) ProtoReflect ¶
func (x *MetadataImport) ProtoReflect() protoreflect.Message
func (*MetadataImport) Reset ¶
func (x *MetadataImport) Reset()
func (*MetadataImport) String ¶
func (x *MetadataImport) String() string
type MetadataImport_DatabaseDump ¶
type MetadataImport_DatabaseDump struct { // The type of the database. // // Deprecated: Do not use. DatabaseType MetadataImport_DatabaseDump_DatabaseType `` /* 170-byte string literal not displayed */ // A Cloud Storage object or folder URI that specifies the source from which // to import metadata. It must begin with `gs://`. GcsUri string `protobuf:"bytes,2,opt,name=gcs_uri,json=gcsUri,proto3" json:"gcs_uri,omitempty"` // Optional. The type of the database dump. If unspecified, defaults to `MYSQL`. Type DatabaseDumpSpec_Type `protobuf:"varint,4,opt,name=type,proto3,enum=google.cloud.metastore.v1.DatabaseDumpSpec_Type" json:"type,omitempty"` // contains filtered or unexported fields }
A specification of the location of and metadata about a database dump from a relational database management system.
func (*MetadataImport_DatabaseDump) Descriptor
deprecated
func (*MetadataImport_DatabaseDump) Descriptor() ([]byte, []int)
Deprecated: Use MetadataImport_DatabaseDump.ProtoReflect.Descriptor instead.
func (*MetadataImport_DatabaseDump) GetDatabaseType
deprecated
func (x *MetadataImport_DatabaseDump) GetDatabaseType() MetadataImport_DatabaseDump_DatabaseType
Deprecated: Do not use.
func (*MetadataImport_DatabaseDump) GetGcsUri ¶
func (x *MetadataImport_DatabaseDump) GetGcsUri() string
func (*MetadataImport_DatabaseDump) GetType ¶
func (x *MetadataImport_DatabaseDump) GetType() DatabaseDumpSpec_Type
func (*MetadataImport_DatabaseDump) ProtoMessage ¶
func (*MetadataImport_DatabaseDump) ProtoMessage()
func (*MetadataImport_DatabaseDump) ProtoReflect ¶
func (x *MetadataImport_DatabaseDump) ProtoReflect() protoreflect.Message
func (*MetadataImport_DatabaseDump) Reset ¶
func (x *MetadataImport_DatabaseDump) Reset()
func (*MetadataImport_DatabaseDump) String ¶
func (x *MetadataImport_DatabaseDump) String() string
type MetadataImport_DatabaseDump_ ¶
type MetadataImport_DatabaseDump_ struct { // Immutable. A database dump from a pre-existing metastore's database. DatabaseDump *MetadataImport_DatabaseDump `protobuf:"bytes,6,opt,name=database_dump,json=databaseDump,proto3,oneof"` }
type MetadataImport_DatabaseDump_DatabaseType ¶
type MetadataImport_DatabaseDump_DatabaseType int32
The type of the database.
const ( // The type of the source database is unknown. MetadataImport_DatabaseDump_DATABASE_TYPE_UNSPECIFIED MetadataImport_DatabaseDump_DatabaseType = 0 // The type of the source database is MySQL. MetadataImport_DatabaseDump_MYSQL MetadataImport_DatabaseDump_DatabaseType = 1 )
func (MetadataImport_DatabaseDump_DatabaseType) Descriptor ¶
func (MetadataImport_DatabaseDump_DatabaseType) Descriptor() protoreflect.EnumDescriptor
func (MetadataImport_DatabaseDump_DatabaseType) EnumDescriptor
deprecated
func (MetadataImport_DatabaseDump_DatabaseType) EnumDescriptor() ([]byte, []int)
Deprecated: Use MetadataImport_DatabaseDump_DatabaseType.Descriptor instead.
func (MetadataImport_DatabaseDump_DatabaseType) Number ¶
func (x MetadataImport_DatabaseDump_DatabaseType) Number() protoreflect.EnumNumber
func (MetadataImport_DatabaseDump_DatabaseType) String ¶
func (x MetadataImport_DatabaseDump_DatabaseType) String() string
func (MetadataImport_DatabaseDump_DatabaseType) Type ¶
func (MetadataImport_DatabaseDump_DatabaseType) Type() protoreflect.EnumType
type MetadataImport_State ¶
type MetadataImport_State int32
The current state of the metadata import.
const ( // The state of the metadata import is unknown. MetadataImport_STATE_UNSPECIFIED MetadataImport_State = 0 // The metadata import is running. MetadataImport_RUNNING MetadataImport_State = 1 // The metadata import completed successfully. MetadataImport_SUCCEEDED MetadataImport_State = 2 // The metadata import is being updated. MetadataImport_UPDATING MetadataImport_State = 3 // The metadata import failed, and attempted metadata changes were rolled // back. MetadataImport_FAILED MetadataImport_State = 4 )
func (MetadataImport_State) Descriptor ¶
func (MetadataImport_State) Descriptor() protoreflect.EnumDescriptor
func (MetadataImport_State) Enum ¶
func (x MetadataImport_State) Enum() *MetadataImport_State
func (MetadataImport_State) EnumDescriptor
deprecated
func (MetadataImport_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use MetadataImport_State.Descriptor instead.
func (MetadataImport_State) Number ¶
func (x MetadataImport_State) Number() protoreflect.EnumNumber
func (MetadataImport_State) String ¶
func (x MetadataImport_State) String() string
func (MetadataImport_State) Type ¶
func (MetadataImport_State) Type() protoreflect.EnumType
type MetadataManagementActivity ¶
type MetadataManagementActivity struct { // Output only. The latest metadata exports of the metastore service. MetadataExports []*MetadataExport `protobuf:"bytes,1,rep,name=metadata_exports,json=metadataExports,proto3" json:"metadata_exports,omitempty"` // contains filtered or unexported fields }
The metadata management activities of the metastore service.
func (*MetadataManagementActivity) Descriptor
deprecated
func (*MetadataManagementActivity) Descriptor() ([]byte, []int)
Deprecated: Use MetadataManagementActivity.ProtoReflect.Descriptor instead.
func (*MetadataManagementActivity) GetMetadataExports ¶
func (x *MetadataManagementActivity) GetMetadataExports() []*MetadataExport
func (*MetadataManagementActivity) ProtoMessage ¶
func (*MetadataManagementActivity) ProtoMessage()
func (*MetadataManagementActivity) ProtoReflect ¶
func (x *MetadataManagementActivity) ProtoReflect() protoreflect.Message
func (*MetadataManagementActivity) Reset ¶
func (x *MetadataManagementActivity) Reset()
func (*MetadataManagementActivity) String ¶
func (x *MetadataManagementActivity) String() string
type OperationMetadata ¶
type OperationMetadata struct { // Output only. The time the operation was created. CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Output only. The time the operation finished running. EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` // Output only. Server-defined resource path for the target of the operation. Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` // Output only. Name of the verb executed by the operation. Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"` // Output only. Human-readable status of the operation, if any. StatusMessage string `protobuf:"bytes,5,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"` // Output only. Identifies whether the caller has requested cancellation // of the operation. Operations that have successfully been cancelled // have [Operation.error][] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1, // corresponding to `Code.CANCELLED`. RequestedCancellation bool `protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"` // Output only. API version used to start the operation. ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"` // contains filtered or unexported fields }
Represents the metadata of a long-running operation.
func (*OperationMetadata) Descriptor
deprecated
func (*OperationMetadata) Descriptor() ([]byte, []int)
Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.
func (*OperationMetadata) GetApiVersion ¶
func (x *OperationMetadata) GetApiVersion() string
func (*OperationMetadata) GetCreateTime ¶
func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp
func (*OperationMetadata) GetEndTime ¶
func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp
func (*OperationMetadata) GetRequestedCancellation ¶
func (x *OperationMetadata) GetRequestedCancellation() bool
func (*OperationMetadata) GetStatusMessage ¶
func (x *OperationMetadata) GetStatusMessage() string
func (*OperationMetadata) GetTarget ¶
func (x *OperationMetadata) GetTarget() string
func (*OperationMetadata) GetVerb ¶
func (x *OperationMetadata) GetVerb() string
func (*OperationMetadata) ProtoMessage ¶
func (*OperationMetadata) ProtoMessage()
func (*OperationMetadata) ProtoReflect ¶
func (x *OperationMetadata) ProtoReflect() protoreflect.Message
func (*OperationMetadata) Reset ¶
func (x *OperationMetadata) Reset()
func (*OperationMetadata) String ¶
func (x *OperationMetadata) String() string
type Secret ¶
type Secret struct { // Types that are assignable to Value: // *Secret_CloudSecret Value isSecret_Value `protobuf_oneof:"value"` // contains filtered or unexported fields }
A securely stored value.
func (*Secret) Descriptor
deprecated
func (*Secret) GetCloudSecret ¶
func (*Secret) ProtoMessage ¶
func (*Secret) ProtoMessage()
func (*Secret) ProtoReflect ¶
func (x *Secret) ProtoReflect() protoreflect.Message
type Secret_CloudSecret ¶
type Secret_CloudSecret struct { // The relative resource name of a Secret Manager secret version, in the // following form: // // `projects/{project_number}/secrets/{secret_id}/versions/{version_id}`. CloudSecret string `protobuf:"bytes,2,opt,name=cloud_secret,json=cloudSecret,proto3,oneof"` }
type Service ¶
type Service struct { // Configuration properties specific to the underlying metastore service // technology (the software that serves metastore queries). // // Types that are assignable to MetastoreConfig: // *Service_HiveMetastoreConfig MetastoreConfig isService_MetastoreConfig `protobuf_oneof:"metastore_config"` // Immutable. The relative resource name of the metastore service, of the form: // // `projects/{project_number}/locations/{location_id}/services/{service_id}`. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Output only. The time when the metastore service was created. CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Output only. The time when the metastore service was last updated. UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"` // User-defined labels for the metastore service. Labels map[string]string `` /* 153-byte string literal not displayed */ // Immutable. The relative resource name of the VPC network on which the instance can be // accessed. It is specified in the following form: // // `projects/{project_number}/global/networks/{network_id}`. Network string `protobuf:"bytes,7,opt,name=network,proto3" json:"network,omitempty"` // Output only. The URI of the endpoint used to access the metastore service. EndpointUri string `protobuf:"bytes,8,opt,name=endpoint_uri,json=endpointUri,proto3" json:"endpoint_uri,omitempty"` // The TCP port at which the metastore service is reached. Default: 9083. Port int32 `protobuf:"varint,9,opt,name=port,proto3" json:"port,omitempty"` // Output only. The current state of the metastore service. State Service_State `protobuf:"varint,10,opt,name=state,proto3,enum=google.cloud.metastore.v1.Service_State" json:"state,omitempty"` // Output only. Additional information about the current state of the metastore service, if // available. StateMessage string `protobuf:"bytes,11,opt,name=state_message,json=stateMessage,proto3" json:"state_message,omitempty"` // Output only. A Cloud Storage URI (starting with `gs://`) that specifies where artifacts // related to the metastore service are stored. ArtifactGcsUri string `protobuf:"bytes,12,opt,name=artifact_gcs_uri,json=artifactGcsUri,proto3" json:"artifact_gcs_uri,omitempty"` // The tier of the service. Tier Service_Tier `protobuf:"varint,13,opt,name=tier,proto3,enum=google.cloud.metastore.v1.Service_Tier" json:"tier,omitempty"` // The one hour maintenance window of the metastore service. This specifies // when the service can be restarted for maintenance purposes in UTC time. MaintenanceWindow *MaintenanceWindow `protobuf:"bytes,15,opt,name=maintenance_window,json=maintenanceWindow,proto3" json:"maintenance_window,omitempty"` // Output only. The globally unique resource identifier of the metastore service. Uid string `protobuf:"bytes,16,opt,name=uid,proto3" json:"uid,omitempty"` // Output only. The metadata management activities of the metastore service. MetadataManagementActivity *MetadataManagementActivity `` /* 142-byte string literal not displayed */ // Immutable. The release channel of the service. // If unspecified, defaults to `STABLE`. ReleaseChannel Service_ReleaseChannel `` /* 159-byte string literal not displayed */ // contains filtered or unexported fields }
A managed metastore service that serves metadata queries.
func (*Service) Descriptor
deprecated
func (*Service) GetArtifactGcsUri ¶
func (*Service) GetCreateTime ¶
func (x *Service) GetCreateTime() *timestamppb.Timestamp
func (*Service) GetEndpointUri ¶
func (*Service) GetHiveMetastoreConfig ¶
func (x *Service) GetHiveMetastoreConfig() *HiveMetastoreConfig
func (*Service) GetMaintenanceWindow ¶
func (x *Service) GetMaintenanceWindow() *MaintenanceWindow
func (*Service) GetMetadataManagementActivity ¶
func (x *Service) GetMetadataManagementActivity() *MetadataManagementActivity
func (*Service) GetMetastoreConfig ¶
func (m *Service) GetMetastoreConfig() isService_MetastoreConfig
func (*Service) GetNetwork ¶
func (*Service) GetReleaseChannel ¶
func (x *Service) GetReleaseChannel() Service_ReleaseChannel
func (*Service) GetState ¶
func (x *Service) GetState() Service_State
func (*Service) GetStateMessage ¶
func (*Service) GetTier ¶
func (x *Service) GetTier() Service_Tier
func (*Service) GetUpdateTime ¶
func (x *Service) GetUpdateTime() *timestamppb.Timestamp
func (*Service) ProtoMessage ¶
func (*Service) ProtoMessage()
func (*Service) ProtoReflect ¶
func (x *Service) ProtoReflect() protoreflect.Message
type Service_HiveMetastoreConfig ¶
type Service_HiveMetastoreConfig struct { // Configuration information specific to running Hive metastore // software as the metastore service. HiveMetastoreConfig *HiveMetastoreConfig `protobuf:"bytes,5,opt,name=hive_metastore_config,json=hiveMetastoreConfig,proto3,oneof"` }
type Service_ReleaseChannel ¶
type Service_ReleaseChannel int32
Release channels bundle features of varying levels of stability. Newer features may be introduced initially into less stable release channels and can be automatically promoted into more stable release channels.
const ( // Release channel is not specified. Service_RELEASE_CHANNEL_UNSPECIFIED Service_ReleaseChannel = 0 // The `CANARY` release channel contains the newest features, which may be // unstable and subject to unresolved issues with no known workarounds. // Services using the `CANARY` release channel are not subject to any SLAs. Service_CANARY Service_ReleaseChannel = 1 // The `STABLE` release channel contains features that are considered stable // and have been validated for production use. Service_STABLE Service_ReleaseChannel = 2 )
func (Service_ReleaseChannel) Descriptor ¶
func (Service_ReleaseChannel) Descriptor() protoreflect.EnumDescriptor
func (Service_ReleaseChannel) Enum ¶
func (x Service_ReleaseChannel) Enum() *Service_ReleaseChannel
func (Service_ReleaseChannel) EnumDescriptor
deprecated
func (Service_ReleaseChannel) EnumDescriptor() ([]byte, []int)
Deprecated: Use Service_ReleaseChannel.Descriptor instead.
func (Service_ReleaseChannel) Number ¶
func (x Service_ReleaseChannel) Number() protoreflect.EnumNumber
func (Service_ReleaseChannel) String ¶
func (x Service_ReleaseChannel) String() string
func (Service_ReleaseChannel) Type ¶
func (Service_ReleaseChannel) Type() protoreflect.EnumType
type Service_State ¶
type Service_State int32
The current state of the metastore service.
const ( // The state of the metastore service is unknown. Service_STATE_UNSPECIFIED Service_State = 0 // The metastore service is in the process of being created. Service_CREATING Service_State = 1 // The metastore service is running and ready to serve queries. Service_ACTIVE Service_State = 2 // The metastore service is entering suspension. Its query-serving // availability may cease unexpectedly. Service_SUSPENDING Service_State = 3 // The metastore service is suspended and unable to serve queries. Service_SUSPENDED Service_State = 4 // The metastore service is being updated. It remains usable but cannot // accept additional update requests or be deleted at this time. Service_UPDATING Service_State = 5 // The metastore service is undergoing deletion. It cannot be used. Service_DELETING Service_State = 6 // The metastore service has encountered an error and cannot be used. The // metastore service should be deleted. Service_ERROR Service_State = 7 )
func (Service_State) Descriptor ¶
func (Service_State) Descriptor() protoreflect.EnumDescriptor
func (Service_State) Enum ¶
func (x Service_State) Enum() *Service_State
func (Service_State) EnumDescriptor
deprecated
func (Service_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use Service_State.Descriptor instead.
func (Service_State) Number ¶
func (x Service_State) Number() protoreflect.EnumNumber
func (Service_State) String ¶
func (x Service_State) String() string
func (Service_State) Type ¶
func (Service_State) Type() protoreflect.EnumType
type Service_Tier ¶
type Service_Tier int32
Available service tiers.
const ( // The tier is not set. Service_TIER_UNSPECIFIED Service_Tier = 0 // The developer tier provides limited scalability and no fault tolerance. // Good for low-cost proof-of-concept. Service_DEVELOPER Service_Tier = 1 // The enterprise tier provides multi-zone high availability, and sufficient // scalability for enterprise-level Dataproc Metastore workloads. Service_ENTERPRISE Service_Tier = 3 )
func (Service_Tier) Descriptor ¶
func (Service_Tier) Descriptor() protoreflect.EnumDescriptor
func (Service_Tier) Enum ¶
func (x Service_Tier) Enum() *Service_Tier
func (Service_Tier) EnumDescriptor
deprecated
func (Service_Tier) EnumDescriptor() ([]byte, []int)
Deprecated: Use Service_Tier.Descriptor instead.
func (Service_Tier) Number ¶
func (x Service_Tier) Number() protoreflect.EnumNumber
func (Service_Tier) String ¶
func (x Service_Tier) String() string
func (Service_Tier) Type ¶
func (Service_Tier) Type() protoreflect.EnumType
type UnimplementedDataprocMetastoreServer ¶
type UnimplementedDataprocMetastoreServer struct { }
UnimplementedDataprocMetastoreServer can be embedded to have forward compatible implementations.
func (*UnimplementedDataprocMetastoreServer) CreateMetadataImport ¶
func (*UnimplementedDataprocMetastoreServer) CreateMetadataImport(context.Context, *CreateMetadataImportRequest) (*longrunning.Operation, error)
func (*UnimplementedDataprocMetastoreServer) CreateService ¶
func (*UnimplementedDataprocMetastoreServer) CreateService(context.Context, *CreateServiceRequest) (*longrunning.Operation, error)
func (*UnimplementedDataprocMetastoreServer) DeleteService ¶
func (*UnimplementedDataprocMetastoreServer) DeleteService(context.Context, *DeleteServiceRequest) (*longrunning.Operation, error)
func (*UnimplementedDataprocMetastoreServer) ExportMetadata ¶
func (*UnimplementedDataprocMetastoreServer) ExportMetadata(context.Context, *ExportMetadataRequest) (*longrunning.Operation, error)
func (*UnimplementedDataprocMetastoreServer) GetMetadataImport ¶
func (*UnimplementedDataprocMetastoreServer) GetMetadataImport(context.Context, *GetMetadataImportRequest) (*MetadataImport, error)
func (*UnimplementedDataprocMetastoreServer) GetService ¶
func (*UnimplementedDataprocMetastoreServer) GetService(context.Context, *GetServiceRequest) (*Service, error)
func (*UnimplementedDataprocMetastoreServer) ListMetadataImports ¶
func (*UnimplementedDataprocMetastoreServer) ListMetadataImports(context.Context, *ListMetadataImportsRequest) (*ListMetadataImportsResponse, error)
func (*UnimplementedDataprocMetastoreServer) ListServices ¶
func (*UnimplementedDataprocMetastoreServer) ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
func (*UnimplementedDataprocMetastoreServer) UpdateMetadataImport ¶
func (*UnimplementedDataprocMetastoreServer) UpdateMetadataImport(context.Context, *UpdateMetadataImportRequest) (*longrunning.Operation, error)
func (*UnimplementedDataprocMetastoreServer) UpdateService ¶
func (*UnimplementedDataprocMetastoreServer) UpdateService(context.Context, *UpdateServiceRequest) (*longrunning.Operation, error)
type UpdateMetadataImportRequest ¶
type UpdateMetadataImportRequest struct { // Required. A field mask used to specify the fields to be overwritten in the // metadata import resource by the update. // Fields specified in the `update_mask` are relative to the resource (not // to the full request). A field is overwritten if it is in the mask. UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // Required. The metadata import to update. The server only merges fields // in the import if they are specified in `update_mask`. // // The metadata import's `name` field is used to identify the metastore // import to be updated. MetadataImport *MetadataImport `protobuf:"bytes,2,opt,name=metadata_import,json=metadataImport,proto3" json:"metadata_import,omitempty"` // Optional. A request ID. Specify a unique request ID to allow the server to ignore the // request if it has completed. The server will ignore subsequent requests // that provide a duplicate request ID for at least 60 minutes after the first // request. // // For example, if an initial request times out, followed by another request // with the same request ID, the server ignores the second request to prevent // the creation of duplicate commitments. // // The request ID must be a valid // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier#Format) // A zero UUID (00000000-0000-0000-0000-000000000000) is not supported. RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
Request message for [DataprocMetastore.UpdateMetadataImport][google.cloud.metastore.v1.DataprocMetastore.UpdateMetadataImport].
func (*UpdateMetadataImportRequest) Descriptor
deprecated
func (*UpdateMetadataImportRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateMetadataImportRequest.ProtoReflect.Descriptor instead.
func (*UpdateMetadataImportRequest) GetMetadataImport ¶
func (x *UpdateMetadataImportRequest) GetMetadataImport() *MetadataImport
func (*UpdateMetadataImportRequest) GetRequestId ¶
func (x *UpdateMetadataImportRequest) GetRequestId() string
func (*UpdateMetadataImportRequest) GetUpdateMask ¶
func (x *UpdateMetadataImportRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateMetadataImportRequest) ProtoMessage ¶
func (*UpdateMetadataImportRequest) ProtoMessage()
func (*UpdateMetadataImportRequest) ProtoReflect ¶
func (x *UpdateMetadataImportRequest) ProtoReflect() protoreflect.Message
func (*UpdateMetadataImportRequest) Reset ¶
func (x *UpdateMetadataImportRequest) Reset()
func (*UpdateMetadataImportRequest) String ¶
func (x *UpdateMetadataImportRequest) String() string
type UpdateServiceRequest ¶
type UpdateServiceRequest struct { // Required. A field mask used to specify the fields to be overwritten in the // metastore service resource by the update. // Fields specified in the `update_mask` are relative to the resource (not // to the full request). A field is overwritten if it is in the mask. UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // Required. The metastore service to update. The server only merges fields // in the service if they are specified in `update_mask`. // // The metastore service's `name` field is used to identify the metastore // service to be updated. Service *Service `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"` // Optional. A request ID. Specify a unique request ID to allow the server to ignore the // request if it has completed. The server will ignore subsequent requests // that provide a duplicate request ID for at least 60 minutes after the first // request. // // For example, if an initial request times out, followed by another request // with the same request ID, the server ignores the second request to prevent // the creation of duplicate commitments. // // The request ID must be a valid // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier#Format) // A zero UUID (00000000-0000-0000-0000-000000000000) is not supported. RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
Request message for [DataprocMetastore.UpdateService][google.cloud.metastore.v1.DataprocMetastore.UpdateService].
func (*UpdateServiceRequest) Descriptor
deprecated
func (*UpdateServiceRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateServiceRequest.ProtoReflect.Descriptor instead.
func (*UpdateServiceRequest) GetRequestId ¶
func (x *UpdateServiceRequest) GetRequestId() string
func (*UpdateServiceRequest) GetService ¶
func (x *UpdateServiceRequest) GetService() *Service
func (*UpdateServiceRequest) GetUpdateMask ¶
func (x *UpdateServiceRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateServiceRequest) ProtoMessage ¶
func (*UpdateServiceRequest) ProtoMessage()
func (*UpdateServiceRequest) ProtoReflect ¶
func (x *UpdateServiceRequest) ProtoReflect() protoreflect.Message
func (*UpdateServiceRequest) Reset ¶
func (x *UpdateServiceRequest) Reset()
func (*UpdateServiceRequest) String ¶
func (x *UpdateServiceRequest) String() string