controller

Documentation

Index

• func NewLastResourceVersions() *lastResourceVersions
• type ClusterState
  • func (c ClusterState) Locators() []identity.Locator
• type CueInstanceController
  • func NewCueInstanceController(client dynamic.Interface, mapper meta.RESTMapper, runtime *cue.Runtime, ...) *CueInstanceController
  • func (c *CueInstanceController) Start(ctx context.Context, stateChan chan ClusterState, errChan chan error) (count int, err error)

Functions

func NewLastResourceVersions

func NewLastResourceVersions() *lastResourceVersions

Types

type ClusterState

type ClusterState map[*identity.Locator]*unstructured.Unstructured

func (ClusterState) Locators

func (c ClusterState) Locators() []identity.Locator

type CueInstanceController

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

func NewCueInstanceController

func NewCueInstanceController(client dynamic.Interface, mapper meta.RESTMapper, runtime *cue.Runtime, instance *cue.Instance) *CueInstanceController

func (*CueInstanceController) Start

func (c *CueInstanceController) Start(ctx context.Context, stateChan chan ClusterState, errChan chan error) (count int, err error)