- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for file_watcher (0.18 sec)
-
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/NonHierarchicalFileWatcherUpdater.java
private final FileWatcher fileWatcher; private final Multiset<String> watchedDirectories = HashMultiset.create(); private final Map<String, String> watchedDirectoryForSnapshot = new HashMap<>(); private final Set<String> watchedWatchableHierarchies = new HashSet<>(); public NonHierarchicalFileWatcherUpdater( FileWatcher fileWatcher, FileWatcherProbeRegistry probeRegistry,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 17 04:59:05 UTC 2023 - 9.8K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/DefaultFileWatcherRegistry.java
* limitations under the License. */ package org.gradle.internal.watch.registry.impl; import net.rubygrapefruit.platform.file.FileWatchEvent; import net.rubygrapefruit.platform.file.FileWatcher; import net.rubygrapefruit.platform.internal.jni.AbstractNativeFileEventFunctions; import net.rubygrapefruit.platform.internal.jni.NativeLogger; import org.gradle.internal.snapshot.FileSystemLocationSnapshot;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 11.2K bytes - Viewed (0) -
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) -
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) -
platforms/core-execution/file-watching/src/test/groovy/org/gradle/internal/watch/registry/impl/HierarchicalFileWatcherUpdaterTest.groovy
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.watch.registry.impl import net.rubygrapefruit.platform.file.FileWatcher import org.gradle.internal.file.FileMetadata.AccessType import org.gradle.internal.snapshot.MissingFileSnapshot import org.gradle.internal.watch.registry.FileWatcherUpdater
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 23 13:24:54 UTC 2024 - 12K bytes - Viewed (0) -
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) -
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) -
platforms/core-execution/file-watching/src/test/groovy/org/gradle/internal/watch/registry/impl/AbstractFileWatcherUpdaterTest.groovy
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.watch.registry.impl import net.rubygrapefruit.platform.file.FileWatcher import org.gradle.api.internal.cache.StringInterner import org.gradle.api.internal.file.TestFiles import org.gradle.api.internal.file.TestVirtualFileSystem import org.gradle.internal.file.FileMetadata.AccessType
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 21.5K bytes - Viewed (0)