Go Task Scheduler with Distributed Lock

Golang Interval job timer, with distributed Lock

goInterLock is golang job/task scheduler with distributed locking mechanism. In distributed system locking is prevent task been executed in every instant that has the scheduler, For example, i…


This content originally appeared on DEV Community and was authored by Jay Ehsaniara

Golang Interval job timer, with distributed Lock

goInterLock is golang job/task scheduler with distributed locking mechanism. In distributed system locking is prevent task been executed in every instant that has the scheduler, For example, if your application has a task of calling some external APIs or doing some DB querying every 10 minutes, the lock prevents the process been run in every instance of that application and you ended up running that task multiple time every 10 minutes.

Quick Start

go get github.com/ehsaniara/gointerlock

Local Scheduler (Single App)

(Interval every 2 seconds)

var job = gointerlock.GoInterval{
    Interval: 2 * time.Second,
    Arg:      myJob,
}
err := job.Run(ctx)
if err != nil {
        log.Fatalf("Error: %s", err)
}

Distributed Scheduler (Scaled Up)

Existing Redis Connection

you should already configure your Redis connection and pass it into the GoInterLock. Also make sure you are giving the
unique name per job

Step 1: configure redis connection redisConnection.Rdb from the existing application and pass it into the Job. for example:

var redisConnector = redis.NewClient(&redis.Options{
    Addr:     "localhost:6379",
    Password: "myRedisPassword", 
    DB:       0,               
})

Step 2: Pass the redis connection into the GoInterval

var job = gointerlock.GoInterval{
    Interval: 2 * time.Second,
    Arg:      myJob,
    Name:     "MyTestJob",
    RedisConnector: redisConnector,
}
err := jobTicker.Run(ctx)
if err != nil {
    log.Fatalf("Error: %s", err)
}

in both examples myJob is your function, for example:

func myJob() {
    fmt.Println(time.Now(), " - called")
}

Note: currently GoInterLock does not support any argument for the job function

Built in Redis Connector

another way is to use an existing redis connection:

var job = gointerlock.GoInterval{
    Name:          "MyTestJob",
    Interval:      2 * time.Second,
    Arg:           myJob,
    RedisHost:     "localhost:6379",
    RedisPassword: "myRedisPassword", //remove this line if no pass (AUTH)
}
err := job.Run(context.Background())
if err != nil {
    log.Fatalf("Error: %s", err)
}
GoInterLock is using go-redis for Redis Connection.


This content originally appeared on DEV Community and was authored by Jay Ehsaniara


Print Share Comment Cite Upload Translate Updates
APA

Jay Ehsaniara | Sciencx (2021-08-01T02:32:40+00:00) Go Task Scheduler with Distributed Lock. Retrieved from https://www.scien.cx/2021/08/01/go-task-scheduler-with-distributed-lock/

MLA
" » Go Task Scheduler with Distributed Lock." Jay Ehsaniara | Sciencx - Sunday August 1, 2021, https://www.scien.cx/2021/08/01/go-task-scheduler-with-distributed-lock/
HARVARD
Jay Ehsaniara | Sciencx Sunday August 1, 2021 » Go Task Scheduler with Distributed Lock., viewed ,<https://www.scien.cx/2021/08/01/go-task-scheduler-with-distributed-lock/>
VANCOUVER
Jay Ehsaniara | Sciencx - » Go Task Scheduler with Distributed Lock. [Internet]. [Accessed ]. Available from: https://www.scien.cx/2021/08/01/go-task-scheduler-with-distributed-lock/
CHICAGO
" » Go Task Scheduler with Distributed Lock." Jay Ehsaniara | Sciencx - Accessed . https://www.scien.cx/2021/08/01/go-task-scheduler-with-distributed-lock/
IEEE
" » Go Task Scheduler with Distributed Lock." Jay Ehsaniara | Sciencx [Online]. Available: https://www.scien.cx/2021/08/01/go-task-scheduler-with-distributed-lock/. [Accessed: ]
rf:citation
» Go Task Scheduler with Distributed Lock | Jay Ehsaniara | Sciencx | https://www.scien.cx/2021/08/01/go-task-scheduler-with-distributed-lock/ |

Please log in to upload a file.



There are no updates yet.
Click the Upload button above to add an update.

You must be logged in to translate posts. Please log in or register.

Related Posts