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
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

worker

package module

Go to main page

Versions in this module

v1

v1.0.0

Sep 8, 2019

v0

v0.4.0

Jul 5, 2018

v0.3.1

Jun 30, 2018

Changes in this version

+ type BsmRedisLockOptions struct

+ RetryCount int

+ RetryDelay time.Duration

+ func (opts BsmRedisLockOptions) NewWith(lockkey string, lockttl time.Duration, retries int, retryDelay time.Duration) BsmRedisLockOptions

+ type DigGroupParams struct

+ Workers []*Worker

+ type Group struct

+ func NewDigGroup(p DigGroupParams) *Group

+ func NewGroup() *Group

+ func (g *Group) Add(workers ...*Worker)

+ func (g *Group) Run()

+ func (g *Group) Stop()

+ type Job func(context.Context)

+ type LockFunc func(context.Context, Job) Job

+ func WithBsmRedisLock(opts BsmRedisLockOptions) LockFunc

+ func WithLock(l Locker) LockFunc

+ func WithRedisLock(opts RedisLockOptions) LockFunc

+ type Locker interface

+ Lock func() error

+ Unlock func()

+ type ObserveFunc func(float64)

+ type RedisClient interface

+ Del func(keys ...string) *redis.IntCmd

+ Eval func(script string, keys []string, args ...interface{}) *redis.Cmd

+ EvalSha func(sha1 string, keys []string, args ...interface{}) *redis.Cmd

+ ScriptExists func(scripts ...string) *redis.BoolSliceCmd

+ ScriptLoad func(script string) *redis.StringCmd

+ SetNX func(key string, value interface{}, expiration time.Duration) *redis.BoolCmd

+ type RedisLockLogger interface

+ Errorw func(msg string, keysAndValues ...interface{})

+ Warnw func(msg string, keysAndValues ...interface{})

+ type RedisLockOptions struct

+ LockKey string

+ LockTTL time.Duration

+ Logger RedisLockLogger

+ RedisCLI RedisClient

+ func (opts *RedisLockOptions) GetLogger() RedisLockLogger

+ func (opts RedisLockOptions) NewWith(lockkey string, lockttl time.Duration) RedisLockOptions

+ type ScheduleFunc func(context.Context, Job) Job

+ func ByCronSchedule(schedule string) ScheduleFunc

+ func ByTicker(period time.Duration) ScheduleFunc

+ func ByTimer(period time.Duration) ScheduleFunc

+ type Worker struct

+ func New(job Job) *Worker

+ func (w *Worker) ByCronSpec(spec string) *Worker

+ func (w *Worker) BySchedule(s ScheduleFunc) *Worker

+ func (w *Worker) ByTicker(period time.Duration) *Worker

+ func (w *Worker) ByTimer(period time.Duration) *Worker

+ func (w *Worker) Run(ctx context.Context)

+ func (w *Worker) SetImmediately(executeOnRun bool) *Worker

+ func (w *Worker) SetObserver(observe ObserveFunc) *Worker

+ func (w *Worker) WithBsmRedisLock(opts BsmRedisLockOptions) *Worker

+ func (w *Worker) WithLock(l Locker) *Worker

+ func (w *Worker) WithRedisLock(opts RedisLockOptions) *Worker