- Sort Score
- Result 10 results
- Languages All
Results 691 - 700 of 1,105 for errC (0.02 sec)
-
internal/kms/config_test.go
) func TestIsPresent(t *testing.T) { for i, test := range isPresentTests { os.Clearenv() for k, v := range test.Env { os.Setenv(k, v) } ok, err := IsPresent() if err != nil && !test.ShouldFail { t.Fatalf("Test %d: %v", i, err) } if err == nil && test.ShouldFail { t.Fatalf("Test %d: should have failed but succeeded", i) } if !test.ShouldFail && ok != test.IsPresent {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 2.7K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Jul 22 15:40:30 UTC 2024 - 16.5K bytes - Viewed (0) -
cmd/lock-rest-server.go
// Consequently, if err != nil, reply is always false return l.makeResp(resp, err) } // RLockHandler - Acquires an RLock. func (l *lockRESTServer) RLockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) { resp := lockRPCRLock.NewResponse() success, err := l.ll.RLock(context.Background(), *args) if err == nil && !success { err = errLockConflict }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 5.8K bytes - Viewed (0) -
internal/net/net.go
) // GetInterfaceNetStats - get procfs.NetDevLine by interfaceName func GetInterfaceNetStats(interf string) (procfs.NetDevLine, error) { proc, err := procfs.Self() if err != nil { return procfs.NetDevLine{}, err } netDev, err := proc.NetDev() if err != nil { return procfs.NetDevLine{}, err } ndl, ok := netDev[interf] if !ok { return procfs.NetDevLine{}, fmt.Errorf("%v interface not found", interf) } return ndl, nil
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 17 08:14:01 UTC 2023 - 1.2K bytes - Viewed (0) -
cmd/data-usage-cache.go
return } (*z)[zb0003] = struct{}{} } } return } // EncodeMsg implements msgp.Encodable func (z dataUsageHashMap) EncodeMsg(en *msgp.Writer) (err error) { err = en.WriteArrayHeader(uint32(len(z))) if err != nil { err = msgp.WrapError(err) return } for zb0004 := range z { err = en.WriteString(zb0004) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 34.7K bytes - Viewed (0) -
internal/config/dns/etcd_dns.go
ctx, cancel := context.WithTimeout(context.Background(), defaultContextTimeout) r, err := c.etcdClient.Get(ctx, key, clientv3.WithPrefix()) defer cancel() if err != nil { return nil, err } if r.Count == 0 { key = strings.TrimSuffix(key, etcdPathSeparator) r, err = c.etcdClient.Get(ctx, key) if err != nil { return nil, err } // only if we are looking at `domain` as true
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 26 15:03:08 UTC 2024 - 8K bytes - Viewed (0) -
cmd/healthcheck-handler.go
defer cancel() if _, err := GlobalKMS.GenerateKey(ctx, &kms.GenerateKeyRequest{AssociatedData: kms.Context{"healthcheck": ""}}); err != nil { switch r.Method { case http.MethodHead: apiErr := toAPIError(r.Context(), err) writeResponse(w, apiErr.HTTPStatusCode, nil, mimeNone) case http.MethodGet: writeErrorResponse(r.Context(), w, toAPIError(r.Context(), err), r.URL) } return } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 26 07:44:34 UTC 2024 - 6.9K bytes - Viewed (0) -
internal/auth/credentials.go
func ExpToInt64(expI interface{}) (expAt int64, err error) { switch exp := expI.(type) { case string: expAt, err = strconv.ParseInt(exp, 10, 64) case float64: expAt, err = int64(exp), nil case int64: expAt, err = exp, nil case int: expAt, err = int64(exp), nil case uint64: expAt, err = int64(exp), nil case uint: expAt, err = int64(exp), nil case json.Number:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 28 17:14:16 UTC 2024 - 12K bytes - Viewed (0) -
istioctl/pkg/xds/google.go
ret := map[string]string{ "x-goog-user-project": c.project, } if err := updateAuthHdrs(ctx, uri, "k8s", c.k8sCreds, ret, "x-mesh-authorization"); err != nil { return nil, err } if err := updateAuthHdrs(ctx, uri, "gcp", c.gcpCreds, ret, "authorization"); err != nil { return nil, err } return ret, nil } func (*meshAuthCredentials) RequireTransportSecurity() bool { return true }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Nov 14 20:23:34 UTC 2022 - 3.4K bytes - Viewed (0) -
istioctl/pkg/multicluster/cluster.go
// (see https://docs.google.com/document/d/1F__vEKeI41P7PPUCMM9PVPYY34pyrvQI5rbTJVnS5c4) func clusterUID(client kubernetes.Interface) (types.UID, error) { kubeSystem, err := client.CoreV1().Namespaces().Get(context.TODO(), "kube-system", metav1.GetOptions{}) if err != nil { return "", err } return kubeSystem.UID, nil
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Sep 02 03:11:58 UTC 2022 - 1.1K bytes - Viewed (0)