- Sort Score
- Result 10 results
- Languages All
Results 891 - 900 of 1,105 for errC (0.02 sec)
-
istioctl/pkg/multicluster/options.go
o.Namespace = ctx.Namespace() if o.Namespace == "" { o.Namespace = ctx.IstioNamespace() configAccess := clientcmd.NewDefaultPathOptions() configAccess.GlobalFile = o.Kubeconfig if config, err := configAccess.GetStartingConfig(); err == nil { if context, ok := config.Contexts[config.CurrentContext]; ok && context.Namespace != "" { o.Namespace = context.Namespace } } }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Aug 01 23:59:49 UTC 2023 - 1.6K bytes - Viewed (0) -
callbacks/query.go
) func Query(db *gorm.DB) { if db.Error == nil { BuildQuerySQL(db) if !db.DryRun && db.Error == nil { rows, err := db.Statement.ConnPool.QueryContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...) if err != nil { db.AddError(err) return } defer func() { db.AddError(rows.Close()) }() gorm.Scan(rows, db, 0) } } }
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Aug 22 11:03:42 UTC 2024 - 10.1K bytes - Viewed (1) -
internal/event/target/nsq_test.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.2K bytes - Viewed (0) -
cmd/generic-handlers.go
h.ServeHTTP(w, r) return } } sr, err := globalDNSConfig.Get(bucket) if err != nil { defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r)) if err == dns.ErrNoEntriesFound { writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(ErrNoSuchBucket), r.URL) } else { writeErrorResponse(r.Context(), w, toAPIError(r.Context(), err), r.URL) } return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 20.5K bytes - Viewed (1) -
internal/bucket/replication/rule_test.go
expectedResult: true, }, } for i, tc := range testCases { tc := tc t.Run(fmt.Sprintf("Test_%d", i+1), func(t *testing.T) { cfg, err := ParseConfig(bytes.NewReader([]byte(tc.inputConfig))) if err != nil { t.Fatalf("Got unexpected error: %v", err) } if got := cfg.Rules[0].MetadataReplicate(tc.opts); got != tc.expectedResult {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 4.6K bytes - Viewed (0) -
internal/http/check_port_linux.go
} }) return nil }, } ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel() l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port)) if err != nil { return err } // As we are able to listen on this network, the port is not in use. // Close the listener and continue check other networks. return l.Close()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 03 21:12:25 UTC 2023 - 1.9K bytes - Viewed (0) -
internal/bucket/encryption/bucket-sse-config.go
type Algorithm string // UnmarshalXML - Unmarshals XML tag to valid SSE algorithm func (alg *Algorithm) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error { var s string if err := d.DecodeElement(&s, &start); err != nil { return err } switch s { case string(AES256): *alg = AES256 case string(AWSKms): *alg = AWSKms default: return errors.New("Unknown SSE algorithm") } return nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 25 00:44:15 UTC 2022 - 4.9K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status_test.go
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Aug 14 19:36:19 UTC 2024 - 6.5K bytes - Viewed (0) -
internal/config/etcd/etcd_test.go
} for _, testCase := range testCases { testCase := testCase t.Run(testCase.s, func(t *testing.T) { endpoints, secure, err := parseEndpoints(testCase.s) if err != nil && testCase.success { t.Errorf("expected to succeed but failed with %s", err) } if !testCase.success && err == nil { t.Error("expected failure but succeeded instead") } if testCase.success {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 2.1K bytes - Viewed (0) -
istioctl/pkg/util/ambient/util.go
isZtunnel := strings.HasPrefix(podName, "ztunnel") if client == nil { return isZtunnel } pod, err := client.Kube().CoreV1().Pods(podNamespace).Get(context.Background(), podName, metav1.GetOptions{}) if err != nil { return isZtunnel } if v, ok := pod.Labels["app"]; ok { return v == "ztunnel" } return isZtunnel }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 1.8K bytes - Viewed (0)