pubsub_go

Aug 26, 2022

Changes in this version

type PubSub

+ func (ps *PubSub) CreateSubscriptions(tid string, sids map[string]string, cfg *SubscriptionConfig) error

+ func (ps *PubSub) CreateTopic(tid string, cfg *TopicConfig) error

+ type SubscriptionConfig struct

+ Settings pubsub.SubscriptionConfig

+ type TopicConfig struct

+ Settings pubsub.TopicConfig

Jun 22, 2022

Changes in this version

+ type Config struct

+ IsLocal bool

+ ProjectID string

+ PublishSettings PublishSettings

+ ReceiveSettings ReceiveSettings

+ ServiceAccountFilePath string

+ type Message struct

+ Attributes map[string]string

+ Message interface{}

+ Topic string

+ type PubSub struct

+ func NewPubSub(c Config) (*PubSub, error)

+ func (ps *PubSub) Publish(m Message) error

+ func (ps *PubSub) Receive(subscription string, messages chan<- *pubsub.Message) error

+ type PublishSettings struct

+ Settings pubsub.PublishSettings

+ type ReceiveSettings struct

+ Settings pubsub.ReceiveSettings