- Sort Score
- Result 10 results
- Languages All
Results 201 - 210 of 1,339 for contextos (0.06 sec)
-
cmd/erasure-multipart.go
func (er erasureObjects) newMultipartUpload(ctx context.Context, bucket string, object string, opts ObjectOptions) (*NewMultipartUploadResult, error) { if opts.CheckPrecondFn != nil { if !opts.NoLock { ns := er.NewNSLock(bucket, object) lkctx, err := ns.GetLock(ctx, globalOperationTimeout) if err != nil { return nil, err } ctx = lkctx.Context() defer ns.Unlock(lkctx) opts.NoLock = true }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 44.7K bytes - Viewed (0) -
cmd/iam.go
// only via IAM notifications. func (sys *IAMSys) LoadGroup(ctx context.Context, objAPI ObjectLayer, group string) error { if !sys.Initialized() { return errServerNotInitialized } return sys.store.GroupNotificationHandler(ctx, group) } // LoadPolicy - reloads a specific canned policy from backend disks or etcd. func (sys *IAMSys) LoadPolicy(ctx context.Context, objAPI ObjectLayer, policyName string) error {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 29 16:01:48 UTC 2024 - 74.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/logic/AccessContextLogic.java
// ============== public AccessContext create(final AccessContextResource resource, final UserTypeSupplier userTypeSupplier, final UserBeanSupplier userBeanSupplier, final AppTypeSupplier appTypeSupplier) { final AccessContext context = new AccessContext();
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 3.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/PrefixQueryCommand.java
final FessConfig fessConfig = ComponentUtil.getFessConfig(); final String field = getSearchField(context.getDefaultField(), prefixQuery.getField()); final String text = prefixQuery.getPrefix().text(); if (Constants.DEFAULT_FIELD.equals(field)) { context.addFieldLog(field, text + "*");
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 4.3K bytes - Viewed (0) -
internal/config/crypto_test.go
) var encryptDecryptTests = []struct { Data []byte Context kms.Context }{ { Data: nil, Context: nil, }, { Data: []byte{1}, Context: nil, }, { Data: []byte{1}, Context: kms.Context{"key": "value"}, }, { Data: make([]byte, 1<<20), Context: kms.Context{"key": "value", "a": "b"}, }, } func TestEncryptDecrypt(t *testing.T) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 3.2K bytes - Viewed (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/path/ProfileActivationFilePathInterpolator.java
return null; } }); interpolator.addValueSource(new MapBasedValueSource(context.getProjectProperties())); interpolator.addValueSource(new MapBasedValueSource(context.getUserProperties())); interpolator.addValueSource(new MapBasedValueSource(context.getSystemProperties())); String absolutePath = interpolator.interpolate(path, "");
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 3.8K bytes - Viewed (0) -
cmd/metrics-v3-cache.go
nodesUpDown: newNodesUpDownCache(), } } type nodesOnline struct { Online, Offline int } func newNodesUpDownCache() *cachevalue.Cache[nodesOnline] { loadNodesUpDown := func(ctx context.Context) (v nodesOnline, err error) { v.Online, v.Offline = globalNotificationSys.GetPeerOnlineCount() return } return cachevalue.NewFromFunc(1*time.Minute, cachevalue.Opts{ReturnLastGood: true}, loadNodesUpDown)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 09 00:51:34 UTC 2024 - 8.1K bytes - Viewed (0) -
src/main/java/jcifs/smb1/ntlmssp/Type2Message.java
* * @param context The local security context. */ public void setContext(byte[] context) { this.context = context; } public byte[] toByteArray() { try { String targetName = getTarget(); byte[] challenge = getChallenge(); byte[] context = getContext(); byte[] targetInformation = getTargetInformation(); int flags = getFlags();
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 12.6K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list.go
} } } hooksList, err := client.Kube().AdmissionregistrationV1().MutatingWebhookConfigurations().List(context.Background(), metav1.ListOptions{ LabelSelector: "app=sidecar-injector", }) if err != nil { return err } hooks := hooksList.Items pods, err := getPods(context.Background(), client) if err != nil { return err }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Oct 18 11:39:52 UTC 2024 - 10.6K bytes - Viewed (0) -
cmd/admin-handlers-config-kv.go
// Logger webhook proxy deleted, apply the dynamic changes applyDynamic(ctx, objectAPI, cfg, config.LoggerWebhookSubSys, r, w) } } } func applyDynamic(ctx context.Context, objectAPI ObjectLayer, cfg config.Config, subSys string, r *http.Request, w http.ResponseWriter, ) { // Apply dynamic values. if err := applyDynamicConfigForSubSys(GlobalContext, objectAPI, cfg, subSys); err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.7K bytes - Viewed (0)