puller

Documentation

Index

• type Message
• type Option
  • func WithLogger(logger *zap.Logger) Option
• type Puller
  • func NewPuller(sub *pubsub.Subscription, opts ...Option) Puller
• type RateLimitedPuller
  • func NewRateLimitedPuller(puller Puller, maxMPS int) RateLimitedPuller

Types

type Message

type Message struct {
	ID         string
	Data       []byte
	Attributes map[string]string

	Ack  func()
	Nack func()
}

type Option

type Option func(*options)

func WithLogger

func WithLogger(logger *zap.Logger) Option

type Puller

type Puller interface {
	Pull(context.Context, func(context.Context, *Message)) error
}

func NewPuller

func NewPuller(sub *pubsub.Subscription, opts ...Option) Puller

type RateLimitedPuller

type RateLimitedPuller interface {
	Run(context.Context) error
	MessageCh() <-chan *Message
}

func NewRateLimitedPuller

func NewRateLimitedPuller(puller Puller, maxMPS int) RateLimitedPuller