- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 858 for err (0.03 sec)
-
internal/config/notify/parse.go
if err := checkValidNotificationKeysForSubSys(subSys, cfg[subSys]); err != nil { return nil, err } switch subSys { case config.NotifyAMQPSubSys: amqpTargets, err := GetNotifyAMQP(cfg[config.NotifyAMQPSubSys]) if err != nil { return nil, err } for id, args := range amqpTargets { if !args.Enable { continue
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 47K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
if target.store != nil { _, err := target.store.Put(eventData) return err } if err := target.init(); err != nil { return err } ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) defer cancel() err := target.checkAndInitClient(ctx) if err != nil { return err } err = target.send(eventData) if xnet.IsNetworkOrHostDown(err, false) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 15K bytes - Viewed (0) -
tests/preload_test.go
}, } values := []*Value{&value1, &value2} if err := DB.Create(&values).Error; err != nil { t.Errorf("failed to create value, got err: %v", err) } var find1 Value err := DB.Joins("Nested").Joins("Nested.Join").Preload("Nested.Preloads").First(&find1, value1.ID).Error if err != nil { t.Errorf("failed to find value, got err: %v", err) } AssertEqual(t, find1, value1) var find2 Value
Registered: Sun Oct 27 09:35:08 UTC 2024 - Last Modified: Wed Jun 12 10:00:47 UTC 2024 - 15.9K bytes - Viewed (0) -
internal/config/identity/openid/jwt_test.go
claimsMap.SetAccessKey("test-access") if err := updateClaimsExpiry("3600", claimsMap.MapClaims); err != nil { t.Error(err) } // Build simple token with updated expiration claim token := jwtgo.NewWithClaims(jwtgo.SigningMethodHS256, claimsMap) tokenString, err := token.SignedString(signKey) if err != nil { t.Error(err) } // Parse token to be sure it is valid
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.3K bytes - Viewed (0) -
internal/bucket/replication/destination.go
if err := e.EncodeToken(start); err != nil { return err } if err := e.EncodeElement(d.String(), xml.StartElement{Name: xml.Name{Local: "Bucket"}}); err != nil { return err } if d.StorageClass != "" { if err := e.EncodeElement(d.StorageClass, xml.StartElement{Name: xml.Name{Local: "StorageClass"}}); err != nil { return err } }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4K bytes - Viewed (0) -
cmd/s3-zip-handlers.go
if len(zipInfo) == 0 { opts.EncryptFn, err = zipObjInfo.metadataEncryptFn(r.Header) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } zipInfo, err = updateObjectMetadataWithZipInfo(ctx, objectAPI, bucket, zipPath, opts) } if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } file, err := zipindex.FindSerialized(zipInfo, object)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.8K bytes - Viewed (0) -
src/bytes/reader_test.go
r := NewReader([]byte("世界")) if _, _, err := r.ReadRune(); err != nil { t.Errorf("ReadRune: unexpected error: %v", err) } const want = "abcdef" r.Reset([]byte(want)) if err := r.UnreadRune(); err == nil { t.Errorf("UnreadRune: expected error, got nil") } buf, err := io.ReadAll(r) if err != nil { t.Errorf("ReadAll: unexpected error: %v", err) } if got := string(buf); got != want {
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 8K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
meta, _, err := sys.GetConfig(GlobalContext, bucket) if err != nil { return time.Time{}, err } return meta.Created.UTC(), nil } // GetPolicyConfig returns configured bucket policy // The returned object may not be modified. func (sys *BucketMetadataSys) GetPolicyConfig(bucket string) (*policy.BucketPolicy, time.Time, error) { meta, _, err := sys.GetConfig(GlobalContext, bucket) if err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 20.4K bytes - Viewed (0) -
cmd/tier-last-day-stats_gen_test.go
v := DailyAllTierStats{} 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 {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 4.6K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor_gen_test.go
v := BucketBandwidthReport{} 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 {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 4.5K bytes - Viewed (0)