ports

Documentation

Index

• Variables
• func AddNewPortCollect(newCollect map[int]*models.PortCollect)
• func DelNoPortCollect(newCollect map[int]*models.PortCollect)
• func Detect()
• func PortCollect(p *models.PortCollect)
• type PortScheduler
  • func NewPortScheduler(p *models.PortCollect) *PortScheduler
  • func (p *PortScheduler) Schedule()
  • func (p *PortScheduler) Stop()

Variables

var (
	Ports              = make(map[int]*models.PortCollect)
	PortsWithScheduler = make(map[int]*PortScheduler)
)

Functions

func AddNewPortCollect

func AddNewPortCollect(newCollect map[int]*models.PortCollect)

func DelNoPortCollect

func DelNoPortCollect(newCollect map[int]*models.PortCollect)

func Detect

func Detect()

func PortCollect

func PortCollect(p *models.PortCollect)

Types

type PortScheduler

type PortScheduler struct {
	Ticker *time.Ticker
	Port   *models.PortCollect
	Quit   chan struct{}
}

func NewPortScheduler

func NewPortScheduler(p *models.PortCollect) *PortScheduler

func (*PortScheduler) Schedule

func (p *PortScheduler) Schedule()

func (*PortScheduler) Stop

func (p *PortScheduler) Stop()