Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewFileSnapshot (0.2 sec)

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

    `
    
    func TestFileSnapshotNoFilter(t *testing.T) {
    	g := NewWithT(t)
    
    	ts := &testState{
    		ConfigFiles: map[string][]byte{"gateway.yml": []byte(gatewayYAML)},
    	}
    
    	ts.testSetup(t)
    
    	fileWatcher := NewFileSnapshot(ts.rootPath, collection.SchemasFor(), "foo")
    	configs, err := fileWatcher.ReadConfigFiles()
    	g.Expect(err).NotTo(HaveOccurred())
    	g.Expect(configs).To(HaveLen(1))
    	g.Expect(configs[0].Domain).To(Equal("foo"))
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Oct 31 14:48:28 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  2. pilot/pkg/config/monitor/file_snapshot.go

    type FileSnapshot struct {
    	root             string
    	domainSuffix     string
    	configTypeFilter map[config.GroupVersionKind]bool
    }
    
    // NewFileSnapshot returns a snapshotter.
    // If no types are provided in the descriptor, all Istio types will be allowed.
    func NewFileSnapshot(root string, schemas collection.Schemas, domainSuffix string) *FileSnapshot {
    	snapshot := &FileSnapshot{
    		root:             root,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Feb 12 17:36:33 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  3. pilot/pkg/config/monitor/README.md

    ```golang
    // Configure the config store
    store := memory.Make(configDescriptor)
    controller = memory.NewController(store)
    // Create an object that will take snapshots of config
    fileSnapshot := configmonitor.NewFileSnapshot(args.Config.FileDir, configDescriptor)
    // Provide snapshot func to monitor
    fileMonitor := configmonitor.NewMonitor(controller, 100*time.Millisecond, fileSnapshot.ReadFile)
    
    // Run the controller and monitor
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Sep 14 20:15:07 UTC 2019
    - 2.1K bytes
    - Viewed (0)
  4. pilot/pkg/config/monitor/monitor_test.go

    	ts := &testState{
    		ConfigFiles: map[string][]byte{"gateway.yml": []byte(statusRegressionYAML)},
    	}
    
    	ts.testSetup(t)
    
    	store := memory.Make(collection.SchemasFor(collections.Gateway))
    	fileWatcher := NewFileSnapshot(ts.rootPath, collection.SchemasFor(), "foo")
    
    	mon := NewMonitor("", store, fileWatcher.ReadConfigFiles, "")
    	stop := make(chan struct{})
    	defer func() { close(stop) }()
    	mon.Start(stop)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Oct 31 14:48:28 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  5. pilot/pkg/bootstrap/configcontroller.go

    	}
    	return crdclient.New(s.kubeClient, opts)
    }
    
    func (s *Server) makeFileMonitor(fileDir string, domainSuffix string, configController model.ConfigStore) error {
    	fileSnapshot := configmonitor.NewFileSnapshot(fileDir, collections.Pilot, domainSuffix)
    	fileMonitor := configmonitor.NewMonitor("file-monitor", configController, fileSnapshot.ReadConfigFiles, fileDir)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 14.1K bytes
    - Viewed (0)
Back to top