Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 551 for Context (0.12 sec)

  1. istioctl/pkg/cli/context.go

    	}
    	impersonateConfig := i.getImpersonateConfig()
    	rawConfigContexts := maps.Keys(rawConfig.Contexts)
    	for _, c := range contexts {
    		if !slices.Contains(rawConfigContexts, c) {
    			return nil, fmt.Errorf("context %q not found", c)
    		}
    	}
    	var clients []kube.CLIClient
    	for _, contextName := range contexts {
    		if i.remoteClients[contextName] != nil {
    			clients = append(clients, i.remoteClients[contextName])
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 23 19:31:32 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. internal/logger/audit.go

    // SetAuditEntry sets Audit info in the context.
    func SetAuditEntry(ctx context.Context, audit *audit.Entry) context.Context {
    	if ctx == nil {
    		LogIf(context.Background(), "audit", fmt.Errorf("context is nil"))
    		return nil
    	}
    	return context.WithValue(ctx, contextAuditKey, audit)
    }
    
    // GetAuditEntry returns Audit entry if set.
    func GetAuditEntry(ctx context.Context) *audit.Entry {
    	if ctx != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. internal/dsync/drwmutex.go

    	ctx, cancel := context.WithTimeout(ctx, ds.Timeouts.Acquire)
    	defer cancel()
    
    	// Special context for NetLockers - do not use timeouts.
    	// Also, pass the trace context info if found for debugging
    	netLockCtx := context.Background()
    	tc, ok := ctx.Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    	if ok {
    		netLockCtx = context.WithValue(netLockCtx, mcontext.ContextTraceKey, tc)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  4. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/BaseParser.java

            // system and user properties
            context.systemProperties = populateSystemProperties(context);
            context.userProperties = populateUserProperties(context);
    
            // options: interpolate
            context.options = context.options.interpolate(
                    Arrays.asList(context.extraInterpolationSource(), context.userProperties, context.systemProperties));
    
            // core extensions
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  5. cmd/erasure-sets.go

    // TransitionObject - transition object content to target tier.
    func (s *erasureSets) TransitionObject(ctx context.Context, bucket, object string, opts ObjectOptions) error {
    	return s.getHashedSet(object).TransitionObject(ctx, bucket, object, opts)
    }
    
    // RestoreTransitionedObject - restore transitioned object content locally on this cluster.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  6. compat/maven-model-builder/src/test/java/org/apache/maven/model/profile/activation/FileProfileActivatorTest.java

            assertActivation(true, newMissingProfile("${basedir}/someFile.txt"), context);
        }
    
        @Test
        void testIsActiveNoFile() {
            assertActivation(false, newExistsProfile(null), context);
            assertActivation(false, newExistsProfile("someFile.txt"), context);
            assertActivation(false, newExistsProfile("${project.basedir}/someFile.txt"), context);
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/query/TermQueryCommand.java

            }
            return convertTextQuery(fessConfig, context, termQuery, boost, field, text);
        }
    
        protected QueryBuilder convertTextQuery(final FessConfig fessConfig, final QueryContext context, final TermQuery termQuery,
                final float boost, final String field, final String text) {
            context.addFieldLog(field, text);
            context.addHighlightedQuery(text);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:15 UTC 2024
    - 10K bytes
    - Viewed (0)
  8. cmd/xl-storage-disk-id-check.go

    	health       *diskHealthTracker
    	healthCheck  bool
    
    	metricsCache *cachevalue.Cache[DiskMetrics]
    	diskCtx      context.Context
    	diskCancel   context.CancelFunc
    }
    
    func (p *xlStorageDiskIDCheck) getMetrics() DiskMetrics {
    	p.metricsCache.InitOnce(5*time.Second,
    		cachevalue.Opts{},
    		func(ctx context.Context) (DiskMetrics, error) {
    			diskMetric := DiskMetrics{
    				LastMinute: make(map[string]AccElem, len(p.apiLatencies)),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  9. istioctl/pkg/cli/option.go

    		return
    	}
    
    	// If a specific context was specified, use that. Otherwise, just use the current context from the kube config.
    	selectedContext := config.CurrentContext
    	if *r.configContext != "" {
    		selectedContext = *r.configContext
    	}
    
    	// Use the namespace associated with the selected context as default, if the context has one
    	context, ok := config.Contexts[selectedContext]
    	if !ok {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 30 01:19:20 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  10. cmd/peer-rest-client.go

    func (client *peerRESTClient) GetLocks(ctx context.Context) (lockMap map[string][]lockRequesterInfo, err error) {
    	resp, err := getLocksRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	if err != nil || resp == nil {
    		return nil, err
    	}
    	return *resp, nil
    }
    
    // LocalStorageInfo - fetch server information for a remote node.
    func (client *peerRESTClient) LocalStorageInfo(ctx context.Context, metrics bool) (info StorageInfo, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
Back to top