pubsub

Documentation

Index

• type Opt
  • func WithByteThreshold(bytes int) Opt
  • func WithCountThreshold(count int) Opt
  • func WithDelayThreshold(duration time.Duration) Opt
  • func WithTimeout(timeout time.Duration) Opt
  • func WithTopicAutocreate(autocreate bool) Opt
  • func WithTopicFormat(format string) Opt
  • func WithTopicRetention(duration time.Duration) Opt
• type Publisher
  • func New(client *pubsub.Client, opts ...Opt) (*Publisher, error)
  • func (p *Publisher) Close() error
  • func (p *Publisher) Name() string
  • func (p *Publisher) ProduceBulk(events []*pb.Event, connGroup string) error

Types

type Opt

type Opt func(*Publisher)

func WithByteThreshold

func WithByteThreshold(bytes int) Opt

func WithCountThreshold

func WithCountThreshold(count int) Opt

func WithDelayThreshold

func WithDelayThreshold(duration time.Duration) Opt

func WithTimeout

func WithTimeout(timeout time.Duration) Opt

func WithTopicAutocreate

func WithTopicAutocreate(autocreate bool) Opt

func WithTopicFormat

func WithTopicFormat(format string) Opt

func WithTopicRetention

func WithTopicRetention(duration time.Duration) Opt

type Publisher

type Publisher struct {
	// contains filtered or unexported fields
}

Publisher publishes to a Google Cloud Platform PubSub Topic.

func New

func New(client *pubsub.Client, opts ...Opt) (*Publisher, error)

NewPubSub creates a new PubSub publisher

func (*Publisher) Close

func (p *Publisher) Close() error

func (*Publisher) Name

func (p *Publisher) Name() string

func (*Publisher) ProduceBulk

func (p *Publisher) ProduceBulk(events []*pb.Event, connGroup string) error