analyticshub

Oct 5, 2023

Changes in this version

type CallOptions

+ DeleteSubscription []gax.CallOption

+ GetSubscription []gax.CallOption

+ ListSharedResourceSubscriptions []gax.CallOption

+ ListSubscriptions []gax.CallOption

+ RefreshSubscription []gax.CallOption

+ RevokeSubscription []gax.CallOption

+ SubscribeDataExchange []gax.CallOption

type Client

+ LROClient *lroauto.OperationsClient

+ func (c *Client) DeleteSubscription(ctx context.Context, req *analyticshubpb.DeleteSubscriptionRequest, ...) (*DeleteSubscriptionOperation, error)

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

+ func (c *Client) GetSubscription(ctx context.Context, req *analyticshubpb.GetSubscriptionRequest, ...) (*analyticshubpb.Subscription, error)

+ func (c *Client) ListSharedResourceSubscriptions(ctx context.Context, ...) *SubscriptionIterator

+ func (c *Client) ListSubscriptions(ctx context.Context, req *analyticshubpb.ListSubscriptionsRequest, ...) *SubscriptionIterator

+ func (c *Client) RefreshSubscription(ctx context.Context, req *analyticshubpb.RefreshSubscriptionRequest, ...) (*RefreshSubscriptionOperation, error)

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

+ func (c *Client) RevokeSubscription(ctx context.Context, req *analyticshubpb.RevokeSubscriptionRequest, ...) (*analyticshubpb.RevokeSubscriptionResponse, error)

+ func (c *Client) SubscribeDataExchange(ctx context.Context, req *analyticshubpb.SubscribeDataExchangeRequest, ...) (*SubscribeDataExchangeOperation, error)

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

+ type DeleteSubscriptionOperation struct

+ func (op *DeleteSubscriptionOperation) Done() bool

+ func (op *DeleteSubscriptionOperation) Metadata() (*analyticshubpb.OperationMetadata, error)

+ func (op *DeleteSubscriptionOperation) Name() string

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

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

+ type RefreshSubscriptionOperation struct

+ func (op *RefreshSubscriptionOperation) Done() bool

+ func (op *RefreshSubscriptionOperation) Metadata() (*analyticshubpb.OperationMetadata, error)

+ func (op *RefreshSubscriptionOperation) Name() string

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

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

+ type SubscribeDataExchangeOperation struct

+ func (op *SubscribeDataExchangeOperation) Done() bool

+ func (op *SubscribeDataExchangeOperation) Metadata() (*analyticshubpb.OperationMetadata, error)

+ func (op *SubscribeDataExchangeOperation) Name() string

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

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

+ type SubscriptionIterator struct

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

+ Response interface{}

+ func (it *SubscriptionIterator) Next() (*analyticshubpb.Subscription, error)

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

Sep 21, 2022

Changes in this version

+ func DefaultAuthScopes() []string

+ type CallOptions struct

+ CreateDataExchange []gax.CallOption

+ CreateListing []gax.CallOption

+ DeleteDataExchange []gax.CallOption

+ DeleteListing []gax.CallOption

+ GetDataExchange []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetListing []gax.CallOption

+ ListDataExchanges []gax.CallOption

+ ListListings []gax.CallOption

+ ListOrgDataExchanges []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ SubscribeListing []gax.CallOption

+ TestIamPermissions []gax.CallOption

+ UpdateDataExchange []gax.CallOption

+ UpdateListing []gax.CallOption

+ type Client struct

+ CallOptions *CallOptions

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

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

+ func (c *Client) Close() error

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

+ func (c *Client) CreateDataExchange(ctx context.Context, req *analyticshubpb.CreateDataExchangeRequest, ...) (*analyticshubpb.DataExchange, error)

+ func (c *Client) CreateListing(ctx context.Context, req *analyticshubpb.CreateListingRequest, ...) (*analyticshubpb.Listing, error)

+ func (c *Client) DeleteDataExchange(ctx context.Context, req *analyticshubpb.DeleteDataExchangeRequest, ...) error

+ func (c *Client) DeleteListing(ctx context.Context, req *analyticshubpb.DeleteListingRequest, ...) error

+ func (c *Client) GetDataExchange(ctx context.Context, req *analyticshubpb.GetDataExchangeRequest, ...) (*analyticshubpb.DataExchange, error)

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

+ func (c *Client) GetListing(ctx context.Context, req *analyticshubpb.GetListingRequest, ...) (*analyticshubpb.Listing, error)

+ func (c *Client) ListDataExchanges(ctx context.Context, req *analyticshubpb.ListDataExchangesRequest, ...) *DataExchangeIterator

+ func (c *Client) ListListings(ctx context.Context, req *analyticshubpb.ListListingsRequest, ...) *ListingIterator

+ func (c *Client) ListOrgDataExchanges(ctx context.Context, req *analyticshubpb.ListOrgDataExchangesRequest, ...) *DataExchangeIterator

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

+ func (c *Client) SubscribeListing(ctx context.Context, req *analyticshubpb.SubscribeListingRequest, ...) (*analyticshubpb.SubscribeListingResponse, error)

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

+ func (c *Client) UpdateDataExchange(ctx context.Context, req *analyticshubpb.UpdateDataExchangeRequest, ...) (*analyticshubpb.DataExchange, error)

+ func (c *Client) UpdateListing(ctx context.Context, req *analyticshubpb.UpdateListingRequest, ...) (*analyticshubpb.Listing, error)

+ type DataExchangeIterator struct

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

+ Response interface{}

+ func (it *DataExchangeIterator) Next() (*analyticshubpb.DataExchange, error)

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

+ type ListingIterator struct

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

+ Response interface{}

+ func (it *ListingIterator) Next() (*analyticshubpb.Listing, error)

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