Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for Walker (0.15 sec)

  1. utils/utils.go

    	yval := reflect.ValueOf(y)
    	if xval.Kind() == reflect.Ptr && xval.IsNil() ||
    		yval.Kind() == reflect.Ptr && yval.IsNil() {
    		return false
    	}
    
    	if valuer, ok := x.(driver.Valuer); ok {
    		x, _ = valuer.Value()
    	}
    	if valuer, ok := y.(driver.Valuer); ok {
    		y, _ = valuer.Value()
    	}
    	return reflect.DeepEqual(x, y)
    }
    
    func ToString(value interface{}) string {
    	switch v := value.(type) {
    	case string:
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Mon Apr 22 06:43:02 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  2. logger/sql.go

    		default:
    			rv := reflect.ValueOf(v)
    			if v == nil || !rv.IsValid() || rv.Kind() == reflect.Ptr && rv.IsNil() {
    				vars[idx] = nullStr
    			} else if valuer, ok := v.(driver.Valuer); ok {
    				v, _ = valuer.Value()
    				convertParams(v, idx)
    			} else if rv.Kind() == reflect.Ptr && !rv.IsZero() {
    				convertParams(reflect.Indirect(rv).Interface(), idx)
    			} else if isNumeric(rv.Kind()) {
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Thu Mar 21 08:00:02 GMT 2024
    - 5K bytes
    - Viewed (0)
  3. internal/cachevalue/cache.go

    // An Update function must be set to provide an updated value when needed.
    type Cache[T any] struct {
    	// updateFn must return an updated value.
    	// If an error is returned the cached value is not set.
    	// Only one caller will call this function at any time, others will be blocking.
    	// The returned value can no longer be modified once returned.
    	// Should be set before calling Get().
    	updateFn func() (T, error)
    
    	// ttl for a cached value.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  4. cmd/warm-backend-azure.go

    }
    
    func (az *warmBackendAzure) InUse(ctx context.Context) (bool, error) {
    	containerURL := az.serviceURL.NewContainerURL(az.Bucket)
    	resp, err := containerURL.ListBlobsHierarchySegment(ctx, azblob.Marker{}, "/", azblob.ListBlobsSegmentOptions{
    		Prefix:     az.Prefix,
    		MaxResults: int32(1),
    	})
    	if err != nil {
    		return false, azureToObjectError(err, az.Bucket, az.Prefix)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 05 16:44:08 GMT 2024
    - 7.8K bytes
    - Viewed (1)
  5. internal/grid/stream.go

    	"errors"
    )
    
    // A Stream is a two-way stream.
    // All responses *must* be read by the caller.
    // If the call is canceled through the context,
    // the appropriate error will be returned.
    type Stream struct {
    	// responses from the remote server.
    	// Channel will be closed after error or when remote closes.
    	// All responses *must* be read by the caller until either an error is returned or the channel is closed.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 28 18:05:18 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  6. schema/serializer.go

    	fieldValue      interface{}
    }
    
    // Scan implements sql.Scanner interface
    func (s *serializer) Scan(value interface{}) error {
    	s.value = value
    	return nil
    }
    
    // Value implements driver.Valuer interface
    func (s serializer) Value() (driver.Value, error) {
    	return s.SerializeValuer.Value(s.Context, s.Field, s.Destination, s.fieldValue)
    }
    
    // SerializerInterface serializer interface
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Mon Mar 18 08:28:46 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  7. cmd/tier-sweeper.go

    	// 3. If bucket versioning is enabled and
    	//    a. version id is specified, remove its remote object.
    	//    b. version id is not specified, nothing to be done (a delete marker is added).
    	delTier := false
    	switch {
    	case !os.Versioned, os.Suspended: // 1, 2.a, 2.b
    		delTier = true
    	case os.Versioned && os.VersionID != "": // 3.a
    		delTier = true
    	}
    	if delTier {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 4.7K bytes
    - Viewed (0)
  8. cmd/object-api-input-checks.go

    		return ObjectNameInvalid{Bucket: bucket, Object: object}
    	}
    	return nil
    }
    
    // Checks for all ListObjects arguments validity.
    func checkListObjsArgs(ctx context.Context, bucket, prefix, marker string) error {
    	// Verify if bucket is valid.
    	if !isMinioMetaBucketName(bucket) && s3utils.CheckValidBucketNameStrict(bucket) != nil {
    		return BucketNameInvalid{Bucket: bucket}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.7K bytes
    - Viewed (0)
  9. cmd/storage-errors.go

    // errLessData - returned when less data available than what was requested.
    var errLessData = StorageErr("less data available than what was requested")
    
    // errMoreData = returned when more data was sent by the caller than what it was supposed to.
    var errMoreData = StorageErr("more data was sent than what was advertised")
    
    // indicates readDirFn to return without further applying the fn()
    var errDoneForNow = errors.New("done for now")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  10. internal/bucket/lifecycle/expiration.go

    	set bool
    }
    
    // MarshalXML encodes delete marker boolean into an XML form.
    func (b Boolean) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error {
    	if !b.set {
    		return nil
    	}
    	return e.EncodeElement(b.val, startElement)
    }
    
    // UnmarshalXML decodes delete marker boolean from the XML form.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 21 20:28:34 GMT 2024
    - 6.6K bytes
    - Viewed (1)
Back to top