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.
type StatusPatchFn ¶
type StatusPatchFn func(*apiv1.ResourceState) *apiv1.ResourceState
Click to show internal directories.
Click to hide internal directories.