Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 1,122 for contextos (0.07 sec)

  1. cmd/erasure-encode_test.go

    	return nil, errFaultyDisk
    }
    
    func (a badDisk) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) error {
    	return errFaultyDisk
    }
    
    func (badDisk) Hostname() string {
    	return ""
    }
    
    const oneMiByte = 1 * humanize.MiByte
    
    var erasureEncodeTests = []struct {
    	dataBlocks                   int
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  2. internal/grid/README.md

    The handler function has this signature.
    
    Sample handler:
    ```go
        handler :=  func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr {
            fmt.Println("Got request with initial payload", p, "from", GetCaller(ctx context.Context))
            fmt.Println("Subroute:", GetSubroute(ctx))
            for {
                select {
                case <-ctx.Done():
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  3. internal/config/dns/etcd_dns.go

    			key := msgPath(fmt.Sprintf("%s.%s", bucket, domainName), c.prefixPath)
    			key = key + etcdPathSeparator + ip
    			ctx, cancel := context.WithTimeout(context.Background(), defaultContextTimeout)
    			_, err = c.etcdClient.Put(ctx, key, string(bucketMsg))
    			cancel()
    			if err != nil {
    				ctx, cancel = context.WithTimeout(context.Background(), defaultContextTimeout)
    				c.etcdClient.Delete(ctx, key)
    				cancel()
    				return err
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 15:03:08 UTC 2024
    - 8K bytes
    - Viewed (0)
  4. callbacks/delete.go

    			if !ok {
    				result, err := db.Statement.ConnPool.ExecContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...)
    				if db.AddError(err) == nil {
    					db.RowsAffected, _ = result.RowsAffected()
    				}
    
    				return
    			}
    
    			if rows, err := db.Statement.ConnPool.QueryContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...); db.AddError(err) == nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Feb 25 02:48:23 UTC 2022
    - 5.6K bytes
    - Viewed (0)
  5. cmd/erasure_test.go

    		buffer := make([]byte, len(data), 2*len(data))
    		copy(buffer, data)
    
    		erasure, err := NewErasure(context.Background(), test.dataBlocks, test.parityBlocks, blockSizeV2)
    		if err != nil {
    			t.Fatalf("Test %d: failed to create erasure: %v", i, err)
    		}
    		encoded, err := erasure.EncodeData(context.Background(), buffer)
    		if err != nil {
    			t.Fatalf("Test %d: failed to encode data: %v", i, err)
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 25 19:37:26 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  6. guava-testlib/src/com/google/common/collect/testing/TestContainerGenerator.java

       * its input unmodified. Provided that the test suite is built without {@link
       * com.google.common.collect.testing.features.CollectionFeature#KNOWN_ORDER}, the tests will look
       * only at the returned contents without regard for order.
       */
      Iterable<E> order(List<E> insertionOrder);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 21 16:49:06 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  7. cmd/bucket-replication.go

    // this node returns a 404
    func proxyHeadToReplicationTarget(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, opts ObjectOptions, proxyTargets *madmin.BucketTargets) (oi ObjectInfo, proxy proxyResult) {
    	_, oi, proxy = proxyHeadToRepTarget(ctx, bucket, object, rs, opts, proxyTargets)
    	return oi, proxy
    }
    
    func scheduleReplication(ctx context.Context, oi ObjectInfo, o ObjectLayer, dsc ReplicateDecision, opType replication.Type) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  8. doc/next/6-stdlib/99-minor/testing/36532.md

    The new [T.Context] and [B.Context] methods return a context that's canceled
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 20 17:36:54 UTC 2024
    - 141 bytes
    - Viewed (0)
  9. schema/utils.go

    	if strings.Contains(t, value) {
    		return tag
    	}
    	return reflect.StructTag(fmt.Sprintf(`gorm:"%s;%s"`, value, t))
    }
    
    // GetRelationsValues get relations's values from a reflect value
    func GetRelationsValues(ctx context.Context, reflectValue reflect.Value, rels []*Relationship) (reflectResults reflect.Value) {
    	for _, rel := range rels {
    		reflectResults = reflect.MakeSlice(reflect.SliceOf(reflect.PtrTo(rel.FieldSchema.ModelType)), 0, 1)
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Aug 19 13:35:14 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  10. internal/config/identity/plugin/config.go

    		o.args.RoleARN: o.args.RolePolicy,
    	}
    }
    
    // checkConnectivity returns true if we are able to connect to the plugin
    // service.
    func (o *AuthNPlugin) checkConnectivity(ctx context.Context) bool {
    	ctx, cancel := context.WithTimeout(ctx, healthCheckTimeout)
    	defer cancel()
    	u := url.URL(*o.args.URL)
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodHead, u.String(), nil)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
Back to top