Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewSyncMonitor (0.14 sec)

  1. pilot/pkg/config/memory/monitor.go

    func NewMonitor(store model.ConfigStore) Monitor {
    	return newBufferedMonitor(store, BufferSize, false)
    }
    
    // NewMonitor returns new Monitor implementation which will process events synchronously
    func NewSyncMonitor(store model.ConfigStore) Monitor {
    	return newBufferedMonitor(store, BufferSize, true)
    }
    
    // NewBufferedMonitor returns new Monitor implementation with the specified event buffer size
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  2. pilot/pkg/config/memory/controller.go

    // NewSyncController return an implementation of model.ConfigStoreController which processes events synchronously
    func NewSyncController(cs model.ConfigStore) *Controller {
    	out := &Controller{
    		configStore: cs,
    		monitor:     NewSyncMonitor(cs),
    	}
    
    	return out
    }
    
    func (c *Controller) RegisterHasSyncedHandler(cb func() bool) {
    	c.hasSynced = cb
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 26 13:54:32 UTC 2023
    - 4.7K bytes
    - Viewed (0)
Back to top