- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 67 for Breiding (0.25 sec)
-
internal/s3select/json/reader_test.go
} r := NewReader(f, &ReaderArgs{}) var record sql.Record for { record, err = r.Read(record) if err != nil { break } } r.Close() if err != io.EOF { t.Fatalf("Reading failed with %s, %s", err, file.Name()) } }) t.Run(file.Name()+"-close", func(t *testing.T) { f, err := os.Open(filepath.Join("testdata", file.Name())) if err != nil { t.Fatal(err) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 2.5K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
// The s3ChunkedReader returns io.EOF when the final 0-length chunk is read. // // NewChunkedReader is not needed by normal applications. The http package // automatically decodes chunking when reading response bodies. func newSignV4ChunkedReader(req *http.Request, trailer bool) (io.ReadCloser, APIErrorCode) { cred, seedSignature, region, seedDate, errCode := calculateSeedSignature(req, trailer) if errCode != ErrNone {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 18.2K bytes - Viewed (0) -
cmd/storage-rest-client.go
readMsgpReaderPool.Put(r) } } func (client *storageRESTClient) ReadVersion(ctx context.Context, origvolume, volume, path, versionID string, opts ReadOptions) (fi FileInfo, err error) { // Use websocket when not reading data. if !opts.ReadData { resp, err := storageReadVersionRPC.Call(ctx, client.gridConn, grid.NewMSSWith(map[string]string{ storageRESTDiskID: *client.diskID.Load(), storageRESTOrigVolume: origvolume,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
internal/grid/manager.go
} } defer conn.Close() if debugPrint { fmt.Printf("grid: Upgraded request: %v\n", req.URL) } msg, _, err := wsutil.ReadClientData(conn) if err != nil { writeErr(fmt.Errorf("reading connect: %w", err)) w.WriteHeader(http.StatusForbidden) return } if debugPrint { fmt.Printf("%s handler: Got message, length %v\n", m.local, len(msg)) } var message message
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux_test.go
` var err error dir := t.TempDir() mountsPath := filepath.Join(dir, "mounts") if err = os.WriteFile(mountsPath, []byte(successCase), 0o666); err != nil { t.Fatal(err) } // Verifies if reading each line worked properly. { var mounts mountInfos mounts, err = readProcMounts(mountsPath) if err != nil { t.Fatal(err) } if len(mounts) != 3 {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.3K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
} // Target - Kafka target. type Target struct { status int32 totalMessages int64 failedMessages int64 wg sync.WaitGroup // Channel of log entries. // Reading logCh must hold read lock on logChMu (to avoid read race) // Sending a value on logCh must hold read lock on logChMu (to avoid closing) logCh chan interface{} logChMu sync.RWMutex
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
cmd/auth-handler_test.go
if s3Error != testCase.s3Error { if _, err := io.ReadAll(testCase.req.Body); toAPIErrorCode(ctx, err) != testCase.s3Error { t.Fatalf("Test %d: Unexpected S3 error: want %d - got %d (got after reading request %s)", i, testCase.s3Error, s3Error, toAPIError(ctx, err).Code) } } } } func TestCheckAdminRequestAuthType(t *testing.T) { ctx, cancel := context.WithCancel(context.Background())
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 15.4K bytes - Viewed (0) -
cmd/format-erasure.go
format.Erasure.Sets[i] = make([]string, setLen) for j := 0; j < setLen; j++ { format.Erasure.Sets[i][j] = mustGetUUID() } } return format } // Returns format Erasure version after reading `format.json`, returns // successfully the version only if the backend is Erasure. func formatGetBackendErasureVersion(b []byte) (string, error) { meta := &formatMetaV1{} if err := json.Unmarshal(b, meta); err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 23.4K bytes - Viewed (0) -
docs/debugging/xattr/main.go
if err := setxattr(path, name, value); err != nil { log.Fatalln(fmt.Errorf("setting attribute %s failed with: %v", name, err)) } } else { if name == "" { log.Fatalln("you must specify an attribute name for reading") } var names []string if name == "." { attrs, err := listxattr(path) if err != nil { log.Fatalln(fmt.Errorf("listing attributes failed with: %v", err)) } names = append(names, attrs...)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Dec 29 23:52:41 GMT 2023 - 3.2K bytes - Viewed (0) -
internal/s3select/parquet/reader.go
parquettypes "github.com/fraugster/parquet-go/parquet" jsonfmt "github.com/minio/minio/internal/s3select/json" "github.com/minio/minio/internal/s3select/sql" ) // Reader implements reading records from parquet input. type Reader struct { io.Closer r *parquetgo.FileReader } // NewParquetReader creates a Reader2 from a io.ReadSeekCloser.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 14 13:54:47 GMT 2022 - 4.5K bytes - Viewed (0)