- Sort Score
- Result 10 results
- Languages All
Results 51 - 59 of 59 for Writer (0.32 sec)
-
cmd/erasure-healing.go
defer grid.PutByteBuffer(buf) writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize()) } else { writers[i] = newBitrotWriter(disk, bucket, minioMetaTmpBucket, partPath, tillOffset, DefaultBitrotAlgorithm, erasure.ShardSize()) } } // Heal each part. erasure.Heal() will write the healed
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/ftp-server-driver.go
"github.com/minio/pkg/v2/mimedb" ftp "goftp.io/server/v2" ) var _ ftp.Driver = &ftpDriver{} // ftpDriver implements ftpDriver to store files in minio type ftpDriver struct { endpoint string } // NewFTPDriver implements ftp.Driver interface func NewFTPDriver() ftp.Driver { return &ftpDriver{endpoint: fmt.Sprintf("127.0.0.1:%s", globalMinioPort)} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 13.6K bytes - Viewed (0) -
cmd/sftp-server-driver.go
w.m.Lock() defer w.m.Unlock() if w.nextOffset == offset { n, err = w.w.Write(b) w.nextOffset += int64(n) } else { w.buffer[offset] = make([]byte, len(b)) copy(w.buffer[offset], b) n = len(b) } again: nextOut, ok := w.buffer[w.nextOffset] if ok { n, err = w.w.Write(nextOut) delete(w.buffer, w.nextOffset) w.nextOffset += int64(n) if n != len(nextOut) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 12.9K bytes - Viewed (0) -
cmd/metacache-set.go
} func calcCommonWritesDeletes(infos []DiskInfo, readQuorum int) (commonWrite, commonDelete uint64) { deletes := make([]uint64, len(infos)) writes := make([]uint64, len(infos)) for index, di := range infos { deletes[index] = di.Metrics.TotalDeletes writes[index] = di.Metrics.TotalWrites } filter := func(list []uint64) (commonCount uint64) { max := 0 signatureMap := map[uint64]int{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
docs/bigdata/README.md
- Run the Apache Spark Pi job in yarn-client mode, using code from **org.apache.spark**: ``` ./bin/spark-submit --class org.apache.spark.examples.SparkPi \ --master yarn-client \ --num-executors 1 \ --driver-memory 512m \ --executor-memory 512m \ --executor-cores 1 \ examples/jars/spark-examples*.jar 10 ``` The job should produce an output as shown below. Note the value of pi in the output. ```
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 14.7K bytes - Viewed (0) -
internal/config/config.go
b.WriteString(KvSpaceSeparator) b.WriteString(ep.Name) b.WriteString(EnvSeparator) b.WriteString(ep.Value) b.WriteString(KvNewline) } } } // WriteTo writes the string representation of the configuration to the given // builder. When off is true, adds a comment character before the config system // output. It also ignores values when empty and deprecated.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0) -
internal/http/headers.go
MinIOSourceMTime = "x-minio-source-mtime" // Header indicates if the etag should be preserved by client MinIOSourceETag = "x-minio-source-etag" // Writes expected write quorum MinIOWriteQuorum = "x-minio-write-quorum" // Reads expected read quorum MinIOReadQuorum = "x-minio-read-quorum" // Indicates if we are using default storage class and there was problem loading config
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 10.4K bytes - Viewed (1) -
cmd/utils.go
) // dump the request into a string in JSON format. func dumpRequest(r *http.Request) string { header := r.Header.Clone() header.Set("Host", r.Host) // Replace all '%' to '%%' so that printer format parser // to ignore URL encoded values. rawURI := strings.ReplaceAll(r.RequestURI, "%", "%%") req := struct { Method string `json:"method"` RequestURI string `json:"reqURI"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 31.4K bytes - Viewed (0) -
internal/event/target/mysql.go
package target import ( "context" "database/sql" "encoding/json" "errors" "fmt" "net/url" "os" "path/filepath" "strconv" "strings" "time" "github.com/go-sql-driver/mysql" "github.com/minio/minio/internal/event" "github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/once" "github.com/minio/minio/internal/store" xnet "github.com/minio/pkg/v2/net" )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 11.5K bytes - Viewed (0)