Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 483 for Cool (0.17 sec)

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

    	response, err = x.ClientConversation.Step(challenge)
    	return
    }
    
    // Done returns true if the conversation is completed or has errored.
    func (x *XDGSCRAMClient) Done() bool {
    	return x.ClientConversation.Done()
    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/api-utils.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"fmt"
    	"net/http"
    	"reflect"
    	"runtime"
    	"strings"
    )
    
    func shouldEscape(c byte) bool {
    	if 'A' <= c && c <= 'Z' || 'a' <= c && c <= 'z' || '0' <= c && c <= '9' {
    		return false
    	}
    
    	switch c {
    	case '-', '_', '.', '/', '*':
    		return false
    	}
    	return true
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  3. docs/debugging/xattr/main.go

    import (
    	"encoding/binary"
    	"errors"
    	"flag"
    	"fmt"
    	"log"
    	"os"
    
    	"github.com/olekukonko/tablewriter"
    	"github.com/pkg/xattr"
    )
    
    var (
    	path, name string
    	value      uint64
    	set, list  bool
    )
    
    func getxattr(path, name string) (uint64, error) {
    	buf, err := xattr.LGet(path, name)
    	if err != nil {
    		return 0, err
    	}
    
    	return binary.LittleEndian.Uint64(buf[:8]), nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 29 23:52:41 GMT 2023
    - 3.2K bytes
    - Viewed (0)
  4. internal/s3select/sql/jsonpath.go

    // If the value should be considered flat (from wildcards) any array returned should be considered individual values.
    func jsonpathEval(p []*JSONPathElement, v interface{}) (r interface{}, flat bool, err error) {
    	// fmt.Printf("JPATHexpr: %v jsonobj: %v\n\n", p, v)
    	if len(p) == 0 || v == nil {
    		return v, false, nil
    	}
    
    	switch {
    	case p[0].Key != nil:
    		key := p[0].Key.keyString()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  5. cmd/postpolicyform_test.go

    	"encoding/base64"
    	"fmt"
    	"net/http"
    	"strings"
    	"testing"
    
    	minio "github.com/minio/minio-go/v7"
    )
    
    func TestParsePostPolicyForm(t *testing.T) {
    	testCases := []struct {
    		policy  string
    		success bool
    	}{
    		// missing expiration, will fail.
    		{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 8.9K bytes
    - Viewed (0)
  6. docs/sts/custom-token-identity.go

    var (
    	// LDAP integrated Minio endpoint
    	stsEndpoint string
    
    	// token to use with AssumeRoleWithCustomToken
    	token string
    
    	// Role ARN to use
    	roleArn string
    
    	// Display credentials flag
    	displayCreds bool
    
    	// Credential expiry duration
    	expiryDuration time.Duration
    
    	// Bucket to list
    	bucketToList string
    )
    
    func init() {
    	flag.StringVar(&stsEndpoint, "sts-ep", "http://localhost:9000", "STS endpoint")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 27 00:58:09 GMT 2022
    - 3.4K bytes
    - Viewed (0)
  7. docs/sts/assume-role.go

    )
    
    var (
    	// Minio endpoint (for STS API)
    	stsEndpoint string
    
    	// User account credentials
    	minioUsername string
    	minioPassword string
    
    	// Display credentials flag
    	displayCreds bool
    
    	// Credential expiry duration
    	expiryDuration time.Duration
    
    	// Bucket to list
    	bucketToList string
    
    	// Session policy file (FIXME: add support in minio-go)
    	sessionPolicyFile string
    )
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 16:09:55 GMT 2024
    - 4K bytes
    - Viewed (1)
  8. cmd/httprange_test.go

    	}
    }
    
    func TestHTTPRequestRangeToHeader(t *testing.T) {
    	validRangeSpecs := []struct {
    		spec        string
    		errExpected bool
    	}{
    		{"bytes=0-", false},
    		{"bytes=1-", false},
    
    		{"bytes=0-9", false},
    		{"bytes=1-10", false},
    		{"bytes=1-1", false},
    		{"bytes=2-5", false},
    
    		{"bytes=-5", false},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 3.7K bytes
    - Viewed (0)
  9. internal/bucket/encryption/bucket-sse-config.go

    		config.XMLNS = xmlNS
    	}
    	return &config, nil
    }
    
    // ApplyOptions ask for specific features to be enabled,
    // when bucketSSEConfig is empty.
    type ApplyOptions struct {
    	AutoEncrypt bool
    }
    
    // Apply applies the SSE bucket configuration on the given HTTP headers and
    // sets the specified SSE headers.
    //
    // Apply does not overwrite any existing SSE headers. Further, it will
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 4.9K bytes
    - Viewed (0)
  10. internal/disk/stat_linux.go

    	"strings"
    	"syscall"
    
    	"github.com/prometheus/procfs/blockdevice"
    	"golang.org/x/sys/unix"
    )
    
    // GetInfo returns total and free bytes available in a directory, e.g. `/`.
    func GetInfo(path string, firstTime bool) (info Info, err error) {
    	s := syscall.Statfs_t{}
    	err = syscall.Statfs(path, &s)
    	if err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := s.Bfree - s.Bavail
    	info = Info{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 26 19:34:50 GMT 2024
    - 4.8K bytes
    - Viewed (0)
Back to top