v0.16.0 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Nov 4, 2023 License: Apache-2.0 Imports: 12 Imported by: 0




This section is empty.


This section is empty.


func NodeFromOpts

func NodeFromOpts(t agent.Target) *v1.Node


type NodeProvider added in v0.11.0

type NodeProvider struct {
	// contains filtered or unexported fields

NodeProvider accepts a callback from virtual-kubelet's node controller, and exposes it to our upstream resources controller, for node status updates. If we updated node status directly, without informing virtual-kubelet, virtual-kubelet would override our changes every minute (with node leases enabled; more often otherwise); which would trigger a reconcile on our end, and another override on vk's end, etc. (controllers disagreeing). When virtual-kubelet is notified of what we think the node status should be, it keeps it in memory, and call kube-apiserver on our behalf.

func (*NodeProvider) NotifyNodeStatus added in v0.11.0

func (p *NodeProvider) NotifyNodeStatus(ctx context.Context, cb func(*corev1.Node))

func (*NodeProvider) Ping added in v0.11.0

func (p *NodeProvider) Ping(ctx context.Context) error

func (*NodeProvider) UpdateNodeStatus added in v0.11.0

func (p *NodeProvider) UpdateNodeStatus(node *corev1.Node)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL