pubsub

Documentation

Index

• Constants
• func ConfigAdd(path string)
• func NewSubscription(ctx context.Context) (*pubsub.Subscription, error)
• func NewSubscriptionWithConfigPath(ctx context.Context, path string) (*pubsub.Subscription, error)
• func NewSubscriptionWithOptions(ctx context.Context, o *Options) (*pubsub.Subscription, error)
• func NewTopic(ctx context.Context) (*pubsub.Topic, error)
• func NewTopicWithConfigPath(ctx context.Context, path string) (*pubsub.Topic, error)
• func NewTopicWithOptions(ctx context.Context, o *Options) (*pubsub.Topic, error)
• type Options
  • func NewOptions() (*Options, error)
  • func NewOptionsWithPath(path string) (opts *Options, err error)

Constants

const (
	SQS    = "sqs"
	SNS    = "sns"
	KAFKA  = "kafka"
	NATS   = "nats"
	PUBSUB = "pubsub"
)

Queue types

Functions

func ConfigAdd

func ConfigAdd(path string)

func NewSubscription

func NewSubscription(ctx context.Context) (*pubsub.Subscription, error)

NewSubscription creates a subscription.

func NewSubscriptionWithConfigPath

func NewSubscriptionWithConfigPath(ctx context.Context, path string) (*pubsub.Subscription, error)

NewSubscriptionWithConfigPath return a subscription with options from config path.

func NewSubscriptionWithOptions

func NewSubscriptionWithOptions(ctx context.Context, o *Options) (*pubsub.Subscription, error)

NewSubscriptionWithOptions return a subscription with options from config path.

func NewTopic

func NewTopic(ctx context.Context) (*pubsub.Topic, error)

NewTopic creates a topic publisher

func NewTopicWithConfigPath

func NewTopicWithConfigPath(ctx context.Context, path string) (*pubsub.Topic, error)

NewTopicWithConfigPath start a new topic for sending messages with options from config path.

func NewTopicWithOptions

func NewTopicWithOptions(ctx context.Context, o *Options) (*pubsub.Topic, error)

NewTopicWithOptions start a new topic for sending messages.

Types

type Options

type Options struct {
	Resource string
	Type     string
	Region   string
}

Options represents pubsub client options.

func NewOptions

func NewOptions() (*Options, error)

NewOptions returns options from config file or environment vars.

func NewOptionsWithPath

func NewOptionsWithPath(path string) (opts *Options, err error)

NewOptionsWithPath unmarshals a given key path into options and returns it.