redislock

redislock

install

go get github.com/go-co-op/gocron/lockers/redislock

usage

Here is an example usage that would be deployed in multiple instances

package main

import (
	"time"

	"github.com/go-co-op/gocron"
	"github.com/go-co-op/gocron/lockers/redislock"
	"github.com/redis/go-redis/v9"
)

func main() {
	redisOptions := &redis.Options{
		Addr: "localhost:6379",
	}
	redisClient := redis.NewClient(redisOptions)
	locker, err := redislock.NewRedisLocker(redisClient)
	if err != nil {
		// handle the error
	}

	s := gocron.NewScheduler(time.UTC)
	s.WithDistributedLocker(locker)

	_, err = s.Every("1s").Name("unique_name").Do(func() {
		// task to do
	})
	if err != nil {
		// handle the error
	}

	s.StartBlocking()
}