Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 858 for err (0.05 sec)

  1. internal/ringbuffer/ring_buffer_test.go

    		t.Errorf("Write error: got %T, want testError1", err)
    	}
    
    	rb.Reset()
    	rb.CloseWithError(testError1{})
    	if _, err := rb.Read(nil); err != (testError1{}) {
    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    	if _, err := rb.Read([]byte{0}); err != (testError1{}) {
    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    	if _, err := rb.ReadByte(); err != (testError1{}) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  2. internal/ioutil/wait_pipe.go

    func (w *PipeWriter) CloseWithError(err error) error {
    	err = w.PipeWriter.CloseWithError(err)
    	w.once.Do(func() {
    		w.done()
    	})
    	return err
    }
    
    // PipeReader is similar to io.PipeReader with wait group
    type PipeReader struct {
    	*io.PipeReader
    	wait func()
    }
    
    // CloseWithError close with supplied error the reader end
    func (r *PipeReader) CloseWithError(err error) error {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 27 14:55:36 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  3. tests/query_test.go

    			Name: "item_2_2",
    		},
    	}
    
    	var err error
    	err = DB.Create(&q1).Error
    	if err != nil {
    		t.Errorf("failed to create:%v", err)
    	}
    
    	err = DB.Create(&q2).Error
    	if err != nil {
    		t.Errorf("failed to create:%v", err)
    	}
    
    	var qs []QueryResetNullValue
    	err = DB.Joins("Item1").Joins("Item2").Find(&qs).Error
    	if err != nil {
    		t.Errorf("failed to find:%v", err)
    	}
    
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 50.4K bytes
    - Viewed (0)
  4. internal/event/target/redis.go

    				return err
    			}
    
    			_, err = conn.Do("HSET", target.args.Key, key, data)
    		}
    		if err != nil {
    			return err
    		}
    	}
    
    	if target.args.Format == event.AccessFormat {
    		data, err := json.Marshal([]RedisAccessEvent{{Event: []event.Event{eventData}, EventTime: eventData.EventTime}})
    		if err != nil {
    			return err
    		}
    		if _, err := conn.Do("RPUSH", target.args.Key, data); err != nil {
    			return err
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  5. internal/event/target/amqp.go

    func (target *AMQPTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    	if err := target.init(); err != nil {
    		return err
    	}
    	ch, confirms, err := target.channel()
    	if err != nil {
    		return err
    	}
    	defer ch.Close()
    
    	return target.send(eventData, ch, confirms)
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. cmd/update.go

    func getModTime(path string) (t time.Time, err error) {
    	// Convert to absolute path
    	absPath, err := filepath.Abs(path)
    	if err != nil {
    		return t, fmt.Errorf("Unable to get absolute path of %s. %w", path, err)
    	}
    
    	// Version is minio non-standard, we will use minio binary's
    	// ModTime as release time.
    	fi, err := Stat(absPath)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  7. tests/delete_test.go

    		}
    	}
    
    	for _, user := range []User{users[0], users[2]} {
    		result = User{}
    		if err := DB.Where("id = ?", user.ID).First(&result).Error; err != nil {
    			t.Errorf("no error should returns when query %v, but got %v", user.ID, err)
    		}
    	}
    
    	if err := DB.Delete(&users[0]).Error; err != nil {
    		t.Errorf("errors happened when delete: %v", err)
    	}
    
    	if err := DB.Delete(&User{}).Error; err != gorm.ErrMissingWhereClause {
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Tue Oct 10 07:03:34 UTC 2023
    - 9.4K bytes
    - Viewed (0)
  8. cmd/format-erasure_test.go

    	b, err := json.Marshal(m)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	if err = os.MkdirAll(pathJoin(rootPath, minioMetaBucket), os.FileMode(0o755)); err != nil {
    		t.Fatal(err)
    	}
    
    	if err = os.WriteFile(pathJoin(rootPath, minioMetaBucket, formatConfigFile), b, os.FileMode(0o644)); err != nil {
    		t.Fatal(err)
    	}
    
    	formatData, _, err := formatErasureMigrate(rootPath)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Apr 15 08:25:46 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  9. internal/bucket/object/lock/lock.go

    func ParseObjectLegalHold(reader io.Reader) (hold *ObjectLegalHold, err error) {
    	buf, err := io.ReadAll(io.LimitReader(reader, maxObjectLockConfigSize))
    	if err != nil {
    		return nil, err
    	}
    
    	hold = &ObjectLegalHold{}
    	if err = xml.NewDecoder(bytes.NewReader(buf)).Decode(hold); err != nil {
    		return nil, err
    	}
    
    	if !hold.Status.Valid() {
    		return nil, ErrMalformedXML
    	}
    	return
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Jun 29 01:20:27 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  10. cmd/benchmark-utils_test.go

    func runPutObjectBenchmark(b *testing.B, obj ObjectLayer, objSize int) {
    	var err error
    	// obtains random bucket name.
    	bucket := getRandomBucketName()
    	// create bucket.
    	err = obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{})
    	if err != nil {
    		b.Fatal(err)
    	}
    
    	// get text data generated for number of bytes equal to object size.
    	textData := generateBytesData(objSize)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Dec 23 15:46:00 UTC 2022
    - 8.2K bytes
    - Viewed (0)
Back to top