sync

Documentation

Index

• type ReconciliationResult
  • func Reconcile(targetObjs []*unstructured.Unstructured, ...) ReconciliationResult
• type SyncContext
  • func NewSyncContext(revision string, reconciliationResult ReconciliationResult, ...) (SyncContext, error)
• type SyncOpt
  • func WithHealthOverride(override health.HealthOverride) SyncOpt
  • func WithInitialState(phase common.OperationPhase, message string, ...) SyncOpt
  • func WithManifestValidation(enabled bool) SyncOpt
  • func WithOperationSettings(dryRun bool, prune bool, force bool, skipHooks bool) SyncOpt
  • func WithPermissionValidator(validator common.PermissionValidator) SyncOpt
  • func WithResourcesFilter(...) SyncOpt

Types

type ReconciliationResult

type ReconciliationResult struct {
	Live   []*unstructured.Unstructured
	Target []*unstructured.Unstructured
	Hooks  []*unstructured.Unstructured
}

func Reconcile

func Reconcile(targetObjs []*unstructured.Unstructured, liveObjByKey map[kube.ResourceKey]*unstructured.Unstructured, namespace string, resInfo kubeutil.ResourceInfoProvider) ReconciliationResult

type SyncContext

type SyncContext interface {
	Terminate()
	Sync()
	GetState() (common.OperationPhase, string, []common.ResourceSyncResult)
}

func NewSyncContext

func NewSyncContext(
	revision string,
	reconciliationResult ReconciliationResult,
	restConfig *rest.Config,
	rawConfig *rest.Config,
	kubectl kubeutil.Kubectl,
	namespace string,
	log *log.Entry,
	opts ...SyncOpt,
) (SyncContext, error)

type SyncOpt

type SyncOpt func(ctx *syncContext)

func WithHealthOverride

func WithHealthOverride(override health.HealthOverride) SyncOpt

func WithInitialState

func WithInitialState(phase common.OperationPhase, message string, results []common.ResourceSyncResult) SyncOpt

func WithManifestValidation

func WithManifestValidation(enabled bool) SyncOpt

func WithOperationSettings

func WithOperationSettings(dryRun bool, prune bool, force bool, skipHooks bool) SyncOpt

func WithPermissionValidator

func WithPermissionValidator(validator common.PermissionValidator) SyncOpt

func WithResourcesFilter

func WithResourcesFilter(resourcesFilter func(key kube.ResourceKey, target *unstructured.Unstructured, live *unstructured.Unstructured) bool) SyncOpt