stats

package

v1.8.6 Latest Latest Go to latest Published: Aug 19, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewHandlerMonitor(nodeId string, clusterId string, egressId string) *HandlerMonitor

func (m *HandlerMonitor) IncBackupStorageWrites(outputType string)

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

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

func (m *HandlerMonitor) RegisterPlaylistChannelSizeGauge(nodeId string, clusterId string, egressId string, channelSizeFunction func() float64)

func (m *HandlerMonitor) RegisterSegmentsChannelSizeGauge(nodeId string, clusterId string, egressId string, channelSizeFunction func() float64)

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

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

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

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

func (m *Monitor) CanAcceptWebRequest() bool

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

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

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

func (m *Monitor) GetAvailableCPU() float64

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

type Service interface {
	IsIdle() bool
	IsDisabled() bool
	IsTerminating() bool
	KillProcess(string, float64)
}