- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 621 for init (0.15 sec)
-
cmd/bucket-lifecycle.go
// transition tasks func (t *transitionState) UpdateWorkers(n int) { t.mu.Lock() defer t.mu.Unlock() if t.objAPI == nil { // Init hasn't been called yet. return } t.updateWorkers(n) } func (t *transitionState) updateWorkers(n int) { for t.numWorkers < n { go t.worker(t.objAPI) t.numWorkers++ } for t.numWorkers > n {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
src/cmd/asm/internal/asm/endtoend_test.go
} } func Test386EndToEnd(t *testing.T) { testEndToEnd(t, "386", "386") } func TestARMEndToEnd(t *testing.T) { defer func(old int) { buildcfg.GOARM.Version = old }(buildcfg.GOARM.Version) for _, goarm := range []int{5, 6, 7} { t.Logf("GOARM=%d", goarm) buildcfg.GOARM.Version = goarm testEndToEnd(t, "arm", "arm") if goarm == 6 { testEndToEnd(t, "arm", "armv6") } }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Dec 07 18:42:59 GMT 2023 - 11.6K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
// Gather the statuses before printing so they may be sorted var fullStatus []*xdsWriterStatus mappedResp := map[string]string{} w := new(tabwriter.Writer).Init(s.Writer, 0, 8, 5, ' ', 0) _, _ = fmt.Fprintln(w, "NAME\tCLUSTER\tCDS\tLDS\tEDS\tRDS\tECDS\tISTIOD\tVERSION") for _, dr := range drs { for _, resource := range dr.Resources { clientConfig := xdsstatus.ClientConfig{}
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0) -
cmd/auth-handler_test.go
creds, err := auth.CreateCredentials("myuser", "mypassword") if err != nil { t.Fatalf("unable create credential, %s", err) } globalActiveCred = creds globalIAMSys.Init(ctx, objLayer, globalEtcdClient, 2*time.Second) // List of test cases for validating http request authentication. testCases := []struct { req *http.Request s3Error APIErrorCode }{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 15.4K bytes - Viewed (0) -
cmd/tier.go
return nil, decErr } default: return nil, fmt.Errorf("tierConfigInit: unknown version: %d", version) } return cfg, nil } // Init initializes tier configuration reading from objAPI func (config *TierConfigMgr) Init(ctx context.Context, objAPI ObjectLayer) error { err := config.Reload(ctx, objAPI) if globalIsDistErasure { go config.refreshTierConfig(ctx, objAPI) } return err
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
types.MergePatchType, labelsPatch, metav1.PatchOptions{}) assert.NoError(t, err) // wait for another two update events // total 3 update at before unlabel point: 1. init ns reconcile 2. ns label reconcile 3. pod annotation update mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(5)) waitForMockCalls() assertPodNotAnnotated(t, client, pod)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 15.8K bytes - Viewed (0) -
internal/event/target/webhook.go
func (target *WebhookTarget) Close() error { target.cancel() return nil } func (target *WebhookTarget) init() error { return target.initOnce.Do(target.initWebhook) } // Only called from init() func (target *WebhookTarget) initWebhook() error { args := target.args transport := target.transport if args.ClientCert != "" && args.ClientKey != "" {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Nov 20 22:40:07 GMT 2023 - 8.5K bytes - Viewed (0) -
internal/logger/targets.go
// a single log entry and Send it to the log target // // e.g. Send the log to a http server type Target interface { String() string Endpoint() string Stats() types.TargetStats Init(ctx context.Context) error IsOnline(ctx context.Context) bool Cancel() Send(ctx context.Context, entry interface{}) error Type() types.TargetType } var ( // systemTargets is the set of enabled loggers.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 02 22:56:14 GMT 2024 - 6.1K bytes - Viewed (0) -
docs/sts/web-identity.go
return d, fmt.Errorf("unexpected error returned by %s : status(%s)", ustr, resp.Status) } dec := json.NewDecoder(resp.Body) if err = dec.Decode(&d); err != nil { return d, err } return d, nil } func init() { flag.StringVar(&stsEndpoint, "sts-ep", "http://localhost:9000", "STS endpoint") flag.StringVar(&configEndpoint, "config-ep", "http://localhost:8080/auth/realms/minio/.well-known/openid-configuration",
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri May 19 09:13:33 GMT 2023 - 7.8K bytes - Viewed (3) -
internal/grid/manager.go
} m := &Manager{ ID: uuid.New(), targets: make(map[string]*Connection, len(o.Hosts)), local: o.Local, authRequest: o.AuthRequest, } 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") }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0)