util

Documentation

Index

• Constants
• func ParallelizeSyncNode(ctx context.Context, workers int, nodelist []*v1.Node, ...)
• func PatchNodeStatus(c v1core.CoreV1Interface, nodeName types.NodeName, oldNode *v1.Node, ...) (*v1.Node, []byte, error)
• type Ops
• type Patch
  • func (p *Patch) Data(obj runtime.Object) ([]byte, error)
  • func (p Patch) Type() types.PatchType

Constants

const Workers = 5

Functions

func ParallelizeSyncNode

func ParallelizeSyncNode(ctx context.Context, workers int, nodelist []*v1.Node, Do func(ctx context.Context, node *v1.Node))

func PatchNodeStatus

func PatchNodeStatus(c v1core.CoreV1Interface, nodeName types.NodeName, oldNode *v1.Node, newNode *v1.Node) (*v1.Node, []byte, error)

PatchNodeStatus patches node status.

Types

type Ops

type Ops struct {
	Op    string      `json:"op,omitempty"`
	Path  string      `json:"path"`
	Value interface{} `json:"value,omitempty"`
}

type Patch

type Patch struct {
	PatchOps []Ops
}

func (*Patch) Data

func (p *Patch) Data(obj runtime.Object) ([]byte, error)

func (Patch) Type

func (p Patch) Type() types.PatchType