Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Worker ¶
type Worker struct {
Debug bool
Queue string
Logger zap.Logger
MaxAttempts int
Client *redis.Client
BlockTimeout time.Duration
SentryURL string
BackoffIntervalMs int64
Clock Clock
}
Worker is a worker implementation that keeps processing webhooks
func New ¶
func New( queue string, redisHost string, redisPort int, redisPassword string, redisDB int, maxAttempts int, logger zap.Logger, debug bool, blockTimeout time.Duration, sentryURL string, backoffIntervalMs int64, clock Clock, ) *Worker
New creates a new worker instance
func NewDefault ¶
func NewDefault(redisHost string, redisPort int, redisPassword string, redisDB int, logger zap.Logger) *Worker
NewDefault returns a new worker with default options
func (*Worker) ProcessSubscription ¶
ProcessSubscription to messages from Queue
Source Files
Click to show internal directories.
Click to hide internal directories.