unifier

Documentation

Index

• type ClusterUnifier
  • func NewClusterUnifier(runtime *cue.Runtime, instance *cue.Instance, informerSet cache.Interface) *ClusterUnifier
  • func (u *ClusterUnifier) Fill(queue workqueue.RateLimitingInterface) (total int, err error)
  • func (u *ClusterUnifier) Lookup(fromCluster map[*identity.Locator]*unstructured.Unstructured, path ...string) (*unstructured.Unstructured, error)
• type Interface

Types

type ClusterUnifier

type ClusterUnifier struct {

	// protects access to the build.Instance being unified
	sync.RWMutex
	// contains filtered or unexported fields
}

ClusterUnifier takes an initial cue.Instance and can return a new cue.Instance where initial has been unified with the current state of the cluster.

func NewClusterUnifier

func NewClusterUnifier(runtime *cue.Runtime, instance *cue.Instance, informerSet cache.Interface) *ClusterUnifier

func (*ClusterUnifier) Fill

func (u *ClusterUnifier) Fill(queue workqueue.RateLimitingInterface) (total int, err error)

func (*ClusterUnifier) Lookup

func (u *ClusterUnifier) Lookup(fromCluster map[*identity.Locator]*unstructured.Unstructured, path ...string) (*unstructured.Unstructured, error)

Lookup first unifies the instance with the cluster state, and then does a lookup of path in the unified instance if the value is concrete, the unstructured representation will be returned.

type Interface

type Interface interface {
	Fill(queue workqueue.RateLimitingInterface) (total int, err error)
	Lookup(fromCluster map[*identity.Locator]*unstructured.Unstructured, path ...string) (*unstructured.Unstructured, error)
}