Search Options

Results per page
Sort
Preferred Languages
Advance

Results 481 - 490 of 1,179 for funcs (0.05 sec)

  1. internal/handlers/proxy.go

    	protoRegex = regexp.MustCompile(`(?i)^(;|,| )+(?:proto=)(https|http)`)
    )
    
    // GetSourceScheme retrieves the scheme from the X-Forwarded-Proto and RFC7239
    // Forwarded headers (in that order).
    func GetSourceScheme(r *http.Request) string {
    	var scheme string
    
    	// Retrieve the scheme from X-Forwarded-Proto.
    	if proto := r.Header.Get(xForwardedProto); proto != "" {
    		scheme = strings.ToLower(proto)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Dec 22 00:56:55 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  2. clause/update_test.go

    package clause_test
    
    import (
    	"fmt"
    	"testing"
    
    	"gorm.io/gorm/clause"
    )
    
    func TestUpdate(t *testing.T) {
    	results := []struct {
    		Clauses []clause.Interface
    		Result  string
    		Vars    []interface{}
    	}{
    		{
    			[]clause.Interface{clause.Update{}},
    			"UPDATE `users`", nil,
    		},
    		{
    			[]clause.Interface{clause.Update{Modifier: "LOW_PRIORITY"}},
    			"UPDATE LOW_PRIORITY `users`", nil,
    		},
    		{
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Jun 02 01:18:01 UTC 2020
    - 722 bytes
    - Viewed (0)
  3. utils/tests/utils.go

    		}
    		got := rv.FieldByName(name).Interface()
    		expect := ev.FieldByName(name).Interface()
    		t.Run(name, func(t *testing.T) {
    			AssertEqual(t, got, expect)
    		})
    	}
    }
    
    func AssertEqual(t *testing.T, got, expect interface{}) {
    	if !reflect.DeepEqual(got, expect) {
    		isEqual := func() {
    			if curTime, ok := got.(time.Time); ok {
    				format := "2006-01-02T15:04:05Z07:00"
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Mar 10 09:21:56 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  4. cmd/endpoint_contrib_test.go

     */
    
    package cmd
    
    import (
    	"testing"
    
    	"github.com/minio/minio-go/v7/pkg/set"
    )
    
    func TestUpdateDomainIPs(t *testing.T) {
    	tempGlobalMinioPort := globalMinioPort
    	defer func() {
    		globalMinioPort = tempGlobalMinioPort
    	}()
    	globalMinioPort = "9000"
    
    	tempGlobalDomainIPs := globalDomainIPs
    	defer func() {
    		globalDomainIPs = tempGlobalDomainIPs
    	}()
    
    	ipv4TestCases := []struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 30 15:50:39 UTC 2021
    - 2.2K bytes
    - Viewed (0)
  5. internal/disk/directio_darwin.go

    const ODirectPlatform = true
    
    // OpenFileDirectIO - bypass kernel cache.
    func OpenFileDirectIO(filePath string, flag int, perm os.FileMode) (*os.File, error) {
    	return directio.OpenFile(filePath, flag, perm)
    }
    
    // DisableDirectIO - disables directio mode.
    func DisableDirectIO(f *os.File) error {
    	fd := f.Fd()
    	_, err := unix.FcntlInt(fd, unix.F_NOCACHE, 0)
    	return err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 17 14:31:36 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  6. internal/logger/target/types/targettype_string.go

    package types
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[TargetConsole-1]
    	_ = x[TargetHTTP-2]
    	_ = x[TargetKafka-3]
    }
    
    const _TargetType_name = "ConsoleHTTPKafka"
    
    var _TargetType_index = [...]uint8{0, 7, 11, 16}
    
    func (i TargetType) String() string {
    	i -= 1
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 10 18:20:21 UTC 2022
    - 703 bytes
    - Viewed (0)
  7. cmd/config-common.go

    	}
    	return buf, r.ObjInfo, nil
    }
    
    func readConfig(ctx context.Context, store objectIO, configFile string) ([]byte, error) {
    	buf, _, err := readConfigWithMetadata(ctx, store, configFile, ObjectOptions{})
    	return buf, err
    }
    
    type objectDeleter interface {
    	DeleteObject(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, error)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  8. cmd/bucket-lifecycle_test.go

    import (
    	"bytes"
    	"net/http"
    	"testing"
    	"time"
    
    	"github.com/minio/minio/internal/bucket/lifecycle"
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    // TestParseRestoreObjStatus tests parseRestoreObjStatus
    func TestParseRestoreObjStatus(t *testing.T) {
    	testCases := []struct {
    		restoreHdr     string
    		expectedStatus restoreObjStatus
    		expectedErr    error
    	}{
    		{
    			// valid: represents a restored object, 'pending' expiry.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 31 09:57:57 UTC 2022
    - 7K bytes
    - Viewed (0)
  9. cmd/bucket-listobjects-handlers.go

    	}
    
    	if marker != "" && !HasPrefix(marker, prefix) {
    		return ErrNotImplemented
    	}
    
    	return ErrNone
    }
    
    func (api objectAPIHandlers) ListObjectVersionsHandler(w http.ResponseWriter, r *http.Request) {
    	api.listObjectVersionsHandler(w, r, false)
    }
    
    func (api objectAPIHandlers) ListObjectVersionsMHandler(w http.ResponseWriter, r *http.Request) {
    	api.listObjectVersionsHandler(w, r, true)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  10. internal/config/etcd/etcd.go

    	}
    
    	return etcdEndpoints, etcdSecure, nil
    }
    
    // Enabled returns if etcd is enabled.
    func Enabled(kvs config.KVS) bool {
    	endpoints := kvs.Get(Endpoints)
    	return endpoints != ""
    }
    
    // LookupConfig - Initialize new etcd config.
    func LookupConfig(kvs config.KVS, rootCAs *x509.CertPool) (Config, error) {
    	cfg := Config{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 23:17:22 UTC 2024
    - 5.2K bytes
    - Viewed (0)
Back to top