pubsubpb

package

Go to main page

Versions in this module

v1

v1.37.0

Mar 7, 2024

v1.37.0-beta.otel.trace2

Apr 9, 2024

v1.37.0-beta.otel.trace

Mar 13, 2024

v1.36.2

Feb 29, 2024

v1.36.1

Jan 30, 2024

v1.36.0

Jan 26, 2024

Changes in this version

+ var IngestionDataSourceSettings_AwsKinesis_State_name = map[int32]string

+ var IngestionDataSourceSettings_AwsKinesis_State_value = map[string]int32

+ var Topic_State_name = map[int32]string

+ var Topic_State_value = map[string]int32

type BigQueryConfig_State

+ const BigQueryConfig_IN_TRANSIT_LOCATION_RESTRICTION

type CloudStorageConfig_State

+ const CloudStorageConfig_IN_TRANSIT_LOCATION_RESTRICTION

+ type IngestionDataSourceSettings struct

+ Source isIngestionDataSourceSettings_Source

+ func (*IngestionDataSourceSettings) Descriptor() ([]byte, []int)

+ func (*IngestionDataSourceSettings) ProtoMessage()

+ func (m *IngestionDataSourceSettings) GetSource() isIngestionDataSourceSettings_Source

+ func (x *IngestionDataSourceSettings) GetAwsKinesis() *IngestionDataSourceSettings_AwsKinesis

+ func (x *IngestionDataSourceSettings) ProtoReflect() protoreflect.Message

+ func (x *IngestionDataSourceSettings) Reset()

+ func (x *IngestionDataSourceSettings) String() string

+ type IngestionDataSourceSettings_AwsKinesis struct

+ AwsRoleArn string

+ ConsumerArn string

+ GcpServiceAccount string

+ State IngestionDataSourceSettings_AwsKinesis_State

+ StreamArn string

+ func (*IngestionDataSourceSettings_AwsKinesis) Descriptor() ([]byte, []int)

+ func (*IngestionDataSourceSettings_AwsKinesis) ProtoMessage()

+ func (x *IngestionDataSourceSettings_AwsKinesis) GetAwsRoleArn() string

+ func (x *IngestionDataSourceSettings_AwsKinesis) GetConsumerArn() string

+ func (x *IngestionDataSourceSettings_AwsKinesis) GetGcpServiceAccount() string

+ func (x *IngestionDataSourceSettings_AwsKinesis) GetState() IngestionDataSourceSettings_AwsKinesis_State

+ func (x *IngestionDataSourceSettings_AwsKinesis) GetStreamArn() string

+ func (x *IngestionDataSourceSettings_AwsKinesis) ProtoReflect() protoreflect.Message

+ func (x *IngestionDataSourceSettings_AwsKinesis) Reset()

+ func (x *IngestionDataSourceSettings_AwsKinesis) String() string

+ type IngestionDataSourceSettings_AwsKinesis_ struct

+ AwsKinesis *IngestionDataSourceSettings_AwsKinesis

+ type IngestionDataSourceSettings_AwsKinesis_State int32

+ const IngestionDataSourceSettings_AwsKinesis_ACTIVE

+ const IngestionDataSourceSettings_AwsKinesis_CONSUMER_NOT_FOUND

+ const IngestionDataSourceSettings_AwsKinesis_KINESIS_PERMISSION_DENIED

+ const IngestionDataSourceSettings_AwsKinesis_PUBLISH_PERMISSION_DENIED

+ const IngestionDataSourceSettings_AwsKinesis_STATE_UNSPECIFIED

+ const IngestionDataSourceSettings_AwsKinesis_STREAM_NOT_FOUND

+ func (IngestionDataSourceSettings_AwsKinesis_State) Descriptor() protoreflect.EnumDescriptor

+ func (IngestionDataSourceSettings_AwsKinesis_State) EnumDescriptor() ([]byte, []int)

+ func (IngestionDataSourceSettings_AwsKinesis_State) Type() protoreflect.EnumType

+ func (x IngestionDataSourceSettings_AwsKinesis_State) Enum() *IngestionDataSourceSettings_AwsKinesis_State

+ func (x IngestionDataSourceSettings_AwsKinesis_State) Number() protoreflect.EnumNumber

+ func (x IngestionDataSourceSettings_AwsKinesis_State) String() string

type MessageStoragePolicy

+ EnforceInTransit bool

+ func (x *MessageStoragePolicy) GetEnforceInTransit() bool

type Topic

+ IngestionDataSourceSettings *IngestionDataSourceSettings

+ State Topic_State

+ func (x *Topic) GetIngestionDataSourceSettings() *IngestionDataSourceSettings

+ func (x *Topic) GetState() Topic_State

+ type Topic_State int32

+ const Topic_ACTIVE

+ const Topic_INGESTION_RESOURCE_ERROR

+ const Topic_STATE_UNSPECIFIED

+ func (Topic_State) Descriptor() protoreflect.EnumDescriptor

+ func (Topic_State) EnumDescriptor() ([]byte, []int)

+ func (Topic_State) Type() protoreflect.EnumType

+ func (x Topic_State) Enum() *Topic_State

+ func (x Topic_State) Number() protoreflect.EnumNumber

+ func (x Topic_State) String() string

v1.35.0

Jan 25, 2024

v1.34.0

Jan 19, 2024

Changes in this version

type BigQueryConfig

+ UseTableSchema bool

+ func (x *BigQueryConfig) GetUseTableSchema() bool

v1.33.0

Jul 24, 2023

v1.32.0

Jun 27, 2023

Changes in this version

type PushConfig

+ Wrapper isPushConfig_Wrapper

+ func (m *PushConfig) GetWrapper() isPushConfig_Wrapper

+ func (x *PushConfig) GetNoWrapper() *PushConfig_NoWrapper

+ func (x *PushConfig) GetPubsubWrapper() *PushConfig_PubsubWrapper

+ type PushConfig_NoWrapper struct

+ WriteMetadata bool

+ func (*PushConfig_NoWrapper) Descriptor() ([]byte, []int)

+ func (*PushConfig_NoWrapper) ProtoMessage()

+ func (x *PushConfig_NoWrapper) GetWriteMetadata() bool

+ func (x *PushConfig_NoWrapper) ProtoReflect() protoreflect.Message

+ func (x *PushConfig_NoWrapper) Reset()

+ func (x *PushConfig_NoWrapper) String() string

+ type PushConfig_NoWrapper_ struct

+ NoWrapper *PushConfig_NoWrapper

+ type PushConfig_PubsubWrapper struct

+ func (*PushConfig_PubsubWrapper) Descriptor() ([]byte, []int)

+ func (*PushConfig_PubsubWrapper) ProtoMessage()

+ func (x *PushConfig_PubsubWrapper) ProtoReflect() protoreflect.Message

+ func (x *PushConfig_PubsubWrapper) Reset()

+ func (x *PushConfig_PubsubWrapper) String() string

+ type PushConfig_PubsubWrapper_ struct

+ PubsubWrapper *PushConfig_PubsubWrapper

v1.31.0

May 24, 2023

Changes in this version

+ var CloudStorageConfig_State_name = map[int32]string

+ var CloudStorageConfig_State_value = map[string]int32

+ type CloudStorageConfig struct

+ Bucket string

+ FilenamePrefix string

+ FilenameSuffix string

+ MaxBytes int64

+ MaxDuration *durationpb.Duration

+ OutputFormat isCloudStorageConfig_OutputFormat

+ State CloudStorageConfig_State

+ func (*CloudStorageConfig) Descriptor() ([]byte, []int)

+ func (*CloudStorageConfig) ProtoMessage()

+ func (m *CloudStorageConfig) GetOutputFormat() isCloudStorageConfig_OutputFormat

+ func (x *CloudStorageConfig) GetAvroConfig() *CloudStorageConfig_AvroConfig

+ func (x *CloudStorageConfig) GetBucket() string

+ func (x *CloudStorageConfig) GetFilenamePrefix() string

+ func (x *CloudStorageConfig) GetFilenameSuffix() string

+ func (x *CloudStorageConfig) GetMaxBytes() int64

+ func (x *CloudStorageConfig) GetMaxDuration() *durationpb.Duration

+ func (x *CloudStorageConfig) GetState() CloudStorageConfig_State

+ func (x *CloudStorageConfig) GetTextConfig() *CloudStorageConfig_TextConfig

+ func (x *CloudStorageConfig) ProtoReflect() protoreflect.Message

+ func (x *CloudStorageConfig) Reset()

+ func (x *CloudStorageConfig) String() string

+ type CloudStorageConfig_AvroConfig struct

+ WriteMetadata bool

+ func (*CloudStorageConfig_AvroConfig) Descriptor() ([]byte, []int)

+ func (*CloudStorageConfig_AvroConfig) ProtoMessage()

+ func (x *CloudStorageConfig_AvroConfig) GetWriteMetadata() bool

+ func (x *CloudStorageConfig_AvroConfig) ProtoReflect() protoreflect.Message

+ func (x *CloudStorageConfig_AvroConfig) Reset()

+ func (x *CloudStorageConfig_AvroConfig) String() string

+ type CloudStorageConfig_AvroConfig_ struct

+ AvroConfig *CloudStorageConfig_AvroConfig

+ type CloudStorageConfig_State int32

+ const CloudStorageConfig_ACTIVE

+ const CloudStorageConfig_NOT_FOUND

+ const CloudStorageConfig_PERMISSION_DENIED

+ const CloudStorageConfig_STATE_UNSPECIFIED

+ func (CloudStorageConfig_State) Descriptor() protoreflect.EnumDescriptor

+ func (CloudStorageConfig_State) EnumDescriptor() ([]byte, []int)

+ func (CloudStorageConfig_State) Type() protoreflect.EnumType

+ func (x CloudStorageConfig_State) Enum() *CloudStorageConfig_State

+ func (x CloudStorageConfig_State) Number() protoreflect.EnumNumber

+ func (x CloudStorageConfig_State) String() string

+ type CloudStorageConfig_TextConfig struct

+ func (*CloudStorageConfig_TextConfig) Descriptor() ([]byte, []int)

+ func (*CloudStorageConfig_TextConfig) ProtoMessage()

+ func (x *CloudStorageConfig_TextConfig) ProtoReflect() protoreflect.Message

+ func (x *CloudStorageConfig_TextConfig) Reset()

+ func (x *CloudStorageConfig_TextConfig) String() string

+ type CloudStorageConfig_TextConfig_ struct

+ TextConfig *CloudStorageConfig_TextConfig

type Subscription

+ CloudStorageConfig *CloudStorageConfig

+ func (x *Subscription) GetCloudStorageConfig() *CloudStorageConfig

v1.30.1

May 3, 2023

v1.30.0

Mar 23, 2023

v1.29.0

Mar 13, 2023

Changes in this version

+ type CommitSchemaRequest struct

+ Name string

+ Schema *Schema

+ func (*CommitSchemaRequest) Descriptor() ([]byte, []int)

+ func (*CommitSchemaRequest) ProtoMessage()

+ func (x *CommitSchemaRequest) GetName() string

+ func (x *CommitSchemaRequest) GetSchema() *Schema

+ func (x *CommitSchemaRequest) ProtoReflect() protoreflect.Message

+ func (x *CommitSchemaRequest) Reset()

+ func (x *CommitSchemaRequest) String() string

+ type DeleteSchemaRevisionRequest struct

+ Name string

+ RevisionId string

+ func (*DeleteSchemaRevisionRequest) Descriptor() ([]byte, []int)

+ func (*DeleteSchemaRevisionRequest) ProtoMessage()

+ func (x *DeleteSchemaRevisionRequest) GetName() string

+ func (x *DeleteSchemaRevisionRequest) GetRevisionId() string

+ func (x *DeleteSchemaRevisionRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteSchemaRevisionRequest) Reset()

+ func (x *DeleteSchemaRevisionRequest) String() string

+ type ListSchemaRevisionsRequest struct

+ Name string

+ PageSize int32

+ PageToken string

+ View SchemaView

+ func (*ListSchemaRevisionsRequest) Descriptor() ([]byte, []int)

+ func (*ListSchemaRevisionsRequest) ProtoMessage()

+ func (x *ListSchemaRevisionsRequest) GetName() string

+ func (x *ListSchemaRevisionsRequest) GetPageSize() int32

+ func (x *ListSchemaRevisionsRequest) GetPageToken() string

+ func (x *ListSchemaRevisionsRequest) GetView() SchemaView

+ func (x *ListSchemaRevisionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListSchemaRevisionsRequest) Reset()

+ func (x *ListSchemaRevisionsRequest) String() string

+ type ListSchemaRevisionsResponse struct

+ NextPageToken string

+ Schemas []*Schema

+ func (*ListSchemaRevisionsResponse) Descriptor() ([]byte, []int)

+ func (*ListSchemaRevisionsResponse) ProtoMessage()

+ func (x *ListSchemaRevisionsResponse) GetNextPageToken() string

+ func (x *ListSchemaRevisionsResponse) GetSchemas() []*Schema

+ func (x *ListSchemaRevisionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListSchemaRevisionsResponse) Reset()

+ func (x *ListSchemaRevisionsResponse) String() string

+ type RollbackSchemaRequest struct

+ Name string

+ RevisionId string

+ func (*RollbackSchemaRequest) Descriptor() ([]byte, []int)

+ func (*RollbackSchemaRequest) ProtoMessage()

+ func (x *RollbackSchemaRequest) GetName() string

+ func (x *RollbackSchemaRequest) GetRevisionId() string

+ func (x *RollbackSchemaRequest) ProtoReflect() protoreflect.Message

+ func (x *RollbackSchemaRequest) Reset()

+ func (x *RollbackSchemaRequest) String() string

type Schema

+ RevisionCreateTime *timestamppb.Timestamp

+ RevisionId string

+ func (x *Schema) GetRevisionCreateTime() *timestamppb.Timestamp

+ func (x *Schema) GetRevisionId() string

type SchemaServiceClient

+ CommitSchema func(ctx context.Context, in *CommitSchemaRequest, opts ...grpc.CallOption) (*Schema, error)

+ DeleteSchemaRevision func(ctx context.Context, in *DeleteSchemaRevisionRequest, opts ...grpc.CallOption) (*Schema, error)

+ ListSchemaRevisions func(ctx context.Context, in *ListSchemaRevisionsRequest, opts ...grpc.CallOption) (*ListSchemaRevisionsResponse, error)

+ RollbackSchema func(ctx context.Context, in *RollbackSchemaRequest, opts ...grpc.CallOption) (*Schema, error)

type SchemaServiceServer

+ CommitSchema func(context.Context, *CommitSchemaRequest) (*Schema, error)

+ DeleteSchemaRevision func(context.Context, *DeleteSchemaRevisionRequest) (*Schema, error)

+ ListSchemaRevisions func(context.Context, *ListSchemaRevisionsRequest) (*ListSchemaRevisionsResponse, error)

+ RollbackSchema func(context.Context, *RollbackSchemaRequest) (*Schema, error)

type SchemaSettings

+ FirstRevisionId string

+ LastRevisionId string

+ func (x *SchemaSettings) GetFirstRevisionId() string

+ func (x *SchemaSettings) GetLastRevisionId() string

type StreamingPullResponse_AcknowledgeConfirmation

+ TemporaryFailedAckIds []string

+ func (x *StreamingPullResponse_AcknowledgeConfirmation) GetTemporaryFailedAckIds() []string

type StreamingPullResponse_ModifyAckDeadlineConfirmation

+ TemporaryFailedAckIds []string

+ func (x *StreamingPullResponse_ModifyAckDeadlineConfirmation) GetTemporaryFailedAckIds() []string

type UnimplementedSchemaServiceServer

+ func (*UnimplementedSchemaServiceServer) CommitSchema(context.Context, *CommitSchemaRequest) (*Schema, error)

+ func (*UnimplementedSchemaServiceServer) DeleteSchemaRevision(context.Context, *DeleteSchemaRevisionRequest) (*Schema, error)

+ func (*UnimplementedSchemaServiceServer) ListSchemaRevisions(context.Context, *ListSchemaRevisionsRequest) (*ListSchemaRevisionsResponse, error)

+ func (*UnimplementedSchemaServiceServer) RollbackSchema(context.Context, *RollbackSchemaRequest) (*Schema, error)

v1.28.0

Dec 5, 2022

v1.27.1

Dec 2, 2022

v1.27.0

Nov 30, 2022

Changes in this version

+ var BigQueryConfig_State_name = map[int32]string

+ var BigQueryConfig_State_value = map[string]int32

+ var Encoding_name = map[int32]string

+ var Encoding_value = map[string]int32

+ var File_google_pubsub_v1_pubsub_proto protoreflect.FileDescriptor

+ var File_google_pubsub_v1_schema_proto protoreflect.FileDescriptor

+ var SchemaView_name = map[int32]string

+ var SchemaView_value = map[string]int32

+ var Schema_Type_name = map[int32]string

+ var Schema_Type_value = map[string]int32

+ var Subscription_State_name = map[int32]string

+ var Subscription_State_value = map[string]int32

+ func RegisterPublisherServer(s *grpc.Server, srv PublisherServer)

+ func RegisterSchemaServiceServer(s *grpc.Server, srv SchemaServiceServer)

+ func RegisterSubscriberServer(s *grpc.Server, srv SubscriberServer)

+ type AcknowledgeRequest struct

+ AckIds []string

+ Subscription string

+ func (*AcknowledgeRequest) Descriptor() ([]byte, []int)

+ func (*AcknowledgeRequest) ProtoMessage()

+ func (x *AcknowledgeRequest) GetAckIds() []string

+ func (x *AcknowledgeRequest) GetSubscription() string

+ func (x *AcknowledgeRequest) ProtoReflect() protoreflect.Message

+ func (x *AcknowledgeRequest) Reset()

+ func (x *AcknowledgeRequest) String() string

+ type BigQueryConfig struct

+ DropUnknownFields bool

+ State BigQueryConfig_State

+ Table string

+ UseTopicSchema bool

+ WriteMetadata bool

+ func (*BigQueryConfig) Descriptor() ([]byte, []int)

+ func (*BigQueryConfig) ProtoMessage()

+ func (x *BigQueryConfig) GetDropUnknownFields() bool

+ func (x *BigQueryConfig) GetState() BigQueryConfig_State

+ func (x *BigQueryConfig) GetTable() string

+ func (x *BigQueryConfig) GetUseTopicSchema() bool

+ func (x *BigQueryConfig) GetWriteMetadata() bool

+ func (x *BigQueryConfig) ProtoReflect() protoreflect.Message

+ func (x *BigQueryConfig) Reset()

+ func (x *BigQueryConfig) String() string

+ type BigQueryConfig_State int32

+ const BigQueryConfig_ACTIVE

+ const BigQueryConfig_NOT_FOUND

+ const BigQueryConfig_PERMISSION_DENIED

+ const BigQueryConfig_SCHEMA_MISMATCH

+ const BigQueryConfig_STATE_UNSPECIFIED

+ func (BigQueryConfig_State) Descriptor() protoreflect.EnumDescriptor

+ func (BigQueryConfig_State) EnumDescriptor() ([]byte, []int)

+ func (BigQueryConfig_State) Type() protoreflect.EnumType

+ func (x BigQueryConfig_State) Enum() *BigQueryConfig_State

+ func (x BigQueryConfig_State) Number() protoreflect.EnumNumber

+ func (x BigQueryConfig_State) String() string

+ type CreateSchemaRequest struct

+ Parent string

+ Schema *Schema

+ SchemaId string

+ func (*CreateSchemaRequest) Descriptor() ([]byte, []int)

+ func (*CreateSchemaRequest) ProtoMessage()

+ func (x *CreateSchemaRequest) GetParent() string

+ func (x *CreateSchemaRequest) GetSchema() *Schema

+ func (x *CreateSchemaRequest) GetSchemaId() string

+ func (x *CreateSchemaRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateSchemaRequest) Reset()

+ func (x *CreateSchemaRequest) String() string

+ type CreateSnapshotRequest struct

+ Labels map[string]string

+ Name string

+ Subscription string

+ func (*CreateSnapshotRequest) Descriptor() ([]byte, []int)

+ func (*CreateSnapshotRequest) ProtoMessage()

+ func (x *CreateSnapshotRequest) GetLabels() map[string]string

+ func (x *CreateSnapshotRequest) GetName() string

+ func (x *CreateSnapshotRequest) GetSubscription() string

+ func (x *CreateSnapshotRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateSnapshotRequest) Reset()

+ func (x *CreateSnapshotRequest) String() string

+ type DeadLetterPolicy struct

+ DeadLetterTopic string

+ MaxDeliveryAttempts int32

+ func (*DeadLetterPolicy) Descriptor() ([]byte, []int)

+ func (*DeadLetterPolicy) ProtoMessage()

+ func (x *DeadLetterPolicy) GetDeadLetterTopic() string

+ func (x *DeadLetterPolicy) GetMaxDeliveryAttempts() int32

+ func (x *DeadLetterPolicy) ProtoReflect() protoreflect.Message

+ func (x *DeadLetterPolicy) Reset()

+ func (x *DeadLetterPolicy) String() string

+ type DeleteSchemaRequest struct

+ Name string

+ func (*DeleteSchemaRequest) Descriptor() ([]byte, []int)

+ func (*DeleteSchemaRequest) ProtoMessage()

+ func (x *DeleteSchemaRequest) GetName() string

+ func (x *DeleteSchemaRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteSchemaRequest) Reset()

+ func (x *DeleteSchemaRequest) String() string

+ type DeleteSnapshotRequest struct

+ Snapshot string

+ func (*DeleteSnapshotRequest) Descriptor() ([]byte, []int)

+ func (*DeleteSnapshotRequest) ProtoMessage()

+ func (x *DeleteSnapshotRequest) GetSnapshot() string

+ func (x *DeleteSnapshotRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteSnapshotRequest) Reset()

+ func (x *DeleteSnapshotRequest) String() string

+ type DeleteSubscriptionRequest struct

+ Subscription string

+ func (*DeleteSubscriptionRequest) Descriptor() ([]byte, []int)

+ func (*DeleteSubscriptionRequest) ProtoMessage()

+ func (x *DeleteSubscriptionRequest) GetSubscription() string

+ func (x *DeleteSubscriptionRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteSubscriptionRequest) Reset()

+ func (x *DeleteSubscriptionRequest) String() string

+ type DeleteTopicRequest struct

+ Topic string

+ func (*DeleteTopicRequest) Descriptor() ([]byte, []int)

+ func (*DeleteTopicRequest) ProtoMessage()

+ func (x *DeleteTopicRequest) GetTopic() string

+ func (x *DeleteTopicRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteTopicRequest) Reset()

+ func (x *DeleteTopicRequest) String() string

+ type DetachSubscriptionRequest struct

+ Subscription string

+ func (*DetachSubscriptionRequest) Descriptor() ([]byte, []int)

+ func (*DetachSubscriptionRequest) ProtoMessage()

+ func (x *DetachSubscriptionRequest) GetSubscription() string

+ func (x *DetachSubscriptionRequest) ProtoReflect() protoreflect.Message

+ func (x *DetachSubscriptionRequest) Reset()

+ func (x *DetachSubscriptionRequest) String() string

+ type DetachSubscriptionResponse struct

+ func (*DetachSubscriptionResponse) Descriptor() ([]byte, []int)

+ func (*DetachSubscriptionResponse) ProtoMessage()

+ func (x *DetachSubscriptionResponse) ProtoReflect() protoreflect.Message

+ func (x *DetachSubscriptionResponse) Reset()

+ func (x *DetachSubscriptionResponse) String() string

+ type Encoding int32

+ const Encoding_BINARY

+ const Encoding_ENCODING_UNSPECIFIED

+ const Encoding_JSON

+ func (Encoding) Descriptor() protoreflect.EnumDescriptor

+ func (Encoding) EnumDescriptor() ([]byte, []int)

+ func (Encoding) Type() protoreflect.EnumType

+ func (x Encoding) Enum() *Encoding

+ func (x Encoding) Number() protoreflect.EnumNumber

+ func (x Encoding) String() string

+ type ExpirationPolicy struct

+ Ttl *durationpb.Duration

+ func (*ExpirationPolicy) Descriptor() ([]byte, []int)

+ func (*ExpirationPolicy) ProtoMessage()

+ func (x *ExpirationPolicy) GetTtl() *durationpb.Duration

+ func (x *ExpirationPolicy) ProtoReflect() protoreflect.Message

+ func (x *ExpirationPolicy) Reset()

+ func (x *ExpirationPolicy) String() string

+ type GetSchemaRequest struct

+ Name string

+ View SchemaView

+ func (*GetSchemaRequest) Descriptor() ([]byte, []int)

+ func (*GetSchemaRequest) ProtoMessage()

+ func (x *GetSchemaRequest) GetName() string

+ func (x *GetSchemaRequest) GetView() SchemaView

+ func (x *GetSchemaRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSchemaRequest) Reset()

+ func (x *GetSchemaRequest) String() string

+ type GetSnapshotRequest struct

+ Snapshot string

+ func (*GetSnapshotRequest) Descriptor() ([]byte, []int)

+ func (*GetSnapshotRequest) ProtoMessage()

+ func (x *GetSnapshotRequest) GetSnapshot() string

+ func (x *GetSnapshotRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSnapshotRequest) Reset()

+ func (x *GetSnapshotRequest) String() string

+ type GetSubscriptionRequest struct

+ Subscription string

+ func (*GetSubscriptionRequest) Descriptor() ([]byte, []int)

+ func (*GetSubscriptionRequest) ProtoMessage()

+ func (x *GetSubscriptionRequest) GetSubscription() string

+ func (x *GetSubscriptionRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSubscriptionRequest) Reset()

+ func (x *GetSubscriptionRequest) String() string

+ type GetTopicRequest struct

+ Topic string

+ func (*GetTopicRequest) Descriptor() ([]byte, []int)

+ func (*GetTopicRequest) ProtoMessage()

+ func (x *GetTopicRequest) GetTopic() string

+ func (x *GetTopicRequest) ProtoReflect() protoreflect.Message

+ func (x *GetTopicRequest) Reset()

+ func (x *GetTopicRequest) String() string

+ type ListSchemasRequest struct

+ PageSize int32

+ PageToken string

+ Parent string

+ View SchemaView

+ func (*ListSchemasRequest) Descriptor() ([]byte, []int)

+ func (*ListSchemasRequest) ProtoMessage()

+ func (x *ListSchemasRequest) GetPageSize() int32

+ func (x *ListSchemasRequest) GetPageToken() string

+ func (x *ListSchemasRequest) GetParent() string

+ func (x *ListSchemasRequest) GetView() SchemaView

+ func (x *ListSchemasRequest) ProtoReflect() protoreflect.Message

+ func (x *ListSchemasRequest) Reset()

+ func (x *ListSchemasRequest) String() string

+ type ListSchemasResponse struct

+ NextPageToken string

+ Schemas []*Schema

+ func (*ListSchemasResponse) Descriptor() ([]byte, []int)

+ func (*ListSchemasResponse) ProtoMessage()

+ func (x *ListSchemasResponse) GetNextPageToken() string

+ func (x *ListSchemasResponse) GetSchemas() []*Schema

+ func (x *ListSchemasResponse) ProtoReflect() protoreflect.Message

+ func (x *ListSchemasResponse) Reset()

+ func (x *ListSchemasResponse) String() string

+ type ListSnapshotsRequest struct

+ PageSize int32

+ PageToken string

+ Project string

+ func (*ListSnapshotsRequest) Descriptor() ([]byte, []int)

+ func (*ListSnapshotsRequest) ProtoMessage()

+ func (x *ListSnapshotsRequest) GetPageSize() int32

+ func (x *ListSnapshotsRequest) GetPageToken() string

+ func (x *ListSnapshotsRequest) GetProject() string

+ func (x *ListSnapshotsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListSnapshotsRequest) Reset()

+ func (x *ListSnapshotsRequest) String() string

+ type ListSnapshotsResponse struct

+ NextPageToken string

+ Snapshots []*Snapshot

+ func (*ListSnapshotsResponse) Descriptor() ([]byte, []int)

+ func (*ListSnapshotsResponse) ProtoMessage()

+ func (x *ListSnapshotsResponse) GetNextPageToken() string

+ func (x *ListSnapshotsResponse) GetSnapshots() []*Snapshot

+ func (x *ListSnapshotsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListSnapshotsResponse) Reset()

+ func (x *ListSnapshotsResponse) String() string

+ type ListSubscriptionsRequest struct

+ PageSize int32

+ PageToken string

+ Project string

+ func (*ListSubscriptionsRequest) Descriptor() ([]byte, []int)

+ func (*ListSubscriptionsRequest) ProtoMessage()

+ func (x *ListSubscriptionsRequest) GetPageSize() int32

+ func (x *ListSubscriptionsRequest) GetPageToken() string

+ func (x *ListSubscriptionsRequest) GetProject() string

+ func (x *ListSubscriptionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListSubscriptionsRequest) Reset()

+ func (x *ListSubscriptionsRequest) String() string

+ type ListSubscriptionsResponse struct

+ NextPageToken string

+ Subscriptions []*Subscription

+ func (*ListSubscriptionsResponse) Descriptor() ([]byte, []int)

+ func (*ListSubscriptionsResponse) ProtoMessage()

+ func (x *ListSubscriptionsResponse) GetNextPageToken() string

+ func (x *ListSubscriptionsResponse) GetSubscriptions() []*Subscription

+ func (x *ListSubscriptionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListSubscriptionsResponse) Reset()

+ func (x *ListSubscriptionsResponse) String() string

+ type ListTopicSnapshotsRequest struct

+ PageSize int32

+ PageToken string

+ Topic string

+ func (*ListTopicSnapshotsRequest) Descriptor() ([]byte, []int)

+ func (*ListTopicSnapshotsRequest) ProtoMessage()

+ func (x *ListTopicSnapshotsRequest) GetPageSize() int32

+ func (x *ListTopicSnapshotsRequest) GetPageToken() string

+ func (x *ListTopicSnapshotsRequest) GetTopic() string

+ func (x *ListTopicSnapshotsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListTopicSnapshotsRequest) Reset()

+ func (x *ListTopicSnapshotsRequest) String() string

+ type ListTopicSnapshotsResponse struct

+ NextPageToken string

+ Snapshots []string

+ func (*ListTopicSnapshotsResponse) Descriptor() ([]byte, []int)

+ func (*ListTopicSnapshotsResponse) ProtoMessage()

+ func (x *ListTopicSnapshotsResponse) GetNextPageToken() string

+ func (x *ListTopicSnapshotsResponse) GetSnapshots() []string

+ func (x *ListTopicSnapshotsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListTopicSnapshotsResponse) Reset()

+ func (x *ListTopicSnapshotsResponse) String() string

+ type ListTopicSubscriptionsRequest struct

+ PageSize int32

+ PageToken string

+ Topic string

+ func (*ListTopicSubscriptionsRequest) Descriptor() ([]byte, []int)

+ func (*ListTopicSubscriptionsRequest) ProtoMessage()

+ func (x *ListTopicSubscriptionsRequest) GetPageSize() int32

+ func (x *ListTopicSubscriptionsRequest) GetPageToken() string

+ func (x *ListTopicSubscriptionsRequest) GetTopic() string

+ func (x *ListTopicSubscriptionsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListTopicSubscriptionsRequest) Reset()

+ func (x *ListTopicSubscriptionsRequest) String() string

+ type ListTopicSubscriptionsResponse struct

+ NextPageToken string

+ Subscriptions []string

+ func (*ListTopicSubscriptionsResponse) Descriptor() ([]byte, []int)

+ func (*ListTopicSubscriptionsResponse) ProtoMessage()

+ func (x *ListTopicSubscriptionsResponse) GetNextPageToken() string

+ func (x *ListTopicSubscriptionsResponse) GetSubscriptions() []string

+ func (x *ListTopicSubscriptionsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListTopicSubscriptionsResponse) Reset()

+ func (x *ListTopicSubscriptionsResponse) String() string

+ type ListTopicsRequest struct

+ PageSize int32

+ PageToken string

+ Project string

+ func (*ListTopicsRequest) Descriptor() ([]byte, []int)

+ func (*ListTopicsRequest) ProtoMessage()

+ func (x *ListTopicsRequest) GetPageSize() int32

+ func (x *ListTopicsRequest) GetPageToken() string

+ func (x *ListTopicsRequest) GetProject() string

+ func (x *ListTopicsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListTopicsRequest) Reset()

+ func (x *ListTopicsRequest) String() string

+ type ListTopicsResponse struct

+ NextPageToken string

+ Topics []*Topic

+ func (*ListTopicsResponse) Descriptor() ([]byte, []int)

+ func (*ListTopicsResponse) ProtoMessage()

+ func (x *ListTopicsResponse) GetNextPageToken() string

+ func (x *ListTopicsResponse) GetTopics() []*Topic

+ func (x *ListTopicsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListTopicsResponse) Reset()

+ func (x *ListTopicsResponse) String() string

+ type MessageStoragePolicy struct

+ AllowedPersistenceRegions []string

+ func (*MessageStoragePolicy) Descriptor() ([]byte, []int)

+ func (*MessageStoragePolicy) ProtoMessage()

+ func (x *MessageStoragePolicy) GetAllowedPersistenceRegions() []string

+ func (x *MessageStoragePolicy) ProtoReflect() protoreflect.Message

+ func (x *MessageStoragePolicy) Reset()

+ func (x *MessageStoragePolicy) String() string

+ type ModifyAckDeadlineRequest struct

+ AckDeadlineSeconds int32

+ AckIds []string

+ Subscription string

+ func (*ModifyAckDeadlineRequest) Descriptor() ([]byte, []int)

+ func (*ModifyAckDeadlineRequest) ProtoMessage()

+ func (x *ModifyAckDeadlineRequest) GetAckDeadlineSeconds() int32

+ func (x *ModifyAckDeadlineRequest) GetAckIds() []string

+ func (x *ModifyAckDeadlineRequest) GetSubscription() string

+ func (x *ModifyAckDeadlineRequest) ProtoReflect() protoreflect.Message

+ func (x *ModifyAckDeadlineRequest) Reset()

+ func (x *ModifyAckDeadlineRequest) String() string

+ type ModifyPushConfigRequest struct

+ PushConfig *PushConfig

+ Subscription string

+ func (*ModifyPushConfigRequest) Descriptor() ([]byte, []int)

+ func (*ModifyPushConfigRequest) ProtoMessage()

+ func (x *ModifyPushConfigRequest) GetPushConfig() *PushConfig

+ func (x *ModifyPushConfigRequest) GetSubscription() string

+ func (x *ModifyPushConfigRequest) ProtoReflect() protoreflect.Message

+ func (x *ModifyPushConfigRequest) Reset()

+ func (x *ModifyPushConfigRequest) String() string

+ type PublishRequest struct

+ Messages []*PubsubMessage

+ Topic string

+ func (*PublishRequest) Descriptor() ([]byte, []int)

+ func (*PublishRequest) ProtoMessage()

+ func (x *PublishRequest) GetMessages() []*PubsubMessage

+ func (x *PublishRequest) GetTopic() string

+ func (x *PublishRequest) ProtoReflect() protoreflect.Message

+ func (x *PublishRequest) Reset()

+ func (x *PublishRequest) String() string

+ type PublishResponse struct

+ MessageIds []string

+ func (*PublishResponse) Descriptor() ([]byte, []int)

+ func (*PublishResponse) ProtoMessage()

+ func (x *PublishResponse) GetMessageIds() []string

+ func (x *PublishResponse) ProtoReflect() protoreflect.Message

+ func (x *PublishResponse) Reset()

+ func (x *PublishResponse) String() string

+ type PublisherClient interface

+ CreateTopic func(ctx context.Context, in *Topic, opts ...grpc.CallOption) (*Topic, error)

+ DeleteTopic func(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DetachSubscription func(ctx context.Context, in *DetachSubscriptionRequest, opts ...grpc.CallOption) (*DetachSubscriptionResponse, error)

+ GetTopic func(ctx context.Context, in *GetTopicRequest, opts ...grpc.CallOption) (*Topic, error)

+ ListTopicSnapshots func(ctx context.Context, in *ListTopicSnapshotsRequest, opts ...grpc.CallOption) (*ListTopicSnapshotsResponse, error)

+ ListTopicSubscriptions func(ctx context.Context, in *ListTopicSubscriptionsRequest, ...) (*ListTopicSubscriptionsResponse, error)

+ ListTopics func(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error)

+ Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)

+ UpdateTopic func(ctx context.Context, in *UpdateTopicRequest, opts ...grpc.CallOption) (*Topic, error)

+ func NewPublisherClient(cc grpc.ClientConnInterface) PublisherClient

+ type PublisherServer interface

+ CreateTopic func(context.Context, *Topic) (*Topic, error)

+ DeleteTopic func(context.Context, *DeleteTopicRequest) (*emptypb.Empty, error)

+ DetachSubscription func(context.Context, *DetachSubscriptionRequest) (*DetachSubscriptionResponse, error)

+ GetTopic func(context.Context, *GetTopicRequest) (*Topic, error)

+ ListTopicSnapshots func(context.Context, *ListTopicSnapshotsRequest) (*ListTopicSnapshotsResponse, error)

+ ListTopicSubscriptions func(context.Context, *ListTopicSubscriptionsRequest) (*ListTopicSubscriptionsResponse, error)

+ ListTopics func(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)

+ Publish func(context.Context, *PublishRequest) (*PublishResponse, error)

+ UpdateTopic func(context.Context, *UpdateTopicRequest) (*Topic, error)

+ type PubsubMessage struct

+ Attributes map[string]string

+ Data []byte

+ MessageId string

+ OrderingKey string

+ PublishTime *timestamppb.Timestamp

+ func (*PubsubMessage) Descriptor() ([]byte, []int)

+ func (*PubsubMessage) ProtoMessage()

+ func (x *PubsubMessage) GetAttributes() map[string]string

+ func (x *PubsubMessage) GetData() []byte

+ func (x *PubsubMessage) GetMessageId() string

+ func (x *PubsubMessage) GetOrderingKey() string

+ func (x *PubsubMessage) GetPublishTime() *timestamppb.Timestamp

+ func (x *PubsubMessage) ProtoReflect() protoreflect.Message

+ func (x *PubsubMessage) Reset()

+ func (x *PubsubMessage) String() string

+ type PullRequest struct

+ MaxMessages int32

+ ReturnImmediately bool

+ Subscription string

+ func (*PullRequest) Descriptor() ([]byte, []int)

+ func (*PullRequest) ProtoMessage()

+ func (x *PullRequest) GetMaxMessages() int32

+ func (x *PullRequest) GetReturnImmediately() bool

+ func (x *PullRequest) GetSubscription() string

+ func (x *PullRequest) ProtoReflect() protoreflect.Message

+ func (x *PullRequest) Reset()

+ func (x *PullRequest) String() string

+ type PullResponse struct

+ ReceivedMessages []*ReceivedMessage

+ func (*PullResponse) Descriptor() ([]byte, []int)

+ func (*PullResponse) ProtoMessage()

+ func (x *PullResponse) GetReceivedMessages() []*ReceivedMessage

+ func (x *PullResponse) ProtoReflect() protoreflect.Message

+ func (x *PullResponse) Reset()

+ func (x *PullResponse) String() string

+ type PushConfig struct

+ Attributes map[string]string

+ AuthenticationMethod isPushConfig_AuthenticationMethod

+ PushEndpoint string

+ func (*PushConfig) Descriptor() ([]byte, []int)

+ func (*PushConfig) ProtoMessage()

+ func (m *PushConfig) GetAuthenticationMethod() isPushConfig_AuthenticationMethod

+ func (x *PushConfig) GetAttributes() map[string]string

+ func (x *PushConfig) GetOidcToken() *PushConfig_OidcToken

+ func (x *PushConfig) GetPushEndpoint() string

+ func (x *PushConfig) ProtoReflect() protoreflect.Message

+ func (x *PushConfig) Reset()

+ func (x *PushConfig) String() string

+ type PushConfig_OidcToken struct

+ Audience string

+ ServiceAccountEmail string

+ func (*PushConfig_OidcToken) Descriptor() ([]byte, []int)

+ func (*PushConfig_OidcToken) ProtoMessage()

+ func (x *PushConfig_OidcToken) GetAudience() string

+ func (x *PushConfig_OidcToken) GetServiceAccountEmail() string

+ func (x *PushConfig_OidcToken) ProtoReflect() protoreflect.Message

+ func (x *PushConfig_OidcToken) Reset()

+ func (x *PushConfig_OidcToken) String() string

+ type PushConfig_OidcToken_ struct

+ OidcToken *PushConfig_OidcToken

+ type ReceivedMessage struct

+ AckId string

+ DeliveryAttempt int32

+ Message *PubsubMessage

+ func (*ReceivedMessage) Descriptor() ([]byte, []int)

+ func (*ReceivedMessage) ProtoMessage()

+ func (x *ReceivedMessage) GetAckId() string

+ func (x *ReceivedMessage) GetDeliveryAttempt() int32

+ func (x *ReceivedMessage) GetMessage() *PubsubMessage

+ func (x *ReceivedMessage) ProtoReflect() protoreflect.Message

+ func (x *ReceivedMessage) Reset()

+ func (x *ReceivedMessage) String() string

+ type RetryPolicy struct

+ MaximumBackoff *durationpb.Duration

+ MinimumBackoff *durationpb.Duration

+ func (*RetryPolicy) Descriptor() ([]byte, []int)

+ func (*RetryPolicy) ProtoMessage()

+ func (x *RetryPolicy) GetMaximumBackoff() *durationpb.Duration

+ func (x *RetryPolicy) GetMinimumBackoff() *durationpb.Duration

+ func (x *RetryPolicy) ProtoReflect() protoreflect.Message

+ func (x *RetryPolicy) Reset()

+ func (x *RetryPolicy) String() string

+ type Schema struct

+ Definition string

+ Name string

+ Type Schema_Type

+ func (*Schema) Descriptor() ([]byte, []int)

+ func (*Schema) ProtoMessage()

+ func (x *Schema) GetDefinition() string

+ func (x *Schema) GetName() string

+ func (x *Schema) GetType() Schema_Type

+ func (x *Schema) ProtoReflect() protoreflect.Message

+ func (x *Schema) Reset()

+ func (x *Schema) String() string

+ type SchemaServiceClient interface

+ CreateSchema func(ctx context.Context, in *CreateSchemaRequest, opts ...grpc.CallOption) (*Schema, error)

+ DeleteSchema func(ctx context.Context, in *DeleteSchemaRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetSchema func(ctx context.Context, in *GetSchemaRequest, opts ...grpc.CallOption) (*Schema, error)

+ ListSchemas func(ctx context.Context, in *ListSchemasRequest, opts ...grpc.CallOption) (*ListSchemasResponse, error)

+ ValidateMessage func(ctx context.Context, in *ValidateMessageRequest, opts ...grpc.CallOption) (*ValidateMessageResponse, error)

+ ValidateSchema func(ctx context.Context, in *ValidateSchemaRequest, opts ...grpc.CallOption) (*ValidateSchemaResponse, error)

+ func NewSchemaServiceClient(cc grpc.ClientConnInterface) SchemaServiceClient

+ type SchemaServiceServer interface

+ CreateSchema func(context.Context, *CreateSchemaRequest) (*Schema, error)

+ DeleteSchema func(context.Context, *DeleteSchemaRequest) (*emptypb.Empty, error)

+ GetSchema func(context.Context, *GetSchemaRequest) (*Schema, error)

+ ListSchemas func(context.Context, *ListSchemasRequest) (*ListSchemasResponse, error)

+ ValidateMessage func(context.Context, *ValidateMessageRequest) (*ValidateMessageResponse, error)

+ ValidateSchema func(context.Context, *ValidateSchemaRequest) (*ValidateSchemaResponse, error)

+ type SchemaSettings struct

+ Encoding Encoding

+ Schema string

+ func (*SchemaSettings) Descriptor() ([]byte, []int)

+ func (*SchemaSettings) ProtoMessage()

+ func (x *SchemaSettings) GetEncoding() Encoding

+ func (x *SchemaSettings) GetSchema() string

+ func (x *SchemaSettings) ProtoReflect() protoreflect.Message

+ func (x *SchemaSettings) Reset()

+ func (x *SchemaSettings) String() string

+ type SchemaView int32

+ const SchemaView_BASIC

+ const SchemaView_FULL

+ const SchemaView_SCHEMA_VIEW_UNSPECIFIED

+ func (SchemaView) Descriptor() protoreflect.EnumDescriptor

+ func (SchemaView) EnumDescriptor() ([]byte, []int)

+ func (SchemaView) Type() protoreflect.EnumType

+ func (x SchemaView) Enum() *SchemaView

+ func (x SchemaView) Number() protoreflect.EnumNumber

+ func (x SchemaView) String() string

+ type Schema_Type int32

+ const Schema_AVRO

+ const Schema_PROTOCOL_BUFFER

+ const Schema_TYPE_UNSPECIFIED

+ func (Schema_Type) Descriptor() protoreflect.EnumDescriptor

+ func (Schema_Type) EnumDescriptor() ([]byte, []int)

+ func (Schema_Type) Type() protoreflect.EnumType

+ func (x Schema_Type) Enum() *Schema_Type

+ func (x Schema_Type) Number() protoreflect.EnumNumber

+ func (x Schema_Type) String() string

+ type SeekRequest struct

+ Subscription string

+ Target isSeekRequest_Target

+ func (*SeekRequest) Descriptor() ([]byte, []int)

+ func (*SeekRequest) ProtoMessage()

+ func (m *SeekRequest) GetTarget() isSeekRequest_Target

+ func (x *SeekRequest) GetSnapshot() string

+ func (x *SeekRequest) GetSubscription() string

+ func (x *SeekRequest) GetTime() *timestamppb.Timestamp

+ func (x *SeekRequest) ProtoReflect() protoreflect.Message

+ func (x *SeekRequest) Reset()

+ func (x *SeekRequest) String() string

+ type SeekRequest_Snapshot struct

+ Snapshot string

+ type SeekRequest_Time struct

+ Time *timestamppb.Timestamp

+ type SeekResponse struct

+ func (*SeekResponse) Descriptor() ([]byte, []int)

+ func (*SeekResponse) ProtoMessage()

+ func (x *SeekResponse) ProtoReflect() protoreflect.Message

+ func (x *SeekResponse) Reset()

+ func (x *SeekResponse) String() string

+ type Snapshot struct

+ ExpireTime *timestamppb.Timestamp

+ Labels map[string]string

+ Name string

+ Topic string

+ func (*Snapshot) Descriptor() ([]byte, []int)

+ func (*Snapshot) ProtoMessage()

+ func (x *Snapshot) GetExpireTime() *timestamppb.Timestamp

+ func (x *Snapshot) GetLabels() map[string]string

+ func (x *Snapshot) GetName() string

+ func (x *Snapshot) GetTopic() string

+ func (x *Snapshot) ProtoReflect() protoreflect.Message

+ func (x *Snapshot) Reset()

+ func (x *Snapshot) String() string

+ type StreamingPullRequest struct

+ AckIds []string

+ ClientId string

+ MaxOutstandingBytes int64

+ MaxOutstandingMessages int64

+ ModifyDeadlineAckIds []string

+ ModifyDeadlineSeconds []int32

+ StreamAckDeadlineSeconds int32

+ Subscription string

+ func (*StreamingPullRequest) Descriptor() ([]byte, []int)

+ func (*StreamingPullRequest) ProtoMessage()

+ func (x *StreamingPullRequest) GetAckIds() []string

+ func (x *StreamingPullRequest) GetClientId() string

+ func (x *StreamingPullRequest) GetMaxOutstandingBytes() int64

+ func (x *StreamingPullRequest) GetMaxOutstandingMessages() int64

+ func (x *StreamingPullRequest) GetModifyDeadlineAckIds() []string

+ func (x *StreamingPullRequest) GetModifyDeadlineSeconds() []int32

+ func (x *StreamingPullRequest) GetStreamAckDeadlineSeconds() int32

+ func (x *StreamingPullRequest) GetSubscription() string

+ func (x *StreamingPullRequest) ProtoReflect() protoreflect.Message

+ func (x *StreamingPullRequest) Reset()

+ func (x *StreamingPullRequest) String() string

+ type StreamingPullResponse struct

+ AcknowledgeConfirmation *StreamingPullResponse_AcknowledgeConfirmation

+ ModifyAckDeadlineConfirmation *StreamingPullResponse_ModifyAckDeadlineConfirmation

+ ReceivedMessages []*ReceivedMessage

+ SubscriptionProperties *StreamingPullResponse_SubscriptionProperties

+ func (*StreamingPullResponse) Descriptor() ([]byte, []int)

+ func (*StreamingPullResponse) ProtoMessage()

+ func (x *StreamingPullResponse) GetAcknowledgeConfirmation() *StreamingPullResponse_AcknowledgeConfirmation

+ func (x *StreamingPullResponse) GetModifyAckDeadlineConfirmation() *StreamingPullResponse_ModifyAckDeadlineConfirmation

+ func (x *StreamingPullResponse) GetReceivedMessages() []*ReceivedMessage

+ func (x *StreamingPullResponse) GetSubscriptionProperties() *StreamingPullResponse_SubscriptionProperties

+ func (x *StreamingPullResponse) ProtoReflect() protoreflect.Message

+ func (x *StreamingPullResponse) Reset()

+ func (x *StreamingPullResponse) String() string

+ type StreamingPullResponse_AcknowledgeConfirmation struct

+ AckIds []string

+ InvalidAckIds []string

+ UnorderedAckIds []string

+ func (*StreamingPullResponse_AcknowledgeConfirmation) Descriptor() ([]byte, []int)

+ func (*StreamingPullResponse_AcknowledgeConfirmation) ProtoMessage()

+ func (x *StreamingPullResponse_AcknowledgeConfirmation) GetAckIds() []string

+ func (x *StreamingPullResponse_AcknowledgeConfirmation) GetInvalidAckIds() []string

+ func (x *StreamingPullResponse_AcknowledgeConfirmation) GetUnorderedAckIds() []string

+ func (x *StreamingPullResponse_AcknowledgeConfirmation) ProtoReflect() protoreflect.Message

+ func (x *StreamingPullResponse_AcknowledgeConfirmation) Reset()

+ func (x *StreamingPullResponse_AcknowledgeConfirmation) String() string

+ type StreamingPullResponse_ModifyAckDeadlineConfirmation struct

+ AckIds []string

+ InvalidAckIds []string

+ func (*StreamingPullResponse_ModifyAckDeadlineConfirmation) Descriptor() ([]byte, []int)

+ func (*StreamingPullResponse_ModifyAckDeadlineConfirmation) ProtoMessage()

+ func (x *StreamingPullResponse_ModifyAckDeadlineConfirmation) GetAckIds() []string

+ func (x *StreamingPullResponse_ModifyAckDeadlineConfirmation) GetInvalidAckIds() []string

+ func (x *StreamingPullResponse_ModifyAckDeadlineConfirmation) ProtoReflect() protoreflect.Message

+ func (x *StreamingPullResponse_ModifyAckDeadlineConfirmation) Reset()

+ func (x *StreamingPullResponse_ModifyAckDeadlineConfirmation) String() string

+ type StreamingPullResponse_SubscriptionProperties struct

+ ExactlyOnceDeliveryEnabled bool

+ MessageOrderingEnabled bool

+ func (*StreamingPullResponse_SubscriptionProperties) Descriptor() ([]byte, []int)

+ func (*StreamingPullResponse_SubscriptionProperties) ProtoMessage()

+ func (x *StreamingPullResponse_SubscriptionProperties) GetExactlyOnceDeliveryEnabled() bool

+ func (x *StreamingPullResponse_SubscriptionProperties) GetMessageOrderingEnabled() bool

+ func (x *StreamingPullResponse_SubscriptionProperties) ProtoReflect() protoreflect.Message

+ func (x *StreamingPullResponse_SubscriptionProperties) Reset()

+ func (x *StreamingPullResponse_SubscriptionProperties) String() string

+ type SubscriberClient interface

+ Acknowledge func(ctx context.Context, in *AcknowledgeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ CreateSnapshot func(ctx context.Context, in *CreateSnapshotRequest, opts ...grpc.CallOption) (*Snapshot, error)

+ CreateSubscription func(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (*Subscription, error)

+ DeleteSnapshot func(ctx context.Context, in *DeleteSnapshotRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DeleteSubscription func(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetSnapshot func(ctx context.Context, in *GetSnapshotRequest, opts ...grpc.CallOption) (*Snapshot, error)

+ GetSubscription func(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error)

+ ListSnapshots func(ctx context.Context, in *ListSnapshotsRequest, opts ...grpc.CallOption) (*ListSnapshotsResponse, error)

+ ListSubscriptions func(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error)

+ ModifyAckDeadline func(ctx context.Context, in *ModifyAckDeadlineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ ModifyPushConfig func(ctx context.Context, in *ModifyPushConfigRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Pull func(ctx context.Context, in *PullRequest, opts ...grpc.CallOption) (*PullResponse, error)

+ Seek func(ctx context.Context, in *SeekRequest, opts ...grpc.CallOption) (*SeekResponse, error)

+ StreamingPull func(ctx context.Context, opts ...grpc.CallOption) (Subscriber_StreamingPullClient, error)

+ UpdateSnapshot func(ctx context.Context, in *UpdateSnapshotRequest, opts ...grpc.CallOption) (*Snapshot, error)

+ UpdateSubscription func(ctx context.Context, in *UpdateSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error)

+ func NewSubscriberClient(cc grpc.ClientConnInterface) SubscriberClient

+ type SubscriberServer interface

+ Acknowledge func(context.Context, *AcknowledgeRequest) (*emptypb.Empty, error)

+ CreateSnapshot func(context.Context, *CreateSnapshotRequest) (*Snapshot, error)

+ CreateSubscription func(context.Context, *Subscription) (*Subscription, error)

+ DeleteSnapshot func(context.Context, *DeleteSnapshotRequest) (*emptypb.Empty, error)

+ DeleteSubscription func(context.Context, *DeleteSubscriptionRequest) (*emptypb.Empty, error)

+ GetSnapshot func(context.Context, *GetSnapshotRequest) (*Snapshot, error)

+ GetSubscription func(context.Context, *GetSubscriptionRequest) (*Subscription, error)

+ ListSnapshots func(context.Context, *ListSnapshotsRequest) (*ListSnapshotsResponse, error)

+ ListSubscriptions func(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)

+ ModifyAckDeadline func(context.Context, *ModifyAckDeadlineRequest) (*emptypb.Empty, error)

+ ModifyPushConfig func(context.Context, *ModifyPushConfigRequest) (*emptypb.Empty, error)

+ Pull func(context.Context, *PullRequest) (*PullResponse, error)

+ Seek func(context.Context, *SeekRequest) (*SeekResponse, error)

+ StreamingPull func(Subscriber_StreamingPullServer) error

+ UpdateSnapshot func(context.Context, *UpdateSnapshotRequest) (*Snapshot, error)

+ UpdateSubscription func(context.Context, *UpdateSubscriptionRequest) (*Subscription, error)

+ type Subscriber_StreamingPullClient interface

+ Recv func() (*StreamingPullResponse, error)

+ Send func(*StreamingPullRequest) error

+ type Subscriber_StreamingPullServer interface

+ Recv func() (*StreamingPullRequest, error)

+ Send func(*StreamingPullResponse) error

+ type Subscription struct

+ AckDeadlineSeconds int32

+ BigqueryConfig *BigQueryConfig

+ DeadLetterPolicy *DeadLetterPolicy

+ Detached bool

+ EnableExactlyOnceDelivery bool

+ EnableMessageOrdering bool

+ ExpirationPolicy *ExpirationPolicy

+ Filter string

+ Labels map[string]string

+ MessageRetentionDuration *durationpb.Duration

+ Name string

+ PushConfig *PushConfig

+ RetainAckedMessages bool

+ RetryPolicy *RetryPolicy

+ State Subscription_State

+ Topic string

+ TopicMessageRetentionDuration *durationpb.Duration

+ func (*Subscription) Descriptor() ([]byte, []int)

+ func (*Subscription) ProtoMessage()

+ func (x *Subscription) GetAckDeadlineSeconds() int32

+ func (x *Subscription) GetBigqueryConfig() *BigQueryConfig

+ func (x *Subscription) GetDeadLetterPolicy() *DeadLetterPolicy

+ func (x *Subscription) GetDetached() bool

+ func (x *Subscription) GetEnableExactlyOnceDelivery() bool

+ func (x *Subscription) GetEnableMessageOrdering() bool

+ func (x *Subscription) GetExpirationPolicy() *ExpirationPolicy

+ func (x *Subscription) GetFilter() string

+ func (x *Subscription) GetLabels() map[string]string

+ func (x *Subscription) GetMessageRetentionDuration() *durationpb.Duration

+ func (x *Subscription) GetName() string

+ func (x *Subscription) GetPushConfig() *PushConfig

+ func (x *Subscription) GetRetainAckedMessages() bool

+ func (x *Subscription) GetRetryPolicy() *RetryPolicy

+ func (x *Subscription) GetState() Subscription_State

+ func (x *Subscription) GetTopic() string

+ func (x *Subscription) GetTopicMessageRetentionDuration() *durationpb.Duration

+ func (x *Subscription) ProtoReflect() protoreflect.Message

+ func (x *Subscription) Reset()

+ func (x *Subscription) String() string

+ type Subscription_State int32

+ const Subscription_ACTIVE

+ const Subscription_RESOURCE_ERROR

+ const Subscription_STATE_UNSPECIFIED

+ func (Subscription_State) Descriptor() protoreflect.EnumDescriptor

+ func (Subscription_State) EnumDescriptor() ([]byte, []int)

+ func (Subscription_State) Type() protoreflect.EnumType

+ func (x Subscription_State) Enum() *Subscription_State

+ func (x Subscription_State) Number() protoreflect.EnumNumber

+ func (x Subscription_State) String() string

+ type Topic struct

+ KmsKeyName string

+ Labels map[string]string

+ MessageRetentionDuration *durationpb.Duration

+ MessageStoragePolicy *MessageStoragePolicy

+ Name string

+ SatisfiesPzs bool

+ SchemaSettings *SchemaSettings

+ func (*Topic) Descriptor() ([]byte, []int)

+ func (*Topic) ProtoMessage()

+ func (x *Topic) GetKmsKeyName() string

+ func (x *Topic) GetLabels() map[string]string

+ func (x *Topic) GetMessageRetentionDuration() *durationpb.Duration

+ func (x *Topic) GetMessageStoragePolicy() *MessageStoragePolicy

+ func (x *Topic) GetName() string

+ func (x *Topic) GetSatisfiesPzs() bool

+ func (x *Topic) GetSchemaSettings() *SchemaSettings

+ func (x *Topic) ProtoReflect() protoreflect.Message

+ func (x *Topic) Reset()

+ func (x *Topic) String() string

+ type UnimplementedPublisherServer struct

+ func (*UnimplementedPublisherServer) CreateTopic(context.Context, *Topic) (*Topic, error)

+ func (*UnimplementedPublisherServer) DeleteTopic(context.Context, *DeleteTopicRequest) (*emptypb.Empty, error)

+ func (*UnimplementedPublisherServer) DetachSubscription(context.Context, *DetachSubscriptionRequest) (*DetachSubscriptionResponse, error)

+ func (*UnimplementedPublisherServer) GetTopic(context.Context, *GetTopicRequest) (*Topic, error)

+ func (*UnimplementedPublisherServer) ListTopicSnapshots(context.Context, *ListTopicSnapshotsRequest) (*ListTopicSnapshotsResponse, error)

+ func (*UnimplementedPublisherServer) ListTopicSubscriptions(context.Context, *ListTopicSubscriptionsRequest) (*ListTopicSubscriptionsResponse, error)

+ func (*UnimplementedPublisherServer) ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)

+ func (*UnimplementedPublisherServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)

+ func (*UnimplementedPublisherServer) UpdateTopic(context.Context, *UpdateTopicRequest) (*Topic, error)

+ type UnimplementedSchemaServiceServer struct

+ func (*UnimplementedSchemaServiceServer) CreateSchema(context.Context, *CreateSchemaRequest) (*Schema, error)

+ func (*UnimplementedSchemaServiceServer) DeleteSchema(context.Context, *DeleteSchemaRequest) (*emptypb.Empty, error)

+ func (*UnimplementedSchemaServiceServer) GetSchema(context.Context, *GetSchemaRequest) (*Schema, error)

+ func (*UnimplementedSchemaServiceServer) ListSchemas(context.Context, *ListSchemasRequest) (*ListSchemasResponse, error)

+ func (*UnimplementedSchemaServiceServer) ValidateMessage(context.Context, *ValidateMessageRequest) (*ValidateMessageResponse, error)

+ func (*UnimplementedSchemaServiceServer) ValidateSchema(context.Context, *ValidateSchemaRequest) (*ValidateSchemaResponse, error)

+ type UnimplementedSubscriberServer struct

+ func (*UnimplementedSubscriberServer) Acknowledge(context.Context, *AcknowledgeRequest) (*emptypb.Empty, error)

+ func (*UnimplementedSubscriberServer) CreateSnapshot(context.Context, *CreateSnapshotRequest) (*Snapshot, error)

+ func (*UnimplementedSubscriberServer) CreateSubscription(context.Context, *Subscription) (*Subscription, error)

+ func (*UnimplementedSubscriberServer) DeleteSnapshot(context.Context, *DeleteSnapshotRequest) (*emptypb.Empty, error)

+ func (*UnimplementedSubscriberServer) DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*emptypb.Empty, error)

+ func (*UnimplementedSubscriberServer) GetSnapshot(context.Context, *GetSnapshotRequest) (*Snapshot, error)

+ func (*UnimplementedSubscriberServer) GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error)

+ func (*UnimplementedSubscriberServer) ListSnapshots(context.Context, *ListSnapshotsRequest) (*ListSnapshotsResponse, error)

+ func (*UnimplementedSubscriberServer) ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)

+ func (*UnimplementedSubscriberServer) ModifyAckDeadline(context.Context, *ModifyAckDeadlineRequest) (*emptypb.Empty, error)

+ func (*UnimplementedSubscriberServer) ModifyPushConfig(context.Context, *ModifyPushConfigRequest) (*emptypb.Empty, error)

+ func (*UnimplementedSubscriberServer) Pull(context.Context, *PullRequest) (*PullResponse, error)

+ func (*UnimplementedSubscriberServer) Seek(context.Context, *SeekRequest) (*SeekResponse, error)

+ func (*UnimplementedSubscriberServer) StreamingPull(Subscriber_StreamingPullServer) error

+ func (*UnimplementedSubscriberServer) UpdateSnapshot(context.Context, *UpdateSnapshotRequest) (*Snapshot, error)

+ func (*UnimplementedSubscriberServer) UpdateSubscription(context.Context, *UpdateSubscriptionRequest) (*Subscription, error)

+ type UpdateSnapshotRequest struct

+ Snapshot *Snapshot

+ UpdateMask *fieldmaskpb.FieldMask

+ func (*UpdateSnapshotRequest) Descriptor() ([]byte, []int)

+ func (*UpdateSnapshotRequest) ProtoMessage()

+ func (x *UpdateSnapshotRequest) GetSnapshot() *Snapshot

+ func (x *UpdateSnapshotRequest) GetUpdateMask() *fieldmaskpb.FieldMask

+ func (x *UpdateSnapshotRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateSnapshotRequest) Reset()

+ func (x *UpdateSnapshotRequest) String() string

+ type UpdateSubscriptionRequest struct

+ Subscription *Subscription

+ UpdateMask *fieldmaskpb.FieldMask

+ func (*UpdateSubscriptionRequest) Descriptor() ([]byte, []int)

+ func (*UpdateSubscriptionRequest) ProtoMessage()

+ func (x *UpdateSubscriptionRequest) GetSubscription() *Subscription

+ func (x *UpdateSubscriptionRequest) GetUpdateMask() *fieldmaskpb.FieldMask

+ func (x *UpdateSubscriptionRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateSubscriptionRequest) Reset()

+ func (x *UpdateSubscriptionRequest) String() string

+ type UpdateTopicRequest struct

+ Topic *Topic

+ UpdateMask *fieldmaskpb.FieldMask

+ func (*UpdateTopicRequest) Descriptor() ([]byte, []int)

+ func (*UpdateTopicRequest) ProtoMessage()

+ func (x *UpdateTopicRequest) GetTopic() *Topic

+ func (x *UpdateTopicRequest) GetUpdateMask() *fieldmaskpb.FieldMask

+ func (x *UpdateTopicRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateTopicRequest) Reset()

+ func (x *UpdateTopicRequest) String() string

+ type ValidateMessageRequest struct

+ Encoding Encoding

+ Message []byte

+ Parent string

+ SchemaSpec isValidateMessageRequest_SchemaSpec

+ func (*ValidateMessageRequest) Descriptor() ([]byte, []int)

+ func (*ValidateMessageRequest) ProtoMessage()

+ func (m *ValidateMessageRequest) GetSchemaSpec() isValidateMessageRequest_SchemaSpec

+ func (x *ValidateMessageRequest) GetEncoding() Encoding

+ func (x *ValidateMessageRequest) GetMessage() []byte

+ func (x *ValidateMessageRequest) GetName() string

+ func (x *ValidateMessageRequest) GetParent() string

+ func (x *ValidateMessageRequest) GetSchema() *Schema

+ func (x *ValidateMessageRequest) ProtoReflect() protoreflect.Message

+ func (x *ValidateMessageRequest) Reset()

+ func (x *ValidateMessageRequest) String() string

+ type ValidateMessageRequest_Name struct

+ Name string

+ type ValidateMessageRequest_Schema struct

+ Schema *Schema

+ type ValidateMessageResponse struct

+ func (*ValidateMessageResponse) Descriptor() ([]byte, []int)

+ func (*ValidateMessageResponse) ProtoMessage()

+ func (x *ValidateMessageResponse) ProtoReflect() protoreflect.Message

+ func (x *ValidateMessageResponse) Reset()

+ func (x *ValidateMessageResponse) String() string

+ type ValidateSchemaRequest struct

+ Parent string

+ Schema *Schema

+ func (*ValidateSchemaRequest) Descriptor() ([]byte, []int)

+ func (*ValidateSchemaRequest) ProtoMessage()

+ func (x *ValidateSchemaRequest) GetParent() string

+ func (x *ValidateSchemaRequest) GetSchema() *Schema

+ func (x *ValidateSchemaRequest) ProtoReflect() protoreflect.Message

+ func (x *ValidateSchemaRequest) Reset()

+ func (x *ValidateSchemaRequest) String() string

+ type ValidateSchemaResponse struct

+ func (*ValidateSchemaResponse) Descriptor() ([]byte, []int)

+ func (*ValidateSchemaResponse) ProtoMessage()

+ func (x *ValidateSchemaResponse) ProtoReflect() protoreflect.Message

+ func (x *ValidateSchemaResponse) Reset()

+ func (x *ValidateSchemaResponse) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL