Search Options

Results per page
Sort
Preferred Languages
Advance

Results 941 - 950 of 1,387 for funcs (0.06 sec)

  1. internal/s3select/parquet/reader.go

    	r *parquetgo.FileReader
    }
    
    // NewParquetReader creates a Reader2 from a io.ReadSeekCloser.
    func NewParquetReader(rsc io.ReadSeekCloser, _ *ReaderArgs) (r *Reader, err error) {
    	fr, err := parquetgo.NewFileReader(rsc)
    	if err != nil {
    		return nil, errParquetParsingError(err)
    	}
    
    	return &Reader{Closer: rsc, r: fr}, nil
    }
    
    func (pr *Reader) Read(dst sql.Record) (rec sql.Record, rerr error) {
    	nextRow, err := pr.r.NextRow()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  2. internal/bucket/object/lock/lock_test.go

    package lock
    
    import (
    	"encoding/xml"
    	"errors"
    	"fmt"
    	"net/http"
    	"reflect"
    	"strings"
    	"testing"
    	"time"
    
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    func TestParseMode(t *testing.T) {
    	testCases := []struct {
    		value        string
    		expectedMode RetMode
    	}{
    		{
    			value:        "governance",
    			expectedMode: RetGovernance,
    		},
    		{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 29 01:20:27 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  3. misc/cgo/gmp/fib.go

    // that pass integers back and forth.  No actual
    // concurrency, just threads and synchronization
    // and foreign code on multiple pthreads.
    
    package main
    
    import (
    	big "."
    	"runtime"
    )
    
    func fibber(c chan *big.Int, out chan string, n int64) {
    	// Keep the fibbers in dedicated operating system
    	// threads, so that this program tests coordination
    	// between pthreads and not just goroutines.
    	runtime.LockOSThread()
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Apr 10 22:32:35 UTC 2023
    - 919 bytes
    - Viewed (0)
  4. cmd/metacache-manager.go

    	trash   map[string]metacache // Recently deleted lists.
    }
    
    const metacacheMaxEntries = 5000
    
    // initManager will start async saving the cache.
    func (m *metacacheManager) initManager() {
    	// Add a transient bucket.
    	// Start saver when object layer is ready.
    	go func() {
    		objAPI := newObjectLayerFn()
    		for objAPI == nil {
    			time.Sleep(time.Second)
    			objAPI = newObjectLayerFn()
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  5. schema/constraint_test.go

    	"gorm.io/gorm/utils/tests"
    )
    
    type UserCheck struct {
    	Name  string `gorm:"check:name_checker,name <> 'jinzhu'"`
    	Name2 string `gorm:"check:name <> 'jinzhu'"`
    	Name3 string `gorm:"check:,name <> 'jinzhu'"`
    }
    
    func TestParseCheck(t *testing.T) {
    	user, err := schema.Parse(&UserCheck{}, &sync.Map{}, schema.NamingStrategy{})
    	if err != nil {
    		t.Fatalf("failed to parse user check, got error %v", err)
    	}
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sun Feb 04 07:49:19 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  6. internal/event/target/nats_tls_contrib_test.go

     */
    
    package target
    
    import (
    	"path"
    	"path/filepath"
    	"testing"
    
    	xnet "github.com/minio/pkg/v3/net"
    	natsserver "github.com/nats-io/nats-server/v2/test"
    )
    
    func TestNatsConnTLSCustomCA(t *testing.T) {
    	s, opts := natsserver.RunServerWithConfig(filepath.Join("testdata", "contrib", "nats_tls.conf"))
    	defer s.Shutdown()
    
    	clientConfig := &NATSArgs{
    		Enable: true,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  7. src/cmd/buildid/buildid.go

    import (
    	"flag"
    	"fmt"
    	"log"
    	"os"
    	"strings"
    
    	"cmd/internal/buildid"
    	"cmd/internal/telemetry/counter"
    )
    
    func usage() {
    	fmt.Fprintf(os.Stderr, "usage: go tool buildid [-w] file\n")
    	flag.PrintDefaults()
    	os.Exit(2)
    }
    
    var wflag = flag.Bool("w", false, "write build ID")
    
    func main() {
    	log.SetPrefix("buildid: ")
    	log.SetFlags(0)
    	counter.Open()
    	flag.Usage = usage
    	flag.Parse()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Jun 21 19:58:04 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  8. cmd/xl-storage-format-v1_gen.go

    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *BitrotAlgorithm) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint
    		zb0001, err = dc.ReadUint()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = BitrotAlgorithm(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z BitrotAlgorithm) EncodeMsg(en *msgp.Writer) (err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  9. doc/go1.17_spec.html

    may be invoked with zero or more arguments for that parameter.
    </p>
    
    <pre>
    func()
    func(x int) int
    func(a, _ int, z float32) bool
    func(a, b int, z float32) (bool)
    func(prefix string, values ...int)
    func(a, b int, z float64, opt ...interface{}) (success bool)
    func(int, int, float64) (float64, *[]int)
    func(n int) func(p *T)
    </pre>
    
    
    <h3 id="Interface_types">Interface types</h3>
    
    <p>
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 10 18:25:45 UTC 2024
    - 211.6K bytes
    - Viewed (0)
  10. cmd/signature-v4-utils_test.go

    package cmd
    
    import (
    	"context"
    	"net/http"
    	"os"
    	"testing"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/auth"
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    func TestCheckValid(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	objLayer, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 05 21:26:41 UTC 2024
    - 14.3K bytes
    - Viewed (0)
Back to top