Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 77 for straum (0.18 sec)

  1. internal/logger/target/kafka/kafka_scram_client_contrib.go

    // each authentication attempt.
    type XDGSCRAMClient struct {
    	*scram.Client
    	*scram.ClientConversation
    	scram.HashGeneratorFcn
    }
    
    // Begin constructs a SCRAM client component based on a given hash.Hash
    // factory receiver.  This constructor will normalize the username, password
    // and authzID via the SASLprep algorithm, as recommended by RFC-5802.  If
    // SASLprep fails, the method returns an error.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
  2. cmd/storage-datatypes_test.go

    "X-Minio-Internal-Server-Side-Encryption-S3-Sealed-Key": "IAAfAPFYRDkHVirJBJxBixNj3PLWt78dFuUTyTLIdLG820J7XqLPBO4gpEEEWw/DoTsJIb+apnaem+rKtQ1h3Q==", "X-Minio-Internal-Server-Side-Encryption-Seal-Algorithm": "DAREv2-HMAC-SHA256", "content-type": "application/octet-stream", "etag": "20000f00e2c3709dc94905c6ce31e1cadbd1c064e14acdcd44cf0ac2db777eeedd88d639fcd64de16851ade8b21a9a1a"}, Parts: []ObjectPartInfo{{ETag: "", Number: 1, Size: 3430, ActualSize: 3398}}, Erasure: ErasureInfo{Algorithm: "reedsolomon", DataBlocks:...
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 9.4K bytes
    - Viewed (0)
  3. cmd/untar.go

    	},
    	{
    		// Zstd skippable frame header.
    		header: []byte{0x2a, 0x4d, 0x18},
    		f:      formatZstd,
    	},
    	{
    		// LZ4
    		header: []byte{0x4, 0x22, 0x4d, 0x18},
    		f:      formatLZ4,
    	},
    	{
    		// Snappy/S2 stream
    		header: []byte{0xff, 0x06, 0x00, 0x00},
    		f:      formatS2,
    	},
    	{
    		header: []byte{0x42, 0x5a, 'h'},
    		f:      formatBZ2,
    	},
    }
    
    type untarOptions struct {
    	ignoreDirs bool
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  4. cmd/object-api-getobjectinfo_test.go

    		{Bucket: "test-getobjectinfo", Name: "Asia/asiapics.jpg", ContentType: "image/jpeg", IsDir: false},
    		{Bucket: "test-getobjectinfo", Name: "Asia/empty-dir/", ContentType: "application/octet-stream", IsDir: true},
    	}
    	testCases := []struct {
    		bucketName string
    		objectName string
    
    		// Expected output of GetObjectInfo.
    		result ObjectInfo
    		err    error
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 23 15:46:00 GMT 2022
    - 5.6K bytes
    - Viewed (0)
  5. internal/config/dns/operator_dns.go

    			TLSClientConfig: &tls.Config{
    				RootCAs: args.rootCAs,
    			},
    			// Go net/http automatically unzip if content-type is
    			// gzip disable this feature, as we are always interested
    			// in raw stream.
    			DisableCompression: true,
    		},
    	}
    	return args, nil
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 06 16:56:10 GMT 2023
    - 6.6K bytes
    - Viewed (0)
  6. cmd/object-handlers.go

    	case authTypeStreamingSigned, authTypeStreamingSignedTrailer:
    		// Initialize stream signature verifier.
    		rd, s3Err = newSignV4ChunkedReader(r, rAuthType == authTypeStreamingSignedTrailer)
    		if s3Err != ErrNone {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Err), r.URL)
    			return
    		}
    	case authTypeStreamingUnsignedTrailer:
    		// Initialize stream chunked reader with optional trailers.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  7. cmd/object-multipart-handlers.go

    	case authTypeStreamingSigned, authTypeStreamingSignedTrailer:
    		// Initialize stream signature verifier.
    		reader, s3Error = newSignV4ChunkedReader(r, rAuthType == authTypeStreamingSignedTrailer)
    		if s3Error != ErrNone {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    			return
    		}
    	case authTypeStreamingUnsignedTrailer:
    		// Initialize stream signature verifier.
    		reader, s3Error = newUnsignedV4ChunkedReader(r, true)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    	}
    
    	return fi.ToObjectInfo(minioMetaBucket, key, opts.Versioned || opts.VersionSuspended), nil
    }
    
    // PutObject - creates an object upon reading from the input stream
    // until EOF, erasure codes the data across all disk and additionally
    // writes `xl.meta` which carries the necessary metadata for future
    // object operations.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  9. internal/event/target/kafka.go

    	}
    
    	config.Net.KeepAlive = 60 * time.Second
    	config.Net.SASL.User = args.SASL.User
    	config.Net.SASL.Password = args.SASL.Password
    	initScramClient(args, config) // initializes configured scram client.
    	config.Net.SASL.Enable = args.SASL.Enable
    
    	tlsConfig, err := saramatls.NewConfig(args.TLS.ClientTLSCert, args.TLS.ClientTLSKey)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 20 08:16:35 GMT 2024
    - 13K bytes
    - Viewed (0)
  10. internal/s3select/sql/value.go

    		// float since we got here, so we convert.
    		flV, _ := v.ToFloat()
    		flA, _ := a.ToFloat()
    		return floatCompare(op, flV, flA), nil
    	}
    
    	strV, ok1s := v.ToString()
    	strA, ok2s := a.ToString()
    	if ok1s && ok2s {
    		return stringCompare(op, strV, strA), nil
    	}
    
    	boolV, ok1b := v.ToBool()
    	boolA, ok2b := a.ToBool()
    	if ok1b && ok2b {
    		return boolCompare(op, boolV, boolA)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 25 20:31:19 GMT 2022
    - 20.2K bytes
    - Viewed (0)
Back to top