▽

Package pubsub

Constants

Deprecated: Please use consts in: cloud.google.com/go/pubsub/apiv1/pubsubpb

const (
    BigQueryConfig_ACTIVE              = src.BigQueryConfig_ACTIVE
    BigQueryConfig_NOT_FOUND           = src.BigQueryConfig_NOT_FOUND
    BigQueryConfig_PERMISSION_DENIED   = src.BigQueryConfig_PERMISSION_DENIED
    BigQueryConfig_SCHEMA_MISMATCH     = src.BigQueryConfig_SCHEMA_MISMATCH
    BigQueryConfig_STATE_UNSPECIFIED   = src.BigQueryConfig_STATE_UNSPECIFIED
    Encoding_BINARY                    = src.Encoding_BINARY
    Encoding_ENCODING_UNSPECIFIED      = src.Encoding_ENCODING_UNSPECIFIED
    Encoding_JSON                      = src.Encoding_JSON
    SchemaView_BASIC                   = src.SchemaView_BASIC
    SchemaView_FULL                    = src.SchemaView_FULL
    SchemaView_SCHEMA_VIEW_UNSPECIFIED = src.SchemaView_SCHEMA_VIEW_UNSPECIFIED
    Schema_AVRO                        = src.Schema_AVRO
    Schema_PROTOCOL_BUFFER             = src.Schema_PROTOCOL_BUFFER
    Schema_TYPE_UNSPECIFIED            = src.Schema_TYPE_UNSPECIFIED
    Subscription_ACTIVE                = src.Subscription_ACTIVE
    Subscription_RESOURCE_ERROR        = src.Subscription_RESOURCE_ERROR
    Subscription_STATE_UNSPECIFIED     = src.Subscription_STATE_UNSPECIFIED
)

Variables

Deprecated: Please use vars in: cloud.google.com/go/pubsub/apiv1/pubsubpb

var (
    BigQueryConfig_State_name          = src.BigQueryConfig_State_name
    BigQueryConfig_State_value         = src.BigQueryConfig_State_value
    Encoding_name                      = src.Encoding_name
    Encoding_value                     = src.Encoding_value
    File_google_pubsub_v1_pubsub_proto = src.File_google_pubsub_v1_pubsub_proto
    File_google_pubsub_v1_schema_proto = src.File_google_pubsub_v1_schema_proto
    SchemaView_name                    = src.SchemaView_name
    SchemaView_value                   = src.SchemaView_value
    Schema_Type_name                   = src.Schema_Type_name
    Schema_Type_value                  = src.Schema_Type_value
    Subscription_State_name            = src.Subscription_State_name
    Subscription_State_value           = src.Subscription_State_value
)

func RegisterPublisherServer ¶

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

Deprecated: Please use funcs in: cloud.google.com/go/pubsub/apiv1/pubsubpb

func RegisterSchemaServiceServer ¶

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

Deprecated: Please use funcs in: cloud.google.com/go/pubsub/apiv1/pubsubpb

func RegisterSubscriberServer ¶

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

Deprecated: Please use funcs in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type AcknowledgeRequest ¶

Request for the Acknowledge method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type AcknowledgeRequest = src.AcknowledgeRequest

type BigQueryConfig ¶

Configuration for a BigQuery subscription.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type BigQueryConfig = src.BigQueryConfig

type BigQueryConfig_State ¶

Possible states for a BigQuery subscription.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type BigQueryConfig_State = src.BigQueryConfig_State

type CreateSchemaRequest ¶

Request for the CreateSchema method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type CreateSchemaRequest = src.CreateSchemaRequest

type CreateSnapshotRequest ¶

Request for the `CreateSnapshot` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type CreateSnapshotRequest = src.CreateSnapshotRequest

type DeadLetterPolicy ¶

Dead lettering is done on a best effort basis. The same message might be dead lettered multiple times. If validation on any of the fields fails at subscription creation/updation, the create/update subscription request will fail.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type DeadLetterPolicy = src.DeadLetterPolicy

type DeleteSchemaRequest ¶

Request for the `DeleteSchema` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type DeleteSchemaRequest = src.DeleteSchemaRequest

type DeleteSnapshotRequest ¶

Request for the `DeleteSnapshot` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type DeleteSnapshotRequest = src.DeleteSnapshotRequest

type DeleteSubscriptionRequest ¶

Request for the DeleteSubscription method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type DeleteSubscriptionRequest = src.DeleteSubscriptionRequest

type DeleteTopicRequest ¶

Request for the `DeleteTopic` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type DeleteTopicRequest = src.DeleteTopicRequest

type DetachSubscriptionRequest ¶

Request for the DetachSubscription method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type DetachSubscriptionRequest = src.DetachSubscriptionRequest

type DetachSubscriptionResponse ¶

Response for the DetachSubscription method. Reserved for future use.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type DetachSubscriptionResponse = src.DetachSubscriptionResponse

type Encoding ¶

Possible encoding types for messages.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type Encoding = src.Encoding

type ExpirationPolicy ¶

A policy that specifies the conditions for resource expiration (i.e., automatic resource deletion).

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ExpirationPolicy = src.ExpirationPolicy

type GetSchemaRequest ¶

Request for the GetSchema method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type GetSchemaRequest = src.GetSchemaRequest

type GetSnapshotRequest ¶

Request for the GetSnapshot method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type GetSnapshotRequest = src.GetSnapshotRequest

type GetSubscriptionRequest ¶

Request for the GetSubscription method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type GetSubscriptionRequest = src.GetSubscriptionRequest

type GetTopicRequest ¶

Request for the GetTopic method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type GetTopicRequest = src.GetTopicRequest

type ListSchemasRequest ¶

Request for the `ListSchemas` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ListSchemasRequest = src.ListSchemasRequest

type ListSchemasResponse ¶

Response for the `ListSchemas` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ListSchemasResponse = src.ListSchemasResponse

type ListSnapshotsRequest ¶

Request for the `ListSnapshots` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ListSnapshotsRequest = src.ListSnapshotsRequest

type ListSnapshotsResponse ¶

Response for the `ListSnapshots` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ListSnapshotsResponse = src.ListSnapshotsResponse

type ListSubscriptionsRequest ¶

Request for the `ListSubscriptions` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ListSubscriptionsRequest = src.ListSubscriptionsRequest

type ListSubscriptionsResponse ¶

Response for the `ListSubscriptions` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ListSubscriptionsResponse = src.ListSubscriptionsResponse

type ListTopicSnapshotsRequest ¶

Request for the `ListTopicSnapshots` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ListTopicSnapshotsRequest = src.ListTopicSnapshotsRequest

type ListTopicSnapshotsResponse ¶

Response for the `ListTopicSnapshots` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ListTopicSnapshotsResponse = src.ListTopicSnapshotsResponse

type ListTopicSubscriptionsRequest ¶

Request for the `ListTopicSubscriptions` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ListTopicSubscriptionsRequest = src.ListTopicSubscriptionsRequest

type ListTopicSubscriptionsResponse ¶

Response for the `ListTopicSubscriptions` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ListTopicSubscriptionsResponse = src.ListTopicSubscriptionsResponse

type ListTopicsRequest ¶

Request for the `ListTopics` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ListTopicsRequest = src.ListTopicsRequest

type ListTopicsResponse ¶

Response for the `ListTopics` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ListTopicsResponse = src.ListTopicsResponse

type MessageStoragePolicy ¶

A policy constraining the storage of messages published to the topic.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type MessageStoragePolicy = src.MessageStoragePolicy

type ModifyAckDeadlineRequest ¶

Request for the ModifyAckDeadline method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ModifyAckDeadlineRequest = src.ModifyAckDeadlineRequest

type ModifyPushConfigRequest ¶

Request for the ModifyPushConfig method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ModifyPushConfigRequest = src.ModifyPushConfigRequest

type PublishRequest ¶

Request for the Publish method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type PublishRequest = src.PublishRequest

type PublishResponse ¶

Response for the `Publish` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type PublishResponse = src.PublishResponse

type PublisherClient ¶

PublisherClient is the client API for Publisher service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type PublisherClient = src.PublisherClient

func NewPublisherClient ¶

func NewPublisherClient(cc grpc.ClientConnInterface) PublisherClient

Deprecated: Please use funcs in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type PublisherServer ¶

PublisherServer is the server API for Publisher service.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type PublisherServer = src.PublisherServer

type PubsubMessage ¶

A message that is published by publishers and consumed by subscribers. The message must contain either a non-empty data field or at least one attribute. Note that client libraries represent this object differently depending on the language. See the corresponding [client library documentation](https://cloud.google.com/pubsub/docs/reference/libraries) for more information. See [quotas and limits] (https://cloud.google.com/pubsub/quotas) for more information about message limits.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type PubsubMessage = src.PubsubMessage

type PullRequest ¶

Request for the `Pull` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type PullRequest = src.PullRequest

type PullResponse ¶

Response for the `Pull` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type PullResponse = src.PullResponse

type PushConfig ¶

Configuration for a push delivery endpoint.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type PushConfig = src.PushConfig

type PushConfig_OidcToken ¶

Contains information needed for generating an [OpenID Connect token](https://developers.google.com/identity/protocols/OpenIDConnect).

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type PushConfig_OidcToken = src.PushConfig_OidcToken

type PushConfig_OidcToken_ ¶

type PushConfig_OidcToken_ = src.PushConfig_OidcToken_

type ReceivedMessage ¶

A message and its corresponding acknowledgment ID.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ReceivedMessage = src.ReceivedMessage

type RetryPolicy ¶

A policy that specifies how Cloud Pub/Sub retries message delivery. Retry delay will be exponential based on provided minimum and maximum backoffs. https://en.wikipedia.org/wiki/Exponential_backoff. RetryPolicy will be triggered on NACKs or acknowledgement deadline exceeded events for a given message. Retry Policy is implemented on a best effort basis. At times, the delay between consecutive deliveries may not match the configuration. That is, delay can be more or less than configured backoff.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type RetryPolicy = src.RetryPolicy

type Schema ¶

A schema resource.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type Schema = src.Schema

type SchemaServiceClient ¶

SchemaServiceClient is the client API for SchemaService service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type SchemaServiceClient = src.SchemaServiceClient

func NewSchemaServiceClient ¶

func NewSchemaServiceClient(cc grpc.ClientConnInterface) SchemaServiceClient

Deprecated: Please use funcs in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type SchemaServiceServer ¶

SchemaServiceServer is the server API for SchemaService service.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type SchemaServiceServer = src.SchemaServiceServer

type SchemaSettings ¶

Settings for validating messages published against a schema.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type SchemaSettings = src.SchemaSettings

type SchemaView ¶

View of Schema object fields to be returned by GetSchema and ListSchemas.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type SchemaView = src.SchemaView

type Schema_Type ¶

Possible schema definition types.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type Schema_Type = src.Schema_Type

type SeekRequest ¶

Request for the `Seek` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type SeekRequest = src.SeekRequest

type SeekRequest_Snapshot ¶

type SeekRequest_Snapshot = src.SeekRequest_Snapshot

type SeekRequest_Time ¶

type SeekRequest_Time = src.SeekRequest_Time

type SeekResponse ¶

Response for the `Seek` method (this response is empty).

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type SeekResponse = src.SeekResponse

type Snapshot ¶

A snapshot resource. Snapshots are used in [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type Snapshot = src.Snapshot

type StreamingPullRequest ¶

Request for the `StreamingPull` streaming RPC method. This request is used to establish the initial stream as well as to stream acknowledgements and ack deadline modifications from the client to the server.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type StreamingPullRequest = src.StreamingPullRequest

type StreamingPullResponse ¶

Response for the `StreamingPull` method. This response is used to stream messages from the server to the client.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type StreamingPullResponse = src.StreamingPullResponse

type StreamingPullResponse_AcknowledgeConfirmation ¶

Acknowledgement IDs sent in one or more previous requests to acknowledge a previously received message.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type StreamingPullResponse_AcknowledgeConfirmation = src.StreamingPullResponse_AcknowledgeConfirmation

type StreamingPullResponse_ModifyAckDeadlineConfirmation ¶

Acknowledgement IDs sent in one or more previous requests to modify the deadline for a specific message.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type StreamingPullResponse_ModifyAckDeadlineConfirmation = src.StreamingPullResponse_ModifyAckDeadlineConfirmation

type StreamingPullResponse_SubscriptionProperties ¶

Subscription properties sent as part of the response.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type StreamingPullResponse_SubscriptionProperties = src.StreamingPullResponse_SubscriptionProperties

type SubscriberClient ¶

SubscriberClient is the client API for Subscriber service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type SubscriberClient = src.SubscriberClient

func NewSubscriberClient ¶

func NewSubscriberClient(cc grpc.ClientConnInterface) SubscriberClient

Deprecated: Please use funcs in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type SubscriberServer ¶

SubscriberServer is the server API for Subscriber service.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type SubscriberServer = src.SubscriberServer

type Subscriber_StreamingPullClient ¶

type Subscriber_StreamingPullClient = src.Subscriber_StreamingPullClient

type Subscriber_StreamingPullServer ¶

type Subscriber_StreamingPullServer = src.Subscriber_StreamingPullServer

type Subscription ¶

A subscription resource.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type Subscription = src.Subscription

type Subscription_State ¶

Possible states for a subscription.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type Subscription_State = src.Subscription_State

type Topic ¶

A topic resource.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type Topic = src.Topic

type UnimplementedPublisherServer ¶

UnimplementedPublisherServer can be embedded to have forward compatible implementations.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type UnimplementedPublisherServer = src.UnimplementedPublisherServer

type UnimplementedSchemaServiceServer ¶

UnimplementedSchemaServiceServer can be embedded to have forward compatible implementations.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type UnimplementedSchemaServiceServer = src.UnimplementedSchemaServiceServer

type UnimplementedSubscriberServer ¶

UnimplementedSubscriberServer can be embedded to have forward compatible implementations.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type UnimplementedSubscriberServer = src.UnimplementedSubscriberServer

type UpdateSnapshotRequest ¶

Request for the UpdateSnapshot method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type UpdateSnapshotRequest = src.UpdateSnapshotRequest

type UpdateSubscriptionRequest ¶

Request for the UpdateSubscription method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type UpdateSubscriptionRequest = src.UpdateSubscriptionRequest

type UpdateTopicRequest ¶

Request for the UpdateTopic method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type UpdateTopicRequest = src.UpdateTopicRequest

type ValidateMessageRequest ¶

Request for the `ValidateMessage` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ValidateMessageRequest = src.ValidateMessageRequest

type ValidateMessageRequest_Name ¶

type ValidateMessageRequest_Name = src.ValidateMessageRequest_Name

type ValidateMessageRequest_Schema ¶

type ValidateMessageRequest_Schema = src.ValidateMessageRequest_Schema

type ValidateMessageResponse ¶

Response for the `ValidateMessage` method. Empty for now.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ValidateMessageResponse = src.ValidateMessageResponse

type ValidateSchemaRequest ¶

Request for the `ValidateSchema` method.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ValidateSchemaRequest = src.ValidateSchemaRequest

type ValidateSchemaResponse ¶

Response for the `ValidateSchema` method. Empty for now.

Deprecated: Please use types in: cloud.google.com/go/pubsub/apiv1/pubsubpb

type ValidateSchemaResponse = src.ValidateSchemaResponse