stats

Documentation

Index

• 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)
  • func (m *Monitor) EgressStarted(req *rpc.StartEgressRequest)
  • func (m *Monitor) GetCPUHold() float64
  • func (m *Monitor) GetCPULoad() float64
  • func (m *Monitor) Start(conf *config.ServiceConfig, isAvailable func() float64) error

Types

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)

func (*Monitor) EgressStarted

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

func (*Monitor) GetCPUHold

func (m *Monitor) GetCPUHold() float64

func (*Monitor) GetCPULoad

func (m *Monitor) GetCPULoad() float64

func (*Monitor) Start

func (m *Monitor) Start(conf *config.ServiceConfig, isAvailable func() float64) error