- Sort Score
- Result 10 results
- Languages All
Results 291 - 300 of 453 for ctx_ (0.05 sec)
-
internal/store/batch_test.go
} var limit uint32 = 100 batch := NewBatch[TestItem](BatchConfig[TestItem]{ Limit: limit, Store: store, CommitTimeout: 5 * time.Minute, Log: func(ctx context.Context, err error, id string, errKind ...interface{}) { t.Log(err) }, }) defer batch.Close() for i := 0; i < int(limit); i++ { if err := batch.Add(testItem); err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 5.6K bytes - Viewed (0) -
cmd/erasure-metadata-utils_test.go
} } func TestShuffleDisks(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() nDisks := 16 disks, err := getRandomDisks(nDisks) if err != nil { t.Fatal(err) } objLayer, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, disks...)) if err != nil { removeRoots(disks) t.Fatal(err) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 7.4K bytes - Viewed (0) -
cmd/config-current_test.go
package cmd import ( "context" "os" "testing" "github.com/minio/minio/internal/config" ) func TestServerConfig(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) if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 16 23:13:47 UTC 2024 - 2K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
| kubectl --kubeconfig=c1.yaml apply -f -`, Args: cobra.NoArgs, RunE: func(c *cobra.Command, args []string) error { if err := opts.prepare(ctx); err != nil { return err } client, err := ctx.CLIClient() if err != nil { return err } out, warn, err := CreateRemoteSecret(client, opts) if err != nil {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 15 16:31:46 UTC 2024 - 23.3K bytes - Viewed (0) -
cmd/erasure-decode.go
} } } else if err != nil { return err } if err = e.DecodeDataAndParityBlocks(ctx, bufs); err != nil { return err } w := multiWriter{ writers: writers, writeQuorum: 1, errs: make([]error, len(writers)), } if err = w.Write(ctx, bufs); err != nil { return err } } return derr
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 9.5K bytes - Viewed (0) -
src/main/java/org/codelibs/core/naming/InitialContextUtil.java
assertArgumentNotEmpty("jndiName", jndiName); try { return ctx.lookup(jndiName); } catch (final NamingException ex) { throw new NamingRuntimeException(ex); } }
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 3K bytes - Viewed (0) -
cmd/namespace-lock_test.go
t.Skip("long test skip it") ctx := context.Background() for i := 0; i < 10000; i++ { nsLk := newNSLock(false) // lk1; ref=1 if !nsLk.lock(ctx, "volume", "path", "source", "opsID", false, time.Second) { t.Fatal("failed to acquire lock") } // lk2 lk2ch := make(chan struct{}) go func() { defer close(lk2ch)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 3.1K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
) 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) if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil { t.Fatalf("unable initialize config file, %s", err) } initAllSubsystems(ctx) initConfigSubsystem(ctx, objLayer)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Apr 05 21:26:41 UTC 2024 - 14.3K bytes - Viewed (0) -
internal/grid/manager.go
} m.handlers.init() if ctx == nil { ctx = context.Background() } for _, host := range o.Hosts { if host == o.Local { if found { return nil, fmt.Errorf("grid: local host found multiple times") } found = true // No connection to local. continue } m.targets[host] = newConnection(connectionParams{ ctx: ctx, id: m.ID,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 10.6K bytes - Viewed (0) -
tests/test_tutorial/test_path_params/test_tutorial005.py
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Thu Sep 28 04:14:40 UTC 2023 - 5K bytes - Viewed (0)