Search Options

Results per page
Sort
Preferred Languages
Advance

Results 861 - 870 of 1,423 for Func (0.05 sec)

  1. cmd/format-erasure_test.go

    			}
    		}
    	}
    }
    
    func BenchmarkInitStorageDisks256(b *testing.B) {
    	benchmarkInitStorageDisksN(b, 256)
    }
    
    func BenchmarkInitStorageDisks1024(b *testing.B) {
    	benchmarkInitStorageDisksN(b, 1024)
    }
    
    func BenchmarkInitStorageDisks2048(b *testing.B) {
    	benchmarkInitStorageDisksN(b, 2048)
    }
    
    func BenchmarkInitStorageDisksMax(b *testing.B) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Apr 15 08:25:46 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  2. internal/crypto/header_test.go

    			"X-Amz-Meta-Test-1":                           []string{"Test-1"},
    		},
    		ExpectedHeader: http.Header{
    			"X-Amz-Meta-Test-1": []string{"Test-1"},
    		},
    	},
    }
    
    func TestRemoveSensitiveHeaders(t *testing.T) {
    	isEqual := func(x, y http.Header) bool {
    		if len(x) != len(y) {
    			return false
    		}
    		for k, v := range x {
    			u, ok := y[k]
    			if !ok || len(v) != len(u) {
    				return false
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 13 14:52:15 UTC 2022
    - 21.4K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/server.go

    	return s, nil
    }
    
    func (s *Server) Ready() {
    	s.isReady.Store(true)
    }
    
    func (s *Server) NotReady() {
    	s.isReady.Store(false)
    }
    
    // buildKubeClient creates the kube client
    func buildKubeClient(kubeConfig string) (kube.Client, error) {
    	// Used by validation
    	kubeRestConfig, err := kube.DefaultRestConfig(kubeConfig, "", func(config *rest.Config) {
    		config.QPS = 80
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  4. src/archive/tar/stat_actime2.go

    // license that can be found in the LICENSE file.
    
    //go:build darwin || freebsd || netbsd
    
    package tar
    
    import (
    	"syscall"
    	"time"
    )
    
    func statAtime(st *syscall.Stat_t) time.Time {
    	return time.Unix(st.Atimespec.Unix())
    }
    
    func statCtime(st *syscall.Stat_t) time.Time {
    	return time.Unix(st.Ctimespec.Unix())
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 28 18:17:57 UTC 2021
    - 421 bytes
    - Viewed (0)
  5. internal/config/policy/plugin/config.go

    	args   Args
    	client *http.Client
    }
    
    // Enabled returns if AuthZPlugin is enabled.
    func Enabled(kvs config.KVS) bool {
    	return kvs.Get(URL) != ""
    }
    
    // LookupConfig lookup AuthZPlugin from config, override with any ENVs.
    func LookupConfig(s config.Config, httpSettings xhttp.ConnSettings, closeRespFn func(io.ReadCloser)) (Args, error) {
    	args := Args{}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  6. src/builtin/builtin.go

    // const declaration. It is zero-indexed.
    const iota = 0 // Untyped int.
    
    // nil is a predeclared identifier representing the zero value for a
    // pointer, channel, func, interface, map, or slice type.
    var nil Type // Type must be a pointer, channel, func, interface, map, or slice type
    
    // Type is here for the purposes of documentation only. It is a stand-in
    // for any Go type, but represents the same type for any given function
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Apr 11 20:22:45 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  7. internal/logger/logrotate.go

    // Write is non-blocking, if the writer's queue is not full.
    // Write is blocking otherwise.
    func (w *Writer) Write(p []byte) (n int, err error) {
    	return w.pw.Write(p)
    }
    
    // Close closes the writer.
    // Any accepted writes will be flushed. Any new writes will be rejected.
    // Once Close() exits, files are synchronized to disk.
    func (w *Writer) Close() error {
    	w.pw.CloseWithError(nil)
    
    	if w.f != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  8. clause/expression_test.go

    package clause_test
    
    import (
    	"database/sql"
    	"fmt"
    	"reflect"
    	"sync"
    	"testing"
    
    	"gorm.io/gorm"
    	"gorm.io/gorm/clause"
    	"gorm.io/gorm/schema"
    	"gorm.io/gorm/utils/tests"
    )
    
    func TestExpr(t *testing.T) {
    	results := []struct {
    		SQL    string
    		Result string
    		Vars   []interface{}
    	}{{
    		SQL:    "create table ? (? ?, ? ?)",
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 10 05:34:33 UTC 2023
    - 8.4K bytes
    - Viewed (0)
  9. tests/associations_has_one_test.go

    package tests_test
    
    import (
    	"testing"
    
    	. "gorm.io/gorm/utils/tests"
    )
    
    func TestHasOneAssociation(t *testing.T) {
    	user := *GetUser("hasone", Config{Account: true})
    
    	if err := DB.Create(&user).Error; err != nil {
    		t.Fatalf("errors happened when create: %v", err)
    	}
    
    	CheckUser(t, user, user)
    
    	// Find
    	var user2 User
    	DB.Find(&user2, "id = ?", user.ID)
    	DB.Model(&user2).Association("Account").Find(&user2.Account)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 10:49:45 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  10. istioctl/pkg/proxyconfig/proxyconfig_test.go

    		},
    	}
    
    	for i, c := range cases {
    		t.Run(fmt.Sprintf("case %d %s", i, strings.Join(c.args, " ")), func(t *testing.T) {
    			verifyExecTestOutput(t, ProxyConfig(cli.NewFakeContext(&cli.NewFakeContextOption{
    				Results:   c.execClientConfig,
    				Namespace: "default",
    			})), c)
    		})
    	}
    }
    
    func verifyExecTestOutput(t *testing.T, cmd *cobra.Command, c execTestCase) {
    	t.Helper()
    
    	var out bytes.Buffer
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Apr 10 21:51:29 UTC 2024
    - 8.9K bytes
    - Viewed (0)
Back to top