-
-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* Update README.md * feat: outlink to production example * feat: gocron v2 example
- Loading branch information
1 parent
b7b8376
commit c1e48fe
Showing
5 changed files
with
109 additions
and
29 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
File renamed without changes.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,61 @@ | ||
| package main | ||
|
|
||
| import ( | ||
| "context" | ||
| "fmt" | ||
| "time" | ||
|
|
||
| elector "github.com/go-co-op/gocron-etcd-elector" | ||
| "github.com/go-co-op/gocron/v2" | ||
| ) | ||
|
|
||
| func main() { | ||
| // Printing some value to verify if container is running in docker logs | ||
| fmt.Println("go-app") | ||
|
|
||
| // Configuring elector with etdc cluster | ||
| cfg := elector.Config{ | ||
| Endpoints: []string{"http://etcd-1:2379", "http://etcd-2:2379", "http://etcd-3:2379"}, | ||
| DialTimeout: 3 * time.Second, | ||
| } | ||
|
|
||
| // Build new elector | ||
| el, err := elector.NewElector(context.Background(), cfg, elector.WithTTL(10)) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
|
|
||
| // el.Start() is a blocking method | ||
| // so running with goroutine | ||
| go func() { | ||
| err := el.Start("/rahul-gandhi/pappu") // specify a directory for storing key value for election | ||
| if err == elector.ErrClosed { | ||
| return | ||
| } | ||
| }() | ||
|
|
||
| // New scheduler with elector | ||
| sh, err := gocron.NewScheduler(gocron.WithDistributedElector(el)) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
|
|
||
| // The scheduler elected as the leader is only allowed to run, other instances don't execute | ||
| _, err = sh.NewJob(gocron.DurationJob(1*time.Second), gocron.NewTask(func() { | ||
| // This if statement doesn't work as intended as only the leader is running | ||
| // So true always | ||
| if el.IsLeader(context.Background()) == nil { | ||
| fmt.Println("Current instance is leader") | ||
| fmt.Println("executing job") | ||
| } else { | ||
| // To see this log printed remove gocron.WithDistributedElector(el) option from the scheduler | ||
| fmt.Printf("Not leader, current leader is %s\n", el.GetLeaderID()) | ||
| } | ||
| })) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
|
|
||
| sh.Start() | ||
| fmt.Println("exit") | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters