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 + AckIds []string + ForceSendFields []string + NullFields []string + func (s *AcknowledgeRequest) MarshalJSON() ([]byte, error) + type Binding struct + Condition *Expr + ForceSendFields []string + Members []string + NullFields []string + Role string + func (s *Binding) MarshalJSON() ([]byte, error) + type CreateSnapshotRequest struct + ForceSendFields []string + Labels map[string]string + NullFields []string + Subscription string + func (s *CreateSnapshotRequest) MarshalJSON() ([]byte, error) + type DeadLetterPolicy struct + DeadLetterTopic string + ForceSendFields []string + MaxDeliveryAttempts int64 + NullFields []string + func (s *DeadLetterPolicy) MarshalJSON() ([]byte, error) + type Empty struct + type ExpirationPolicy struct + ForceSendFields []string + NullFields []string + Ttl string + func (s *ExpirationPolicy) MarshalJSON() ([]byte, error) + type Expr struct + Description string + Expression string + ForceSendFields []string + Location string + NullFields []string + Title string + func (s *Expr) MarshalJSON() ([]byte, error) + type ListSnapshotsResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + Snapshots []*Snapshot + func (s *ListSnapshotsResponse) MarshalJSON() ([]byte, error) + type ListSubscriptionsResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + Subscriptions []*Subscription + func (s *ListSubscriptionsResponse) MarshalJSON() ([]byte, error) + type ListTopicSnapshotsResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + Snapshots []string + func (s *ListTopicSnapshotsResponse) MarshalJSON() ([]byte, error) + type ListTopicSubscriptionsResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + Subscriptions []string + func (s *ListTopicSubscriptionsResponse) MarshalJSON() ([]byte, error) + type ListTopicsResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + Topics []*Topic + func (s *ListTopicsResponse) MarshalJSON() ([]byte, error) + type MessageStoragePolicy struct + AllowedPersistenceRegions []string + ForceSendFields []string + NullFields []string + func (s *MessageStoragePolicy) MarshalJSON() ([]byte, error) + type ModifyAckDeadlineRequest struct + AckDeadlineSeconds int64 + AckIds []string + ForceSendFields []string + NullFields []string + func (s *ModifyAckDeadlineRequest) MarshalJSON() ([]byte, error) + type ModifyPushConfigRequest struct + ForceSendFields []string + NullFields []string + PushConfig *PushConfig + func (s *ModifyPushConfigRequest) MarshalJSON() ([]byte, error) + type OidcToken struct + Audience string + ForceSendFields []string + NullFields []string + ServiceAccountEmail string + func (s *OidcToken) MarshalJSON() ([]byte, error) + type Policy struct + Bindings []*Binding + Etag string + ForceSendFields []string + NullFields []string + Version int64 + func (s *Policy) MarshalJSON() ([]byte, error) + type ProjectsService struct + Snapshots *ProjectsSnapshotsService + Subscriptions *ProjectsSubscriptionsService + Topics *ProjectsTopicsService + func NewProjectsService(s *Service) *ProjectsService + type ProjectsSnapshotsCreateCall struct + func (c *ProjectsSnapshotsCreateCall) Context(ctx context.Context) *ProjectsSnapshotsCreateCall + func (c *ProjectsSnapshotsCreateCall) Do(opts ...googleapi.CallOption) (*Snapshot, error) + func (c *ProjectsSnapshotsCreateCall) Fields(s ...googleapi.Field) *ProjectsSnapshotsCreateCall + func (c *ProjectsSnapshotsCreateCall) Header() http.Header + type ProjectsSnapshotsDeleteCall struct + func (c *ProjectsSnapshotsDeleteCall) Context(ctx context.Context) *ProjectsSnapshotsDeleteCall + func (c *ProjectsSnapshotsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *ProjectsSnapshotsDeleteCall) Fields(s ...googleapi.Field) *ProjectsSnapshotsDeleteCall + func (c *ProjectsSnapshotsDeleteCall) Header() http.Header + type ProjectsSnapshotsGetCall struct + func (c *ProjectsSnapshotsGetCall) Context(ctx context.Context) *ProjectsSnapshotsGetCall + func (c *ProjectsSnapshotsGetCall) Do(opts ...googleapi.CallOption) (*Snapshot, error) + func (c *ProjectsSnapshotsGetCall) Fields(s ...googleapi.Field) *ProjectsSnapshotsGetCall + func (c *ProjectsSnapshotsGetCall) Header() http.Header + func (c *ProjectsSnapshotsGetCall) IfNoneMatch(entityTag string) *ProjectsSnapshotsGetCall + type ProjectsSnapshotsGetIamPolicyCall struct + func (c *ProjectsSnapshotsGetIamPolicyCall) Context(ctx context.Context) *ProjectsSnapshotsGetIamPolicyCall + func (c *ProjectsSnapshotsGetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error) + func (c *ProjectsSnapshotsGetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsSnapshotsGetIamPolicyCall + func (c *ProjectsSnapshotsGetIamPolicyCall) Header() http.Header + func (c *ProjectsSnapshotsGetIamPolicyCall) IfNoneMatch(entityTag string) *ProjectsSnapshotsGetIamPolicyCall + func (c *ProjectsSnapshotsGetIamPolicyCall) OptionsRequestedPolicyVersion(optionsRequestedPolicyVersion int64) *ProjectsSnapshotsGetIamPolicyCall + type ProjectsSnapshotsListCall struct + func (c *ProjectsSnapshotsListCall) Context(ctx context.Context) *ProjectsSnapshotsListCall + func (c *ProjectsSnapshotsListCall) Do(opts ...googleapi.CallOption) (*ListSnapshotsResponse, error) + func (c *ProjectsSnapshotsListCall) Fields(s ...googleapi.Field) *ProjectsSnapshotsListCall + func (c *ProjectsSnapshotsListCall) Header() http.Header + func (c *ProjectsSnapshotsListCall) IfNoneMatch(entityTag string) *ProjectsSnapshotsListCall + func (c *ProjectsSnapshotsListCall) PageSize(pageSize int64) *ProjectsSnapshotsListCall + func (c *ProjectsSnapshotsListCall) PageToken(pageToken string) *ProjectsSnapshotsListCall + func (c *ProjectsSnapshotsListCall) Pages(ctx context.Context, f func(*ListSnapshotsResponse) error) error + type ProjectsSnapshotsPatchCall struct + func (c *ProjectsSnapshotsPatchCall) Context(ctx context.Context) *ProjectsSnapshotsPatchCall + func (c *ProjectsSnapshotsPatchCall) Do(opts ...googleapi.CallOption) (*Snapshot, error) + func (c *ProjectsSnapshotsPatchCall) Fields(s ...googleapi.Field) *ProjectsSnapshotsPatchCall + func (c *ProjectsSnapshotsPatchCall) Header() http.Header + type ProjectsSnapshotsService struct + func NewProjectsSnapshotsService(s *Service) *ProjectsSnapshotsService + func (r *ProjectsSnapshotsService) Create(name string, createsnapshotrequest *CreateSnapshotRequest) *ProjectsSnapshotsCreateCall + func (r *ProjectsSnapshotsService) Delete(snapshot string) *ProjectsSnapshotsDeleteCall + func (r *ProjectsSnapshotsService) Get(snapshot string) *ProjectsSnapshotsGetCall + func (r *ProjectsSnapshotsService) GetIamPolicy(resource string) *ProjectsSnapshotsGetIamPolicyCall + func (r *ProjectsSnapshotsService) List(project string) *ProjectsSnapshotsListCall + func (r *ProjectsSnapshotsService) Patch(name string, updatesnapshotrequest *UpdateSnapshotRequest) *ProjectsSnapshotsPatchCall + func (r *ProjectsSnapshotsService) SetIamPolicy(resource string, setiampolicyrequest *SetIamPolicyRequest) *ProjectsSnapshotsSetIamPolicyCall + func (r *ProjectsSnapshotsService) TestIamPermissions(resource string, testiampermissionsrequest *TestIamPermissionsRequest) *ProjectsSnapshotsTestIamPermissionsCall + type ProjectsSnapshotsSetIamPolicyCall struct + func (c *ProjectsSnapshotsSetIamPolicyCall) Context(ctx context.Context) *ProjectsSnapshotsSetIamPolicyCall + func (c *ProjectsSnapshotsSetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error) + func (c *ProjectsSnapshotsSetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsSnapshotsSetIamPolicyCall + func (c *ProjectsSnapshotsSetIamPolicyCall) Header() http.Header + type ProjectsSnapshotsTestIamPermissionsCall struct + func (c *ProjectsSnapshotsTestIamPermissionsCall) Context(ctx context.Context) *ProjectsSnapshotsTestIamPermissionsCall + func (c *ProjectsSnapshotsTestIamPermissionsCall) Do(opts ...googleapi.CallOption) (*TestIamPermissionsResponse, error) + func (c *ProjectsSnapshotsTestIamPermissionsCall) Fields(s ...googleapi.Field) *ProjectsSnapshotsTestIamPermissionsCall + func (c *ProjectsSnapshotsTestIamPermissionsCall) Header() http.Header + type ProjectsSubscriptionsAcknowledgeCall struct + func (c *ProjectsSubscriptionsAcknowledgeCall) Context(ctx context.Context) *ProjectsSubscriptionsAcknowledgeCall + func (c *ProjectsSubscriptionsAcknowledgeCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *ProjectsSubscriptionsAcknowledgeCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsAcknowledgeCall + func (c *ProjectsSubscriptionsAcknowledgeCall) Header() http.Header + type ProjectsSubscriptionsCreateCall struct + func (c *ProjectsSubscriptionsCreateCall) Context(ctx context.Context) *ProjectsSubscriptionsCreateCall + func (c *ProjectsSubscriptionsCreateCall) Do(opts ...googleapi.CallOption) (*Subscription, error) + func (c *ProjectsSubscriptionsCreateCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsCreateCall + func (c *ProjectsSubscriptionsCreateCall) Header() http.Header + type ProjectsSubscriptionsDeleteCall struct + func (c *ProjectsSubscriptionsDeleteCall) Context(ctx context.Context) *ProjectsSubscriptionsDeleteCall + func (c *ProjectsSubscriptionsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *ProjectsSubscriptionsDeleteCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsDeleteCall + func (c *ProjectsSubscriptionsDeleteCall) Header() http.Header + type ProjectsSubscriptionsGetCall struct + func (c *ProjectsSubscriptionsGetCall) Context(ctx context.Context) *ProjectsSubscriptionsGetCall + func (c *ProjectsSubscriptionsGetCall) Do(opts ...googleapi.CallOption) (*Subscription, error) + func (c *ProjectsSubscriptionsGetCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsGetCall + func (c *ProjectsSubscriptionsGetCall) Header() http.Header + func (c *ProjectsSubscriptionsGetCall) IfNoneMatch(entityTag string) *ProjectsSubscriptionsGetCall + type ProjectsSubscriptionsGetIamPolicyCall struct + func (c *ProjectsSubscriptionsGetIamPolicyCall) Context(ctx context.Context) *ProjectsSubscriptionsGetIamPolicyCall + func (c *ProjectsSubscriptionsGetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error) + func (c *ProjectsSubscriptionsGetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsGetIamPolicyCall + func (c *ProjectsSubscriptionsGetIamPolicyCall) Header() http.Header + func (c *ProjectsSubscriptionsGetIamPolicyCall) IfNoneMatch(entityTag string) *ProjectsSubscriptionsGetIamPolicyCall + func (c *ProjectsSubscriptionsGetIamPolicyCall) OptionsRequestedPolicyVersion(optionsRequestedPolicyVersion int64) *ProjectsSubscriptionsGetIamPolicyCall + type ProjectsSubscriptionsListCall struct + func (c *ProjectsSubscriptionsListCall) Context(ctx context.Context) *ProjectsSubscriptionsListCall + func (c *ProjectsSubscriptionsListCall) Do(opts ...googleapi.CallOption) (*ListSubscriptionsResponse, error) + func (c *ProjectsSubscriptionsListCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsListCall + func (c *ProjectsSubscriptionsListCall) Header() http.Header + func (c *ProjectsSubscriptionsListCall) IfNoneMatch(entityTag string) *ProjectsSubscriptionsListCall + func (c *ProjectsSubscriptionsListCall) PageSize(pageSize int64) *ProjectsSubscriptionsListCall + func (c *ProjectsSubscriptionsListCall) PageToken(pageToken string) *ProjectsSubscriptionsListCall + func (c *ProjectsSubscriptionsListCall) Pages(ctx context.Context, f func(*ListSubscriptionsResponse) error) error + type ProjectsSubscriptionsModifyAckDeadlineCall struct + func (c *ProjectsSubscriptionsModifyAckDeadlineCall) Context(ctx context.Context) *ProjectsSubscriptionsModifyAckDeadlineCall + func (c *ProjectsSubscriptionsModifyAckDeadlineCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *ProjectsSubscriptionsModifyAckDeadlineCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsModifyAckDeadlineCall + func (c *ProjectsSubscriptionsModifyAckDeadlineCall) Header() http.Header + type ProjectsSubscriptionsModifyPushConfigCall struct + func (c *ProjectsSubscriptionsModifyPushConfigCall) Context(ctx context.Context) *ProjectsSubscriptionsModifyPushConfigCall + func (c *ProjectsSubscriptionsModifyPushConfigCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *ProjectsSubscriptionsModifyPushConfigCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsModifyPushConfigCall + func (c *ProjectsSubscriptionsModifyPushConfigCall) Header() http.Header + type ProjectsSubscriptionsPatchCall struct + func (c *ProjectsSubscriptionsPatchCall) Context(ctx context.Context) *ProjectsSubscriptionsPatchCall + func (c *ProjectsSubscriptionsPatchCall) Do(opts ...googleapi.CallOption) (*Subscription, error) + func (c *ProjectsSubscriptionsPatchCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsPatchCall + func (c *ProjectsSubscriptionsPatchCall) Header() http.Header + type ProjectsSubscriptionsPullCall struct + func (c *ProjectsSubscriptionsPullCall) Context(ctx context.Context) *ProjectsSubscriptionsPullCall + func (c *ProjectsSubscriptionsPullCall) Do(opts ...googleapi.CallOption) (*PullResponse, error) + func (c *ProjectsSubscriptionsPullCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsPullCall + func (c *ProjectsSubscriptionsPullCall) Header() http.Header + type ProjectsSubscriptionsSeekCall struct + func (c *ProjectsSubscriptionsSeekCall) Context(ctx context.Context) *ProjectsSubscriptionsSeekCall + func (c *ProjectsSubscriptionsSeekCall) Do(opts ...googleapi.CallOption) (*SeekResponse, error) + func (c *ProjectsSubscriptionsSeekCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsSeekCall + func (c *ProjectsSubscriptionsSeekCall) Header() http.Header + type ProjectsSubscriptionsService struct + func NewProjectsSubscriptionsService(s *Service) *ProjectsSubscriptionsService + func (r *ProjectsSubscriptionsService) Acknowledge(subscription string, acknowledgerequest *AcknowledgeRequest) *ProjectsSubscriptionsAcknowledgeCall + func (r *ProjectsSubscriptionsService) Create(name string, subscription *Subscription) *ProjectsSubscriptionsCreateCall + func (r *ProjectsSubscriptionsService) Delete(subscription string) *ProjectsSubscriptionsDeleteCall + func (r *ProjectsSubscriptionsService) Get(subscription string) *ProjectsSubscriptionsGetCall + func (r *ProjectsSubscriptionsService) GetIamPolicy(resource string) *ProjectsSubscriptionsGetIamPolicyCall + func (r *ProjectsSubscriptionsService) List(project string) *ProjectsSubscriptionsListCall + func (r *ProjectsSubscriptionsService) ModifyAckDeadline(subscription string, modifyackdeadlinerequest *ModifyAckDeadlineRequest) *ProjectsSubscriptionsModifyAckDeadlineCall + func (r *ProjectsSubscriptionsService) ModifyPushConfig(subscription string, modifypushconfigrequest *ModifyPushConfigRequest) *ProjectsSubscriptionsModifyPushConfigCall + func (r *ProjectsSubscriptionsService) Patch(name string, updatesubscriptionrequest *UpdateSubscriptionRequest) *ProjectsSubscriptionsPatchCall + func (r *ProjectsSubscriptionsService) Pull(subscription string, pullrequest *PullRequest) *ProjectsSubscriptionsPullCall + func (r *ProjectsSubscriptionsService) Seek(subscription string, seekrequest *SeekRequest) *ProjectsSubscriptionsSeekCall + func (r *ProjectsSubscriptionsService) SetIamPolicy(resource string, setiampolicyrequest *SetIamPolicyRequest) *ProjectsSubscriptionsSetIamPolicyCall + func (r *ProjectsSubscriptionsService) TestIamPermissions(resource string, testiampermissionsrequest *TestIamPermissionsRequest) *ProjectsSubscriptionsTestIamPermissionsCall + type ProjectsSubscriptionsSetIamPolicyCall struct + func (c *ProjectsSubscriptionsSetIamPolicyCall) Context(ctx context.Context) *ProjectsSubscriptionsSetIamPolicyCall + func (c *ProjectsSubscriptionsSetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error) + func (c *ProjectsSubscriptionsSetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsSetIamPolicyCall + func (c *ProjectsSubscriptionsSetIamPolicyCall) Header() http.Header + type ProjectsSubscriptionsTestIamPermissionsCall struct + func (c *ProjectsSubscriptionsTestIamPermissionsCall) Context(ctx context.Context) *ProjectsSubscriptionsTestIamPermissionsCall + func (c *ProjectsSubscriptionsTestIamPermissionsCall) Do(opts ...googleapi.CallOption) (*TestIamPermissionsResponse, error) + func (c *ProjectsSubscriptionsTestIamPermissionsCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsTestIamPermissionsCall + func (c *ProjectsSubscriptionsTestIamPermissionsCall) Header() http.Header + type ProjectsTopicsCreateCall struct + func (c *ProjectsTopicsCreateCall) Context(ctx context.Context) *ProjectsTopicsCreateCall + func (c *ProjectsTopicsCreateCall) Do(opts ...googleapi.CallOption) (*Topic, error) + func (c *ProjectsTopicsCreateCall) Fields(s ...googleapi.Field) *ProjectsTopicsCreateCall + func (c *ProjectsTopicsCreateCall) Header() http.Header + type ProjectsTopicsDeleteCall struct + func (c *ProjectsTopicsDeleteCall) Context(ctx context.Context) *ProjectsTopicsDeleteCall + func (c *ProjectsTopicsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *ProjectsTopicsDeleteCall) Fields(s ...googleapi.Field) *ProjectsTopicsDeleteCall + func (c *ProjectsTopicsDeleteCall) Header() http.Header + type ProjectsTopicsGetCall struct + func (c *ProjectsTopicsGetCall) Context(ctx context.Context) *ProjectsTopicsGetCall + func (c *ProjectsTopicsGetCall) Do(opts ...googleapi.CallOption) (*Topic, error) + func (c *ProjectsTopicsGetCall) Fields(s ...googleapi.Field) *ProjectsTopicsGetCall + func (c *ProjectsTopicsGetCall) Header() http.Header + func (c *ProjectsTopicsGetCall) IfNoneMatch(entityTag string) *ProjectsTopicsGetCall + type ProjectsTopicsGetIamPolicyCall struct + func (c *ProjectsTopicsGetIamPolicyCall) Context(ctx context.Context) *ProjectsTopicsGetIamPolicyCall + func (c *ProjectsTopicsGetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error) + func (c *ProjectsTopicsGetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsTopicsGetIamPolicyCall + func (c *ProjectsTopicsGetIamPolicyCall) Header() http.Header + func (c *ProjectsTopicsGetIamPolicyCall) IfNoneMatch(entityTag string) *ProjectsTopicsGetIamPolicyCall + func (c *ProjectsTopicsGetIamPolicyCall) OptionsRequestedPolicyVersion(optionsRequestedPolicyVersion int64) *ProjectsTopicsGetIamPolicyCall + type ProjectsTopicsListCall struct + func (c *ProjectsTopicsListCall) Context(ctx context.Context) *ProjectsTopicsListCall + func (c *ProjectsTopicsListCall) Do(opts ...googleapi.CallOption) (*ListTopicsResponse, error) + func (c *ProjectsTopicsListCall) Fields(s ...googleapi.Field) *ProjectsTopicsListCall + func (c *ProjectsTopicsListCall) Header() http.Header + func (c *ProjectsTopicsListCall) IfNoneMatch(entityTag string) *ProjectsTopicsListCall + func (c *ProjectsTopicsListCall) PageSize(pageSize int64) *ProjectsTopicsListCall + func (c *ProjectsTopicsListCall) PageToken(pageToken string) *ProjectsTopicsListCall + func (c *ProjectsTopicsListCall) Pages(ctx context.Context, f func(*ListTopicsResponse) error) error + type ProjectsTopicsPatchCall struct + func (c *ProjectsTopicsPatchCall) Context(ctx context.Context) *ProjectsTopicsPatchCall + func (c *ProjectsTopicsPatchCall) Do(opts ...googleapi.CallOption) (*Topic, error) + func (c *ProjectsTopicsPatchCall) Fields(s ...googleapi.Field) *ProjectsTopicsPatchCall + func (c *ProjectsTopicsPatchCall) Header() http.Header + type ProjectsTopicsPublishCall struct + func (c *ProjectsTopicsPublishCall) Context(ctx context.Context) *ProjectsTopicsPublishCall + func (c *ProjectsTopicsPublishCall) Do(opts ...googleapi.CallOption) (*PublishResponse, error) + func (c *ProjectsTopicsPublishCall) Fields(s ...googleapi.Field) *ProjectsTopicsPublishCall + func (c *ProjectsTopicsPublishCall) Header() http.Header + type ProjectsTopicsService struct + Snapshots *ProjectsTopicsSnapshotsService + Subscriptions *ProjectsTopicsSubscriptionsService + func NewProjectsTopicsService(s *Service) *ProjectsTopicsService + func (r *ProjectsTopicsService) Create(name string, topic *Topic) *ProjectsTopicsCreateCall + func (r *ProjectsTopicsService) Delete(topic string) *ProjectsTopicsDeleteCall + func (r *ProjectsTopicsService) Get(topic string) *ProjectsTopicsGetCall + func (r *ProjectsTopicsService) GetIamPolicy(resource string) *ProjectsTopicsGetIamPolicyCall + func (r *ProjectsTopicsService) List(project string) *ProjectsTopicsListCall + func (r *ProjectsTopicsService) Patch(name string, updatetopicrequest *UpdateTopicRequest) *ProjectsTopicsPatchCall + func (r *ProjectsTopicsService) Publish(topic string, publishrequest *PublishRequest) *ProjectsTopicsPublishCall + func (r *ProjectsTopicsService) SetIamPolicy(resource string, setiampolicyrequest *SetIamPolicyRequest) *ProjectsTopicsSetIamPolicyCall + func (r *ProjectsTopicsService) TestIamPermissions(resource string, testiampermissionsrequest *TestIamPermissionsRequest) *ProjectsTopicsTestIamPermissionsCall + type ProjectsTopicsSetIamPolicyCall struct + func (c *ProjectsTopicsSetIamPolicyCall) Context(ctx context.Context) *ProjectsTopicsSetIamPolicyCall + func (c *ProjectsTopicsSetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error) + func (c *ProjectsTopicsSetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsTopicsSetIamPolicyCall + func (c *ProjectsTopicsSetIamPolicyCall) Header() http.Header + type ProjectsTopicsSnapshotsListCall struct + func (c *ProjectsTopicsSnapshotsListCall) Context(ctx context.Context) *ProjectsTopicsSnapshotsListCall + func (c *ProjectsTopicsSnapshotsListCall) Do(opts ...googleapi.CallOption) (*ListTopicSnapshotsResponse, error) + func (c *ProjectsTopicsSnapshotsListCall) Fields(s ...googleapi.Field) *ProjectsTopicsSnapshotsListCall + func (c *ProjectsTopicsSnapshotsListCall) Header() http.Header + func (c *ProjectsTopicsSnapshotsListCall) IfNoneMatch(entityTag string) *ProjectsTopicsSnapshotsListCall + func (c *ProjectsTopicsSnapshotsListCall) PageSize(pageSize int64) *ProjectsTopicsSnapshotsListCall + func (c *ProjectsTopicsSnapshotsListCall) PageToken(pageToken string) *ProjectsTopicsSnapshotsListCall + func (c *ProjectsTopicsSnapshotsListCall) Pages(ctx context.Context, f func(*ListTopicSnapshotsResponse) error) error + type ProjectsTopicsSnapshotsService struct + func NewProjectsTopicsSnapshotsService(s *Service) *ProjectsTopicsSnapshotsService + func (r *ProjectsTopicsSnapshotsService) List(topic string) *ProjectsTopicsSnapshotsListCall + type ProjectsTopicsSubscriptionsListCall struct + func (c *ProjectsTopicsSubscriptionsListCall) Context(ctx context.Context) *ProjectsTopicsSubscriptionsListCall + func (c *ProjectsTopicsSubscriptionsListCall) Do(opts ...googleapi.CallOption) (*ListTopicSubscriptionsResponse, error) + func (c *ProjectsTopicsSubscriptionsListCall) Fields(s ...googleapi.Field) *ProjectsTopicsSubscriptionsListCall + func (c *ProjectsTopicsSubscriptionsListCall) Header() http.Header + func (c *ProjectsTopicsSubscriptionsListCall) IfNoneMatch(entityTag string) *ProjectsTopicsSubscriptionsListCall + func (c *ProjectsTopicsSubscriptionsListCall) PageSize(pageSize int64) *ProjectsTopicsSubscriptionsListCall + func (c *ProjectsTopicsSubscriptionsListCall) PageToken(pageToken string) *ProjectsTopicsSubscriptionsListCall + func (c *ProjectsTopicsSubscriptionsListCall) Pages(ctx context.Context, f func(*ListTopicSubscriptionsResponse) error) error + type ProjectsTopicsSubscriptionsService struct + func NewProjectsTopicsSubscriptionsService(s *Service) *ProjectsTopicsSubscriptionsService + func (r *ProjectsTopicsSubscriptionsService) List(topic string) *ProjectsTopicsSubscriptionsListCall + type ProjectsTopicsTestIamPermissionsCall struct + func (c *ProjectsTopicsTestIamPermissionsCall) Context(ctx context.Context) *ProjectsTopicsTestIamPermissionsCall + func (c *ProjectsTopicsTestIamPermissionsCall) Do(opts ...googleapi.CallOption) (*TestIamPermissionsResponse, error) + func (c *ProjectsTopicsTestIamPermissionsCall) Fields(s ...googleapi.Field) *ProjectsTopicsTestIamPermissionsCall + func (c *ProjectsTopicsTestIamPermissionsCall) Header() http.Header + type PublishRequest struct + ForceSendFields []string + Messages []*PubsubMessage + NullFields []string + func (s *PublishRequest) MarshalJSON() ([]byte, error) + type PublishResponse struct + ForceSendFields []string + MessageIds []string + NullFields []string + func (s *PublishResponse) MarshalJSON() ([]byte, error) + type PubsubMessage struct + Attributes map[string]string + Data string + ForceSendFields []string + MessageId string + NullFields []string + PublishTime string + func (s *PubsubMessage) MarshalJSON() ([]byte, error) + type PullRequest struct + ForceSendFields []string + MaxMessages int64 + NullFields []string + ReturnImmediately bool + func (s *PullRequest) MarshalJSON() ([]byte, error) + type PullResponse struct + ForceSendFields []string + NullFields []string + ReceivedMessages []*ReceivedMessage + func (s *PullResponse) MarshalJSON() ([]byte, error) + type PushConfig struct + Attributes map[string]string + ForceSendFields []string + NullFields []string + OidcToken *OidcToken + PushEndpoint string + func (s *PushConfig) MarshalJSON() ([]byte, error) + type ReceivedMessage struct + AckId string + DeliveryAttempt int64 + ForceSendFields []string + Message *PubsubMessage + NullFields []string + func (s *ReceivedMessage) MarshalJSON() ([]byte, error) + type SeekRequest struct + ForceSendFields []string + NullFields []string + Snapshot string + Time string + func (s *SeekRequest) MarshalJSON() ([]byte, error) + type SeekResponse struct + type Service struct + BasePath string + Projects *ProjectsService + UserAgent string + func New(client *http.Client) (*Service, error) + func NewService(ctx context.Context, opts ...option.ClientOption) (*Service, error) + type SetIamPolicyRequest struct + ForceSendFields []string + NullFields []string + Policy *Policy + func (s *SetIamPolicyRequest) MarshalJSON() ([]byte, error) + type Snapshot struct + ExpireTime string + ForceSendFields []string + Labels map[string]string + Name string + NullFields []string + Topic string + func (s *Snapshot) MarshalJSON() ([]byte, error) + type Subscription struct + AckDeadlineSeconds int64 + DeadLetterPolicy *DeadLetterPolicy + ExpirationPolicy *ExpirationPolicy + Filter string + ForceSendFields []string + Labels map[string]string + MessageRetentionDuration string + Name string + NullFields []string + PushConfig *PushConfig + RetainAckedMessages bool + Topic string + func (s *Subscription) MarshalJSON() ([]byte, error) + type TestIamPermissionsRequest struct + ForceSendFields []string + NullFields []string + Permissions []string + func (s *TestIamPermissionsRequest) MarshalJSON() ([]byte, error) + type TestIamPermissionsResponse struct + ForceSendFields []string + NullFields []string + Permissions []string + func (s *TestIamPermissionsResponse) MarshalJSON() ([]byte, error) + type Topic struct + ForceSendFields []string + KmsKeyName string + Labels map[string]string + MessageStoragePolicy *MessageStoragePolicy + Name string + NullFields []string + func (s *Topic) MarshalJSON() ([]byte, error) + type UpdateSnapshotRequest struct + ForceSendFields []string + NullFields []string + Snapshot *Snapshot + UpdateMask string + func (s *UpdateSnapshotRequest) MarshalJSON() ([]byte, error) + type UpdateSubscriptionRequest struct + ForceSendFields []string + NullFields []string + Subscription *Subscription + UpdateMask string + func (s *UpdateSubscriptionRequest) MarshalJSON() ([]byte, error) + type UpdateTopicRequest struct + ForceSendFields []string + NullFields []string + Topic *Topic + UpdateMask string + func (s *UpdateTopicRequest) MarshalJSON() ([]byte, error)
Go to main page