Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

curlyq

package module

Go to main page

Versions in this module

v1

v1.0.0-rc2

Apr 25, 2020

v1.0.0-rc1

Feb 13, 2020

v0

v0.4.0

Feb 10, 2020

Changes in this version

type ConsumerOpts

+ CustodianMaxAttempts int

+ CustodianMaxBackoff time.Duration

+ HeartbeatMaxAttempts int

+ HeartbeatMaxBackoff time.Duration

+ HeartbeatPollInterval time.Duration

+ JobMaxAttempts int

+ JobMaxBackoff time.Duration

+ PollerBufferSize int

+ PollerMaxAttempts int

+ PollerMaxBackoff time.Duration

+ PollerPollDuration time.Duration

+ ProcessorConcurrency int

+ SchedulerMaxAttempts int

+ SchedulerMaxBackoff time.Duration

+ type ErrExceededMaxBackoff struct

+ Attempt int

+ Process string

+ func (e ErrExceededMaxBackoff) Error() string

+ type LoudLogger struct

+ func (l *LoudLogger) Debug(args ...interface{})

+ func (l *LoudLogger) Error(args ...interface{})

+ func (l *LoudLogger) Info(args ...interface{})

+ func (l *LoudLogger) Warn(args ...interface{})

v0.3.0

Feb 9, 2020

Changes in this version

+ type EmptyLogger struct

+ func (l *EmptyLogger) Debug(args ...interface{})

+ func (l *EmptyLogger) Error(args ...interface{})

+ func (l *EmptyLogger) Info(args ...interface{})

+ func (l *EmptyLogger) Warn(args ...interface{})

v0.2.0

Jan 27, 2020

Changes in this version

type ConsumerOpts

+ Logger Logger

+ type DefaultLogger struct

+ func (l *DefaultLogger) Debug(args ...interface{})

+ func (l *DefaultLogger) Error(args ...interface{})

+ func (l *DefaultLogger) Info(args ...interface{})

+ func (l *DefaultLogger) Warn(args ...interface{})

+ type ErrFailedToAckJob struct

+ Err error

+ Job Job

+ func (e ErrFailedToAckJob) Error() string

+ type ErrFailedToKillJob struct

+ Err error

+ Job Job

+ func (e ErrFailedToKillJob) Error() string

+ type ErrFailedToRetryJob struct

+ Err error

+ Job Job

+ func (e ErrFailedToRetryJob) Error() string

+ type Logger interface

+ Debug func(...interface{})

+ Error func(...interface{})

+ Info func(...interface{})

+ Warn func(...interface{})

type ProducerOpts

+ Logger Logger

v0.1.0

Jan 24, 2020

Changes in this version

+ type Consumer struct

+ func NewConsumer(opts *ConsumerOpts) *Consumer

+ func (c *Consumer) Consume(handler HandlerFunc, signals ...os.Signal) error

+ func (c *Consumer) ConsumeCtx(ctx context.Context, handler HandlerFunc) error

+ type ConsumerOpts struct

+ Address string

+ Client *redis.Client

+ CustodianConsumerTimeout time.Duration

+ CustodianMaxJobs uint

+ CustodianPollInterval time.Duration

+ ExecutorsBufferSize uint

+ ExecutorsConcurrency uint

+ ExecutorsMaxAttempts uint

+ ExecutorsPollInterval time.Duration

+ HeartbeatInterval time.Duration

+ Queue string

+ SchedulerMaxJobs uint

+ SchedulerPollInterval time.Duration

+ ShutdownGracePeriod time.Duration

+ type HandlerFunc func(context.Context, Job) error

+ type Job struct

+ Attempt uint

+ Data []byte

+ ID string

+ type Producer struct

+ func NewProducer(opts *ProducerOpts) *Producer

+ func (p *Producer) Perform(job Job) (string, error)

+ func (p *Producer) PerformAfter(duration time.Duration, job Job) (string, error)

+ func (p *Producer) PerformAfterCtx(ctx context.Context, duration time.Duration, job Job) (string, error)

+ func (p *Producer) PerformAt(at time.Time, job Job) (string, error)

+ func (p *Producer) PerformAtCtx(ctx context.Context, at time.Time, job Job) (string, error)

+ func (p *Producer) PerformCtx(ctx context.Context, job Job) (string, error)

+ type ProducerOpts struct

+ Address string

+ Client *redis.Client

+ Queue string