nrtupdater

package

v0.15.3 Latest Latest Go to latest Published: Jan 16, 2024 License: Apache-2.0 Imports: 16 Imported by: 4

Documentation ¶

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

View Source

var NotConfigured = errors.New("unconfigured feature")

This section is empty.

type Args struct {
	NoPublish bool
	Oneshot   bool
	Hostname  string
}

Command line arguments

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

func NewCachedNodeGetter(k8sInterface kubernetes.Interface, ctx context.Context) (*CachedNodeGetter, error)

func (ng *CachedNodeGetter) Get(ctx context.Context, nodeName string, _ metav1.GetOptions) (*corev1.Node, error)

type ConnectionError struct {
	Err error
}

func (err ConnectionError) Error() string

func (err ConnectionError) Unwrap() error

type DisabledNodeGetter struct {
}

func (ng *DisabledNodeGetter) Get(ctx context.Context, nodeName string, opts metav1.GetOptions) (*corev1.Node, error)

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

func (mi MonitorInfo) UpdateReason() string

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

func NewNRTUpdater(nodeGetter NodeGetter, 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 NodeGetter interface {
	Get(ctx context.Context, nodeName string, opts metav1.GetOptions) (*corev1.Node, error)
}

type NotFound struct {
	NodeName string
}

func (err NotFound) Error() string

type TMConfig struct {
	Policy string
	Scope  string
}

func (conf TMConfig) IsValid() bool

Path	Synopsis
fake