- Sort Score
- Result 10 results
- Languages All
Results 941 - 950 of 1,387 for funcs (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)