Package cloud.google.com/go/bigquery/biglake/apiv1alpha1/biglakepb (v1.54.0)

Version 1.54.0

• 1.64.0 (latest)
• 1.63.1
• 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

Alpha

This library is covered by the Pre-GA Offerings Terms of the Terms of Service. Pre-GA libraries might have limited support, and changes to pre-GA libraries might not be compatible with other pre-GA versions. For more information, see the launch stage descriptions.

Note: To get more information about this package, such as access to older versions, view this package on pkg.go.dev.

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

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

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 (x *Catalog) GetName() string

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

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

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

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 (x *Database) GetName() string

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

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

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

Deprecated: Use Lock.ProtoReflect.Descriptor instead.

func (*Lock) GetCreateTime

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

func (*Lock) GetName

func (x *Lock) GetName() string

func (*Lock) GetResources

func (m *Lock) GetResources() isLock_Resources

func (*Lock) GetState

func (x *Lock) GetState() Lock_State

func (*Lock) GetTableId

func (x *Lock) GetTableId() string

func (*Lock) GetType

func (x *Lock) GetType() Lock_Type

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

func (x *Lock) String() 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 (x Lock_Type) Enum() *Lock_Type

func (Lock_Type) EnumDescriptor

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

Deprecated: Use Lock_Type.Descriptor instead.

func (Lock_Type) Number

func (x Lock_Type) Number() protoreflect.EnumNumber

func (Lock_Type) String

func (x Lock_Type) String() 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

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

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 (x *Table) GetEtag() string

func (*Table) GetExpireTime

func (x *Table) GetExpireTime() *timestamppb.Timestamp

func (*Table) GetHiveOptions

func (x *Table) GetHiveOptions() *HiveTableOptions

func (*Table) GetName

func (x *Table) GetName() string

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

func (x *Table) String() 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 (x TableView) Enum() *TableView

func (TableView) EnumDescriptor

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

Deprecated: Use TableView.Descriptor instead.

func (TableView) Number

func (x TableView) Number() protoreflect.EnumNumber

func (TableView) String

func (x TableView) String() 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