Documentation
Index ¶
- Variables
- func RegisterDataprocMetastoreServer(s *grpc.Server, srv DataprocMetastoreServer)
- type CreateMetadataImportRequest
- func (*CreateMetadataImportRequest) Descriptor() ([]byte, []int)
- 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)
- 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 DataprocMetastoreClient
- type DataprocMetastoreServer
- type DeleteServiceRequest
- func (*DeleteServiceRequest) Descriptor() ([]byte, []int)
- 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 GetMetadataImportRequest
- func (*GetMetadataImportRequest) Descriptor() ([]byte, []int)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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)
- 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 MetadataImport
- func (*MetadataImport) Descriptor() ([]byte, []int)
- 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)
- func (x *MetadataImport_DatabaseDump) GetDatabaseType() MetadataImport_DatabaseDump_DatabaseType
- func (x *MetadataImport_DatabaseDump) GetGcsUri() string
- func (x *MetadataImport_DatabaseDump) GetSourceDatabase() string
- 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)
- 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)
- func (x MetadataImport_State) Number() protoreflect.EnumNumber
- func (x MetadataImport_State) String() string
- func (MetadataImport_State) Type() protoreflect.EnumType
- type OperationMetadata
- func (*OperationMetadata) Descriptor() ([]byte, []int)
- 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)
- 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 (m *Service) GetMetastoreConfig() isService_MetastoreConfig
- func (x *Service) GetName() string
- func (x *Service) GetNetwork() string
- func (x *Service) GetPort() int32
- func (x *Service) GetState() Service_State
- func (x *Service) GetStateMessage() string
- func (x *Service) GetTier() Service_Tier
- 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_State
- func (Service_State) Descriptor() protoreflect.EnumDescriptor
- func (x Service_State) Enum() *Service_State
- func (Service_State) EnumDescriptor() ([]byte, []int)
- func (x Service_State) Number() protoreflect.EnumNumber
- func (x Service_State) String() string
- func (Service_State) Type() protoreflect.EnumType
- type Service_Tier
- 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) 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)
- 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)
- 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 ¶
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", 3: "ENTERPRISE", } Service_Tier_value = map[string]int32{ "TIER_UNSPECIFIED": 0, "ENTERPRISE": 3, } )
Enum value maps for Service_Tier.
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 File_google_cloud_metastore_v1alpha_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_id}/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.v1alpha.DataprocMetastore.CreateMetadataImport].
func (*CreateMetadataImportRequest) Descriptor ¶
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_id}/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 1 and 64 characters long, 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.v1alpha.DataprocMetastore.CreateService].
func (*CreateServiceRequest) Descriptor ¶
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 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) }
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) }
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_id}/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.v1alpha.DataprocMetastore.DeleteService].
func (*DeleteServiceRequest) Descriptor ¶
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 GetMetadataImportRequest ¶
type GetMetadataImportRequest struct { // Required. The relative resource name of the metadata import to retrieve, in the // following form: // // "projects/{project_id}/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.v1alpha.DataprocMetastore.GetMetadataImport].
func (*GetMetadataImportRequest) Descriptor ¶
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_id}/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.v1alpha.DataprocMetastore.GetService].
func (*GetServiceRequest) Descriptor ¶
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. 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 ¶
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 ¶
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_id}/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.v1alpha.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.v1alpha.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](/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.v1alpha.DataprocMetastore.ListMetadataImports].
func (*ListMetadataImportsRequest) Descriptor ¶
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.v1alpha.DataprocMetastore.ListMetadataImports].
func (*ListMetadataImportsResponse) Descriptor ¶
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_id}/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.v1alpha.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.v1alpha.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](/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.v1alpha.DataprocMetastore.ListServices].
func (*ListServicesRequest) Descriptor ¶
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.v1alpha.DataprocMetastore.ListServices].
func (*ListServicesResponse) Descriptor ¶
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 ¶
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 ¶
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 MetadataImport ¶
type MetadataImport struct { // Immutable. The relative resource name of the metadata import, of the form: // // "projects/{project_id}/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.v1alpha.MetadataImport_State" json:"state,omitempty"` // The metadata to be imported. // // Types that are assignable to Metadata: // *MetadataImport_DatabaseDump_ Metadata isMetadataImport_Metadata `protobuf_oneof:"metadata"` // contains filtered or unexported fields }
A metastore resource that imports metadata.
func (*MetadataImport) Descriptor ¶
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. DatabaseType MetadataImport_DatabaseDump_DatabaseType `` /* 175-byte string literal not displayed */ // A Cloud Storage object 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"` // The name of the source database. SourceDatabase string `protobuf:"bytes,3,opt,name=source_database,json=sourceDatabase,proto3" json:"source_database,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 ¶
func (*MetadataImport_DatabaseDump) Descriptor() ([]byte, []int)
Deprecated: Use MetadataImport_DatabaseDump.ProtoReflect.Descriptor instead.
func (*MetadataImport_DatabaseDump) GetDatabaseType ¶
func (x *MetadataImport_DatabaseDump) GetDatabaseType() MetadataImport_DatabaseDump_DatabaseType
func (*MetadataImport_DatabaseDump) GetGcsUri ¶
func (x *MetadataImport_DatabaseDump) GetGcsUri() string
func (*MetadataImport_DatabaseDump) GetSourceDatabase ¶
func (x *MetadataImport_DatabaseDump) GetSourceDatabase() string
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 ¶
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 ¶
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 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 ¶
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: Use Secret.ProtoReflect.Descriptor instead.
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_id}/secrets/{secret_id}/versions/{version_id}". CloudSecret string `protobuf:"bytes,2,opt,name=cloud_secret,json=cloudSecret,proto3,oneof"` }
type Service ¶
type Service struct { // Immutable. The relative resource name of the metastore service, of the form: // // "projects/{project_id}/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 */ // 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 VPC network on which the instance can be // accessed. The network must belong to the same project as the metastore // instance. It is specified in the following form: // // "projects/{project_id}/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.v1alpha.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.v1alpha.Service_Tier" json:"tier,omitempty"` // contains filtered or unexported fields }
A managed metastore service that serves metadata queries.
func (*Service) Descriptor ¶
Deprecated: Use Service.ProtoReflect.Descriptor instead.
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) GetMetastoreConfig ¶
func (m *Service) GetMetastoreConfig() isService_MetastoreConfig
func (*Service) GetNetwork ¶
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_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 ¶
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 enterprise tier combines a powerful metastore serving layer with a // highly scalable data storage layer. 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 ¶
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) 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.v1alpha.DataprocMetastore.UpdateMetadataImport].
func (*UpdateMetadataImportRequest) Descriptor ¶
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.v1alpha.DataprocMetastore.UpdateService].
func (*UpdateServiceRequest) Descriptor ¶
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