Search Options

Results per page
Sort
Preferred Languages
Advance

Results 861 - 870 of 1,385 for _func (0.04 sec)

  1. cmd/xl-storage-format-v2-legacy.go

    package cmd
    
    import (
    	"fmt"
    	"time"
    
    	"github.com/tinylib/msgp/msgp"
    )
    
    // unmarshalV unmarshals with a specific header version.
    func (x *xlMetaV2VersionHeader) unmarshalV(v uint8, bts []byte) (o []byte, err error) {
    	switch v {
    	case 1:
    		return x.unmarshalV1(bts)
    	case 2:
    		x2 := xlMetaV2VersionHeaderV2{xlMetaV2VersionHeader: x}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 19 16:43:43 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  2. internal/config/subnet/config.go

    }
    
    var configLock sync.RWMutex
    
    // Registered indicates if cluster is registered or not
    func (c *Config) Registered() bool {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	return len(c.APIKey) > 0
    }
    
    // ApplyEnv - applies the current subnet config to Console UI specific environment variables.
    func (c *Config) ApplyEnv() {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	if c.License != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.8K 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/cmd/asm/internal/asm/line_test.go

    		{"BSWAPW R11", `unrecognized instruction`},
    	})
    }
    
    func testBadInstParser(t *testing.T, goarch string, tests []badInstTest) {
    	for i, test := range tests {
    		arch, ctxt := setArch(goarch)
    		tokenizer := lex.NewTokenizer("", strings.NewReader(test.input+"\n"), nil)
    		parser := NewParser(ctxt, arch, tokenizer)
    
    		err := tryParse(t, func() {
    			parser.Parse()
    		})
    
    		switch {
    		case err == nil:
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  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. 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)
  9. 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)
  10. cmd/tier-last-day-stats.go

    type lastDayTierStats struct {
    	Bins      [24]tierStats
    	UpdatedAt time.Time
    }
    
    func (l *lastDayTierStats) addStats(ts tierStats) {
    	now := time.Now()
    	l.forwardTo(now)
    
    	nowIdx := now.Hour()
    	l.Bins[nowIdx] = l.Bins[nowIdx].add(ts)
    }
    
    // forwardTo moves time to t, clearing entries between last update and t.
    func (l *lastDayTierStats) forwardTo(t time.Time) {
    	if t.IsZero() {
    		t = time.Now()
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 2.8K bytes
    - Viewed (0)
Back to top