- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,863 for if (0.18 sec)
-
cmd/local-locker_gen.go
// write "Name" err = en.Append(0x89, 0xa4, 0x4e, 0x61, 0x6d, 0x65) if err != nil { return } err = en.WriteString(z.Name) if err != nil { err = msgp.WrapError(err, "Name") return } // write "Writer" err = en.Append(0xa6, 0x57, 0x72, 0x69, 0x74, 0x65, 0x72) if err != nil { return } err = en.WriteBool(z.Writer) if err != nil { err = msgp.WrapError(err, "Writer") return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 13.8K bytes - Viewed (0) -
callbacks/associations.go
} // check association values has been saved // if values kind is Struct, check it has been saved // if values kind is Slice/Array, check all items have been saved var visitMapStoreKey = "gorm:saved_association_map" func checkAssociationsSaved(db *gorm.DB, values reflect.Value) bool { if visit, ok := db.Get(visitMapStoreKey); ok { if v, ok := visit.(*visitMap); ok { if loadOrStoreVisitMap(v, values) { return true }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Apr 11 03:06:13 GMT 2023 - 14.3K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
if err != nil { return err } // Check if the current bucket has a configured lifecycle policy lc, err = globalLifecycleSys.Get(bi.Name) if err != nil && !errors.Is(err, BucketLifecycleNotFound{Bucket: bi.Name}) { return err } // Check if bucket is object locked. lr, err = globalBucketObjectLockSys.Get(bi.Name) if err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/bucket-object-lock.go
config, _, err := globalBucketMetadataSys.GetObjectLockConfig(bucketName) if err != nil { if errors.Is(err, BucketObjectLockConfigNotFound{Bucket: bucketName}) { return r, nil } if errors.Is(err, errInvalidArgument) { return r, err } return r, err } return config.ToRetention(), nil } // enforceRetentionForDeletion checks if it is appropriate to remove an
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 13.2K bytes - Viewed (0) -
cmd/config-current.go
if _, err := browser.LookupConfig(s[config.BrowserSubSys][config.Default]); err != nil { return err } default: if config.LoggerSubSystems.Contains(subSys) { if err := logger.ValidateSubSysConfig(ctx, s, subSys); err != nil { return err } } } if config.NotifySubSystems.Contains(subSys) { if err := notify.TestSubSysNotificationTargets(ctx, s, subSys, NewHTTPTransport()); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0) -
cmd/data-usage-cache_gen_test.go
v := allTierStats{} bts, err := v.MarshalMsg(nil) if err != nil { t.Fatal(err) } left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) } left, err = msgp.Skip(bts) if err != nil { t.Fatal(err) } if len(left) > 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Jan 13 07:51:08 GMT 2024 - 28.1K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
} else if filter.Name == TCPListener { if !strings.Contains(string(filter.GetTypedConfig().GetValue()), util.BlackHoleCluster) { nTCP++ } } } } if nHTTP > 0 { if nTCP == 0 { return "HTTP" } return "HTTP+TCP" } else if nTCP > 0 { return "TCP" } return "UNKNOWN" } func retrieveListenerAddress(l *listener.Listener) string {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
internal/grid/muxclient.go
if err := m.send(msg); err != nil { return nil, err } if debugReqs { fmt.Println(m.MuxID, m.parent.String(), "SEND") } // Wait for response or context. select { case v, ok := <-ch: if !ok { return nil, ErrDisconnected } if debugReqs && v.Err != nil { v.Err = fmt.Errorf("%d %s RESP ERR: %w", m.MuxID, m.parent.String(), v.Err) } return v.Msg, v.Err case <-ctx.Done(): if debugReqs {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
v, err = cr.reader.ReadByte() if err != nil { if err == io.EOF { return io.ErrUnexpectedEOF } } if v != '\n' { return errMalformedEncoding } break } // Read signature var signatureBuffer bytes.Buffer for { v, err := cr.reader.ReadByte() if err != nil { if err == io.EOF { return io.ErrUnexpectedEOF } } if v != '\r' {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 18.2K bytes - Viewed (0) -
cmd/metacache-server-pool.go
// we should return 'errs' from per disk if isAllNotFound(errs) { if isAllVolumeNotFound(errs) { return errVolumeNotFound } return nil } if err != nil { return err } if contextCanceled(ctx) { return ctx.Err() } for _, err := range errs { if errors.Is(err, io.EOF) { continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0)