yukari

Documentation

Index

• Variables
• func Scheduler(OKASAN_SCHEDULERS map[string]*OkasanScheduler)
• type KodomoScheduler
  • func NewKodomoScheduler(name string, sleepTime int8) *KodomoScheduler
• type OkasanScheduler
  • func NewOkasanScheduler(name string, sleepTime int8) *OkasanScheduler
• type StopChan
  • func NewStopChan() *StopChan
  • func (s *StopChan) Stop()

Variables

var (
	NODENAMES         = miporin.GetNodenames()
	CLIENTSET         = miporin.GetClientSet()
	DYNCLIENT         = miporin.GetDynamicClient()
	MAXPON            = []int{10, 10, 3}
	OKASAN_SCRAPERS   = map[string]*scraper.OkasanScraper{}
	OKASAN_SCHEDULERS = map[string]*OkasanScheduler{}
)

Functions

func Scheduler

func Scheduler(OKASAN_SCHEDULERS map[string]*OkasanScheduler)

Types

type KodomoScheduler

type KodomoScheduler struct {
	Name     string
	Decision map[string]int32

	Okasan       *OkasanScheduler
	ScheduleStop *StopChan
	// contains filtered or unexported fields
}

func NewKodomoScheduler

func NewKodomoScheduler(
	name string, sleepTime int8,
) *KodomoScheduler

type OkasanScheduler

type OkasanScheduler struct {
	Name string

	Kodomo      map[string]*KodomoScheduler
	MaxPoN      map[string]int32
	KPADecision map[string]map[string]int32
	// contains filtered or unexported fields
}

func NewOkasanScheduler

func NewOkasanScheduler(
	name string,
	sleepTime int8,
) *OkasanScheduler

type StopChan

type StopChan struct {
	Kodomo chan bool
	Okasan chan bool
}

func NewStopChan

func NewStopChan() *StopChan

func (*StopChan) Stop

func (s *StopChan) Stop()