- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,275 for context (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
cmd/naughty-disk_test.go
Registered: 2025-05-25 19:28 - Last Modified: 2025-04-25 05:41 - 10.1K bytes - Viewed (0)