Versions in this module Expand all Collapse all v0 v0.196.2 Sep 10, 2024 Changes in this version + const CloudPlatformScope + const PubsubScope + type AcknowledgeRequest struct + AckIds []string + ForceSendFields []string + NullFields []string + func (s AcknowledgeRequest) MarshalJSON() ([]byte, error) + type AnalyticsHubSubscriptionInfo struct + ForceSendFields []string + Listing string + NullFields []string + Subscription string + func (s AnalyticsHubSubscriptionInfo) MarshalJSON() ([]byte, error) + type AvroConfig struct + ForceSendFields []string + NullFields []string + UseTopicSchema bool + WriteMetadata bool + func (s AvroConfig) MarshalJSON() ([]byte, error) + type AwsKinesis struct + AwsRoleArn string + ConsumerArn string + ForceSendFields []string + GcpServiceAccount string + NullFields []string + State string + StreamArn string + func (s AwsKinesis) MarshalJSON() ([]byte, error) + type BigQueryConfig struct + DropUnknownFields bool + ForceSendFields []string + NullFields []string + ServiceAccountEmail string + State string + Table string + UseTableSchema bool + UseTopicSchema bool + WriteMetadata bool + func (s BigQueryConfig) MarshalJSON() ([]byte, error) + type Binding struct + Condition *Expr + ForceSendFields []string + Members []string + NullFields []string + Role string + func (s Binding) MarshalJSON() ([]byte, error) + type CloudStorageConfig struct + AvroConfig *AvroConfig + Bucket string + FilenameDatetimeFormat string + FilenamePrefix string + FilenameSuffix string + ForceSendFields []string + MaxBytes int64 + MaxDuration string + MaxMessages int64 + NullFields []string + ServiceAccountEmail string + State string + TextConfig *TextConfig + func (s CloudStorageConfig) MarshalJSON() ([]byte, error) + type CommitSchemaRequest struct + ForceSendFields []string + NullFields []string + Schema *Schema + func (s CommitSchemaRequest) 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 DetachSubscriptionResponse struct + 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 IngestionDataSourceSettings struct + AwsKinesis *AwsKinesis + ForceSendFields []string + NullFields []string + func (s IngestionDataSourceSettings) MarshalJSON() ([]byte, error) + type ListSchemaRevisionsResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + Schemas []*Schema + func (s ListSchemaRevisionsResponse) MarshalJSON() ([]byte, error) + type ListSchemasResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + Schemas []*Schema + func (s ListSchemasResponse) 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 + EnforceInTransit bool + 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 NoWrapper struct + ForceSendFields []string + NullFields []string + WriteMetadata bool + func (s NoWrapper) 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 ProjectsSchemasCommitCall struct + func (c *ProjectsSchemasCommitCall) Context(ctx context.Context) *ProjectsSchemasCommitCall + func (c *ProjectsSchemasCommitCall) Do(opts ...googleapi.CallOption) (*Schema, error) + func (c *ProjectsSchemasCommitCall) Fields(s ...googleapi.Field) *ProjectsSchemasCommitCall + func (c *ProjectsSchemasCommitCall) Header() http.Header + type ProjectsSchemasCreateCall struct + func (c *ProjectsSchemasCreateCall) Context(ctx context.Context) *ProjectsSchemasCreateCall + func (c *ProjectsSchemasCreateCall) Do(opts ...googleapi.CallOption) (*Schema, error) + func (c *ProjectsSchemasCreateCall) Fields(s ...googleapi.Field) *ProjectsSchemasCreateCall + func (c *ProjectsSchemasCreateCall) Header() http.Header + func (c *ProjectsSchemasCreateCall) SchemaId(schemaId string) *ProjectsSchemasCreateCall + type ProjectsSchemasDeleteCall struct + func (c *ProjectsSchemasDeleteCall) Context(ctx context.Context) *ProjectsSchemasDeleteCall + func (c *ProjectsSchemasDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) + func (c *ProjectsSchemasDeleteCall) Fields(s ...googleapi.Field) *ProjectsSchemasDeleteCall + func (c *ProjectsSchemasDeleteCall) Header() http.Header + type ProjectsSchemasDeleteRevisionCall struct + func (c *ProjectsSchemasDeleteRevisionCall) Context(ctx context.Context) *ProjectsSchemasDeleteRevisionCall + func (c *ProjectsSchemasDeleteRevisionCall) Do(opts ...googleapi.CallOption) (*Schema, error) + func (c *ProjectsSchemasDeleteRevisionCall) Fields(s ...googleapi.Field) *ProjectsSchemasDeleteRevisionCall + func (c *ProjectsSchemasDeleteRevisionCall) Header() http.Header + func (c *ProjectsSchemasDeleteRevisionCall) RevisionId(revisionId string) *ProjectsSchemasDeleteRevisionCall + type ProjectsSchemasGetCall struct + func (c *ProjectsSchemasGetCall) Context(ctx context.Context) *ProjectsSchemasGetCall + func (c *ProjectsSchemasGetCall) Do(opts ...googleapi.CallOption) (*Schema, error) + func (c *ProjectsSchemasGetCall) Fields(s ...googleapi.Field) *ProjectsSchemasGetCall + func (c *ProjectsSchemasGetCall) Header() http.Header + func (c *ProjectsSchemasGetCall) IfNoneMatch(entityTag string) *ProjectsSchemasGetCall + func (c *ProjectsSchemasGetCall) View(view string) *ProjectsSchemasGetCall + type ProjectsSchemasGetIamPolicyCall struct + func (c *ProjectsSchemasGetIamPolicyCall) Context(ctx context.Context) *ProjectsSchemasGetIamPolicyCall + func (c *ProjectsSchemasGetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error) + func (c *ProjectsSchemasGetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsSchemasGetIamPolicyCall + func (c *ProjectsSchemasGetIamPolicyCall) Header() http.Header + func (c *ProjectsSchemasGetIamPolicyCall) IfNoneMatch(entityTag string) *ProjectsSchemasGetIamPolicyCall + func (c *ProjectsSchemasGetIamPolicyCall) OptionsRequestedPolicyVersion(optionsRequestedPolicyVersion int64) *ProjectsSchemasGetIamPolicyCall + type ProjectsSchemasListCall struct + func (c *ProjectsSchemasListCall) Context(ctx context.Context) *ProjectsSchemasListCall + func (c *ProjectsSchemasListCall) Do(opts ...googleapi.CallOption) (*ListSchemasResponse, error) + func (c *ProjectsSchemasListCall) Fields(s ...googleapi.Field) *ProjectsSchemasListCall + func (c *ProjectsSchemasListCall) Header() http.Header + func (c *ProjectsSchemasListCall) IfNoneMatch(entityTag string) *ProjectsSchemasListCall + func (c *ProjectsSchemasListCall) PageSize(pageSize int64) *ProjectsSchemasListCall + func (c *ProjectsSchemasListCall) PageToken(pageToken string) *ProjectsSchemasListCall + func (c *ProjectsSchemasListCall) Pages(ctx context.Context, f func(*ListSchemasResponse) error) error + func (c *ProjectsSchemasListCall) View(view string) *ProjectsSchemasListCall + type ProjectsSchemasListRevisionsCall struct + func (c *ProjectsSchemasListRevisionsCall) Context(ctx context.Context) *ProjectsSchemasListRevisionsCall + func (c *ProjectsSchemasListRevisionsCall) Do(opts ...googleapi.CallOption) (*ListSchemaRevisionsResponse, error) + func (c *ProjectsSchemasListRevisionsCall) Fields(s ...googleapi.Field) *ProjectsSchemasListRevisionsCall + func (c *ProjectsSchemasListRevisionsCall) Header() http.Header + func (c *ProjectsSchemasListRevisionsCall) IfNoneMatch(entityTag string) *ProjectsSchemasListRevisionsCall + func (c *ProjectsSchemasListRevisionsCall) PageSize(pageSize int64) *ProjectsSchemasListRevisionsCall + func (c *ProjectsSchemasListRevisionsCall) PageToken(pageToken string) *ProjectsSchemasListRevisionsCall + func (c *ProjectsSchemasListRevisionsCall) Pages(ctx context.Context, f func(*ListSchemaRevisionsResponse) error) error + func (c *ProjectsSchemasListRevisionsCall) View(view string) *ProjectsSchemasListRevisionsCall + type ProjectsSchemasRollbackCall struct + func (c *ProjectsSchemasRollbackCall) Context(ctx context.Context) *ProjectsSchemasRollbackCall + func (c *ProjectsSchemasRollbackCall) Do(opts ...googleapi.CallOption) (*Schema, error) + func (c *ProjectsSchemasRollbackCall) Fields(s ...googleapi.Field) *ProjectsSchemasRollbackCall + func (c *ProjectsSchemasRollbackCall) Header() http.Header + type ProjectsSchemasService struct + func NewProjectsSchemasService(s *Service) *ProjectsSchemasService + func (r *ProjectsSchemasService) Commit(name string, commitschemarequest *CommitSchemaRequest) *ProjectsSchemasCommitCall + func (r *ProjectsSchemasService) Create(parent string, schema *Schema) *ProjectsSchemasCreateCall + func (r *ProjectsSchemasService) Delete(name string) *ProjectsSchemasDeleteCall + func (r *ProjectsSchemasService) DeleteRevision(name string) *ProjectsSchemasDeleteRevisionCall + func (r *ProjectsSchemasService) Get(name string) *ProjectsSchemasGetCall + func (r *ProjectsSchemasService) GetIamPolicy(resource string) *ProjectsSchemasGetIamPolicyCall + func (r *ProjectsSchemasService) List(parent string) *ProjectsSchemasListCall + func (r *ProjectsSchemasService) ListRevisions(name string) *ProjectsSchemasListRevisionsCall + func (r *ProjectsSchemasService) Rollback(name string, rollbackschemarequest *RollbackSchemaRequest) *ProjectsSchemasRollbackCall + func (r *ProjectsSchemasService) SetIamPolicy(resource string, setiampolicyrequest *SetIamPolicyRequest) *ProjectsSchemasSetIamPolicyCall + func (r *ProjectsSchemasService) TestIamPermissions(resource string, testiampermissionsrequest *TestIamPermissionsRequest) *ProjectsSchemasTestIamPermissionsCall + func (r *ProjectsSchemasService) Validate(parent string, validateschemarequest *ValidateSchemaRequest) *ProjectsSchemasValidateCall + func (r *ProjectsSchemasService) ValidateMessage(parent string, validatemessagerequest *ValidateMessageRequest) *ProjectsSchemasValidateMessageCall + type ProjectsSchemasSetIamPolicyCall struct + func (c *ProjectsSchemasSetIamPolicyCall) Context(ctx context.Context) *ProjectsSchemasSetIamPolicyCall + func (c *ProjectsSchemasSetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error) + func (c *ProjectsSchemasSetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsSchemasSetIamPolicyCall + func (c *ProjectsSchemasSetIamPolicyCall) Header() http.Header + type ProjectsSchemasTestIamPermissionsCall struct + func (c *ProjectsSchemasTestIamPermissionsCall) Context(ctx context.Context) *ProjectsSchemasTestIamPermissionsCall + func (c *ProjectsSchemasTestIamPermissionsCall) Do(opts ...googleapi.CallOption) (*TestIamPermissionsResponse, error) + func (c *ProjectsSchemasTestIamPermissionsCall) Fields(s ...googleapi.Field) *ProjectsSchemasTestIamPermissionsCall + func (c *ProjectsSchemasTestIamPermissionsCall) Header() http.Header + type ProjectsSchemasValidateCall struct + func (c *ProjectsSchemasValidateCall) Context(ctx context.Context) *ProjectsSchemasValidateCall + func (c *ProjectsSchemasValidateCall) Do(opts ...googleapi.CallOption) (*ValidateSchemaResponse, error) + func (c *ProjectsSchemasValidateCall) Fields(s ...googleapi.Field) *ProjectsSchemasValidateCall + func (c *ProjectsSchemasValidateCall) Header() http.Header + type ProjectsSchemasValidateMessageCall struct + func (c *ProjectsSchemasValidateMessageCall) Context(ctx context.Context) *ProjectsSchemasValidateMessageCall + func (c *ProjectsSchemasValidateMessageCall) Do(opts ...googleapi.CallOption) (*ValidateMessageResponse, error) + func (c *ProjectsSchemasValidateMessageCall) Fields(s ...googleapi.Field) *ProjectsSchemasValidateMessageCall + func (c *ProjectsSchemasValidateMessageCall) Header() http.Header + type ProjectsService struct + Schemas *ProjectsSchemasService + 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 ProjectsSubscriptionsDetachCall struct + func (c *ProjectsSubscriptionsDetachCall) Context(ctx context.Context) *ProjectsSubscriptionsDetachCall + func (c *ProjectsSubscriptionsDetachCall) Do(opts ...googleapi.CallOption) (*DetachSubscriptionResponse, error) + func (c *ProjectsSubscriptionsDetachCall) Fields(s ...googleapi.Field) *ProjectsSubscriptionsDetachCall + func (c *ProjectsSubscriptionsDetachCall) 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) Detach(subscription string) *ProjectsSubscriptionsDetachCall + 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 + OrderingKey string + PublishTime string + func (s PubsubMessage) MarshalJSON() ([]byte, error) + type PubsubWrapper struct + 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 + NoWrapper *NoWrapper + NullFields []string + OidcToken *OidcToken + PubsubWrapper *PubsubWrapper + 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 RetryPolicy struct + ForceSendFields []string + MaximumBackoff string + MinimumBackoff string + NullFields []string + func (s RetryPolicy) MarshalJSON() ([]byte, error) + type RollbackSchemaRequest struct + ForceSendFields []string + NullFields []string + RevisionId string + func (s RollbackSchemaRequest) MarshalJSON() ([]byte, error) + type Schema struct + Definition string + ForceSendFields []string + Name string + NullFields []string + RevisionCreateTime string + RevisionId string + Type string + func (s Schema) MarshalJSON() ([]byte, error) + type SchemaSettings struct + Encoding string + FirstRevisionId string + ForceSendFields []string + LastRevisionId string + NullFields []string + Schema string + func (s SchemaSettings) 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 + AnalyticsHubSubscriptionInfo *AnalyticsHubSubscriptionInfo + BigqueryConfig *BigQueryConfig + CloudStorageConfig *CloudStorageConfig + DeadLetterPolicy *DeadLetterPolicy + Detached bool + EnableExactlyOnceDelivery bool + EnableMessageOrdering bool + ExpirationPolicy *ExpirationPolicy + Filter string + ForceSendFields []string + Labels map[string]string + MessageRetentionDuration string + Name string + NullFields []string + PushConfig *PushConfig + RetainAckedMessages bool + RetryPolicy *RetryPolicy + State string + Topic string + TopicMessageRetentionDuration 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 TextConfig struct + type Topic struct + ForceSendFields []string + IngestionDataSourceSettings *IngestionDataSourceSettings + KmsKeyName string + Labels map[string]string + MessageRetentionDuration string + MessageStoragePolicy *MessageStoragePolicy + Name string + NullFields []string + SatisfiesPzs bool + SchemaSettings *SchemaSettings + State 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) + type ValidateMessageRequest struct + Encoding string + ForceSendFields []string + Message string + Name string + NullFields []string + Schema *Schema + func (s ValidateMessageRequest) MarshalJSON() ([]byte, error) + type ValidateMessageResponse struct + type ValidateSchemaRequest struct + ForceSendFields []string + NullFields []string + Schema *Schema + func (s ValidateSchemaRequest) MarshalJSON() ([]byte, error) + type ValidateSchemaResponse struct
Go to main page