flowcontrol

type ResourceSliceStatusUpdate ¶

type ResourceSliceStatusUpdate struct {
	SlicedResource *reconstitution.ManifestRef
	PatchFn        StatusPatchFn
}

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(cli client.Client, batchInterval time.Duration, burst int) *ResourceSliceWriteBuffer

func NewResourceSliceWriteBufferForManager(mgr ctrl.Manager, batchInterval time.Duration, burst int) *ResourceSliceWriteBuffer

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

func (w *ResourceSliceWriteBuffer) Start(ctx context.Context) error

type StatusPatchFn ¶

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