- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for WaitTimeout (0.88 sec)
-
operator/pkg/helmreconciler/reconciler.go
Log clog.Logger // Wait determines if we will wait for resources to be fully applied. Only applies to components that have no // dependencies. Wait bool // WaitTimeout controls the amount of time to wait for resources in a component to become ready before giving up. WaitTimeout time.Duration // Log tracks the installation progress for all components. ProgressLog *progress.Log // Force ignores validation errors Force bool
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 22 08:32:23 UTC 2024 - 22K bytes - Viewed (0) -
pilot/pkg/util/network/ip.go
"fmt" "net" "net/netip" "strconv" "time" "istio.io/istio/pkg/log" "istio.io/istio/pkg/sleep" ) // Network-related utility functions const ( waitInterval = 100 * time.Millisecond waitTimeout = 2 * time.Minute ) // ip family enum type IPFamilyType int const ( IPv4 = iota IPv6 UNKNOWN ) type lookupIPAddrType = func(ctx context.Context, addr string) ([]netip.Addr, error)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Dec 21 21:27:21 UTC 2023 - 6.3K bytes - Viewed (0) -
internal/event/target/mqtt.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.2K bytes - Viewed (0) -
operator/pkg/helmreconciler/wait.go
} // WaitForResources polls to get the current status of all pods, PVCs, and Services // until all are ready or a timeout is reached func WaitForResources(objects object.K8sObjects, client kube.Client, waitTimeout time.Duration, dryRun bool, l *progress.ManifestLog, ) error { if dryRun || TestMode { return nil } if err := waitForCRDs(objects, client); err != nil { return err } var notReady []string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 08 03:13:12 UTC 2023 - 13.1K bytes - Viewed (0) -
operator/cmd/mesh/install.go
waitTimeout time.Duration, l clog.Logger, ) error { // Needed in case we are running a test through this path that doesn't start a new process. cache.FlushObjectCaches() opts := &helmreconciler.Options{ DryRun: dryRun, Log: l, WaitTimeout: waitTimeout, ProgressLog: progress.NewLog(), Force: force, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 21:52:35 UTC 2024 - 15.4K bytes - Viewed (0) -
operator/cmd/mesh/shared.go
Context string // DryRun performs all steps except actually applying the manifests or creating output dirs/files. DryRun bool // Maximum amount of time to wait for resources to be ready after install when Wait=true. WaitTimeout time.Duration } func applyManifest(kubeClient kube.Client, client client.Client, manifestStr string, componentName name.ComponentName, opts *applyOptions, iop *v1alpha1.IstioOperator, l clog.Logger, ) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 29 02:29:02 UTC 2024 - 5.1K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
waypointName = constants.DefaultNamespaceWaypoint enrollNamespace bool overwrite bool ) const waitTimeout = 90 * time.Second func Cmd(ctx cli.Context) *cobra.Command { makeGateway := func(forApply bool) (*gateway.Gateway, error) { ns := ctx.NamespaceOrDefault(ctx.Namespace()) if ctx.Namespace() == "" && !forApply {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 15:59:33 UTC 2024 - 16.4K bytes - Viewed (0) -
tools/bug-report/pkg/kubectlcmd/kubectlcmd.go
Namespace string // DryRun performs all steps but only logs the Run command without running it. DryRun bool // Maximum amount of time to wait for resources to be ready after install when Wait=true. WaitTimeout time.Duration // output - output mode for Run i.e. --output. Output string // extraArgs - more args to be added to the Run command, which are appended to // the end of the Run command. ExtraArgs []string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 16 01:18:03 UTC 2023 - 7.2K bytes - Viewed (0) -
operator/pkg/helmreconciler/apply.go
scope.Infof("Pruning object %s from cache.", k) delete(objectCache.Cache, k) } if len(changedObjectKeys) > 0 { err := WaitForResources(result.processedObjects, h.kubeClient, h.opts.WaitTimeout, h.opts.DryRun, plog) if err != nil { werr := fmt.Errorf("failed to wait for resource: %v", err) plog.ReportError(werr.Error()) return result, werr } plog.ReportFinished() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 12 17:12:54 UTC 2023 - 6.4K bytes - Viewed (0) -
pilot/pkg/xds/eds_test.go
err, id) return } log.Infof("Received all pushes %v", id) rcvClients.Inc() adscConn.Close() }(current) } ok := waitTimeout(wgConnect, to) if !ok { t.Fatal("Failed to connect") } log.Info("Done connecting") // All clients are connected - this can start pushing changes. for j := 0; j < nPushes; j++ { if inc {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0)