Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,689 for Context (0.11 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. cmd/object_api_suite_test.go

    }
    
    // Tests validate PutObject without prefix.
    func testPutObject(obj ObjectLayer, instanceType string, t TestErrHandler) {
    	content := []byte("testcontent")
    	length := int64(len(content))
    	readerEOF := newTestReaderEOF(content)
    	readerNoEOF := newTestReaderNoEOF(content)
    	err := obj.MakeBucket(context.Background(), "bucket", MakeBucketOptions{})
    	if err != nil {
    		t.Fatalf("%s: <ERROR> %s", instanceType, err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. cmd/logging.go

    func rebalanceLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "rebalance", err, errKind...)
    }
    
    func rebalanceLogEvent(ctx context.Context, msg string, args ...interface{}) {
    	logger.Event(ctx, "rebalance", msg, args...)
    }
    
    func adminLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "admin", err, errKind...)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 18:49:48 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  7. 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 (0)
  8. 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)
  9. 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)
  10. 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)
Back to top