sync

Documentation

Index

• Variables
• func DeleteNoLongerExistingModuleStatus(ctx context.Context, kyma *v1beta2.Kyma, moduleFunc GetModuleFunc, ...)
• func NeedToUpdate(manifestInCluster, newManifest *v1beta2.Manifest, ...) bool
• type GetModuleFunc
• type RemoveMetricsFunc
• type Runner
  • func New(clnt client.Client) *Runner
  • func (r *Runner) ReconcileManifests(ctx context.Context, kyma *v1beta2.Kyma, modules common.Modules) error
  • func (r *Runner) SyncModuleStatus(ctx context.Context, kyma *v1beta2.Kyma, modules common.Modules, ...)

Variables

var ErrServerSideApplyFailed = errors.New("ServerSideApply failed")

Functions

func DeleteNoLongerExistingModuleStatus

func DeleteNoLongerExistingModuleStatus(ctx context.Context, kyma *v1beta2.Kyma, moduleFunc GetModuleFunc,
	kymaMetricsRemoveMetrics, moduleMetricsRemoveMetrics RemoveMetricsFunc,
)

func NeedToUpdate

func NeedToUpdate(manifestInCluster, newManifest *v1beta2.Manifest, moduleInStatus *v1beta2.ModuleStatus,
	module *common.Module,
) bool

Types

type GetModuleFunc

type GetModuleFunc func(ctx context.Context, module client.Object) error

type RemoveMetricsFunc

type RemoveMetricsFunc func(kymaName, moduleName string)

type Runner

type Runner struct {
	client.Client
	// contains filtered or unexported fields
}

func New

func New(clnt client.Client) *Runner

func (*Runner) ReconcileManifests

func (r *Runner) ReconcileManifests(ctx context.Context, kyma *v1beta2.Kyma,
	modules common.Modules,
) error

func (*Runner) SyncModuleStatus

func (r *Runner) SyncModuleStatus(ctx context.Context, kyma *v1beta2.Kyma, modules common.Modules,
	kymaMetrics *metrics.KymaMetrics, moduleMetrics *metrics.ModuleMetrics,
)