Search Options

Results per page
Sort
Preferred Languages
Advance

Results 891 - 900 of 1,105 for errC (0.04 sec)

  1. 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)
  2. 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)
  3. internal/event/target/nsq_test.go

    			n := NSQArgs{
    				Enable:      tt.fields.Enable,
    				NSQDAddress: tt.fields.NSQDAddress,
    				Topic:       tt.fields.Topic,
    			}
    			if err := n.Validate(); (err != nil) != tt.wantErr {
    				t.Errorf("NSQArgs.Validate() error = %v, wantErr %v", err, tt.wantErr)
    			}
    		})
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. istioctl/pkg/writer/pilot/status_test.go

    			for key, ss := range tt.input {
    				input[key] = ss
    			}
    
    			err := sw.PrintAll(input)
    			if tt.wantErr {
    				assert.Error(t, err)
    			} else {
    				assert.NoError(t, err)
    			}
    			want, _ := os.ReadFile(tt.want)
    			if err := util.Compare(got.Bytes(), want); err != nil {
    				t.Error(err)
    			}
    		})
    	}
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Aug 14 19:36:19 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top