- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 130 for io (0.12 sec)
-
internal/s3select/csv/record.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package csv import ( "encoding/json" "errors" "fmt" "io" "strconv" "strings" "github.com/bcicen/jstream" csv "github.com/minio/csvparser" "github.com/minio/minio/internal/s3select/sql" ) // Record - is a CSV record. type Record struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Sep 13 00:00:59 GMT 2022 - 4.1K bytes - Viewed (0) -
internal/config/heal/heal.go
) // Compression environment variables const ( Bitrot = "bitrotscan" Sleep = "max_sleep" IOCount = "max_io" DriveWorkers = "drive_workers" EnvBitrot = "MINIO_HEAL_BITROTSCAN" EnvSleep = "MINIO_HEAL_MAX_SLEEP" EnvIOCount = "MINIO_HEAL_MAX_IO" EnvDriveWorkers = "MINIO_HEAL_DRIVE_WORKERS" ) var configMutex sync.RWMutex // Config represents the heal settings.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 4.9K bytes - Viewed (0) -
internal/logger/logrotate.go
return err } } return nil } var stdErrEnc = json.NewEncoder(os.Stderr) func (w *Writer) listen() { for { var r io.Reader = w.pr if w.opts.MaximumFileSize > 0 { r = io.LimitReader(w.pr, w.opts.MaximumFileSize) } if _, err := io.Copy(w.f, r); err != nil { msg := fmt.Sprintf("unable to write to log file %v: %v", w.f.Name(), err) stdErrEnc.Encode(&log.Entry{ Level: ErrorKind,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 11:38:40 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/erasure-utils.go
// You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "encoding/base64" "fmt" "io" "strings" "github.com/klauspost/reedsolomon" ) // getDataBlockLen - get length of data blocks from encoded blocks. func getDataBlockLen(enBlocks [][]byte, dataBlocks int) int { size := 0
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 3.1K bytes - Viewed (0) -
internal/s3select/sql/jsonpath_test.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package sql import ( "bytes" "fmt" "io" "os" "path/filepath" "reflect" "testing" "github.com/alecthomas/participle" "github.com/bcicen/jstream" ) func getJSONStructs(b []byte) ([]interface{}, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 2.8K bytes - Viewed (0) -
cmd/warm-backend-azure.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "encoding/base64" "errors" "fmt" "io" "net/http" "net/url" "strings" "time" "github.com/Azure/azure-storage-blob-go/azblob" "github.com/Azure/go-autorest/autorest/adal" "github.com/Azure/go-autorest/autorest/azure"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 05 16:44:08 GMT 2024 - 7.8K bytes - Viewed (1) -
cmd/warm-backend-minio.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "errors" "fmt" "io" "math" "net/url" "strings" "github.com/minio/madmin-go/v3" minio "github.com/minio/minio-go/v7" "github.com/minio/minio-go/v7/pkg/credentials" ) type warmBackendMinIO struct { warmBackendS3
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.8K bytes - Viewed (0) -
internal/http/request-recorder.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package http import ( "bytes" "io" ) // RequestRecorder - records the // of a given io.Reader type RequestRecorder struct { // Data source to record io.Reader // Response body should be logged LogBody bool // internal recording buffer buf bytes.Buffer // total bytes read including header size
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 12 21:37:19 GMT 2023 - 1.8K bytes - Viewed (0) -
cmd/bitrot_test.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "io" "testing" ) func testBitrotReaderWriterAlgo(t *testing.T, bitrotAlgo BitrotAlgorithm) { tmpDir := t.TempDir() volume := "testvol" filePath := "testfile" disk, err := newLocalXLStorage(tmpDir)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 2.1K bytes - Viewed (0) -
cmd/bucket-versioning-handler.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "encoding/base64" "encoding/xml" "io" "net/http" humanize "github.com/dustin/go-humanize" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/bucket/versioning" "github.com/minio/minio/internal/logger" "github.com/minio/mux"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5K bytes - Viewed (0)