pubsub

Documentation

Index

• type MessageHandler
• type Publish
• type PublishClient
  • func (pc *PublishClient) Publish(message *ps.Message)
• type SubscriberClient
  • func NewSubscriberClient(ctx context.Context, s *pubsub.Subscription, mh MessageHandler) SubscriberClient

Types

type MessageHandler

type MessageHandler interface {
	OnMessage(*pubsub.Message) error
}

MessageHandler interface OnMessage function is what a subscriber will call. Any work done on a message should be done in the OnMessage function

type Publish

type Publish interface {
	Publish(message *ps.Message)
}

Publish interface intended to allow mocking of google Topic.Publish()

type PublishClient

type PublishClient struct {
	Context context.Context
	Topic   *ps.Topic
	Batch   bool
}

PublishClient settings for the Publisher

func (*PublishClient) Publish

func (pc *PublishClient) Publish(message *ps.Message)

Publish Publishes a message to the provided topic.

type SubscriberClient

type SubscriberClient struct {
	Subscritpion *pubsub.Subscription
	Context      context.Context
	Handler      MessageHandler
}

SubscriberClient Holdes the methods that will be used in the workers

func NewSubscriberClient

func NewSubscriberClient(ctx context.Context, s *pubsub.Subscription, mh MessageHandler) SubscriberClient

NewSubscriberClient initilizes a new subscriber to be uused in a worker.