stats

package
v1.15.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 6, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ResultCompleted         = "completed"
	ResultAborted           = "aborted"
	ResultStoppedCPU        = "stopped_cpu"
	ResultKilledCPU         = "killed_cpu"
	ResultKilledOOM         = "killed_oom"
	ResultKilledShutdown    = "killed_shutdown"
	ResultProcessError      = "process_error"
	ResultDuplicateIdentity = "duplicate_identity"
)

Handler-level results (livekit_egress_handler_results_total)

View Source 
const HandlerMetricPrefix = "livekit_egress_"

HandlerMetricPrefix is the family-name prefix of every metric a handler exports to the service. Families outside it belong to linked libraries and stay inside the handler process.

Variables

This section is empty.

Functions

func FilterHandlerFamilies added in v1.15.0 

func FilterHandlerFamilies(in []*dto.MetricFamily) []*dto.MetricFamily

FilterHandlerFamilies keeps the families a handler owns. The service merges handler families across processes and cannot merge foreign gauges that share a label set, so nothing outside HandlerMetricPrefix is exported.

Types

type HandlerMonitor added in v1.8.1 

type HandlerMonitor struct {
	// contains filtered or unexported fields
}

func NewHandlerMonitor added in v1.8.1 

func NewHandlerMonitor(nodeID, clusterID string) *HandlerMonitor

func (*HandlerMonitor) IncBackupStorageWrites added in v1.8.1 

func (m *HandlerMonitor) IncBackupStorageWrites(outputType string)

func (*HandlerMonitor) IncUploadCountFailure added in v1.8.1 

func (m *HandlerMonitor) IncUploadCountFailure(uploadType string, status string, hasCustomEndpoint bool, elapsed float64)

func (*HandlerMonitor) IncUploadCountSuccess added in v1.8.1 

func (m *HandlerMonitor) IncUploadCountSuccess(uploadType string, hasCustomEndpoint bool, elapsed float64)

func (*HandlerMonitor) RegisterPlaylistChannelSizeGauge added in v1.8.1 

func (m *HandlerMonitor) RegisterPlaylistChannelSizeGauge(nodeID, clusterID, egressID string, channelSizeFunction func() float64)

func (*HandlerMonitor) RegisterSegmentsChannelSizeGauge added in v1.8.1 

func (m *HandlerMonitor) RegisterSegmentsChannelSizeGauge(nodeID, clusterID, egressID string, channelSizeFunction func() float64)

type Monitor 

type Monitor struct {
	// contains filtered or unexported fields
}

func NewMonitor 

func NewMonitor(conf *config.ServiceConfig, svc Service) (*Monitor, error)

func (*Monitor) AcceptRequest 

func (m *Monitor) AcceptRequest(req *rpc.StartEgressRequest) error

func (*Monitor) CanAcceptRequest 

func (m *Monitor) CanAcceptRequest(req *rpc.StartEgressRequest) bool

func (*Monitor) CanAcceptWebRequest added in v1.8.6 

func (m *Monitor) CanAcceptWebRequest() bool

func (*Monitor) EgressAborted added in v1.7.5 

func (m *Monitor) EgressAborted(req *rpc.StartEgressRequest)

func (*Monitor) EgressEnded 

func (m *Monitor) EgressEnded(req *rpc.StartEgressRequest) (float64, float64, int)

func (*Monitor) EgressStarted 

func (m *Monitor) EgressStarted(req *rpc.StartEgressRequest)

func (*Monitor) GetAvailableCPU added in v1.8.3 

func (m *Monitor) GetAvailableCPU() float64

func (*Monitor) GetAvailableMemory added in v1.10.0 

func (m *Monitor) GetAvailableMemory() float64

func (*Monitor) HandlerResult added in v1.13.0 

func (m *Monitor) HandlerResult(egressID string, result string)

func (*Monitor) SetPulseSinkReapGraceSec added in v1.14.0 

func (m *Monitor) SetPulseSinkReapGraceSec(graceSec int)

SetPulseSinkReapGraceSec applies an updated reap grace, taking effect on the reaper's next tick. A non-positive grace disables reaping.

func (*Monitor) UpdatePID added in v1.8.1 

func (m *Monitor) UpdatePID(egressID string, pid int)

type Service added in v1.8.4 

type Service interface {
	IsIdle() bool
	IsDisabled() bool
	IsTerminating() bool
	StopProcess(egressID string, reason string)
	KillProcess(egressID string, reason string, err error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.