nrtupdater

Documentation

Index

• Constants
• type Args
• type MonitorInfo
  • func (mi MonitorInfo) UpdateReason() string
• type NRTUpdater
  • func NewNRTUpdater(args Args, policy string) *NRTUpdater
  • func (te *NRTUpdater) Run(infoChannel <-chan MonitorInfo, condChan chan v1.PodCondition)
  • func (te *NRTUpdater) Stop()
  • func (te *NRTUpdater) Update(info MonitorInfo) error
  • func (te *NRTUpdater) UpdateWithClient(cli topologyclientset.Interface, info MonitorInfo) error

Constants

const (
	RTEUpdatePeriodic = "periodic"
	RTEUpdateReactive = "reactive"
)

const (
	AnnotationRTEUpdate = "k8stopoawareschedwg/rte-update"
)

Types

type Args

type Args struct {
	NoPublish bool
	Oneshot   bool
	Hostname  string
}

Command line arguments

type MonitorInfo

type MonitorInfo struct {
	Timer bool
	Zones v1alpha1.ZoneList
}

func (MonitorInfo) UpdateReason

func (mi MonitorInfo) UpdateReason() string

type NRTUpdater

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

func NewNRTUpdater

func NewNRTUpdater(args Args, policy string) *NRTUpdater

func (*NRTUpdater) Run

func (te *NRTUpdater) Run(infoChannel <-chan MonitorInfo, condChan chan v1.PodCondition)

func (*NRTUpdater) Stop

func (te *NRTUpdater) Stop()

func (*NRTUpdater) Update

func (te *NRTUpdater) Update(info MonitorInfo) error

func (*NRTUpdater) UpdateWithClient

func (te *NRTUpdater) UpdateWithClient(cli topologyclientset.Interface, info MonitorInfo) error