pubsub

Documentation

Index

• Variables
• type Client
  • func NewClient(ctx context.Context, project string, opts ...Option) (*Client, error)
  • func (c *Client) CreatePublisher(topic string, opts ...PublishOption) (publisher.Publisher, error)
  • func (c *Client) CreatePublisherInProject(topic, project string, opts ...PublishOption) (publisher.Publisher, error)
  • func (c *Client) CreatePuller(subscription, topic string, opts ...ReceiveOption) (puller.Puller, error)
  • func (c *Client) DeleteSubscription(id string) error
  • func (c *Client) DeleteSubscriptionIfExist(id string) error
  • func (c *Client) SubscriptionExists(id string) (bool, error)
• type Option
  • func WithBackoff(bf backoff.Backoff) Option
  • func WithLogger(l *zap.Logger) Option
  • func WithMetrics(registerer metrics.Registerer) Option
  • func WithRetries(retries int) Option
• type PublishOption
  • func WithPublishNumGoroutines(n int) PublishOption
  • func WithPublishTimeout(timeout time.Duration) PublishOption
• type ReceiveOption
  • func WithMaxExtension(d time.Duration) ReceiveOption
  • func WithMaxOutstandingBytes(b int) ReceiveOption
  • func WithMaxOutstandingMessages(n int) ReceiveOption
  • func WithNumGoroutines(n int) ReceiveOption

Variables

var (
	ErrInvalidTopic = errors.New("pubsub: invalid topic")
)

Types

type Client

type Client struct {
	*pubsub.Client
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ctx context.Context, project string, opts ...Option) (*Client, error)

func (*Client) CreatePublisher

func (c *Client) CreatePublisher(topic string, opts ...PublishOption) (publisher.Publisher, error)

func (*Client) CreatePublisherInProject

func (c *Client) CreatePublisherInProject(topic, project string, opts ...PublishOption) (publisher.Publisher, error)

func (*Client) CreatePuller

func (c *Client) CreatePuller(subscription, topic string, opts ...ReceiveOption) (puller.Puller, error)

func (*Client) DeleteSubscription

func (c *Client) DeleteSubscription(id string) error

func (*Client) DeleteSubscriptionIfExist

func (c *Client) DeleteSubscriptionIfExist(id string) error

func (*Client) SubscriptionExists

func (c *Client) SubscriptionExists(id string) (bool, error)

type Option

type Option func(*options)

func WithBackoff

func WithBackoff(bf backoff.Backoff) Option

func WithLogger

func WithLogger(l *zap.Logger) Option

func WithMetrics

func WithMetrics(registerer metrics.Registerer) Option

func WithRetries

func WithRetries(retries int) Option

type PublishOption

type PublishOption func(*publishOptions)

func WithPublishNumGoroutines

func WithPublishNumGoroutines(n int) PublishOption

func WithPublishTimeout

func WithPublishTimeout(timeout time.Duration) PublishOption

type ReceiveOption

type ReceiveOption func(*receiveOptions)

func WithMaxExtension

func WithMaxExtension(d time.Duration) ReceiveOption

func WithMaxOutstandingBytes

func WithMaxOutstandingBytes(b int) ReceiveOption

func WithMaxOutstandingMessages

func WithMaxOutstandingMessages(n int) ReceiveOption

func WithNumGoroutines

func WithNumGoroutines(n int) ReceiveOption