Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 37 for appendFile (0.07 seconds)

  1. cmd/naughty-disk_test.go

    		return err
    	}
    	return d.disk.CreateFile(ctx, origvolume, volume, path, size, reader)
    }
    
    func (d *naughtyDisk) AppendFile(ctx context.Context, volume string, path string, buf []byte) error {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.AppendFile(ctx, volume, path, buf)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 10.1K bytes
    - Click Count (0)
  2. cmd/storage-rest-client.go

    func (client *storageRESTClient) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) {
    	return errInvalidArgument
    }
    
    // AppendFile - append to a file.
    func (client *storageRESTClient) AppendFile(ctx context.Context, volume string, path string, buf []byte) error {
    	values := make(url.Values)
    	values.Set(storageRESTVolume, volume)
    	values.Set(storageRESTFilePath, path)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 08 02:38:41 GMT 2025
    - 30.4K bytes
    - Click Count (0)
  3. cmd/erasure-encode_test.go

    	"context"
    	"crypto/rand"
    	"io"
    	"testing"
    
    	"github.com/dustin/go-humanize"
    )
    
    type badDisk struct{ StorageAPI }
    
    func (a badDisk) String() string {
    	return "bad-disk"
    }
    
    func (a badDisk) AppendFile(ctx context.Context, volume string, path string, buf []byte) error {
    	return errFaultyDisk
    }
    
    func (a badDisk) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  4. cmd/storage-rest_test.go

    		}
    	}
    }
    
    func testStorageAPIRenameFile(t *testing.T, storage StorageAPI) {
    	err := storage.AppendFile(t.Context(), "foo", "myobject", []byte("foo"))
    	if err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    
    	err = storage.AppendFile(t.Context(), "foo", "otherobject", []byte("foo"))
    	if err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    
    	testCases := []struct {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  5. cmd/xl-storage-disk-id-check.go

    		return p.storage.ReadFile(ctx, volume, path, offset, buf, verifier)
    	})
    }
    
    // Legacy API - does not have any deadlines
    func (p *xlStorageDiskIDCheck) AppendFile(ctx context.Context, volume string, path string, buf []byte) (err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricAppendFile, volume, path)
    	if err != nil {
    		return err
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  6. cmd/storage-rest-server.go

    	filePath := r.Form.Get(storageRESTFilePath)
    
    	buf := make([]byte, r.ContentLength)
    	_, err := io.ReadFull(r.Body, buf)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    	err = s.getStorage().AppendFile(r.Context(), volume, filePath, buf)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    	}
    }
    
    // CreateFileHandler - copy the contents from the request.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 45.7K bytes
    - Click Count (0)
  7. cmd/batch-handlers_gen.go

    	// string "jt"
    	o = append(o, 0xa2, 0x6a, 0x74)
    	o = msgp.AppendString(o, z.JobType)
    	// string "st"
    	o = append(o, 0xa2, 0x73, 0x74)
    	o = msgp.AppendTime(o, z.StartTime)
    	// string "lu"
    	o = append(o, 0xa2, 0x6c, 0x75)
    	o = msgp.AppendTime(o, z.LastUpdate)
    	// string "ra"
    	o = append(o, 0xa2, 0x72, 0x61)
    	o = msgp.AppendInt(o, z.RetryAttempts)
    	// string "at"
    	o = append(o, 0xa2, 0x61, 0x74)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 20.4K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/base/Joiner.java

      public <A extends Appendable> A appendTo(A appendable, Iterator<?> parts) throws IOException {
        checkNotNull(appendable);
        if (parts.hasNext()) {
          appendable.append(toString(parts.next()));
          while (parts.hasNext()) {
            appendable.append(separator);
            appendable.append(toString(parts.next()));
          }
        }
        return appendable;
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 19.3K bytes
    - Click Count (0)
  9. cmd/erasure-server-pool-rebalance_gen.go

    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 3
    	// string "startTs"
    	o = append(o, 0x83, 0xa7, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x73)
    	o = msgp.AppendTime(o, z.StartTime)
    	// string "stopTs"
    	o = append(o, 0xa6, 0x73, 0x74, 0x6f, 0x70, 0x54, 0x73)
    	o = msgp.AppendTime(o, z.EndTime)
    	// string "status"
    	o = append(o, 0xa6, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73)
    	o = msgp.AppendUint8(o, uint8(z.Status))
    	return
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.8K bytes
    - Click Count (0)
  10. guava/src/com/google/common/base/Joiner.java

      public <A extends Appendable> A appendTo(A appendable, Iterator<?> parts) throws IOException {
        checkNotNull(appendable);
        if (parts.hasNext()) {
          appendable.append(toString(parts.next()));
          while (parts.hasNext()) {
            appendable.append(separator);
            appendable.append(toString(parts.next()));
          }
        }
        return appendable;
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Apr 14 15:16:19 GMT 2025
    - 21K bytes
    - Click Count (0)
Back to Top