mesh_group_reconciler.sk.go

// Code generated by solo-kit. DO NOT EDIT.

package v1

import (
	"github.com/solo-io/go-utils/contextutils"
	"github.com/solo-io/solo-kit/pkg/api/v1/clients"
	"github.com/solo-io/solo-kit/pkg/api/v1/reconcile"
	"github.com/solo-io/solo-kit/pkg/api/v1/resources"
)

// Option to copy anything from the original to the desired before writing. Return value of false means don't update
type TransitionMeshGroupFunc func(original, desired *MeshGroup) (bool, error)

type MeshGroupReconciler interface {
	Reconcile(namespace string, desiredResources MeshGroupList, transition TransitionMeshGroupFunc, opts clients.ListOpts) error
}

func meshGroupsToResources(list MeshGroupList) resources.ResourceList {
	var resourceList resources.ResourceList
	for _, meshGroup := range list {
		resourceList = append(resourceList, meshGroup)
	}
	return resourceList
}

func NewMeshGroupReconciler(client MeshGroupClient) MeshGroupReconciler {
	return &meshGroupReconciler{
		base: reconcile.NewReconciler(client.BaseClient()),
	}
}

type meshGroupReconciler struct {
	base reconcile.Reconciler
}

func (r *meshGroupReconciler) Reconcile(namespace string, desiredResources MeshGroupList, transition TransitionMeshGroupFunc, opts clients.ListOpts) error {
	opts = opts.WithDefaults()
	opts.Ctx = contextutils.WithLogger(opts.Ctx, "meshGroup_reconciler")
	var transitionResources reconcile.TransitionResourcesFunc
	if transition != nil {
		transitionResources = func(original, desired resources.Resource) (bool, error) {
			return transition(original.(*MeshGroup), desired.(*MeshGroup))
		}
	}
	return r.base.Reconcile(namespace, meshGroupsToResources(desiredResources), transitionResources, opts)
}