- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 82 for Langen (0.36 sec)
-
cmd/storage-rest-client.go
if err != nil { for i := range errs { errs[i] = toStorageErr(err) } return errs } dErrResp := &DeleteVersionsErrsResp{} if err = gob.NewDecoder(reader).Decode(dErrResp); err != nil { for i := range errs { errs[i] = toStorageErr(err) } return errs } for i, dErr := range dErrResp.Errs { errs[i] = toStorageErr(dErr) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
operator/cmd/mesh/profile-list.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 1.9K bytes - Viewed (0) -
cmd/bitrot_test.go
} if _, err = reader.ReadAt(b[:5], 30); err != nil { t.Fatal(err) } if br, ok := reader.(io.Closer); ok { br.Close() } } func TestAllBitrotAlgorithms(t *testing.T) { for bitrotAlgo := range bitrotAlgorithms { testBitrotReaderWriterAlgo(t, bitrotAlgo) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 2.1K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
// PendingTasks returns the number of pending ILM expiry tasks. func (es *expiryState) PendingTasks() int { w := es.workers.Load() if w == nil || len(*w) == 0 { return 0 } var tasks int for _, wrkr := range *w { tasks += len(wrkr) } return tasks } // enqueueTierJournalEntry enqueues a tier journal entry referring to a remote // object corresponding to a 'replaced' object versions. This applies only to
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
uploadID string expectedErrType error }{bucket, "\\", uploadID, InvalidUploadID{}}) } // Iterating over creatPartCases to generate multipart chunks. for i, testCase := range abortTestCases { err = obj.AbortMultipartUpload(context.Background(), testCase.bucketName, testCase.objName, testCase.uploadID, opts) if testCase.expectedErrType == nil && err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 77.1K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux_test.go
} // Error cases where parsing fails with invalid Freq and Pass params. { errorCases := []string{ "/dev/1 /path/to/mount type flags a 0\n", "/dev/2 /path/to/mount type flags 0 b\n", } for _, ec := range errorCases { _, rerr := parseMountFrom(strings.NewReader(ec)) if rerr == nil { t.Errorf("expected error") } } } } // Helpers for tests.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.3K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
switch { case err != nil: return "", err case len(files) == 0: return "", fmt.Errorf("no networks found in %s", confDir) } sort.Strings(files) for _, confFile := range files { var confList *libcni.NetworkConfigList if strings.HasSuffix(confFile, ".conflist") { confList, err = libcni.ConfListFromFile(confFile) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/policies.go
if r := cmp.Compare(a.Namespace, b.Namespace); r != 0 { return r } return cmp.Compare(a.Name, b.Name) }) fmt.Fprintln(w, "NAMESPACE\tPOLICY NAME\tACTION\tSCOPE") for _, pol := range pols { fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", pol.Namespace, pol.Name, pol.Action, pol.Scope) } return w.Flush() } // PrintPolicyDump prints the relevant services in the config dump to the ConfigWriter stdout
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/storage-datatypes.go
func (f *FileInfoVersions) findVersionIndex(v string) int { if f == nil || v == "" { return -1 } if v == nullVersionID { for i, ver := range f.Versions { if ver.VersionID == "" { return i } } return -1 } for i, ver := range f.Versions { if ver.VersionID == v { return i } } return -1 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
internal/grid/stream.go
func (s *Stream) Results(next func(b []byte) error) (err error) { done := false defer func() { if s.cancel != nil { s.cancel(err) } if !done { // Drain channel. for range s.responses { } } }() doneCh := s.ctx.Done() for { select { case <-doneCh: if err := context.Cause(s.ctx); !errors.Is(err, errStreamEOF) { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0)