Documentation ¶
Overview ¶
Example ¶
例子
package main import ( "delayer-client-golang/delayer" "github.com/gomodule/redigo/redis" ) func main() { // 通过连接信息创建客户端 cli := delayer.Client{ Host: "127.0.0.1", Port: "6379", Database: 0, Password: "", } cli.Init() // 通过已有连接创建客户端 pool := redis.Pool{} conn := pool.Get() cli1 := delayer.Client{ Conn: conn, } cli1.Init() }
Output:
Index ¶
Examples ¶
Constants ¶
View Source
const ( KEY_JOB_POOL = "delayer:job_pool" PREFIX_JOB_BUCKET = "delayer:job_bucket:" PREFIX_READY_QUEUE = "delayer:ready_queue:" )
键名
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
客户端结构
func (*Client) BPop ¶
阻塞取出任务
Example ¶
BPop 例子
package main import ( "delayer-client-golang/delayer" "fmt" ) func main() { cli := delayer.Client{ Host: "127.0.0.1", Port: "6379", Database: 0, Password: "", } cli.Init() msg, err := cli.BPop("test", 10) fmt.Println(msg) fmt.Println(err) }
Output:
func (*Client) Pop ¶
取出任务
Example ¶
Pop 例子
package main import ( "delayer-client-golang/delayer" "fmt" ) func main() { cli := delayer.Client{ Host: "127.0.0.1", Port: "6379", Database: 0, Password: "", } cli.Init() msg, err := cli.Pop("test") fmt.Println(msg) fmt.Println(err) }
Output:
func (*Client) Push ¶
增加任务
Example ¶
Push 例子
package main import ( "crypto/md5" "delayer-client-golang/delayer" "fmt" "time" ) func main() { cli := delayer.Client{ Host: "127.0.0.1", Port: "6379", Database: 0, Password: "", } cli.Init() msg := delayer.Message{ ID: fmt.Sprintf("%x", md5.Sum([]byte(time.Now().String()))), Topic: "test", Body: "test body", } reply, err := cli.Push(msg, 10, 600) fmt.Println(msg) fmt.Println(reply) fmt.Println(err) }
Output:
func (*Client) Remove ¶
移除任务
Example ¶
Remove 例子
package main import ( "delayer-client-golang/delayer" "fmt" ) func main() { cli := delayer.Client{ Host: "127.0.0.1", Port: "6379", Database: 0, Password: "", } cli.Init() ok, err := cli.Remove("9a8482a06630840ce7da9da62d748b8a") fmt.Println(ok) fmt.Println(err) }
Output:
Click to show internal directories.
Click to hide internal directories.