analyticshubpb

Jul 22, 2024

Changes in this version

+ var DiscoveryType_name = map[int32]string

+ var DiscoveryType_value = map[string]int32

type DataExchange

+ DiscoveryType *DiscoveryType

+ func (x *DataExchange) GetDiscoveryType() DiscoveryType

+ type DiscoveryType int32

+ const DiscoveryType_DISCOVERY_TYPE_PRIVATE

+ const DiscoveryType_DISCOVERY_TYPE_PUBLIC

+ const DiscoveryType_DISCOVERY_TYPE_UNSPECIFIED

+ func (DiscoveryType) Descriptor() protoreflect.EnumDescriptor

+ func (DiscoveryType) EnumDescriptor() ([]byte, []int)

+ func (DiscoveryType) Type() protoreflect.EnumType

+ func (x DiscoveryType) Enum() *DiscoveryType

+ func (x DiscoveryType) Number() protoreflect.EnumNumber

+ func (x DiscoveryType) String() string

type Listing

+ DiscoveryType *DiscoveryType

+ func (x *Listing) GetDiscoveryType() DiscoveryType

type Listing_BigQueryDatasetSource

+ RestrictedExportPolicy *Listing_BigQueryDatasetSource_RestrictedExportPolicy

+ func (x *Listing_BigQueryDatasetSource) GetRestrictedExportPolicy() *Listing_BigQueryDatasetSource_RestrictedExportPolicy

+ type Listing_BigQueryDatasetSource_RestrictedExportPolicy struct

+ Enabled *wrapperspb.BoolValue

+ RestrictDirectTableAccess *wrapperspb.BoolValue

+ RestrictQueryResult *wrapperspb.BoolValue

+ func (*Listing_BigQueryDatasetSource_RestrictedExportPolicy) Descriptor() ([]byte, []int)

+ func (*Listing_BigQueryDatasetSource_RestrictedExportPolicy) ProtoMessage()

+ func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) GetEnabled() *wrapperspb.BoolValue

+ func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) GetRestrictDirectTableAccess() *wrapperspb.BoolValue

+ func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) GetRestrictQueryResult() *wrapperspb.BoolValue

+ func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) ProtoReflect() protoreflect.Message

+ func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) Reset()

+ func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) String() string

Mar 27, 2024

Changes in this version

type Listing_BigQueryDatasetSource

+ SelectedResources []*Listing_BigQueryDatasetSource_SelectedResource

+ func (x *Listing_BigQueryDatasetSource) GetSelectedResources() []*Listing_BigQueryDatasetSource_SelectedResource

+ type Listing_BigQueryDatasetSource_SelectedResource struct

+ Resource isListing_BigQueryDatasetSource_SelectedResource_Resource

+ func (*Listing_BigQueryDatasetSource_SelectedResource) Descriptor() ([]byte, []int)

+ func (*Listing_BigQueryDatasetSource_SelectedResource) ProtoMessage()

+ func (m *Listing_BigQueryDatasetSource_SelectedResource) GetResource() isListing_BigQueryDatasetSource_SelectedResource_Resource

+ func (x *Listing_BigQueryDatasetSource_SelectedResource) GetTable() string

+ func (x *Listing_BigQueryDatasetSource_SelectedResource) ProtoReflect() protoreflect.Message

+ func (x *Listing_BigQueryDatasetSource_SelectedResource) Reset()

+ func (x *Listing_BigQueryDatasetSource_SelectedResource) String() string

+ type Listing_BigQueryDatasetSource_SelectedResource_Table struct

+ Table string

type SharingEnvironmentConfig_DcrExchangeConfig

+ SingleLinkedDatasetPerCleanroom *bool

+ SingleSelectedResourceSharingRestriction *bool

+ func (x *SharingEnvironmentConfig_DcrExchangeConfig) GetSingleLinkedDatasetPerCleanroom() bool

+ func (x *SharingEnvironmentConfig_DcrExchangeConfig) GetSingleSelectedResourceSharingRestriction() bool

Oct 5, 2023

Changes in this version

+ var Subscription_State_name = map[int32]string

+ var Subscription_State_value = map[string]int32

type AnalyticsHubServiceClient

+ DeleteSubscription func(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)

+ GetSubscription func(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error)

+ ListSharedResourceSubscriptions func(ctx context.Context, in *ListSharedResourceSubscriptionsRequest, ...) (*ListSharedResourceSubscriptionsResponse, error)

+ ListSubscriptions func(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error)

+ RefreshSubscription func(ctx context.Context, in *RefreshSubscriptionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)

+ RevokeSubscription func(ctx context.Context, in *RevokeSubscriptionRequest, opts ...grpc.CallOption) (*RevokeSubscriptionResponse, error)

+ SubscribeDataExchange func(ctx context.Context, in *SubscribeDataExchangeRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)

type AnalyticsHubServiceServer

+ DeleteSubscription func(context.Context, *DeleteSubscriptionRequest) (*longrunningpb.Operation, error)

+ GetSubscription func(context.Context, *GetSubscriptionRequest) (*Subscription, error)

+ ListSharedResourceSubscriptions func(context.Context, *ListSharedResourceSubscriptionsRequest) (*ListSharedResourceSubscriptionsResponse, error)

+ ListSubscriptions func(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)

+ RefreshSubscription func(context.Context, *RefreshSubscriptionRequest) (*longrunningpb.Operation, error)

+ RevokeSubscription func(context.Context, *RevokeSubscriptionRequest) (*RevokeSubscriptionResponse, error)

+ SubscribeDataExchange func(context.Context, *SubscribeDataExchangeRequest) (*longrunningpb.Operation, error)

type DataExchange

+ SharingEnvironmentConfig *SharingEnvironmentConfig

+ func (x *DataExchange) GetSharingEnvironmentConfig() *SharingEnvironmentConfig

+ type DeleteSubscriptionRequest struct

+ Name string

+ func (*DeleteSubscriptionRequest) Descriptor() ([]byte, []int)

+ func (*DeleteSubscriptionRequest) ProtoMessage()

+ func (x *DeleteSubscriptionRequest) GetName() string

+ func (x *DeleteSubscriptionRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteSubscriptionRequest) Reset()

+ func (x *DeleteSubscriptionRequest) String() string

+ type GetSubscriptionRequest struct

+ Name string

+ func (*GetSubscriptionRequest) Descriptor() ([]byte, []int)

+ func (*GetSubscriptionRequest) ProtoMessage()

+ func (x *GetSubscriptionRequest) GetName() string

+ func (x *GetSubscriptionRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSubscriptionRequest) Reset()

+ func (x *GetSubscriptionRequest) String() string

+ type ListSharedResourceSubscriptionsRequest struct

+ IncludeDeletedSubscriptions bool

+ PageSize int32

+ PageToken string

+ Resource string

+ func (*ListSharedResourceSubscriptionsRequest) Descriptor() ([]byte, []int)

+ func (*ListSharedResourceSubscriptionsRequest) ProtoMessage()

+ func (x *ListSharedResourceSubscriptionsRequest) GetIncludeDeletedSubscriptions() bool

+ func (x *ListSharedResourceSubscriptionsRequest) GetPageSize() int32

+ func (x *ListSharedResourceSubscriptionsRequest) GetPageToken() string

+ func (x *ListSharedResourceSubscriptionsRequest) GetResource() string

+ func (x *ListSharedResourceSubscriptionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListSharedResourceSubscriptionsRequest) Reset()

+ func (x *ListSharedResourceSubscriptionsRequest) String() string

+ type ListSharedResourceSubscriptionsResponse struct

+ NextPageToken string

+ SharedResourceSubscriptions []*Subscription

+ func (*ListSharedResourceSubscriptionsResponse) Descriptor() ([]byte, []int)

+ func (*ListSharedResourceSubscriptionsResponse) ProtoMessage()

+ func (x *ListSharedResourceSubscriptionsResponse) GetNextPageToken() string

+ func (x *ListSharedResourceSubscriptionsResponse) GetSharedResourceSubscriptions() []*Subscription

+ func (x *ListSharedResourceSubscriptionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListSharedResourceSubscriptionsResponse) Reset()

+ func (x *ListSharedResourceSubscriptionsResponse) String() string

+ type ListSubscriptionsRequest struct

+ Filter string

+ PageSize int32

+ PageToken string

+ Parent string

+ func (*ListSubscriptionsRequest) Descriptor() ([]byte, []int)

+ func (*ListSubscriptionsRequest) ProtoMessage()

+ func (x *ListSubscriptionsRequest) GetFilter() string

+ func (x *ListSubscriptionsRequest) GetPageSize() int32

+ func (x *ListSubscriptionsRequest) GetPageToken() string

+ func (x *ListSubscriptionsRequest) GetParent() string

+ func (x *ListSubscriptionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListSubscriptionsRequest) Reset()

+ func (x *ListSubscriptionsRequest) String() string

+ type ListSubscriptionsResponse struct

+ NextPageToken string

+ Subscriptions []*Subscription

+ func (*ListSubscriptionsResponse) Descriptor() ([]byte, []int)

+ func (*ListSubscriptionsResponse) ProtoMessage()

+ func (x *ListSubscriptionsResponse) GetNextPageToken() string

+ func (x *ListSubscriptionsResponse) GetSubscriptions() []*Subscription

+ func (x *ListSubscriptionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListSubscriptionsResponse) Reset()

+ func (x *ListSubscriptionsResponse) String() string

type Listing

+ RestrictedExportConfig *Listing_RestrictedExportConfig

+ func (x *Listing) GetRestrictedExportConfig() *Listing_RestrictedExportConfig

+ type Listing_RestrictedExportConfig struct

+ Enabled bool

+ RestrictDirectTableAccess bool

+ RestrictQueryResult bool

+ func (*Listing_RestrictedExportConfig) Descriptor() ([]byte, []int)

+ func (*Listing_RestrictedExportConfig) ProtoMessage()

+ func (x *Listing_RestrictedExportConfig) GetEnabled() bool

+ func (x *Listing_RestrictedExportConfig) GetRestrictDirectTableAccess() bool

+ func (x *Listing_RestrictedExportConfig) GetRestrictQueryResult() bool

+ func (x *Listing_RestrictedExportConfig) ProtoReflect() protoreflect.Message

+ func (x *Listing_RestrictedExportConfig) Reset()

+ func (x *Listing_RestrictedExportConfig) String() string

+ type OperationMetadata struct

+ ApiVersion string

+ CreateTime *timestamppb.Timestamp

+ EndTime *timestamppb.Timestamp

+ RequestedCancellation bool

+ StatusMessage string

+ Target string

+ Verb string

+ func (*OperationMetadata) Descriptor() ([]byte, []int)

+ func (*OperationMetadata) ProtoMessage()

+ func (x *OperationMetadata) GetApiVersion() string

+ func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp

+ func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp

+ func (x *OperationMetadata) GetRequestedCancellation() bool

+ func (x *OperationMetadata) GetStatusMessage() string

+ func (x *OperationMetadata) GetTarget() string

+ func (x *OperationMetadata) GetVerb() string

+ func (x *OperationMetadata) ProtoReflect() protoreflect.Message

+ func (x *OperationMetadata) Reset()

+ func (x *OperationMetadata) String() string

+ type RefreshSubscriptionRequest struct

+ Name string

+ func (*RefreshSubscriptionRequest) Descriptor() ([]byte, []int)

+ func (*RefreshSubscriptionRequest) ProtoMessage()

+ func (x *RefreshSubscriptionRequest) GetName() string

+ func (x *RefreshSubscriptionRequest) ProtoReflect() protoreflect.Message

+ func (x *RefreshSubscriptionRequest) Reset()

+ func (x *RefreshSubscriptionRequest) String() string

+ type RefreshSubscriptionResponse struct

+ Subscription *Subscription

+ func (*RefreshSubscriptionResponse) Descriptor() ([]byte, []int)

+ func (*RefreshSubscriptionResponse) ProtoMessage()

+ func (x *RefreshSubscriptionResponse) GetSubscription() *Subscription

+ func (x *RefreshSubscriptionResponse) ProtoReflect() protoreflect.Message

+ func (x *RefreshSubscriptionResponse) Reset()

+ func (x *RefreshSubscriptionResponse) String() string

+ type RevokeSubscriptionRequest struct

+ Name string

+ func (*RevokeSubscriptionRequest) Descriptor() ([]byte, []int)

+ func (*RevokeSubscriptionRequest) ProtoMessage()

+ func (x *RevokeSubscriptionRequest) GetName() string

+ func (x *RevokeSubscriptionRequest) ProtoReflect() protoreflect.Message

+ func (x *RevokeSubscriptionRequest) Reset()

+ func (x *RevokeSubscriptionRequest) String() string

+ type RevokeSubscriptionResponse struct

+ func (*RevokeSubscriptionResponse) Descriptor() ([]byte, []int)

+ func (*RevokeSubscriptionResponse) ProtoMessage()

+ func (x *RevokeSubscriptionResponse) ProtoReflect() protoreflect.Message

+ func (x *RevokeSubscriptionResponse) Reset()

+ func (x *RevokeSubscriptionResponse) String() string

+ type SharingEnvironmentConfig struct

+ Environment isSharingEnvironmentConfig_Environment

+ func (*SharingEnvironmentConfig) Descriptor() ([]byte, []int)

+ func (*SharingEnvironmentConfig) ProtoMessage()

+ func (m *SharingEnvironmentConfig) GetEnvironment() isSharingEnvironmentConfig_Environment

+ func (x *SharingEnvironmentConfig) GetDcrExchangeConfig() *SharingEnvironmentConfig_DcrExchangeConfig

+ func (x *SharingEnvironmentConfig) GetDefaultExchangeConfig() *SharingEnvironmentConfig_DefaultExchangeConfig

+ func (x *SharingEnvironmentConfig) ProtoReflect() protoreflect.Message

+ func (x *SharingEnvironmentConfig) Reset()

+ func (x *SharingEnvironmentConfig) String() string

+ type SharingEnvironmentConfig_DcrExchangeConfig struct

+ func (*SharingEnvironmentConfig_DcrExchangeConfig) Descriptor() ([]byte, []int)

+ func (*SharingEnvironmentConfig_DcrExchangeConfig) ProtoMessage()

+ func (x *SharingEnvironmentConfig_DcrExchangeConfig) ProtoReflect() protoreflect.Message

+ func (x *SharingEnvironmentConfig_DcrExchangeConfig) Reset()

+ func (x *SharingEnvironmentConfig_DcrExchangeConfig) String() string

+ type SharingEnvironmentConfig_DcrExchangeConfig_ struct

+ DcrExchangeConfig *SharingEnvironmentConfig_DcrExchangeConfig

+ type SharingEnvironmentConfig_DefaultExchangeConfig struct

+ func (*SharingEnvironmentConfig_DefaultExchangeConfig) Descriptor() ([]byte, []int)

+ func (*SharingEnvironmentConfig_DefaultExchangeConfig) ProtoMessage()

+ func (x *SharingEnvironmentConfig_DefaultExchangeConfig) ProtoReflect() protoreflect.Message

+ func (x *SharingEnvironmentConfig_DefaultExchangeConfig) Reset()

+ func (x *SharingEnvironmentConfig_DefaultExchangeConfig) String() string

+ type SharingEnvironmentConfig_DefaultExchangeConfig_ struct

+ DefaultExchangeConfig *SharingEnvironmentConfig_DefaultExchangeConfig

+ type SubscribeDataExchangeRequest struct

+ Destination string

+ Name string

+ SubscriberContact string

+ Subscription string

+ func (*SubscribeDataExchangeRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeDataExchangeRequest) ProtoMessage()

+ func (x *SubscribeDataExchangeRequest) GetDestination() string

+ func (x *SubscribeDataExchangeRequest) GetName() string

+ func (x *SubscribeDataExchangeRequest) GetSubscriberContact() string

+ func (x *SubscribeDataExchangeRequest) GetSubscription() string

+ func (x *SubscribeDataExchangeRequest) ProtoReflect() protoreflect.Message

+ func (x *SubscribeDataExchangeRequest) Reset()

+ func (x *SubscribeDataExchangeRequest) String() string

+ type SubscribeDataExchangeResponse struct

+ Subscription *Subscription

+ func (*SubscribeDataExchangeResponse) Descriptor() ([]byte, []int)

+ func (*SubscribeDataExchangeResponse) ProtoMessage()

+ func (x *SubscribeDataExchangeResponse) GetSubscription() *Subscription

+ func (x *SubscribeDataExchangeResponse) ProtoReflect() protoreflect.Message

+ func (x *SubscribeDataExchangeResponse) Reset()

+ func (x *SubscribeDataExchangeResponse) String() string

type SubscribeListingResponse

+ Subscription *Subscription

+ func (x *SubscribeListingResponse) GetSubscription() *Subscription

+ type Subscription struct

+ CreationTime *timestamppb.Timestamp

+ LastModifyTime *timestamppb.Timestamp

+ LinkedDatasetMap map[string]*Subscription_LinkedResource

+ Name string

+ OrganizationDisplayName string

+ OrganizationId string

+ ResourceName isSubscription_ResourceName

+ State Subscription_State

+ SubscriberContact string

+ func (*Subscription) Descriptor() ([]byte, []int)

+ func (*Subscription) ProtoMessage()

+ func (m *Subscription) GetResourceName() isSubscription_ResourceName

+ func (x *Subscription) GetCreationTime() *timestamppb.Timestamp

+ func (x *Subscription) GetDataExchange() string

+ func (x *Subscription) GetLastModifyTime() *timestamppb.Timestamp

+ func (x *Subscription) GetLinkedDatasetMap() map[string]*Subscription_LinkedResource

+ func (x *Subscription) GetListing() string

+ func (x *Subscription) GetName() string

+ func (x *Subscription) GetOrganizationDisplayName() string

+ func (x *Subscription) GetOrganizationId() string

+ func (x *Subscription) GetState() Subscription_State

+ func (x *Subscription) GetSubscriberContact() string

+ func (x *Subscription) ProtoReflect() protoreflect.Message

+ func (x *Subscription) Reset()

+ func (x *Subscription) String() string

+ type Subscription_DataExchange struct

+ DataExchange string

+ type Subscription_LinkedResource struct

+ Reference isSubscription_LinkedResource_Reference

+ func (*Subscription_LinkedResource) Descriptor() ([]byte, []int)

+ func (*Subscription_LinkedResource) ProtoMessage()

+ func (m *Subscription_LinkedResource) GetReference() isSubscription_LinkedResource_Reference

+ func (x *Subscription_LinkedResource) GetLinkedDataset() string

+ func (x *Subscription_LinkedResource) ProtoReflect() protoreflect.Message

+ func (x *Subscription_LinkedResource) Reset()

+ func (x *Subscription_LinkedResource) String() string

+ type Subscription_LinkedResource_LinkedDataset struct

+ LinkedDataset string

+ type Subscription_Listing struct

+ Listing string

+ type Subscription_State int32

+ const Subscription_STATE_ACTIVE

+ const Subscription_STATE_INACTIVE

+ const Subscription_STATE_STALE

+ const Subscription_STATE_UNSPECIFIED

+ func (Subscription_State) Descriptor() protoreflect.EnumDescriptor

+ func (Subscription_State) EnumDescriptor() ([]byte, []int)

+ func (Subscription_State) Type() protoreflect.EnumType

+ func (x Subscription_State) Enum() *Subscription_State

+ func (x Subscription_State) Number() protoreflect.EnumNumber

+ func (x Subscription_State) String() string

type UnimplementedAnalyticsHubServiceServer

+ func (*UnimplementedAnalyticsHubServiceServer) DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*longrunningpb.Operation, error)

+ func (*UnimplementedAnalyticsHubServiceServer) GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error)

+ func (*UnimplementedAnalyticsHubServiceServer) ListSharedResourceSubscriptions(context.Context, *ListSharedResourceSubscriptionsRequest) (*ListSharedResourceSubscriptionsResponse, error)

+ func (*UnimplementedAnalyticsHubServiceServer) ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)

+ func (*UnimplementedAnalyticsHubServiceServer) RefreshSubscription(context.Context, *RefreshSubscriptionRequest) (*longrunningpb.Operation, error)

+ func (*UnimplementedAnalyticsHubServiceServer) RevokeSubscription(context.Context, *RevokeSubscriptionRequest) (*RevokeSubscriptionResponse, error)

+ func (*UnimplementedAnalyticsHubServiceServer) SubscribeDataExchange(context.Context, *SubscribeDataExchangeRequest) (*longrunningpb.Operation, error)

Sep 21, 2022

Changes in this version

+ var File_google_cloud_bigquery_analyticshub_v1_analyticshub_proto protoreflect.FileDescriptor

+ var Listing_Category_name = map[int32]string

+ var Listing_Category_value = map[string]int32

+ var Listing_State_name = map[int32]string

+ var Listing_State_value = map[string]int32

+ func RegisterAnalyticsHubServiceServer(s *grpc.Server, srv AnalyticsHubServiceServer)

+ type AnalyticsHubServiceClient interface

+ CreateDataExchange func(ctx context.Context, in *CreateDataExchangeRequest, opts ...grpc.CallOption) (*DataExchange, error)

+ CreateListing func(ctx context.Context, in *CreateListingRequest, opts ...grpc.CallOption) (*Listing, error)

+ DeleteDataExchange func(ctx context.Context, in *DeleteDataExchangeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DeleteListing func(ctx context.Context, in *DeleteListingRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetDataExchange func(ctx context.Context, in *GetDataExchangeRequest, opts ...grpc.CallOption) (*DataExchange, error)

+ GetIamPolicy func(ctx context.Context, in *v1.GetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error)

+ GetListing func(ctx context.Context, in *GetListingRequest, opts ...grpc.CallOption) (*Listing, error)

+ ListDataExchanges func(ctx context.Context, in *ListDataExchangesRequest, opts ...grpc.CallOption) (*ListDataExchangesResponse, error)

+ ListListings func(ctx context.Context, in *ListListingsRequest, opts ...grpc.CallOption) (*ListListingsResponse, error)

+ ListOrgDataExchanges func(ctx context.Context, in *ListOrgDataExchangesRequest, opts ...grpc.CallOption) (*ListOrgDataExchangesResponse, error)

+ SetIamPolicy func(ctx context.Context, in *v1.SetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error)

+ SubscribeListing func(ctx context.Context, in *SubscribeListingRequest, opts ...grpc.CallOption) (*SubscribeListingResponse, error)

+ TestIamPermissions func(ctx context.Context, in *v1.TestIamPermissionsRequest, opts ...grpc.CallOption) (*v1.TestIamPermissionsResponse, error)

+ UpdateDataExchange func(ctx context.Context, in *UpdateDataExchangeRequest, opts ...grpc.CallOption) (*DataExchange, error)

+ UpdateListing func(ctx context.Context, in *UpdateListingRequest, opts ...grpc.CallOption) (*Listing, error)

+ func NewAnalyticsHubServiceClient(cc grpc.ClientConnInterface) AnalyticsHubServiceClient

+ type AnalyticsHubServiceServer interface

+ CreateDataExchange func(context.Context, *CreateDataExchangeRequest) (*DataExchange, error)

+ CreateListing func(context.Context, *CreateListingRequest) (*Listing, error)

+ DeleteDataExchange func(context.Context, *DeleteDataExchangeRequest) (*emptypb.Empty, error)

+ DeleteListing func(context.Context, *DeleteListingRequest) (*emptypb.Empty, error)

+ GetDataExchange func(context.Context, *GetDataExchangeRequest) (*DataExchange, error)

+ GetIamPolicy func(context.Context, *v1.GetIamPolicyRequest) (*v1.Policy, error)

+ GetListing func(context.Context, *GetListingRequest) (*Listing, error)

+ ListDataExchanges func(context.Context, *ListDataExchangesRequest) (*ListDataExchangesResponse, error)

+ ListListings func(context.Context, *ListListingsRequest) (*ListListingsResponse, error)

+ ListOrgDataExchanges func(context.Context, *ListOrgDataExchangesRequest) (*ListOrgDataExchangesResponse, error)

+ SetIamPolicy func(context.Context, *v1.SetIamPolicyRequest) (*v1.Policy, error)

+ SubscribeListing func(context.Context, *SubscribeListingRequest) (*SubscribeListingResponse, error)

+ TestIamPermissions func(context.Context, *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error)

+ UpdateDataExchange func(context.Context, *UpdateDataExchangeRequest) (*DataExchange, error)

+ UpdateListing func(context.Context, *UpdateListingRequest) (*Listing, error)

+ type CreateDataExchangeRequest struct

+ DataExchange *DataExchange

+ DataExchangeId string

+ Parent string

+ func (*CreateDataExchangeRequest) Descriptor() ([]byte, []int)

+ func (*CreateDataExchangeRequest) ProtoMessage()

+ func (x *CreateDataExchangeRequest) GetDataExchange() *DataExchange

+ func (x *CreateDataExchangeRequest) GetDataExchangeId() string

+ func (x *CreateDataExchangeRequest) GetParent() string

+ func (x *CreateDataExchangeRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateDataExchangeRequest) Reset()

+ func (x *CreateDataExchangeRequest) String() string

+ type CreateListingRequest struct

+ Listing *Listing

+ ListingId string

+ Parent string

+ func (*CreateListingRequest) Descriptor() ([]byte, []int)

+ func (*CreateListingRequest) ProtoMessage()

+ func (x *CreateListingRequest) GetListing() *Listing

+ func (x *CreateListingRequest) GetListingId() string

+ func (x *CreateListingRequest) GetParent() string

+ func (x *CreateListingRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateListingRequest) Reset()

+ func (x *CreateListingRequest) String() string

+ type DataExchange struct

+ Description string

+ DisplayName string

+ Documentation string

+ Icon []byte

+ ListingCount int32

+ Name string

+ PrimaryContact string

+ func (*DataExchange) Descriptor() ([]byte, []int)

+ func (*DataExchange) ProtoMessage()

+ func (x *DataExchange) GetDescription() string

+ func (x *DataExchange) GetDisplayName() string

+ func (x *DataExchange) GetDocumentation() string

+ func (x *DataExchange) GetIcon() []byte

+ func (x *DataExchange) GetListingCount() int32

+ func (x *DataExchange) GetName() string

+ func (x *DataExchange) GetPrimaryContact() string

+ func (x *DataExchange) ProtoReflect() protoreflect.Message

+ func (x *DataExchange) Reset()

+ func (x *DataExchange) String() string

+ type DataProvider struct

+ Name string

+ PrimaryContact string

+ func (*DataProvider) Descriptor() ([]byte, []int)

+ func (*DataProvider) ProtoMessage()

+ func (x *DataProvider) GetName() string

+ func (x *DataProvider) GetPrimaryContact() string

+ func (x *DataProvider) ProtoReflect() protoreflect.Message

+ func (x *DataProvider) Reset()

+ func (x *DataProvider) String() string

+ type DeleteDataExchangeRequest struct

+ Name string

+ func (*DeleteDataExchangeRequest) Descriptor() ([]byte, []int)

+ func (*DeleteDataExchangeRequest) ProtoMessage()

+ func (x *DeleteDataExchangeRequest) GetName() string

+ func (x *DeleteDataExchangeRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteDataExchangeRequest) Reset()

+ func (x *DeleteDataExchangeRequest) String() string

+ type DeleteListingRequest struct

+ Name string

+ func (*DeleteListingRequest) Descriptor() ([]byte, []int)

+ func (*DeleteListingRequest) ProtoMessage()

+ func (x *DeleteListingRequest) GetName() string

+ func (x *DeleteListingRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteListingRequest) Reset()

+ func (x *DeleteListingRequest) String() string

+ type DestinationDataset struct

+ DatasetReference *DestinationDatasetReference

+ Description *wrapperspb.StringValue

+ FriendlyName *wrapperspb.StringValue

+ Labels map[string]string

+ Location string

+ func (*DestinationDataset) Descriptor() ([]byte, []int)

+ func (*DestinationDataset) ProtoMessage()

+ func (x *DestinationDataset) GetDatasetReference() *DestinationDatasetReference

+ func (x *DestinationDataset) GetDescription() *wrapperspb.StringValue

+ func (x *DestinationDataset) GetFriendlyName() *wrapperspb.StringValue

+ func (x *DestinationDataset) GetLabels() map[string]string

+ func (x *DestinationDataset) GetLocation() string

+ func (x *DestinationDataset) ProtoReflect() protoreflect.Message

+ func (x *DestinationDataset) Reset()

+ func (x *DestinationDataset) String() string

+ type DestinationDatasetReference struct

+ DatasetId string

+ ProjectId string

+ func (*DestinationDatasetReference) Descriptor() ([]byte, []int)

+ func (*DestinationDatasetReference) ProtoMessage()

+ func (x *DestinationDatasetReference) GetDatasetId() string

+ func (x *DestinationDatasetReference) GetProjectId() string

+ func (x *DestinationDatasetReference) ProtoReflect() protoreflect.Message

+ func (x *DestinationDatasetReference) Reset()

+ func (x *DestinationDatasetReference) String() string

+ type GetDataExchangeRequest struct

+ Name string

+ func (*GetDataExchangeRequest) Descriptor() ([]byte, []int)

+ func (*GetDataExchangeRequest) ProtoMessage()

+ func (x *GetDataExchangeRequest) GetName() string

+ func (x *GetDataExchangeRequest) ProtoReflect() protoreflect.Message

+ func (x *GetDataExchangeRequest) Reset()

+ func (x *GetDataExchangeRequest) String() string

+ type GetListingRequest struct

+ Name string

+ func (*GetListingRequest) Descriptor() ([]byte, []int)

+ func (*GetListingRequest) ProtoMessage()

+ func (x *GetListingRequest) GetName() string

+ func (x *GetListingRequest) ProtoReflect() protoreflect.Message

+ func (x *GetListingRequest) Reset()

+ func (x *GetListingRequest) String() string

+ type ListDataExchangesRequest struct

+ PageSize int32

+ PageToken string

+ Parent string

+ func (*ListDataExchangesRequest) Descriptor() ([]byte, []int)

+ func (*ListDataExchangesRequest) ProtoMessage()

+ func (x *ListDataExchangesRequest) GetPageSize() int32

+ func (x *ListDataExchangesRequest) GetPageToken() string

+ func (x *ListDataExchangesRequest) GetParent() string

+ func (x *ListDataExchangesRequest) ProtoReflect() protoreflect.Message

+ func (x *ListDataExchangesRequest) Reset()

+ func (x *ListDataExchangesRequest) String() string

+ type ListDataExchangesResponse struct

+ DataExchanges []*DataExchange

+ NextPageToken string

+ func (*ListDataExchangesResponse) Descriptor() ([]byte, []int)

+ func (*ListDataExchangesResponse) ProtoMessage()

+ func (x *ListDataExchangesResponse) GetDataExchanges() []*DataExchange

+ func (x *ListDataExchangesResponse) GetNextPageToken() string

+ func (x *ListDataExchangesResponse) ProtoReflect() protoreflect.Message

+ func (x *ListDataExchangesResponse) Reset()

+ func (x *ListDataExchangesResponse) String() string

+ type ListListingsRequest struct

+ PageSize int32

+ PageToken string

+ Parent string

+ func (*ListListingsRequest) Descriptor() ([]byte, []int)

+ func (*ListListingsRequest) ProtoMessage()

+ func (x *ListListingsRequest) GetPageSize() int32

+ func (x *ListListingsRequest) GetPageToken() string

+ func (x *ListListingsRequest) GetParent() string

+ func (x *ListListingsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListListingsRequest) Reset()

+ func (x *ListListingsRequest) String() string

+ type ListListingsResponse struct

+ Listings []*Listing

+ NextPageToken string

+ func (*ListListingsResponse) Descriptor() ([]byte, []int)

+ func (*ListListingsResponse) ProtoMessage()

+ func (x *ListListingsResponse) GetListings() []*Listing

+ func (x *ListListingsResponse) GetNextPageToken() string

+ func (x *ListListingsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListListingsResponse) Reset()

+ func (x *ListListingsResponse) String() string

+ type ListOrgDataExchangesRequest struct

+ Organization string

+ PageSize int32

+ PageToken string

+ func (*ListOrgDataExchangesRequest) Descriptor() ([]byte, []int)

+ func (*ListOrgDataExchangesRequest) ProtoMessage()

+ func (x *ListOrgDataExchangesRequest) GetOrganization() string

+ func (x *ListOrgDataExchangesRequest) GetPageSize() int32

+ func (x *ListOrgDataExchangesRequest) GetPageToken() string

+ func (x *ListOrgDataExchangesRequest) ProtoReflect() protoreflect.Message

+ func (x *ListOrgDataExchangesRequest) Reset()

+ func (x *ListOrgDataExchangesRequest) String() string

+ type ListOrgDataExchangesResponse struct

+ DataExchanges []*DataExchange

+ NextPageToken string

+ func (*ListOrgDataExchangesResponse) Descriptor() ([]byte, []int)

+ func (*ListOrgDataExchangesResponse) ProtoMessage()

+ func (x *ListOrgDataExchangesResponse) GetDataExchanges() []*DataExchange

+ func (x *ListOrgDataExchangesResponse) GetNextPageToken() string

+ func (x *ListOrgDataExchangesResponse) ProtoReflect() protoreflect.Message

+ func (x *ListOrgDataExchangesResponse) Reset()

+ func (x *ListOrgDataExchangesResponse) String() string

+ type Listing struct

+ Categories []Listing_Category

+ DataProvider *DataProvider

+ Description string

+ DisplayName string

+ Documentation string

+ Icon []byte

+ Name string

+ PrimaryContact string

+ Publisher *Publisher

+ RequestAccess string

+ Source isListing_Source

+ State Listing_State

+ func (*Listing) Descriptor() ([]byte, []int)

+ func (*Listing) ProtoMessage()

+ func (m *Listing) GetSource() isListing_Source

+ func (x *Listing) GetBigqueryDataset() *Listing_BigQueryDatasetSource

+ func (x *Listing) GetCategories() []Listing_Category

+ func (x *Listing) GetDataProvider() *DataProvider

+ func (x *Listing) GetDescription() string

+ func (x *Listing) GetDisplayName() string

+ func (x *Listing) GetDocumentation() string

+ func (x *Listing) GetIcon() []byte

+ func (x *Listing) GetName() string

+ func (x *Listing) GetPrimaryContact() string

+ func (x *Listing) GetPublisher() *Publisher

+ func (x *Listing) GetRequestAccess() string

+ func (x *Listing) GetState() Listing_State

+ func (x *Listing) ProtoReflect() protoreflect.Message

+ func (x *Listing) Reset()

+ func (x *Listing) String() string

+ type Listing_BigQueryDatasetSource struct

+ Dataset string

+ func (*Listing_BigQueryDatasetSource) Descriptor() ([]byte, []int)

+ func (*Listing_BigQueryDatasetSource) ProtoMessage()

+ func (x *Listing_BigQueryDatasetSource) GetDataset() string

+ func (x *Listing_BigQueryDatasetSource) ProtoReflect() protoreflect.Message

+ func (x *Listing_BigQueryDatasetSource) Reset()

+ func (x *Listing_BigQueryDatasetSource) String() string

+ type Listing_BigqueryDataset struct

+ BigqueryDataset *Listing_BigQueryDatasetSource

+ type Listing_Category int32

+ const Listing_CATEGORY_ADVERTISING_AND_MARKETING

+ const Listing_CATEGORY_CLIMATE_AND_ENVIRONMENT

+ const Listing_CATEGORY_COMMERCE

+ const Listing_CATEGORY_DEMOGRAPHICS

+ const Listing_CATEGORY_ECONOMICS

+ const Listing_CATEGORY_EDUCATION

+ const Listing_CATEGORY_ENERGY

+ const Listing_CATEGORY_FINANCIAL

+ const Listing_CATEGORY_GAMING

+ const Listing_CATEGORY_GEOSPATIAL

+ const Listing_CATEGORY_HEALTHCARE_AND_LIFE_SCIENCE

+ const Listing_CATEGORY_MEDIA

+ const Listing_CATEGORY_OTHERS

+ const Listing_CATEGORY_PUBLIC_SECTOR

+ const Listing_CATEGORY_RETAIL

+ const Listing_CATEGORY_SCIENCE_AND_RESEARCH

+ const Listing_CATEGORY_SPORTS

+ const Listing_CATEGORY_TRANSPORTATION_AND_LOGISTICS

+ const Listing_CATEGORY_TRAVEL_AND_TOURISM

+ const Listing_CATEGORY_UNSPECIFIED

+ func (Listing_Category) Descriptor() protoreflect.EnumDescriptor

+ func (Listing_Category) EnumDescriptor() ([]byte, []int)

+ func (Listing_Category) Type() protoreflect.EnumType

+ func (x Listing_Category) Enum() *Listing_Category

+ func (x Listing_Category) Number() protoreflect.EnumNumber

+ func (x Listing_Category) String() string

+ type Listing_State int32

+ const Listing_ACTIVE

+ const Listing_STATE_UNSPECIFIED

+ func (Listing_State) Descriptor() protoreflect.EnumDescriptor

+ func (Listing_State) EnumDescriptor() ([]byte, []int)

+ func (Listing_State) Type() protoreflect.EnumType

+ func (x Listing_State) Enum() *Listing_State

+ func (x Listing_State) Number() protoreflect.EnumNumber

+ func (x Listing_State) String() string

+ type Publisher struct

+ Name string

+ PrimaryContact string

+ func (*Publisher) Descriptor() ([]byte, []int)

+ func (*Publisher) ProtoMessage()

+ func (x *Publisher) GetName() string

+ func (x *Publisher) GetPrimaryContact() string

+ func (x *Publisher) ProtoReflect() protoreflect.Message

+ func (x *Publisher) Reset()

+ func (x *Publisher) String() string

+ type SubscribeListingRequest struct

+ Destination isSubscribeListingRequest_Destination

+ Name string

+ func (*SubscribeListingRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeListingRequest) ProtoMessage()

+ func (m *SubscribeListingRequest) GetDestination() isSubscribeListingRequest_Destination

+ func (x *SubscribeListingRequest) GetDestinationDataset() *DestinationDataset

+ func (x *SubscribeListingRequest) GetName() string

+ func (x *SubscribeListingRequest) ProtoReflect() protoreflect.Message

+ func (x *SubscribeListingRequest) Reset()

+ func (x *SubscribeListingRequest) String() string

+ type SubscribeListingRequest_DestinationDataset struct

+ DestinationDataset *DestinationDataset

+ type SubscribeListingResponse struct

+ func (*SubscribeListingResponse) Descriptor() ([]byte, []int)

+ func (*SubscribeListingResponse) ProtoMessage()

+ func (x *SubscribeListingResponse) ProtoReflect() protoreflect.Message

+ func (x *SubscribeListingResponse) Reset()

+ func (x *SubscribeListingResponse) String() string

+ type UnimplementedAnalyticsHubServiceServer struct

+ func (*UnimplementedAnalyticsHubServiceServer) CreateDataExchange(context.Context, *CreateDataExchangeRequest) (*DataExchange, error)

+ func (*UnimplementedAnalyticsHubServiceServer) CreateListing(context.Context, *CreateListingRequest) (*Listing, error)

+ func (*UnimplementedAnalyticsHubServiceServer) DeleteDataExchange(context.Context, *DeleteDataExchangeRequest) (*emptypb.Empty, error)

+ func (*UnimplementedAnalyticsHubServiceServer) DeleteListing(context.Context, *DeleteListingRequest) (*emptypb.Empty, error)

+ func (*UnimplementedAnalyticsHubServiceServer) GetDataExchange(context.Context, *GetDataExchangeRequest) (*DataExchange, error)

+ func (*UnimplementedAnalyticsHubServiceServer) GetIamPolicy(context.Context, *v1.GetIamPolicyRequest) (*v1.Policy, error)

+ func (*UnimplementedAnalyticsHubServiceServer) GetListing(context.Context, *GetListingRequest) (*Listing, error)

+ func (*UnimplementedAnalyticsHubServiceServer) ListDataExchanges(context.Context, *ListDataExchangesRequest) (*ListDataExchangesResponse, error)

+ func (*UnimplementedAnalyticsHubServiceServer) ListListings(context.Context, *ListListingsRequest) (*ListListingsResponse, error)

+ func (*UnimplementedAnalyticsHubServiceServer) ListOrgDataExchanges(context.Context, *ListOrgDataExchangesRequest) (*ListOrgDataExchangesResponse, error)

+ func (*UnimplementedAnalyticsHubServiceServer) SetIamPolicy(context.Context, *v1.SetIamPolicyRequest) (*v1.Policy, error)

+ func (*UnimplementedAnalyticsHubServiceServer) SubscribeListing(context.Context, *SubscribeListingRequest) (*SubscribeListingResponse, error)

+ func (*UnimplementedAnalyticsHubServiceServer) TestIamPermissions(context.Context, *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error)

+ func (*UnimplementedAnalyticsHubServiceServer) UpdateDataExchange(context.Context, *UpdateDataExchangeRequest) (*DataExchange, error)

+ func (*UnimplementedAnalyticsHubServiceServer) UpdateListing(context.Context, *UpdateListingRequest) (*Listing, error)

+ type UpdateDataExchangeRequest struct

+ DataExchange *DataExchange

+ UpdateMask *fieldmaskpb.FieldMask

+ func (*UpdateDataExchangeRequest) Descriptor() ([]byte, []int)

+ func (*UpdateDataExchangeRequest) ProtoMessage()

+ func (x *UpdateDataExchangeRequest) GetDataExchange() *DataExchange

+ func (x *UpdateDataExchangeRequest) GetUpdateMask() *fieldmaskpb.FieldMask

+ func (x *UpdateDataExchangeRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateDataExchangeRequest) Reset()

+ func (x *UpdateDataExchangeRequest) String() string

+ type UpdateListingRequest struct

+ Listing *Listing

+ UpdateMask *fieldmaskpb.FieldMask

+ func (*UpdateListingRequest) Descriptor() ([]byte, []int)

+ func (*UpdateListingRequest) ProtoMessage()

+ func (x *UpdateListingRequest) GetListing() *Listing

+ func (x *UpdateListingRequest) GetUpdateMask() *fieldmaskpb.FieldMask

+ func (x *UpdateListingRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateListingRequest) Reset()

+ func (x *UpdateListingRequest) String() string