Versions in this module Expand all Collapse all v0 v0.196.2 Sep 10, 2024 Changes in this version + const CloudPlatformScope + type AdminProjectsLocationsOperationsCancelCall struct + func (c *AdminProjectsLocationsOperationsCancelCall) Context(ctx context.Context) *AdminProjectsLocationsOperationsCancelCall + func (c *AdminProjectsLocationsOperationsCancelCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *AdminProjectsLocationsOperationsCancelCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsOperationsCancelCall + func (c *AdminProjectsLocationsOperationsCancelCall) Header() http.Header + type AdminProjectsLocationsOperationsDeleteCall struct + func (c *AdminProjectsLocationsOperationsDeleteCall) Context(ctx context.Context) *AdminProjectsLocationsOperationsDeleteCall + func (c *AdminProjectsLocationsOperationsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *AdminProjectsLocationsOperationsDeleteCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsOperationsDeleteCall + func (c *AdminProjectsLocationsOperationsDeleteCall) Header() http.Header + type AdminProjectsLocationsOperationsGetCall struct + func (c *AdminProjectsLocationsOperationsGetCall) Context(ctx context.Context) *AdminProjectsLocationsOperationsGetCall + func (c *AdminProjectsLocationsOperationsGetCall) Do(opts ...googleapi.CallOption) (*Operation, error) + func (c *AdminProjectsLocationsOperationsGetCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsOperationsGetCall + func (c *AdminProjectsLocationsOperationsGetCall) Header() http.Header + func (c *AdminProjectsLocationsOperationsGetCall) IfNoneMatch(entityTag string) *AdminProjectsLocationsOperationsGetCall + type AdminProjectsLocationsOperationsListCall struct + func (c *AdminProjectsLocationsOperationsListCall) Context(ctx context.Context) *AdminProjectsLocationsOperationsListCall + func (c *AdminProjectsLocationsOperationsListCall) Do(opts ...googleapi.CallOption) (*ListOperationsResponse, error) + func (c *AdminProjectsLocationsOperationsListCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsOperationsListCall + func (c *AdminProjectsLocationsOperationsListCall) Filter(filter string) *AdminProjectsLocationsOperationsListCall + func (c *AdminProjectsLocationsOperationsListCall) Header() http.Header + func (c *AdminProjectsLocationsOperationsListCall) IfNoneMatch(entityTag string) *AdminProjectsLocationsOperationsListCall + func (c *AdminProjectsLocationsOperationsListCall) PageSize(pageSize int64) *AdminProjectsLocationsOperationsListCall + func (c *AdminProjectsLocationsOperationsListCall) PageToken(pageToken string) *AdminProjectsLocationsOperationsListCall + func (c *AdminProjectsLocationsOperationsListCall) Pages(ctx context.Context, f func(*ListOperationsResponse) error) error + type AdminProjectsLocationsOperationsService struct + func NewAdminProjectsLocationsOperationsService(s *Service) *AdminProjectsLocationsOperationsService + func (r *AdminProjectsLocationsOperationsService) Cancel(name string, canceloperationrequest *CancelOperationRequest) *AdminProjectsLocationsOperationsCancelCall + func (r *AdminProjectsLocationsOperationsService) Delete(name string) *AdminProjectsLocationsOperationsDeleteCall + func (r *AdminProjectsLocationsOperationsService) Get(name string) *AdminProjectsLocationsOperationsGetCall + func (r *AdminProjectsLocationsOperationsService) List(name string) *AdminProjectsLocationsOperationsListCall + type AdminProjectsLocationsReservationsCreateCall struct + func (c *AdminProjectsLocationsReservationsCreateCall) Context(ctx context.Context) *AdminProjectsLocationsReservationsCreateCall + func (c *AdminProjectsLocationsReservationsCreateCall) Do(opts ...googleapi.CallOption) (*Reservation, error) + func (c *AdminProjectsLocationsReservationsCreateCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsReservationsCreateCall + func (c *AdminProjectsLocationsReservationsCreateCall) Header() http.Header + func (c *AdminProjectsLocationsReservationsCreateCall) ReservationId(reservationId string) *AdminProjectsLocationsReservationsCreateCall + type AdminProjectsLocationsReservationsDeleteCall struct + func (c *AdminProjectsLocationsReservationsDeleteCall) Context(ctx context.Context) *AdminProjectsLocationsReservationsDeleteCall + func (c *AdminProjectsLocationsReservationsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *AdminProjectsLocationsReservationsDeleteCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsReservationsDeleteCall + func (c *AdminProjectsLocationsReservationsDeleteCall) Header() http.Header + type AdminProjectsLocationsReservationsGetCall struct + func (c *AdminProjectsLocationsReservationsGetCall) Context(ctx context.Context) *AdminProjectsLocationsReservationsGetCall + func (c *AdminProjectsLocationsReservationsGetCall) Do(opts ...googleapi.CallOption) (*Reservation, error) + func (c *AdminProjectsLocationsReservationsGetCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsReservationsGetCall + func (c *AdminProjectsLocationsReservationsGetCall) Header() http.Header + func (c *AdminProjectsLocationsReservationsGetCall) IfNoneMatch(entityTag string) *AdminProjectsLocationsReservationsGetCall + type AdminProjectsLocationsReservationsListCall struct + func (c *AdminProjectsLocationsReservationsListCall) Context(ctx context.Context) *AdminProjectsLocationsReservationsListCall + func (c *AdminProjectsLocationsReservationsListCall) Do(opts ...googleapi.CallOption) (*ListReservationsResponse, error) + func (c *AdminProjectsLocationsReservationsListCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsReservationsListCall + func (c *AdminProjectsLocationsReservationsListCall) Header() http.Header + func (c *AdminProjectsLocationsReservationsListCall) IfNoneMatch(entityTag string) *AdminProjectsLocationsReservationsListCall + func (c *AdminProjectsLocationsReservationsListCall) PageSize(pageSize int64) *AdminProjectsLocationsReservationsListCall + func (c *AdminProjectsLocationsReservationsListCall) PageToken(pageToken string) *AdminProjectsLocationsReservationsListCall + func (c *AdminProjectsLocationsReservationsListCall) Pages(ctx context.Context, f func(*ListReservationsResponse) error) error + type AdminProjectsLocationsReservationsPatchCall struct + func (c *AdminProjectsLocationsReservationsPatchCall) Context(ctx context.Context) *AdminProjectsLocationsReservationsPatchCall + func (c *AdminProjectsLocationsReservationsPatchCall) Do(opts ...googleapi.CallOption) (*Reservation, error) + func (c *AdminProjectsLocationsReservationsPatchCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsReservationsPatchCall + func (c *AdminProjectsLocationsReservationsPatchCall) Header() http.Header + func (c *AdminProjectsLocationsReservationsPatchCall) UpdateMask(updateMask string) *AdminProjectsLocationsReservationsPatchCall + type AdminProjectsLocationsReservationsService struct + Topics *AdminProjectsLocationsReservationsTopicsService + func NewAdminProjectsLocationsReservationsService(s *Service) *AdminProjectsLocationsReservationsService + func (r *AdminProjectsLocationsReservationsService) Create(parent string, reservation *Reservation) *AdminProjectsLocationsReservationsCreateCall + func (r *AdminProjectsLocationsReservationsService) Delete(name string) *AdminProjectsLocationsReservationsDeleteCall + func (r *AdminProjectsLocationsReservationsService) Get(name string) *AdminProjectsLocationsReservationsGetCall + func (r *AdminProjectsLocationsReservationsService) List(parent string) *AdminProjectsLocationsReservationsListCall + func (r *AdminProjectsLocationsReservationsService) Patch(name string, reservation *Reservation) *AdminProjectsLocationsReservationsPatchCall + type AdminProjectsLocationsReservationsTopicsListCall struct + func (c *AdminProjectsLocationsReservationsTopicsListCall) Context(ctx context.Context) *AdminProjectsLocationsReservationsTopicsListCall + func (c *AdminProjectsLocationsReservationsTopicsListCall) Do(opts ...googleapi.CallOption) (*ListReservationTopicsResponse, error) + func (c *AdminProjectsLocationsReservationsTopicsListCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsReservationsTopicsListCall + func (c *AdminProjectsLocationsReservationsTopicsListCall) Header() http.Header + func (c *AdminProjectsLocationsReservationsTopicsListCall) IfNoneMatch(entityTag string) *AdminProjectsLocationsReservationsTopicsListCall + func (c *AdminProjectsLocationsReservationsTopicsListCall) PageSize(pageSize int64) *AdminProjectsLocationsReservationsTopicsListCall + func (c *AdminProjectsLocationsReservationsTopicsListCall) PageToken(pageToken string) *AdminProjectsLocationsReservationsTopicsListCall + func (c *AdminProjectsLocationsReservationsTopicsListCall) Pages(ctx context.Context, f func(*ListReservationTopicsResponse) error) error + type AdminProjectsLocationsReservationsTopicsService struct + func NewAdminProjectsLocationsReservationsTopicsService(s *Service) *AdminProjectsLocationsReservationsTopicsService + func (r *AdminProjectsLocationsReservationsTopicsService) List(name string) *AdminProjectsLocationsReservationsTopicsListCall + type AdminProjectsLocationsService struct + Operations *AdminProjectsLocationsOperationsService + Reservations *AdminProjectsLocationsReservationsService + 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) SkipBacklog(skipBacklog bool) *AdminProjectsLocationsSubscriptionsCreateCall + 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 AdminProjectsLocationsSubscriptionsSeekCall struct + func (c *AdminProjectsLocationsSubscriptionsSeekCall) Context(ctx context.Context) *AdminProjectsLocationsSubscriptionsSeekCall + func (c *AdminProjectsLocationsSubscriptionsSeekCall) Do(opts ...googleapi.CallOption) (*Operation, error) + func (c *AdminProjectsLocationsSubscriptionsSeekCall) Fields(s ...googleapi.Field) *AdminProjectsLocationsSubscriptionsSeekCall + func (c *AdminProjectsLocationsSubscriptionsSeekCall) Header() http.Header + 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 + func (r *AdminProjectsLocationsSubscriptionsService) Seek(name string, seeksubscriptionrequest *SeekSubscriptionRequest) *AdminProjectsLocationsSubscriptionsSeekCall + 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 CancelOperationRequest struct + type Capacity struct + ForceSendFields []string + NullFields []string + PublishMibPerSec int64 + SubscribeMibPerSec int64 + func (s Capacity) MarshalJSON() ([]byte, error) + type CommitCursorRequest struct + Cursor *Cursor + ForceSendFields []string + NullFields []string + Partition int64 + func (s CommitCursorRequest) MarshalJSON() ([]byte, error) + type CommitCursorResponse struct + type ComputeHeadCursorRequest struct + ForceSendFields []string + NullFields []string + Partition int64 + func (s ComputeHeadCursorRequest) MarshalJSON() ([]byte, error) + type ComputeHeadCursorResponse struct + ForceSendFields []string + HeadCursor *Cursor + NullFields []string + func (s ComputeHeadCursorResponse) 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 ComputeTimeCursorRequest struct + ForceSendFields []string + NullFields []string + Partition int64 + Target *TimeTarget + func (s ComputeTimeCursorRequest) MarshalJSON() ([]byte, error) + type ComputeTimeCursorResponse struct + Cursor *Cursor + ForceSendFields []string + NullFields []string + func (s ComputeTimeCursorResponse) 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 CursorProjectsLocationsSubscriptionsCommitCursorCall struct + func (c *CursorProjectsLocationsSubscriptionsCommitCursorCall) Context(ctx context.Context) *CursorProjectsLocationsSubscriptionsCommitCursorCall + func (c *CursorProjectsLocationsSubscriptionsCommitCursorCall) Do(opts ...googleapi.CallOption) (*CommitCursorResponse, error) + func (c *CursorProjectsLocationsSubscriptionsCommitCursorCall) Fields(s ...googleapi.Field) *CursorProjectsLocationsSubscriptionsCommitCursorCall + func (c *CursorProjectsLocationsSubscriptionsCommitCursorCall) Header() http.Header + 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 + func (r *CursorProjectsLocationsSubscriptionsService) CommitCursor(subscription string, commitcursorrequest *CommitCursorRequest) *CursorProjectsLocationsSubscriptionsCommitCursorCall + 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 ExportConfig struct + CurrentState string + DeadLetterTopic string + DesiredState string + ForceSendFields []string + NullFields []string + PubsubConfig *PubSubConfig + func (s ExportConfig) MarshalJSON() ([]byte, error) + type ListOperationsResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + Operations []*Operation + func (s ListOperationsResponse) MarshalJSON() ([]byte, error) + type ListPartitionCursorsResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + PartitionCursors []*PartitionCursor + func (s ListPartitionCursorsResponse) MarshalJSON() ([]byte, error) + type ListReservationTopicsResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + Topics []string + func (s ListReservationTopicsResponse) MarshalJSON() ([]byte, error) + type ListReservationsResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + Reservations []*Reservation + func (s ListReservationsResponse) 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 Operation struct + Done bool + Error *Status + ForceSendFields []string + Metadata googleapi.RawMessage + Name string + NullFields []string + Response googleapi.RawMessage + func (s Operation) MarshalJSON() ([]byte, error) + type OperationMetadata struct + CreateTime string + EndTime string + ForceSendFields []string + NullFields []string + Target string + Verb string + func (s OperationMetadata) 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 PubSubConfig struct + ForceSendFields []string + NullFields []string + Topic string + func (s PubSubConfig) MarshalJSON() ([]byte, error) + type Reservation struct + ForceSendFields []string + Name string + NullFields []string + ThroughputCapacity int64 + func (s Reservation) MarshalJSON() ([]byte, error) + type ReservationConfig struct + ForceSendFields []string + NullFields []string + ThroughputReservation string + func (s ReservationConfig) MarshalJSON() ([]byte, error) + type RetentionConfig struct + ForceSendFields []string + NullFields []string + PerPartitionBytes int64 + Period string + func (s RetentionConfig) MarshalJSON() ([]byte, error) + type SeekSubscriptionRequest struct + ForceSendFields []string + NamedTarget string + NullFields []string + TimeTarget *TimeTarget + func (s SeekSubscriptionRequest) MarshalJSON() ([]byte, error) + type SeekSubscriptionResponse struct + 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 Status struct + Code int64 + Details []googleapi.RawMessage + ForceSendFields []string + Message string + NullFields []string + func (s Status) MarshalJSON() ([]byte, error) + type Subscription struct + DeliveryConfig *DeliveryConfig + ExportConfig *ExportConfig + ForceSendFields []string + Name string + NullFields []string + Topic string + func (s Subscription) MarshalJSON() ([]byte, error) + type TimeTarget struct + EventTime string + ForceSendFields []string + NullFields []string + PublishTime string + func (s TimeTarget) MarshalJSON() ([]byte, error) + type Topic struct + ForceSendFields []string + Name string + NullFields []string + PartitionConfig *PartitionConfig + ReservationConfig *ReservationConfig + 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 TopicStatsProjectsLocationsTopicsComputeHeadCursorCall struct + func (c *TopicStatsProjectsLocationsTopicsComputeHeadCursorCall) Context(ctx context.Context) *TopicStatsProjectsLocationsTopicsComputeHeadCursorCall + func (c *TopicStatsProjectsLocationsTopicsComputeHeadCursorCall) Do(opts ...googleapi.CallOption) (*ComputeHeadCursorResponse, error) + func (c *TopicStatsProjectsLocationsTopicsComputeHeadCursorCall) Fields(s ...googleapi.Field) *TopicStatsProjectsLocationsTopicsComputeHeadCursorCall + func (c *TopicStatsProjectsLocationsTopicsComputeHeadCursorCall) Header() http.Header + 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 TopicStatsProjectsLocationsTopicsComputeTimeCursorCall struct + func (c *TopicStatsProjectsLocationsTopicsComputeTimeCursorCall) Context(ctx context.Context) *TopicStatsProjectsLocationsTopicsComputeTimeCursorCall + func (c *TopicStatsProjectsLocationsTopicsComputeTimeCursorCall) Do(opts ...googleapi.CallOption) (*ComputeTimeCursorResponse, error) + func (c *TopicStatsProjectsLocationsTopicsComputeTimeCursorCall) Fields(s ...googleapi.Field) *TopicStatsProjectsLocationsTopicsComputeTimeCursorCall + func (c *TopicStatsProjectsLocationsTopicsComputeTimeCursorCall) Header() http.Header + type TopicStatsProjectsLocationsTopicsService struct + func NewTopicStatsProjectsLocationsTopicsService(s *Service) *TopicStatsProjectsLocationsTopicsService + func (r *TopicStatsProjectsLocationsTopicsService) ComputeHeadCursor(topic string, computeheadcursorrequest *ComputeHeadCursorRequest) *TopicStatsProjectsLocationsTopicsComputeHeadCursorCall + func (r *TopicStatsProjectsLocationsTopicsService) ComputeMessageStats(topic string, computemessagestatsrequest *ComputeMessageStatsRequest) *TopicStatsProjectsLocationsTopicsComputeMessageStatsCall + func (r *TopicStatsProjectsLocationsTopicsService) ComputeTimeCursor(topic string, computetimecursorrequest *ComputeTimeCursorRequest) *TopicStatsProjectsLocationsTopicsComputeTimeCursorCall + type TopicStatsProjectsService struct + Locations *TopicStatsProjectsLocationsService + func NewTopicStatsProjectsService(s *Service) *TopicStatsProjectsService + type TopicStatsService struct + Projects *TopicStatsProjectsService + func NewTopicStatsService(s *Service) *TopicStatsService
Go to main page