nrtupdater

Documentation

Index

• Constants
• type Args
• type MonitorInfo
  • func (mi MonitorInfo) UpdateReason() string
• type NRTUpdater
  • func NewNRTUpdater(args Args, tmconf TMConfig) *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
• type TMConfig
  • func (conf TMConfig) IsValid() bool

Constants

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

Types

type Args

type Args struct {
	NoPublish bool
	Oneshot   bool
	Hostname  string
}

Command line arguments

type MonitorInfo

type MonitorInfo struct {
	Timer       bool
	Zones       v1alpha2.ZoneList
	Attributes  v1alpha2.AttributeList
	Annotations map[string]string
}

func (MonitorInfo) UpdateReason

func (mi MonitorInfo) UpdateReason() string

type NRTUpdater

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

func NewNRTUpdater

func NewNRTUpdater(args Args, tmconf TMConfig) *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

type TMConfig

type TMConfig struct {
	Policy string
	Scope  string
}

func (TMConfig) IsValid

func (conf TMConfig) IsValid() bool