cloudpubsub

Documentation

Index

• type Config
• type Driver
  • func CreateDriver(ctx context.Context, projectID, topicID string, opts ...Option) (*Driver, error)
  • func (d *Driver) Close(ctx context.Context) error
  • func (d *Driver) Flush()
  • func (d *Driver) Publish(ctx context.Context, msg *pubee.Message) <-chan error
• type Option
  • func WithClientOptions(opts ...option.ClientOption) Option
  • func WithCreateTopicIfNeeded() Option
  • func WithDeleteTopicOnClose() Option
  • func WithPublishSettings(f func(*pubsub.PublishSettings)) Option
  • func WithUpdateTopicConfig(cfg pubsub.TopicConfigToUpdate) Option

Types

type Config

type Config struct {
	ClientOpts          []option.ClientOption
	PublishSettingsFunc func(*pubsub.PublishSettings)
	TopicConfig         *pubsub.TopicConfigToUpdate
	CreateTopic         bool
	DeleteTopic         bool
}

Config represents publisher configuration.

type Driver

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

func CreateDriver

func CreateDriver(ctx context.Context, projectID, topicID string, opts ...Option) (*Driver, error)

func (*Driver) Close

func (d *Driver) Close(ctx context.Context) error

func (*Driver) Flush

func (d *Driver) Flush()

func (*Driver) Publish

func (d *Driver) Publish(ctx context.Context, msg *pubee.Message) <-chan error

type Option

type Option func(*Config)

Option is publisher Option

func WithClientOptions

func WithClientOptions(opts ...option.ClientOption) Option

WithClientOptions returns an Option that set option.ClientOption implementation(s).

func WithCreateTopicIfNeeded

func WithCreateTopicIfNeeded() Option

func WithDeleteTopicOnClose

func WithDeleteTopicOnClose() Option

func WithPublishSettings

func WithPublishSettings(f func(*pubsub.PublishSettings)) Option

WithPublishSettings returns an Option that set pubsub.PublishSettings to the pubsub.Topic.

func WithUpdateTopicConfig

func WithUpdateTopicConfig(cfg pubsub.TopicConfigToUpdate) Option

WithUpdateTopicConfig returns an Option that update configuration for pubsub.Topic.