biglake

Sep 18, 2024

Changes in this version

type CatalogIterator

+ func (it *CatalogIterator) All() iter.Seq2[*biglakepb.Catalog, error]

type DatabaseIterator

+ func (it *DatabaseIterator) All() iter.Seq2[*biglakepb.Database, error]

type LockIterator

+ func (it *LockIterator) All() iter.Seq2[*biglakepb.Lock, error]

type TableIterator

+ func (it *TableIterator) All() iter.Seq2[*biglakepb.Table, error]

Aug 17, 2023

Changes in this version

+ func DefaultAuthScopes() []string

+ type CatalogIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*biglakepb.Catalog, nextPageToken string, err error)

+ Response interface{}

+ func (it *CatalogIterator) Next() (*biglakepb.Catalog, error)

+ func (it *CatalogIterator) PageInfo() *iterator.PageInfo

+ type DatabaseIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*biglakepb.Database, nextPageToken string, err error)

+ Response interface{}

+ func (it *DatabaseIterator) Next() (*biglakepb.Database, error)

+ func (it *DatabaseIterator) PageInfo() *iterator.PageInfo

+ type LockIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*biglakepb.Lock, nextPageToken string, err error)

+ Response interface{}

+ func (it *LockIterator) Next() (*biglakepb.Lock, error)

+ func (it *LockIterator) PageInfo() *iterator.PageInfo

+ type MetastoreCallOptions struct

+ CheckLock []gax.CallOption

+ CreateCatalog []gax.CallOption

+ CreateDatabase []gax.CallOption

+ CreateLock []gax.CallOption

+ CreateTable []gax.CallOption

+ DeleteCatalog []gax.CallOption

+ DeleteDatabase []gax.CallOption

+ DeleteLock []gax.CallOption

+ DeleteTable []gax.CallOption

+ GetCatalog []gax.CallOption

+ GetDatabase []gax.CallOption

+ GetTable []gax.CallOption

+ ListCatalogs []gax.CallOption

+ ListDatabases []gax.CallOption

+ ListLocks []gax.CallOption

+ ListTables []gax.CallOption

+ RenameTable []gax.CallOption

+ UpdateDatabase []gax.CallOption

+ UpdateTable []gax.CallOption

+ type MetastoreClient struct

+ CallOptions *MetastoreCallOptions

+ func NewMetastoreClient(ctx context.Context, opts ...option.ClientOption) (*MetastoreClient, error)

+ func NewMetastoreRESTClient(ctx context.Context, opts ...option.ClientOption) (*MetastoreClient, error)

+ func (c *MetastoreClient) CheckLock(ctx context.Context, req *biglakepb.CheckLockRequest, opts ...gax.CallOption) (*biglakepb.Lock, error)

+ func (c *MetastoreClient) Close() error

+ func (c *MetastoreClient) Connection() *grpc.ClientConn

+ func (c *MetastoreClient) CreateCatalog(ctx context.Context, req *biglakepb.CreateCatalogRequest, ...) (*biglakepb.Catalog, error)

+ func (c *MetastoreClient) CreateDatabase(ctx context.Context, req *biglakepb.CreateDatabaseRequest, ...) (*biglakepb.Database, error)

+ func (c *MetastoreClient) CreateLock(ctx context.Context, req *biglakepb.CreateLockRequest, opts ...gax.CallOption) (*biglakepb.Lock, error)

+ func (c *MetastoreClient) CreateTable(ctx context.Context, req *biglakepb.CreateTableRequest, opts ...gax.CallOption) (*biglakepb.Table, error)

+ func (c *MetastoreClient) DeleteCatalog(ctx context.Context, req *biglakepb.DeleteCatalogRequest, ...) (*biglakepb.Catalog, error)

+ func (c *MetastoreClient) DeleteDatabase(ctx context.Context, req *biglakepb.DeleteDatabaseRequest, ...) (*biglakepb.Database, error)

+ func (c *MetastoreClient) DeleteLock(ctx context.Context, req *biglakepb.DeleteLockRequest, opts ...gax.CallOption) error

+ func (c *MetastoreClient) DeleteTable(ctx context.Context, req *biglakepb.DeleteTableRequest, opts ...gax.CallOption) (*biglakepb.Table, error)

+ func (c *MetastoreClient) GetCatalog(ctx context.Context, req *biglakepb.GetCatalogRequest, opts ...gax.CallOption) (*biglakepb.Catalog, error)

+ func (c *MetastoreClient) GetDatabase(ctx context.Context, req *biglakepb.GetDatabaseRequest, opts ...gax.CallOption) (*biglakepb.Database, error)

+ func (c *MetastoreClient) GetTable(ctx context.Context, req *biglakepb.GetTableRequest, opts ...gax.CallOption) (*biglakepb.Table, error)

+ func (c *MetastoreClient) ListCatalogs(ctx context.Context, req *biglakepb.ListCatalogsRequest, ...) *CatalogIterator

+ func (c *MetastoreClient) ListDatabases(ctx context.Context, req *biglakepb.ListDatabasesRequest, ...) *DatabaseIterator

+ func (c *MetastoreClient) ListLocks(ctx context.Context, req *biglakepb.ListLocksRequest, opts ...gax.CallOption) *LockIterator

+ func (c *MetastoreClient) ListTables(ctx context.Context, req *biglakepb.ListTablesRequest, opts ...gax.CallOption) *TableIterator

+ func (c *MetastoreClient) RenameTable(ctx context.Context, req *biglakepb.RenameTableRequest, opts ...gax.CallOption) (*biglakepb.Table, error)

+ func (c *MetastoreClient) UpdateDatabase(ctx context.Context, req *biglakepb.UpdateDatabaseRequest, ...) (*biglakepb.Database, error)

+ func (c *MetastoreClient) UpdateTable(ctx context.Context, req *biglakepb.UpdateTableRequest, opts ...gax.CallOption) (*biglakepb.Table, error)

+ type TableIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*biglakepb.Table, nextPageToken string, err error)

+ Response interface{}

+ func (it *TableIterator) Next() (*biglakepb.Table, error)

+ func (it *TableIterator) PageInfo() *iterator.PageInfo