78 lines
1.8 KiB
Go
78 lines
1.8 KiB
Go
package observability
|
|
|
|
import (
|
|
"github.com/go-logr/logr"
|
|
|
|
"github.com/livekit/protocol/logger"
|
|
"github.com/livekit/protocol/observability/agentsobs"
|
|
"github.com/livekit/protocol/observability/egressobs"
|
|
"github.com/livekit/protocol/observability/gatewayobs"
|
|
"github.com/livekit/protocol/observability/ingressobs"
|
|
"github.com/livekit/protocol/observability/roomobs"
|
|
"github.com/livekit/protocol/observability/storageobs"
|
|
"github.com/livekit/protocol/observability/telephonycallobs"
|
|
"github.com/livekit/protocol/observability/telephonyobs"
|
|
)
|
|
|
|
const Project = "livekit"
|
|
|
|
var discardLogger = logger.LogRLogger(logr.Discard())
|
|
|
|
type Reporter interface {
|
|
Logger(projectID string) (logger.Logger, error)
|
|
Room() roomobs.Reporter
|
|
Agent() agentsobs.Reporter
|
|
Gateway() gatewayobs.Reporter
|
|
Telephony() telephonyobs.Reporter
|
|
Egress() egressobs.Reporter
|
|
Ingress() ingressobs.Reporter
|
|
TelephonyCall() telephonycallobs.Reporter
|
|
Storage() storageobs.Reporter
|
|
Close()
|
|
}
|
|
|
|
func NewReporter() Reporter {
|
|
return reporter{}
|
|
}
|
|
|
|
type reporter struct{}
|
|
|
|
func (reporter) Logger(projectID string) (logger.Logger, error) {
|
|
return discardLogger, nil
|
|
}
|
|
|
|
func (reporter) Room() roomobs.Reporter {
|
|
return roomobs.NewNoopReporter()
|
|
}
|
|
|
|
func (reporter) Agent() agentsobs.Reporter {
|
|
return agentsobs.NewNoopReporter()
|
|
}
|
|
|
|
func (reporter) Gateway() gatewayobs.Reporter {
|
|
return gatewayobs.NewNoopReporter()
|
|
}
|
|
|
|
func (reporter) Telephony() telephonyobs.Reporter {
|
|
return telephonyobs.NewNoopReporter()
|
|
}
|
|
|
|
func (reporter) Egress() egressobs.Reporter {
|
|
return egressobs.NewNoopReporter()
|
|
}
|
|
|
|
func (reporter) Ingress() ingressobs.Reporter {
|
|
return ingressobs.NewNoopReporter()
|
|
}
|
|
|
|
func (reporter) TelephonyCall() telephonycallobs.Reporter {
|
|
return telephonycallobs.NewNoopReporter()
|
|
}
|
|
|
|
func (reporter) Storage() storageobs.Reporter {
|
|
return storageobs.NewNoopReporter()
|
|
}
|
|
|
|
func (reporter) Close() {
|
|
}
|