gpubsub

Documentation

Index

• type PubsubMsgBroker
  • func New(projectID, apiKey, topicPrefix, subsName string) (*PubsubMsgBroker, error)
  • func NewMetered(projectID, apiKey, topicPrefix, subsName string, meter metric.MeterMust) (*PubsubMsgBroker, error)
  • func (p *PubsubMsgBroker) Close() error
  • func (p *PubsubMsgBroker) PublishMsg(ctx context.Context, tname mbroker.TopicName, data []byte) (err error)
  • func (p *PubsubMsgBroker) RegisterTopicHandler(tname mbroker.TopicName, handler mbroker.TopicHandler, opts ...mbroker.Option) error

Types

type PubsubMsgBroker

type PubsubMsgBroker struct {
	// contains filtered or unexported fields
}

PubsubMsgBroker is an implementation of MsgBroker for Google PubSub.

func New

func New(projectID, apiKey, topicPrefix, subsName string) (*PubsubMsgBroker, error)

New returns a new *PubsubMsgBroker.

func NewMetered

func NewMetered(projectID, apiKey, topicPrefix, subsName string, meter metric.MeterMust) (*PubsubMsgBroker, error)

NewMetered is the same as New but exporting some metrics.

func (*PubsubMsgBroker) Close

func (p *PubsubMsgBroker) Close() error

Close closes the client.

func (*PubsubMsgBroker) PublishMsg

func (p *PubsubMsgBroker) PublishMsg(ctx context.Context, tname mbroker.TopicName, data []byte) (err error)

PublishMsg publishes a payload to a topic. If the topic doesn't exist, it's created. The topic name is the same as described in RegisterTopicHandler method documentation.

func (*PubsubMsgBroker) RegisterTopicHandler

func (p *PubsubMsgBroker) RegisterTopicHandler(
	tname mbroker.TopicName,
	handler mbroker.TopicHandler,
	opts ...mbroker.Option) error

RegisterTopicHandler registers a handler for a topic.

• If the topic doesn't exist in PubSub, it's automatically created. The topic name is defined as '<topic-prefix>-<topic-name>'.
• If a subscription doesn't exist in PubSub it's automatically created. The subscription name is defined as '<topic-prefix>-<topic-name>-<subs-name>' (e.g: "staging-new-batch-created-brokerd")