Documentation ¶
Overview ¶
Package pubsub provides Google Pub/Sub related implementation.
Index ¶
- type PubSub
- func (p *PubSub) Close() error
- func (p *PubSub) EnsureSubscription(ctx context.Context, topic *pubsub.Topic, id string) (*pubsub.Subscription, error)
- func (p *PubSub) EnsureTopic(ctx context.Context, id string) (*pubsub.Topic, error)
- func (p *PubSub) Publish(topicID string, msg []byte) mq.PublishResult
- func (p *PubSub) Subscribe(ctx context.Context, channel string, h mq.Handler) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PubSub ¶
type PubSub struct {
// contains filtered or unexported fields
}
PubSub represents the PubSub (client).
func (*PubSub) EnsureSubscription ¶
func (p *PubSub) EnsureSubscription(ctx context.Context, topic *pubsub.Topic, id string) (*pubsub.Subscription, error)
EnsureSubscription ensures the subscription exists.
func (*PubSub) EnsureTopic ¶
EnsureTopic ensures the topic exists.
Click to show internal directories.
Click to hide internal directories.