puller

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

	Ack  func()
	Nack func()
}

type Option func(*options)

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

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