flowcontrol

package
v0.0.48 Latest Latest
Warning

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

Go to latest
Published: Feb 21, 2025 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ResourceSliceWriteBuffer

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

ResourceSliceWriteBuffer reduces load on etcd/apiserver by collecting resource slice status updates over a short period of time and applying them in a single patch request.

func NewResourceSliceWriteBuffer

func NewResourceSliceWriteBuffer(cli client.Client) *ResourceSliceWriteBuffer

func NewResourceSliceWriteBufferForManager

func NewResourceSliceWriteBufferForManager(mgr ctrl.Manager) *ResourceSliceWriteBuffer

func (*ResourceSliceWriteBuffer) PatchStatusAsync

func (w *ResourceSliceWriteBuffer) PatchStatusAsync(ctx context.Context, ref *resource.ManifestRef, patchFn StatusPatchFn)

PatchStatusAsync returns after enqueueing the given status update. The update will eventually be applied, or dropped only if the slice is deleted.

func (*ResourceSliceWriteBuffer) Start

type StatusPatchFn

type StatusPatchFn func(*apiv1.ResourceState) *apiv1.ResourceState

Jump to

Keyboard shortcuts

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