Skip to content

Commit c8871c4

Browse files
authored
add client observability middleware helper (#970)
1 parent 81a3dfb commit c8871c4

2 files changed

Lines changed: 8 additions & 1 deletion

File tree

logger/logger.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -418,7 +418,7 @@ func (l *zapLogger[T]) WithoutSampler() Logger {
418418
func (l *zapLogger[T]) WithDeferredValues() (Logger, DeferredFieldResolver) {
419419
dup := *l
420420
def, resolve := zaputil.NewDeferrer()
421-
dup.deferred = append(dup.deferred, def)
421+
dup.deferred = append(dup.deferred[0:len(dup.deferred):len(dup.deferred)], def)
422422
dup.zap = dup.makeZap()
423423
return &dup, resolve
424424
}

rpc/typed_api.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -100,6 +100,13 @@ func WithDefaultServerOptions(psrpcConfig PSRPCConfig, logger logger.Logger) psr
100100
)
101101
}
102102

103+
func WithClientObservability(logger logger.Logger) psrpc.ClientOption {
104+
return psrpc.WithClientOptions(
105+
middleware.WithClientMetrics(PSRPCMetricsObserver{}),
106+
WithClientLogger(logger),
107+
)
108+
}
109+
103110
//go:generate go run github.com/maxbrunsfeld/counterfeiter/v6 -generate
104111

105112
type TypedSignalClient = SignalClient[livekit.NodeID]

0 commit comments

Comments
 (0)