Versions in this module Expand all Collapse all v0 v0.25.2 May 21, 2020 Changes in this version + const CloudPlatformScope + const PubsubScope + type AcknowledgeRequest struct + AckId []string + ForceSendFields []string + NullFields []string + Subscription string + func (s *AcknowledgeRequest) MarshalJSON() ([]byte, error) + type Empty struct + type Label struct + ForceSendFields []string + Key string + NullFields []string + NumValue int64 + StrValue string + func (s *Label) MarshalJSON() ([]byte, error) + type ListSubscriptionsResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + Subscription []*Subscription + func (s *ListSubscriptionsResponse) MarshalJSON() ([]byte, error) + type ListTopicsResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + Topic []*Topic + func (s *ListTopicsResponse) MarshalJSON() ([]byte, error) + type ModifyAckDeadlineRequest struct + AckDeadlineSeconds int64 + AckId string + AckIds []string + ForceSendFields []string + NullFields []string + Subscription string + func (s *ModifyAckDeadlineRequest) MarshalJSON() ([]byte, error) + type ModifyPushConfigRequest struct + ForceSendFields []string + NullFields []string + PushConfig *PushConfig + Subscription string + func (s *ModifyPushConfigRequest) MarshalJSON() ([]byte, error) + type PublishBatchRequest struct + ForceSendFields []string + Messages []*PubsubMessage + NullFields []string + Topic string + func (s *PublishBatchRequest) MarshalJSON() ([]byte, error) + type PublishBatchResponse struct + ForceSendFields []string + MessageIds []string + NullFields []string + func (s *PublishBatchResponse) MarshalJSON() ([]byte, error) + type PublishRequest struct + ForceSendFields []string + Message *PubsubMessage + NullFields []string + Topic string + func (s *PublishRequest) MarshalJSON() ([]byte, error) + type PubsubEvent struct + Deleted bool + ForceSendFields []string + Message *PubsubMessage + NullFields []string + Subscription string + Truncated bool + func (s *PubsubEvent) MarshalJSON() ([]byte, error) + type PubsubMessage struct + Data string + ForceSendFields []string + Label []*Label + MessageId string + NullFields []string + PublishTime int64 + func (s *PubsubMessage) MarshalJSON() ([]byte, error) + type PullBatchRequest struct + ForceSendFields []string + MaxEvents int64 + NullFields []string + ReturnImmediately bool + Subscription string + func (s *PullBatchRequest) MarshalJSON() ([]byte, error) + type PullBatchResponse struct + ForceSendFields []string + NullFields []string + PullResponses []*PullResponse + func (s *PullBatchResponse) MarshalJSON() ([]byte, error) + type PullRequest struct + ForceSendFields []string + NullFields []string + ReturnImmediately bool + Subscription string + func (s *PullRequest) MarshalJSON() ([]byte, error) + type PullResponse struct + AckId string + ForceSendFields []string + NullFields []string + PubsubEvent *PubsubEvent + func (s *PullResponse) MarshalJSON() ([]byte, error) + type PushConfig struct + ForceSendFields []string + NullFields []string + PushEndpoint string + func (s *PushConfig) MarshalJSON() ([]byte, error) + type Service struct + BasePath string + Subscriptions *SubscriptionsService + Topics *TopicsService + UserAgent string + func New(client *http.Client) (*Service, error) + func NewService(ctx context.Context, opts ...option.ClientOption) (*Service, error) + type Subscription struct + AckDeadlineSeconds int64 + ForceSendFields []string + Name string + NullFields []string + PushConfig *PushConfig + Topic string + func (s *Subscription) MarshalJSON() ([]byte, error) + type SubscriptionsAcknowledgeCall struct + func (c *SubscriptionsAcknowledgeCall) Context(ctx context.Context) *SubscriptionsAcknowledgeCall + func (c *SubscriptionsAcknowledgeCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *SubscriptionsAcknowledgeCall) Fields(s ...googleapi.Field) *SubscriptionsAcknowledgeCall + func (c *SubscriptionsAcknowledgeCall) Header() http.Header + type SubscriptionsCreateCall struct + func (c *SubscriptionsCreateCall) Context(ctx context.Context) *SubscriptionsCreateCall + func (c *SubscriptionsCreateCall) Do(opts ...googleapi.CallOption) (*Subscription, error) + func (c *SubscriptionsCreateCall) Fields(s ...googleapi.Field) *SubscriptionsCreateCall + func (c *SubscriptionsCreateCall) Header() http.Header + type SubscriptionsDeleteCall struct + func (c *SubscriptionsDeleteCall) Context(ctx context.Context) *SubscriptionsDeleteCall + func (c *SubscriptionsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *SubscriptionsDeleteCall) Fields(s ...googleapi.Field) *SubscriptionsDeleteCall + func (c *SubscriptionsDeleteCall) Header() http.Header + type SubscriptionsGetCall struct + func (c *SubscriptionsGetCall) Context(ctx context.Context) *SubscriptionsGetCall + func (c *SubscriptionsGetCall) Do(opts ...googleapi.CallOption) (*Subscription, error) + func (c *SubscriptionsGetCall) Fields(s ...googleapi.Field) *SubscriptionsGetCall + func (c *SubscriptionsGetCall) Header() http.Header + func (c *SubscriptionsGetCall) IfNoneMatch(entityTag string) *SubscriptionsGetCall + type SubscriptionsListCall struct + func (c *SubscriptionsListCall) Context(ctx context.Context) *SubscriptionsListCall + func (c *SubscriptionsListCall) Do(opts ...googleapi.CallOption) (*ListSubscriptionsResponse, error) + func (c *SubscriptionsListCall) Fields(s ...googleapi.Field) *SubscriptionsListCall + func (c *SubscriptionsListCall) Header() http.Header + func (c *SubscriptionsListCall) IfNoneMatch(entityTag string) *SubscriptionsListCall + func (c *SubscriptionsListCall) MaxResults(maxResults int64) *SubscriptionsListCall + func (c *SubscriptionsListCall) PageToken(pageToken string) *SubscriptionsListCall + func (c *SubscriptionsListCall) Pages(ctx context.Context, f func(*ListSubscriptionsResponse) error) error + func (c *SubscriptionsListCall) Query(query string) *SubscriptionsListCall + type SubscriptionsModifyAckDeadlineCall struct + func (c *SubscriptionsModifyAckDeadlineCall) Context(ctx context.Context) *SubscriptionsModifyAckDeadlineCall + func (c *SubscriptionsModifyAckDeadlineCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *SubscriptionsModifyAckDeadlineCall) Fields(s ...googleapi.Field) *SubscriptionsModifyAckDeadlineCall + func (c *SubscriptionsModifyAckDeadlineCall) Header() http.Header + type SubscriptionsModifyPushConfigCall struct + func (c *SubscriptionsModifyPushConfigCall) Context(ctx context.Context) *SubscriptionsModifyPushConfigCall + func (c *SubscriptionsModifyPushConfigCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *SubscriptionsModifyPushConfigCall) Fields(s ...googleapi.Field) *SubscriptionsModifyPushConfigCall + func (c *SubscriptionsModifyPushConfigCall) Header() http.Header + type SubscriptionsPullBatchCall struct + func (c *SubscriptionsPullBatchCall) Context(ctx context.Context) *SubscriptionsPullBatchCall + func (c *SubscriptionsPullBatchCall) Do(opts ...googleapi.CallOption) (*PullBatchResponse, error) + func (c *SubscriptionsPullBatchCall) Fields(s ...googleapi.Field) *SubscriptionsPullBatchCall + func (c *SubscriptionsPullBatchCall) Header() http.Header + type SubscriptionsPullCall struct + func (c *SubscriptionsPullCall) Context(ctx context.Context) *SubscriptionsPullCall + func (c *SubscriptionsPullCall) Do(opts ...googleapi.CallOption) (*PullResponse, error) + func (c *SubscriptionsPullCall) Fields(s ...googleapi.Field) *SubscriptionsPullCall + func (c *SubscriptionsPullCall) Header() http.Header + type SubscriptionsService struct + func NewSubscriptionsService(s *Service) *SubscriptionsService + func (r *SubscriptionsService) Acknowledge(acknowledgerequest *AcknowledgeRequest) *SubscriptionsAcknowledgeCall + func (r *SubscriptionsService) Create(subscription *Subscription) *SubscriptionsCreateCall + func (r *SubscriptionsService) Delete(subscription string) *SubscriptionsDeleteCall + func (r *SubscriptionsService) Get(subscription string) *SubscriptionsGetCall + func (r *SubscriptionsService) List() *SubscriptionsListCall + func (r *SubscriptionsService) ModifyAckDeadline(modifyackdeadlinerequest *ModifyAckDeadlineRequest) *SubscriptionsModifyAckDeadlineCall + func (r *SubscriptionsService) ModifyPushConfig(modifypushconfigrequest *ModifyPushConfigRequest) *SubscriptionsModifyPushConfigCall + func (r *SubscriptionsService) Pull(pullrequest *PullRequest) *SubscriptionsPullCall + func (r *SubscriptionsService) PullBatch(pullbatchrequest *PullBatchRequest) *SubscriptionsPullBatchCall + type Topic struct + ForceSendFields []string + Name string + NullFields []string + func (s *Topic) MarshalJSON() ([]byte, error) + type TopicsCreateCall struct + func (c *TopicsCreateCall) Context(ctx context.Context) *TopicsCreateCall + func (c *TopicsCreateCall) Do(opts ...googleapi.CallOption) (*Topic, error) + func (c *TopicsCreateCall) Fields(s ...googleapi.Field) *TopicsCreateCall + func (c *TopicsCreateCall) Header() http.Header + type TopicsDeleteCall struct + func (c *TopicsDeleteCall) Context(ctx context.Context) *TopicsDeleteCall + func (c *TopicsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *TopicsDeleteCall) Fields(s ...googleapi.Field) *TopicsDeleteCall + func (c *TopicsDeleteCall) Header() http.Header + type TopicsGetCall struct + func (c *TopicsGetCall) Context(ctx context.Context) *TopicsGetCall + func (c *TopicsGetCall) Do(opts ...googleapi.CallOption) (*Topic, error) + func (c *TopicsGetCall) Fields(s ...googleapi.Field) *TopicsGetCall + func (c *TopicsGetCall) Header() http.Header + func (c *TopicsGetCall) IfNoneMatch(entityTag string) *TopicsGetCall + type TopicsListCall struct + func (c *TopicsListCall) Context(ctx context.Context) *TopicsListCall + func (c *TopicsListCall) Do(opts ...googleapi.CallOption) (*ListTopicsResponse, error) + func (c *TopicsListCall) Fields(s ...googleapi.Field) *TopicsListCall + func (c *TopicsListCall) Header() http.Header + func (c *TopicsListCall) IfNoneMatch(entityTag string) *TopicsListCall + func (c *TopicsListCall) MaxResults(maxResults int64) *TopicsListCall + func (c *TopicsListCall) PageToken(pageToken string) *TopicsListCall + func (c *TopicsListCall) Pages(ctx context.Context, f func(*ListTopicsResponse) error) error + func (c *TopicsListCall) Query(query string) *TopicsListCall + type TopicsPublishBatchCall struct + func (c *TopicsPublishBatchCall) Context(ctx context.Context) *TopicsPublishBatchCall + func (c *TopicsPublishBatchCall) Do(opts ...googleapi.CallOption) (*PublishBatchResponse, error) + func (c *TopicsPublishBatchCall) Fields(s ...googleapi.Field) *TopicsPublishBatchCall + func (c *TopicsPublishBatchCall) Header() http.Header + type TopicsPublishCall struct + func (c *TopicsPublishCall) Context(ctx context.Context) *TopicsPublishCall + func (c *TopicsPublishCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *TopicsPublishCall) Fields(s ...googleapi.Field) *TopicsPublishCall + func (c *TopicsPublishCall) Header() http.Header + type TopicsService struct + func NewTopicsService(s *Service) *TopicsService + func (r *TopicsService) Create(topic *Topic) *TopicsCreateCall + func (r *TopicsService) Delete(topic string) *TopicsDeleteCall + func (r *TopicsService) Get(topic string) *TopicsGetCall + func (r *TopicsService) List() *TopicsListCall + func (r *TopicsService) Publish(publishrequest *PublishRequest) *TopicsPublishCall + func (r *TopicsService) PublishBatch(publishbatchrequest *PublishBatchRequest) *TopicsPublishBatchCall
Go to main page