Lines Matching defs:controller

62 type controller struct {  struct
63 	configStoreMu sync.RWMutex
65 	configStore   map[resource.GroupVersionKind]map[string]map[string]*model.Config
66 	options       *Options
67 	eventHandlers map[resource.GroupVersionKind][]func(model.Config, model.Config, model.Event)
68 	ledger        ledger.Ledger
70 	syncedMu sync.Mutex
71 	synced   map[string]bool
91 func (c *controller) Schemas() collection.Schemas {
97 …controller) List(typ resource.GroupVersionKind, namespace string) (out []model.Config, err error) {
128 func (c *controller) Apply(change *sink.Change) error {
249 func (c *controller) objectInRevision(o *model.Config) bool {
260 func (c *controller) HasSynced() bool {
280 …entHandler(kind resource.GroupVersionKind, handler func(model.Config, model.Config, model.Event)) {
284 func (c *controller) Version() string {
288 …*controller) GetResourceAtVersion(version string, key string) (resourceVersion string, err error) {
292 func (c *controller) GetLedger() ledger.Ledger {
296 func (c *controller) SetLedger(l ledger.Ledger) error {
302 func (c *controller) Run(<-chan struct{}) {
307 func (c *controller) Get(_ resource.GroupVersionKind, _, _ string) *model.Config {
313 func (c *controller) Update(model.Config) (newRevision string, err error) {
319 func (c *controller) Create(model.Config) (revision string, err error) {
325 func (c *controller) Delete(_ resource.GroupVersionKind, _, _ string) error {
329 func (c *controller) sync(collection string) {
335 …c (c *controller) serviceEntryEvents(currentStore, prevStore map[string]map[string]*model.Config) {
381 func (c *controller) removeConfig(kind resource.GroupVersionKind, resources []string) {
402 …ller) incrementalUpdate(kind resource.GroupVersionKind, conf map[string]map[string]*model.Config) {