Documentation ¶
Index ¶
- Constants
- func ComputeHash(obj interface{}, collisionCount *int32) string
- func DeepHashObject(hasher hash.Hash, objectToWrite interface{})
- func ParseProbes(packageProbes []packagesv1alpha1.ObjectSetProbe) internalprobe.Interface
- func PausedObjectMatches(ppo packagesv1alpha1.ObjectSetPausedObject, obj client.Object) bool
- func TeardownPhase(ctx context.Context, c client.Client, owner PausingClientObject, ...) (cleanupDone bool, err error)
- func UnstructuredFromObjectObject(packageObject *packagesv1alpha1.ObjectSetObject) (*unstructured.Unstructured, error)
- type PausingClientObject
- type PhaseReconciler
Constants ¶
View Source
const ( CacheFinalizer = "packages.thetechnick.ninja/object-set-cache" ObjectSetLabelKey = "packages.thetechnick.ninja/object-set" )
Variables ¶
This section is empty.
Functions ¶
func ComputeHash ¶
ComputeHash returns a hash value calculated from pod template and a collisionCount to avoid hash collision. The hash will be safe encoded to avoid bad words.
func DeepHashObject ¶
DeepHashObject writes specified object to hash using the spew library which follows pointers and prints actual values of the nested objects ensuring the hash does not change when a pointer changes.
func ParseProbes ¶
func ParseProbes( packageProbes []packagesv1alpha1.ObjectSetProbe, ) internalprobe.Interface
func PausedObjectMatches ¶
func PausedObjectMatches(ppo packagesv1alpha1.ObjectSetPausedObject, obj client.Object) bool
func TeardownPhase ¶
func TeardownPhase( ctx context.Context, c client.Client, owner PausingClientObject, phase packagesv1alpha1.ObjectPhase, ) (cleanupDone bool, err error)
func UnstructuredFromObjectObject ¶
func UnstructuredFromObjectObject(packageObject *packagesv1alpha1.ObjectSetObject) (*unstructured.Unstructured, error)
Types ¶
type PausingClientObject ¶
type PhaseReconciler ¶
type PhaseReconciler struct {
// contains filtered or unexported fields
}
func NewPhaseReconciler ¶
func NewPhaseReconciler( dw dynamicWatcher, c client.Client, scheme *runtime.Scheme, ownerStrategy ownerStrategy, ) *PhaseReconciler
func (*PhaseReconciler) Reconcile ¶
func (r *PhaseReconciler) Reconcile( ctx context.Context, owner PausingClientObject, phase packagesv1alpha1.ObjectPhase, probe internalprobe.Interface, ) (failedProbes []string, err error)
Click to show internal directories.
Click to hide internal directories.