cronjob

Documentation

Index

• Variables
• func New(lc lifecycle.Lifecycle, cmder redis.Cmdable) (gocron.Scheduler, error)
• type DistributedElector
  • func NewDistributedElector(cmder redis.Cmdable) *DistributedElector
  • func (e *DistributedElector) IsLeader(ctx context.Context) error
  • func (e *DistributedElector) Lock(ctx context.Context, key string) (gocron.Lock, error)
  • func (e *DistributedElector) Stop(ctx context.Context)
  • func (e *DistributedElector) Unlock(ctx context.Context, key string) error

Variables

var (
	Clock      clockwork.Clock = clockwork.NewRealClock()
	LeaderKey                  = "cronjob:leader"
	DefaultTTL                 = 10 * time.Minute
)

Functions

func New

func New(lc lifecycle.Lifecycle, cmder redis.Cmdable) (gocron.Scheduler, error)

Types

type DistributedElector

type DistributedElector struct {
	// contains filtered or unexported fields
}

func NewDistributedElector

func NewDistributedElector(cmder redis.Cmdable) *DistributedElector

func (*DistributedElector) IsLeader

func (e *DistributedElector) IsLeader(ctx context.Context) error

func (*DistributedElector) Lock

func (e *DistributedElector) Lock(ctx context.Context, key string) (gocron.Lock, error)

func (*DistributedElector) Stop

func (e *DistributedElector) Stop(ctx context.Context)

func (*DistributedElector) Unlock

func (e *DistributedElector) Unlock(ctx context.Context, key string) error