queues

Documentation

Index

• func AddNewNodeToTheQueue(ip net.IPAddr)
• func CountOfActiveNodes() int
• func FindNotActiveNodes() []net.IPAddr
• func FindTheMostNonOverloadedNode() net.IPAddr
• func ReleaseNode(ip net.IPAddr)
• type QueueDB

Functions

func AddNewNodeToTheQueue

func AddNewNodeToTheQueue(ip net.IPAddr)

func CountOfActiveNodes

func CountOfActiveNodes() int

func FindNotActiveNodes

func FindNotActiveNodes() []net.IPAddr

func FindTheMostNonOverloadedNode

func FindTheMostNonOverloadedNode() net.IPAddr

func ReleaseNode

func ReleaseNode(ip net.IPAddr)

Types

type QueueDB

type QueueDB interface {
	GetIP() net.IPAddr
	Insert(ip net.IPAddr) error
	SelectCountOfActive() (int, error)
	SelectNotActive() ([]net.IPAddr, error)
	SelectTheMostNotLoaded() error
	UpdateActiveJobsCount(ip net.IPAddr) error
}