- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 551 for Context (0.12 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)