ezpubsub

May 4, 2020

Changes in this version

+ var ErrNoProjectSpecified = errors.New("no project specified")

+ var ErrNoSubscriptionSpecified = errors.New("no subscription specified")

+ var ErrNoTopicSpecified = errors.New("no topic specified")

+ func SimpleAckListener(msg *pubsub.Message)

+ type Admin struct

+ func NewAdmin(project string) (*Admin, error)

+ func (a *Admin) DeleteSubscription(subscription string) error

+ func (a *Admin) DeleteSubscriptions(subscriptions ...string) error

+ func (a *Admin) DeleteTopic(topicName string) error

+ func (a *Admin) ListSubscriptions() ([]string, error)

+ func (a *Admin) ListTopics() ([]string, error)

+ func (a *Admin) SubscriptionExists(subscriptionName string) (bool, error)

+ func (a *Admin) TopicExists(topicName string) (bool, error)

+ type ErrorHandler = func(error)

+ type Listener = func(*pubsub.Message)

+ type Publisher struct

+ func NewPublisher(config *PublisherConfig) (*Publisher, error)

+ func (p *Publisher) Publish(data []byte)

+ func (p *Publisher) PublishBatchSync(payloads [][]byte)

+ func (p *Publisher) PublishObject(obj interface{}) error

+ func (p *Publisher) PublishString(s string)

+ type PublisherConfig struct

+ ErrorHandler ErrorHandler

+ Project string

+ ServerIdHandler ServerIdHandler

+ Topic string

+ type ServerIdHandler = func(string)

+ type Subscriber struct

+ func NewSubscriber(config *SubscriberConfig) (*Subscriber, error)

+ func (s *Subscriber) Start()

+ type SubscriberConfig struct

+ ErrorHandler ErrorHandler

+ Listener Listener

+ Project string

+ PushEndpoint string

+ Subscription string

+ Topic string