pubsub

Oct 3, 2018

Changes in this version

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

+ var ModAckTimeoutCountView *view.View

type ReceiveSettings

+ Synchronous bool

Aug 7, 2018

Changes in this version

+ type MessageStoragePolicy struct

+ AllowedPersistenceRegions []string

type SubscriptionConfig

+ Labels map[string]string

type SubscriptionConfigToUpdate

+ Labels map[string]string

type Topic

+ func (t *Topic) Config(ctx context.Context) (TopicConfig, error)

+ func (t *Topic) Update(ctx context.Context, cfg TopicConfigToUpdate) (TopicConfig, error)

+ type TopicConfig struct

+ Labels map[string]string

+ MessageStoragePolicy MessageStoragePolicy

+ type TopicConfigToUpdate struct

+ Labels map[string]string

Feb 27, 2018

Changes in this version

+ var AckCount *stats.Int64Measure

+ var AckCountView *view.View

+ var ModAckCount *stats.Int64Measure

+ var ModAckCountView *view.View

+ var NackCount *stats.Int64Measure

+ var NackCountView *view.View

+ var PullCount *stats.Int64Measure

+ var PullCountView *view.View

+ var StreamOpenCount *stats.Int64Measure

+ var StreamOpenCountView *view.View

+ var StreamRequestCount *stats.Int64Measure

+ var StreamRequestCountView *view.View

+ var StreamResponseCount *stats.Int64Measure

+ var StreamResponseCountView *view.View

+ var StreamRetryCount *stats.Int64Measure

+ var StreamRetryCountView *view.View

type Client

+ func (c *Client) SubscriptionInProject(id, projectID string) *Subscription

Jan 19, 2018

Changes in this version

type Client

+ func (c *Client) Snapshot(id string) *Snapshot

+ func (c *Client) Snapshots(ctx context.Context) *SnapshotConfigIterator

+ type Snapshot struct

+ func (s *Snapshot) ID() string

+ func (snap *Snapshot) Delete(ctx context.Context) error

+ type SnapshotConfig struct

+ Expiration time.Time

+ Topic *Topic

+ type SnapshotConfigIterator struct

+ func (snaps *SnapshotConfigIterator) Next() (*SnapshotConfig, error)

type Subscription

+ func (s *Subscription) CreateSnapshot(ctx context.Context, name string) (*SnapshotConfig, error)

+ func (s *Subscription) SeekToSnapshot(ctx context.Context, snap *Snapshot) error

+ func (s *Subscription) SeekToTime(ctx context.Context, t time.Time) error

type SubscriptionConfig

+ RetainAckedMessages bool

+ RetentionDuration time.Duration

type SubscriptionConfigToUpdate

+ AckDeadline time.Duration

+ RetainAckedMessages optional.Bool

+ RetentionDuration time.Duration

Aug 22, 2017

Changes in this version

type Client

+ func (c *Client) TopicInProject(id, projectID string) *Topic

Jun 30, 2017

Changes in this version

type ReceiveSettings

+ NumGoroutines int

type Subscription

+ func (s *Subscription) Update(ctx context.Context, cfg SubscriptionConfigToUpdate) (SubscriptionConfig, error)

+ type SubscriptionConfigToUpdate struct

+ PushConfig *PushConfig

Jun 14, 2017

Changes in this version

+ const MaxPublishRequestBytes

+ const MaxPublishRequestCount

+ var DefaultPublishSettings = PublishSettings

+ var DefaultReceiveSettings = ReceiveSettings

+ var ErrOversizedMessage = bundler.ErrOversizedItem

type Message

+ func (m *Message) Ack()

+ func (m *Message) Nack()

+ type PublishResult struct

+ func (r *PublishResult) Get(ctx context.Context) (serverID string, err error)

+ func (r *PublishResult) Ready() <-chan struct{}

+ type PublishSettings struct

+ ByteThreshold int

+ CountThreshold int

+ DelayThreshold time.Duration

+ NumGoroutines int

+ Timeout time.Duration

+ type ReceiveSettings struct

+ MaxExtension time.Duration

+ MaxOutstandingBytes int

+ MaxOutstandingMessages int

type Subscription

+ ReceiveSettings ReceiveSettings

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

type Topic

+ PublishSettings PublishSettings

+ func (t *Topic) Stop()

Nov 1, 2016

Changes in this version

type Subscription

+ func (s *Subscription) IAM() *iam.Handle

type Topic

+ func (t *Topic) IAM() *iam.Handle

Oct 3, 2016

Changes in this version

type Client

+ func (c *Client) Close() error

+ func (c *Client) CreateSubscription(ctx context.Context, id string, topic *Topic, ackDeadline time.Duration, ...) (*Subscription, error)

+ func (c *Client) CreateTopic(ctx context.Context, id string) (*Topic, error)

type Message

+ PublishTime time.Time

+ type MessageIterator struct

+ func (it *MessageIterator) Next() (*Message, error)

+ func (it *MessageIterator) Stop()

type Subscription

+ func (s *Subscription) ID() string

+ func (s *Subscription) String() string

type Topic

+ func (t *Topic) ID() string

+ func (t *Topic) String() string

Aug 3, 2016

Changes in this version

+ const DefaultMaxExtension

+ const DefaultMaxPrefetch

+ const MaxPublishBatchSize

+ const ScopeCloudPlatform

+ const ScopePubSub

+ var Done = errors.New("no more messages")

+ type Client struct

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

+ func (c *Client) NewSubscription(ctx context.Context, name string, topic *Topic, ackDeadline time.Duration, ...) (*Subscription, error)

+ func (c *Client) NewTopic(ctx context.Context, name string) (*Topic, error)

+ func (c *Client) Subscription(name string) *Subscription

+ func (c *Client) Subscriptions(ctx context.Context) *SubscriptionIterator

+ func (c *Client) Topic(name string) *Topic

+ func (c *Client) Topics(ctx context.Context) *TopicIterator

+ type Iterator struct

+ func (it *Iterator) Next() (*Message, error)

+ func (it *Iterator) Stop()

+ type Message struct

+ AckID string

+ Attributes map[string]string

+ Data []byte

+ ID string

+ func (m *Message) Done(ack bool)

+ type PullOption interface

+ func MaxExtension(duration time.Duration) PullOption

+ func MaxPrefetch(num int) PullOption

+ type PushConfig struct

+ Attributes map[string]string

+ Endpoint string

+ type Subscription struct

+ func (s *Subscription) Config(ctx context.Context) (*SubscriptionConfig, error)

+ func (s *Subscription) Delete(ctx context.Context) error

+ func (s *Subscription) Exists(ctx context.Context) (bool, error)

+ func (s *Subscription) ModifyPushConfig(ctx context.Context, conf *PushConfig) error

+ func (s *Subscription) Name() string

+ func (s *Subscription) Pull(ctx context.Context, opts ...PullOption) (*Iterator, error)

+ type SubscriptionConfig struct

+ AckDeadline time.Duration

+ PushConfig PushConfig

+ Topic *Topic

+ type SubscriptionIterator struct

+ func (subs *SubscriptionIterator) Next() (*Subscription, error)

+ type Topic struct

+ func (t *Topic) Delete(ctx context.Context) error

+ func (t *Topic) Exists(ctx context.Context) (bool, error)

+ func (t *Topic) Name() string

+ func (t *Topic) Publish(ctx context.Context, msgs ...*Message) ([]string, error)

+ func (t *Topic) Subscriptions(ctx context.Context) *SubscriptionIterator

+ type TopicIterator struct

+ func (tps *TopicIterator) Next() (*Topic, error)