Add PSRPC observability to IOInfoClient (#1056)

Author: biglittlebigben

pkg/config/service.go

@@ -19,10 +19,12 @@ import (
 	"os"
 	"time"
 
+	"github.com/prometheus/client_golang/prometheus"
 	"gopkg.in/yaml.v3"
 
 	"github.com/livekit/egress/pkg/errors"
 	"github.com/livekit/protocol/logger"
+	"github.com/livekit/protocol/rpc"
 	"github.com/livekit/protocol/utils"
 )
 
@@ -102,6 +104,8 @@ func NewServiceConfig(confString string) (*ServiceConfig, error) {
 	conf.NodeID = utils.NewGuid("NE_")
 	conf.InitDefaults()
 
+	rpc.InitPSRPCStats(prometheus.Labels{"node_id": conf.NodeID, "node_type": "EGRESS"})
+
 	if err := conf.initLogger("nodeID", conf.NodeID, "clusterID", conf.ClusterID); err != nil {
 		return nil, err
 	}

pkg/info/io.go

@@ -72,7 +72,7 @@ type update struct {
 }
 
 func NewIOClient(conf *config.BaseConfig, bus psrpc.MessageBus) (IOClient, error) {
-	client, err := rpc.NewIOInfoClient(bus)
+	client, err := rpc.NewIOInfoClient(bus, rpc.WithClientObservability(logger.GetLogger()))
 	if err != nil {
 		return nil, err
 	}