Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 453 for ctx_ (0.02 sec)

  1. istioctl/pkg/waypoint/waypoint.go

    	enrollNamespace bool
    	overwrite       bool
    )
    
    const waitTimeout = 90 * time.Second
    
    func Cmd(ctx cli.Context) *cobra.Command {
    	makeGateway := func(forApply bool) (*gateway.Gateway, error) {
    		ns := ctx.NamespaceOrDefault(ctx.Namespace())
    		if ctx.Namespace() == "" && !forApply {
    			ns = ""
    		}
    		// If a user sets the waypoint name to an empty string, set it to the default namespace waypoint name.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  2. cmd/healthcheck-handler.go

    }
    
    // ClusterCheckHandler returns if the server is ready for requests.
    func ClusterCheckHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "ClusterCheckHandler")
    
    	objLayer := checkHealth(w)
    	if objLayer == nil {
    		return
    	}
    
    	ctx, cancel := context.WithTimeout(ctx, globalAPIConfig.getClusterDeadline())
    	defer cancel()
    
    	opts := HealthOptions{
    		Maintenance:    r.Form.Get("maintenance") == "true",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 26 07:44:34 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  3. cmd/jwt_test.go

    	return token.SignedString([]byte(secretKey))
    }
    
    // Tests web request authenticator.
    func TestWebRequestAuthenticate(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    		t.Fatal(err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  4. cmd/background-heal-ops.go

    	waitForLowIO(maxIO, maxWait, currentHTTPIO)
    }
    
    func initBackgroundHealing(ctx context.Context, objAPI ObjectLayer) {
    	bgSeq := newBgHealSequence()
    	// Run the background healer
    	for i := 0; i < globalBackgroundHealRoutine.workers; i++ {
    		go globalBackgroundHealRoutine.AddWorker(ctx, objAPI, bgSeq)
    	}
    
    	globalBackgroundHealState.LaunchNewHealSequence(bgSeq, objAPI)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. internal/logger/logonce.go

    // on how it is used.
    func LogOnceIf(ctx context.Context, subsystem string, err error, id string, errKind ...interface{}) {
    	if logIgnoreError(err) {
    		return
    	}
    	logOnce.logOnceIf(ctx, subsystem, err, id, errKind...)
    }
    
    // LogOnceConsoleIf - similar to LogOnceIf but exclusively only logs to console target.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  6. cmd/site-replication-utils.go

    	peerResyncMap map[string]resyncState
    }
    
    func newSiteResyncMetrics(ctx context.Context) *siteResyncMetrics {
    	s := siteResyncMetrics{
    		resyncStatus:  make(map[string]SiteResyncStatus),
    		peerResyncMap: make(map[string]resyncState),
    	}
    	go s.save(ctx)
    	go s.init(ctx)
    	return &s
    }
    
    // init site resync metrics
    func (sm *siteResyncMetrics) init(ctx context.Context) {
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/ztunnelserver_test.go

    func TestZtunnelSendsPodSnapshot(t *testing.T) {
    	ztunnelKeepAliveCheckInterval = time.Second / 10
    	mt := monitortest.New(t)
    	setupLogging()
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	fixture := connect(ctx)
    	ztunClient := fixture.ztunClient
    	uid := fixture.uid
    
    	m, fds := readRequest(t, ztunClient)
    	// we got am essage from ztun, so it should have observed us being connected
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  8. cmd/warm-backend-gcs.go

    // FIXME: add support for remote version ID in GCS remote tier and remove this.
    // Currently it's a no-op.
    func (gcs *warmBackendGCS) Put(ctx context.Context, key string, data io.Reader, length int64) (remoteVersionID, error) {
    	return gcs.PutWithMeta(ctx, key, data, length, map[string]string{})
    }
    
    func (gcs *warmBackendGCS) Get(ctx context.Context, key string, rv remoteVersionID, opts WarmBackendGetOpts) (r io.ReadCloser, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  9. cmd/admin-handlers_test.go

    }
    
    // prepareAdminErasureTestBed - helper function that setups a single-node
    // Erasure backend for admin-handler tests.
    func prepareAdminErasureTestBed(ctx context.Context) (*adminErasureTestBed, error) {
    	ctx, cancel := context.WithCancel(ctx)
    
    	// reset global variables to start afresh.
    	resetTestGlobals()
    
    	// Set globalIsErasure to indicate that the setup uses an erasure
    	// code backend.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  10. internal/cachevalue/cache.go

    func NewFromFunc[T any](ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) *Cache[T] {
    	return &Cache[T]{
    		ttl:      ttl,
    		updateFn: update,
    		opts:     opts,
    	}
    }
    
    // InitOnce initializes the cache with a TTL and an update function. It is
    // guaranteed to be called only once.
    func (t *Cache[T]) InitOnce(ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) {
    	t.Once.Do(func() {
    		t.ttl = ttl
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
Back to top