Search Options

Results per page
Sort
Preferred Languages
Advance

Results 401 - 410 of 1,179 for _func (0.03 sec)

  1. internal/config/identity/openid/ecdsa-sha3_contrib.go

    	SigningMethodES3384 *jwt.SigningMethodECDSA
    	SigningMethodES3512 *jwt.SigningMethodECDSA
    )
    
    func init() {
    	// ES256
    	SigningMethodES3256 = &jwt.SigningMethodECDSA{Name: "ES3256", Hash: crypto.SHA3_256, KeySize: 32, CurveBits: 256}
    	jwt.RegisterSigningMethod(SigningMethodES3256.Alg(), func() jwt.SigningMethod {
    		return SigningMethodES3256
    	})
    
    	// ES384
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Nov 05 19:20:08 UTC 2021
    - 1.8K bytes
    - Viewed (0)
  2. cmd/postpolicyform.go

    )
    
    // toString - Safely convert interface to string without causing panic.
    func toString(val interface{}) string {
    	switch v := val.(type) {
    	case string:
    		return v
    	default:
    		return ""
    	}
    }
    
    // toLowerString - safely convert interface to lower string
    func toLowerString(val interface{}) string {
    	return strings.ToLower(toString(val))
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  3. cmd/kms-handlers_test.go

    	adminTestBed, err := prepareAdminErasureTestBed(context.Background())
    	if err != nil {
    		t.Fatal(err)
    	}
    	registerKMSRouter(adminTestBed.router)
    
    	if enableKMS {
    		GlobalKMS = kms.NewStub("default-test-key")
    	}
    
    	tearDown := func() {
    		adminTestBed.TearDown()
    		GlobalKMS = nil
    	}
    	return adminTestBed, tearDown
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  4. cmd/background-newdisks-heal-ops.go

    	h.HealedBuckets = nil
    	h.Object = ""
    	h.Bucket = ""
    }
    
    func (h *healingTracker) getLastUpdate() time.Time {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    
    	return h.LastUpdate
    }
    
    func (h *healingTracker) getBucket() string {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    
    	return h.Bucket
    }
    
    func (h *healingTracker) setBucket(bucket string) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  5. internal/grid/muxclient.go

    		m.closed = true
    	}
    }
    
    // respHandler
    func (m *muxClient) handleOneWayStream(respHandler chan<- Response, respServer <-chan Response) {
    	if debugPrint {
    		start := time.Now()
    		defer func() {
    			fmt.Println("Mux", m.MuxID, "Request took", time.Since(start).Round(time.Millisecond))
    		}()
    	}
    	defer func() {
    		// addErrorNonBlockingClose will close the response channel
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  6. cmd/warm-backend-gcs.go

    	client       *storage.Client
    	Bucket       string
    	Prefix       string
    	StorageClass string
    }
    
    func (gcs *warmBackendGCS) getDest(object string) string {
    	destObj := object
    	if gcs.Prefix != "" {
    		destObj = fmt.Sprintf("%s/%s", gcs.Prefix, object)
    	}
    	return destObj
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  7. tests/count_test.go

    	}
    
    	expects = []User{{Name: "count-1", Age: 1}, {Name: "count-2", Age: 1}, {Name: "count-3", Age: 1}}
    	sort.SliceStable(users, func(i, j int) bool {
    		return strings.Compare(users[i].Name, users[j].Name) < 0
    	})
    
    	AssertEqual(t, users, expects)
    
    	var count9 int64
    	if err := DB.Scopes(func(tx *gorm.DB) *gorm.DB {
    		return tx.Table("users")
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Oct 30 09:15:49 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  8. cmd/api-router.go

    	"github.com/minio/pkg/v3/wildcard"
    	"github.com/rs/cors"
    )
    
    func newHTTPServerFn() *xhttp.Server {
    	globalObjLayerMutex.RLock()
    	defer globalObjLayerMutex.RUnlock()
    	return globalHTTPServer
    }
    
    func setHTTPServer(h *xhttp.Server) {
    	globalObjLayerMutex.Lock()
    	globalHTTPServer = h
    	globalObjLayerMutex.Unlock()
    }
    
    func newConsoleServerFn() *consoleapi.Server {
    	globalObjLayerMutex.RLock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  9. src/cmd/cgo/ast.go

    		f.ExpFunc = append(f.ExpFunc, &ExpFunc{
    			Func:    n,
    			ExpName: name,
    			Doc:     doc,
    		})
    		break
    	}
    }
    
    // Make f.ExpFunc[i] point at the Func from this AST instead of the other one.
    func (f *File) saveExport2(x interface{}, context astContext) {
    	n, ok := x.(*ast.FuncDecl)
    	if !ok {
    		return
    	}
    
    	for _, exp := range f.ExpFunc {
    		if exp.Func.Name.Name == n.Name.Name {
    			exp.Func = n
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 14 15:47:06 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-utils_test.go

    	}
    	chkNumVersions := func(fis []FileInfo) bool {
    		for i := 0; i < len(fis)-1; i++ {
    			if fis[i].NumVersions != fis[i+1].NumVersions {
    				return false
    			}
    		}
    		return true
    	}
    	if !chkNumVersions(fivs.Versions) {
    		t.Fatalf("Expected all versions to have the same NumVersions")
    	}
    
    	sort.Slice(versions, func(i, j int) bool {
    		if versions[i].IsLatest {
    			return true
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 7.1K bytes
    - Viewed (0)
Back to top