- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 145 for Leider (0.15 sec)
-
internal/config/crypto.go
func Decrypt(k kms.KMS, ciphertext io.Reader, context kms.Context) (io.Reader, error) { const ( MaxMetadataSize = 1 << 20 // max. size of the metadata Version = 1 ) var header [5]byte if _, err := io.ReadFull(ciphertext, header[:]); err != nil { return nil, err } if header[0] != Version { return nil, fmt.Errorf("config: unknown ciphertext version %d", header[0]) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 4.8K 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 Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 4.4K bytes - Viewed (0) -
internal/http/request-recorder.go
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 bytesRead int } // Close is a no operation closer func (r *RequestRecorder) Close() error {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Apr 12 21:37:19 GMT 2023 - 1.8K bytes - Viewed (0) -
cmd/tier-journal_gen.go
package cmd // Code generated by github.com/tinylib/msgp DO NOT EDIT. import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *jentry) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr()
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jun 03 21:26:51 GMT 2021 - 6.1K bytes - Viewed (0) -
internal/s3select/parquet/reader.go
"github.com/minio/minio/internal/s3select/sql" ) // Reader implements reading records from parquet input. type Reader struct { io.Closer r *parquetgo.FileReader } // NewParquetReader creates a Reader2 from a io.ReadSeekCloser. func NewParquetReader(rsc io.ReadSeekCloser, _ *ReaderArgs) (r *Reader, err error) { fr, err := parquetgo.NewFileReader(rsc) if err != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 14 13:54:47 GMT 2022 - 4.5K bytes - Viewed (0) -
internal/s3select/json/reader_test.go
Klaus Post <******@****.***> 1663610716 +0200
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) -
internal/handlers/proxy_test.go
{forwarded, `for=192.0.2.60;proto=http;by=203.0.113.43`, "http"}, // Multiple params } for _, v := range headers { req := &http.Request{ Header: http.Header{ v.key: []string{v.val}, }, } res := GetSourceScheme(req) if res != v.expected { t.Errorf("wrong header for %s: got %s want %s", v.key, res, v.expected) } } } // TestGetSourceIP - check the source ip of a request is parsed correctly.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Dec 22 00:56:55 GMT 2023 - 3.2K bytes - Viewed (0) -
cmd/jwt_test.go
req *http.Request expectedErr error }{ // Set valid authorization header. { req: &http.Request{ Header: http.Header{ "Authorization": []string{token}, }, }, expectedErr: nil, }, // No authorization header. { req: &http.Request{ Header: http.Header{}, }, expectedErr: errNoAuthToken, }, // Invalid authorization token. {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:45:14 GMT 2024 - 4.5K bytes - Viewed (0) -
cmd/bitrot_test.go
bw.Close() } reader := newBitrotReader(disk, nil, volume, filePath, 35, bitrotAlgo, bitrotWriterSum(writer), 10) b := make([]byte, 10) if _, err = reader.ReadAt(b, 0); err != nil { t.Fatal(err) } if _, err = reader.ReadAt(b, 10); err != nil { t.Fatal(err) } if _, err = reader.ReadAt(b, 20); err != nil { t.Fatal(err) } if _, err = reader.ReadAt(b[:5], 30); err != nil { t.Fatal(err) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 2.1K bytes - Viewed (0) -
internal/handlers/proxy.go
// Retrieve the scheme from X-Forwarded-Proto. if proto := r.Header.Get(xForwardedProto); proto != "" { scheme = strings.ToLower(proto) } else if proto = r.Header.Get(xForwardedScheme); proto != "" { scheme = strings.ToLower(proto) } else if proto := r.Header.Get(forwarded); proto != "" { // match should contain at least two elements if the protocol was // specified in the Forwarded header. The first element will always be
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Dec 22 00:56:55 GMT 2023 - 5.1K bytes - Viewed (0)