Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PubSubClient ¶
type PubSubClient struct {
Topic *pubsub.Topic
Subscription *pubsub.Subscription
// contains filtered or unexported fields
}
func New ¶
func New(gcpProject string) *PubSubClient
func (*PubSubClient) Publish ¶
func (p *PubSubClient) Publish(message []byte, attributes map[string]string) error
func (*PubSubClient) SetSubscription ¶
func (p *PubSubClient) SetSubscription(subscription string) error
func (*PubSubClient) SetTopic ¶
func (p *PubSubClient) SetTopic(topicName string) error
func (*PubSubClient) Subscribe ¶
func (p *PubSubClient) Subscribe() error
Source Files
Click to show internal directories.
Click to hide internal directories.