cloudpubsub

Documentation

Index

• func CreateSubscriber(ctx context.Context, projectID, subscriptionID string, opts ...Option) (subee.Subscriber, error)
• type Config
• type Message
  • func (m *Message) Data() []byte
  • func (m *Message) Metadata() map[string]string
• type Option
  • func WithClientOptions(opts ...option.ClientOption) Option
  • func WithReceiveSettings(cfg pubsub.ReceiveSettings) Option

Functions

func CreateSubscriber

func CreateSubscriber(ctx context.Context, projectID, subscriptionID string, opts ...Option) (subee.Subscriber, error)

CreateSubscriber returns Subscriber implementation.

Types

type Config

type Config struct {
	ClientOpts      []option.ClientOption
	ReceiveSettings pubsub.ReceiveSettings
}

Config represents subscriber configuration.

type Message

type Message struct {
	*pubsub.Message
}

Message is wrapps *pubsub.Message

func (*Message) Data

func (m *Message) Data() []byte

Data returns *pubsub.Message.Data

func (*Message) Metadata

func (m *Message) Metadata() map[string]string

Metadata returns message attributes.

type Option

type Option func(*Config)

Option is subscriber Option

func WithClientOptions

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

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

func WithReceiveSettings

func WithReceiveSettings(cfg pubsub.ReceiveSettings) Option

WithReceiveSettings returns an Option that set pubsub.ReceiveSettings to the pubsub.Subscription.