diff --git a/main/main.go b/main/main.go index 4b9470e..793eb7e 100644 --- a/main/main.go +++ b/main/main.go @@ -4,6 +4,8 @@ import ( "context" "gitea.timerzz.com/kedaya_haitao/common/pkg/database" "gitea.timerzz.com/kedaya_haitao/common/pkg/proxy" + "gitea.timerzz.com/kedaya_haitao/pusher/rpc/pusher" + "github.com/cloudwego/kitex/client" "github.com/gofiber/fiber/v3" "github.com/gofiber/fiber/v3/middleware/cors" "github.com/golang/glog" @@ -34,6 +36,8 @@ func main() { watcherCtl := watcher.NewController(ctx, db, pool) + pusher.InitClient("pusher", client.WithHostPorts("pusher:8080")) + r := fiber.New() r.Use(cors.New())