Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 1,387 for funcs (0.04 sec)

  1. tests/connpool_test.go

    func (c *wrapperConnPool) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error) {
    	c.got = append(c.got, query)
    	return c.db.ExecContext(ctx, query, args...)
    }
    
    func (c *wrapperConnPool) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error) {
    	c.got = append(c.got, query)
    	return c.db.QueryContext(ctx, query, args...)
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Feb 06 02:54:40 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. internal/grid/grid_types_msgp_test.go

    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z testRequest) Msgsize() (s int) {
    	s = 1 + 4 + msgp.IntSize + 7 + msgp.StringPrefixSize + len(z.String)
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *testResponse) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 8.1K bytes
    - Viewed (0)
  3. cmd/perf-tests.go

    	DownloadTimes madmin.TimeDurations
    	DownloadTTFB  madmin.TimeDurations
    	Error         string
    }
    
    func newRandomReader(size int) io.Reader {
    	return io.LimitReader(randreader.New(), int64(size))
    }
    
    type firstByteRecorder struct {
    	t *time.Time
    	r io.Reader
    }
    
    func (f *firstByteRecorder) Read(p []byte) (n int, err error) {
    	if f.t != nil || len(p) == 0 {
    		return f.r.Read(p)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  4. cmd/jwt_test.go

    		b.Fatal(err)
    	}
    
    	b.ResetTimer()
    	b.ReportAllocs()
    	b.RunParallel(func(pb *testing.PB) {
    		for pb.Next() {
    			err = xjwt.ParseWithClaims(token, xjwt.NewMapClaims(), func(*xjwt.MapClaims) ([]byte, error) {
    				return []byte(creds.SecretKey), nil
    			})
    			if err != nil {
    				b.Fatal(err)
    			}
    		}
    	})
    }
    
    func BenchmarkAuthenticateNode(b *testing.B) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  5. migrator/table_type.go

    }
    
    // Schema returns the schema of the table.
    func (ct TableType) Schema() string {
    	return ct.SchemaValue
    }
    
    // Name returns the name of the table.
    func (ct TableType) Name() string {
    	return ct.NameValue
    }
    
    // Type returns the type of the table.
    func (ct TableType) Type() string {
    	return ct.TypeValue
    }
    
    // Comment returns the comment of current table.
    func (ct TableType) Comment() (comment string, ok bool) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri May 05 07:58:27 UTC 2023
    - 688 bytes
    - Viewed (0)
  6. internal/s3select/sql/funceval.go

    		// TODO: implement
    		fallthrough
    
    	default:
    		return nil, errNotImplemented
    	}
    }
    
    func coalesce(args []*Value) (res *Value, err error) {
    	for _, arg := range args {
    		if arg.IsNull() {
    			continue
    		}
    		return arg, nil
    	}
    	return FromNull(), nil
    }
    
    func nullif(v1, v2 *Value) (res *Value, err error) {
    	// Handle Null cases
    	if v1.IsNull() || v2.IsNull() {
    		return v1, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 13.2K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/ztunnelserver.go

    		listener: l,
    		conns: &connMgr{
    			connectionSet: map[*ZtunnelConnection]struct{}{},
    		},
    		pods: pods,
    	}, nil
    }
    
    func (z *ztunnelServer) Close() error {
    	return z.listener.Close()
    }
    
    func (z *ztunnelServer) Run(ctx context.Context) {
    	context.AfterFunc(ctx, func() { _ = z.Close() })
    
    	// Allow at most 5 requests per second. This is still a ridiculous amount; at most we should have 2 ztunnels on our node,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/cni-watcher.go

    		ctx:                   ctx,
    	}
    
    	mux.HandleFunc(pconstants.CNIAddEventPath, s.handleAddEvent)
    	return s
    }
    
    func (s *CniPluginServer) Stop() {
    	s.cniListenServerCancel()
    }
    
    // Start starts up a UDS server which receives events from the CNI chain plugin.
    func (s *CniPluginServer) Start() error {
    	if s.sockAddress == "" {
    		return fmt.Errorf("no socket address provided")
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-decom_gen.go

    func (z *PoolStatus) Msgsize() (s int) {
    	s = 1 + 3 + msgp.IntSize + 3 + msgp.StringPrefixSize + len(z.CmdLine) + 3 + msgp.TimeSize + 4
    	if z.Decommission == nil {
    		s += msgp.NilSize
    	} else {
    		s += z.Decommission.Msgsize()
    	}
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *decomError) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 04 21:02:54 UTC 2022
    - 26.7K bytes
    - Viewed (0)
  10. cmd/config-dir.go

    type ConfigDir struct {
    	path string
    }
    
    func getDefaultConfigDir() string {
    	homeDir, err := homedir.Dir()
    	if err != nil {
    		return ""
    	}
    
    	return filepath.Join(homeDir, defaultMinioConfigDir)
    }
    
    func getDefaultCertsDir() string {
    	return filepath.Join(getDefaultConfigDir(), certsDir)
    }
    
    func getDefaultCertsCADir() string {
    	return filepath.Join(getDefaultCertsDir(), certsCADir)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 3K bytes
    - Viewed (0)
Back to top