- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 71 for Read (0.32 sec)
-
cmd/erasure-server-pool-decom.go
return nil } return err } if len(data) == 0 { // Seems to be empty create a new poolMeta object. return nil } if len(data) <= 4 { return fmt.Errorf("poolMeta: no data") } // Read header switch binary.LittleEndian.Uint16(data[0:2]) { case poolMetaFormat: default: return fmt.Errorf("poolMeta: unknown format: %d", binary.LittleEndian.Uint16(data[0:2])) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/metrics-v3-system-process.go
processIORCharBytesMD = NewCounterMD(processIORCharBytes, "Total bytes read by the process from the underlying storage system including cache, /proc/[pid]/io rchar") processIOReadBytesMD = NewCounterMD(processIOReadBytes, "Total bytes read by the process from the underlying storage system, /proc/[pid]/io read_bytes")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 16:07:23 GMT 2024 - 6.4K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
setupLogging() ctx, cancel := context.WithCancel(context.Background()) defer cancel() fixture := connect(ctx) ztunClient := fixture.ztunClient uid := fixture.uid // read initial pod add readRequest(t, ztunClient) sendAck(ztunClient) // read snapshot sent m, fds := readRequest(t, ztunClient) assert.Equal(t, len(fds), 0) sent := m.Payload.(*zdsapi.WorkloadRequest_SnapshotSent).SnapshotSent if sent == nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject.go
for _, ws := range was { if ws.Injected { injectedTotal++ } w.AddRow(ws) } w.Flush() if injectedTotal > 1 { fmt.Fprintf(writer, "ERROR: multiple webhooks will inject, which can lead to errors") } return nil } type webhookAnalysis struct { Name string Revision string Injected bool Reason string }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/iam-store.go
} else { c.iamUsersMap[key] = u } c.updatedAt = time.Now() return nil } // IAMStorageAPI defines an interface for the IAM persistence layer type IAMStorageAPI interface { // The role of the read-write lock is to prevent go routines from // concurrently reading and writing the IAM storage. The (r)lock() // functions return the iamCache. The cache can be safely written to // only when returned by `lock()`.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/erasure-decode.go
bufCount := 0 for _, b := range buf { if len(b) > 0 { bufCount++ } } return bufCount >= p.dataBlocks } // Read reads from readers in parallel. Returns p.dataBlocks number of bufs. func (p *parallelReader) Read(dst [][]byte) ([][]byte, error) { newBuf := dst if len(dst) != len(p.readers) { newBuf = make([][]byte, len(p.readers)) } else { for i := range newBuf {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/server-main.go
Hidden: true, }, cli.DurationFlag{ Name: "read-header-timeout", Value: xhttp.DefaultReadHeaderTimeout, Usage: "read header timeout is the amount of time allowed to read request headers", EnvVar: "MINIO_READ_HEADER_TIMEOUT", Hidden: true, }, cli.DurationFlag{ Name: "conn-client-read-deadline", Usage: "custom connection READ deadline for incoming requests", Hidden: true,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 34.9K bytes - Viewed (1) -
internal/event/name_test.go
}{ {BucketCreated, "s3:BucketCreated:*"}, {BucketRemoved, "s3:BucketRemoved:*"}, {ObjectAccessedAll, "s3:ObjectAccessed:*"}, {ObjectAccessedGet, "s3:ObjectAccessed:Get"}, {ObjectAccessedHead, "s3:ObjectAccessed:Head"}, {ObjectCreatedAll, "s3:ObjectCreated:*"}, {ObjectCreatedCompleteMultipartUpload, "s3:ObjectCreated:CompleteMultipartUpload"}, {ObjectCreatedCopy, "s3:ObjectCreated:Copy"}, {ObjectCreatedPost, "s3:ObjectCreated:Post"},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/object-api-listobjects_test.go
// The length of the expected ListObjectsResult.Objects // should match in both expected result from test cases // and in the output. On failure calling t.Fatalf, // otherwise it may lead to index out of range error in // assertion following this. if !testCase.versioned { if len(testCase.resultL.Objects) != len(resultL.Objects) { t.Logf("want: %v", objInfoNames(testCase.resultL.Objects))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 11:07:40 GMT 2024 - 73.1K bytes - Viewed (0) -
cmd/config-current.go
Description: "persist IAM assets externally to etcd", }, config.HelpKV{ Key: config.CacheSubSys, Type: "string", Description: "enable cache plugin on MinIO for GET/HEAD requests", Optional: true, }, config.HelpKV{ Key: config.BrowserSubSys, Description: "manage Browser HTTP specific features, such as Security headers, etc.", Optional: true, },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0)