Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 2,275 for context (0.06 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: 2025-05-25 19:28
    - Last Modified: 2022-01-02 17:15
    - 6K bytes
    - Viewed (0)
  2. istioctl/pkg/cli/context.go

    	// CLIClientsForContexts returns clients for all the given contexts in a kubeconfig.
    	CLIClientsForContexts(contexts []string) ([]kube.CLIClient, error)
    }
    
    type instance struct {
    	// clients are cached clients for each revision
    	clients map[string]kube.CLIClient
    	// remoteClients are cached clients for each context with empty revision.
    	remoteClients map[string]kube.CLIClient
    	RootFlags
    }
    
    Registered: 2025-05-28 22:53
    - Last Modified: 2025-05-02 02:51
    - 9.3K bytes
    - Viewed (0)
  3. 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: 2025-05-25 19:28
    - Last Modified: 2022-01-20 17:36
    - 4.4K 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: 2025-05-25 19:28
    - Last Modified: 2025-02-18 16:25
    - 33.3K bytes
    - Viewed (0)
  5. cmd/handler-utils.go

    			tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    			if ok {
    				tc.FuncName = "s3.AppendObject"
    				tc.ResponseRecorder.LogErrBody = true
    			}
    
    			writeErrorResponse(r.Context(), w, getAPIError(ErrNotImplemented), r.URL)
    			return
    		}
    
    		tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    		if ok {
    			tc.FuncName = "s3.ValidRequest"
    Registered: 2025-05-25 19:28
    - Last Modified: 2025-05-07 15:37
    - 16.3K bytes
    - Viewed (1)
  6. 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: 2025-05-25 19:28
    - Last Modified: 2025-01-19 23:13
    - 37K bytes
    - Viewed (1)
  7. 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: 2025-05-25 19:28
    - Last Modified: 2025-03-13 05:29
    - 4.6K bytes
    - Viewed (0)
  8. src/main/java/jcifs/CIFSContext.java

     */
    package jcifs;
    
    
    import java.net.URLStreamHandler;
    
    
    /**
     * Encapsulation of client context
     * 
     * 
     * A context holds the client configuration, shared services as well as the active credentials.
     * 
     * Usually you will want to create one context per client configuration and then
     * multiple sub-contexts using different credentials (if necessary).
     * 
    Registered: 2025-05-25 00:10
    - Last Modified: 2018-07-01 13:12
    - 3.7K bytes
    - Viewed (0)
  9. 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: 2025-05-25 19:28
    - Last Modified: 2025-01-31 19:54
    - 20.4K bytes
    - Viewed (0)
  10. cmd/naughty-disk_test.go

    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.DeleteVol(ctx, volume, forceDelete)
    }
    
    func (d *naughtyDisk) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.WalkDir(ctx, opts, wr)
    }
    
    Registered: 2025-05-25 19:28
    - Last Modified: 2025-04-25 05:41
    - 10.1K bytes
    - Viewed (0)
Back to top