- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 248 for Block (0.2 sec)
-
cmd/metacache-set.go
return pathJoin(bucketMetaPrefix, bucket, metacachePrefix, id) } // objectPath returns the object path of the cache. func (o *listPathOptions) objectPath(block int) string { return pathJoin(metacachePrefixForID(o.Bucket, o.ID), "block-"+strconv.Itoa(block)+".s2") } func (o *listPathOptions) SetFilter() { switch { case metacacheSharePrefix: return case o.Prefix == o.BaseDir: // No additional prefix
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) -
cmd/erasure-decode.go
var bytesWritten int64 var bufs [][]byte for block := startBlock; block <= endBlock; block++ { var blockOffset, blockLength int64 switch { case startBlock == endBlock: blockOffset = offset % e.blockSize blockLength = length case block == startBlock: blockOffset = offset % e.blockSize blockLength = e.blockSize - blockOffset case block == endBlock: blockOffset = 0
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
.golangci.yml
- govet - ineffassign - misspell - revive - staticcheck - tenv - typecheck - unconvert - unused issues: exclude-use-default: false exclude: - "empty-block:" - "unused-parameter:" - "dot-imports:" - should have a package comment
Others - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Dec 07 02:17:03 GMT 2023 - 689 bytes - Viewed (0) -
internal/s3select/json/preader.go
type PReader struct { args *ReaderArgs readCloser io.ReadCloser // raw input buf *bufio.Reader // input to the splitter current []jstream.KVS // current block of results to be returned recordsRead int // number of records read in current slice input chan *queueItem // input for workers queue chan *queueItem // output from workers in order
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 6.4K bytes - Viewed (0) -
cmd/veeam-sos-api.go
// slots are used for object offloading or writing) // // - <KbBlockSize> // Veeam Block Size for backup and restore processing before compression is applied. The higher the block size, the more // backup space is needed for incremental backups. Larger block sizes also mean less performance for random read restore
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jan 30 18:43:58 GMT 2024 - 8.2K bytes - Viewed (2) -
cmd/metacache-stream.go
buf.Reset() bytebufferpool.Put(buf) }() block := newMetacacheWriter(buf, 1<<20) defer block.Close() finishBlock := func() { if err := block.Close(); err != nil { w.streamErr = err return } current.data = buf.Bytes() w.streamErr = nextBlock(¤t) // Prepare for next current.n++ buf.Reset() block.Reset(buf) current.First = "" }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
cmd/xl-storage-format-v1.go
DataBlocks int `json:"data"` // ParityBlocks is the number of parity blocks for erasure-coding ParityBlocks int `json:"parity"` // BlockSize is the size of one erasure-coded block BlockSize int64 `json:"blockSize"` // Index is the index of the current disk Index int `json:"index"` // Distribution is the distribution of the data and parity blocks Distribution []int `json:"distribution"`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 8.2K bytes - Viewed (0) -
docs/sts/dex.yaml
# Uncomment for HTTPS options. # https: 127.0.0.1:5554 # tlsCert: /etc/dex/tls.crt # tlsKey: /etc/dex/tls.key # Configuration for telemetry telemetry: http: 0.0.0.0:5558 # Uncomment this block to enable configuration for the expiration time durations. expiry: signingKeys: "3h" idTokens: "3h" # Options for controlling the logger. logger: level: "debug" format: "text" # can also be "json"
Others - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Jul 15 11:55:55 GMT 2020 - 2.7K bytes - Viewed (1) -
internal/grid/connection_test.go
}() cleanReqs := make(chan struct{}) gotCall := make(chan struct{}) defer close(cleanReqs) // 1: Block forever h1 := func(payload []byte) ([]byte, *RemoteErr) { gotCall <- struct{}{} <-cleanReqs return nil, nil } // 2: Also block, but with streaming. h2 := StreamHandler{ Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 6K bytes - Viewed (0) -
internal/ioutil/ioutil.go
"os" "runtime/debug" "sync" "time" "github.com/dustin/go-humanize" "github.com/minio/minio/internal/disk" ) // Block sizes constant. const ( SmallBlock = 32 * humanize.KiByte // Default r/w block size for smaller objects. LargeBlock = 1 * humanize.MiByte // Default r/w block size for normal objects. ) // aligned sync.Pool's var ( ODirectPoolLarge = sync.Pool{ New: func() interface{} {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0)