mo

Documentation

Index

• type DataSource
• type Monitor
  • func NewMonitor(dataSource DataSource) *Monitor
  • func (mo *Monitor) Monitor(duration time.Duration) *Snapshot
• type Snapshot

Types

type DataSource

type DataSource interface {
	GetTotalConsumer() map[string]uint64
	GetTotalConn() uint64
	GetTotalTopic() uint64
	GetMessageIn() uint64
	GetMessageOut() uint64
}

DataSource DataSource

type Monitor

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

Monitor Monitor

func NewMonitor

func NewMonitor(dataSource DataSource) *Monitor

NewMonitor NewMonitor

func (*Monitor) Monitor

func (mo *Monitor) Monitor(duration time.Duration) *Snapshot

Monitor Monitor

type Snapshot

type Snapshot struct {
	CPUPercent        float64
	MemPercent        float64
	AverageNetIn      uint64
	AverageNetOut     uint64
	Thread            uint64
	Goroutine         uint64
	TotalConn         uint64
	TotalTopic        uint64
	TotalConsumer     uint64
	MaxConsumer       uint64
	TotalMessageIn    uint64
	AverageMessageIn  uint64
	TotalMessageOut   uint64
	AverageMessageOut uint64
}

Snapshot Snapshot