Versions in this module Expand all Collapse all v0 v0.37.1 Dec 15, 2020 Changes in this version + const CloudPlatformScope + type AdminProjectsLocationsService struct + Subscriptions *AdminProjectsLocationsSubscriptionsService + Topics *AdminProjectsLocationsTopicsService + func NewAdminProjectsLocationsService(s *Service) *AdminProjectsLocationsService + type AdminProjectsLocationsSubscriptionsCreateCall struct + func (c *AdminProjectsLocationsSubscriptionsCreateCall) Context(ctx context.Context) *AdminProjectsLocationsSubscriptionsCreateCall + func (c *AdminProjectsLocationsSubscriptionsCreateCall) Do(opts ...googleapi.CallOption) (*Subscription, error) + func (c *AdminProjectsLocationsSubscriptionsCreateCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsSubscriptionsCreateCall + func (c *AdminProjectsLocationsSubscriptionsCreateCall) Header() http.Header + func (c *AdminProjectsLocationsSubscriptionsCreateCall) SubscriptionId(subscriptionId string) *AdminProjectsLocationsSubscriptionsCreateCall + type AdminProjectsLocationsSubscriptionsDeleteCall struct + func (c *AdminProjectsLocationsSubscriptionsDeleteCall) Context(ctx context.Context) *AdminProjectsLocationsSubscriptionsDeleteCall + func (c *AdminProjectsLocationsSubscriptionsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *AdminProjectsLocationsSubscriptionsDeleteCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsSubscriptionsDeleteCall + func (c *AdminProjectsLocationsSubscriptionsDeleteCall) Header() http.Header + type AdminProjectsLocationsSubscriptionsGetCall struct + func (c *AdminProjectsLocationsSubscriptionsGetCall) Context(ctx context.Context) *AdminProjectsLocationsSubscriptionsGetCall + func (c *AdminProjectsLocationsSubscriptionsGetCall) Do(opts ...googleapi.CallOption) (*Subscription, error) + func (c *AdminProjectsLocationsSubscriptionsGetCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsSubscriptionsGetCall + func (c *AdminProjectsLocationsSubscriptionsGetCall) Header() http.Header + func (c *AdminProjectsLocationsSubscriptionsGetCall) IfNoneMatch(entityTag string) *AdminProjectsLocationsSubscriptionsGetCall + type AdminProjectsLocationsSubscriptionsListCall struct + func (c *AdminProjectsLocationsSubscriptionsListCall) Context(ctx context.Context) *AdminProjectsLocationsSubscriptionsListCall + func (c *AdminProjectsLocationsSubscriptionsListCall) Do(opts ...googleapi.CallOption) (*ListSubscriptionsResponse, error) + func (c *AdminProjectsLocationsSubscriptionsListCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsSubscriptionsListCall + func (c *AdminProjectsLocationsSubscriptionsListCall) Header() http.Header + func (c *AdminProjectsLocationsSubscriptionsListCall) IfNoneMatch(entityTag string) *AdminProjectsLocationsSubscriptionsListCall + func (c *AdminProjectsLocationsSubscriptionsListCall) PageSize(pageSize int64) *AdminProjectsLocationsSubscriptionsListCall + func (c *AdminProjectsLocationsSubscriptionsListCall) PageToken(pageToken string) *AdminProjectsLocationsSubscriptionsListCall + func (c *AdminProjectsLocationsSubscriptionsListCall) Pages(ctx context.Context, f func(*ListSubscriptionsResponse) error) error + type AdminProjectsLocationsSubscriptionsPatchCall struct + func (c *AdminProjectsLocationsSubscriptionsPatchCall) Context(ctx context.Context) *AdminProjectsLocationsSubscriptionsPatchCall + func (c *AdminProjectsLocationsSubscriptionsPatchCall) Do(opts ...googleapi.CallOption) (*Subscription, error) + func (c *AdminProjectsLocationsSubscriptionsPatchCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsSubscriptionsPatchCall + func (c *AdminProjectsLocationsSubscriptionsPatchCall) Header() http.Header + func (c *AdminProjectsLocationsSubscriptionsPatchCall) UpdateMask(updateMask string) *AdminProjectsLocationsSubscriptionsPatchCall + type AdminProjectsLocationsSubscriptionsService struct + func NewAdminProjectsLocationsSubscriptionsService(s *Service) *AdminProjectsLocationsSubscriptionsService + func (r *AdminProjectsLocationsSubscriptionsService) Create(parent string, subscription *Subscription) *AdminProjectsLocationsSubscriptionsCreateCall + func (r *AdminProjectsLocationsSubscriptionsService) Delete(name string) *AdminProjectsLocationsSubscriptionsDeleteCall + func (r *AdminProjectsLocationsSubscriptionsService) Get(name string) *AdminProjectsLocationsSubscriptionsGetCall + func (r *AdminProjectsLocationsSubscriptionsService) List(parent string) *AdminProjectsLocationsSubscriptionsListCall + func (r *AdminProjectsLocationsSubscriptionsService) Patch(name string, subscription *Subscription) *AdminProjectsLocationsSubscriptionsPatchCall + type AdminProjectsLocationsTopicsCreateCall struct + func (c *AdminProjectsLocationsTopicsCreateCall) Context(ctx context.Context) *AdminProjectsLocationsTopicsCreateCall + func (c *AdminProjectsLocationsTopicsCreateCall) Do(opts ...googleapi.CallOption) (*Topic, error) + func (c *AdminProjectsLocationsTopicsCreateCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsTopicsCreateCall + func (c *AdminProjectsLocationsTopicsCreateCall) Header() http.Header + func (c *AdminProjectsLocationsTopicsCreateCall) TopicId(topicId string) *AdminProjectsLocationsTopicsCreateCall + type AdminProjectsLocationsTopicsDeleteCall struct + func (c *AdminProjectsLocationsTopicsDeleteCall) Context(ctx context.Context) *AdminProjectsLocationsTopicsDeleteCall + func (c *AdminProjectsLocationsTopicsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *AdminProjectsLocationsTopicsDeleteCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsTopicsDeleteCall + func (c *AdminProjectsLocationsTopicsDeleteCall) Header() http.Header + type AdminProjectsLocationsTopicsGetCall struct + func (c *AdminProjectsLocationsTopicsGetCall) Context(ctx context.Context) *AdminProjectsLocationsTopicsGetCall + func (c *AdminProjectsLocationsTopicsGetCall) Do(opts ...googleapi.CallOption) (*Topic, error) + func (c *AdminProjectsLocationsTopicsGetCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsTopicsGetCall + func (c *AdminProjectsLocationsTopicsGetCall) Header() http.Header + func (c *AdminProjectsLocationsTopicsGetCall) IfNoneMatch(entityTag string) *AdminProjectsLocationsTopicsGetCall + type AdminProjectsLocationsTopicsGetPartitionsCall struct + func (c *AdminProjectsLocationsTopicsGetPartitionsCall) Context(ctx context.Context) *AdminProjectsLocationsTopicsGetPartitionsCall + func (c *AdminProjectsLocationsTopicsGetPartitionsCall) Do(opts ...googleapi.CallOption) (*TopicPartitions, error) + func (c *AdminProjectsLocationsTopicsGetPartitionsCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsTopicsGetPartitionsCall + func (c *AdminProjectsLocationsTopicsGetPartitionsCall) Header() http.Header + func (c *AdminProjectsLocationsTopicsGetPartitionsCall) IfNoneMatch(entityTag string) *AdminProjectsLocationsTopicsGetPartitionsCall + type AdminProjectsLocationsTopicsListCall struct + func (c *AdminProjectsLocationsTopicsListCall) Context(ctx context.Context) *AdminProjectsLocationsTopicsListCall + func (c *AdminProjectsLocationsTopicsListCall) Do(opts ...googleapi.CallOption) (*ListTopicsResponse, error) + func (c *AdminProjectsLocationsTopicsListCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsTopicsListCall + func (c *AdminProjectsLocationsTopicsListCall) Header() http.Header + func (c *AdminProjectsLocationsTopicsListCall) IfNoneMatch(entityTag string) *AdminProjectsLocationsTopicsListCall + func (c *AdminProjectsLocationsTopicsListCall) PageSize(pageSize int64) *AdminProjectsLocationsTopicsListCall + func (c *AdminProjectsLocationsTopicsListCall) PageToken(pageToken string) *AdminProjectsLocationsTopicsListCall + func (c *AdminProjectsLocationsTopicsListCall) Pages(ctx context.Context, f func(*ListTopicsResponse) error) error + type AdminProjectsLocationsTopicsPatchCall struct + func (c *AdminProjectsLocationsTopicsPatchCall) Context(ctx context.Context) *AdminProjectsLocationsTopicsPatchCall + func (c *AdminProjectsLocationsTopicsPatchCall) Do(opts ...googleapi.CallOption) (*Topic, error) + func (c *AdminProjectsLocationsTopicsPatchCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsTopicsPatchCall + func (c *AdminProjectsLocationsTopicsPatchCall) Header() http.Header + func (c *AdminProjectsLocationsTopicsPatchCall) UpdateMask(updateMask string) *AdminProjectsLocationsTopicsPatchCall + type AdminProjectsLocationsTopicsService struct + Subscriptions *AdminProjectsLocationsTopicsSubscriptionsService + func NewAdminProjectsLocationsTopicsService(s *Service) *AdminProjectsLocationsTopicsService + func (r *AdminProjectsLocationsTopicsService) Create(parent string, topic *Topic) *AdminProjectsLocationsTopicsCreateCall + func (r *AdminProjectsLocationsTopicsService) Delete(name string) *AdminProjectsLocationsTopicsDeleteCall + func (r *AdminProjectsLocationsTopicsService) Get(name string) *AdminProjectsLocationsTopicsGetCall + func (r *AdminProjectsLocationsTopicsService) GetPartitions(name string) *AdminProjectsLocationsTopicsGetPartitionsCall + func (r *AdminProjectsLocationsTopicsService) List(parent string) *AdminProjectsLocationsTopicsListCall + func (r *AdminProjectsLocationsTopicsService) Patch(name string, topic *Topic) *AdminProjectsLocationsTopicsPatchCall + type AdminProjectsLocationsTopicsSubscriptionsListCall struct + func (c *AdminProjectsLocationsTopicsSubscriptionsListCall) Context(ctx context.Context) *AdminProjectsLocationsTopicsSubscriptionsListCall + func (c *AdminProjectsLocationsTopicsSubscriptionsListCall) Do(opts ...googleapi.CallOption) (*ListTopicSubscriptionsResponse, error) + func (c *AdminProjectsLocationsTopicsSubscriptionsListCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsTopicsSubscriptionsListCall + func (c *AdminProjectsLocationsTopicsSubscriptionsListCall) Header() http.Header + func (c *AdminProjectsLocationsTopicsSubscriptionsListCall) IfNoneMatch(entityTag string) *AdminProjectsLocationsTopicsSubscriptionsListCall + func (c *AdminProjectsLocationsTopicsSubscriptionsListCall) PageSize(pageSize int64) *AdminProjectsLocationsTopicsSubscriptionsListCall + func (c *AdminProjectsLocationsTopicsSubscriptionsListCall) PageToken(pageToken string) *AdminProjectsLocationsTopicsSubscriptionsListCall + func (c *AdminProjectsLocationsTopicsSubscriptionsListCall) Pages(ctx context.Context, f func(*ListTopicSubscriptionsResponse) error) error + type AdminProjectsLocationsTopicsSubscriptionsService struct + func NewAdminProjectsLocationsTopicsSubscriptionsService(s *Service) *AdminProjectsLocationsTopicsSubscriptionsService + func (r *AdminProjectsLocationsTopicsSubscriptionsService) List(name string) *AdminProjectsLocationsTopicsSubscriptionsListCall + type AdminProjectsService struct + Locations *AdminProjectsLocationsService + func NewAdminProjectsService(s *Service) *AdminProjectsService + type AdminService struct + Projects *AdminProjectsService + func NewAdminService(s *Service) *AdminService + type Capacity struct + ForceSendFields []string + NullFields []string + PublishMibPerSec int64 + SubscribeMibPerSec int64 + func (s *Capacity) MarshalJSON() ([]byte, error) + type ComputeMessageStatsRequest struct + EndCursor *Cursor + ForceSendFields []string + NullFields []string + Partition int64 + StartCursor *Cursor + func (s *ComputeMessageStatsRequest) MarshalJSON() ([]byte, error) + type ComputeMessageStatsResponse struct + ForceSendFields []string + MessageBytes int64 + MessageCount int64 + MinimumEventTime string + MinimumPublishTime string + NullFields []string + func (s *ComputeMessageStatsResponse) MarshalJSON() ([]byte, error) + type Cursor struct + ForceSendFields []string + NullFields []string + Offset int64 + func (s *Cursor) MarshalJSON() ([]byte, error) + type CursorProjectsLocationsService struct + Subscriptions *CursorProjectsLocationsSubscriptionsService + func NewCursorProjectsLocationsService(s *Service) *CursorProjectsLocationsService + type CursorProjectsLocationsSubscriptionsCursorsListCall struct + func (c *CursorProjectsLocationsSubscriptionsCursorsListCall) Context(ctx context.Context) *CursorProjectsLocationsSubscriptionsCursorsListCall + func (c *CursorProjectsLocationsSubscriptionsCursorsListCall) Do(opts ...googleapi.CallOption) (*ListPartitionCursorsResponse, error) + func (c *CursorProjectsLocationsSubscriptionsCursorsListCall) Fields(s ...googleapi.Field) *CursorProjectsLocationsSubscriptionsCursorsListCall + func (c *CursorProjectsLocationsSubscriptionsCursorsListCall) Header() http.Header + func (c *CursorProjectsLocationsSubscriptionsCursorsListCall) IfNoneMatch(entityTag string) *CursorProjectsLocationsSubscriptionsCursorsListCall + func (c *CursorProjectsLocationsSubscriptionsCursorsListCall) PageSize(pageSize int64) *CursorProjectsLocationsSubscriptionsCursorsListCall + func (c *CursorProjectsLocationsSubscriptionsCursorsListCall) PageToken(pageToken string) *CursorProjectsLocationsSubscriptionsCursorsListCall + func (c *CursorProjectsLocationsSubscriptionsCursorsListCall) Pages(ctx context.Context, f func(*ListPartitionCursorsResponse) error) error + type CursorProjectsLocationsSubscriptionsCursorsService struct + func NewCursorProjectsLocationsSubscriptionsCursorsService(s *Service) *CursorProjectsLocationsSubscriptionsCursorsService + func (r *CursorProjectsLocationsSubscriptionsCursorsService) List(parent string) *CursorProjectsLocationsSubscriptionsCursorsListCall + type CursorProjectsLocationsSubscriptionsService struct + Cursors *CursorProjectsLocationsSubscriptionsCursorsService + func NewCursorProjectsLocationsSubscriptionsService(s *Service) *CursorProjectsLocationsSubscriptionsService + type CursorProjectsService struct + Locations *CursorProjectsLocationsService + func NewCursorProjectsService(s *Service) *CursorProjectsService + type CursorService struct + Projects *CursorProjectsService + func NewCursorService(s *Service) *CursorService + type DeliveryConfig struct + DeliveryRequirement string + ForceSendFields []string + NullFields []string + func (s *DeliveryConfig) MarshalJSON() ([]byte, error) + type Empty struct + type ListPartitionCursorsResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + PartitionCursors []*PartitionCursor + func (s *ListPartitionCursorsResponse) 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 PartitionConfig struct + Capacity *Capacity + Count int64 + ForceSendFields []string + NullFields []string + Scale int64 + func (s *PartitionConfig) MarshalJSON() ([]byte, error) + type PartitionCursor struct + Cursor *Cursor + ForceSendFields []string + NullFields []string + Partition int64 + func (s *PartitionCursor) MarshalJSON() ([]byte, error) + type RetentionConfig struct + ForceSendFields []string + NullFields []string + PerPartitionBytes int64 + Period string + func (s *RetentionConfig) MarshalJSON() ([]byte, error) + type Service struct + Admin *AdminService + BasePath string + Cursor *CursorService + TopicStats *TopicStatsService + UserAgent string + func New(client *http.Client) (*Service, error) + func NewService(ctx context.Context, opts ...option.ClientOption) (*Service, error) + type Subscription struct + DeliveryConfig *DeliveryConfig + ForceSendFields []string + Name string + NullFields []string + Topic string + func (s *Subscription) MarshalJSON() ([]byte, error) + type Topic struct + ForceSendFields []string + Name string + NullFields []string + PartitionConfig *PartitionConfig + RetentionConfig *RetentionConfig + func (s *Topic) MarshalJSON() ([]byte, error) + type TopicPartitions struct + ForceSendFields []string + NullFields []string + PartitionCount int64 + func (s *TopicPartitions) MarshalJSON() ([]byte, error) + type TopicStatsProjectsLocationsService struct + Topics *TopicStatsProjectsLocationsTopicsService + func NewTopicStatsProjectsLocationsService(s *Service) *TopicStatsProjectsLocationsService + type TopicStatsProjectsLocationsTopicsComputeMessageStatsCall struct + func (c *TopicStatsProjectsLocationsTopicsComputeMessageStatsCall) Context(ctx context.Context) *TopicStatsProjectsLocationsTopicsComputeMessageStatsCall + func (c *TopicStatsProjectsLocationsTopicsComputeMessageStatsCall) Do(opts ...googleapi.CallOption) (*ComputeMessageStatsResponse, error) + func (c *TopicStatsProjectsLocationsTopicsComputeMessageStatsCall) Fields(s ...googleapi.Field) *TopicStatsProjectsLocationsTopicsComputeMessageStatsCall + func (c *TopicStatsProjectsLocationsTopicsComputeMessageStatsCall) Header() http.Header + type TopicStatsProjectsLocationsTopicsService struct + func NewTopicStatsProjectsLocationsTopicsService(s *Service) *TopicStatsProjectsLocationsTopicsService + func (r *TopicStatsProjectsLocationsTopicsService) ComputeMessageStats(topic string, computemessagestatsrequest *ComputeMessageStatsRequest) *TopicStatsProjectsLocationsTopicsComputeMessageStatsCall + type TopicStatsProjectsService struct + Locations *TopicStatsProjectsLocationsService + func NewTopicStatsProjectsService(s *Service) *TopicStatsProjectsService + type TopicStatsService struct + Projects *TopicStatsProjectsService + func NewTopicStatsService(s *Service) *TopicStatsService