- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 109 for Dailey (0.33 sec)
-
cni/pkg/nodeagent/netns_linux.go
// inspired by netns.Do() but with an existing fd. func NetnsDo(fdable NetnsFd, toRun func() error) error { containedCall := func() error { threadNS, err := netns.GetCurrentNS() if err != nil { return fmt.Errorf("failed to open current netns: %v", err) } defer threadNS.Close() // switch to target namespace if err = NetnsSet(fdable); err != nil { return err } defer func() {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jan 31 10:05:36 GMT 2024 - 2.7K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers.go
NamespaceParam(ns).DefaultNamespace(). SingleResourceType() builder.ResourceNames("pods", resname) infos, err := builder.Do().Infos() if err != nil { return nil, "", "", "", fmt.Errorf("failed retrieving: %v in the %q namespace", err, ns) } if len(infos) != 1 { return nil, "", "", "", errors.New("expected a resource") } _, ok := infos[0].Object.(*corev1.Pod) if ok {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 06 15:01:41 GMT 2024 - 6.2K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
file := os.Stdin if filename != "-" { var err error file, err = os.Open(filename) if err != nil { return nil, err } } defer func() { if err := file.Close(); err != nil { log.Errorf("failed to close %s: %s", filename, err) } }() data, err := io.ReadAll(file) if err != nil { return nil, err } return data, nil } func StableXdsStatusCommand(ctx cli.Context) *cobra.Command {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 6.2K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/route_test.go
gotOut := &bytes.Buffer{} cw := &ConfigWriter{Stdout: gotOut} cd, _ := os.ReadFile(fmt.Sprintf("testdata/routes/%s/configdump.json", tt.name)) if err := cw.Prime(cd); err != nil { t.Errorf("failed to parse config dump: %s", err) } err := cw.PrintRouteSummary(RouteFilter{Verbose: true}) assert.NoError(t, err) wantOutputFile := path.Join("testdata/routes", tt.name, "output.txt")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 2.8K bytes - Viewed (0) -
cni/pkg/repair/repair_test_helpers.go
Name: constants.ValidationContainerName, State: corev1.ContainerState{ Waiting: &corev1.ContainerStateWaiting{ Reason: "CrashLoopBackOff", Message: "Back-off 5m0s restarting failed blah blah blah", }, }, LastTerminationState: corev1.ContainerState{ Terminated: &corev1.ContainerStateTerminated{ ExitCode: constants.ValidationErrorCode, Reason: "Error",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 12 17:39:53 GMT 2023 - 4.7K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/connections.go
if filter.Namespace != "" && filter.Namespace != state.Info.Namespace { return false } return true }) out, err := json.MarshalIndent(workloads, "", " ") if err != nil { return fmt.Errorf("failed to marshal workloads: %v", err) } if outputFormat == "yaml" { if out, err = yaml.JSONToYAML(out); err != nil { return err } } fmt.Fprintln(c.Stdout, string(out)) return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 15:39:28 GMT 2024 - 3.3K bytes - Viewed (0) -
RELEASE_BRANCHES.md
* All changes should have an associated GitHub issue and/or a release note. * In the event that a bug cannot be automatically backported, the istio-testing bot creates an issue for a failed attempt and assigns it to the developer. This issue **is not** sufficient for requesting approval. * For manual cherry-picks:
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Nov 12 23:27:43 GMT 2021 - 3.9K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
err error scopeName string }{err: err, scopeName: si.Name} }(scope) } wg.Wait() close(ch) for result := range ch { if result.err != nil { return fmt.Errorf("failed updating Scope %s: %v", result.scopeName, result.err) } } return nil } func (c *ControlzClient) GetScope(scope string) (*ScopeInfo, error) { var s ScopeInfo
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
} *sidecarTemplate = injectConfig } else { injector, err = setUpExternalInjector(cliContext, revision, injectorAddress) if err != nil || injector.clientConfig == nil { log.Warnf("failed to get injection config from mutatingWebhookConfigurations %q, will fall back to "+ "get injection from the injection configmap %q : %v", whcName, defaultInjectWebhookConfigName, err)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0) -
common/scripts/kind_provisioner.sh
function retry() { local n=1 local max=5 local delay=5 while true; do "$@" && break if [[ $n -lt $max ]]; then ((n++)) log "Command failed. Attempt $n/$max:" sleep $delay; else log "The command has failed after $n attempts." >&2 return 2 fi done } # load_cluster_topology function reads cluster configuration topology file and
Shell Script - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 08 19:12:55 GMT 2024 - 17.3K bytes - Viewed (1)