Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,850 for Context (0.1 sec)

  1. internal/kms/context.go

    package kms
    
    import (
    	"bytes"
    	"sort"
    	"unicode/utf8"
    )
    
    // Context is a set of key-value pairs that
    // are associated with a generate data encryption
    // key (DEK).
    //
    // A KMS implementation may bind the context to the
    // generated DEK such that the same context must be
    // provided when decrypting an encrypted DEK.
    type Context map[string]string
    
    // MarshalText returns a canonical text representation of
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 6K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. internal/dsync/dsync-client_test.go

    }
    
    func (restClient *ReconnectRESTClient) Lock(ctx context.Context, args LockArgs) (status bool, err error) {
    	return restClient.Call("/v1/lock", args)
    }
    
    func (restClient *ReconnectRESTClient) RUnlock(ctx context.Context, args LockArgs) (status bool, err error) {
    	return restClient.Call("/v1/runlock", args)
    }
    
    func (restClient *ReconnectRESTClient) Unlock(ctx context.Context, args LockArgs) (status bool, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 20 17:36:09 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top