graceful

README

gocron-graceful

Graceful shutdown implementation for gocron based worker

Installing

go get github.com/ashulepov/gocron-graceful

Using

package main

import (
	"log"
	"sync"

	"github.com/ashulepov/gocron-graceful"
	"github.com/jasonlvhit/gocron"
)

func main() {
	graceful.Worker("tasks", task)
}

func task(wg *sync.WaitGroup) {
	cron := gocron.NewScheduler()
	cron.Every(1).Seconds().Do(graceful.TaskWrapper, wg, job1)
	cron.Every(2).Seconds().Do(graceful.TaskWrapper, wg, job2)
	go func() {
		<-cron.Start()
	}()
}

func job1() {
	log.Println("job 1")
}

func job2() {
	log.Println("job 2")
}

Testing

Unit-tests:

go test -v

Documentation

Index

• func TaskWrapper(wg *sync.WaitGroup, task func())
• func Worker(name string, task func(wg *sync.WaitGroup))

Functions

func TaskWrapper

func TaskWrapper(wg *sync.WaitGroup, task func())

TaskWrapper is wrapper for graceful tasks

func Worker

func Worker(name string, task func(wg *sync.WaitGroup))

Worker runs task worker