joblock

Documentation

Index

• type JobLock
• type JobLockTask
  • func (t *JobLockTask) Run(ctx context.Context) error
  • func (t *JobLockTask) UnLock(ctx context.Context) error

Types

type JobLock

type JobLock struct {
	ID     primitive.ObjectID `json:"_id" bson:"_id"`
	Name   string             `json:"name" bson:"name"`
	Expiry time.Time          `json:"expiry" bson:"expiry"`
}

type JobLockTask

type JobLockTask struct {
	Name     string
	Arg      func()
	Interval time.Duration
	Timeout  time.Duration
	Debug    bool
	// contains filtered or unexported fields
}

func (*JobLockTask) Run

func (t *JobLockTask) Run(ctx context.Context) error

func (*JobLockTask) UnLock

func (t *JobLockTask) UnLock(ctx context.Context) error