dataplex

Mar 19, 2024

Changes in this version

+ type AspectTypeIterator struct

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

+ Response interface{}

+ func (it *AspectTypeIterator) Next() (*dataplexpb.AspectType, error)

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

+ type CatalogCallOptions struct

+ CancelOperation []gax.CallOption

+ CreateAspectType []gax.CallOption

+ CreateEntry []gax.CallOption

+ CreateEntryGroup []gax.CallOption

+ CreateEntryType []gax.CallOption

+ DeleteAspectType []gax.CallOption

+ DeleteEntry []gax.CallOption

+ DeleteEntryGroup []gax.CallOption

+ DeleteEntryType []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetAspectType []gax.CallOption

+ GetEntry []gax.CallOption

+ GetEntryGroup []gax.CallOption

+ GetEntryType []gax.CallOption

+ GetLocation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListAspectTypes []gax.CallOption

+ ListEntries []gax.CallOption

+ ListEntryGroups []gax.CallOption

+ ListEntryTypes []gax.CallOption

+ ListLocations []gax.CallOption

+ ListOperations []gax.CallOption

+ LookupEntry []gax.CallOption

+ SearchEntries []gax.CallOption

+ UpdateAspectType []gax.CallOption

+ UpdateEntry []gax.CallOption

+ UpdateEntryGroup []gax.CallOption

+ UpdateEntryType []gax.CallOption

+ type CatalogClient struct

+ CallOptions *CatalogCallOptions

+ LROClient *lroauto.OperationsClient

+ func NewCatalogClient(ctx context.Context, opts ...option.ClientOption) (*CatalogClient, error)

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

+ func (c *CatalogClient) Close() error

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

+ func (c *CatalogClient) CreateAspectType(ctx context.Context, req *dataplexpb.CreateAspectTypeRequest, ...) (*CreateAspectTypeOperation, error)

+ func (c *CatalogClient) CreateAspectTypeOperation(name string) *CreateAspectTypeOperation

+ func (c *CatalogClient) CreateEntry(ctx context.Context, req *dataplexpb.CreateEntryRequest, ...) (*dataplexpb.Entry, error)

+ func (c *CatalogClient) CreateEntryGroup(ctx context.Context, req *dataplexpb.CreateEntryGroupRequest, ...) (*CreateEntryGroupOperation, error)

+ func (c *CatalogClient) CreateEntryGroupOperation(name string) *CreateEntryGroupOperation

+ func (c *CatalogClient) CreateEntryType(ctx context.Context, req *dataplexpb.CreateEntryTypeRequest, ...) (*CreateEntryTypeOperation, error)

+ func (c *CatalogClient) CreateEntryTypeOperation(name string) *CreateEntryTypeOperation

+ func (c *CatalogClient) DeleteAspectType(ctx context.Context, req *dataplexpb.DeleteAspectTypeRequest, ...) (*DeleteAspectTypeOperation, error)

+ func (c *CatalogClient) DeleteAspectTypeOperation(name string) *DeleteAspectTypeOperation

+ func (c *CatalogClient) DeleteEntry(ctx context.Context, req *dataplexpb.DeleteEntryRequest, ...) (*dataplexpb.Entry, error)

+ func (c *CatalogClient) DeleteEntryGroup(ctx context.Context, req *dataplexpb.DeleteEntryGroupRequest, ...) (*DeleteEntryGroupOperation, error)

+ func (c *CatalogClient) DeleteEntryGroupOperation(name string) *DeleteEntryGroupOperation

+ func (c *CatalogClient) DeleteEntryType(ctx context.Context, req *dataplexpb.DeleteEntryTypeRequest, ...) (*DeleteEntryTypeOperation, error)

+ func (c *CatalogClient) DeleteEntryTypeOperation(name string) *DeleteEntryTypeOperation

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

+ func (c *CatalogClient) GetAspectType(ctx context.Context, req *dataplexpb.GetAspectTypeRequest, ...) (*dataplexpb.AspectType, error)

+ func (c *CatalogClient) GetEntry(ctx context.Context, req *dataplexpb.GetEntryRequest, opts ...gax.CallOption) (*dataplexpb.Entry, error)

+ func (c *CatalogClient) GetEntryGroup(ctx context.Context, req *dataplexpb.GetEntryGroupRequest, ...) (*dataplexpb.EntryGroup, error)

+ func (c *CatalogClient) GetEntryType(ctx context.Context, req *dataplexpb.GetEntryTypeRequest, ...) (*dataplexpb.EntryType, error)

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

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

+ func (c *CatalogClient) ListAspectTypes(ctx context.Context, req *dataplexpb.ListAspectTypesRequest, ...) *AspectTypeIterator

+ func (c *CatalogClient) ListEntries(ctx context.Context, req *dataplexpb.ListEntriesRequest, ...) *EntryIterator

+ func (c *CatalogClient) ListEntryGroups(ctx context.Context, req *dataplexpb.ListEntryGroupsRequest, ...) *EntryGroupIterator

+ func (c *CatalogClient) ListEntryTypes(ctx context.Context, req *dataplexpb.ListEntryTypesRequest, ...) *EntryTypeIterator

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

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

+ func (c *CatalogClient) LookupEntry(ctx context.Context, req *dataplexpb.LookupEntryRequest, ...) (*dataplexpb.Entry, error)

+ func (c *CatalogClient) SearchEntries(ctx context.Context, req *dataplexpb.SearchEntriesRequest, ...) *SearchEntriesResultIterator

+ func (c *CatalogClient) UpdateAspectType(ctx context.Context, req *dataplexpb.UpdateAspectTypeRequest, ...) (*UpdateAspectTypeOperation, error)

+ func (c *CatalogClient) UpdateAspectTypeOperation(name string) *UpdateAspectTypeOperation

+ func (c *CatalogClient) UpdateEntry(ctx context.Context, req *dataplexpb.UpdateEntryRequest, ...) (*dataplexpb.Entry, error)

+ func (c *CatalogClient) UpdateEntryGroup(ctx context.Context, req *dataplexpb.UpdateEntryGroupRequest, ...) (*UpdateEntryGroupOperation, error)

+ func (c *CatalogClient) UpdateEntryGroupOperation(name string) *UpdateEntryGroupOperation

+ func (c *CatalogClient) UpdateEntryType(ctx context.Context, req *dataplexpb.UpdateEntryTypeRequest, ...) (*UpdateEntryTypeOperation, error)

+ func (c *CatalogClient) UpdateEntryTypeOperation(name string) *UpdateEntryTypeOperation

+ type CreateAspectTypeOperation struct

+ func (op *CreateAspectTypeOperation) Done() bool

+ func (op *CreateAspectTypeOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *CreateAspectTypeOperation) Name() string

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

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

+ type CreateEntryGroupOperation struct

+ func (op *CreateEntryGroupOperation) Done() bool

+ func (op *CreateEntryGroupOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *CreateEntryGroupOperation) Name() string

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

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

+ type CreateEntryTypeOperation struct

+ func (op *CreateEntryTypeOperation) Done() bool

+ func (op *CreateEntryTypeOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *CreateEntryTypeOperation) Name() string

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

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

type DataScanCallOptions

+ GenerateDataQualityRules []gax.CallOption

type DataScanClient

+ func (c *DataScanClient) GenerateDataQualityRules(ctx context.Context, req *dataplexpb.GenerateDataQualityRulesRequest, ...) (*dataplexpb.GenerateDataQualityRulesResponse, error)

+ type DeleteAspectTypeOperation struct

+ func (op *DeleteAspectTypeOperation) Done() bool

+ func (op *DeleteAspectTypeOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *DeleteAspectTypeOperation) Name() string

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

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

+ type DeleteEntryGroupOperation struct

+ func (op *DeleteEntryGroupOperation) Done() bool

+ func (op *DeleteEntryGroupOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *DeleteEntryGroupOperation) Name() string

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

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

+ type DeleteEntryTypeOperation struct

+ func (op *DeleteEntryTypeOperation) Done() bool

+ func (op *DeleteEntryTypeOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *DeleteEntryTypeOperation) Name() string

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

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

+ type EntryGroupIterator struct

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

+ Response interface{}

+ func (it *EntryGroupIterator) Next() (*dataplexpb.EntryGroup, error)

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

+ type EntryIterator struct

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

+ Response interface{}

+ func (it *EntryIterator) Next() (*dataplexpb.Entry, error)

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

+ type EntryTypeIterator struct

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

+ Response interface{}

+ func (it *EntryTypeIterator) Next() (*dataplexpb.EntryType, error)

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

+ type SearchEntriesResultIterator struct

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

+ Response interface{}

+ func (it *SearchEntriesResultIterator) Next() (*dataplexpb.SearchEntriesResult, error)

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

+ type UpdateAspectTypeOperation struct

+ func (op *UpdateAspectTypeOperation) Done() bool

+ func (op *UpdateAspectTypeOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *UpdateAspectTypeOperation) Name() string

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

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

+ type UpdateEntryGroupOperation struct

+ func (op *UpdateEntryGroupOperation) Done() bool

+ func (op *UpdateEntryGroupOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *UpdateEntryGroupOperation) Name() string

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

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

+ type UpdateEntryTypeOperation struct

+ func (op *UpdateEntryTypeOperation) Done() bool

+ func (op *UpdateEntryTypeOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *UpdateEntryTypeOperation) Name() string

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

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

Jul 26, 2023

Changes in this version

+ type CreateDataAttributeBindingOperation struct

+ func (op *CreateDataAttributeBindingOperation) Done() bool

+ func (op *CreateDataAttributeBindingOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *CreateDataAttributeBindingOperation) Name() string

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

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

+ type CreateDataAttributeOperation struct

+ func (op *CreateDataAttributeOperation) Done() bool

+ func (op *CreateDataAttributeOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *CreateDataAttributeOperation) Name() string

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

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

+ type CreateDataTaxonomyOperation struct

+ func (op *CreateDataTaxonomyOperation) Done() bool

+ func (op *CreateDataTaxonomyOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *CreateDataTaxonomyOperation) Name() string

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

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

+ type DataAttributeBindingIterator struct

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

+ Response interface{}

+ func (it *DataAttributeBindingIterator) Next() (*dataplexpb.DataAttributeBinding, error)

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

+ type DataAttributeIterator struct

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

+ Response interface{}

+ func (it *DataAttributeIterator) Next() (*dataplexpb.DataAttribute, error)

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

+ type DataTaxonomyCallOptions struct

+ CancelOperation []gax.CallOption

+ CreateDataAttribute []gax.CallOption

+ CreateDataAttributeBinding []gax.CallOption

+ CreateDataTaxonomy []gax.CallOption

+ DeleteDataAttribute []gax.CallOption

+ DeleteDataAttributeBinding []gax.CallOption

+ DeleteDataTaxonomy []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetDataAttribute []gax.CallOption

+ GetDataAttributeBinding []gax.CallOption

+ GetDataTaxonomy []gax.CallOption

+ GetLocation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListDataAttributeBindings []gax.CallOption

+ ListDataAttributes []gax.CallOption

+ ListDataTaxonomies []gax.CallOption

+ ListLocations []gax.CallOption

+ ListOperations []gax.CallOption

+ UpdateDataAttribute []gax.CallOption

+ UpdateDataAttributeBinding []gax.CallOption

+ UpdateDataTaxonomy []gax.CallOption

+ type DataTaxonomyClient struct

+ CallOptions *DataTaxonomyCallOptions

+ LROClient *lroauto.OperationsClient

+ func NewDataTaxonomyClient(ctx context.Context, opts ...option.ClientOption) (*DataTaxonomyClient, error)

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

+ func (c *DataTaxonomyClient) Close() error

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

+ func (c *DataTaxonomyClient) CreateDataAttribute(ctx context.Context, req *dataplexpb.CreateDataAttributeRequest, ...) (*CreateDataAttributeOperation, error)

+ func (c *DataTaxonomyClient) CreateDataAttributeBinding(ctx context.Context, req *dataplexpb.CreateDataAttributeBindingRequest, ...) (*CreateDataAttributeBindingOperation, error)

+ func (c *DataTaxonomyClient) CreateDataAttributeBindingOperation(name string) *CreateDataAttributeBindingOperation

+ func (c *DataTaxonomyClient) CreateDataAttributeOperation(name string) *CreateDataAttributeOperation

+ func (c *DataTaxonomyClient) CreateDataTaxonomy(ctx context.Context, req *dataplexpb.CreateDataTaxonomyRequest, ...) (*CreateDataTaxonomyOperation, error)

+ func (c *DataTaxonomyClient) CreateDataTaxonomyOperation(name string) *CreateDataTaxonomyOperation

+ func (c *DataTaxonomyClient) DeleteDataAttribute(ctx context.Context, req *dataplexpb.DeleteDataAttributeRequest, ...) (*DeleteDataAttributeOperation, error)

+ func (c *DataTaxonomyClient) DeleteDataAttributeBinding(ctx context.Context, req *dataplexpb.DeleteDataAttributeBindingRequest, ...) (*DeleteDataAttributeBindingOperation, error)

+ func (c *DataTaxonomyClient) DeleteDataAttributeBindingOperation(name string) *DeleteDataAttributeBindingOperation

+ func (c *DataTaxonomyClient) DeleteDataAttributeOperation(name string) *DeleteDataAttributeOperation

+ func (c *DataTaxonomyClient) DeleteDataTaxonomy(ctx context.Context, req *dataplexpb.DeleteDataTaxonomyRequest, ...) (*DeleteDataTaxonomyOperation, error)

+ func (c *DataTaxonomyClient) DeleteDataTaxonomyOperation(name string) *DeleteDataTaxonomyOperation

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

+ func (c *DataTaxonomyClient) GetDataAttribute(ctx context.Context, req *dataplexpb.GetDataAttributeRequest, ...) (*dataplexpb.DataAttribute, error)

+ func (c *DataTaxonomyClient) GetDataAttributeBinding(ctx context.Context, req *dataplexpb.GetDataAttributeBindingRequest, ...) (*dataplexpb.DataAttributeBinding, error)

+ func (c *DataTaxonomyClient) GetDataTaxonomy(ctx context.Context, req *dataplexpb.GetDataTaxonomyRequest, ...) (*dataplexpb.DataTaxonomy, error)

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

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

+ func (c *DataTaxonomyClient) ListDataAttributeBindings(ctx context.Context, req *dataplexpb.ListDataAttributeBindingsRequest, ...) *DataAttributeBindingIterator

+ func (c *DataTaxonomyClient) ListDataAttributes(ctx context.Context, req *dataplexpb.ListDataAttributesRequest, ...) *DataAttributeIterator

+ func (c *DataTaxonomyClient) ListDataTaxonomies(ctx context.Context, req *dataplexpb.ListDataTaxonomiesRequest, ...) *DataTaxonomyIterator

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

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

+ func (c *DataTaxonomyClient) UpdateDataAttribute(ctx context.Context, req *dataplexpb.UpdateDataAttributeRequest, ...) (*UpdateDataAttributeOperation, error)

+ func (c *DataTaxonomyClient) UpdateDataAttributeBinding(ctx context.Context, req *dataplexpb.UpdateDataAttributeBindingRequest, ...) (*UpdateDataAttributeBindingOperation, error)

+ func (c *DataTaxonomyClient) UpdateDataAttributeBindingOperation(name string) *UpdateDataAttributeBindingOperation

+ func (c *DataTaxonomyClient) UpdateDataAttributeOperation(name string) *UpdateDataAttributeOperation

+ func (c *DataTaxonomyClient) UpdateDataTaxonomy(ctx context.Context, req *dataplexpb.UpdateDataTaxonomyRequest, ...) (*UpdateDataTaxonomyOperation, error)

+ func (c *DataTaxonomyClient) UpdateDataTaxonomyOperation(name string) *UpdateDataTaxonomyOperation

+ type DataTaxonomyIterator struct

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

+ Response interface{}

+ func (it *DataTaxonomyIterator) Next() (*dataplexpb.DataTaxonomy, error)

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

+ type DeleteDataAttributeBindingOperation struct

+ func (op *DeleteDataAttributeBindingOperation) Done() bool

+ func (op *DeleteDataAttributeBindingOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *DeleteDataAttributeBindingOperation) Name() string

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

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

+ type DeleteDataAttributeOperation struct

+ func (op *DeleteDataAttributeOperation) Done() bool

+ func (op *DeleteDataAttributeOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *DeleteDataAttributeOperation) Name() string

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

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

+ type DeleteDataTaxonomyOperation struct

+ func (op *DeleteDataTaxonomyOperation) Done() bool

+ func (op *DeleteDataTaxonomyOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *DeleteDataTaxonomyOperation) Name() string

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

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

+ type UpdateDataAttributeBindingOperation struct

+ func (op *UpdateDataAttributeBindingOperation) Done() bool

+ func (op *UpdateDataAttributeBindingOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *UpdateDataAttributeBindingOperation) Name() string

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

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

+ type UpdateDataAttributeOperation struct

+ func (op *UpdateDataAttributeOperation) Done() bool

+ func (op *UpdateDataAttributeOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *UpdateDataAttributeOperation) Name() string

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

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

+ type UpdateDataTaxonomyOperation struct

+ func (op *UpdateDataTaxonomyOperation) Done() bool

+ func (op *UpdateDataTaxonomyOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *UpdateDataTaxonomyOperation) Name() string

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

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

May 3, 2023

Changes in this version

type CallOptions

+ RunTask []gax.CallOption

type Client

+ func (c *Client) RunTask(ctx context.Context, req *dataplexpb.RunTaskRequest, opts ...gax.CallOption) (*dataplexpb.RunTaskResponse, error)

Jan 5, 2023

Changes in this version

+ type CreateDataScanOperation struct

+ func (op *CreateDataScanOperation) Done() bool

+ func (op *CreateDataScanOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *CreateDataScanOperation) Name() string

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

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

+ type DataScanCallOptions struct

+ CancelOperation []gax.CallOption

+ CreateDataScan []gax.CallOption

+ DeleteDataScan []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetDataScan []gax.CallOption

+ GetDataScanJob []gax.CallOption

+ GetLocation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListDataScanJobs []gax.CallOption

+ ListDataScans []gax.CallOption

+ ListLocations []gax.CallOption

+ ListOperations []gax.CallOption

+ RunDataScan []gax.CallOption

+ UpdateDataScan []gax.CallOption

+ type DataScanClient struct

+ CallOptions *DataScanCallOptions

+ LROClient *lroauto.OperationsClient

+ func NewDataScanClient(ctx context.Context, opts ...option.ClientOption) (*DataScanClient, error)

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

+ func (c *DataScanClient) Close() error

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

+ func (c *DataScanClient) CreateDataScan(ctx context.Context, req *dataplexpb.CreateDataScanRequest, ...) (*CreateDataScanOperation, error)

+ func (c *DataScanClient) CreateDataScanOperation(name string) *CreateDataScanOperation

+ func (c *DataScanClient) DeleteDataScan(ctx context.Context, req *dataplexpb.DeleteDataScanRequest, ...) (*DeleteDataScanOperation, error)

+ func (c *DataScanClient) DeleteDataScanOperation(name string) *DeleteDataScanOperation

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

+ func (c *DataScanClient) GetDataScan(ctx context.Context, req *dataplexpb.GetDataScanRequest, ...) (*dataplexpb.DataScan, error)

+ func (c *DataScanClient) GetDataScanJob(ctx context.Context, req *dataplexpb.GetDataScanJobRequest, ...) (*dataplexpb.DataScanJob, error)

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

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

+ func (c *DataScanClient) ListDataScanJobs(ctx context.Context, req *dataplexpb.ListDataScanJobsRequest, ...) *DataScanJobIterator

+ func (c *DataScanClient) ListDataScans(ctx context.Context, req *dataplexpb.ListDataScansRequest, ...) *DataScanIterator

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

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

+ func (c *DataScanClient) RunDataScan(ctx context.Context, req *dataplexpb.RunDataScanRequest, ...) (*dataplexpb.RunDataScanResponse, error)

+ func (c *DataScanClient) UpdateDataScan(ctx context.Context, req *dataplexpb.UpdateDataScanRequest, ...) (*UpdateDataScanOperation, error)

+ func (c *DataScanClient) UpdateDataScanOperation(name string) *UpdateDataScanOperation

+ type DataScanIterator struct

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

+ Response interface{}

+ func (it *DataScanIterator) Next() (*dataplexpb.DataScan, error)

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

+ type DataScanJobIterator struct

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

+ Response interface{}

+ func (it *DataScanJobIterator) Next() (*dataplexpb.DataScanJob, error)

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

+ type DeleteDataScanOperation struct

+ func (op *DeleteDataScanOperation) Done() bool

+ func (op *DeleteDataScanOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *DeleteDataScanOperation) Name() string

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

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

+ type UpdateDataScanOperation struct

+ func (op *UpdateDataScanOperation) Done() bool

+ func (op *UpdateDataScanOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *UpdateDataScanOperation) Name() string

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

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

Jul 19, 2022

Changes in this version

type CallOptions

+ CancelOperation []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetLocation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListLocations []gax.CallOption

+ ListOperations []gax.CallOption

type Client

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

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

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

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

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

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

type ContentCallOptions

+ CancelOperation []gax.CallOption

+ 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 ContentClient

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

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

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

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

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

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

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

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

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

+ 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 MetadataCallOptions

+ CancelOperation []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetLocation []gax.CallOption

+ GetOperation []gax.CallOption

+ ListLocations []gax.CallOption

+ ListOperations []gax.CallOption

type MetadataClient

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

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

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

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

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

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

+ 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

Feb 22, 2022

Changes in this version

type CallOptions

+ CreateEnvironment []gax.CallOption

+ DeleteEnvironment []gax.CallOption

+ GetEnvironment []gax.CallOption

+ ListEnvironments []gax.CallOption

+ ListSessions []gax.CallOption

+ UpdateEnvironment []gax.CallOption

type Client

+ func (c *Client) CreateEnvironment(ctx context.Context, req *dataplexpb.CreateEnvironmentRequest, ...) (*CreateEnvironmentOperation, error)

+ func (c *Client) CreateEnvironmentOperation(name string) *CreateEnvironmentOperation

+ func (c *Client) DeleteEnvironment(ctx context.Context, req *dataplexpb.DeleteEnvironmentRequest, ...) (*DeleteEnvironmentOperation, error)

+ func (c *Client) DeleteEnvironmentOperation(name string) *DeleteEnvironmentOperation

+ func (c *Client) GetEnvironment(ctx context.Context, req *dataplexpb.GetEnvironmentRequest, ...) (*dataplexpb.Environment, error)

+ func (c *Client) ListEnvironments(ctx context.Context, req *dataplexpb.ListEnvironmentsRequest, ...) *EnvironmentIterator

+ func (c *Client) ListSessions(ctx context.Context, req *dataplexpb.ListSessionsRequest, ...) *SessionIterator

+ func (c *Client) UpdateEnvironment(ctx context.Context, req *dataplexpb.UpdateEnvironmentRequest, ...) (*UpdateEnvironmentOperation, error)

+ func (c *Client) UpdateEnvironmentOperation(name string) *UpdateEnvironmentOperation

+ type ContentCallOptions struct

+ CreateContent []gax.CallOption

+ DeleteContent []gax.CallOption

+ GetContent []gax.CallOption

+ ListContent []gax.CallOption

+ UpdateContent []gax.CallOption

+ type ContentClient struct

+ CallOptions *ContentCallOptions

+ func NewContentClient(ctx context.Context, opts ...option.ClientOption) (*ContentClient, error)

+ func (c *ContentClient) Close() error

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

+ func (c *ContentClient) CreateContent(ctx context.Context, req *dataplexpb.CreateContentRequest, ...) (*dataplexpb.Content, error)

+ func (c *ContentClient) DeleteContent(ctx context.Context, req *dataplexpb.DeleteContentRequest, ...) error

+ func (c *ContentClient) GetContent(ctx context.Context, req *dataplexpb.GetContentRequest, opts ...gax.CallOption) (*dataplexpb.Content, error)

+ func (c *ContentClient) ListContent(ctx context.Context, req *dataplexpb.ListContentRequest, ...) *ContentIterator

+ func (c *ContentClient) UpdateContent(ctx context.Context, req *dataplexpb.UpdateContentRequest, ...) (*dataplexpb.Content, error)

+ type ContentIterator struct

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

+ Response interface{}

+ func (it *ContentIterator) Next() (*dataplexpb.Content, error)

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

+ type CreateEnvironmentOperation struct

+ func (op *CreateEnvironmentOperation) Done() bool

+ func (op *CreateEnvironmentOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *CreateEnvironmentOperation) Name() string

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

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

+ type DeleteEnvironmentOperation struct

+ func (op *DeleteEnvironmentOperation) Done() bool

+ func (op *DeleteEnvironmentOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *DeleteEnvironmentOperation) Name() string

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

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

+ type EnvironmentIterator struct

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

+ Response interface{}

+ func (it *EnvironmentIterator) Next() (*dataplexpb.Environment, error)

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

type MetadataCallOptions

+ CreateEntity []gax.CallOption

+ CreatePartition []gax.CallOption

+ DeleteEntity []gax.CallOption

+ DeletePartition []gax.CallOption

+ UpdateEntity []gax.CallOption

type MetadataClient

+ func (c *MetadataClient) CreateEntity(ctx context.Context, req *dataplexpb.CreateEntityRequest, ...) (*dataplexpb.Entity, error)

+ func (c *MetadataClient) CreatePartition(ctx context.Context, req *dataplexpb.CreatePartitionRequest, ...) (*dataplexpb.Partition, error)

+ func (c *MetadataClient) DeleteEntity(ctx context.Context, req *dataplexpb.DeleteEntityRequest, ...) error

+ func (c *MetadataClient) DeletePartition(ctx context.Context, req *dataplexpb.DeletePartitionRequest, ...) error

+ func (c *MetadataClient) UpdateEntity(ctx context.Context, req *dataplexpb.UpdateEntityRequest, ...) (*dataplexpb.Entity, error)

+ type SessionIterator struct

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

+ Response interface{}

+ func (it *SessionIterator) Next() (*dataplexpb.Session, error)

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

+ type UpdateEnvironmentOperation struct

+ func (op *UpdateEnvironmentOperation) Done() bool

+ func (op *UpdateEnvironmentOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *UpdateEnvironmentOperation) Name() string

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

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

Jan 28, 2022

Changes in this version

+ func DefaultAuthScopes() []string

+ type ActionIterator struct

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

+ Response interface{}

+ func (it *ActionIterator) Next() (*dataplexpb.Action, error)

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

+ type AssetIterator struct

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

+ Response interface{}

+ func (it *AssetIterator) Next() (*dataplexpb.Asset, error)

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

+ type CallOptions struct

+ CancelJob []gax.CallOption

+ CreateAsset []gax.CallOption

+ CreateLake []gax.CallOption

+ CreateTask []gax.CallOption

+ CreateZone []gax.CallOption

+ DeleteAsset []gax.CallOption

+ DeleteLake []gax.CallOption

+ DeleteTask []gax.CallOption

+ DeleteZone []gax.CallOption

+ GetAsset []gax.CallOption

+ GetJob []gax.CallOption

+ GetLake []gax.CallOption

+ GetTask []gax.CallOption

+ GetZone []gax.CallOption

+ ListAssetActions []gax.CallOption

+ ListAssets []gax.CallOption

+ ListJobs []gax.CallOption

+ ListLakeActions []gax.CallOption

+ ListLakes []gax.CallOption

+ ListTasks []gax.CallOption

+ ListZoneActions []gax.CallOption

+ ListZones []gax.CallOption

+ UpdateAsset []gax.CallOption

+ UpdateLake []gax.CallOption

+ UpdateTask []gax.CallOption

+ UpdateZone []gax.CallOption

+ type Client struct

+ CallOptions *CallOptions

+ LROClient *lroauto.OperationsClient

+ func NewClient(ctx context.Context, opts ...option.ClientOption) (*Client, error)

+ func (c *Client) CancelJob(ctx context.Context, req *dataplexpb.CancelJobRequest, opts ...gax.CallOption) error

+ func (c *Client) Close() error

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

+ func (c *Client) CreateAsset(ctx context.Context, req *dataplexpb.CreateAssetRequest, ...) (*CreateAssetOperation, error)

+ func (c *Client) CreateAssetOperation(name string) *CreateAssetOperation

+ func (c *Client) CreateLake(ctx context.Context, req *dataplexpb.CreateLakeRequest, opts ...gax.CallOption) (*CreateLakeOperation, error)

+ func (c *Client) CreateLakeOperation(name string) *CreateLakeOperation

+ func (c *Client) CreateTask(ctx context.Context, req *dataplexpb.CreateTaskRequest, opts ...gax.CallOption) (*CreateTaskOperation, error)

+ func (c *Client) CreateTaskOperation(name string) *CreateTaskOperation

+ func (c *Client) CreateZone(ctx context.Context, req *dataplexpb.CreateZoneRequest, opts ...gax.CallOption) (*CreateZoneOperation, error)

+ func (c *Client) CreateZoneOperation(name string) *CreateZoneOperation

+ func (c *Client) DeleteAsset(ctx context.Context, req *dataplexpb.DeleteAssetRequest, ...) (*DeleteAssetOperation, error)

+ func (c *Client) DeleteAssetOperation(name string) *DeleteAssetOperation

+ func (c *Client) DeleteLake(ctx context.Context, req *dataplexpb.DeleteLakeRequest, opts ...gax.CallOption) (*DeleteLakeOperation, error)

+ func (c *Client) DeleteLakeOperation(name string) *DeleteLakeOperation

+ func (c *Client) DeleteTask(ctx context.Context, req *dataplexpb.DeleteTaskRequest, opts ...gax.CallOption) (*DeleteTaskOperation, error)

+ func (c *Client) DeleteTaskOperation(name string) *DeleteTaskOperation

+ func (c *Client) DeleteZone(ctx context.Context, req *dataplexpb.DeleteZoneRequest, opts ...gax.CallOption) (*DeleteZoneOperation, error)

+ func (c *Client) DeleteZoneOperation(name string) *DeleteZoneOperation

+ func (c *Client) GetAsset(ctx context.Context, req *dataplexpb.GetAssetRequest, opts ...gax.CallOption) (*dataplexpb.Asset, error)

+ func (c *Client) GetJob(ctx context.Context, req *dataplexpb.GetJobRequest, opts ...gax.CallOption) (*dataplexpb.Job, error)

+ func (c *Client) GetLake(ctx context.Context, req *dataplexpb.GetLakeRequest, opts ...gax.CallOption) (*dataplexpb.Lake, error)

+ func (c *Client) GetTask(ctx context.Context, req *dataplexpb.GetTaskRequest, opts ...gax.CallOption) (*dataplexpb.Task, error)

+ func (c *Client) GetZone(ctx context.Context, req *dataplexpb.GetZoneRequest, opts ...gax.CallOption) (*dataplexpb.Zone, error)

+ func (c *Client) ListAssetActions(ctx context.Context, req *dataplexpb.ListAssetActionsRequest, ...) *ActionIterator

+ func (c *Client) ListAssets(ctx context.Context, req *dataplexpb.ListAssetsRequest, opts ...gax.CallOption) *AssetIterator

+ func (c *Client) ListJobs(ctx context.Context, req *dataplexpb.ListJobsRequest, opts ...gax.CallOption) *JobIterator

+ func (c *Client) ListLakeActions(ctx context.Context, req *dataplexpb.ListLakeActionsRequest, ...) *ActionIterator

+ func (c *Client) ListLakes(ctx context.Context, req *dataplexpb.ListLakesRequest, opts ...gax.CallOption) *LakeIterator

+ func (c *Client) ListTasks(ctx context.Context, req *dataplexpb.ListTasksRequest, opts ...gax.CallOption) *TaskIterator

+ func (c *Client) ListZoneActions(ctx context.Context, req *dataplexpb.ListZoneActionsRequest, ...) *ActionIterator

+ func (c *Client) ListZones(ctx context.Context, req *dataplexpb.ListZonesRequest, opts ...gax.CallOption) *ZoneIterator

+ func (c *Client) UpdateAsset(ctx context.Context, req *dataplexpb.UpdateAssetRequest, ...) (*UpdateAssetOperation, error)

+ func (c *Client) UpdateAssetOperation(name string) *UpdateAssetOperation

+ func (c *Client) UpdateLake(ctx context.Context, req *dataplexpb.UpdateLakeRequest, opts ...gax.CallOption) (*UpdateLakeOperation, error)

+ func (c *Client) UpdateLakeOperation(name string) *UpdateLakeOperation

+ func (c *Client) UpdateTask(ctx context.Context, req *dataplexpb.UpdateTaskRequest, opts ...gax.CallOption) (*UpdateTaskOperation, error)

+ func (c *Client) UpdateTaskOperation(name string) *UpdateTaskOperation

+ func (c *Client) UpdateZone(ctx context.Context, req *dataplexpb.UpdateZoneRequest, opts ...gax.CallOption) (*UpdateZoneOperation, error)

+ func (c *Client) UpdateZoneOperation(name string) *UpdateZoneOperation

+ type CreateAssetOperation struct

+ func (op *CreateAssetOperation) Done() bool

+ func (op *CreateAssetOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *CreateAssetOperation) Name() string

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

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

+ type CreateLakeOperation struct

+ func (op *CreateLakeOperation) Done() bool

+ func (op *CreateLakeOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *CreateLakeOperation) Name() string

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

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

+ type CreateTaskOperation struct

+ func (op *CreateTaskOperation) Done() bool

+ func (op *CreateTaskOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *CreateTaskOperation) Name() string

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

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

+ type CreateZoneOperation struct

+ func (op *CreateZoneOperation) Done() bool

+ func (op *CreateZoneOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *CreateZoneOperation) Name() string

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

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

+ type DeleteAssetOperation struct

+ func (op *DeleteAssetOperation) Done() bool

+ func (op *DeleteAssetOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *DeleteAssetOperation) Name() string

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

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

+ type DeleteLakeOperation struct

+ func (op *DeleteLakeOperation) Done() bool

+ func (op *DeleteLakeOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *DeleteLakeOperation) Name() string

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

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

+ type DeleteTaskOperation struct

+ func (op *DeleteTaskOperation) Done() bool

+ func (op *DeleteTaskOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *DeleteTaskOperation) Name() string

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

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

+ type DeleteZoneOperation struct

+ func (op *DeleteZoneOperation) Done() bool

+ func (op *DeleteZoneOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *DeleteZoneOperation) Name() string

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

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

+ type EntityIterator struct

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

+ Response interface{}

+ func (it *EntityIterator) Next() (*dataplexpb.Entity, error)

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

+ type JobIterator struct

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

+ Response interface{}

+ func (it *JobIterator) Next() (*dataplexpb.Job, error)

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

+ type LakeIterator struct

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

+ Response interface{}

+ func (it *LakeIterator) Next() (*dataplexpb.Lake, error)

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

+ type MetadataCallOptions struct

+ GetEntity []gax.CallOption

+ GetPartition []gax.CallOption

+ ListEntities []gax.CallOption

+ ListPartitions []gax.CallOption

+ type MetadataClient struct

+ CallOptions *MetadataCallOptions

+ func NewMetadataClient(ctx context.Context, opts ...option.ClientOption) (*MetadataClient, error)

+ func (c *MetadataClient) Close() error

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

+ func (c *MetadataClient) GetEntity(ctx context.Context, req *dataplexpb.GetEntityRequest, opts ...gax.CallOption) (*dataplexpb.Entity, error)

+ func (c *MetadataClient) GetPartition(ctx context.Context, req *dataplexpb.GetPartitionRequest, ...) (*dataplexpb.Partition, error)

+ func (c *MetadataClient) ListEntities(ctx context.Context, req *dataplexpb.ListEntitiesRequest, ...) *EntityIterator

+ func (c *MetadataClient) ListPartitions(ctx context.Context, req *dataplexpb.ListPartitionsRequest, ...) *PartitionIterator

+ type PartitionIterator struct

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

+ Response interface{}

+ func (it *PartitionIterator) Next() (*dataplexpb.Partition, error)

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

+ type TaskIterator struct

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

+ Response interface{}

+ func (it *TaskIterator) Next() (*dataplexpb.Task, error)

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

+ type UpdateAssetOperation struct

+ func (op *UpdateAssetOperation) Done() bool

+ func (op *UpdateAssetOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *UpdateAssetOperation) Name() string

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

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

+ type UpdateLakeOperation struct

+ func (op *UpdateLakeOperation) Done() bool

+ func (op *UpdateLakeOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *UpdateLakeOperation) Name() string

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

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

+ type UpdateTaskOperation struct

+ func (op *UpdateTaskOperation) Done() bool

+ func (op *UpdateTaskOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *UpdateTaskOperation) Name() string

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

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

+ type UpdateZoneOperation struct

+ func (op *UpdateZoneOperation) Done() bool

+ func (op *UpdateZoneOperation) Metadata() (*dataplexpb.OperationMetadata, error)

+ func (op *UpdateZoneOperation) Name() string

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

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

+ type ZoneIterator struct

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

+ Response interface{}

+ func (it *ZoneIterator) Next() (*dataplexpb.Zone, error)

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