controller

type BundleController struct {
	BundleInf    cache.SharedIndexInformer
	BundleClient smithClient_v1.BundlesGetter
	BundleStore  BundleStore
	SmartClient  smith.SmartClient
	Rc           ReadyChecker
	Store        Store
	SpecCheck    SpecCheck
	// Bundle objects that need to be synced.
	Queue   workqueue.RateLimitingInterface
	Workers int

	// CRD
	CrdResyncPeriod time.Duration

	Namespace string

	Plugins map[smith_v1.PluginName]plugin.Plugin
	Scheme  *runtime.Scheme
	// contains filtered or unexported fields
}

type BundleStore interface {
	// Get returns Bundle based on its namespace and name.
	Get(namespace, bundleName string) (*smith_v1.Bundle, error)
	// GetBundlesByCrd returns Bundles which have a resource defined by CRD.
	GetBundlesByCrd(*apiext_v1b1.CustomResourceDefinition) ([]*smith_v1.Bundle, error)
	// GetBundlesByObject returns Bundles which have a resource of a particular group/kind with a name in a namespace.
	GetBundlesByObject(gk schema.GroupKind, namespace, name string) ([]*smith_v1.Bundle, error)
}

type ReadyChecker interface {
	IsReady(*unstructured.Unstructured) (isReady, retriableError bool, e error)
}

type SpecCheck interface {
	CompareActualVsSpec(spec, actual runtime.Object) (updatedSpec *unstructured.Unstructured, match bool, err error)
}

type SpecProcessor struct {
	// contains filtered or unexported fields
}

type Store interface {
	smith.ByNameStore
	GetObjectsForBundle(namespace, bundleName string) ([]runtime.Object, error)
	AddInformer(schema.GroupVersionKind, cache.SharedIndexInformer)
	RemoveInformer(schema.GroupVersionKind) bool
}