publisher

Documentation

Index

• func New(uri string, options ...Option) pubsub.Publisher
• type Option
  • func WithEnsureDurableFanout(name string, args map[string]interface{}) Option
  • func WithEnsureDurableQueue(name string, args map[string]interface{}) Option
  • func WithEnsureDurableTopic(name string, args map[string]interface{}) Option
  • func WithRetry(maxRetries uint64) Option

Functions

func New

func New(uri string, options ...Option) pubsub.Publisher

Types

type Option

type Option func(*publisher)

func WithEnsureDurableFanout

func WithEnsureDurableFanout(name string, args map[string]interface{}) Option

func WithEnsureDurableQueue

func WithEnsureDurableQueue(name string, args map[string]interface{}) Option

func WithEnsureDurableTopic

func WithEnsureDurableTopic(name string, args map[string]interface{}) Option

func WithRetry

func WithRetry(maxRetries uint64) Option