metastore

Sep 12, 2024

Changes in this version

type BackupIterator

+ func (it *BackupIterator) All() iter.Seq2[*metastorepb.Backup, error]

type FederationIterator

+ func (it *FederationIterator) All() iter.Seq2[*metastorepb.Federation, error]

type LocationIterator

+ func (it *LocationIterator) All() iter.Seq2[*locationpb.Location, error]

type MetadataImportIterator

+ func (it *MetadataImportIterator) All() iter.Seq2[*metastorepb.MetadataImport, error]

type OperationIterator

+ func (it *OperationIterator) All() iter.Seq2[*longrunningpb.Operation, error]

type ServiceIterator

+ func (it *ServiceIterator) All() iter.Seq2[*metastorepb.Service, error]

May 8, 2023

Changes in this version

type DataprocMetastoreCallOptions

+ CancelOperation []gax.CallOption

type DataprocMetastoreClient

+ func (c *DataprocMetastoreClient) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, ...) error

type DataprocMetastoreFederationCallOptions

+ CancelOperation []gax.CallOption

type DataprocMetastoreFederationClient

+ func (c *DataprocMetastoreFederationClient) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, ...) error

Jan 5, 2023

Changes in this version

+ type AlterMetadataResourceLocationOperation struct

+ func (op *AlterMetadataResourceLocationOperation) Done() bool

+ func (op *AlterMetadataResourceLocationOperation) Metadata() (*metastorepb.OperationMetadata, error)

+ func (op *AlterMetadataResourceLocationOperation) Name() string

+ func (op *AlterMetadataResourceLocationOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*metastorepb.AlterMetadataResourceLocationResponse, error)

+ func (op *AlterMetadataResourceLocationOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*metastorepb.AlterMetadataResourceLocationResponse, error)

type DataprocMetastoreCallOptions

+ AlterMetadataResourceLocation []gax.CallOption

+ MoveTableToDatabase []gax.CallOption

+ QueryMetadata []gax.CallOption

+ RemoveIamPolicy []gax.CallOption

type DataprocMetastoreClient

+ func (c *DataprocMetastoreClient) AlterMetadataResourceLocation(ctx context.Context, req *metastorepb.AlterMetadataResourceLocationRequest, ...) (*AlterMetadataResourceLocationOperation, error)

+ func (c *DataprocMetastoreClient) AlterMetadataResourceLocationOperation(name string) *AlterMetadataResourceLocationOperation

+ func (c *DataprocMetastoreClient) MoveTableToDatabase(ctx context.Context, req *metastorepb.MoveTableToDatabaseRequest, ...) (*MoveTableToDatabaseOperation, error)

+ func (c *DataprocMetastoreClient) MoveTableToDatabaseOperation(name string) *MoveTableToDatabaseOperation

+ func (c *DataprocMetastoreClient) QueryMetadata(ctx context.Context, req *metastorepb.QueryMetadataRequest, ...) (*QueryMetadataOperation, error)

+ func (c *DataprocMetastoreClient) QueryMetadataOperation(name string) *QueryMetadataOperation

+ func (c *DataprocMetastoreClient) RemoveIamPolicy(ctx context.Context, req *metastorepb.RemoveIamPolicyRequest, ...) (*metastorepb.RemoveIamPolicyResponse, error)

+ type MoveTableToDatabaseOperation struct

+ func (op *MoveTableToDatabaseOperation) Done() bool

+ func (op *MoveTableToDatabaseOperation) Metadata() (*metastorepb.OperationMetadata, error)

+ func (op *MoveTableToDatabaseOperation) Name() string

+ func (op *MoveTableToDatabaseOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*metastorepb.MoveTableToDatabaseResponse, error)

+ func (op *MoveTableToDatabaseOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*metastorepb.MoveTableToDatabaseResponse, error)

+ type QueryMetadataOperation struct

+ func (op *QueryMetadataOperation) Done() bool

+ func (op *QueryMetadataOperation) Metadata() (*metastorepb.OperationMetadata, error)

+ func (op *QueryMetadataOperation) Name() string

+ func (op *QueryMetadataOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*metastorepb.QueryMetadataResponse, error)

+ func (op *QueryMetadataOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*metastorepb.QueryMetadataResponse, error)

Dec 1, 2022

Changes in this version

+ type CreateFederationOperation struct

+ func (op *CreateFederationOperation) Done() bool

+ func (op *CreateFederationOperation) Metadata() (*metastorepb.OperationMetadata, error)

+ func (op *CreateFederationOperation) Name() string

+ func (op *CreateFederationOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*metastorepb.Federation, error)

+ func (op *CreateFederationOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*metastorepb.Federation, error)

type DataprocMetastoreCallOptions

+ DeleteOperation []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetLocation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListLocations []gax.CallOption

+ ListOperations []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []gax.CallOption

type DataprocMetastoreClient

+ func (c *DataprocMetastoreClient) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

+ func (c *DataprocMetastoreClient) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *DataprocMetastoreClient) GetLocation(ctx context.Context, req *locationpb.GetLocationRequest, ...) (*locationpb.Location, error)

+ func (c *DataprocMetastoreClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

+ func (c *DataprocMetastoreClient) ListLocations(ctx context.Context, req *locationpb.ListLocationsRequest, ...) *LocationIterator

+ func (c *DataprocMetastoreClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ func (c *DataprocMetastoreClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *DataprocMetastoreClient) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest, ...) (*iampb.TestIamPermissionsResponse, error)

+ type DataprocMetastoreFederationCallOptions struct

+ CreateFederation []gax.CallOption

+ DeleteFederation []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetFederation []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetLocation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListFederations []gax.CallOption

+ ListLocations []gax.CallOption

+ ListOperations []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []gax.CallOption

+ UpdateFederation []gax.CallOption

+ type DataprocMetastoreFederationClient struct

+ CallOptions *DataprocMetastoreFederationCallOptions

+ LROClient *lroauto.OperationsClient

+ func NewDataprocMetastoreFederationClient(ctx context.Context, opts ...option.ClientOption) (*DataprocMetastoreFederationClient, error)

+ func NewDataprocMetastoreFederationRESTClient(ctx context.Context, opts ...option.ClientOption) (*DataprocMetastoreFederationClient, error)

+ func (c *DataprocMetastoreFederationClient) Close() error

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

+ func (c *DataprocMetastoreFederationClient) CreateFederation(ctx context.Context, req *metastorepb.CreateFederationRequest, ...) (*CreateFederationOperation, error)

+ func (c *DataprocMetastoreFederationClient) CreateFederationOperation(name string) *CreateFederationOperation

+ func (c *DataprocMetastoreFederationClient) DeleteFederation(ctx context.Context, req *metastorepb.DeleteFederationRequest, ...) (*DeleteFederationOperation, error)

+ func (c *DataprocMetastoreFederationClient) DeleteFederationOperation(name string) *DeleteFederationOperation

+ func (c *DataprocMetastoreFederationClient) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

+ func (c *DataprocMetastoreFederationClient) GetFederation(ctx context.Context, req *metastorepb.GetFederationRequest, ...) (*metastorepb.Federation, error)

+ func (c *DataprocMetastoreFederationClient) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *DataprocMetastoreFederationClient) GetLocation(ctx context.Context, req *locationpb.GetLocationRequest, ...) (*locationpb.Location, error)

+ func (c *DataprocMetastoreFederationClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

+ func (c *DataprocMetastoreFederationClient) ListFederations(ctx context.Context, req *metastorepb.ListFederationsRequest, ...) *FederationIterator

+ func (c *DataprocMetastoreFederationClient) ListLocations(ctx context.Context, req *locationpb.ListLocationsRequest, ...) *LocationIterator

+ func (c *DataprocMetastoreFederationClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ func (c *DataprocMetastoreFederationClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *DataprocMetastoreFederationClient) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest, ...) (*iampb.TestIamPermissionsResponse, error)

+ func (c *DataprocMetastoreFederationClient) UpdateFederation(ctx context.Context, req *metastorepb.UpdateFederationRequest, ...) (*UpdateFederationOperation, error)

+ func (c *DataprocMetastoreFederationClient) UpdateFederationOperation(name string) *UpdateFederationOperation

+ type DeleteFederationOperation struct

+ func (op *DeleteFederationOperation) Done() bool

+ func (op *DeleteFederationOperation) Metadata() (*metastorepb.OperationMetadata, error)

+ func (op *DeleteFederationOperation) Name() string

+ func (op *DeleteFederationOperation) Poll(ctx context.Context, opts ...gax.CallOption) error

+ func (op *DeleteFederationOperation) Wait(ctx context.Context, opts ...gax.CallOption) error

+ type FederationIterator struct

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

+ Response interface{}

+ func (it *FederationIterator) Next() (*metastorepb.Federation, error)

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

+ type LocationIterator struct

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

+ Response interface{}

+ func (it *LocationIterator) Next() (*locationpb.Location, error)

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

+ type OperationIterator struct

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

+ Response interface{}

+ func (it *OperationIterator) Next() (*longrunningpb.Operation, error)

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

+ type UpdateFederationOperation struct

+ func (op *UpdateFederationOperation) Done() bool

+ func (op *UpdateFederationOperation) Metadata() (*metastorepb.OperationMetadata, error)

+ func (op *UpdateFederationOperation) Name() string

+ func (op *UpdateFederationOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*metastorepb.Federation, error)

+ func (op *UpdateFederationOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*metastorepb.Federation, error)

Jun 29, 2022

Changes in this version

type DataprocMetastoreClient

+ func NewDataprocMetastoreRESTClient(ctx context.Context, opts ...option.ClientOption) (*DataprocMetastoreClient, error)

Aug 17, 2021

Changes in this version

+ func DefaultAuthScopes() []string

+ type BackupIterator struct

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

+ Response interface{}

+ func (it *BackupIterator) Next() (*metastorepb.Backup, error)

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

+ type CreateBackupOperation struct

+ func (op *CreateBackupOperation) Done() bool

+ func (op *CreateBackupOperation) Metadata() (*metastorepb.OperationMetadata, error)

+ func (op *CreateBackupOperation) Name() string

+ func (op *CreateBackupOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*metastorepb.Backup, error)

+ func (op *CreateBackupOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*metastorepb.Backup, error)

+ type CreateMetadataImportOperation struct

+ func (op *CreateMetadataImportOperation) Done() bool

+ func (op *CreateMetadataImportOperation) Metadata() (*metastorepb.OperationMetadata, error)

+ func (op *CreateMetadataImportOperation) Name() string

+ func (op *CreateMetadataImportOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*metastorepb.MetadataImport, error)

+ func (op *CreateMetadataImportOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*metastorepb.MetadataImport, error)

+ type CreateServiceOperation struct

+ func (op *CreateServiceOperation) Done() bool

+ func (op *CreateServiceOperation) Metadata() (*metastorepb.OperationMetadata, error)

+ func (op *CreateServiceOperation) Name() string

+ func (op *CreateServiceOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*metastorepb.Service, error)

+ func (op *CreateServiceOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*metastorepb.Service, error)

+ type DataprocMetastoreCallOptions struct

+ CreateBackup []gax.CallOption

+ CreateMetadataImport []gax.CallOption

+ CreateService []gax.CallOption

+ DeleteBackup []gax.CallOption

+ DeleteService []gax.CallOption

+ ExportMetadata []gax.CallOption

+ GetBackup []gax.CallOption

+ GetMetadataImport []gax.CallOption

+ GetService []gax.CallOption

+ ListBackups []gax.CallOption

+ ListMetadataImports []gax.CallOption

+ ListServices []gax.CallOption

+ RestoreService []gax.CallOption

+ UpdateMetadataImport []gax.CallOption

+ UpdateService []gax.CallOption

+ type DataprocMetastoreClient struct

+ CallOptions *DataprocMetastoreCallOptions

+ LROClient *lroauto.OperationsClient

+ func NewDataprocMetastoreClient(ctx context.Context, opts ...option.ClientOption) (*DataprocMetastoreClient, error)

+ func (c *DataprocMetastoreClient) Close() error

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

+ func (c *DataprocMetastoreClient) CreateBackup(ctx context.Context, req *metastorepb.CreateBackupRequest, ...) (*CreateBackupOperation, error)

+ func (c *DataprocMetastoreClient) CreateBackupOperation(name string) *CreateBackupOperation

+ func (c *DataprocMetastoreClient) CreateMetadataImport(ctx context.Context, req *metastorepb.CreateMetadataImportRequest, ...) (*CreateMetadataImportOperation, error)

+ func (c *DataprocMetastoreClient) CreateMetadataImportOperation(name string) *CreateMetadataImportOperation

+ func (c *DataprocMetastoreClient) CreateService(ctx context.Context, req *metastorepb.CreateServiceRequest, ...) (*CreateServiceOperation, error)

+ func (c *DataprocMetastoreClient) CreateServiceOperation(name string) *CreateServiceOperation

+ func (c *DataprocMetastoreClient) DeleteBackup(ctx context.Context, req *metastorepb.DeleteBackupRequest, ...) (*DeleteBackupOperation, error)

+ func (c *DataprocMetastoreClient) DeleteBackupOperation(name string) *DeleteBackupOperation

+ func (c *DataprocMetastoreClient) DeleteService(ctx context.Context, req *metastorepb.DeleteServiceRequest, ...) (*DeleteServiceOperation, error)

+ func (c *DataprocMetastoreClient) DeleteServiceOperation(name string) *DeleteServiceOperation

+ func (c *DataprocMetastoreClient) ExportMetadata(ctx context.Context, req *metastorepb.ExportMetadataRequest, ...) (*ExportMetadataOperation, error)

+ func (c *DataprocMetastoreClient) ExportMetadataOperation(name string) *ExportMetadataOperation

+ func (c *DataprocMetastoreClient) GetBackup(ctx context.Context, req *metastorepb.GetBackupRequest, opts ...gax.CallOption) (*metastorepb.Backup, error)

+ func (c *DataprocMetastoreClient) GetMetadataImport(ctx context.Context, req *metastorepb.GetMetadataImportRequest, ...) (*metastorepb.MetadataImport, error)

+ func (c *DataprocMetastoreClient) GetService(ctx context.Context, req *metastorepb.GetServiceRequest, ...) (*metastorepb.Service, error)

+ func (c *DataprocMetastoreClient) ListBackups(ctx context.Context, req *metastorepb.ListBackupsRequest, ...) *BackupIterator

+ func (c *DataprocMetastoreClient) ListMetadataImports(ctx context.Context, req *metastorepb.ListMetadataImportsRequest, ...) *MetadataImportIterator

+ func (c *DataprocMetastoreClient) ListServices(ctx context.Context, req *metastorepb.ListServicesRequest, ...) *ServiceIterator

+ func (c *DataprocMetastoreClient) RestoreService(ctx context.Context, req *metastorepb.RestoreServiceRequest, ...) (*RestoreServiceOperation, error)

+ func (c *DataprocMetastoreClient) RestoreServiceOperation(name string) *RestoreServiceOperation

+ func (c *DataprocMetastoreClient) UpdateMetadataImport(ctx context.Context, req *metastorepb.UpdateMetadataImportRequest, ...) (*UpdateMetadataImportOperation, error)

+ func (c *DataprocMetastoreClient) UpdateMetadataImportOperation(name string) *UpdateMetadataImportOperation

+ func (c *DataprocMetastoreClient) UpdateService(ctx context.Context, req *metastorepb.UpdateServiceRequest, ...) (*UpdateServiceOperation, error)

+ func (c *DataprocMetastoreClient) UpdateServiceOperation(name string) *UpdateServiceOperation

+ type DeleteBackupOperation struct

+ func (op *DeleteBackupOperation) Done() bool

+ func (op *DeleteBackupOperation) Metadata() (*metastorepb.OperationMetadata, error)

+ func (op *DeleteBackupOperation) Name() string

+ func (op *DeleteBackupOperation) Poll(ctx context.Context, opts ...gax.CallOption) error

+ func (op *DeleteBackupOperation) Wait(ctx context.Context, opts ...gax.CallOption) error

+ type DeleteServiceOperation struct

+ func (op *DeleteServiceOperation) Done() bool

+ func (op *DeleteServiceOperation) Metadata() (*metastorepb.OperationMetadata, error)

+ func (op *DeleteServiceOperation) Name() string

+ func (op *DeleteServiceOperation) Poll(ctx context.Context, opts ...gax.CallOption) error

+ func (op *DeleteServiceOperation) Wait(ctx context.Context, opts ...gax.CallOption) error

+ type ExportMetadataOperation struct

+ func (op *ExportMetadataOperation) Done() bool

+ func (op *ExportMetadataOperation) Metadata() (*metastorepb.OperationMetadata, error)

+ func (op *ExportMetadataOperation) Name() string

+ func (op *ExportMetadataOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*metastorepb.MetadataExport, error)

+ func (op *ExportMetadataOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*metastorepb.MetadataExport, error)

+ type MetadataImportIterator struct

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

+ Response interface{}

+ func (it *MetadataImportIterator) Next() (*metastorepb.MetadataImport, error)

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

+ type RestoreServiceOperation struct

+ func (op *RestoreServiceOperation) Done() bool

+ func (op *RestoreServiceOperation) Metadata() (*metastorepb.OperationMetadata, error)

+ func (op *RestoreServiceOperation) Name() string

+ func (op *RestoreServiceOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*metastorepb.Restore, error)

+ func (op *RestoreServiceOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*metastorepb.Restore, error)

+ type ServiceIterator struct

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

+ Response interface{}

+ func (it *ServiceIterator) Next() (*metastorepb.Service, error)

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

+ type UpdateMetadataImportOperation struct

+ func (op *UpdateMetadataImportOperation) Done() bool

+ func (op *UpdateMetadataImportOperation) Metadata() (*metastorepb.OperationMetadata, error)

+ func (op *UpdateMetadataImportOperation) Name() string

+ func (op *UpdateMetadataImportOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*metastorepb.MetadataImport, error)

+ func (op *UpdateMetadataImportOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*metastorepb.MetadataImport, error)

+ type UpdateServiceOperation struct

+ func (op *UpdateServiceOperation) Done() bool

+ func (op *UpdateServiceOperation) Metadata() (*metastorepb.OperationMetadata, error)

+ func (op *UpdateServiceOperation) Name() string

+ func (op *UpdateServiceOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*metastorepb.Service, error)

+ func (op *UpdateServiceOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*metastorepb.Service, error)