gpubsub

func NewPubSubLiteMessageBus ¶ added in v1.2.4

func NewPubSubLiteMessageBus(uri string) (mq IMessageBus, err error)

NewPubSubLiteMessageBus factory method for PubSub IMessageBus implementation

param: URI - represents the redis connection string in the format of: pubsub://project/region

func NewPubSubMessageBus ¶

func NewPubSubMessageBus(URI string) (mq IMessageBus, err error)

NewPubSubMessageBus factory method for PubSub IMessageBus implementation

param: URI - represents the redis connection string in the format of: pubsub://projectId

func StreamingFactory ¶ added in v1.2.32

func StreamingFactory(uri string) (IMessageBus, error)

StreamingFactory - Analyzes the URI string and calls the appropriate factory function