package main import ( "time" "github.com/go-redis/redis/v8" bolt "github.com/jojomak13/QueueBolt" ) func main() { queue := bolt.NewQueue(redis.Options{ Addr: "localhost:6379", }, 1) queue.Run() queue.Add(bolt.Job{ ID: "3248932489", Payload: "welcome jojo", ExecuteAt: time.Now().Add(time.Second * 2).Unix(), }) queue.Add(bolt.Job{ ID: "32489", Payload: "welcome jojo again", ExecuteAt: time.Now().Add(time.Second * 4).Unix(), }) select { // } }
-
Notifications
You must be signed in to change notification settings - Fork 0
jojomak13/QueueBolt
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Latest commit | ||||
Repository files navigation
About
No description, website, or topics provided.
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published