Documentation
¶
Overview ¶
Package analyticshubpb is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterAnalyticsHubServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterAnalyticsHubServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AnalyticsHubServiceClient) error
- func RegisterAnalyticsHubServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterAnalyticsHubServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AnalyticsHubServiceServer) error
- func RegisterAnalyticsHubServiceServer(s grpc.ServiceRegistrar, srv AnalyticsHubServiceServer)
- type AnalyticsHubServiceClient
- type AnalyticsHubServiceServer
- type CreateDataExchangeRequest
- func (*CreateDataExchangeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDataExchangeRequest) GetDataExchange() *DataExchange
- func (x *CreateDataExchangeRequest) GetDataExchangeId() string
- func (x *CreateDataExchangeRequest) GetParent() string
- func (*CreateDataExchangeRequest) ProtoMessage()
- func (x *CreateDataExchangeRequest) ProtoReflect() protoreflect.Message
- func (x *CreateDataExchangeRequest) Reset()
- func (x *CreateDataExchangeRequest) String() string
- type CreateListingRequest
- func (*CreateListingRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateListingRequest) GetListing() *Listing
- func (x *CreateListingRequest) GetListingId() string
- func (x *CreateListingRequest) GetParent() string
- func (*CreateListingRequest) ProtoMessage()
- func (x *CreateListingRequest) ProtoReflect() protoreflect.Message
- func (x *CreateListingRequest) Reset()
- func (x *CreateListingRequest) String() string
- type DataExchange
- func (*DataExchange) Descriptor() ([]byte, []int)deprecated
- func (x *DataExchange) GetDescription() string
- func (x *DataExchange) GetDiscoveryType() DiscoveryType
- 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) GetSharingEnvironmentConfig() *SharingEnvironmentConfig
- func (*DataExchange) ProtoMessage()
- func (x *DataExchange) ProtoReflect() protoreflect.Message
- func (x *DataExchange) Reset()
- func (x *DataExchange) String() string
- type DataProvider
- func (*DataProvider) Descriptor() ([]byte, []int)deprecated
- func (x *DataProvider) GetName() string
- func (x *DataProvider) GetPrimaryContact() string
- func (*DataProvider) ProtoMessage()
- func (x *DataProvider) ProtoReflect() protoreflect.Message
- func (x *DataProvider) Reset()
- func (x *DataProvider) String() string
- type DeleteDataExchangeRequest
- func (*DeleteDataExchangeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteDataExchangeRequest) GetName() string
- func (*DeleteDataExchangeRequest) ProtoMessage()
- func (x *DeleteDataExchangeRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteDataExchangeRequest) Reset()
- func (x *DeleteDataExchangeRequest) String() string
- type DeleteListingRequest
- func (*DeleteListingRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteListingRequest) GetName() string
- func (*DeleteListingRequest) ProtoMessage()
- func (x *DeleteListingRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteListingRequest) Reset()
- func (x *DeleteListingRequest) String() string
- type DeleteSubscriptionRequest
- func (*DeleteSubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSubscriptionRequest) GetName() string
- func (*DeleteSubscriptionRequest) ProtoMessage()
- func (x *DeleteSubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteSubscriptionRequest) Reset()
- func (x *DeleteSubscriptionRequest) String() string
- type DestinationDataset
- func (*DestinationDataset) Descriptor() ([]byte, []int)deprecated
- func (x *DestinationDataset) GetDatasetReference() *DestinationDatasetReference
- func (x *DestinationDataset) GetDescription() *wrappers.StringValue
- func (x *DestinationDataset) GetFriendlyName() *wrappers.StringValue
- func (x *DestinationDataset) GetLabels() map[string]string
- func (x *DestinationDataset) GetLocation() string
- func (*DestinationDataset) ProtoMessage()
- func (x *DestinationDataset) ProtoReflect() protoreflect.Message
- func (x *DestinationDataset) Reset()
- func (x *DestinationDataset) String() string
- type DestinationDatasetReference
- func (*DestinationDatasetReference) Descriptor() ([]byte, []int)deprecated
- func (x *DestinationDatasetReference) GetDatasetId() string
- func (x *DestinationDatasetReference) GetProjectId() string
- func (*DestinationDatasetReference) ProtoMessage()
- func (x *DestinationDatasetReference) ProtoReflect() protoreflect.Message
- func (x *DestinationDatasetReference) Reset()
- func (x *DestinationDatasetReference) String() string
- type DiscoveryType
- func (DiscoveryType) Descriptor() protoreflect.EnumDescriptor
- func (x DiscoveryType) Enum() *DiscoveryType
- func (DiscoveryType) EnumDescriptor() ([]byte, []int)deprecated
- func (x DiscoveryType) Number() protoreflect.EnumNumber
- func (x DiscoveryType) String() string
- func (DiscoveryType) Type() protoreflect.EnumType
- type GetDataExchangeRequest
- func (*GetDataExchangeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDataExchangeRequest) GetName() string
- func (*GetDataExchangeRequest) ProtoMessage()
- func (x *GetDataExchangeRequest) ProtoReflect() protoreflect.Message
- func (x *GetDataExchangeRequest) Reset()
- func (x *GetDataExchangeRequest) String() string
- type GetListingRequest
- type GetSubscriptionRequest
- func (*GetSubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSubscriptionRequest) GetName() string
- func (*GetSubscriptionRequest) ProtoMessage()
- func (x *GetSubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *GetSubscriptionRequest) Reset()
- func (x *GetSubscriptionRequest) String() string
- type ListDataExchangesRequest
- func (*ListDataExchangesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListDataExchangesRequest) GetPageSize() int32
- func (x *ListDataExchangesRequest) GetPageToken() string
- func (x *ListDataExchangesRequest) GetParent() string
- func (*ListDataExchangesRequest) ProtoMessage()
- func (x *ListDataExchangesRequest) ProtoReflect() protoreflect.Message
- func (x *ListDataExchangesRequest) Reset()
- func (x *ListDataExchangesRequest) String() string
- type ListDataExchangesResponse
- func (*ListDataExchangesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListDataExchangesResponse) GetDataExchanges() []*DataExchange
- func (x *ListDataExchangesResponse) GetNextPageToken() string
- func (*ListDataExchangesResponse) ProtoMessage()
- func (x *ListDataExchangesResponse) ProtoReflect() protoreflect.Message
- func (x *ListDataExchangesResponse) Reset()
- func (x *ListDataExchangesResponse) String() string
- type ListListingsRequest
- func (*ListListingsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListListingsRequest) GetPageSize() int32
- func (x *ListListingsRequest) GetPageToken() string
- func (x *ListListingsRequest) GetParent() string
- func (*ListListingsRequest) ProtoMessage()
- func (x *ListListingsRequest) ProtoReflect() protoreflect.Message
- func (x *ListListingsRequest) Reset()
- func (x *ListListingsRequest) String() string
- type ListListingsResponse
- func (*ListListingsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListListingsResponse) GetListings() []*Listing
- func (x *ListListingsResponse) GetNextPageToken() string
- func (*ListListingsResponse) ProtoMessage()
- func (x *ListListingsResponse) ProtoReflect() protoreflect.Message
- func (x *ListListingsResponse) Reset()
- func (x *ListListingsResponse) String() string
- type ListOrgDataExchangesRequest
- func (*ListOrgDataExchangesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListOrgDataExchangesRequest) GetOrganization() string
- func (x *ListOrgDataExchangesRequest) GetPageSize() int32
- func (x *ListOrgDataExchangesRequest) GetPageToken() string
- func (*ListOrgDataExchangesRequest) ProtoMessage()
- func (x *ListOrgDataExchangesRequest) ProtoReflect() protoreflect.Message
- func (x *ListOrgDataExchangesRequest) Reset()
- func (x *ListOrgDataExchangesRequest) String() string
- type ListOrgDataExchangesResponse
- func (*ListOrgDataExchangesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListOrgDataExchangesResponse) GetDataExchanges() []*DataExchange
- func (x *ListOrgDataExchangesResponse) GetNextPageToken() string
- func (*ListOrgDataExchangesResponse) ProtoMessage()
- func (x *ListOrgDataExchangesResponse) ProtoReflect() protoreflect.Message
- func (x *ListOrgDataExchangesResponse) Reset()
- func (x *ListOrgDataExchangesResponse) String() string
- type ListSharedResourceSubscriptionsRequest
- func (*ListSharedResourceSubscriptionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListSharedResourceSubscriptionsRequest) GetIncludeDeletedSubscriptions() bool
- func (x *ListSharedResourceSubscriptionsRequest) GetPageSize() int32
- func (x *ListSharedResourceSubscriptionsRequest) GetPageToken() string
- func (x *ListSharedResourceSubscriptionsRequest) GetResource() string
- func (*ListSharedResourceSubscriptionsRequest) ProtoMessage()
- func (x *ListSharedResourceSubscriptionsRequest) ProtoReflect() protoreflect.Message
- func (x *ListSharedResourceSubscriptionsRequest) Reset()
- func (x *ListSharedResourceSubscriptionsRequest) String() string
- type ListSharedResourceSubscriptionsResponse
- func (*ListSharedResourceSubscriptionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSharedResourceSubscriptionsResponse) GetNextPageToken() string
- func (x *ListSharedResourceSubscriptionsResponse) GetSharedResourceSubscriptions() []*Subscription
- func (*ListSharedResourceSubscriptionsResponse) ProtoMessage()
- func (x *ListSharedResourceSubscriptionsResponse) ProtoReflect() protoreflect.Message
- func (x *ListSharedResourceSubscriptionsResponse) Reset()
- func (x *ListSharedResourceSubscriptionsResponse) String() string
- type ListSubscriptionsRequest
- func (*ListSubscriptionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListSubscriptionsRequest) GetFilter() string
- func (x *ListSubscriptionsRequest) GetPageSize() int32
- func (x *ListSubscriptionsRequest) GetPageToken() string
- func (x *ListSubscriptionsRequest) GetParent() string
- func (*ListSubscriptionsRequest) ProtoMessage()
- func (x *ListSubscriptionsRequest) ProtoReflect() protoreflect.Message
- func (x *ListSubscriptionsRequest) Reset()
- func (x *ListSubscriptionsRequest) String() string
- type ListSubscriptionsResponse
- func (*ListSubscriptionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSubscriptionsResponse) GetNextPageToken() string
- func (x *ListSubscriptionsResponse) GetSubscriptions() []*Subscription
- func (*ListSubscriptionsResponse) ProtoMessage()
- func (x *ListSubscriptionsResponse) ProtoReflect() protoreflect.Message
- func (x *ListSubscriptionsResponse) Reset()
- func (x *ListSubscriptionsResponse) String() string
- type Listing
- func (*Listing) Descriptor() ([]byte, []int)deprecated
- 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) GetDiscoveryType() DiscoveryType
- 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) GetRestrictedExportConfig() *Listing_RestrictedExportConfig
- func (m *Listing) GetSource() isListing_Source
- func (x *Listing) GetState() Listing_State
- func (*Listing) ProtoMessage()
- func (x *Listing) ProtoReflect() protoreflect.Message
- func (x *Listing) Reset()
- func (x *Listing) String() string
- type Listing_BigQueryDatasetSource
- func (*Listing_BigQueryDatasetSource) Descriptor() ([]byte, []int)deprecated
- func (x *Listing_BigQueryDatasetSource) GetDataset() string
- func (x *Listing_BigQueryDatasetSource) GetRestrictedExportPolicy() *Listing_BigQueryDatasetSource_RestrictedExportPolicy
- func (x *Listing_BigQueryDatasetSource) GetSelectedResources() []*Listing_BigQueryDatasetSource_SelectedResource
- func (*Listing_BigQueryDatasetSource) ProtoMessage()
- func (x *Listing_BigQueryDatasetSource) ProtoReflect() protoreflect.Message
- func (x *Listing_BigQueryDatasetSource) Reset()
- func (x *Listing_BigQueryDatasetSource) String() string
- type Listing_BigQueryDatasetSource_RestrictedExportPolicy
- func (*Listing_BigQueryDatasetSource_RestrictedExportPolicy) Descriptor() ([]byte, []int)deprecated
- func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) GetEnabled() *wrappers.BoolValue
- func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) GetRestrictDirectTableAccess() *wrappers.BoolValue
- func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) GetRestrictQueryResult() *wrappers.BoolValue
- func (*Listing_BigQueryDatasetSource_RestrictedExportPolicy) ProtoMessage()
- func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) ProtoReflect() protoreflect.Message
- func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) Reset()
- func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) String() string
- type Listing_BigQueryDatasetSource_SelectedResource
- func (*Listing_BigQueryDatasetSource_SelectedResource) Descriptor() ([]byte, []int)deprecated
- func (m *Listing_BigQueryDatasetSource_SelectedResource) GetResource() isListing_BigQueryDatasetSource_SelectedResource_Resource
- func (x *Listing_BigQueryDatasetSource_SelectedResource) GetTable() string
- func (*Listing_BigQueryDatasetSource_SelectedResource) ProtoMessage()
- 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
- type Listing_BigqueryDataset
- type Listing_Category
- func (Listing_Category) Descriptor() protoreflect.EnumDescriptor
- func (x Listing_Category) Enum() *Listing_Category
- func (Listing_Category) EnumDescriptor() ([]byte, []int)deprecated
- func (x Listing_Category) Number() protoreflect.EnumNumber
- func (x Listing_Category) String() string
- func (Listing_Category) Type() protoreflect.EnumType
- type Listing_RestrictedExportConfig
- func (*Listing_RestrictedExportConfig) Descriptor() ([]byte, []int)deprecated
- func (x *Listing_RestrictedExportConfig) GetEnabled() bool
- func (x *Listing_RestrictedExportConfig) GetRestrictDirectTableAccess() bool
- func (x *Listing_RestrictedExportConfig) GetRestrictQueryResult() bool
- func (*Listing_RestrictedExportConfig) ProtoMessage()
- func (x *Listing_RestrictedExportConfig) ProtoReflect() protoreflect.Message
- func (x *Listing_RestrictedExportConfig) Reset()
- func (x *Listing_RestrictedExportConfig) String() string
- type Listing_State
- func (Listing_State) Descriptor() protoreflect.EnumDescriptor
- func (x Listing_State) Enum() *Listing_State
- func (Listing_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x Listing_State) Number() protoreflect.EnumNumber
- func (x Listing_State) String() string
- func (Listing_State) Type() protoreflect.EnumType
- type OperationMetadata
- func (*OperationMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *OperationMetadata) GetApiVersion() string
- func (x *OperationMetadata) GetCreateTime() *timestamp.Timestamp
- func (x *OperationMetadata) GetEndTime() *timestamp.Timestamp
- func (x *OperationMetadata) GetRequestedCancellation() bool
- func (x *OperationMetadata) GetStatusMessage() string
- func (x *OperationMetadata) GetTarget() string
- func (x *OperationMetadata) GetVerb() string
- func (*OperationMetadata) ProtoMessage()
- func (x *OperationMetadata) ProtoReflect() protoreflect.Message
- func (x *OperationMetadata) Reset()
- func (x *OperationMetadata) String() string
- type Publisher
- type RefreshSubscriptionRequest
- func (*RefreshSubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RefreshSubscriptionRequest) GetName() string
- func (*RefreshSubscriptionRequest) ProtoMessage()
- func (x *RefreshSubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *RefreshSubscriptionRequest) Reset()
- func (x *RefreshSubscriptionRequest) String() string
- type RefreshSubscriptionResponse
- func (*RefreshSubscriptionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RefreshSubscriptionResponse) GetSubscription() *Subscription
- func (*RefreshSubscriptionResponse) ProtoMessage()
- func (x *RefreshSubscriptionResponse) ProtoReflect() protoreflect.Message
- func (x *RefreshSubscriptionResponse) Reset()
- func (x *RefreshSubscriptionResponse) String() string
- type RevokeSubscriptionRequest
- func (*RevokeSubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RevokeSubscriptionRequest) GetName() string
- func (*RevokeSubscriptionRequest) ProtoMessage()
- func (x *RevokeSubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *RevokeSubscriptionRequest) Reset()
- func (x *RevokeSubscriptionRequest) String() string
- type RevokeSubscriptionResponse
- type SharingEnvironmentConfig
- func (*SharingEnvironmentConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SharingEnvironmentConfig) GetDcrExchangeConfig() *SharingEnvironmentConfig_DcrExchangeConfig
- func (x *SharingEnvironmentConfig) GetDefaultExchangeConfig() *SharingEnvironmentConfig_DefaultExchangeConfig
- func (m *SharingEnvironmentConfig) GetEnvironment() isSharingEnvironmentConfig_Environment
- func (*SharingEnvironmentConfig) ProtoMessage()
- func (x *SharingEnvironmentConfig) ProtoReflect() protoreflect.Message
- func (x *SharingEnvironmentConfig) Reset()
- func (x *SharingEnvironmentConfig) String() string
- type SharingEnvironmentConfig_DcrExchangeConfig
- func (*SharingEnvironmentConfig_DcrExchangeConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SharingEnvironmentConfig_DcrExchangeConfig) GetSingleLinkedDatasetPerCleanroom() bool
- func (x *SharingEnvironmentConfig_DcrExchangeConfig) GetSingleSelectedResourceSharingRestriction() bool
- 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_
- type SharingEnvironmentConfig_DefaultExchangeConfig
- func (*SharingEnvironmentConfig_DefaultExchangeConfig) Descriptor() ([]byte, []int)deprecated
- 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_
- type SubscribeDataExchangeRequest
- func (*SubscribeDataExchangeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeDataExchangeRequest) GetDestination() string
- func (x *SubscribeDataExchangeRequest) GetName() string
- func (x *SubscribeDataExchangeRequest) GetSubscriberContact() string
- func (x *SubscribeDataExchangeRequest) GetSubscription() string
- func (*SubscribeDataExchangeRequest) ProtoMessage()
- func (x *SubscribeDataExchangeRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeDataExchangeRequest) Reset()
- func (x *SubscribeDataExchangeRequest) String() string
- type SubscribeDataExchangeResponse
- func (*SubscribeDataExchangeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeDataExchangeResponse) GetSubscription() *Subscription
- func (*SubscribeDataExchangeResponse) ProtoMessage()
- func (x *SubscribeDataExchangeResponse) ProtoReflect() protoreflect.Message
- func (x *SubscribeDataExchangeResponse) Reset()
- func (x *SubscribeDataExchangeResponse) String() string
- type SubscribeListingRequest
- func (*SubscribeListingRequest) Descriptor() ([]byte, []int)deprecated
- func (m *SubscribeListingRequest) GetDestination() isSubscribeListingRequest_Destination
- func (x *SubscribeListingRequest) GetDestinationDataset() *DestinationDataset
- func (x *SubscribeListingRequest) GetName() string
- func (*SubscribeListingRequest) ProtoMessage()
- func (x *SubscribeListingRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeListingRequest) Reset()
- func (x *SubscribeListingRequest) String() string
- type SubscribeListingRequest_DestinationDataset
- type SubscribeListingResponse
- func (*SubscribeListingResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeListingResponse) GetSubscription() *Subscription
- func (*SubscribeListingResponse) ProtoMessage()
- func (x *SubscribeListingResponse) ProtoReflect() protoreflect.Message
- func (x *SubscribeListingResponse) Reset()
- func (x *SubscribeListingResponse) String() string
- type Subscription
- func (*Subscription) Descriptor() ([]byte, []int)deprecated
- func (x *Subscription) GetCreationTime() *timestamp.Timestamp
- func (x *Subscription) GetDataExchange() string
- func (x *Subscription) GetLastModifyTime() *timestamp.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 (m *Subscription) GetResourceName() isSubscription_ResourceName
- func (x *Subscription) GetState() Subscription_State
- func (x *Subscription) GetSubscriberContact() string
- func (*Subscription) ProtoMessage()
- func (x *Subscription) ProtoReflect() protoreflect.Message
- func (x *Subscription) Reset()
- func (x *Subscription) String() string
- type Subscription_DataExchange
- type Subscription_LinkedResource
- func (*Subscription_LinkedResource) Descriptor() ([]byte, []int)deprecated
- func (x *Subscription_LinkedResource) GetLinkedDataset() string
- func (m *Subscription_LinkedResource) GetReference() isSubscription_LinkedResource_Reference
- func (*Subscription_LinkedResource) ProtoMessage()
- func (x *Subscription_LinkedResource) ProtoReflect() protoreflect.Message
- func (x *Subscription_LinkedResource) Reset()
- func (x *Subscription_LinkedResource) String() string
- type Subscription_LinkedResource_LinkedDataset
- type Subscription_Listing
- type Subscription_State
- func (Subscription_State) Descriptor() protoreflect.EnumDescriptor
- func (x Subscription_State) Enum() *Subscription_State
- func (Subscription_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x Subscription_State) Number() protoreflect.EnumNumber
- func (x Subscription_State) String() string
- func (Subscription_State) Type() protoreflect.EnumType
- type UnimplementedAnalyticsHubServiceServer
- func (UnimplementedAnalyticsHubServiceServer) CreateDataExchange(context.Context, *CreateDataExchangeRequest) (*DataExchange, error)
- func (UnimplementedAnalyticsHubServiceServer) CreateListing(context.Context, *CreateListingRequest) (*Listing, error)
- func (UnimplementedAnalyticsHubServiceServer) DeleteDataExchange(context.Context, *DeleteDataExchangeRequest) (*empty.Empty, error)
- func (UnimplementedAnalyticsHubServiceServer) DeleteListing(context.Context, *DeleteListingRequest) (*empty.Empty, error)
- func (UnimplementedAnalyticsHubServiceServer) DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*longrunningpb.Operation, error)
- func (UnimplementedAnalyticsHubServiceServer) GetDataExchange(context.Context, *GetDataExchangeRequest) (*DataExchange, error)
- func (UnimplementedAnalyticsHubServiceServer) GetIamPolicy(context.Context, *iampb.GetIamPolicyRequest) (*iampb.Policy, error)
- func (UnimplementedAnalyticsHubServiceServer) GetListing(context.Context, *GetListingRequest) (*Listing, error)
- func (UnimplementedAnalyticsHubServiceServer) GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, 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) 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) SetIamPolicy(context.Context, *iampb.SetIamPolicyRequest) (*iampb.Policy, error)
- func (UnimplementedAnalyticsHubServiceServer) SubscribeDataExchange(context.Context, *SubscribeDataExchangeRequest) (*longrunningpb.Operation, error)
- func (UnimplementedAnalyticsHubServiceServer) SubscribeListing(context.Context, *SubscribeListingRequest) (*SubscribeListingResponse, error)
- func (UnimplementedAnalyticsHubServiceServer) TestIamPermissions(context.Context, *iampb.TestIamPermissionsRequest) (*iampb.TestIamPermissionsResponse, error)
- func (UnimplementedAnalyticsHubServiceServer) UpdateDataExchange(context.Context, *UpdateDataExchangeRequest) (*DataExchange, error)
- func (UnimplementedAnalyticsHubServiceServer) UpdateListing(context.Context, *UpdateListingRequest) (*Listing, error)
- type UnsafeAnalyticsHubServiceServer
- type UpdateDataExchangeRequest
- func (*UpdateDataExchangeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDataExchangeRequest) GetDataExchange() *DataExchange
- func (x *UpdateDataExchangeRequest) GetUpdateMask() *field_mask.FieldMask
- func (*UpdateDataExchangeRequest) ProtoMessage()
- func (x *UpdateDataExchangeRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateDataExchangeRequest) Reset()
- func (x *UpdateDataExchangeRequest) String() string
- type UpdateListingRequest
- func (*UpdateListingRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateListingRequest) GetListing() *Listing
- func (x *UpdateListingRequest) GetUpdateMask() *field_mask.FieldMask
- func (*UpdateListingRequest) ProtoMessage()
- func (x *UpdateListingRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateListingRequest) Reset()
- func (x *UpdateListingRequest) String() string
Constants ¶
This section is empty.
Variables ¶
var ( DiscoveryType_name = map[int32]string{ 0: "DISCOVERY_TYPE_UNSPECIFIED", 1: "DISCOVERY_TYPE_PRIVATE", 2: "DISCOVERY_TYPE_PUBLIC", } DiscoveryType_value = map[string]int32{ "DISCOVERY_TYPE_UNSPECIFIED": 0, "DISCOVERY_TYPE_PRIVATE": 1, "DISCOVERY_TYPE_PUBLIC": 2, } )
Enum value maps for DiscoveryType.
var ( Listing_State_name = map[int32]string{ 0: "STATE_UNSPECIFIED", 1: "ACTIVE", } Listing_State_value = map[string]int32{ "STATE_UNSPECIFIED": 0, "ACTIVE": 1, } )
Enum value maps for Listing_State.
var ( Listing_Category_name = map[int32]string{ 0: "CATEGORY_UNSPECIFIED", 1: "CATEGORY_OTHERS", 2: "CATEGORY_ADVERTISING_AND_MARKETING", 3: "CATEGORY_COMMERCE", 4: "CATEGORY_CLIMATE_AND_ENVIRONMENT", 5: "CATEGORY_DEMOGRAPHICS", 6: "CATEGORY_ECONOMICS", 7: "CATEGORY_EDUCATION", 8: "CATEGORY_ENERGY", 9: "CATEGORY_FINANCIAL", 10: "CATEGORY_GAMING", 11: "CATEGORY_GEOSPATIAL", 12: "CATEGORY_HEALTHCARE_AND_LIFE_SCIENCE", 13: "CATEGORY_MEDIA", 14: "CATEGORY_PUBLIC_SECTOR", 15: "CATEGORY_RETAIL", 16: "CATEGORY_SPORTS", 17: "CATEGORY_SCIENCE_AND_RESEARCH", 18: "CATEGORY_TRANSPORTATION_AND_LOGISTICS", 19: "CATEGORY_TRAVEL_AND_TOURISM", } Listing_Category_value = map[string]int32{ "CATEGORY_UNSPECIFIED": 0, "CATEGORY_OTHERS": 1, "CATEGORY_ADVERTISING_AND_MARKETING": 2, "CATEGORY_COMMERCE": 3, "CATEGORY_CLIMATE_AND_ENVIRONMENT": 4, "CATEGORY_DEMOGRAPHICS": 5, "CATEGORY_ECONOMICS": 6, "CATEGORY_EDUCATION": 7, "CATEGORY_ENERGY": 8, "CATEGORY_FINANCIAL": 9, "CATEGORY_GAMING": 10, "CATEGORY_GEOSPATIAL": 11, "CATEGORY_HEALTHCARE_AND_LIFE_SCIENCE": 12, "CATEGORY_MEDIA": 13, "CATEGORY_PUBLIC_SECTOR": 14, "CATEGORY_RETAIL": 15, "CATEGORY_SPORTS": 16, "CATEGORY_SCIENCE_AND_RESEARCH": 17, "CATEGORY_TRANSPORTATION_AND_LOGISTICS": 18, "CATEGORY_TRAVEL_AND_TOURISM": 19, } )
Enum value maps for Listing_Category.
var ( Subscription_State_name = map[int32]string{ 0: "STATE_UNSPECIFIED", 1: "STATE_ACTIVE", 2: "STATE_STALE", 3: "STATE_INACTIVE", } Subscription_State_value = map[string]int32{ "STATE_UNSPECIFIED": 0, "STATE_ACTIVE": 1, "STATE_STALE": 2, "STATE_INACTIVE": 3, } )
Enum value maps for Subscription_State.
var AnalyticsHubService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "mockgcp.cloud.bigquery.analyticshub.v1.AnalyticsHubService", HandlerType: (*AnalyticsHubServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListDataExchanges", Handler: _AnalyticsHubService_ListDataExchanges_Handler, }, { MethodName: "ListOrgDataExchanges", Handler: _AnalyticsHubService_ListOrgDataExchanges_Handler, }, { MethodName: "GetDataExchange", Handler: _AnalyticsHubService_GetDataExchange_Handler, }, { MethodName: "CreateDataExchange", Handler: _AnalyticsHubService_CreateDataExchange_Handler, }, { MethodName: "UpdateDataExchange", Handler: _AnalyticsHubService_UpdateDataExchange_Handler, }, { MethodName: "DeleteDataExchange", Handler: _AnalyticsHubService_DeleteDataExchange_Handler, }, { MethodName: "ListListings", Handler: _AnalyticsHubService_ListListings_Handler, }, { MethodName: "GetListing", Handler: _AnalyticsHubService_GetListing_Handler, }, { MethodName: "CreateListing", Handler: _AnalyticsHubService_CreateListing_Handler, }, { MethodName: "UpdateListing", Handler: _AnalyticsHubService_UpdateListing_Handler, }, { MethodName: "DeleteListing", Handler: _AnalyticsHubService_DeleteListing_Handler, }, { MethodName: "SubscribeListing", Handler: _AnalyticsHubService_SubscribeListing_Handler, }, { MethodName: "SubscribeDataExchange", Handler: _AnalyticsHubService_SubscribeDataExchange_Handler, }, { MethodName: "RefreshSubscription", Handler: _AnalyticsHubService_RefreshSubscription_Handler, }, { MethodName: "GetSubscription", Handler: _AnalyticsHubService_GetSubscription_Handler, }, { MethodName: "ListSubscriptions", Handler: _AnalyticsHubService_ListSubscriptions_Handler, }, { MethodName: "ListSharedResourceSubscriptions", Handler: _AnalyticsHubService_ListSharedResourceSubscriptions_Handler, }, { MethodName: "RevokeSubscription", Handler: _AnalyticsHubService_RevokeSubscription_Handler, }, { MethodName: "DeleteSubscription", Handler: _AnalyticsHubService_DeleteSubscription_Handler, }, { MethodName: "GetIamPolicy", Handler: _AnalyticsHubService_GetIamPolicy_Handler, }, { MethodName: "SetIamPolicy", Handler: _AnalyticsHubService_SetIamPolicy_Handler, }, { MethodName: "TestIamPermissions", Handler: _AnalyticsHubService_TestIamPermissions_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "mockgcp/cloud/bigquery/analyticshub/v1/analyticshub.proto", }
AnalyticsHubService_ServiceDesc is the grpc.ServiceDesc for AnalyticsHubService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_mockgcp_cloud_bigquery_analyticshub_v1_analyticshub_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAnalyticsHubServiceHandler ¶
func RegisterAnalyticsHubServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterAnalyticsHubServiceHandler registers the http handlers for service AnalyticsHubService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterAnalyticsHubServiceHandlerClient ¶
func RegisterAnalyticsHubServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AnalyticsHubServiceClient) error
RegisterAnalyticsHubServiceHandlerClient registers the http handlers for service AnalyticsHubService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AnalyticsHubServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AnalyticsHubServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AnalyticsHubServiceClient" to call the correct interceptors.
func RegisterAnalyticsHubServiceHandlerFromEndpoint ¶
func RegisterAnalyticsHubServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterAnalyticsHubServiceHandlerFromEndpoint is same as RegisterAnalyticsHubServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterAnalyticsHubServiceHandlerServer ¶
func RegisterAnalyticsHubServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AnalyticsHubServiceServer) error
RegisterAnalyticsHubServiceHandlerServer registers the http handlers for service AnalyticsHubService to "mux". UnaryRPC :call AnalyticsHubServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterAnalyticsHubServiceHandlerFromEndpoint instead.
func RegisterAnalyticsHubServiceServer ¶
func RegisterAnalyticsHubServiceServer(s grpc.ServiceRegistrar, srv AnalyticsHubServiceServer)
Types ¶
type AnalyticsHubServiceClient ¶
type AnalyticsHubServiceClient interface { // Lists all data exchanges in a given project and location. ListDataExchanges(ctx context.Context, in *ListDataExchangesRequest, opts ...grpc.CallOption) (*ListDataExchangesResponse, error) // Lists all data exchanges from projects in a given organization and // location. ListOrgDataExchanges(ctx context.Context, in *ListOrgDataExchangesRequest, opts ...grpc.CallOption) (*ListOrgDataExchangesResponse, error) // Gets the details of a data exchange. GetDataExchange(ctx context.Context, in *GetDataExchangeRequest, opts ...grpc.CallOption) (*DataExchange, error) // Creates a new data exchange. CreateDataExchange(ctx context.Context, in *CreateDataExchangeRequest, opts ...grpc.CallOption) (*DataExchange, error) // Updates an existing data exchange. UpdateDataExchange(ctx context.Context, in *UpdateDataExchangeRequest, opts ...grpc.CallOption) (*DataExchange, error) // Deletes an existing data exchange. DeleteDataExchange(ctx context.Context, in *DeleteDataExchangeRequest, opts ...grpc.CallOption) (*empty.Empty, error) // Lists all listings in a given project and location. ListListings(ctx context.Context, in *ListListingsRequest, opts ...grpc.CallOption) (*ListListingsResponse, error) // Gets the details of a listing. GetListing(ctx context.Context, in *GetListingRequest, opts ...grpc.CallOption) (*Listing, error) // Creates a new listing. CreateListing(ctx context.Context, in *CreateListingRequest, opts ...grpc.CallOption) (*Listing, error) // Updates an existing listing. UpdateListing(ctx context.Context, in *UpdateListingRequest, opts ...grpc.CallOption) (*Listing, error) // Deletes a listing. DeleteListing(ctx context.Context, in *DeleteListingRequest, opts ...grpc.CallOption) (*empty.Empty, error) // Subscribes to a listing. // // Currently, with Analytics Hub, you can create listings that // reference only BigQuery datasets. // Upon subscription to a listing for a BigQuery dataset, Analytics Hub // creates a linked dataset in the subscriber's project. SubscribeListing(ctx context.Context, in *SubscribeListingRequest, opts ...grpc.CallOption) (*SubscribeListingResponse, error) // Creates a Subscription to a Data Exchange. This is a long-running operation // as it will create one or more linked datasets. SubscribeDataExchange(ctx context.Context, in *SubscribeDataExchangeRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) // Refreshes a Subscription to a Data Exchange. A Data Exchange can become // stale when a publisher adds or removes data. This is a long-running // operation as it may create many linked datasets. RefreshSubscription(ctx context.Context, in *RefreshSubscriptionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) // Gets the details of a Subscription. GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error) // Lists all subscriptions in a given project and location. ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error) ListSharedResourceSubscriptions(ctx context.Context, in *ListSharedResourceSubscriptionsRequest, opts ...grpc.CallOption) (*ListSharedResourceSubscriptionsResponse, error) // Revokes a given subscription. RevokeSubscription(ctx context.Context, in *RevokeSubscriptionRequest, opts ...grpc.CallOption) (*RevokeSubscriptionResponse, error) // Deletes a subscription. DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) // Gets the IAM policy. GetIamPolicy(ctx context.Context, in *iampb.GetIamPolicyRequest, opts ...grpc.CallOption) (*iampb.Policy, error) // Sets the IAM policy. SetIamPolicy(ctx context.Context, in *iampb.SetIamPolicyRequest, opts ...grpc.CallOption) (*iampb.Policy, error) // Returns the permissions that a caller has. TestIamPermissions(ctx context.Context, in *iampb.TestIamPermissionsRequest, opts ...grpc.CallOption) (*iampb.TestIamPermissionsResponse, error) }
AnalyticsHubServiceClient is the client API for AnalyticsHubService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAnalyticsHubServiceClient ¶
func NewAnalyticsHubServiceClient(cc grpc.ClientConnInterface) AnalyticsHubServiceClient
type AnalyticsHubServiceServer ¶
type AnalyticsHubServiceServer interface { // Lists all data exchanges in a given project and location. ListDataExchanges(context.Context, *ListDataExchangesRequest) (*ListDataExchangesResponse, error) // Lists all data exchanges from projects in a given organization and // location. ListOrgDataExchanges(context.Context, *ListOrgDataExchangesRequest) (*ListOrgDataExchangesResponse, error) // Gets the details of a data exchange. GetDataExchange(context.Context, *GetDataExchangeRequest) (*DataExchange, error) // Creates a new data exchange. CreateDataExchange(context.Context, *CreateDataExchangeRequest) (*DataExchange, error) // Updates an existing data exchange. UpdateDataExchange(context.Context, *UpdateDataExchangeRequest) (*DataExchange, error) // Deletes an existing data exchange. DeleteDataExchange(context.Context, *DeleteDataExchangeRequest) (*empty.Empty, error) // Lists all listings in a given project and location. ListListings(context.Context, *ListListingsRequest) (*ListListingsResponse, error) // Gets the details of a listing. GetListing(context.Context, *GetListingRequest) (*Listing, error) // Creates a new listing. CreateListing(context.Context, *CreateListingRequest) (*Listing, error) // Updates an existing listing. UpdateListing(context.Context, *UpdateListingRequest) (*Listing, error) // Deletes a listing. DeleteListing(context.Context, *DeleteListingRequest) (*empty.Empty, error) // Subscribes to a listing. // // Currently, with Analytics Hub, you can create listings that // reference only BigQuery datasets. // Upon subscription to a listing for a BigQuery dataset, Analytics Hub // creates a linked dataset in the subscriber's project. SubscribeListing(context.Context, *SubscribeListingRequest) (*SubscribeListingResponse, error) // Creates a Subscription to a Data Exchange. This is a long-running operation // as it will create one or more linked datasets. SubscribeDataExchange(context.Context, *SubscribeDataExchangeRequest) (*longrunningpb.Operation, error) // Refreshes a Subscription to a Data Exchange. A Data Exchange can become // stale when a publisher adds or removes data. This is a long-running // operation as it may create many linked datasets. RefreshSubscription(context.Context, *RefreshSubscriptionRequest) (*longrunningpb.Operation, error) // Gets the details of a Subscription. GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error) // Lists all subscriptions in a given project and location. ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error) ListSharedResourceSubscriptions(context.Context, *ListSharedResourceSubscriptionsRequest) (*ListSharedResourceSubscriptionsResponse, error) // Revokes a given subscription. RevokeSubscription(context.Context, *RevokeSubscriptionRequest) (*RevokeSubscriptionResponse, error) // Deletes a subscription. DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*longrunningpb.Operation, error) // Gets the IAM policy. GetIamPolicy(context.Context, *iampb.GetIamPolicyRequest) (*iampb.Policy, error) // Sets the IAM policy. SetIamPolicy(context.Context, *iampb.SetIamPolicyRequest) (*iampb.Policy, error) // Returns the permissions that a caller has. TestIamPermissions(context.Context, *iampb.TestIamPermissionsRequest) (*iampb.TestIamPermissionsResponse, error) // contains filtered or unexported methods }
AnalyticsHubServiceServer is the server API for AnalyticsHubService service. All implementations must embed UnimplementedAnalyticsHubServiceServer for forward compatibility
type CreateDataExchangeRequest ¶
type CreateDataExchangeRequest struct { // Required. The parent resource path of the data exchange. // e.g. `projects/myproject/locations/US`. Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // Required. The ID of the data exchange. // Must contain only Unicode letters, numbers (0-9), underscores (_). // Should not use characters that require URL-escaping, or characters // outside of ASCII, spaces. // Max length: 100 bytes. DataExchangeId string `protobuf:"bytes,2,opt,name=data_exchange_id,json=dataExchangeId,proto3" json:"data_exchange_id,omitempty"` // Required. The data exchange to create. DataExchange *DataExchange `protobuf:"bytes,3,opt,name=data_exchange,json=dataExchange,proto3" json:"data_exchange,omitempty"` // contains filtered or unexported fields }
Message for creating a data exchange.
func (*CreateDataExchangeRequest) Descriptor
deprecated
func (*CreateDataExchangeRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateDataExchangeRequest.ProtoReflect.Descriptor instead.
func (*CreateDataExchangeRequest) GetDataExchange ¶
func (x *CreateDataExchangeRequest) GetDataExchange() *DataExchange
func (*CreateDataExchangeRequest) GetDataExchangeId ¶
func (x *CreateDataExchangeRequest) GetDataExchangeId() string
func (*CreateDataExchangeRequest) GetParent ¶
func (x *CreateDataExchangeRequest) GetParent() string
func (*CreateDataExchangeRequest) ProtoMessage ¶
func (*CreateDataExchangeRequest) ProtoMessage()
func (*CreateDataExchangeRequest) ProtoReflect ¶
func (x *CreateDataExchangeRequest) ProtoReflect() protoreflect.Message
func (*CreateDataExchangeRequest) Reset ¶
func (x *CreateDataExchangeRequest) Reset()
func (*CreateDataExchangeRequest) String ¶
func (x *CreateDataExchangeRequest) String() string
type CreateListingRequest ¶
type CreateListingRequest struct { // Required. The parent resource path of the listing. // e.g. `projects/myproject/locations/US/dataExchanges/123`. Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // Required. The ID of the listing to create. // Must contain only Unicode letters, numbers (0-9), underscores (_). // Should not use characters that require URL-escaping, or characters // outside of ASCII, spaces. // Max length: 100 bytes. ListingId string `protobuf:"bytes,2,opt,name=listing_id,json=listingId,proto3" json:"listing_id,omitempty"` // Required. The listing to create. Listing *Listing `protobuf:"bytes,3,opt,name=listing,proto3" json:"listing,omitempty"` // contains filtered or unexported fields }
Message for creating a listing.
func (*CreateListingRequest) Descriptor
deprecated
func (*CreateListingRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateListingRequest.ProtoReflect.Descriptor instead.
func (*CreateListingRequest) GetListing ¶
func (x *CreateListingRequest) GetListing() *Listing
func (*CreateListingRequest) GetListingId ¶
func (x *CreateListingRequest) GetListingId() string
func (*CreateListingRequest) GetParent ¶
func (x *CreateListingRequest) GetParent() string
func (*CreateListingRequest) ProtoMessage ¶
func (*CreateListingRequest) ProtoMessage()
func (*CreateListingRequest) ProtoReflect ¶
func (x *CreateListingRequest) ProtoReflect() protoreflect.Message
func (*CreateListingRequest) Reset ¶
func (x *CreateListingRequest) Reset()
func (*CreateListingRequest) String ¶
func (x *CreateListingRequest) String() string
type DataExchange ¶
type DataExchange struct { // Output only. The resource name of the data exchange. // e.g. `projects/myproject/locations/US/dataExchanges/123`. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Required. Human-readable display name of the data exchange. The display // name must contain only Unicode letters, numbers (0-9), underscores (_), // dashes (-), spaces ( ), ampersands (&) and must not start or end with // spaces. Default value is an empty string. Max length: 63 bytes. DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"` // Optional. Description of the data exchange. The description must not // contain Unicode non-characters as well as C0 and C1 control codes except // tabs (HT), new lines (LF), carriage returns (CR), and page breaks (FF). // Default value is an empty string. // Max length: 2000 bytes. Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` // Optional. Email or URL of the primary point of contact of the data // exchange. Max Length: 1000 bytes. PrimaryContact string `protobuf:"bytes,4,opt,name=primary_contact,json=primaryContact,proto3" json:"primary_contact,omitempty"` // Optional. Documentation describing the data exchange. Documentation string `protobuf:"bytes,5,opt,name=documentation,proto3" json:"documentation,omitempty"` // Output only. Number of listings contained in the data exchange. ListingCount int32 `protobuf:"varint,6,opt,name=listing_count,json=listingCount,proto3" json:"listing_count,omitempty"` // Optional. Base64 encoded image representing the data exchange. Max // Size: 3.0MiB Expected image dimensions are 512x512 pixels, however the API // only performs validation on size of the encoded data. Note: For byte // fields, the content of the fields are base64-encoded (which increases the // size of the data by 33-36%) when using JSON on the wire. Icon []byte `protobuf:"bytes,7,opt,name=icon,proto3" json:"icon,omitempty"` // Optional. Configurable data sharing environment option for a data exchange. SharingEnvironmentConfig *SharingEnvironmentConfig `` /* 135-byte string literal not displayed */ // Optional. Type of discovery on the discovery page for all the listings // under this exchange. Updating this field also updates (overwrites) the // discovery_type field for all the listings under this exchange. DiscoveryType *DiscoveryType `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
A data exchange is a container that lets you share data. Along with the descriptive information about the data exchange, it contains listings that reference shared datasets.
func (*DataExchange) Descriptor
deprecated
func (*DataExchange) Descriptor() ([]byte, []int)
Deprecated: Use DataExchange.ProtoReflect.Descriptor instead.
func (*DataExchange) GetDescription ¶
func (x *DataExchange) GetDescription() string
func (*DataExchange) GetDiscoveryType ¶
func (x *DataExchange) GetDiscoveryType() DiscoveryType
func (*DataExchange) GetDisplayName ¶
func (x *DataExchange) GetDisplayName() string
func (*DataExchange) GetDocumentation ¶
func (x *DataExchange) GetDocumentation() string
func (*DataExchange) GetIcon ¶
func (x *DataExchange) GetIcon() []byte
func (*DataExchange) GetListingCount ¶
func (x *DataExchange) GetListingCount() int32
func (*DataExchange) GetName ¶
func (x *DataExchange) GetName() string
func (*DataExchange) GetPrimaryContact ¶
func (x *DataExchange) GetPrimaryContact() string
func (*DataExchange) GetSharingEnvironmentConfig ¶
func (x *DataExchange) GetSharingEnvironmentConfig() *SharingEnvironmentConfig
func (*DataExchange) ProtoMessage ¶
func (*DataExchange) ProtoMessage()
func (*DataExchange) ProtoReflect ¶
func (x *DataExchange) ProtoReflect() protoreflect.Message
func (*DataExchange) Reset ¶
func (x *DataExchange) Reset()
func (*DataExchange) String ¶
func (x *DataExchange) String() string
type DataProvider ¶
type DataProvider struct { // Optional. Name of the data provider. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Optional. Email or URL of the data provider. // Max Length: 1000 bytes. PrimaryContact string `protobuf:"bytes,2,opt,name=primary_contact,json=primaryContact,proto3" json:"primary_contact,omitempty"` // contains filtered or unexported fields }
Contains details of the data provider.
func (*DataProvider) Descriptor
deprecated
func (*DataProvider) Descriptor() ([]byte, []int)
Deprecated: Use DataProvider.ProtoReflect.Descriptor instead.
func (*DataProvider) GetName ¶
func (x *DataProvider) GetName() string
func (*DataProvider) GetPrimaryContact ¶
func (x *DataProvider) GetPrimaryContact() string
func (*DataProvider) ProtoMessage ¶
func (*DataProvider) ProtoMessage()
func (*DataProvider) ProtoReflect ¶
func (x *DataProvider) ProtoReflect() protoreflect.Message
func (*DataProvider) Reset ¶
func (x *DataProvider) Reset()
func (*DataProvider) String ¶
func (x *DataProvider) String() string
type DeleteDataExchangeRequest ¶
type DeleteDataExchangeRequest struct { // Required. The full name of the data exchange resource that you want to // delete. For example, `projects/myproject/locations/US/dataExchanges/123`. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Message for deleting a data exchange.
func (*DeleteDataExchangeRequest) Descriptor
deprecated
func (*DeleteDataExchangeRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDataExchangeRequest.ProtoReflect.Descriptor instead.
func (*DeleteDataExchangeRequest) GetName ¶
func (x *DeleteDataExchangeRequest) GetName() string
func (*DeleteDataExchangeRequest) ProtoMessage ¶
func (*DeleteDataExchangeRequest) ProtoMessage()
func (*DeleteDataExchangeRequest) ProtoReflect ¶
func (x *DeleteDataExchangeRequest) ProtoReflect() protoreflect.Message
func (*DeleteDataExchangeRequest) Reset ¶
func (x *DeleteDataExchangeRequest) Reset()
func (*DeleteDataExchangeRequest) String ¶
func (x *DeleteDataExchangeRequest) String() string
type DeleteListingRequest ¶
type DeleteListingRequest struct { // Required. Resource name of the listing to delete. // e.g. `projects/myproject/locations/US/dataExchanges/123/listings/456`. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Message for deleting a listing.
func (*DeleteListingRequest) Descriptor
deprecated
func (*DeleteListingRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteListingRequest.ProtoReflect.Descriptor instead.
func (*DeleteListingRequest) GetName ¶
func (x *DeleteListingRequest) GetName() string
func (*DeleteListingRequest) ProtoMessage ¶
func (*DeleteListingRequest) ProtoMessage()
func (*DeleteListingRequest) ProtoReflect ¶
func (x *DeleteListingRequest) ProtoReflect() protoreflect.Message
func (*DeleteListingRequest) Reset ¶
func (x *DeleteListingRequest) Reset()
func (*DeleteListingRequest) String ¶
func (x *DeleteListingRequest) String() string
type DeleteSubscriptionRequest ¶
type DeleteSubscriptionRequest struct { // Required. Resource name of the subscription to delete. // e.g. projects/123/locations/US/subscriptions/456 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Message for deleting a subscription.
func (*DeleteSubscriptionRequest) Descriptor
deprecated
func (*DeleteSubscriptionRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSubscriptionRequest.ProtoReflect.Descriptor instead.
func (*DeleteSubscriptionRequest) GetName ¶
func (x *DeleteSubscriptionRequest) GetName() string
func (*DeleteSubscriptionRequest) ProtoMessage ¶
func (*DeleteSubscriptionRequest) ProtoMessage()
func (*DeleteSubscriptionRequest) ProtoReflect ¶
func (x *DeleteSubscriptionRequest) ProtoReflect() protoreflect.Message
func (*DeleteSubscriptionRequest) Reset ¶
func (x *DeleteSubscriptionRequest) Reset()
func (*DeleteSubscriptionRequest) String ¶
func (x *DeleteSubscriptionRequest) String() string
type DestinationDataset ¶
type DestinationDataset struct { // Required. A reference that identifies the destination dataset. DatasetReference *DestinationDatasetReference `protobuf:"bytes,1,opt,name=dataset_reference,json=datasetReference,proto3" json:"dataset_reference,omitempty"` // Optional. A descriptive name for the dataset. FriendlyName *wrappers.StringValue `protobuf:"bytes,2,opt,name=friendly_name,json=friendlyName,proto3" json:"friendly_name,omitempty"` // Optional. A user-friendly description of the dataset. Description *wrappers.StringValue `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` // Optional. The labels associated with this dataset. You can use these // to organize and group your datasets. // You can set this property when inserting or updating a dataset. // See https://cloud.google.com/resource-manager/docs/creating-managing-labels // for more information. Labels map[string]string `` /* 153-byte string literal not displayed */ // Required. The geographic location where the dataset should reside. See // https://cloud.google.com/bigquery/docs/locations for supported // locations. Location string `protobuf:"bytes,5,opt,name=location,proto3" json:"location,omitempty"` // contains filtered or unexported fields }
Defines the destination bigquery dataset.
func (*DestinationDataset) Descriptor
deprecated
func (*DestinationDataset) Descriptor() ([]byte, []int)
Deprecated: Use DestinationDataset.ProtoReflect.Descriptor instead.
func (*DestinationDataset) GetDatasetReference ¶
func (x *DestinationDataset) GetDatasetReference() *DestinationDatasetReference
func (*DestinationDataset) GetDescription ¶
func (x *DestinationDataset) GetDescription() *wrappers.StringValue
func (*DestinationDataset) GetFriendlyName ¶
func (x *DestinationDataset) GetFriendlyName() *wrappers.StringValue
func (*DestinationDataset) GetLabels ¶
func (x *DestinationDataset) GetLabels() map[string]string
func (*DestinationDataset) GetLocation ¶
func (x *DestinationDataset) GetLocation() string
func (*DestinationDataset) ProtoMessage ¶
func (*DestinationDataset) ProtoMessage()
func (*DestinationDataset) ProtoReflect ¶
func (x *DestinationDataset) ProtoReflect() protoreflect.Message
func (*DestinationDataset) Reset ¶
func (x *DestinationDataset) Reset()
func (*DestinationDataset) String ¶
func (x *DestinationDataset) String() string
type DestinationDatasetReference ¶
type DestinationDatasetReference struct { // Required. A unique ID for this dataset, without the project name. The ID // must contain only letters (a-z, A-Z), numbers (0-9), or underscores (_). // The maximum length is 1,024 characters. DatasetId string `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"` // Required. The ID of the project containing this dataset. ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // contains filtered or unexported fields }
Contains the reference that identifies a destination bigquery dataset.
func (*DestinationDatasetReference) Descriptor
deprecated
func (*DestinationDatasetReference) Descriptor() ([]byte, []int)
Deprecated: Use DestinationDatasetReference.ProtoReflect.Descriptor instead.
func (*DestinationDatasetReference) GetDatasetId ¶
func (x *DestinationDatasetReference) GetDatasetId() string
func (*DestinationDatasetReference) GetProjectId ¶
func (x *DestinationDatasetReference) GetProjectId() string
func (*DestinationDatasetReference) ProtoMessage ¶
func (*DestinationDatasetReference) ProtoMessage()
func (*DestinationDatasetReference) ProtoReflect ¶
func (x *DestinationDatasetReference) ProtoReflect() protoreflect.Message
func (*DestinationDatasetReference) Reset ¶
func (x *DestinationDatasetReference) Reset()
func (*DestinationDatasetReference) String ¶
func (x *DestinationDatasetReference) String() string
type DiscoveryType ¶
type DiscoveryType int32
Specifies the type of discovery on the discovery page. Note that this does not control the visibility of the exchange/listing which is defined by IAM permission.
const ( // Unspecified. Defaults to DISCOVERY_TYPE_PRIVATE. DiscoveryType_DISCOVERY_TYPE_UNSPECIFIED DiscoveryType = 0 // The Data exchange/listing can be discovered in the 'Private' results // list. DiscoveryType_DISCOVERY_TYPE_PRIVATE DiscoveryType = 1 // The Data exchange/listing can be discovered in the 'Public' results // list. DiscoveryType_DISCOVERY_TYPE_PUBLIC DiscoveryType = 2 )
func (DiscoveryType) Descriptor ¶
func (DiscoveryType) Descriptor() protoreflect.EnumDescriptor
func (DiscoveryType) Enum ¶
func (x DiscoveryType) Enum() *DiscoveryType
func (DiscoveryType) EnumDescriptor
deprecated
func (DiscoveryType) EnumDescriptor() ([]byte, []int)
Deprecated: Use DiscoveryType.Descriptor instead.
func (DiscoveryType) Number ¶
func (x DiscoveryType) Number() protoreflect.EnumNumber
func (DiscoveryType) String ¶
func (x DiscoveryType) String() string
func (DiscoveryType) Type ¶
func (DiscoveryType) Type() protoreflect.EnumType
type GetDataExchangeRequest ¶
type GetDataExchangeRequest struct { // Required. The resource name of the data exchange. // e.g. `projects/myproject/locations/US/dataExchanges/123`. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Message for getting a data exchange.
func (*GetDataExchangeRequest) Descriptor
deprecated
func (*GetDataExchangeRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDataExchangeRequest.ProtoReflect.Descriptor instead.
func (*GetDataExchangeRequest) GetName ¶
func (x *GetDataExchangeRequest) GetName() string
func (*GetDataExchangeRequest) ProtoMessage ¶
func (*GetDataExchangeRequest) ProtoMessage()
func (*GetDataExchangeRequest) ProtoReflect ¶
func (x *GetDataExchangeRequest) ProtoReflect() protoreflect.Message
func (*GetDataExchangeRequest) Reset ¶
func (x *GetDataExchangeRequest) Reset()
func (*GetDataExchangeRequest) String ¶
func (x *GetDataExchangeRequest) String() string
type GetListingRequest ¶
type GetListingRequest struct { // Required. The resource name of the listing. // e.g. `projects/myproject/locations/US/dataExchanges/123/listings/456`. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Message for getting a listing.
func (*GetListingRequest) Descriptor
deprecated
func (*GetListingRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetListingRequest.ProtoReflect.Descriptor instead.
func (*GetListingRequest) GetName ¶
func (x *GetListingRequest) GetName() string
func (*GetListingRequest) ProtoMessage ¶
func (*GetListingRequest) ProtoMessage()
func (*GetListingRequest) ProtoReflect ¶
func (x *GetListingRequest) ProtoReflect() protoreflect.Message
func (*GetListingRequest) Reset ¶
func (x *GetListingRequest) Reset()
func (*GetListingRequest) String ¶
func (x *GetListingRequest) String() string
type GetSubscriptionRequest ¶
type GetSubscriptionRequest struct { // Required. Resource name of the subscription. // e.g. projects/123/locations/US/subscriptions/456 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Message for getting a subscription.
func (*GetSubscriptionRequest) Descriptor
deprecated
func (*GetSubscriptionRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSubscriptionRequest.ProtoReflect.Descriptor instead.
func (*GetSubscriptionRequest) GetName ¶
func (x *GetSubscriptionRequest) GetName() string
func (*GetSubscriptionRequest) ProtoMessage ¶
func (*GetSubscriptionRequest) ProtoMessage()
func (*GetSubscriptionRequest) ProtoReflect ¶
func (x *GetSubscriptionRequest) ProtoReflect() protoreflect.Message
func (*GetSubscriptionRequest) Reset ¶
func (x *GetSubscriptionRequest) Reset()
func (*GetSubscriptionRequest) String ¶
func (x *GetSubscriptionRequest) String() string
type ListDataExchangesRequest ¶
type ListDataExchangesRequest struct { // Required. The parent resource path of the data exchanges. // e.g. `projects/myproject/locations/US`. Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // The maximum number of results to return in a single response page. Leverage // the page tokens to iterate through the entire collection. PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // Page token, returned by a previous call, to request the next page of // results. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // contains filtered or unexported fields }
Message for requesting the list of data exchanges.
func (*ListDataExchangesRequest) Descriptor
deprecated
func (*ListDataExchangesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListDataExchangesRequest.ProtoReflect.Descriptor instead.
func (*ListDataExchangesRequest) GetPageSize ¶
func (x *ListDataExchangesRequest) GetPageSize() int32
func (*ListDataExchangesRequest) GetPageToken ¶
func (x *ListDataExchangesRequest) GetPageToken() string
func (*ListDataExchangesRequest) GetParent ¶
func (x *ListDataExchangesRequest) GetParent() string
func (*ListDataExchangesRequest) ProtoMessage ¶
func (*ListDataExchangesRequest) ProtoMessage()
func (*ListDataExchangesRequest) ProtoReflect ¶
func (x *ListDataExchangesRequest) ProtoReflect() protoreflect.Message
func (*ListDataExchangesRequest) Reset ¶
func (x *ListDataExchangesRequest) Reset()
func (*ListDataExchangesRequest) String ¶
func (x *ListDataExchangesRequest) String() string
type ListDataExchangesResponse ¶
type ListDataExchangesResponse struct { // The list of data exchanges. DataExchanges []*DataExchange `protobuf:"bytes,1,rep,name=data_exchanges,json=dataExchanges,proto3" json:"data_exchanges,omitempty"` // A token to request the next page of results. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
Message for response to the list of data exchanges.
func (*ListDataExchangesResponse) Descriptor
deprecated
func (*ListDataExchangesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListDataExchangesResponse.ProtoReflect.Descriptor instead.
func (*ListDataExchangesResponse) GetDataExchanges ¶
func (x *ListDataExchangesResponse) GetDataExchanges() []*DataExchange
func (*ListDataExchangesResponse) GetNextPageToken ¶
func (x *ListDataExchangesResponse) GetNextPageToken() string
func (*ListDataExchangesResponse) ProtoMessage ¶
func (*ListDataExchangesResponse) ProtoMessage()
func (*ListDataExchangesResponse) ProtoReflect ¶
func (x *ListDataExchangesResponse) ProtoReflect() protoreflect.Message
func (*ListDataExchangesResponse) Reset ¶
func (x *ListDataExchangesResponse) Reset()
func (*ListDataExchangesResponse) String ¶
func (x *ListDataExchangesResponse) String() string
type ListListingsRequest ¶
type ListListingsRequest struct { // Required. The parent resource path of the listing. // e.g. `projects/myproject/locations/US/dataExchanges/123`. Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // The maximum number of results to return in a single response page. Leverage // the page tokens to iterate through the entire collection. PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // Page token, returned by a previous call, to request the next page of // results. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // contains filtered or unexported fields }
Message for requesting the list of listings.
func (*ListListingsRequest) Descriptor
deprecated
func (*ListListingsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListListingsRequest.ProtoReflect.Descriptor instead.
func (*ListListingsRequest) GetPageSize ¶
func (x *ListListingsRequest) GetPageSize() int32
func (*ListListingsRequest) GetPageToken ¶
func (x *ListListingsRequest) GetPageToken() string
func (*ListListingsRequest) GetParent ¶
func (x *ListListingsRequest) GetParent() string
func (*ListListingsRequest) ProtoMessage ¶
func (*ListListingsRequest) ProtoMessage()
func (*ListListingsRequest) ProtoReflect ¶
func (x *ListListingsRequest) ProtoReflect() protoreflect.Message
func (*ListListingsRequest) Reset ¶
func (x *ListListingsRequest) Reset()
func (*ListListingsRequest) String ¶
func (x *ListListingsRequest) String() string
type ListListingsResponse ¶
type ListListingsResponse struct { // The list of Listing. Listings []*Listing `protobuf:"bytes,1,rep,name=listings,proto3" json:"listings,omitempty"` // A token to request the next page of results. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
Message for response to the list of Listings.
func (*ListListingsResponse) Descriptor
deprecated
func (*ListListingsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListListingsResponse.ProtoReflect.Descriptor instead.
func (*ListListingsResponse) GetListings ¶
func (x *ListListingsResponse) GetListings() []*Listing
func (*ListListingsResponse) GetNextPageToken ¶
func (x *ListListingsResponse) GetNextPageToken() string
func (*ListListingsResponse) ProtoMessage ¶
func (*ListListingsResponse) ProtoMessage()
func (*ListListingsResponse) ProtoReflect ¶
func (x *ListListingsResponse) ProtoReflect() protoreflect.Message
func (*ListListingsResponse) Reset ¶
func (x *ListListingsResponse) Reset()
func (*ListListingsResponse) String ¶
func (x *ListListingsResponse) String() string
type ListOrgDataExchangesRequest ¶
type ListOrgDataExchangesRequest struct { // Required. The organization resource path of the projects containing // DataExchanges. e.g. `organizations/myorg/locations/US`. Organization string `protobuf:"bytes,1,opt,name=organization,proto3" json:"organization,omitempty"` // The maximum number of results to return in a single response page. Leverage // the page tokens to iterate through the entire collection. PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // Page token, returned by a previous call, to request the next page of // results. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // contains filtered or unexported fields }
Message for requesting the list of data exchanges from projects in an organization and location.
func (*ListOrgDataExchangesRequest) Descriptor
deprecated
func (*ListOrgDataExchangesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListOrgDataExchangesRequest.ProtoReflect.Descriptor instead.
func (*ListOrgDataExchangesRequest) GetOrganization ¶
func (x *ListOrgDataExchangesRequest) GetOrganization() string
func (*ListOrgDataExchangesRequest) GetPageSize ¶
func (x *ListOrgDataExchangesRequest) GetPageSize() int32
func (*ListOrgDataExchangesRequest) GetPageToken ¶
func (x *ListOrgDataExchangesRequest) GetPageToken() string
func (*ListOrgDataExchangesRequest) ProtoMessage ¶
func (*ListOrgDataExchangesRequest) ProtoMessage()
func (*ListOrgDataExchangesRequest) ProtoReflect ¶
func (x *ListOrgDataExchangesRequest) ProtoReflect() protoreflect.Message
func (*ListOrgDataExchangesRequest) Reset ¶
func (x *ListOrgDataExchangesRequest) Reset()
func (*ListOrgDataExchangesRequest) String ¶
func (x *ListOrgDataExchangesRequest) String() string
type ListOrgDataExchangesResponse ¶
type ListOrgDataExchangesResponse struct { // The list of data exchanges. DataExchanges []*DataExchange `protobuf:"bytes,1,rep,name=data_exchanges,json=dataExchanges,proto3" json:"data_exchanges,omitempty"` // A token to request the next page of results. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
Message for response to listing data exchanges in an organization and location.
func (*ListOrgDataExchangesResponse) Descriptor
deprecated
func (*ListOrgDataExchangesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListOrgDataExchangesResponse.ProtoReflect.Descriptor instead.
func (*ListOrgDataExchangesResponse) GetDataExchanges ¶
func (x *ListOrgDataExchangesResponse) GetDataExchanges() []*DataExchange
func (*ListOrgDataExchangesResponse) GetNextPageToken ¶
func (x *ListOrgDataExchangesResponse) GetNextPageToken() string
func (*ListOrgDataExchangesResponse) ProtoMessage ¶
func (*ListOrgDataExchangesResponse) ProtoMessage()
func (*ListOrgDataExchangesResponse) ProtoReflect ¶
func (x *ListOrgDataExchangesResponse) ProtoReflect() protoreflect.Message
func (*ListOrgDataExchangesResponse) Reset ¶
func (x *ListOrgDataExchangesResponse) Reset()
func (*ListOrgDataExchangesResponse) String ¶
func (x *ListOrgDataExchangesResponse) String() string
type ListSharedResourceSubscriptionsRequest ¶
type ListSharedResourceSubscriptionsRequest struct { // either a Listing or a DataExchange. e.g. // projects/123/locations/US/dataExchanges/456 OR e.g. // projects/123/locations/US/dataExchanges/456/listings/789 Resource string `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` // (up to 63 days after deletion). IncludeDeletedSubscriptions bool `` /* 145-byte string literal not displayed */ PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // contains filtered or unexported fields }
Message for listing subscriptions of a shared resource.
func (*ListSharedResourceSubscriptionsRequest) Descriptor
deprecated
func (*ListSharedResourceSubscriptionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListSharedResourceSubscriptionsRequest.ProtoReflect.Descriptor instead.
func (*ListSharedResourceSubscriptionsRequest) GetIncludeDeletedSubscriptions ¶
func (x *ListSharedResourceSubscriptionsRequest) GetIncludeDeletedSubscriptions() bool
func (*ListSharedResourceSubscriptionsRequest) GetPageSize ¶
func (x *ListSharedResourceSubscriptionsRequest) GetPageSize() int32
func (*ListSharedResourceSubscriptionsRequest) GetPageToken ¶
func (x *ListSharedResourceSubscriptionsRequest) GetPageToken() string
func (*ListSharedResourceSubscriptionsRequest) GetResource ¶
func (x *ListSharedResourceSubscriptionsRequest) GetResource() string
func (*ListSharedResourceSubscriptionsRequest) ProtoMessage ¶
func (*ListSharedResourceSubscriptionsRequest) ProtoMessage()
func (*ListSharedResourceSubscriptionsRequest) ProtoReflect ¶
func (x *ListSharedResourceSubscriptionsRequest) ProtoReflect() protoreflect.Message
func (*ListSharedResourceSubscriptionsRequest) Reset ¶
func (x *ListSharedResourceSubscriptionsRequest) Reset()
func (*ListSharedResourceSubscriptionsRequest) String ¶
func (x *ListSharedResourceSubscriptionsRequest) String() string
type ListSharedResourceSubscriptionsResponse ¶
type ListSharedResourceSubscriptionsResponse struct { Subscription `` /* 144-byte string literal not displayed */ NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }SharedResourceSubscriptions []*
Message for response to the listing of shared resource subscriptions.
func (*ListSharedResourceSubscriptionsResponse) Descriptor
deprecated
func (*ListSharedResourceSubscriptionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListSharedResourceSubscriptionsResponse.ProtoReflect.Descriptor instead.
func (*ListSharedResourceSubscriptionsResponse) GetNextPageToken ¶
func (x *ListSharedResourceSubscriptionsResponse) GetNextPageToken() string
func (*ListSharedResourceSubscriptionsResponse) GetSharedResourceSubscriptions ¶
func (x *ListSharedResourceSubscriptionsResponse) GetSharedResourceSubscriptions() []*Subscription
func (*ListSharedResourceSubscriptionsResponse) ProtoMessage ¶
func (*ListSharedResourceSubscriptionsResponse) ProtoMessage()
func (*ListSharedResourceSubscriptionsResponse) ProtoReflect ¶
func (x *ListSharedResourceSubscriptionsResponse) ProtoReflect() protoreflect.Message
func (*ListSharedResourceSubscriptionsResponse) Reset ¶
func (x *ListSharedResourceSubscriptionsResponse) Reset()
func (*ListSharedResourceSubscriptionsResponse) String ¶
func (x *ListSharedResourceSubscriptionsResponse) String() string
type ListSubscriptionsRequest ¶
type ListSubscriptionsRequest struct { // Required. The parent resource path of the subscription. // e.g. projects/myproject/locations/US Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // An expression for filtering the results of the request. Eligible // fields for filtering are: // // - `listing` // - `data_exchange` // // Alternatively, a literal wrapped in double quotes may be provided. // This will be checked for an exact match against both fields above. // // In all cases, the full Data Exchange or Listing resource name must // be provided. Some example of using filters: // // - data_exchange="projects/myproject/locations/us/dataExchanges/123" // - listing="projects/123/locations/us/dataExchanges/456/listings/789" // - "projects/myproject/locations/us/dataExchanges/123" Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` // The maximum number of results to return in a single response page. PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // Page token, returned by a previous call. PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // contains filtered or unexported fields }
Message for listing subscriptions.
func (*ListSubscriptionsRequest) Descriptor
deprecated
func (*ListSubscriptionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListSubscriptionsRequest.ProtoReflect.Descriptor instead.
func (*ListSubscriptionsRequest) GetFilter ¶
func (x *ListSubscriptionsRequest) GetFilter() string
func (*ListSubscriptionsRequest) GetPageSize ¶
func (x *ListSubscriptionsRequest) GetPageSize() int32
func (*ListSubscriptionsRequest) GetPageToken ¶
func (x *ListSubscriptionsRequest) GetPageToken() string
func (*ListSubscriptionsRequest) GetParent ¶
func (x *ListSubscriptionsRequest) GetParent() string
func (*ListSubscriptionsRequest) ProtoMessage ¶
func (*ListSubscriptionsRequest) ProtoMessage()
func (*ListSubscriptionsRequest) ProtoReflect ¶
func (x *ListSubscriptionsRequest) ProtoReflect() protoreflect.Message
func (*ListSubscriptionsRequest) Reset ¶
func (x *ListSubscriptionsRequest) Reset()
func (*ListSubscriptionsRequest) String ¶
func (x *ListSubscriptionsRequest) String() string
type ListSubscriptionsResponse ¶
type ListSubscriptionsResponse struct { // The list of subscriptions. Subscriptions []*Subscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` // Next page token. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
Message for response to the listing of subscriptions.
func (*ListSubscriptionsResponse) Descriptor
deprecated
func (*ListSubscriptionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListSubscriptionsResponse.ProtoReflect.Descriptor instead.
func (*ListSubscriptionsResponse) GetNextPageToken ¶
func (x *ListSubscriptionsResponse) GetNextPageToken() string
func (*ListSubscriptionsResponse) GetSubscriptions ¶
func (x *ListSubscriptionsResponse) GetSubscriptions() []*Subscription
func (*ListSubscriptionsResponse) ProtoMessage ¶
func (*ListSubscriptionsResponse) ProtoMessage()
func (*ListSubscriptionsResponse) ProtoReflect ¶
func (x *ListSubscriptionsResponse) ProtoReflect() protoreflect.Message
func (*ListSubscriptionsResponse) Reset ¶
func (x *ListSubscriptionsResponse) Reset()
func (*ListSubscriptionsResponse) String ¶
func (x *ListSubscriptionsResponse) String() string
type Listing ¶
type Listing struct { // Listing source. // // Types that are assignable to Source: // // *Listing_BigqueryDataset Source isListing_Source `protobuf_oneof:"source"` // Output only. The resource name of the listing. // e.g. `projects/myproject/locations/US/dataExchanges/123/listings/456` Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Required. Human-readable display name of the listing. The display name must // contain only Unicode letters, numbers (0-9), underscores (_), dashes (-), // spaces ( ), ampersands (&) and can't start or end with spaces. Default // value is an empty string. Max length: 63 bytes. DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"` // Optional. Short description of the listing. The description must not // contain Unicode non-characters and C0 and C1 control codes except tabs // (HT), new lines (LF), carriage returns (CR), and page breaks (FF). Default // value is an empty string. Max length: 2000 bytes. Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` // Optional. Email or URL of the primary point of contact of the listing. // Max Length: 1000 bytes. PrimaryContact string `protobuf:"bytes,4,opt,name=primary_contact,json=primaryContact,proto3" json:"primary_contact,omitempty"` // Optional. Documentation describing the listing. Documentation string `protobuf:"bytes,5,opt,name=documentation,proto3" json:"documentation,omitempty"` // Output only. Current state of the listing. State Listing_State `protobuf:"varint,7,opt,name=state,proto3,enum=mockgcp.cloud.bigquery.analyticshub.v1.Listing_State" json:"state,omitempty"` // Optional. Base64 encoded image representing the listing. Max Size: 3.0MiB // Expected image dimensions are 512x512 pixels, however the API only // performs validation on size of the encoded data. // Note: For byte fields, the contents of the field are base64-encoded (which // increases the size of the data by 33-36%) when using JSON on the wire. Icon []byte `protobuf:"bytes,8,opt,name=icon,proto3" json:"icon,omitempty"` // Optional. Details of the data provider who owns the source data. DataProvider *DataProvider `protobuf:"bytes,9,opt,name=data_provider,json=dataProvider,proto3" json:"data_provider,omitempty"` // Optional. Categories of the listing. Up to two categories are allowed. Categories []Listing_Category `` /* 143-byte string literal not displayed */ // Optional. Details of the publisher who owns the listing and who can share // the source data. Publisher *Publisher `protobuf:"bytes,11,opt,name=publisher,proto3" json:"publisher,omitempty"` // Optional. Email or URL of the request access of the listing. // Subscribers can use this reference to request access. // Max Length: 1000 bytes. RequestAccess string `protobuf:"bytes,12,opt,name=request_access,json=requestAccess,proto3" json:"request_access,omitempty"` // Optional. If set, restricted export configuration will be propagated and // enforced on the linked dataset. RestrictedExportConfig *Listing_RestrictedExportConfig `` /* 130-byte string literal not displayed */ // Optional. Type of discovery of the listing on the discovery page. DiscoveryType *DiscoveryType `` /* 166-byte string literal not displayed */ // contains filtered or unexported fields }
A listing is what gets published into a data exchange that a subscriber can subscribe to. It contains a reference to the data source along with descriptive information that will help subscribers find and subscribe the data.
func (*Listing) Descriptor
deprecated
func (*Listing) GetBigqueryDataset ¶
func (x *Listing) GetBigqueryDataset() *Listing_BigQueryDatasetSource
func (*Listing) GetCategories ¶
func (x *Listing) GetCategories() []Listing_Category
func (*Listing) GetDataProvider ¶
func (x *Listing) GetDataProvider() *DataProvider
func (*Listing) GetDescription ¶
func (*Listing) GetDiscoveryType ¶
func (x *Listing) GetDiscoveryType() DiscoveryType
func (*Listing) GetDisplayName ¶
func (*Listing) GetDocumentation ¶
func (*Listing) GetPrimaryContact ¶
func (*Listing) GetPublisher ¶
func (*Listing) GetRequestAccess ¶
func (*Listing) GetRestrictedExportConfig ¶
func (x *Listing) GetRestrictedExportConfig() *Listing_RestrictedExportConfig
func (*Listing) GetState ¶
func (x *Listing) GetState() Listing_State
func (*Listing) ProtoMessage ¶
func (*Listing) ProtoMessage()
func (*Listing) ProtoReflect ¶
func (x *Listing) ProtoReflect() protoreflect.Message
type Listing_BigQueryDatasetSource ¶
type Listing_BigQueryDatasetSource struct { // Resource name of the dataset source for this listing. // e.g. `projects/myproject/datasets/123` Dataset string `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"` // Optional. Resources in this dataset that are selectively shared. // If this field is empty, then the entire dataset (all resources) are // shared. This field is only valid for data clean room exchanges. SelectedResources []*Listing_BigQueryDatasetSource_SelectedResource `protobuf:"bytes,2,rep,name=selected_resources,json=selectedResources,proto3" json:"selected_resources,omitempty"` // Optional. If set, restricted export policy will be propagated and // enforced on the linked dataset. RestrictedExportPolicy *Listing_BigQueryDatasetSource_RestrictedExportPolicy `` /* 129-byte string literal not displayed */ // contains filtered or unexported fields }
A reference to a shared dataset. It is an existing BigQuery dataset with a collection of objects such as tables and views that you want to share with subscribers. When subscriber's subscribe to a listing, Analytics Hub creates a linked dataset in the subscriber's project. A Linked dataset is an opaque, read-only BigQuery dataset that serves as a _symbolic link_ to a shared dataset.
func (*Listing_BigQueryDatasetSource) Descriptor
deprecated
func (*Listing_BigQueryDatasetSource) Descriptor() ([]byte, []int)
Deprecated: Use Listing_BigQueryDatasetSource.ProtoReflect.Descriptor instead.
func (*Listing_BigQueryDatasetSource) GetDataset ¶
func (x *Listing_BigQueryDatasetSource) GetDataset() string
func (*Listing_BigQueryDatasetSource) GetRestrictedExportPolicy ¶
func (x *Listing_BigQueryDatasetSource) GetRestrictedExportPolicy() *Listing_BigQueryDatasetSource_RestrictedExportPolicy
func (*Listing_BigQueryDatasetSource) GetSelectedResources ¶
func (x *Listing_BigQueryDatasetSource) GetSelectedResources() []*Listing_BigQueryDatasetSource_SelectedResource
func (*Listing_BigQueryDatasetSource) ProtoMessage ¶
func (*Listing_BigQueryDatasetSource) ProtoMessage()
func (*Listing_BigQueryDatasetSource) ProtoReflect ¶
func (x *Listing_BigQueryDatasetSource) ProtoReflect() protoreflect.Message
func (*Listing_BigQueryDatasetSource) Reset ¶
func (x *Listing_BigQueryDatasetSource) Reset()
func (*Listing_BigQueryDatasetSource) String ¶
func (x *Listing_BigQueryDatasetSource) String() string
type Listing_BigQueryDatasetSource_RestrictedExportPolicy ¶
type Listing_BigQueryDatasetSource_RestrictedExportPolicy struct { // Optional. If true, enable restricted export. Enabled *wrappers.BoolValue `protobuf:"bytes,1,opt,name=enabled,proto3" json:"enabled,omitempty"` // Optional. If true, restrict direct table access (read // api/tabledata.list) on linked table. RestrictDirectTableAccess *wrappers.BoolValue `` /* 140-byte string literal not displayed */ // Optional. If true, restrict export of query result derived from // restricted linked dataset table. RestrictQueryResult *wrappers.BoolValue `protobuf:"bytes,3,opt,name=restrict_query_result,json=restrictQueryResult,proto3" json:"restrict_query_result,omitempty"` // contains filtered or unexported fields }
Restricted export policy used to configure restricted export on linked dataset.
func (*Listing_BigQueryDatasetSource_RestrictedExportPolicy) Descriptor
deprecated
func (*Listing_BigQueryDatasetSource_RestrictedExportPolicy) Descriptor() ([]byte, []int)
Deprecated: Use Listing_BigQueryDatasetSource_RestrictedExportPolicy.ProtoReflect.Descriptor instead.
func (*Listing_BigQueryDatasetSource_RestrictedExportPolicy) GetEnabled ¶
func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) GetEnabled() *wrappers.BoolValue
func (*Listing_BigQueryDatasetSource_RestrictedExportPolicy) GetRestrictDirectTableAccess ¶
func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) GetRestrictDirectTableAccess() *wrappers.BoolValue
func (*Listing_BigQueryDatasetSource_RestrictedExportPolicy) GetRestrictQueryResult ¶
func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) GetRestrictQueryResult() *wrappers.BoolValue
func (*Listing_BigQueryDatasetSource_RestrictedExportPolicy) ProtoMessage ¶
func (*Listing_BigQueryDatasetSource_RestrictedExportPolicy) ProtoMessage()
func (*Listing_BigQueryDatasetSource_RestrictedExportPolicy) ProtoReflect ¶
func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) ProtoReflect() protoreflect.Message
func (*Listing_BigQueryDatasetSource_RestrictedExportPolicy) Reset ¶
func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) Reset()
func (*Listing_BigQueryDatasetSource_RestrictedExportPolicy) String ¶
func (x *Listing_BigQueryDatasetSource_RestrictedExportPolicy) String() string
type Listing_BigQueryDatasetSource_SelectedResource ¶
type Listing_BigQueryDatasetSource_SelectedResource struct { // Types that are assignable to Resource: // // *Listing_BigQueryDatasetSource_SelectedResource_Table Resource isListing_BigQueryDatasetSource_SelectedResource_Resource `protobuf_oneof:"resource"` // contains filtered or unexported fields }
Resource in this dataset that are selectively shared.
func (*Listing_BigQueryDatasetSource_SelectedResource) Descriptor
deprecated
func (*Listing_BigQueryDatasetSource_SelectedResource) Descriptor() ([]byte, []int)
Deprecated: Use Listing_BigQueryDatasetSource_SelectedResource.ProtoReflect.Descriptor instead.
func (*Listing_BigQueryDatasetSource_SelectedResource) GetResource ¶
func (m *Listing_BigQueryDatasetSource_SelectedResource) GetResource() isListing_BigQueryDatasetSource_SelectedResource_Resource
func (*Listing_BigQueryDatasetSource_SelectedResource) GetTable ¶
func (x *Listing_BigQueryDatasetSource_SelectedResource) GetTable() string
func (*Listing_BigQueryDatasetSource_SelectedResource) ProtoMessage ¶
func (*Listing_BigQueryDatasetSource_SelectedResource) ProtoMessage()
func (*Listing_BigQueryDatasetSource_SelectedResource) ProtoReflect ¶
func (x *Listing_BigQueryDatasetSource_SelectedResource) ProtoReflect() protoreflect.Message
func (*Listing_BigQueryDatasetSource_SelectedResource) Reset ¶
func (x *Listing_BigQueryDatasetSource_SelectedResource) Reset()
func (*Listing_BigQueryDatasetSource_SelectedResource) String ¶
func (x *Listing_BigQueryDatasetSource_SelectedResource) String() string
type Listing_BigQueryDatasetSource_SelectedResource_Table ¶
type Listing_BigQueryDatasetSource_SelectedResource_Table struct { // Optional. Format: // For table: // `projects/{projectId}/datasets/{datasetId}/tables/{tableId}` // Example:"projects/test_project/datasets/test_dataset/tables/test_table" Table string `protobuf:"bytes,1,opt,name=table,proto3,oneof"` }
type Listing_BigqueryDataset ¶
type Listing_BigqueryDataset struct { // Required. Shared dataset i.e. BigQuery dataset source. BigqueryDataset *Listing_BigQueryDatasetSource `protobuf:"bytes,6,opt,name=bigquery_dataset,json=bigqueryDataset,proto3,oneof"` }
type Listing_Category ¶
type Listing_Category int32
Listing categories.
const ( Listing_CATEGORY_UNSPECIFIED Listing_Category = 0 Listing_CATEGORY_OTHERS Listing_Category = 1 Listing_CATEGORY_ADVERTISING_AND_MARKETING Listing_Category = 2 Listing_CATEGORY_COMMERCE Listing_Category = 3 Listing_CATEGORY_CLIMATE_AND_ENVIRONMENT Listing_Category = 4 Listing_CATEGORY_DEMOGRAPHICS Listing_Category = 5 Listing_CATEGORY_ECONOMICS Listing_Category = 6 Listing_CATEGORY_EDUCATION Listing_Category = 7 Listing_CATEGORY_ENERGY Listing_Category = 8 Listing_CATEGORY_FINANCIAL Listing_Category = 9 Listing_CATEGORY_GAMING Listing_Category = 10 Listing_CATEGORY_GEOSPATIAL Listing_Category = 11 Listing_CATEGORY_HEALTHCARE_AND_LIFE_SCIENCE Listing_Category = 12 Listing_CATEGORY_MEDIA Listing_Category = 13 Listing_CATEGORY_PUBLIC_SECTOR Listing_Category = 14 Listing_CATEGORY_RETAIL Listing_Category = 15 Listing_CATEGORY_SPORTS Listing_Category = 16 Listing_CATEGORY_SCIENCE_AND_RESEARCH Listing_Category = 17 Listing_CATEGORY_TRANSPORTATION_AND_LOGISTICS Listing_Category = 18 Listing_CATEGORY_TRAVEL_AND_TOURISM Listing_Category = 19 )
func (Listing_Category) Descriptor ¶
func (Listing_Category) Descriptor() protoreflect.EnumDescriptor
func (Listing_Category) Enum ¶
func (x Listing_Category) Enum() *Listing_Category
func (Listing_Category) EnumDescriptor
deprecated
func (Listing_Category) EnumDescriptor() ([]byte, []int)
Deprecated: Use Listing_Category.Descriptor instead.
func (Listing_Category) Number ¶
func (x Listing_Category) Number() protoreflect.EnumNumber
func (Listing_Category) String ¶
func (x Listing_Category) String() string
func (Listing_Category) Type ¶
func (Listing_Category) Type() protoreflect.EnumType
type Listing_RestrictedExportConfig ¶
type Listing_RestrictedExportConfig struct { // Optional. If true, enable restricted export. Enabled bool `protobuf:"varint,3,opt,name=enabled,proto3" json:"enabled,omitempty"` // Output only. If true, restrict direct table access(read // api/tabledata.list) on linked table. RestrictDirectTableAccess bool `` /* 141-byte string literal not displayed */ // Optional. If true, restrict export of query result derived from // restricted linked dataset table. RestrictQueryResult bool `protobuf:"varint,2,opt,name=restrict_query_result,json=restrictQueryResult,proto3" json:"restrict_query_result,omitempty"` // contains filtered or unexported fields }
Restricted export config, used to configure restricted export on linked dataset.
func (*Listing_RestrictedExportConfig) Descriptor
deprecated
func (*Listing_RestrictedExportConfig) Descriptor() ([]byte, []int)
Deprecated: Use Listing_RestrictedExportConfig.ProtoReflect.Descriptor instead.
func (*Listing_RestrictedExportConfig) GetEnabled ¶
func (x *Listing_RestrictedExportConfig) GetEnabled() bool
func (*Listing_RestrictedExportConfig) GetRestrictDirectTableAccess ¶
func (x *Listing_RestrictedExportConfig) GetRestrictDirectTableAccess() bool
func (*Listing_RestrictedExportConfig) GetRestrictQueryResult ¶
func (x *Listing_RestrictedExportConfig) GetRestrictQueryResult() bool
func (*Listing_RestrictedExportConfig) ProtoMessage ¶
func (*Listing_RestrictedExportConfig) ProtoMessage()
func (*Listing_RestrictedExportConfig) ProtoReflect ¶
func (x *Listing_RestrictedExportConfig) ProtoReflect() protoreflect.Message
func (*Listing_RestrictedExportConfig) Reset ¶
func (x *Listing_RestrictedExportConfig) Reset()
func (*Listing_RestrictedExportConfig) String ¶
func (x *Listing_RestrictedExportConfig) String() string
type Listing_State ¶
type Listing_State int32
State of the listing.
const ( // Default value. This value is unused. Listing_STATE_UNSPECIFIED Listing_State = 0 // Subscribable state. Users with dataexchange.listings.subscribe permission // can subscribe to this listing. Listing_ACTIVE Listing_State = 1 )
func (Listing_State) Descriptor ¶
func (Listing_State) Descriptor() protoreflect.EnumDescriptor
func (Listing_State) Enum ¶
func (x Listing_State) Enum() *Listing_State
func (Listing_State) EnumDescriptor
deprecated
func (Listing_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use Listing_State.Descriptor instead.
func (Listing_State) Number ¶
func (x Listing_State) Number() protoreflect.EnumNumber
func (Listing_State) String ¶
func (x Listing_State) String() string
func (Listing_State) Type ¶
func (Listing_State) Type() protoreflect.EnumType
type OperationMetadata ¶
type OperationMetadata struct { // Output only. The time the operation was created. CreateTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Output only. The time the operation finished running. EndTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` // Output only. Server-defined resource path for the target of the operation. Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` // Output only. Name of the verb executed by the operation. Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"` // Output only. Human-readable status of the operation, if any. StatusMessage string `protobuf:"bytes,5,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"` // Output only. Identifies whether the user has requested cancellation // of the operation. Operations that have successfully been cancelled // have [Operation.error][] value with a // [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to // `Code.CANCELLED`. RequestedCancellation bool `protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"` // Output only. API version used to start the operation. ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"` // contains filtered or unexported fields }
Represents the metadata of a long-running operation in Analytics Hub.
func (*OperationMetadata) Descriptor
deprecated
func (*OperationMetadata) Descriptor() ([]byte, []int)
Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.
func (*OperationMetadata) GetApiVersion ¶
func (x *OperationMetadata) GetApiVersion() string
func (*OperationMetadata) GetCreateTime ¶
func (x *OperationMetadata) GetCreateTime() *timestamp.Timestamp
func (*OperationMetadata) GetEndTime ¶
func (x *OperationMetadata) GetEndTime() *timestamp.Timestamp
func (*OperationMetadata) GetRequestedCancellation ¶
func (x *OperationMetadata) GetRequestedCancellation() bool
func (*OperationMetadata) GetStatusMessage ¶
func (x *OperationMetadata) GetStatusMessage() string
func (*OperationMetadata) GetTarget ¶
func (x *OperationMetadata) GetTarget() string
func (*OperationMetadata) GetVerb ¶
func (x *OperationMetadata) GetVerb() string
func (*OperationMetadata) ProtoMessage ¶
func (*OperationMetadata) ProtoMessage()
func (*OperationMetadata) ProtoReflect ¶
func (x *OperationMetadata) ProtoReflect() protoreflect.Message
func (*OperationMetadata) Reset ¶
func (x *OperationMetadata) Reset()
func (*OperationMetadata) String ¶
func (x *OperationMetadata) String() string
type Publisher ¶
type Publisher struct { // Optional. Name of the listing publisher. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Optional. Email or URL of the listing publisher. // Max Length: 1000 bytes. PrimaryContact string `protobuf:"bytes,2,opt,name=primary_contact,json=primaryContact,proto3" json:"primary_contact,omitempty"` // contains filtered or unexported fields }
Contains details of the listing publisher.
func (*Publisher) Descriptor
deprecated
func (*Publisher) GetPrimaryContact ¶
func (*Publisher) ProtoMessage ¶
func (*Publisher) ProtoMessage()
func (*Publisher) ProtoReflect ¶
func (x *Publisher) ProtoReflect() protoreflect.Message
type RefreshSubscriptionRequest ¶
type RefreshSubscriptionRequest struct { // Required. Resource name of the Subscription to refresh. // e.g. `projects/subscriberproject/locations/US/subscriptions/123` Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Message for refreshing a subscription.
func (*RefreshSubscriptionRequest) Descriptor
deprecated
func (*RefreshSubscriptionRequest) Descriptor() ([]byte, []int)
Deprecated: Use RefreshSubscriptionRequest.ProtoReflect.Descriptor instead.
func (*RefreshSubscriptionRequest) GetName ¶
func (x *RefreshSubscriptionRequest) GetName() string
func (*RefreshSubscriptionRequest) ProtoMessage ¶
func (*RefreshSubscriptionRequest) ProtoMessage()
func (*RefreshSubscriptionRequest) ProtoReflect ¶
func (x *RefreshSubscriptionRequest) ProtoReflect() protoreflect.Message
func (*RefreshSubscriptionRequest) Reset ¶
func (x *RefreshSubscriptionRequest) Reset()
func (*RefreshSubscriptionRequest) String ¶
func (x *RefreshSubscriptionRequest) String() string
type RefreshSubscriptionResponse ¶
type RefreshSubscriptionResponse struct { // The refreshed subscription resource. Subscription *Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` // contains filtered or unexported fields }
Message for response when you refresh a subscription.
func (*RefreshSubscriptionResponse) Descriptor
deprecated
func (*RefreshSubscriptionResponse) Descriptor() ([]byte, []int)
Deprecated: Use RefreshSubscriptionResponse.ProtoReflect.Descriptor instead.
func (*RefreshSubscriptionResponse) GetSubscription ¶
func (x *RefreshSubscriptionResponse) GetSubscription() *Subscription
func (*RefreshSubscriptionResponse) ProtoMessage ¶
func (*RefreshSubscriptionResponse) ProtoMessage()
func (*RefreshSubscriptionResponse) ProtoReflect ¶
func (x *RefreshSubscriptionResponse) ProtoReflect() protoreflect.Message
func (*RefreshSubscriptionResponse) Reset ¶
func (x *RefreshSubscriptionResponse) Reset()
func (*RefreshSubscriptionResponse) String ¶
func (x *RefreshSubscriptionResponse) String() string
type RevokeSubscriptionRequest ¶
type RevokeSubscriptionRequest struct { // Required. Resource name of the subscription to revoke. // e.g. projects/123/locations/US/subscriptions/456 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Message for revoking a subscription.
func (*RevokeSubscriptionRequest) Descriptor
deprecated
func (*RevokeSubscriptionRequest) Descriptor() ([]byte, []int)
Deprecated: Use RevokeSubscriptionRequest.ProtoReflect.Descriptor instead.
func (*RevokeSubscriptionRequest) GetName ¶
func (x *RevokeSubscriptionRequest) GetName() string
func (*RevokeSubscriptionRequest) ProtoMessage ¶
func (*RevokeSubscriptionRequest) ProtoMessage()
func (*RevokeSubscriptionRequest) ProtoReflect ¶
func (x *RevokeSubscriptionRequest) ProtoReflect() protoreflect.Message
func (*RevokeSubscriptionRequest) Reset ¶
func (x *RevokeSubscriptionRequest) Reset()
func (*RevokeSubscriptionRequest) String ¶
func (x *RevokeSubscriptionRequest) String() string
type RevokeSubscriptionResponse ¶
type RevokeSubscriptionResponse struct {
// contains filtered or unexported fields
}
Message for response when you revoke a subscription.
func (*RevokeSubscriptionResponse) Descriptor
deprecated
func (*RevokeSubscriptionResponse) Descriptor() ([]byte, []int)
Deprecated: Use RevokeSubscriptionResponse.ProtoReflect.Descriptor instead.
func (*RevokeSubscriptionResponse) ProtoMessage ¶
func (*RevokeSubscriptionResponse) ProtoMessage()
func (*RevokeSubscriptionResponse) ProtoReflect ¶
func (x *RevokeSubscriptionResponse) ProtoReflect() protoreflect.Message
func (*RevokeSubscriptionResponse) Reset ¶
func (x *RevokeSubscriptionResponse) Reset()
func (*RevokeSubscriptionResponse) String ¶
func (x *RevokeSubscriptionResponse) String() string
type SharingEnvironmentConfig ¶
type SharingEnvironmentConfig struct { // Types that are assignable to Environment: // // *SharingEnvironmentConfig_DefaultExchangeConfig_ // *SharingEnvironmentConfig_DcrExchangeConfig_ Environment isSharingEnvironmentConfig_Environment `protobuf_oneof:"environment"` // contains filtered or unexported fields }
Sharing environment is a behavior model for sharing data within a data exchange. This option is configurable for a data exchange.
func (*SharingEnvironmentConfig) Descriptor
deprecated
func (*SharingEnvironmentConfig) Descriptor() ([]byte, []int)
Deprecated: Use SharingEnvironmentConfig.ProtoReflect.Descriptor instead.
func (*SharingEnvironmentConfig) GetDcrExchangeConfig ¶
func (x *SharingEnvironmentConfig) GetDcrExchangeConfig() *SharingEnvironmentConfig_DcrExchangeConfig
func (*SharingEnvironmentConfig) GetDefaultExchangeConfig ¶
func (x *SharingEnvironmentConfig) GetDefaultExchangeConfig() *SharingEnvironmentConfig_DefaultExchangeConfig
func (*SharingEnvironmentConfig) GetEnvironment ¶
func (m *SharingEnvironmentConfig) GetEnvironment() isSharingEnvironmentConfig_Environment
func (*SharingEnvironmentConfig) ProtoMessage ¶
func (*SharingEnvironmentConfig) ProtoMessage()
func (*SharingEnvironmentConfig) ProtoReflect ¶
func (x *SharingEnvironmentConfig) ProtoReflect() protoreflect.Message
func (*SharingEnvironmentConfig) Reset ¶
func (x *SharingEnvironmentConfig) Reset()
func (*SharingEnvironmentConfig) String ¶
func (x *SharingEnvironmentConfig) String() string
type SharingEnvironmentConfig_DcrExchangeConfig ¶
type SharingEnvironmentConfig_DcrExchangeConfig struct { // Output only. If True, this DCR restricts the contributors to sharing // only a single resource in a Listing. And no two resources should have the // same IDs. So if a contributor adds a view with a conflicting name, the // CreateListing API will reject the request. if False, the data contributor // can publish an entire dataset (as before). This is not configurable, and // by default, all new DCRs will have the restriction set to True. SingleSelectedResourceSharingRestriction *bool `` /* 194-byte string literal not displayed */ // Output only. If True, when subscribing to this DCR, it will create only // one linked dataset containing all resources shared within the // cleanroom. If False, when subscribing to this DCR, it will // create 1 linked dataset per listing. This is not configurable, and by // default, all new DCRs will have the restriction set to True. SingleLinkedDatasetPerCleanroom *bool `` /* 167-byte string literal not displayed */ // contains filtered or unexported fields }
Data Clean Room (DCR), used for privacy-safe and secured data sharing.
func (*SharingEnvironmentConfig_DcrExchangeConfig) Descriptor
deprecated
func (*SharingEnvironmentConfig_DcrExchangeConfig) Descriptor() ([]byte, []int)
Deprecated: Use SharingEnvironmentConfig_DcrExchangeConfig.ProtoReflect.Descriptor instead.
func (*SharingEnvironmentConfig_DcrExchangeConfig) GetSingleLinkedDatasetPerCleanroom ¶
func (x *SharingEnvironmentConfig_DcrExchangeConfig) GetSingleLinkedDatasetPerCleanroom() bool
func (*SharingEnvironmentConfig_DcrExchangeConfig) GetSingleSelectedResourceSharingRestriction ¶
func (x *SharingEnvironmentConfig_DcrExchangeConfig) GetSingleSelectedResourceSharingRestriction() bool
func (*SharingEnvironmentConfig_DcrExchangeConfig) ProtoMessage ¶
func (*SharingEnvironmentConfig_DcrExchangeConfig) ProtoMessage()
func (*SharingEnvironmentConfig_DcrExchangeConfig) ProtoReflect ¶
func (x *SharingEnvironmentConfig_DcrExchangeConfig) ProtoReflect() protoreflect.Message
func (*SharingEnvironmentConfig_DcrExchangeConfig) Reset ¶
func (x *SharingEnvironmentConfig_DcrExchangeConfig) Reset()
func (*SharingEnvironmentConfig_DcrExchangeConfig) String ¶
func (x *SharingEnvironmentConfig_DcrExchangeConfig) String() string
type SharingEnvironmentConfig_DcrExchangeConfig_ ¶
type SharingEnvironmentConfig_DcrExchangeConfig_ struct { // Data Clean Room (DCR), used for privacy-safe and secured data sharing. DcrExchangeConfig *SharingEnvironmentConfig_DcrExchangeConfig `protobuf:"bytes,2,opt,name=dcr_exchange_config,json=dcrExchangeConfig,proto3,oneof"` }
type SharingEnvironmentConfig_DefaultExchangeConfig ¶
type SharingEnvironmentConfig_DefaultExchangeConfig struct {
// contains filtered or unexported fields
}
Default Analytics Hub data exchange, used for secured data sharing.
func (*SharingEnvironmentConfig_DefaultExchangeConfig) Descriptor
deprecated
func (*SharingEnvironmentConfig_DefaultExchangeConfig) Descriptor() ([]byte, []int)
Deprecated: Use SharingEnvironmentConfig_DefaultExchangeConfig.ProtoReflect.Descriptor instead.
func (*SharingEnvironmentConfig_DefaultExchangeConfig) ProtoMessage ¶
func (*SharingEnvironmentConfig_DefaultExchangeConfig) ProtoMessage()
func (*SharingEnvironmentConfig_DefaultExchangeConfig) ProtoReflect ¶
func (x *SharingEnvironmentConfig_DefaultExchangeConfig) ProtoReflect() protoreflect.Message
func (*SharingEnvironmentConfig_DefaultExchangeConfig) Reset ¶
func (x *SharingEnvironmentConfig_DefaultExchangeConfig) Reset()
func (*SharingEnvironmentConfig_DefaultExchangeConfig) String ¶
func (x *SharingEnvironmentConfig_DefaultExchangeConfig) String() string
type SharingEnvironmentConfig_DefaultExchangeConfig_ ¶
type SharingEnvironmentConfig_DefaultExchangeConfig_ struct { // Default Analytics Hub data exchange, used for secured data sharing. DefaultExchangeConfig *SharingEnvironmentConfig_DefaultExchangeConfig `protobuf:"bytes,1,opt,name=default_exchange_config,json=defaultExchangeConfig,proto3,oneof"` }
type SubscribeDataExchangeRequest ¶
type SubscribeDataExchangeRequest struct { // Required. Resource name of the Data Exchange. // e.g. `projects/publisherproject/locations/US/dataExchanges/123` Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Required. The parent resource path of the Subscription. // e.g. `projects/subscriberproject/locations/US` Destination string `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"` // Required. Name of the subscription to create. // e.g. `subscription1` Subscription string `protobuf:"bytes,4,opt,name=subscription,proto3" json:"subscription,omitempty"` // Email of the subscriber. SubscriberContact string `protobuf:"bytes,3,opt,name=subscriber_contact,json=subscriberContact,proto3" json:"subscriber_contact,omitempty"` // contains filtered or unexported fields }
Message for subscribing to a Data Exchange.
func (*SubscribeDataExchangeRequest) Descriptor
deprecated
func (*SubscribeDataExchangeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeDataExchangeRequest.ProtoReflect.Descriptor instead.
func (*SubscribeDataExchangeRequest) GetDestination ¶
func (x *SubscribeDataExchangeRequest) GetDestination() string
func (*SubscribeDataExchangeRequest) GetName ¶
func (x *SubscribeDataExchangeRequest) GetName() string
func (*SubscribeDataExchangeRequest) GetSubscriberContact ¶
func (x *SubscribeDataExchangeRequest) GetSubscriberContact() string
func (*SubscribeDataExchangeRequest) GetSubscription ¶
func (x *SubscribeDataExchangeRequest) GetSubscription() string
func (*SubscribeDataExchangeRequest) ProtoMessage ¶
func (*SubscribeDataExchangeRequest) ProtoMessage()
func (*SubscribeDataExchangeRequest) ProtoReflect ¶
func (x *SubscribeDataExchangeRequest) ProtoReflect() protoreflect.Message
func (*SubscribeDataExchangeRequest) Reset ¶
func (x *SubscribeDataExchangeRequest) Reset()
func (*SubscribeDataExchangeRequest) String ¶
func (x *SubscribeDataExchangeRequest) String() string
type SubscribeDataExchangeResponse ¶
type SubscribeDataExchangeResponse struct { // Subscription object created from this subscribe action. Subscription *Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` // contains filtered or unexported fields }
Message for response when you subscribe to a Data Exchange.
func (*SubscribeDataExchangeResponse) Descriptor
deprecated
func (*SubscribeDataExchangeResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeDataExchangeResponse.ProtoReflect.Descriptor instead.
func (*SubscribeDataExchangeResponse) GetSubscription ¶
func (x *SubscribeDataExchangeResponse) GetSubscription() *Subscription
func (*SubscribeDataExchangeResponse) ProtoMessage ¶
func (*SubscribeDataExchangeResponse) ProtoMessage()
func (*SubscribeDataExchangeResponse) ProtoReflect ¶
func (x *SubscribeDataExchangeResponse) ProtoReflect() protoreflect.Message
func (*SubscribeDataExchangeResponse) Reset ¶
func (x *SubscribeDataExchangeResponse) Reset()
func (*SubscribeDataExchangeResponse) String ¶
func (x *SubscribeDataExchangeResponse) String() string
type SubscribeListingRequest ¶
type SubscribeListingRequest struct { // Resulting destination of the listing that you subscribed to. // // Types that are assignable to Destination: // // *SubscribeListingRequest_DestinationDataset Destination isSubscribeListingRequest_Destination `protobuf_oneof:"destination"` // Required. Resource name of the listing that you want to subscribe to. // e.g. `projects/myproject/locations/US/dataExchanges/123/listings/456`. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Message for subscribing to a listing.
func (*SubscribeListingRequest) Descriptor
deprecated
func (*SubscribeListingRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeListingRequest.ProtoReflect.Descriptor instead.
func (*SubscribeListingRequest) GetDestination ¶
func (m *SubscribeListingRequest) GetDestination() isSubscribeListingRequest_Destination
func (*SubscribeListingRequest) GetDestinationDataset ¶
func (x *SubscribeListingRequest) GetDestinationDataset() *DestinationDataset
func (*SubscribeListingRequest) GetName ¶
func (x *SubscribeListingRequest) GetName() string
func (*SubscribeListingRequest) ProtoMessage ¶
func (*SubscribeListingRequest) ProtoMessage()
func (*SubscribeListingRequest) ProtoReflect ¶
func (x *SubscribeListingRequest) ProtoReflect() protoreflect.Message
func (*SubscribeListingRequest) Reset ¶
func (x *SubscribeListingRequest) Reset()
func (*SubscribeListingRequest) String ¶
func (x *SubscribeListingRequest) String() string
type SubscribeListingRequest_DestinationDataset ¶
type SubscribeListingRequest_DestinationDataset struct { // Input only. BigQuery destination dataset to create for the subscriber. DestinationDataset *DestinationDataset `protobuf:"bytes,3,opt,name=destination_dataset,json=destinationDataset,proto3,oneof"` }
type SubscribeListingResponse ¶
type SubscribeListingResponse struct { // Subscription object created from this subscribe action. Subscription *Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` // contains filtered or unexported fields }
Message for response when you subscribe to a listing.
func (*SubscribeListingResponse) Descriptor
deprecated
func (*SubscribeListingResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeListingResponse.ProtoReflect.Descriptor instead.
func (*SubscribeListingResponse) GetSubscription ¶
func (x *SubscribeListingResponse) GetSubscription() *Subscription
func (*SubscribeListingResponse) ProtoMessage ¶
func (*SubscribeListingResponse) ProtoMessage()
func (*SubscribeListingResponse) ProtoReflect ¶
func (x *SubscribeListingResponse) ProtoReflect() protoreflect.Message
func (*SubscribeListingResponse) Reset ¶
func (x *SubscribeListingResponse) Reset()
func (*SubscribeListingResponse) String ¶
func (x *SubscribeListingResponse) String() string
type Subscription ¶
type Subscription struct { // Types that are assignable to ResourceName: // // *Subscription_Listing // *Subscription_DataExchange ResourceName isSubscription_ResourceName `protobuf_oneof:"resource_name"` // Output only. The resource name of the subscription. // e.g. `projects/myproject/locations/US/subscriptions/123`. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Output only. Timestamp when the subscription was created. CreationTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"` // Output only. Timestamp when the subscription was last modified. LastModifyTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=last_modify_time,json=lastModifyTime,proto3" json:"last_modify_time,omitempty"` // Output only. Organization of the project this subscription belongs to. OrganizationId string `protobuf:"bytes,4,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"` // Output only. Display name of the project of this subscription. OrganizationDisplayName string `` /* 133-byte string literal not displayed */ // Output only. Current state of the subscription. State Subscription_State `` /* 127-byte string literal not displayed */ // Output only. Map of listing resource names to associated linked resource, // e.g. projects/123/locations/US/dataExchanges/456/listings/789 // -> // projects/123/datasets/my_dataset // // For listing-level subscriptions, this is a map of size 1. // Only contains values if state == STATE_ACTIVE. LinkedDatasetMap map[string]*Subscription_LinkedResource `` /* 199-byte string literal not displayed */ // Output only. Email of the subscriber. SubscriberContact string `protobuf:"bytes,9,opt,name=subscriber_contact,json=subscriberContact,proto3" json:"subscriber_contact,omitempty"` // contains filtered or unexported fields }
A subscription represents a subscribers' access to a particular set of published data. It contains references to associated listings, data exchanges, and linked datasets.
func (*Subscription) Descriptor
deprecated
func (*Subscription) Descriptor() ([]byte, []int)
Deprecated: Use Subscription.ProtoReflect.Descriptor instead.
func (*Subscription) GetCreationTime ¶
func (x *Subscription) GetCreationTime() *timestamp.Timestamp
func (*Subscription) GetDataExchange ¶
func (x *Subscription) GetDataExchange() string
func (*Subscription) GetLastModifyTime ¶
func (x *Subscription) GetLastModifyTime() *timestamp.Timestamp
func (*Subscription) GetLinkedDatasetMap ¶
func (x *Subscription) GetLinkedDatasetMap() map[string]*Subscription_LinkedResource
func (*Subscription) GetListing ¶
func (x *Subscription) GetListing() string
func (*Subscription) GetName ¶
func (x *Subscription) GetName() string
func (*Subscription) GetOrganizationDisplayName ¶
func (x *Subscription) GetOrganizationDisplayName() string
func (*Subscription) GetOrganizationId ¶
func (x *Subscription) GetOrganizationId() string
func (*Subscription) GetResourceName ¶
func (m *Subscription) GetResourceName() isSubscription_ResourceName
func (*Subscription) GetState ¶
func (x *Subscription) GetState() Subscription_State
func (*Subscription) GetSubscriberContact ¶
func (x *Subscription) GetSubscriberContact() string
func (*Subscription) ProtoMessage ¶
func (*Subscription) ProtoMessage()
func (*Subscription) ProtoReflect ¶
func (x *Subscription) ProtoReflect() protoreflect.Message
func (*Subscription) Reset ¶
func (x *Subscription) Reset()
func (*Subscription) String ¶
func (x *Subscription) String() string
type Subscription_DataExchange ¶
type Subscription_DataExchange struct { // Output only. Resource name of the source Data Exchange. // e.g. projects/123/locations/US/dataExchanges/456 DataExchange string `protobuf:"bytes,6,opt,name=data_exchange,json=dataExchange,proto3,oneof"` }
type Subscription_LinkedResource ¶
type Subscription_LinkedResource struct { // Types that are assignable to Reference: // // *Subscription_LinkedResource_LinkedDataset Reference isSubscription_LinkedResource_Reference `protobuf_oneof:"reference"` // contains filtered or unexported fields }
Reference to a linked resource tracked by this Subscription.
func (*Subscription_LinkedResource) Descriptor
deprecated
func (*Subscription_LinkedResource) Descriptor() ([]byte, []int)
Deprecated: Use Subscription_LinkedResource.ProtoReflect.Descriptor instead.
func (*Subscription_LinkedResource) GetLinkedDataset ¶
func (x *Subscription_LinkedResource) GetLinkedDataset() string
func (*Subscription_LinkedResource) GetReference ¶
func (m *Subscription_LinkedResource) GetReference() isSubscription_LinkedResource_Reference
func (*Subscription_LinkedResource) ProtoMessage ¶
func (*Subscription_LinkedResource) ProtoMessage()
func (*Subscription_LinkedResource) ProtoReflect ¶
func (x *Subscription_LinkedResource) ProtoReflect() protoreflect.Message
func (*Subscription_LinkedResource) Reset ¶
func (x *Subscription_LinkedResource) Reset()
func (*Subscription_LinkedResource) String ¶
func (x *Subscription_LinkedResource) String() string
type Subscription_LinkedResource_LinkedDataset ¶
type Subscription_LinkedResource_LinkedDataset struct { // Output only. Name of the linked dataset, e.g. // projects/subscriberproject/datasets/linked_dataset LinkedDataset string `protobuf:"bytes,1,opt,name=linked_dataset,json=linkedDataset,proto3,oneof"` }
type Subscription_Listing ¶
type Subscription_Listing struct { // Output only. Resource name of the source Listing. // e.g. projects/123/locations/US/dataExchanges/456/listings/789 Listing string `protobuf:"bytes,5,opt,name=listing,proto3,oneof"` }
type Subscription_State ¶
type Subscription_State int32
State of the subscription.
const ( // Default value. This value is unused. Subscription_STATE_UNSPECIFIED Subscription_State = 0 // This subscription is active and the data is accessible. Subscription_STATE_ACTIVE Subscription_State = 1 // The data referenced by this subscription is out of date and should be // refreshed. This can happen when a data provider adds or removes datasets. Subscription_STATE_STALE Subscription_State = 2 // This subscription has been cancelled or revoked and the data is no longer // accessible. Subscription_STATE_INACTIVE Subscription_State = 3 )
func (Subscription_State) Descriptor ¶
func (Subscription_State) Descriptor() protoreflect.EnumDescriptor
func (Subscription_State) Enum ¶
func (x Subscription_State) Enum() *Subscription_State
func (Subscription_State) EnumDescriptor
deprecated
func (Subscription_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use Subscription_State.Descriptor instead.
func (Subscription_State) Number ¶
func (x Subscription_State) Number() protoreflect.EnumNumber
func (Subscription_State) String ¶
func (x Subscription_State) String() string
func (Subscription_State) Type ¶
func (Subscription_State) Type() protoreflect.EnumType
type UnimplementedAnalyticsHubServiceServer ¶
type UnimplementedAnalyticsHubServiceServer struct { }
UnimplementedAnalyticsHubServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedAnalyticsHubServiceServer) CreateDataExchange ¶
func (UnimplementedAnalyticsHubServiceServer) CreateDataExchange(context.Context, *CreateDataExchangeRequest) (*DataExchange, error)
func (UnimplementedAnalyticsHubServiceServer) CreateListing ¶
func (UnimplementedAnalyticsHubServiceServer) CreateListing(context.Context, *CreateListingRequest) (*Listing, error)
func (UnimplementedAnalyticsHubServiceServer) DeleteDataExchange ¶
func (UnimplementedAnalyticsHubServiceServer) DeleteDataExchange(context.Context, *DeleteDataExchangeRequest) (*empty.Empty, error)
func (UnimplementedAnalyticsHubServiceServer) DeleteListing ¶
func (UnimplementedAnalyticsHubServiceServer) DeleteListing(context.Context, *DeleteListingRequest) (*empty.Empty, error)
func (UnimplementedAnalyticsHubServiceServer) DeleteSubscription ¶
func (UnimplementedAnalyticsHubServiceServer) DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*longrunningpb.Operation, error)
func (UnimplementedAnalyticsHubServiceServer) GetDataExchange ¶
func (UnimplementedAnalyticsHubServiceServer) GetDataExchange(context.Context, *GetDataExchangeRequest) (*DataExchange, error)
func (UnimplementedAnalyticsHubServiceServer) GetIamPolicy ¶
func (UnimplementedAnalyticsHubServiceServer) GetIamPolicy(context.Context, *iampb.GetIamPolicyRequest) (*iampb.Policy, error)
func (UnimplementedAnalyticsHubServiceServer) GetListing ¶
func (UnimplementedAnalyticsHubServiceServer) GetListing(context.Context, *GetListingRequest) (*Listing, error)
func (UnimplementedAnalyticsHubServiceServer) GetSubscription ¶
func (UnimplementedAnalyticsHubServiceServer) GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error)
func (UnimplementedAnalyticsHubServiceServer) ListDataExchanges ¶
func (UnimplementedAnalyticsHubServiceServer) ListDataExchanges(context.Context, *ListDataExchangesRequest) (*ListDataExchangesResponse, error)
func (UnimplementedAnalyticsHubServiceServer) ListListings ¶
func (UnimplementedAnalyticsHubServiceServer) ListListings(context.Context, *ListListingsRequest) (*ListListingsResponse, error)
func (UnimplementedAnalyticsHubServiceServer) ListOrgDataExchanges ¶
func (UnimplementedAnalyticsHubServiceServer) ListOrgDataExchanges(context.Context, *ListOrgDataExchangesRequest) (*ListOrgDataExchangesResponse, error)
func (UnimplementedAnalyticsHubServiceServer) ListSharedResourceSubscriptions ¶
func (UnimplementedAnalyticsHubServiceServer) ListSharedResourceSubscriptions(context.Context, *ListSharedResourceSubscriptionsRequest) (*ListSharedResourceSubscriptionsResponse, error)
func (UnimplementedAnalyticsHubServiceServer) ListSubscriptions ¶
func (UnimplementedAnalyticsHubServiceServer) ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)
func (UnimplementedAnalyticsHubServiceServer) RefreshSubscription ¶
func (UnimplementedAnalyticsHubServiceServer) RefreshSubscription(context.Context, *RefreshSubscriptionRequest) (*longrunningpb.Operation, error)
func (UnimplementedAnalyticsHubServiceServer) RevokeSubscription ¶
func (UnimplementedAnalyticsHubServiceServer) RevokeSubscription(context.Context, *RevokeSubscriptionRequest) (*RevokeSubscriptionResponse, error)
func (UnimplementedAnalyticsHubServiceServer) SetIamPolicy ¶
func (UnimplementedAnalyticsHubServiceServer) SetIamPolicy(context.Context, *iampb.SetIamPolicyRequest) (*iampb.Policy, error)
func (UnimplementedAnalyticsHubServiceServer) SubscribeDataExchange ¶
func (UnimplementedAnalyticsHubServiceServer) SubscribeDataExchange(context.Context, *SubscribeDataExchangeRequest) (*longrunningpb.Operation, error)
func (UnimplementedAnalyticsHubServiceServer) SubscribeListing ¶
func (UnimplementedAnalyticsHubServiceServer) SubscribeListing(context.Context, *SubscribeListingRequest) (*SubscribeListingResponse, error)
func (UnimplementedAnalyticsHubServiceServer) TestIamPermissions ¶
func (UnimplementedAnalyticsHubServiceServer) TestIamPermissions(context.Context, *iampb.TestIamPermissionsRequest) (*iampb.TestIamPermissionsResponse, error)
func (UnimplementedAnalyticsHubServiceServer) UpdateDataExchange ¶
func (UnimplementedAnalyticsHubServiceServer) UpdateDataExchange(context.Context, *UpdateDataExchangeRequest) (*DataExchange, error)
func (UnimplementedAnalyticsHubServiceServer) UpdateListing ¶
func (UnimplementedAnalyticsHubServiceServer) UpdateListing(context.Context, *UpdateListingRequest) (*Listing, error)
type UnsafeAnalyticsHubServiceServer ¶
type UnsafeAnalyticsHubServiceServer interface {
// contains filtered or unexported methods
}
UnsafeAnalyticsHubServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AnalyticsHubServiceServer will result in compilation errors.
type UpdateDataExchangeRequest ¶
type UpdateDataExchangeRequest struct { // Required. Field mask specifies the fields to update in the data exchange // resource. The fields specified in the // `updateMask` are relative to the resource and are not a full request. UpdateMask *field_mask.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // Required. The data exchange to update. DataExchange *DataExchange `protobuf:"bytes,2,opt,name=data_exchange,json=dataExchange,proto3" json:"data_exchange,omitempty"` // contains filtered or unexported fields }
Message for updating a data exchange.
func (*UpdateDataExchangeRequest) Descriptor
deprecated
func (*UpdateDataExchangeRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateDataExchangeRequest.ProtoReflect.Descriptor instead.
func (*UpdateDataExchangeRequest) GetDataExchange ¶
func (x *UpdateDataExchangeRequest) GetDataExchange() *DataExchange
func (*UpdateDataExchangeRequest) GetUpdateMask ¶
func (x *UpdateDataExchangeRequest) GetUpdateMask() *field_mask.FieldMask
func (*UpdateDataExchangeRequest) ProtoMessage ¶
func (*UpdateDataExchangeRequest) ProtoMessage()
func (*UpdateDataExchangeRequest) ProtoReflect ¶
func (x *UpdateDataExchangeRequest) ProtoReflect() protoreflect.Message
func (*UpdateDataExchangeRequest) Reset ¶
func (x *UpdateDataExchangeRequest) Reset()
func (*UpdateDataExchangeRequest) String ¶
func (x *UpdateDataExchangeRequest) String() string
type UpdateListingRequest ¶
type UpdateListingRequest struct { // Required. Field mask specifies the fields to update in the listing // resource. The fields specified in the `updateMask` are relative to the // resource and are not a full request. UpdateMask *field_mask.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // Required. The listing to update. Listing *Listing `protobuf:"bytes,2,opt,name=listing,proto3" json:"listing,omitempty"` // contains filtered or unexported fields }
Message for updating a Listing.
func (*UpdateListingRequest) Descriptor
deprecated
func (*UpdateListingRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateListingRequest.ProtoReflect.Descriptor instead.
func (*UpdateListingRequest) GetListing ¶
func (x *UpdateListingRequest) GetListing() *Listing
func (*UpdateListingRequest) GetUpdateMask ¶
func (x *UpdateListingRequest) GetUpdateMask() *field_mask.FieldMask
func (*UpdateListingRequest) ProtoMessage ¶
func (*UpdateListingRequest) ProtoMessage()
func (*UpdateListingRequest) ProtoReflect ¶
func (x *UpdateListingRequest) ProtoReflect() protoreflect.Message
func (*UpdateListingRequest) Reset ¶
func (x *UpdateListingRequest) Reset()
func (*UpdateListingRequest) String ¶
func (x *UpdateListingRequest) String() string