flowcontrol

Documentation

Index

• type ResourceSliceWriteBuffer
  • func NewResourceSliceWriteBuffer(cli client.Client) *ResourceSliceWriteBuffer
  • func NewResourceSliceWriteBufferForManager(mgr ctrl.Manager) *ResourceSliceWriteBuffer
  • func (w *ResourceSliceWriteBuffer) PatchStatusAsync(ctx context.Context, ref *resource.ManifestRef, patchFn StatusPatchFn)
  • func (w *ResourceSliceWriteBuffer) Start(ctx context.Context) error
• type StatusPatchFn

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

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

type StatusPatchFn

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