Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for getDrivers (0.09 sec)

  1. cmd/tier.go

    	binary.LittleEndian.PutUint16(data[2:4], tierConfigVersion)
    
    	// Marshal the tier config
    	return config.MarshalMsg(data)
    }
    
    // getDriver returns a warmBackend interface object initialized with remote tier config matching tierName
    func (config *TierConfigMgr) getDriver(ctx context.Context, tierName string) (d WarmBackend, err error) {
    	config.Lock()
    	defer config.Unlock()
    
    	var ok bool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    func getTransitionedObjectReader(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, oi ObjectInfo, opts ObjectOptions) (gr *GetObjectReader, err error) {
    	tgtClient, err := globalTierConfigMgr.getDriver(ctx, oi.TransitionedObject.Tier)
    	if err != nil {
    		return nil, fmt.Errorf("transition storage class not configured: %w", err)
    	}
    
    	fn, off, length, err := NewGetObjectReader(rs, oi, opts, h)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
Back to top