diff --git a/goutils b/goutils index 480773ef..be5938f4 160000 --- a/goutils +++ b/goutils @@ -1 +1 @@ -Subproject commit 480773ef00a31230f961cbb76e273ac82ad77849 +Subproject commit be5938f43cf04c6171a67b7124d47a03986908bc diff --git a/internal/entrypoint/entrypoint.go b/internal/entrypoint/entrypoint.go index 15b15dbb..4bd1b1c3 100644 --- a/internal/entrypoint/entrypoint.go +++ b/internal/entrypoint/entrypoint.go @@ -66,8 +66,8 @@ func NewEntrypoint(parent task.Parent, cfg *Config) *Entrypoint { cfg: cfg, findRouteFunc: findRouteAnyDomain, shortLinkMatcher: newShortLinkMatcher(), - streamRoutes: pool.New[types.StreamRoute]("stream_routes"), - excludedRoutes: pool.New[types.Route]("excluded_routes"), + streamRoutes: pool.New[types.StreamRoute]("stream_routes", "stream_routes"), + excludedRoutes: pool.New[types.Route]("excluded_routes", "excluded_routes"), servers: xsync.NewMap[string, *httpServer](), } return ep diff --git a/internal/entrypoint/http_server.go b/internal/entrypoint/http_server.go index 01475a1f..553b5420 100644 --- a/internal/entrypoint/http_server.go +++ b/internal/entrypoint/http_server.go @@ -80,7 +80,7 @@ func (srv *httpServer) Listen(addr string, proto HTTPProto) error { } srv.stopFunc = task.FinishAndWait srv.addr = addr - srv.routes = pool.New[types.HTTPRoute](fmt.Sprintf("[%s] %s", proto, addr)) + srv.routes = pool.New[types.HTTPRoute](fmt.Sprintf("[%s] %s", proto, addr), "http_routes") srv.routes.DisableLog(srv.ep.httpPoolDisableLog.Load()) return nil } diff --git a/internal/net/gphttp/loadbalancer/loadbalancer.go b/internal/net/gphttp/loadbalancer/loadbalancer.go index ee271cad..6a8477ec 100644 --- a/internal/net/gphttp/loadbalancer/loadbalancer.go +++ b/internal/net/gphttp/loadbalancer/loadbalancer.go @@ -48,7 +48,7 @@ const maxWeight int = 100 func New(cfg *types.LoadBalancerConfig) *LoadBalancer { lb := &LoadBalancer{ LoadBalancerConfig: cfg, - pool: pool.New[types.LoadBalancerServer]("loadbalancer." + cfg.Link), + pool: pool.New[types.LoadBalancerServer]("loadbalancer."+cfg.Link, "loadbalancers"), l: log.With().Str("name", cfg.Link).Logger(), } lb.UpdateConfigIfNeeded(cfg) diff --git a/internal/proxmox/node.go b/internal/proxmox/node.go index 7b6e0a95..e78d810e 100644 --- a/internal/proxmox/node.go +++ b/internal/proxmox/node.go @@ -42,7 +42,7 @@ func (n *NodeConfig) Validate() error { return errs.Error() } -var Nodes = pool.New[*Node]("proxmox_nodes") +var Nodes = pool.New[*Node]("proxmox_nodes", "proxmox_node") func NewNode(client *Client, name, id string) *Node { return &Node{