Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for file_watcher (0.69 sec)

  1. pilot/pkg/bootstrap/certcontroller.go

    					}
    				case <-s.fileWatcher.Events(tlsOptions.CertFile):
    					if keyCertTimerC == nil {
    						keyCertTimerC = time.After(watchDebounceDelay)
    					}
    				case <-s.fileWatcher.Events(tlsOptions.KeyFile):
    					if keyCertTimerC == nil {
    						keyCertTimerC = time.After(watchDebounceDelay)
    					}
    				case err := <-s.fileWatcher.Errors(tlsOptions.CertFile):
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  2. pkg/istio-agent/agent.go

    	envoyAgent *envoy.Agent
    
    	sdsServer   SDSService
    	secretCache *cache.SecretManagerClient
    
    	// Used when proxying envoy xds via istio-agent is enabled.
    	xdsProxy    *XdsProxy
    	fileWatcher filewatcher.FileWatcher
    
    	// local DNS Server that processes DNS requests locally and forwards to upstream DNS if needed.
    	localDNSServer *dnsClient.LocalDNSServer
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 10:02:56 UTC 2024
    - 26.7K bytes
    - Viewed (0)
  3. pilot/pkg/bootstrap/server.go

    	// If the address os empty, the webhooks will be set on the default httpPort.
    	httpsMux *http.ServeMux // webhooks
    
    	// fileWatcher used to watch mesh config, networks and certificates.
    	fileWatcher filewatcher.FileWatcher
    
    	// certWatcher watches the certificates for changes and triggers a notification to Istiod.
    	cacertsWatcher *fsnotify.Watcher
    	dnsNames       []string
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  4. pilot/pkg/bootstrap/server_test.go

    func TestReloadIstiodCert(t *testing.T) {
    	dir := t.TempDir()
    	stop := make(chan struct{})
    	s := &Server{
    		fileWatcher:             filewatcher.NewWatcher(),
    		server:                  server.New(),
    		istiodCertBundleWatcher: keycertbundle.NewWatcher(),
    	}
    
    	defer func() {
    		close(stop)
    		_ = s.fileWatcher.Close()
    	}()
    
    	certFile := filepath.Join(dir, "cert-file.yaml")
    	keyFile := filepath.Join(dir, "key-file.yaml")
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 23.1K bytes
    - Viewed (0)
Back to top