feat: kq support trace

Author: MarkJoyMa

example/kq/consumer/queue.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"context"
 	"fmt"
 
 	"github.com/zeromicro/go-queue/kq"
@@ -11,7 +12,7 @@ func main() {
 	var c kq.KqConf
 	conf.MustLoad("config.yaml", &c)
 
-	q := kq.MustNewQueue(c, kq.WithHandle(func(k, v string) error {
+	q := kq.MustNewQueue(c, kq.WithHandle(func(ctx context.Context, k, v string) error {
 		fmt.Printf("=> %s\n", v)
 		return nil
 	}))

example/kq/producer/produce.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"context"
 	"encoding/json"
 	"fmt"
 	"log"
@@ -41,7 +42,7 @@ func main() {
 		}
 
 		fmt.Println(string(body))
-		if err := pusher.Push(string(body)); err != nil {
+		if err := pusher.Push(context.Background(), string(body)); err != nil {
 			log.Fatal(err)
 		}
 	}