- 1.63.1 (latest)
- 1.63.0
- 1.62.0
- 1.61.0
- 1.60.0
- 1.59.1
- 1.58.0
- 1.57.1
- 1.54.0
- 1.53.0
- 1.52.0
- 1.51.2
- 1.50.0
- 1.49.0
- 1.48.0
- 1.47.0
- 1.46.0
- 1.45.0
- 1.44.0
- 1.43.0
- 1.42.0
- 1.41.0
- 1.40.0
- 1.39.0
- 1.38.0
- 1.37.0
- 1.36.0
- 1.35.0
- 1.34.1
- 1.33.0
- 1.32.0
- 1.31.0
- 1.30.2
- 1.29.0
- 1.28.0
- 1.27.0
- 1.26.0
- 1.25.0
- 1.24.0
- 1.23.0
- 1.22.0
- 1.21.0
- 1.20.1
- 1.19.0
- 1.18.0
- 1.17.0
- 1.16.0
- 1.15.0
Variables
TableView_name, TableView_value
var (
TableView_name = map[int32]string{
0: "TABLE_VIEW_UNSPECIFIED",
1: "BASIC",
2: "FULL",
}
TableView_value = map[string]int32{
"TABLE_VIEW_UNSPECIFIED": 0,
"BASIC": 1,
"FULL": 2,
}
)
Enum value maps for TableView.
Database_Type_name, Database_Type_value
var (
Database_Type_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "HIVE",
}
Database_Type_value = map[string]int32{
"TYPE_UNSPECIFIED": 0,
"HIVE": 1,
}
)
Enum value maps for Database_Type.
Table_Type_name, Table_Type_value
var (
Table_Type_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "HIVE",
}
Table_Type_value = map[string]int32{
"TYPE_UNSPECIFIED": 0,
"HIVE": 1,
}
)
Enum value maps for Table_Type.
Lock_Type_name, Lock_Type_value
var (
Lock_Type_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "EXCLUSIVE",
}
Lock_Type_value = map[string]int32{
"TYPE_UNSPECIFIED": 0,
"EXCLUSIVE": 1,
}
)
Enum value maps for Lock_Type.
Lock_State_name, Lock_State_value
var (
Lock_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "WAITING",
2: "ACQUIRED",
}
Lock_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"WAITING": 1,
"ACQUIRED": 2,
}
)
Enum value maps for Lock_State.
File_google_cloud_bigquery_biglake_v1alpha1_metastore_proto
var File_google_cloud_bigquery_biglake_v1alpha1_metastore_proto protoreflect.FileDescriptor
Functions
func RegisterMetastoreServiceServer
func RegisterMetastoreServiceServer(s *grpc.Server, srv MetastoreServiceServer)
Catalog
type Catalog struct {
// Output only. The resource name.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Output only. The creation time of the catalog.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The last modification time of the catalog.
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// Output only. The deletion time of the catalog. Only set after the catalog
// is deleted.
DeleteTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=delete_time,json=deleteTime,proto3" json:"delete_time,omitempty"`
// Output only. The time when this catalog is considered expired. Only set
// after the catalog is deleted.
ExpireTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
// contains filtered or unexported fields
}
Catalog is the container of databases.
func (*Catalog) Descriptor
Deprecated: Use Catalog.ProtoReflect.Descriptor instead.
func (*Catalog) GetCreateTime
func (x *Catalog) GetCreateTime() *timestamppb.Timestamp
func (*Catalog) GetDeleteTime
func (x *Catalog) GetDeleteTime() *timestamppb.Timestamp
func (*Catalog) GetExpireTime
func (x *Catalog) GetExpireTime() *timestamppb.Timestamp
func (*Catalog) GetName
func (*Catalog) GetUpdateTime
func (x *Catalog) GetUpdateTime() *timestamppb.Timestamp
func (*Catalog) ProtoMessage
func (*Catalog) ProtoMessage()
func (*Catalog) ProtoReflect
func (x *Catalog) ProtoReflect() protoreflect.Message
func (*Catalog) Reset
func (x *Catalog) Reset()
func (*Catalog) String
CheckLockRequest
type CheckLockRequest struct {
// Required. The name of the lock to check.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}/locks/{lock_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Request message for the CheckLock method.
func (*CheckLockRequest) Descriptor
func (*CheckLockRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckLockRequest.ProtoReflect.Descriptor instead.
func (*CheckLockRequest) GetName
func (x *CheckLockRequest) GetName() string
func (*CheckLockRequest) ProtoMessage
func (*CheckLockRequest) ProtoMessage()
func (*CheckLockRequest) ProtoReflect
func (x *CheckLockRequest) ProtoReflect() protoreflect.Message
func (*CheckLockRequest) Reset
func (x *CheckLockRequest) Reset()
func (*CheckLockRequest) String
func (x *CheckLockRequest) String() string
CreateCatalogRequest
type CreateCatalogRequest struct {
// Required. The parent resource where this catalog will be created.
// Format: projects/{project_id_or_number}/locations/{location_id}
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The catalog to create.
// The `name` field does not need to be provided.
Catalog *Catalog `protobuf:"bytes,2,opt,name=catalog,proto3" json:"catalog,omitempty"`
// Required. The ID to use for the catalog, which will become the final
// component of the catalog's resource name.
CatalogId string `protobuf:"bytes,3,opt,name=catalog_id,json=catalogId,proto3" json:"catalog_id,omitempty"`
// contains filtered or unexported fields
}
Request message for the CreateCatalog method.
func (*CreateCatalogRequest) Descriptor
func (*CreateCatalogRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateCatalogRequest.ProtoReflect.Descriptor instead.
func (*CreateCatalogRequest) GetCatalog
func (x *CreateCatalogRequest) GetCatalog() *Catalog
func (*CreateCatalogRequest) GetCatalogId
func (x *CreateCatalogRequest) GetCatalogId() string
func (*CreateCatalogRequest) GetParent
func (x *CreateCatalogRequest) GetParent() string
func (*CreateCatalogRequest) ProtoMessage
func (*CreateCatalogRequest) ProtoMessage()
func (*CreateCatalogRequest) ProtoReflect
func (x *CreateCatalogRequest) ProtoReflect() protoreflect.Message
func (*CreateCatalogRequest) Reset
func (x *CreateCatalogRequest) Reset()
func (*CreateCatalogRequest) String
func (x *CreateCatalogRequest) String() string
CreateDatabaseRequest
type CreateDatabaseRequest struct {
// Required. The parent resource where this database will be created.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The database to create.
// The `name` field does not need to be provided.
Database *Database `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
// Required. The ID to use for the database, which will become the final
// component of the database's resource name.
DatabaseId string `protobuf:"bytes,3,opt,name=database_id,json=databaseId,proto3" json:"database_id,omitempty"`
// contains filtered or unexported fields
}
Request message for the CreateDatabase method.
func (*CreateDatabaseRequest) Descriptor
func (*CreateDatabaseRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateDatabaseRequest.ProtoReflect.Descriptor instead.
func (*CreateDatabaseRequest) GetDatabase
func (x *CreateDatabaseRequest) GetDatabase() *Database
func (*CreateDatabaseRequest) GetDatabaseId
func (x *CreateDatabaseRequest) GetDatabaseId() string
func (*CreateDatabaseRequest) GetParent
func (x *CreateDatabaseRequest) GetParent() string
func (*CreateDatabaseRequest) ProtoMessage
func (*CreateDatabaseRequest) ProtoMessage()
func (*CreateDatabaseRequest) ProtoReflect
func (x *CreateDatabaseRequest) ProtoReflect() protoreflect.Message
func (*CreateDatabaseRequest) Reset
func (x *CreateDatabaseRequest) Reset()
func (*CreateDatabaseRequest) String
func (x *CreateDatabaseRequest) String() string
CreateLockRequest
type CreateLockRequest struct {
// Required. The parent resource where this lock will be created.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The lock to create. The `name` field does not need to be provided
// for the lock creation.
Lock *Lock `protobuf:"bytes,2,opt,name=lock,proto3" json:"lock,omitempty"`
// contains filtered or unexported fields
}
Request message for the CreateLock method.
func (*CreateLockRequest) Descriptor
func (*CreateLockRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateLockRequest.ProtoReflect.Descriptor instead.
func (*CreateLockRequest) GetLock
func (x *CreateLockRequest) GetLock() *Lock
func (*CreateLockRequest) GetParent
func (x *CreateLockRequest) GetParent() string
func (*CreateLockRequest) ProtoMessage
func (*CreateLockRequest) ProtoMessage()
func (*CreateLockRequest) ProtoReflect
func (x *CreateLockRequest) ProtoReflect() protoreflect.Message
func (*CreateLockRequest) Reset
func (x *CreateLockRequest) Reset()
func (*CreateLockRequest) String
func (x *CreateLockRequest) String() string
CreateTableRequest
type CreateTableRequest struct {
// Required. The parent resource where this table will be created.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The table to create. The `name` field does not need to be
// provided for the table creation.
Table *Table `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
// Required. The ID to use for the table, which will become the final
// component of the table's resource name.
TableId string `protobuf:"bytes,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
// contains filtered or unexported fields
}
Request message for the CreateTable method.
func (*CreateTableRequest) Descriptor
func (*CreateTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateTableRequest.ProtoReflect.Descriptor instead.
func (*CreateTableRequest) GetParent
func (x *CreateTableRequest) GetParent() string
func (*CreateTableRequest) GetTable
func (x *CreateTableRequest) GetTable() *Table
func (*CreateTableRequest) GetTableId
func (x *CreateTableRequest) GetTableId() string
func (*CreateTableRequest) ProtoMessage
func (*CreateTableRequest) ProtoMessage()
func (*CreateTableRequest) ProtoReflect
func (x *CreateTableRequest) ProtoReflect() protoreflect.Message
func (*CreateTableRequest) Reset
func (x *CreateTableRequest) Reset()
func (*CreateTableRequest) String
func (x *CreateTableRequest) String() string
Database
type Database struct {
// Options specified for the database type.
//
// Types that are assignable to Options:
//
// *Database_HiveOptions
Options isDatabase_Options `protobuf_oneof:"options"`
// Output only. The resource name.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Output only. The creation time of the database.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The last modification time of the database.
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// Output only. The deletion time of the database. Only set after the database
// is deleted.
DeleteTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=delete_time,json=deleteTime,proto3" json:"delete_time,omitempty"`
// Output only. The time when this database is considered expired. Only set
// after the database is deleted.
ExpireTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
// The database type.
Type Database_Type `protobuf:"varint,6,opt,name=type,proto3,enum=google.cloud.bigquery.biglake.v1alpha1.Database_Type" json:"type,omitempty"`
// contains filtered or unexported fields
}
Database is the container of tables.
func (*Database) Descriptor
Deprecated: Use Database.ProtoReflect.Descriptor instead.
func (*Database) GetCreateTime
func (x *Database) GetCreateTime() *timestamppb.Timestamp
func (*Database) GetDeleteTime
func (x *Database) GetDeleteTime() *timestamppb.Timestamp
func (*Database) GetExpireTime
func (x *Database) GetExpireTime() *timestamppb.Timestamp
func (*Database) GetHiveOptions
func (x *Database) GetHiveOptions() *HiveDatabaseOptions
func (*Database) GetName
func (*Database) GetOptions
func (m *Database) GetOptions() isDatabase_Options
func (*Database) GetType
func (x *Database) GetType() Database_Type
func (*Database) GetUpdateTime
func (x *Database) GetUpdateTime() *timestamppb.Timestamp
func (*Database) ProtoMessage
func (*Database) ProtoMessage()
func (*Database) ProtoReflect
func (x *Database) ProtoReflect() protoreflect.Message
func (*Database) Reset
func (x *Database) Reset()
func (*Database) String
Database_HiveOptions
type Database_HiveOptions struct {
// Options of a Hive database.
HiveOptions *HiveDatabaseOptions `protobuf:"bytes,7,opt,name=hive_options,json=hiveOptions,proto3,oneof"`
}
Database_Type
type Database_Type int32
The database type.
Database_TYPE_UNSPECIFIED, Database_HIVE
const (
// The type is not specified.
Database_TYPE_UNSPECIFIED Database_Type = 0
// Represents a database storing tables compatible with Hive Metastore
// tables.
Database_HIVE Database_Type = 1
)
func (Database_Type) Descriptor
func (Database_Type) Descriptor() protoreflect.EnumDescriptor
func (Database_Type) Enum
func (x Database_Type) Enum() *Database_Type
func (Database_Type) EnumDescriptor
func (Database_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use Database_Type.Descriptor instead.
func (Database_Type) Number
func (x Database_Type) Number() protoreflect.EnumNumber
func (Database_Type) String
func (x Database_Type) String() string
func (Database_Type) Type
func (Database_Type) Type() protoreflect.EnumType
DeleteCatalogRequest
type DeleteCatalogRequest struct {
// Required. The name of the catalog to delete.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Request message for the DeleteCatalog method.
func (*DeleteCatalogRequest) Descriptor
func (*DeleteCatalogRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteCatalogRequest.ProtoReflect.Descriptor instead.
func (*DeleteCatalogRequest) GetName
func (x *DeleteCatalogRequest) GetName() string
func (*DeleteCatalogRequest) ProtoMessage
func (*DeleteCatalogRequest) ProtoMessage()
func (*DeleteCatalogRequest) ProtoReflect
func (x *DeleteCatalogRequest) ProtoReflect() protoreflect.Message
func (*DeleteCatalogRequest) Reset
func (x *DeleteCatalogRequest) Reset()
func (*DeleteCatalogRequest) String
func (x *DeleteCatalogRequest) String() string
DeleteDatabaseRequest
type DeleteDatabaseRequest struct {
// Required. The name of the database to delete.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Request message for the DeleteDatabase method.
func (*DeleteDatabaseRequest) Descriptor
func (*DeleteDatabaseRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDatabaseRequest.ProtoReflect.Descriptor instead.
func (*DeleteDatabaseRequest) GetName
func (x *DeleteDatabaseRequest) GetName() string
func (*DeleteDatabaseRequest) ProtoMessage
func (*DeleteDatabaseRequest) ProtoMessage()
func (*DeleteDatabaseRequest) ProtoReflect
func (x *DeleteDatabaseRequest) ProtoReflect() protoreflect.Message
func (*DeleteDatabaseRequest) Reset
func (x *DeleteDatabaseRequest) Reset()
func (*DeleteDatabaseRequest) String
func (x *DeleteDatabaseRequest) String() string
DeleteLockRequest
type DeleteLockRequest struct {
// Required. The name of the lock to delete.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}/locks/{lock_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Request message for the DeleteLock method.
func (*DeleteLockRequest) Descriptor
func (*DeleteLockRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteLockRequest.ProtoReflect.Descriptor instead.
func (*DeleteLockRequest) GetName
func (x *DeleteLockRequest) GetName() string
func (*DeleteLockRequest) ProtoMessage
func (*DeleteLockRequest) ProtoMessage()
func (*DeleteLockRequest) ProtoReflect
func (x *DeleteLockRequest) ProtoReflect() protoreflect.Message
func (*DeleteLockRequest) Reset
func (x *DeleteLockRequest) Reset()
func (*DeleteLockRequest) String
func (x *DeleteLockRequest) String() string
DeleteTableRequest
type DeleteTableRequest struct {
// Required. The name of the table to delete.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}/tables/{table_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Request message for the DeleteTable method.
func (*DeleteTableRequest) Descriptor
func (*DeleteTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteTableRequest.ProtoReflect.Descriptor instead.
func (*DeleteTableRequest) GetName
func (x *DeleteTableRequest) GetName() string
func (*DeleteTableRequest) ProtoMessage
func (*DeleteTableRequest) ProtoMessage()
func (*DeleteTableRequest) ProtoReflect
func (x *DeleteTableRequest) ProtoReflect() protoreflect.Message
func (*DeleteTableRequest) Reset
func (x *DeleteTableRequest) Reset()
func (*DeleteTableRequest) String
func (x *DeleteTableRequest) String() string
GetCatalogRequest
type GetCatalogRequest struct {
// Required. The name of the catalog to retrieve.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Request message for the GetCatalog method.
func (*GetCatalogRequest) Descriptor
func (*GetCatalogRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetCatalogRequest.ProtoReflect.Descriptor instead.
func (*GetCatalogRequest) GetName
func (x *GetCatalogRequest) GetName() string
func (*GetCatalogRequest) ProtoMessage
func (*GetCatalogRequest) ProtoMessage()
func (*GetCatalogRequest) ProtoReflect
func (x *GetCatalogRequest) ProtoReflect() protoreflect.Message
func (*GetCatalogRequest) Reset
func (x *GetCatalogRequest) Reset()
func (*GetCatalogRequest) String
func (x *GetCatalogRequest) String() string
GetDatabaseRequest
type GetDatabaseRequest struct {
// Required. The name of the database to retrieve.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Request message for the GetDatabase method.
func (*GetDatabaseRequest) Descriptor
func (*GetDatabaseRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDatabaseRequest.ProtoReflect.Descriptor instead.
func (*GetDatabaseRequest) GetName
func (x *GetDatabaseRequest) GetName() string
func (*GetDatabaseRequest) ProtoMessage
func (*GetDatabaseRequest) ProtoMessage()
func (*GetDatabaseRequest) ProtoReflect
func (x *GetDatabaseRequest) ProtoReflect() protoreflect.Message
func (*GetDatabaseRequest) Reset
func (x *GetDatabaseRequest) Reset()
func (*GetDatabaseRequest) String
func (x *GetDatabaseRequest) String() string
GetTableRequest
type GetTableRequest struct {
// Required. The name of the table to retrieve.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}/tables/{table_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Request message for the GetTable method.
func (*GetTableRequest) Descriptor
func (*GetTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTableRequest.ProtoReflect.Descriptor instead.
func (*GetTableRequest) GetName
func (x *GetTableRequest) GetName() string
func (*GetTableRequest) ProtoMessage
func (*GetTableRequest) ProtoMessage()
func (*GetTableRequest) ProtoReflect
func (x *GetTableRequest) ProtoReflect() protoreflect.Message
func (*GetTableRequest) Reset
func (x *GetTableRequest) Reset()
func (*GetTableRequest) String
func (x *GetTableRequest) String() string
HiveDatabaseOptions
type HiveDatabaseOptions struct {
LocationUri string `protobuf:"bytes,1,opt,name=location_uri,json=locationUri,proto3" json:"location_uri,omitempty"`
Parameters map[string]string "" /* 161 byte string literal not displayed */
}
Options of a Hive database.
func (*HiveDatabaseOptions) Descriptor
func (*HiveDatabaseOptions) Descriptor() ([]byte, []int)
Deprecated: Use HiveDatabaseOptions.ProtoReflect.Descriptor instead.
func (*HiveDatabaseOptions) GetLocationUri
func (x *HiveDatabaseOptions) GetLocationUri() string
func (*HiveDatabaseOptions) GetParameters
func (x *HiveDatabaseOptions) GetParameters() map[string]string
func (*HiveDatabaseOptions) ProtoMessage
func (*HiveDatabaseOptions) ProtoMessage()
func (*HiveDatabaseOptions) ProtoReflect
func (x *HiveDatabaseOptions) ProtoReflect() protoreflect.Message
func (*HiveDatabaseOptions) Reset
func (x *HiveDatabaseOptions) Reset()
func (*HiveDatabaseOptions) String
func (x *HiveDatabaseOptions) String() string
HiveTableOptions
type HiveTableOptions struct {
Parameters map[string]string "" /* 161 byte string literal not displayed */
TableType string `protobuf:"bytes,2,opt,name=table_type,json=tableType,proto3" json:"table_type,omitempty"`
StorageDescriptor *HiveTableOptions_StorageDescriptor `protobuf:"bytes,3,opt,name=storage_descriptor,json=storageDescriptor,proto3" json:"storage_descriptor,omitempty"`
}
Options of a Hive table.
func (*HiveTableOptions) Descriptor
func (*HiveTableOptions) Descriptor() ([]byte, []int)
Deprecated: Use HiveTableOptions.ProtoReflect.Descriptor instead.
func (*HiveTableOptions) GetParameters
func (x *HiveTableOptions) GetParameters() map[string]string
func (*HiveTableOptions) GetStorageDescriptor
func (x *HiveTableOptions) GetStorageDescriptor() *HiveTableOptions_StorageDescriptor
func (*HiveTableOptions) GetTableType
func (x *HiveTableOptions) GetTableType() string
func (*HiveTableOptions) ProtoMessage
func (*HiveTableOptions) ProtoMessage()
func (*HiveTableOptions) ProtoReflect
func (x *HiveTableOptions) ProtoReflect() protoreflect.Message
func (*HiveTableOptions) Reset
func (x *HiveTableOptions) Reset()
func (*HiveTableOptions) String
func (x *HiveTableOptions) String() string
HiveTableOptions_SerDeInfo
type HiveTableOptions_SerDeInfo struct {
// The fully qualified Java class name of the serialization library.
SerializationLib string `protobuf:"bytes,1,opt,name=serialization_lib,json=serializationLib,proto3" json:"serialization_lib,omitempty"`
// contains filtered or unexported fields
}
Serializer and deserializer information.
func (*HiveTableOptions_SerDeInfo) Descriptor
func (*HiveTableOptions_SerDeInfo) Descriptor() ([]byte, []int)
Deprecated: Use HiveTableOptions_SerDeInfo.ProtoReflect.Descriptor instead.
func (*HiveTableOptions_SerDeInfo) GetSerializationLib
func (x *HiveTableOptions_SerDeInfo) GetSerializationLib() string
func (*HiveTableOptions_SerDeInfo) ProtoMessage
func (*HiveTableOptions_SerDeInfo) ProtoMessage()
func (*HiveTableOptions_SerDeInfo) ProtoReflect
func (x *HiveTableOptions_SerDeInfo) ProtoReflect() protoreflect.Message
func (*HiveTableOptions_SerDeInfo) Reset
func (x *HiveTableOptions_SerDeInfo) Reset()
func (*HiveTableOptions_SerDeInfo) String
func (x *HiveTableOptions_SerDeInfo) String() string
HiveTableOptions_StorageDescriptor
type HiveTableOptions_StorageDescriptor struct {
// Cloud Storage folder URI where the table data is stored, starting with
// "gs://".
LocationUri string `protobuf:"bytes,1,opt,name=location_uri,json=locationUri,proto3" json:"location_uri,omitempty"`
// The fully qualified Java class name of the input format.
InputFormat string `protobuf:"bytes,2,opt,name=input_format,json=inputFormat,proto3" json:"input_format,omitempty"`
// The fully qualified Java class name of the output format.
OutputFormat string `protobuf:"bytes,3,opt,name=output_format,json=outputFormat,proto3" json:"output_format,omitempty"`
// Serializer and deserializer information.
SerdeInfo *HiveTableOptions_SerDeInfo `protobuf:"bytes,4,opt,name=serde_info,json=serdeInfo,proto3" json:"serde_info,omitempty"`
// contains filtered or unexported fields
}
Stores physical storage information of the data.
func (*HiveTableOptions_StorageDescriptor) Descriptor
func (*HiveTableOptions_StorageDescriptor) Descriptor() ([]byte, []int)
Deprecated: Use HiveTableOptions_StorageDescriptor.ProtoReflect.Descriptor instead.
func (*HiveTableOptions_StorageDescriptor) GetInputFormat
func (x *HiveTableOptions_StorageDescriptor) GetInputFormat() string
func (*HiveTableOptions_StorageDescriptor) GetLocationUri
func (x *HiveTableOptions_StorageDescriptor) GetLocationUri() string
func (*HiveTableOptions_StorageDescriptor) GetOutputFormat
func (x *HiveTableOptions_StorageDescriptor) GetOutputFormat() string
func (*HiveTableOptions_StorageDescriptor) GetSerdeInfo
func (x *HiveTableOptions_StorageDescriptor) GetSerdeInfo() *HiveTableOptions_SerDeInfo
func (*HiveTableOptions_StorageDescriptor) ProtoMessage
func (*HiveTableOptions_StorageDescriptor) ProtoMessage()
func (*HiveTableOptions_StorageDescriptor) ProtoReflect
func (x *HiveTableOptions_StorageDescriptor) ProtoReflect() protoreflect.Message
func (*HiveTableOptions_StorageDescriptor) Reset
func (x *HiveTableOptions_StorageDescriptor) Reset()
func (*HiveTableOptions_StorageDescriptor) String
func (x *HiveTableOptions_StorageDescriptor) String() string
ListCatalogsRequest
type ListCatalogsRequest struct {
// Required. The parent, which owns this collection of catalogs.
// Format: projects/{project_id_or_number}/locations/{location_id}
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of catalogs to return. The service may return fewer than
// this value.
// If unspecified, at most 50 catalogs will be returned.
// The maximum value is 1000; values above 1000 will be coerced to 1000.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// A page token, received from a previous `ListCatalogs` call.
// Provide this to retrieve the subsequent page.
//
// When paginating, all other parameters provided to `ListCatalogs` must match
// the call that provided the page token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}
Request message for the ListCatalogs method.
func (*ListCatalogsRequest) Descriptor
func (*ListCatalogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListCatalogsRequest.ProtoReflect.Descriptor instead.
func (*ListCatalogsRequest) GetPageSize
func (x *ListCatalogsRequest) GetPageSize() int32
func (*ListCatalogsRequest) GetPageToken
func (x *ListCatalogsRequest) GetPageToken() string
func (*ListCatalogsRequest) GetParent
func (x *ListCatalogsRequest) GetParent() string
func (*ListCatalogsRequest) ProtoMessage
func (*ListCatalogsRequest) ProtoMessage()
func (*ListCatalogsRequest) ProtoReflect
func (x *ListCatalogsRequest) ProtoReflect() protoreflect.Message
func (*ListCatalogsRequest) Reset
func (x *ListCatalogsRequest) Reset()
func (*ListCatalogsRequest) String
func (x *ListCatalogsRequest) String() string
ListCatalogsResponse
type ListCatalogsResponse struct {
// The catalogs from the specified project.
Catalogs []*Catalog `protobuf:"bytes,1,rep,name=catalogs,proto3" json:"catalogs,omitempty"`
// A token, which 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"`
// contains filtered or unexported fields
}
Response message for the ListCatalogs method.
func (*ListCatalogsResponse) Descriptor
func (*ListCatalogsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListCatalogsResponse.ProtoReflect.Descriptor instead.
func (*ListCatalogsResponse) GetCatalogs
func (x *ListCatalogsResponse) GetCatalogs() []*Catalog
func (*ListCatalogsResponse) GetNextPageToken
func (x *ListCatalogsResponse) GetNextPageToken() string
func (*ListCatalogsResponse) ProtoMessage
func (*ListCatalogsResponse) ProtoMessage()
func (*ListCatalogsResponse) ProtoReflect
func (x *ListCatalogsResponse) ProtoReflect() protoreflect.Message
func (*ListCatalogsResponse) Reset
func (x *ListCatalogsResponse) Reset()
func (*ListCatalogsResponse) String
func (x *ListCatalogsResponse) String() string
ListDatabasesRequest
type ListDatabasesRequest struct {
// Required. The parent, which owns this collection of databases.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of databases to return. The service may return fewer
// than this value.
// If unspecified, at most 50 databases will be returned.
// The maximum value is 1000; values above 1000 will be coerced to 1000.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// A page token, received from a previous `ListDatabases` call.
// Provide this to retrieve the subsequent page.
//
// When paginating, all other parameters provided to `ListDatabases` must
// match the call that provided the page token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}
Request message for the ListDatabases method.
func (*ListDatabasesRequest) Descriptor
func (*ListDatabasesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListDatabasesRequest.ProtoReflect.Descriptor instead.
func (*ListDatabasesRequest) GetPageSize
func (x *ListDatabasesRequest) GetPageSize() int32
func (*ListDatabasesRequest) GetPageToken
func (x *ListDatabasesRequest) GetPageToken() string
func (*ListDatabasesRequest) GetParent
func (x *ListDatabasesRequest) GetParent() string
func (*ListDatabasesRequest) ProtoMessage
func (*ListDatabasesRequest) ProtoMessage()
func (*ListDatabasesRequest) ProtoReflect
func (x *ListDatabasesRequest) ProtoReflect() protoreflect.Message
func (*ListDatabasesRequest) Reset
func (x *ListDatabasesRequest) Reset()
func (*ListDatabasesRequest) String
func (x *ListDatabasesRequest) String() string
ListDatabasesResponse
type ListDatabasesResponse struct {
// The databases from the specified catalog.
Databases []*Database `protobuf:"bytes,1,rep,name=databases,proto3" json:"databases,omitempty"`
// A token, which 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"`
// contains filtered or unexported fields
}
Response message for the ListDatabases method.
func (*ListDatabasesResponse) Descriptor
func (*ListDatabasesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListDatabasesResponse.ProtoReflect.Descriptor instead.
func (*ListDatabasesResponse) GetDatabases
func (x *ListDatabasesResponse) GetDatabases() []*Database
func (*ListDatabasesResponse) GetNextPageToken
func (x *ListDatabasesResponse) GetNextPageToken() string
func (*ListDatabasesResponse) ProtoMessage
func (*ListDatabasesResponse) ProtoMessage()
func (*ListDatabasesResponse) ProtoReflect
func (x *ListDatabasesResponse) ProtoReflect() protoreflect.Message
func (*ListDatabasesResponse) Reset
func (x *ListDatabasesResponse) Reset()
func (*ListDatabasesResponse) String
func (x *ListDatabasesResponse) String() string
ListLocksRequest
type ListLocksRequest struct {
// Required. The parent, which owns this collection of locks.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of locks to return. The service may return fewer than
// this value.
// If unspecified, at most 50 locks will be returned.
// The maximum value is 1000; values above 1000 will be coerced to 1000.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// A page token, received from a previous `ListLocks` call.
// Provide this to retrieve the subsequent page.
//
// When paginating, all other parameters provided to `ListLocks` must match
// the call that provided the page token.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}
Request message for the ListLocks method.
func (*ListLocksRequest) Descriptor
func (*ListLocksRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListLocksRequest.ProtoReflect.Descriptor instead.
func (*ListLocksRequest) GetPageSize
func (x *ListLocksRequest) GetPageSize() int32
func (*ListLocksRequest) GetPageToken
func (x *ListLocksRequest) GetPageToken() string
func (*ListLocksRequest) GetParent
func (x *ListLocksRequest) GetParent() string
func (*ListLocksRequest) ProtoMessage
func (*ListLocksRequest) ProtoMessage()
func (*ListLocksRequest) ProtoReflect
func (x *ListLocksRequest) ProtoReflect() protoreflect.Message
func (*ListLocksRequest) Reset
func (x *ListLocksRequest) Reset()
func (*ListLocksRequest) String
func (x *ListLocksRequest) String() string
ListLocksResponse
type ListLocksResponse struct {
// The locks from the specified database.
Locks []*Lock `protobuf:"bytes,1,rep,name=locks,proto3" json:"locks,omitempty"`
// A token, which 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"`
// contains filtered or unexported fields
}
Response message for the ListLocks method.
func (*ListLocksResponse) Descriptor
func (*ListLocksResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListLocksResponse.ProtoReflect.Descriptor instead.
func (*ListLocksResponse) GetLocks
func (x *ListLocksResponse) GetLocks() []*Lock
func (*ListLocksResponse) GetNextPageToken
func (x *ListLocksResponse) GetNextPageToken() string
func (*ListLocksResponse) ProtoMessage
func (*ListLocksResponse) ProtoMessage()
func (*ListLocksResponse) ProtoReflect
func (x *ListLocksResponse) ProtoReflect() protoreflect.Message
func (*ListLocksResponse) Reset
func (x *ListLocksResponse) Reset()
func (*ListLocksResponse) String
func (x *ListLocksResponse) String() string
ListTablesRequest
type ListTablesRequest struct {
// Required. The parent, which owns this collection of tables.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of tables to return. The service may return fewer than
// this value.
// If unspecified, at most 50 tables will be returned.
// The maximum value is 1000; values above 1000 will be coerced to 1000.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// A page token, received from a previous `ListTables` call.
// Provide this to retrieve the subsequent page.
//
// When paginating, all other parameters provided to `ListTables` 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"`
// The view for the returned tables.
View TableView `protobuf:"varint,4,opt,name=view,proto3,enum=google.cloud.bigquery.biglake.v1alpha1.TableView" json:"view,omitempty"`
// contains filtered or unexported fields
}
Request message for the ListTables method.
func (*ListTablesRequest) Descriptor
func (*ListTablesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListTablesRequest.ProtoReflect.Descriptor instead.
func (*ListTablesRequest) GetPageSize
func (x *ListTablesRequest) GetPageSize() int32
func (*ListTablesRequest) GetPageToken
func (x *ListTablesRequest) GetPageToken() string
func (*ListTablesRequest) GetParent
func (x *ListTablesRequest) GetParent() string
func (*ListTablesRequest) GetView
func (x *ListTablesRequest) GetView() TableView
func (*ListTablesRequest) ProtoMessage
func (*ListTablesRequest) ProtoMessage()
func (*ListTablesRequest) ProtoReflect
func (x *ListTablesRequest) ProtoReflect() protoreflect.Message
func (*ListTablesRequest) Reset
func (x *ListTablesRequest) Reset()
func (*ListTablesRequest) String
func (x *ListTablesRequest) String() string
ListTablesResponse
type ListTablesResponse struct {
// The tables from the specified database.
Tables []*Table `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
// A token, which 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"`
// contains filtered or unexported fields
}
Response message for the ListTables method.
func (*ListTablesResponse) Descriptor
func (*ListTablesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListTablesResponse.ProtoReflect.Descriptor instead.
func (*ListTablesResponse) GetNextPageToken
func (x *ListTablesResponse) GetNextPageToken() string
func (*ListTablesResponse) GetTables
func (x *ListTablesResponse) GetTables() []*Table
func (*ListTablesResponse) ProtoMessage
func (*ListTablesResponse) ProtoMessage()
func (*ListTablesResponse) ProtoReflect
func (x *ListTablesResponse) ProtoReflect() protoreflect.Message
func (*ListTablesResponse) Reset
func (x *ListTablesResponse) Reset()
func (*ListTablesResponse) String
func (x *ListTablesResponse) String() string
Lock
type Lock struct {
// The resource that the lock will be created on.
//
// Types that are assignable to Resources:
//
// *Lock_TableId
Resources isLock_Resources `protobuf_oneof:"resources"`
// Output only. The resource name.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}/locks/{lock_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Output only. The creation time of the lock.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// The lock type.
Type Lock_Type `protobuf:"varint,3,opt,name=type,proto3,enum=google.cloud.bigquery.biglake.v1alpha1.Lock_Type" json:"type,omitempty"`
// Output only. The lock state.
State Lock_State `protobuf:"varint,4,opt,name=state,proto3,enum=google.cloud.bigquery.biglake.v1alpha1.Lock_State" json:"state,omitempty"`
// contains filtered or unexported fields
}
Represents a lock.
func (*Lock) Descriptor
Deprecated: Use Lock.ProtoReflect.Descriptor instead.
func (*Lock) GetCreateTime
func (x *Lock) GetCreateTime() *timestamppb.Timestamp
func (*Lock) GetName
func (*Lock) GetResources
func (m *Lock) GetResources() isLock_Resources
func (*Lock) GetState
func (x *Lock) GetState() Lock_State
func (*Lock) GetTableId
func (*Lock) GetType
func (*Lock) ProtoMessage
func (*Lock) ProtoMessage()
func (*Lock) ProtoReflect
func (x *Lock) ProtoReflect() protoreflect.Message
func (*Lock) Reset
func (x *Lock) Reset()
func (*Lock) String
Lock_State
type Lock_State int32
The lock state.
Lock_STATE_UNSPECIFIED, Lock_WAITING, Lock_ACQUIRED
const (
// The state is not specified.
Lock_STATE_UNSPECIFIED Lock_State = 0
// Waiting to acquire the lock.
Lock_WAITING Lock_State = 1
// The lock has been acquired.
Lock_ACQUIRED Lock_State = 2
)
func (Lock_State) Descriptor
func (Lock_State) Descriptor() protoreflect.EnumDescriptor
func (Lock_State) Enum
func (x Lock_State) Enum() *Lock_State
func (Lock_State) EnumDescriptor
func (Lock_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use Lock_State.Descriptor instead.
func (Lock_State) Number
func (x Lock_State) Number() protoreflect.EnumNumber
func (Lock_State) String
func (x Lock_State) String() string
func (Lock_State) Type
func (Lock_State) Type() protoreflect.EnumType
Lock_TableId
type Lock_TableId struct {
// The table ID (not fully qualified name) in the same database that the
// lock will be created on. The table must exist.
TableId string `protobuf:"bytes,5,opt,name=table_id,json=tableId,proto3,oneof"`
}
Lock_Type
type Lock_Type int32
The lock type.
Lock_TYPE_UNSPECIFIED, Lock_EXCLUSIVE
const (
// The type is not specified.
Lock_TYPE_UNSPECIFIED Lock_Type = 0
// An exclusive lock prevents another lock from being created on the same
// resource.
Lock_EXCLUSIVE Lock_Type = 1
)
func (Lock_Type) Descriptor
func (Lock_Type) Descriptor() protoreflect.EnumDescriptor
func (Lock_Type) Enum
func (Lock_Type) EnumDescriptor
Deprecated: Use Lock_Type.Descriptor instead.
func (Lock_Type) Number
func (x Lock_Type) Number() protoreflect.EnumNumber
func (Lock_Type) String
func (Lock_Type) Type
func (Lock_Type) Type() protoreflect.EnumType
MetastoreServiceClient
type MetastoreServiceClient interface {
// Creates a new catalog.
CreateCatalog(ctx context.Context, in *CreateCatalogRequest, opts ...grpc.CallOption) (*Catalog, error)
// Deletes an existing catalog specified by the catalog ID.
DeleteCatalog(ctx context.Context, in *DeleteCatalogRequest, opts ...grpc.CallOption) (*Catalog, error)
// Gets the catalog specified by the resource name.
GetCatalog(ctx context.Context, in *GetCatalogRequest, opts ...grpc.CallOption) (*Catalog, error)
// List all catalogs in a specified project.
ListCatalogs(ctx context.Context, in *ListCatalogsRequest, opts ...grpc.CallOption) (*ListCatalogsResponse, error)
// Creates a new database.
CreateDatabase(ctx context.Context, in *CreateDatabaseRequest, opts ...grpc.CallOption) (*Database, error)
// Deletes an existing database specified by the database ID.
DeleteDatabase(ctx context.Context, in *DeleteDatabaseRequest, opts ...grpc.CallOption) (*Database, error)
// Updates an existing database specified by the database ID.
UpdateDatabase(ctx context.Context, in *UpdateDatabaseRequest, opts ...grpc.CallOption) (*Database, error)
// Gets the database specified by the resource name.
GetDatabase(ctx context.Context, in *GetDatabaseRequest, opts ...grpc.CallOption) (*Database, error)
// List all databases in a specified catalog.
ListDatabases(ctx context.Context, in *ListDatabasesRequest, opts ...grpc.CallOption) (*ListDatabasesResponse, error)
// Creates a new table.
CreateTable(ctx context.Context, in *CreateTableRequest, opts ...grpc.CallOption) (*Table, error)
// Deletes an existing table specified by the table ID.
DeleteTable(ctx context.Context, in *DeleteTableRequest, opts ...grpc.CallOption) (*Table, error)
// Updates an existing table specified by the table ID.
UpdateTable(ctx context.Context, in *UpdateTableRequest, opts ...grpc.CallOption) (*Table, error)
// Renames an existing table specified by the table ID.
RenameTable(ctx context.Context, in *RenameTableRequest, opts ...grpc.CallOption) (*Table, error)
// Gets the table specified by the resource name.
GetTable(ctx context.Context, in *GetTableRequest, opts ...grpc.CallOption) (*Table, error)
// List all tables in a specified database.
ListTables(ctx context.Context, in *ListTablesRequest, opts ...grpc.CallOption) (*ListTablesResponse, error)
// Creates a new lock.
CreateLock(ctx context.Context, in *CreateLockRequest, opts ...grpc.CallOption) (*Lock, error)
// Deletes an existing lock specified by the lock ID.
DeleteLock(ctx context.Context, in *DeleteLockRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Checks the state of a lock specified by the lock ID.
CheckLock(ctx context.Context, in *CheckLockRequest, opts ...grpc.CallOption) (*Lock, error)
// List all locks in a specified database.
ListLocks(ctx context.Context, in *ListLocksRequest, opts ...grpc.CallOption) (*ListLocksResponse, error)
}
MetastoreServiceClient is the client API for MetastoreService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMetastoreServiceClient
func NewMetastoreServiceClient(cc grpc.ClientConnInterface) MetastoreServiceClient
MetastoreServiceServer
type MetastoreServiceServer interface {
// Creates a new catalog.
CreateCatalog(context.Context, *CreateCatalogRequest) (*Catalog, error)
// Deletes an existing catalog specified by the catalog ID.
DeleteCatalog(context.Context, *DeleteCatalogRequest) (*Catalog, error)
// Gets the catalog specified by the resource name.
GetCatalog(context.Context, *GetCatalogRequest) (*Catalog, error)
// List all catalogs in a specified project.
ListCatalogs(context.Context, *ListCatalogsRequest) (*ListCatalogsResponse, error)
// Creates a new database.
CreateDatabase(context.Context, *CreateDatabaseRequest) (*Database, error)
// Deletes an existing database specified by the database ID.
DeleteDatabase(context.Context, *DeleteDatabaseRequest) (*Database, error)
// Updates an existing database specified by the database ID.
UpdateDatabase(context.Context, *UpdateDatabaseRequest) (*Database, error)
// Gets the database specified by the resource name.
GetDatabase(context.Context, *GetDatabaseRequest) (*Database, error)
// List all databases in a specified catalog.
ListDatabases(context.Context, *ListDatabasesRequest) (*ListDatabasesResponse, error)
// Creates a new table.
CreateTable(context.Context, *CreateTableRequest) (*Table, error)
// Deletes an existing table specified by the table ID.
DeleteTable(context.Context, *DeleteTableRequest) (*Table, error)
// Updates an existing table specified by the table ID.
UpdateTable(context.Context, *UpdateTableRequest) (*Table, error)
// Renames an existing table specified by the table ID.
RenameTable(context.Context, *RenameTableRequest) (*Table, error)
// Gets the table specified by the resource name.
GetTable(context.Context, *GetTableRequest) (*Table, error)
// List all tables in a specified database.
ListTables(context.Context, *ListTablesRequest) (*ListTablesResponse, error)
// Creates a new lock.
CreateLock(context.Context, *CreateLockRequest) (*Lock, error)
// Deletes an existing lock specified by the lock ID.
DeleteLock(context.Context, *DeleteLockRequest) (*emptypb.Empty, error)
// Checks the state of a lock specified by the lock ID.
CheckLock(context.Context, *CheckLockRequest) (*Lock, error)
// List all locks in a specified database.
ListLocks(context.Context, *ListLocksRequest) (*ListLocksResponse, error)
}
MetastoreServiceServer is the server API for MetastoreService service.
RenameTableRequest
type RenameTableRequest struct {
// Required. The table's `name` field is used to identify the table to rename.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}/tables/{table_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Required. The new `name` for the specified table, must be in the same
// database. Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}/tables/{table_id}
NewName string `protobuf:"bytes,2,opt,name=new_name,json=newName,proto3" json:"new_name,omitempty"`
// contains filtered or unexported fields
}
Request message for the RenameTable method in MetastoreService
func (*RenameTableRequest) Descriptor
func (*RenameTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use RenameTableRequest.ProtoReflect.Descriptor instead.
func (*RenameTableRequest) GetName
func (x *RenameTableRequest) GetName() string
func (*RenameTableRequest) GetNewName
func (x *RenameTableRequest) GetNewName() string
func (*RenameTableRequest) ProtoMessage
func (*RenameTableRequest) ProtoMessage()
func (*RenameTableRequest) ProtoReflect
func (x *RenameTableRequest) ProtoReflect() protoreflect.Message
func (*RenameTableRequest) Reset
func (x *RenameTableRequest) Reset()
func (*RenameTableRequest) String
func (x *RenameTableRequest) String() string
Table
type Table struct {
// Options specified for the table type.
//
// Types that are assignable to Options:
//
// *Table_HiveOptions
Options isTable_Options `protobuf_oneof:"options"`
// Output only. The resource name.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}/tables/{table_id}
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Output only. The creation time of the table.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The last modification time of the table.
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// Output only. The deletion time of the table. Only set after the table is
// deleted.
DeleteTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=delete_time,json=deleteTime,proto3" json:"delete_time,omitempty"`
// Output only. The time when this table is considered expired. Only set after
// the table is deleted.
ExpireTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
// The table type.
Type Table_Type `protobuf:"varint,6,opt,name=type,proto3,enum=google.cloud.bigquery.biglake.v1alpha1.Table_Type" json:"type,omitempty"`
// The checksum of a table object computed by the server based on the value of
// other fields. It may be sent on update requests to ensure the client has an
// up-to-date value before proceeding. It is only checked for update table
// operations.
Etag string `protobuf:"bytes,8,opt,name=etag,proto3" json:"etag,omitempty"`
// contains filtered or unexported fields
}
Represents a table.
func (*Table) Descriptor
Deprecated: Use Table.ProtoReflect.Descriptor instead.
func (*Table) GetCreateTime
func (x *Table) GetCreateTime() *timestamppb.Timestamp
func (*Table) GetDeleteTime
func (x *Table) GetDeleteTime() *timestamppb.Timestamp
func (*Table) GetEtag
func (*Table) GetExpireTime
func (x *Table) GetExpireTime() *timestamppb.Timestamp
func (*Table) GetHiveOptions
func (x *Table) GetHiveOptions() *HiveTableOptions
func (*Table) GetName
func (*Table) GetOptions
func (m *Table) GetOptions() isTable_Options
func (*Table) GetType
func (x *Table) GetType() Table_Type
func (*Table) GetUpdateTime
func (x *Table) GetUpdateTime() *timestamppb.Timestamp
func (*Table) ProtoMessage
func (*Table) ProtoMessage()
func (*Table) ProtoReflect
func (x *Table) ProtoReflect() protoreflect.Message
func (*Table) Reset
func (x *Table) Reset()
func (*Table) String
TableView
type TableView int32
View on Table. Represents which fields will be populated for calls that return Table objects.
TableView_TABLE_VIEW_UNSPECIFIED, TableView_BASIC, TableView_FULL
const (
// Default value. The API will default to the BASIC view.
TableView_TABLE_VIEW_UNSPECIFIED TableView = 0
// Include only table names.
// This is the default value.
TableView_BASIC TableView = 1
// Include everything.
TableView_FULL TableView = 2
)
func (TableView) Descriptor
func (TableView) Descriptor() protoreflect.EnumDescriptor
func (TableView) Enum
func (TableView) EnumDescriptor
Deprecated: Use TableView.Descriptor instead.
func (TableView) Number
func (x TableView) Number() protoreflect.EnumNumber
func (TableView) String
func (TableView) Type
func (TableView) Type() protoreflect.EnumType
Table_HiveOptions
type Table_HiveOptions struct {
// Options of a Hive table.
HiveOptions *HiveTableOptions `protobuf:"bytes,7,opt,name=hive_options,json=hiveOptions,proto3,oneof"`
}
Table_Type
type Table_Type int32
The table type.
Table_TYPE_UNSPECIFIED, Table_HIVE
const (
// The type is not specified.
Table_TYPE_UNSPECIFIED Table_Type = 0
// Represents a table compatible with Hive Metastore tables.
Table_HIVE Table_Type = 1
)
func (Table_Type) Descriptor
func (Table_Type) Descriptor() protoreflect.EnumDescriptor
func (Table_Type) Enum
func (x Table_Type) Enum() *Table_Type
func (Table_Type) EnumDescriptor
func (Table_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use Table_Type.Descriptor instead.
func (Table_Type) Number
func (x Table_Type) Number() protoreflect.EnumNumber
func (Table_Type) String
func (x Table_Type) String() string
func (Table_Type) Type
func (Table_Type) Type() protoreflect.EnumType
UnimplementedMetastoreServiceServer
type UnimplementedMetastoreServiceServer struct {
}
UnimplementedMetastoreServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedMetastoreServiceServer) CheckLock
func (*UnimplementedMetastoreServiceServer) CheckLock(context.Context, *CheckLockRequest) (*Lock, error)
func (*UnimplementedMetastoreServiceServer) CreateCatalog
func (*UnimplementedMetastoreServiceServer) CreateCatalog(context.Context, *CreateCatalogRequest) (*Catalog, error)
func (*UnimplementedMetastoreServiceServer) CreateDatabase
func (*UnimplementedMetastoreServiceServer) CreateDatabase(context.Context, *CreateDatabaseRequest) (*Database, error)
func (*UnimplementedMetastoreServiceServer) CreateLock
func (*UnimplementedMetastoreServiceServer) CreateLock(context.Context, *CreateLockRequest) (*Lock, error)
func (*UnimplementedMetastoreServiceServer) CreateTable
func (*UnimplementedMetastoreServiceServer) CreateTable(context.Context, *CreateTableRequest) (*Table, error)
func (*UnimplementedMetastoreServiceServer) DeleteCatalog
func (*UnimplementedMetastoreServiceServer) DeleteCatalog(context.Context, *DeleteCatalogRequest) (*Catalog, error)
func (*UnimplementedMetastoreServiceServer) DeleteDatabase
func (*UnimplementedMetastoreServiceServer) DeleteDatabase(context.Context, *DeleteDatabaseRequest) (*Database, error)
func (*UnimplementedMetastoreServiceServer) DeleteLock
func (*UnimplementedMetastoreServiceServer) DeleteLock(context.Context, *DeleteLockRequest) (*emptypb.Empty, error)
func (*UnimplementedMetastoreServiceServer) DeleteTable
func (*UnimplementedMetastoreServiceServer) DeleteTable(context.Context, *DeleteTableRequest) (*Table, error)
func (*UnimplementedMetastoreServiceServer) GetCatalog
func (*UnimplementedMetastoreServiceServer) GetCatalog(context.Context, *GetCatalogRequest) (*Catalog, error)
func (*UnimplementedMetastoreServiceServer) GetDatabase
func (*UnimplementedMetastoreServiceServer) GetDatabase(context.Context, *GetDatabaseRequest) (*Database, error)
func (*UnimplementedMetastoreServiceServer) GetTable
func (*UnimplementedMetastoreServiceServer) GetTable(context.Context, *GetTableRequest) (*Table, error)
func (*UnimplementedMetastoreServiceServer) ListCatalogs
func (*UnimplementedMetastoreServiceServer) ListCatalogs(context.Context, *ListCatalogsRequest) (*ListCatalogsResponse, error)
func (*UnimplementedMetastoreServiceServer) ListDatabases
func (*UnimplementedMetastoreServiceServer) ListDatabases(context.Context, *ListDatabasesRequest) (*ListDatabasesResponse, error)
func (*UnimplementedMetastoreServiceServer) ListLocks
func (*UnimplementedMetastoreServiceServer) ListLocks(context.Context, *ListLocksRequest) (*ListLocksResponse, error)
func (*UnimplementedMetastoreServiceServer) ListTables
func (*UnimplementedMetastoreServiceServer) ListTables(context.Context, *ListTablesRequest) (*ListTablesResponse, error)
func (*UnimplementedMetastoreServiceServer) RenameTable
func (*UnimplementedMetastoreServiceServer) RenameTable(context.Context, *RenameTableRequest) (*Table, error)
func (*UnimplementedMetastoreServiceServer) UpdateDatabase
func (*UnimplementedMetastoreServiceServer) UpdateDatabase(context.Context, *UpdateDatabaseRequest) (*Database, error)
func (*UnimplementedMetastoreServiceServer) UpdateTable
func (*UnimplementedMetastoreServiceServer) UpdateTable(context.Context, *UpdateTableRequest) (*Table, error)
UpdateDatabaseRequest
type UpdateDatabaseRequest struct {
// Required. The database to update.
//
// The database's `name` field is used to identify the database to update.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}
Database *Database `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
// The list of fields to update.
//
// For the `FieldMask` definition, see
// https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#fieldmask
// If not set, defaults to all of the fields that are allowed to update.
UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// contains filtered or unexported fields
}
Request message for the UpdateDatabase method.
func (*UpdateDatabaseRequest) Descriptor
func (*UpdateDatabaseRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDatabaseRequest.ProtoReflect.Descriptor instead.
func (*UpdateDatabaseRequest) GetDatabase
func (x *UpdateDatabaseRequest) GetDatabase() *Database
func (*UpdateDatabaseRequest) GetUpdateMask
func (x *UpdateDatabaseRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateDatabaseRequest) ProtoMessage
func (*UpdateDatabaseRequest) ProtoMessage()
func (*UpdateDatabaseRequest) ProtoReflect
func (x *UpdateDatabaseRequest) ProtoReflect() protoreflect.Message
func (*UpdateDatabaseRequest) Reset
func (x *UpdateDatabaseRequest) Reset()
func (*UpdateDatabaseRequest) String
func (x *UpdateDatabaseRequest) String() string
UpdateTableRequest
type UpdateTableRequest struct {
// Required. The table to update.
//
// The table's `name` field is used to identify the table to update.
// Format:
// projects/{project_id_or_number}/locations/{location_id}/catalogs/{catalog_id}/databases/{database_id}/tables/{table_id}
Table *Table `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
// The list of fields to update.
//
// For the `FieldMask` definition, see
// https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#fieldmask
// If not set, defaults to all of the fields that are allowed to update.
UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// contains filtered or unexported fields
}
Request message for the UpdateTable method.
func (*UpdateTableRequest) Descriptor
func (*UpdateTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateTableRequest.ProtoReflect.Descriptor instead.
func (*UpdateTableRequest) GetTable
func (x *UpdateTableRequest) GetTable() *Table
func (*UpdateTableRequest) GetUpdateMask
func (x *UpdateTableRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateTableRequest) ProtoMessage
func (*UpdateTableRequest) ProtoMessage()
func (*UpdateTableRequest) ProtoReflect
func (x *UpdateTableRequest) ProtoReflect() protoreflect.Message
func (*UpdateTableRequest) Reset
func (x *UpdateTableRequest) Reset()
func (*UpdateTableRequest) String
func (x *UpdateTableRequest) String() string