flowcontrol

Documentation

Index

• type ResourceSliceWriteBuffer
  • 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 *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, batchInterval time.Duration, burst int) *ResourceSliceWriteBuffer

func NewResourceSliceWriteBufferForManager

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

func (*ResourceSliceWriteBuffer) PatchStatusAsync

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

func (*ResourceSliceWriteBuffer) Start

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

type StatusPatchFn

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