stats

Documentation

Index

• type HandlerMonitor
  • 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, ...)
  • func (m *HandlerMonitor) RegisterSegmentsChannelSizeGauge(nodeId string, clusterId string, egressId string, ...)
• type Monitor
  • func NewMonitor(conf *config.ServiceConfig) *Monitor
  • func (m *Monitor) AcceptRequest(req *rpc.StartEgressRequest) error
  • func (m *Monitor) CanAcceptRequest(req *rpc.StartEgressRequest) 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) GetCPULoad() float64
  • func (m *Monitor) GetRequestCount() int
  • func (m *Monitor) Start(conf *config.ServiceConfig, isIdle func() float64, ...) error
  • func (m *Monitor) UpdatePID(egressID string, pid int)

Types

type HandlerMonitor

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

func NewHandlerMonitor

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

func (*HandlerMonitor) IncBackupStorageWrites

func (m *HandlerMonitor) IncBackupStorageWrites(outputType string)

func (*HandlerMonitor) IncUploadCountFailure

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

func (*HandlerMonitor) IncUploadCountSuccess

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

func (*HandlerMonitor) RegisterPlaylistChannelSizeGauge

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

func (*HandlerMonitor) RegisterSegmentsChannelSizeGauge

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

type Monitor

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

func NewMonitor

func NewMonitor(conf *config.ServiceConfig) *Monitor

func (*Monitor) AcceptRequest

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

func (*Monitor) CanAcceptRequest

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

func (*Monitor) EgressAborted

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

func (*Monitor) EgressEnded

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

func (*Monitor) EgressStarted

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

func (*Monitor) GetAvailableCPU

func (m *Monitor) GetAvailableCPU() float64

func (*Monitor) GetCPULoad

func (m *Monitor) GetCPULoad() float64

func (*Monitor) GetRequestCount

func (m *Monitor) GetRequestCount() int

func (*Monitor) Start

func (m *Monitor) Start(
	conf *config.ServiceConfig,
	isIdle func() float64,
	canAcceptRequest func() float64,
	isDisabled func() float64,
	killProcess func(string, float64),
) error

func (*Monitor) UpdatePID

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