- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 59 for Berger (0.15 sec)
-
cni/pkg/nodeagent/cni-watcher.go
// If the cniListener exits, at least we should record an error log log.Errorf("CNI listener server exiting unexpectedly: %v", err) } }() context.AfterFunc(s.ctx, func() { if err := s.cniListenServer.Close(); err != nil { log.Errorf("CNI listen server terminated with error: %v", err) } else { log.Debug("CNI listen server terminated") } }) return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0) -
cni/pkg/cmd/root.go
// Start UDS log server udsLogger := udsLog.NewUDSLogger() if err = udsLogger.StartUDSLogServer(cfg.InstallConfig.LogUDSAddress, ctx.Done()); err != nil { log.Errorf("Failed to start up UDS Log Server: %v", err) return } // Creates a basic health endpoint server that reports health status // based on atomic flag, as set by installer // TODO nodeagent watch server should affect this too, and drop atomic flag
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
common-protos/k8s.io/api/flowcontrol/v1beta1/generated.proto
// `assuredConcurrencyShares` (ACS) configures the execution // limit, which is a limit on the number of requests of this // priority level that may be exeucting at a given time. ACS must // be a positive number. The server's concurrency limit (SCL) is // divided among the concurrency-controlled priority levels in // proportion to their assured concurrency shares. This produces // the assured concurrency value (ACV) --- the number of requests
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 19.4K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
).Return(nil) dpServer := &meshDataplane{ kubeClient: client.Kube(), netServer: fs, } handlers := setupHandlers(ctx, client, dpServer, "istio-system") // We are not going to start the server, so the sockpath is irrelevant pluginServer := startCniPluginServer(ctx, "/tmp/test.sock", handlers, dpServer) // label the namespace labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":"%s"}}}`,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 5.4K bytes - Viewed (0) -
cni/pkg/nodeagent/healthServer.go
// limitations under the License. package nodeagent import ( "net/http" "sync/atomic" "istio.io/istio/cni/pkg/constants" ) // StartHealthServer initializes and starts a web server that exposes liveness and readiness endpoints at port 8000. func StartHealthServer() (installReady *atomic.Value, watchReady *atomic.Value) { router := http.NewServeMux() installReady, watchReady = initRouter(router)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 1.8K bytes - Viewed (0) -
.github/ISSUE_TEMPLATE/bug_report.yml
client version: 1.0.0 control plane version: 1.0.0 data plane version: 1.0.0 (100 proxies) $ kubectl version Client Version: v1.0.0 Kustomize Version: v1.0.0 Server Version: v1.0.0 render: Text validations: required: true - type: textarea id: additional-info attributes: label: Additional Information description: |
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jan 10 15:17:29 GMT 2024 - 2.7K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient.go
"istio.io/istio/cni/pkg/nodeagent" ) // newCNIClient is a unit test override variable for mocking. var newCNIClient = buildClient // An udsCore write entries to an UDS server with HTTP Post. Log messages will be encoded into a JSON array. type CNIEventClient struct { client *http.Client url string } func buildClient(address, path string) CNIEventClient { c := &http.Client{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2.4K bytes - Viewed (0) -
common-protos/k8s.io/api/autoscaling/v1/generated.proto
// selector is the string-encoded form of a standard kubernetes label selector for the given metric. // When set, it is passed as an additional parameter to the metrics server for more specific metrics scoping // When unset, just the metricName will be used to gather metrics. // +optional optional k8s.io.apimachinery.pkg.apis.meta.v1.LabelSelector selector = 4;
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 22K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
Configure requires either the WorkloadGroup artifact path or its location on the API server.`, Example: ` # configure example using a local WorkloadGroup artifact istioctl x workload entry configure -f workloadgroup.yaml -o config # configure example using the API server istioctl x workload entry configure --name foo --namespace bar -o config`,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0) -
common-protos/k8s.io/api/policy/v1beta1/generated.proto
optional int64 observedGeneration = 1; // DisruptedPods contains information about pods whose eviction was // processed by the API server eviction subresource handler but has not // yet been observed by the PodDisruptionBudget controller. // A pod will be in this map from the time when the API server processed the // eviction request to the time when the pod is seen by PDB controller
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 19.6K bytes - Viewed (0)