- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 360 for io (0.2 sec)
-
cmd/metrics-v3-system-process.go
} func loadProcIOMetrics(ctx context.Context, io procfs.ProcIO, m MetricValues) { if io.RChar > 0 { m.Set(processIORCharBytes, float64(io.RChar)) } if io.ReadBytes > 0 { m.Set(processIOReadBytes, float64(io.ReadBytes)) } if io.WChar > 0 { m.Set(processIOWCharBytes, float64(io.WChar)) } if io.WriteBytes > 0 { m.Set(processIOWriteBytes, float64(io.WriteBytes)) } if io.SyscR > 0 {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 16:07:23 GMT 2024 - 6.4K bytes - Viewed (0) -
internal/etag/reader.go
// access to the ETag computed by a low-level io.Reader: // // content := etag.NewReader(r.Body, nil) // // compressedContent := Compress(content) // encryptedContent := Encrypt(compressedContent) // // // Now, we need an io.Reader that can access // // the ETag computed over the content. // reader := etag.Wrap(encryptedContent, content) func Wrap(wrapped, content io.Reader) io.Reader { if t, ok := content.(Tagger); ok {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/erasure-encode.go
func (e *Erasure) Encode(ctx context.Context, src io.Reader, writers []io.Writer, buf []byte, quorum int) (total int64, err error) { writer := ¶llelWriter{ writers: writers, writeQuorum: quorum, errs: make([]error, len(writers)), } for { var blocks [][]byte n, err := io.ReadFull(src, buf) if err != nil { if !IsErrIgnored(err, []error{ io.EOF, io.ErrUnexpectedEOF, }...) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 3K bytes - Viewed (0) -
README.md
[![Slack](https://slack.min.io/slack?type=svg)](https://slack.min.io) [![Docker Pulls](https://img.shields.io/docker/pulls/minio/minio.svg?maxAge=604800)](https://hub.docker.com/r/minio/minio/) [![license](https://img.shields.io/badge/license-AGPL%20V3-blue)](https://github.com/minio/minio/blob/master/LICENSE) [![MinIO](https://raw.githubusercontent.com/minio/minio/master/.github/logo.svg?sanitize=true)](https://min.io)
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Feb 14 17:51:34 GMT 2024 - 18.7K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
r.err = &err return } } if in.Error == io.EOF { return } } } // NewReader - creates new JSON reader using readCloser. func NewReader(readCloser io.ReadCloser, args *json.ReaderArgs) *Reader { r := Reader{ args: args, readCloser: &safeCloser{r: io.Reader(readCloser)}, decoded: make(chan simdjson.Object, 1000),
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0) -
docs/debugging/inspect/decrypt-v2.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package main import ( "errors" "fmt" "io" "os" "github.com/minio/madmin-go/v3/estream" ) type keepFileErr struct { error } func extractInspectV2(pk []byte, r io.Reader, w io.Writer, okMsg string) error { privKey, err := bytesToPrivateKey(pk) if err != nil { return fmt.Errorf("decoding key returned: %w", err) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 2.2K bytes - Viewed (0) -
cmd/metacache-set.go
switch { case err == nil: case errors.Is(err, io.ErrUnexpectedEOF): if retries == 10 { err := o.checkMetacacheState(ctx, rpc) if err != nil { return entries, fmt.Errorf("remote listing canceled: %w", err) } retries = -1 } retryWait() continue case errors.Is(err, io.EOF): return entries, io.EOF } // We got a stream to start at. loadedPart := 0
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
Dockerfile.release
# Download minio binary and signature file RUN curl -s -q https://dl.min.io/server/minio/release/linux-${TARGETARCH}/archive/minio.${RELEASE} -o /go/bin/minio && \ curl -s -q https://dl.min.io/server/minio/release/linux-${TARGETARCH}/archive/minio.${RELEASE}.minisig -o /go/bin/minio.minisig && \ chmod +x /go/bin/minio # Download mc binary and signature file RUN curl -s -q https://dl.min.io/client/mc/release/linux-${TARGETARCH}/mc -o /go/bin/mc && \
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 29 19:10:49 GMT 2024 - 2.8K bytes - Viewed (1) -
internal/s3select/json/preader_test.go
b.ReportAllocs() b.ResetTimer() var record sql.Record for i := 0; i < b.N; i++ { r := NewPReader(io.NopCloser(bytes.NewBuffer(f)), &ReaderArgs{}) for { record, err = r.Read(record) if err != nil { break } } r.Close() if err != io.EOF { b.Fatalf("Reading failed with %s, %s", err, file.Name()) } } }) }
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) -
helm-releases/minio-4.0.12.tgz
node-role.kubernetes.io/ingress: platform annotations: {} # kubernetes.io/ingress.class: nginx # kubernetes.io/tls-acme: "true" # kubernetes.io/ingress.allow-http: "false" # kubernetes.io/ingress.global-static-ip-name: "" # nginx.ingress.kubernetes.io/secure-backends: "true" # nginx.ingress.kubernetes.io/backend-protocol: "HTTPS" # nginx.ingress.kubernetes.io/whitelist-source-range: 0.0.0.0/0 path: / hosts: - console.minio-example.local tls: [] # - secretName: chart-example-tls # hosts: # - chart-example.local ##...
Others - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Aug 14 05:50:43 GMT 2022 - 19.4K bytes - Viewed (0)