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 Empty struct + type Expr struct + Description string + Expression string + ForceSendFields []string + Location string + NullFields []string + Title string + func (s *Expr) MarshalJSON() ([]byte, error) + type ListSubscriptionsResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + Subscriptions []*Subscription + func (s *ListSubscriptionsResponse) 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 ModifyAckDeadlineRequest struct + AckDeadlineSeconds int64 + AckId string + 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 + Subscriptions *ProjectsSubscriptionsService + Topics *ProjectsTopicsService + func NewProjectsService(s *Service) *ProjectsService + 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 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 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) Pull(subscription string, pullrequest *PullRequest) *ProjectsSubscriptionsPullCall + 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 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 + 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) 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 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 + ForceSendFields []string + Message *PubsubMessage + NullFields []string + func (s *ReceivedMessage) MarshalJSON() ([]byte, error) + 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 Subscription struct + AckDeadlineSeconds int64 + ForceSendFields []string + Name string + NullFields []string + PushConfig *PushConfig + 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 + Name string + NullFields []string + func (s *Topic) MarshalJSON() ([]byte, error)
Go to main page