- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 172 for some (0.17 sec)
-
cmd/os-reliable.go
// directory" error message. Handle this specifically // here. return errFileAccessDenied } } return err } // Reliably retries os.RemoveAll if for some reason os.RemoveAll returns // syscall.ENOTEMPTY (children has files). func reliableRemoveAll(dirPath string) (err error) { i := 0 for { // Removes all the directories and files.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/erasure-common.go
dataArray = append(dataArray, toAdd) } ignoredErrs := []error{ errFileNotFound, errVolumeNotFound, errFileVersionNotFound, io.ErrUnexpectedEOF, // some times we would read without locks, ignore these errors io.EOF, // some times we would read without locks, ignore these errors context.DeadlineExceeded, context.Canceled, } ignoredErrs = append(ignoredErrs, objectOpIgnoredErrs...)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/license-update.go
// will keep performing the license update. If the leader goes down for some // reason, the lock will be released and another node will acquire it and // take over because of this loop. for { licenceUpdaterLoop(ctx, objAPI) // license update stopped for some reason. // sleep for some time and try again. duration := time.Duration(r.Float64() * float64(time.Hour))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
} podNetns := NewPodNetnsProcFinder(os.DirFS(filepath.Join(pconstants.HostMountsPath, "proc"))) netServer := newNetServer(ztunnelServer, podNsMap, iptablesConfigurator, podNetns, set) // Set some defaults s := &Server{ ctx: ctx, kubeClient: client, isReady: ready, dataplane: &meshDataplane{ kubeClient: client.Kube(), netServer: netServer, }, } s.NotReady()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
t.Fatalf("Expected the APIErrorCode to be %d, but got %d", ErrNone, errCode) } inputQuery := r.URL.Query() // case where some headers need to get from request query signedHeaders = append(signedHeaders, "x-amz-server-side-encryption") // expect to fail with `ErrUnsignedHeaders` because couldn't find some header _, errCode = extractSignedHeaders(signedHeaders, r) if errCode != ErrUnsignedHeaders {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 14.3K bytes - Viewed (0) -
internal/logger/console.go
// Print the error message: the following code takes care // of splitting error text and always pretty printing the // red banner along with the error message. Since the error // message itself contains some colored text, we needed // to use some ANSI control escapes to cursor color state // and freely move in the screen. for _, line := range strings.Split(errMsg, "\n") { if len(line) == 0 { // No more text to print, just quit.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/kms/kms.go
// DEK is a data encryption key. It consists of a // plaintext-ciphertext pair and the ID of the key // used to generate the ciphertext. // // The plaintext can be used for cryptographic // operations - like encrypting some data. The // ciphertext is the encrypted version of the // plaintext data and can be stored on untrusted // storage. type DEK struct { KeyID string Plaintext []byte Ciphertext []byte }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 4.6K bytes - Viewed (0) -
istioctl/cmd/root.go
configType := filepath.Ext(root.IstioConfig) configName := baseName[0 : len(baseName)-len(configType)] if configType != "" { configType = configType[1:] } // Allow users to override some variables through $HOME/.istioctl/config.yaml // and environment variables. viper.SetEnvPrefix("ISTIOCTL") viper.AutomaticEnv() viper.AllowEmptyEnv(true) // So we can say ISTIOCTL_CERT_DIR="" to suppress certs
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 11 20:51:30 GMT 2024 - 10K bytes - Viewed (0) -
internal/s3select/csv/reader.go
dst = make([]byte, 0, skip+1024) } dst = dst[:skip] if skip > 0 { n, err := io.ReadFull(r.buf, dst) if err != nil && err != io.ErrUnexpectedEOF { // If an EOF happens after reading some but not all the bytes, // ReadFull returns ErrUnexpectedEOF. return dst[:n], err } dst = dst[:n] if err == io.ErrUnexpectedEOF { return dst, io.EOF } } // Read until next line.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
} // Iterate all the pod. for _, pod := range list.Items { touchedPods++ if options.XdsViaAgentsLimit != 0 && touchedPods > options.XdsViaAgentsLimit { fmt.Fprintf(options.MessageWriter, "Some proxies may be missing from the list"+ " because the number of visited pod hits the limit %d,"+ " which can be set by `--xds-via-agents-limit` flag.\n", options.XdsViaAgentsLimit) break GetProxyLoop }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0)