resource

Documentation

Index

• func Slice(comp *apiv1.Composition, previous []*apiv1.ResourceSlice, ...) ([]*apiv1.ResourceSlice, error)
• type ManifestRef
• type Ref
• type Resource
  • func NewResource(ctx context.Context, renv *readiness.Env, slice *apiv1.ResourceSlice, ...) (*Resource, error)
  • func (r *Resource) Deleted() bool
  • func (r *Resource) FindStatus(slice *apiv1.ResourceSlice) *apiv1.ResourceState
  • func (l *Resource) HasBeenSeen() bool
  • func (l *Resource) MatchesLastSeen(rv string) bool
  • func (r *Resource) NeedsToBePatched(current *unstructured.Unstructured) bool
  • func (l *Resource) ObserveReconciliation() time.Duration
  • func (l *Resource) ObserveVersion(rv string)
  • func (r *Resource) Parse() (*unstructured.Unstructured, error)

Functions

func Slice

func Slice(comp *apiv1.Composition, previous []*apiv1.ResourceSlice, outputs []*unstructured.Unstructured, maxJsonBytes int) ([]*apiv1.ResourceSlice, error)

Slice builds a new set of resource slices by merging a new set of resources onto an old set of slices. - New and updated resources are partitioned across slices per maxJsonBytes - Removed resources are converted into "tombstones" i.e. manifests with Deleted == true

Types

type ManifestRef

type ManifestRef struct {
	Slice types.NamespacedName
	Index int // position of this manifest within the slice
}

ManifestRef references a particular resource manifest within a resource slice.

type Ref

type Ref struct {
	Name, Namespace, Group, Kind string
}

Ref refers to a specific synthesized resource.

type Resource

type Resource struct {
	Ref               Ref
	Manifest          *apiv1.Manifest
	ManifestRef       ManifestRef
	ReconcileInterval *metav1.Duration
	GVK               schema.GroupVersionKind
	SliceDeleted      bool
	ReadinessChecks   readiness.Checks
	Patch             jsonpatch.Patch
	DisableUpdates    bool
	ReadinessGroup    uint

	// DefinedGroupKind is set on CRDs to represent the resource type they define.
	DefinedGroupKind *schema.GroupKind
	// contains filtered or unexported fields
}

Resource is the controller's internal representation of a single resource out of a ResourceSlice.

func NewResource

func NewResource(ctx context.Context, renv *readiness.Env, slice *apiv1.ResourceSlice, index int) (*Resource, error)

func (*Resource) Deleted

func (r *Resource) Deleted() bool

func (*Resource) FindStatus

func (r *Resource) FindStatus(slice *apiv1.ResourceSlice) *apiv1.ResourceState

func (*Resource) HasBeenSeen

func (l *Resource) HasBeenSeen() bool

func (*Resource) MatchesLastSeen

func (l *Resource) MatchesLastSeen(rv string) bool

func (*Resource) NeedsToBePatched

func (r *Resource) NeedsToBePatched(current *unstructured.Unstructured) bool

func (*Resource) ObserveReconciliation

func (l *Resource) ObserveReconciliation() time.Duration

func (*Resource) ObserveVersion

func (l *Resource) ObserveVersion(rv string)

func (*Resource) Parse

func (r *Resource) Parse() (*unstructured.Unstructured, error)