- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for file_watcher (0.14 sec)
-
pkg/istio-agent/testdata/grpc-bootstrap.json
"PILOT_SAN": [ "istiod.istio-system.svc" ] }, "locality": {}, "UserAgentVersionType": null }, "certificate_providers": { "default": { "plugin_name": "file_watcher", "config": { "certificate_file": "/cert/path/cert-chain.pem", "private_key_file": "/cert/path/key.pem", "ca_certificate_file": "/cert/path/root-cert.pem", "refresh_interval": "900s"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 16:55:16 UTC 2024 - 957 bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/testdata/xds_bootstrap.json
], "GENERATOR": "grpc", "NAMESPACE": "test" }, "localisty": {}, "UserAgentVersionType": "istiov1" }, "certificate_providers": { "default": { "plugin_name": "file_watcher", "config": { "certificate_file": "../../../../tests/testdata/certs/default/cert-chain.pem", "private_key_file": "../../../../tests/testdata/certs/default/key.pem",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 08 18:48:42 UTC 2022 - 961 bytes - Viewed (0) -
pkg/test/echo/server/endpoint/grpcbootstrap.go
// limitations under the License. package endpoint import "encoding/json" // Mirror types from grpc to avoid pulling in a bunch of deps const FileWatcherCertProviderName = "file_watcher" type FileWatcherCertProviderConfig struct { CertificateFile string `json:"certificate_file,omitempty"` PrivateKeyFile string `json:"private_key_file,omitempty"`
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 06 23:16:02 UTC 2023 - 1.7K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/grpcready/probe.go
type probe struct { sync.RWMutex bootstrapPath string bootstrap *grpcxds.Bootstrap } // NewProbe returns a probe that checks if a valid bootstrap file can be loaded once. // If that bootstrap file has a file_watcher cert provider, we also ensure those certs exist. func NewProbe(bootstrapPath string) ready.Prober { return &probe{bootstrapPath: bootstrapPath} } func (p *probe) Check() error { // TODO file watch?
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 28 16:58:31 UTC 2021 - 1.9K bytes - Viewed (0) -
pkg/istio-agent/grpcxds/grpc_bootstrap.go
log.Warnf("failed parsing config in certificate_provider: %v", err) } } else { log.Warnf("did not find config in certificate_provider") } return nil } const FileWatcherCertProviderName = "file_watcher" type FileWatcherCertProviderConfig struct { CertificateFile string `json:"certificate_file,omitempty"` PrivateKeyFile string `json:"private_key_file,omitempty"`
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 00:31:03 UTC 2024 - 7.1K bytes - Viewed (0) -
pkg/filewatcher/filewatcher.go
// limitations under the License. package filewatcher import ( "errors" "fmt" "path/filepath" "sync" "github.com/fsnotify/fsnotify" ) // FileWatcher is an interface that watches a set of files, // delivering events to related channel. type FileWatcher interface { // Start watching a path. Calling Add multiple times on the same path panics.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4.3K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/HierarchicalFileWatcherUpdater.java
private final FileWatcher fileWatcher; private final FileSystemLocationToWatchValidator locationToWatchValidator; private ImmutableSet<File> watchedHierarchies = ImmutableSet.of(); public HierarchicalFileWatcherUpdater( FileWatcher fileWatcher, FileSystemLocationToWatchValidator locationToWatchValidator,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/config/mesh/watcher.go
handlers[i].handler() } } // Add to the FileWatcher the provided file and execute the provided function // on any change event for this file. // Using a debouncing mechanism to avoid calling the callback multiple times // per event. func addFileWatcher(fileWatcher filewatcher.FileWatcher, file string, callback func()) { _ = fileWatcher.Add(file) go func() { var timerC <-chan time.Time for {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 7.4K bytes - Viewed (0) -
pilot/pkg/bootstrap/mesh.go
func (s *Server) initMeshNetworks(args *PilotArgs, fileWatcher filewatcher.FileWatcher) { if s.environment.NetworksWatcher != nil { return } log.Info("initializing mesh networks") if args.NetworksConfigFile != "" { var err error s.environment.NetworksWatcher, err = mesh.NewNetworksWatcher(fileWatcher, args.NetworksConfigFile) if err != nil { log.Info(err) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4.5K bytes - Viewed (0) -
pkg/filewatcher/fakefilewatcher.go
// limitations under the License. package filewatcher import ( "errors" "fmt" "sync" "github.com/fsnotify/fsnotify" ) // NewFileWatcherFunc returns a function which creates a new file // watcher. This may be used to provide test hooks for using the // FakeWatcher implementation below. type NewFileWatcherFunc func() FileWatcher // FakeWatcher provides a fake file watcher implementation for unit
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 14:06:41 UTC 2023 - 3.6K bytes - Viewed (0)