workers

Documentation

Index

• func Subscribe(ctx context.Context, sc pubsub.SubscriberClient)
• type CountMessageHandler
  • func NewCountMessageHandler() *CountMessageHandler
  • func (cmh *CountMessageHandler) OnMessage(m *ps.Message) error
• type PublisheWorker
  • func (pw *PublisheWorker) GenerateMessages(count int) error

Functions

func Subscribe

func Subscribe(ctx context.Context, sc pubsub.SubscriberClient)

Subscribe consumes messages from the subscriptions sc contains the subscription, and the OnMessge Handler

Types

type CountMessageHandler

type CountMessageHandler struct {
	// AutoAck  auto ack messages
	AutoAck bool
	// Count the number of messages consumed
	Count     int
	Preview   bool
	Formatter f.Formatter
}

CountMessageHandler used to count the number of messages consumed

func NewCountMessageHandler

func NewCountMessageHandler() *CountMessageHandler

NewCountMessageHandler Initilize the count message handler returns CountMessageHandler a new count message handler

func (*CountMessageHandler) OnMessage

func (cmh *CountMessageHandler) OnMessage(m *ps.Message) error

OnMessage calls cmh to increment the number of messages.

type PublisheWorker

type PublisheWorker struct {
	Publish pubsub.Publish
}

PublisheWorker Sets the publisher to use

func (*PublisheWorker) GenerateMessages

func (pw *PublisheWorker) GenerateMessages(count int) error

GenerateMessages generats a number of messages