pubsub

package module

Go to main page

Versions in this module

v2

v2.5.1

Mar 31, 2026

v2.5.0

Mar 19, 2026

Changes in this version

type ReceiveSettings

+ EnablePerStreamFlowControl bool

v2.4.0

Feb 4, 2026

v2.3.0

Oct 22, 2025

v2.2.1

Oct 14, 2025

v2.2.0

Oct 3, 2025

v2.1.0

Sep 25, 2025

Changes in this version

+ const ShutdownBehaviorNackImmediately

+ const ShutdownBehaviorWaitForProcessing

type ReceiveSettings

+ ShutdownOptions *ShutdownOptions

+ type ShutdownBehavior int

+ type ShutdownOptions struct

+ Behavior ShutdownBehavior

+ Timeout time.Duration

v2.0.1

Sep 3, 2025

v2.0.0

Jul 16, 2025

Changes in this version

+ const DetectProjectID

+ const MaxPublishRequestBytes

+ const MaxPublishRequestCount

+ const ScopeCloudPlatform

+ const ScopePubSub

+ var AckCount = stats.Int64(statsPrefix + "ack_count", "Number of PubSub messages acked", ...)

+ var AckCountView *view.View

+ var DefaultPublishSettings = PublishSettings

+ var DefaultPublishViews []*view.View

+ var DefaultReceiveSettings = ReceiveSettings

+ var DefaultSubscribeViews []*view.View

+ var ErrEmptyProjectID = errors.New("pubsub: projectID string is empty")

+ var ErrFlowControllerMaxOutstandingBytes = errors.New("pubsub: MaxOutstandingBytes flow control limit exceeded")

+ var ErrFlowControllerMaxOutstandingMessages = errors.New("pubsub: MaxOutstandingMessages flow controller limit exceeded")

+ var ErrOversizedMessage = bundler.ErrOversizedItem

+ var ErrPublisherStopped = errors.New("pubsub: Stop has been called for this publisher")

+ var ModAckCount = stats.Int64(statsPrefix + "mod_ack_count", "Number of ack-deadlines modified", ...)

+ var ModAckCountView *view.View

+ var ModAckTimeoutCount = stats.Int64(statsPrefix + "mod_ack_timeout_count", ...)

+ var ModAckTimeoutCountView *view.View

+ var NackCount = stats.Int64(statsPrefix + "nack_count", "Number of PubSub messages nacked", ...)

+ var NackCountView *view.View

+ var OutstandingBytes = stats.Int64(statsPrefix + "outstanding_bytes", "Number of outstanding bytes", ...)

+ var OutstandingBytesView *view.View

+ var OutstandingMessages = stats.Int64(statsPrefix + "outstanding_messages", "Number of outstanding Pub/Sub messages", ...)

+ var OutstandingMessagesView *view.View

+ var PublishLatency = stats.Float64(statsPrefix + "publish_roundtrip_latency", ...)

+ var PublishLatencyView *view.View

+ var PublishedMessages = stats.Int64(statsPrefix + "published_messages", "Number of PubSub message published", ...)

+ var PublishedMessagesView *view.View

+ var PublisherOutstandingBytes = stats.Int64(statsPrefix + "publisher_outstanding_bytes", ...)

+ var PublisherOutstandingBytesView *view.View

+ var PublisherOutstandingMessages = stats.Int64(statsPrefix + "publisher_outstanding_messages", ...)

+ var PublisherOutstandingMessagesView *view.View

+ var PullCount = stats.Int64(statsPrefix + "pull_count", "Number of PubSub messages pulled", ...)

+ var PullCountView *view.View

+ var StreamOpenCount = stats.Int64(statsPrefix + "stream_open_count", ...)

+ var StreamOpenCountView *view.View

+ var StreamRequestCount = stats.Int64(statsPrefix + "stream_request_count", ...)

+ var StreamRequestCountView *view.View

+ var StreamResponseCount = stats.Int64(statsPrefix + "stream_response_count", ...)

+ var StreamResponseCountView *view.View

+ var StreamRetryCount = stats.Int64(statsPrefix + "stream_retry_count", ...)

+ var StreamRetryCountView *view.View

+ func NewMessageCarrierFromPB(msg *pb.PubsubMessage) propagation.TextMapCarrier

+ type AckResult = ipubsub.AckResult

+ type AcknowledgeStatus = ipubsub.AcknowledgeStatus

+ const AcknowledgeStatusFailedPrecondition

+ const AcknowledgeStatusInvalidAckID

+ const AcknowledgeStatusOther

+ const AcknowledgeStatusPermissionDenied

+ const AcknowledgeStatusSuccess

+ type Client struct

+ SubscriptionAdminClient *vkit.SubscriptionAdminClient

+ TopicAdminClient *vkit.TopicAdminClient

+ func NewClient(ctx context.Context, projectID string, opts ...option.ClientOption) (c *Client, err error)

+ func NewClientWithConfig(ctx context.Context, projectID string, config *ClientConfig, ...) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) Project() string

+ func (c *Client) Publisher(topicNameOrID string) *Publisher

+ func (c *Client) Subscriber(nameOrID string) *Subscriber

+ type ClientConfig struct

+ EnableOpenTelemetryTracing bool

+ SubscriptionAdminCallOptions *vkit.SubscriptionAdminCallOptions

+ TopicAdminCallOptions *vkit.TopicAdminCallOptions

+ type ErrPublishingPaused struct

+ OrderingKey string

+ func (e ErrPublishingPaused) Error() string

+ type FlowControlSettings struct

+ LimitExceededBehavior LimitExceededBehavior

+ MaxOutstandingBytes int

+ MaxOutstandingMessages int

+ type LimitExceededBehavior int

+ const FlowControlBlock

+ const FlowControlIgnore

+ const FlowControlSignalError

+ type Message = ipubsub.Message

+ type PublishResult = ipubsub.PublishResult

+ type PublishSettings struct

+ ByteThreshold int

+ CompressionBytesThreshold int

+ CountThreshold int

+ DelayThreshold time.Duration

+ EnableCompression bool

+ FlowControlSettings FlowControlSettings

+ NumGoroutines int

+ Timeout time.Duration

+ type Publisher struct

+ EnableMessageOrdering bool

+ PublishSettings PublishSettings

+ func (t *Publisher) Flush()

+ func (t *Publisher) ID() string

+ func (t *Publisher) Publish(ctx context.Context, msg *Message) *PublishResult

+ func (t *Publisher) ResumePublish(orderingKey string)

+ func (t *Publisher) Stop()

+ func (t *Publisher) String() string

+ type ReceiveSettings struct

+ MaxDurationPerAckExtension time.Duration

+ MaxExtension time.Duration

+ MaxOutstandingBytes int

+ MaxOutstandingMessages int

+ MinDurationPerAckExtension time.Duration

+ NumGoroutines int

+ type Subscriber struct

+ ReceiveSettings ReceiveSettings

+ func (s *Subscriber) ID() string

+ func (s *Subscriber) Receive(ctx context.Context, f func(context.Context, *Message)) error

+ func (s *Subscriber) String() string

v2.0.0-alpha.2

Jun 6, 2025

v2.0.0-alpha

May 20, 2025

Other modules containing this package

cloud.google.com/go

cloud.google.com/go/pubsub

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