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 ..

func NewSubscriptionWithConfigPath

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

func NewSubscriptionWithOptions

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

NewSubscriptionWithOptions ..

func NewTopic

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

NewTopic ..

func NewTopicWithConfigPath

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

func NewTopicWithOptions

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

NewTopicWithOptions start a new topic for send message

Types

type Options

type Options struct {
	Resource string
	Type     string
	Region   string
}

Options ..

func NewOptions

func NewOptions() (*Options, error)

func NewOptionsWithPath

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