- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 462 for CTX (0.2 sec)
-
cmd/bucket-metadata-sys.go
} err = sys.save(ctx, meta) return updatedAt, err } func (sys *BucketMetadataSys) save(ctx context.Context, meta BucketMetadata) error { objAPI := newObjectLayerFn() if objAPI == nil { return errServerNotInitialized } if isMinioMetaBucketName(meta.Name) { return errInvalidArgument } if err := meta.Save(ctx, objAPI); err != nil { return err }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 19.8K bytes - Viewed (0) -
src/test/java/jcifs/tests/EnumTest.java
CIFSContext ctx = getContext(); ctx = withConfig(ctx, new DelegatingConfiguration(ctx.getConfig()) { @Override public int getListCount () { return pageSize; } }); ctx = withTestNTLMCredentials(ctx); try ( SmbResource root = ctx.get(getTestShareURL());
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Thu Jan 05 13:09:03 GMT 2023 - 25.5K bytes - Viewed (0) -
cmd/erasure-multipart.go
func (er erasureObjects) NewMultipartUpload(ctx context.Context, bucket, object string, opts ObjectOptions) (*NewMultipartUploadResult, error) { if !opts.NoAuditLog { auditObjectErasureSet(ctx, object, &er) } return er.newMultipartUpload(ctx, bucket, object, opts) } // renamePart - renames multipart part to its relevant location under uploadID.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cmd/erasure-sets.go
return s.getHashedSet(object).TransitionObject(ctx, bucket, object, opts) } // RestoreTransitionedObject - restore transitioned object content locally on this cluster. func (s *erasureSets) RestoreTransitionedObject(ctx context.Context, bucket, object string, opts ObjectOptions) error { return s.getHashedSet(object).RestoreTransitionedObject(ctx, bucket, object, opts) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 37.5K bytes - Viewed (5) -
istioctl/pkg/proxyconfig/proxyconfig.go
configCmd.AddCommand(clusterConfigCmd(ctx)) configCmd.AddCommand(allConfigCmd(ctx)) configCmd.AddCommand(listenerConfigCmd(ctx)) configCmd.AddCommand(logCmd(ctx)) configCmd.AddCommand(routeConfigCmd(ctx)) configCmd.AddCommand(bootstrapConfigCmd(ctx)) configCmd.AddCommand(endpointConfigCmd(ctx)) configCmd.AddCommand(edsConfigCmd(ctx)) configCmd.AddCommand(secretConfigCmd(ctx))
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0) -
cmd/lock-rest-client.go
func (c *lockRESTClient) RLock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCRLock, &args) } // Lock calls lock REST API. func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCLock, &args) } // RUnlock calls read unlock REST API.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Nov 24 17:07:14 GMT 2023 - 3.3K bytes - Viewed (0) -
internal/dsync/drwmutex.go
func (dm *DRWMutex) lockBlocking(ctx context.Context, lockLossCallback func(), id, source string, isReadLock bool, opts Options) (locked bool) { restClnts, _ := dm.clnt.GetLockers() // Create lock array to capture the successful lockers locks := make([]string, len(restClnts)) // Add total timeout ctx, cancel := context.WithTimeout(ctx, opts.Timeout) defer cancel()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/iam-etcd-store.go
return deleteKeyEtcd(ctx, ies.client, path) } func (ies *IAMEtcdStore) loadPolicyDocWithRetry(ctx context.Context, policy string, m map[string]PolicyDoc, _ int) error { return ies.loadPolicyDoc(ctx, policy, m) } func (ies *IAMEtcdStore) loadPolicyDoc(ctx context.Context, policy string, m map[string]PolicyDoc) error { data, err := ies.loadIAMConfigBytes(ctx, getPolicyDocPath(policy)) if err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
cmd/bucket-versioning-handler.go
}, r.URL) return } configData, err := xml.Marshal(v) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketVersioningConfig, configData) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Call site replication hook. //
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5K bytes - Viewed (0) -
cmd/metacache-set.go
} func (o *listPathOptions) setBucketMeta(ctx context.Context) { lc, _ := globalLifecycleSys.Get(o.Bucket) vc, _ := globalBucketVersioningSys.Get(o.Bucket) // Check if bucket is object locked. rcfg, _ := globalBucketObjectLockSys.Get(o.Bucket) replCfg, _, _ := globalBucketMetadataSys.GetReplicationConfig(ctx, o.Bucket) tgts, _ := globalBucketTargetSys.ListBucketTargets(ctx, o.Bucket) o.Lifecycle = lc o.Versioning = vc
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0)