- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 230 for io (0.14 sec)
-
internal/s3select/csv/reader.go
} dst = dst[:skip] if skip > 0 { n, err := io.ReadFull(r.buf, dst) if err != nil && err != io.ErrUnexpectedEOF { // If an EOF happens after reading some but not all the bytes, // ReadFull returns ErrUnexpectedEOF. return dst[:n], err } dst = dst[:n] if err == io.ErrUnexpectedEOF { return dst, io.EOF } } // Read until next line. in, err := r.buf.ReadBytes('\n')
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
internal/ioutil/discard.go
package ioutil import ( "io" ) // Discard is just like io.Discard without the io.ReaderFrom compatible // implementation which is buggy on NUMA systems, we have to use a simpler // io.Writer implementation alone avoids also unnecessary buffer copies, // and as such incurred latencies. var Discard io.Writer = discard{} // discard is /dev/null for Golang. type discard struct{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 1.3K bytes - Viewed (0) -
docs/debugging/inspect/decrypt-v1.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package main import ( "encoding/binary" "encoding/hex" "fmt" "hash/crc32" "io" "github.com/secure-io/sio-go" ) func extractInspectV1(keyHex string, r io.Reader, w io.Writer, okMsg string) error { id, err := hex.DecodeString(keyHex[:8]) if err != nil { return err } key, err := hex.DecodeString(keyHex[8:]) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 1.6K bytes - Viewed (0) -
internal/hash/reader.go
package hash import ( "bytes" "context" "encoding/base64" "encoding/hex" "errors" "hash" "io" "net/http" "github.com/minio/minio/internal/etag" "github.com/minio/minio/internal/hash/sha256" "github.com/minio/minio/internal/ioutil" ) // A Reader wraps an io.Reader and computes the MD5 checksum // of the read content as ETag. Optionally, it also computes // the SHA256 checksum of the content.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 10.8K bytes - Viewed (0) -
internal/s3select/csv/reader_contrib_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 38.5K bytes - Viewed (0) -
cmd/test-utils_test.go
// If the body is read in the handler the same request cannot be made use of. buf, err := io.ReadAll(anonReq.Body) if err != nil { t.Fatal(failTestStr(anonTestStr, err.Error())) } // creating 2 read closer (to set as request body) from the body content. readerOne := io.NopCloser(bytes.NewBuffer(buf)) readerTwo := io.NopCloser(bytes.NewBuffer(buf)) anonReq.Body = readerOne // call the HTTP handler.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
var signature [80]byte _, err = io.ReadFull(cr.reader, signature[:]) if err == io.EOF { err = io.ErrUnexpectedEOF } if err != nil { cr.err = err return n, cr.err } if !bytes.HasPrefix(signature[:], []byte("chunk-signature=")) { cr.err = errMalformedEncoding return n, cr.err } b, err := cr.reader.ReadByte() if err == io.EOF { err = io.ErrUnexpectedEOF } if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 18.2K bytes - Viewed (0) -
internal/crypto/key.go
// system (crypto/rand) is used. func GenerateKey(extKey []byte, random io.Reader) (key ObjectKey) { if random == nil { random = rand.Reader } if len(extKey) != 32 { // safety check logger.CriticalIf(context.Background(), errors.New("crypto: invalid key length")) } var nonce [32]byte if _, err := io.ReadFull(random, nonce[:]); err != nil { logger.CriticalIf(context.Background(), errOutOfEntropy) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 20:28:10 GMT 2024 - 6.4K bytes - Viewed (0) -
internal/crypto/sse.go
return } // EncryptSinglePart encrypts an io.Reader which must be the // body of a single-part PUT request. func EncryptSinglePart(r io.Reader, key ObjectKey) io.Reader { r, err := sio.EncryptReader(r, sio.Config{MinVersion: sio.Version20, Key: key[:], CipherSuites: fips.DARECiphers()}) if err != nil { logger.CriticalIf(context.Background(), errors.New("Unable to encrypt io.Reader using object key")) } return r }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 4.4K bytes - Viewed (0) -
internal/config/crypto.go
package config import ( "bytes" "context" "crypto/rand" "encoding/binary" "errors" "fmt" "io" jsoniter "github.com/json-iterator/go" "github.com/minio/minio/internal/fips" "github.com/minio/minio/internal/kms" "github.com/secure-io/sio-go" "github.com/secure-io/sio-go/sioutil" ) // EncryptBytes encrypts the plaintext with a key managed by KMS.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 4.8K bytes - Viewed (0)