Versions in this module Expand all Collapse all v0 v0.3.0 Jan 9, 2019 Changes in this version + func Creator(value interface{}) util.PubSubClientCreator + type Client struct + Data ClientData + func (c *Client) CreateSubscription(ctx context.Context, id string, topic util.PubSubTopic) (util.PubSubSubscription, error) + func (c *Client) CreateTopic(ctx context.Context, id string) (util.PubSubTopic, error) + func (c *Client) SubscriptionInProject(id, projectId string) util.PubSubSubscription + func (c *Client) Topic(id string) util.PubSubTopic + type ClientData struct + CreateSubErr error + CreateTopicErr error + SubscriptionData SubscriptionData + TopicData TopicData + type CreatorData struct + ClientCreateErr error + ClientData ClientData + type Message struct + MessageData MessageData + func (m *Message) Ack() + func (m *Message) Attributes() map[string]string + func (m *Message) Data() []byte + func (m *Message) ID() string + func (m *Message) Nack() + type MessageData struct + Ack bool + Nack bool + type PublishResult struct + Data PublishResultData + func (r *PublishResult) Get(ctx context.Context) (serverID string, err error) + func (r *PublishResult) Ready() <-chan struct{} + type PublishResultData struct + Err error + ID string + Ready <-chan struct{} + type Subscription struct + Data SubscriptionData + func (s *Subscription) Delete(ctx context.Context) error + func (s *Subscription) Exists(ctx context.Context) (bool, error) + func (s *Subscription) ID() string + func (s *Subscription) Receive(ctx context.Context, f func(context.Context, util.PubSubMessage)) error + type SubscriptionData struct + DeleteErr error + Exists bool + ExistsErr error + ReceiveErr error + ReceiveFunc func(context.Context, util.PubSubMessage) + type Topic struct + Data TopicData + func (t *Topic) Delete(ctx context.Context) error + func (t *Topic) Exists(ctx context.Context) (bool, error) + func (t *Topic) ID() string + func (t *Topic) Publish(ctx context.Context, msg *pubsub.Message) util.PubSubPublishResult + func (t *Topic) Stop() + type TopicData struct + DeleteErr error + Exists bool + ExistsErr error + Publish PublishResultData + Stop bool
Go to main page