Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for getTax (0.18 sec)

  1. cmd/xl-storage-free-version.go

    		if version.header.VersionID != uv || version.header.Type != ObjectType {
    			continue
    		}
    		// if uv has tiered content we add a
    		// free-version to track it for asynchronous
    		// deletion via scanner.
    		ver, err := x.getIdx(i)
    		if err != nil {
    			return err
    		}
    
    		if freeVersion, toFree := ver.ObjectV2.InitFreeVersion(fi); toFree {
    			return x.addVersion(freeVersion)
    		}
    		return nil
    	}
    	return nil
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  2. cmd/xl-storage-format-v2.go

    	for i, ver := range x.versions {
    		if key == ver.header.VersionID {
    			obj, err := x.getIdx(i)
    			return i, obj, err
    		}
    	}
    	return -1, nil, errFileVersionNotFound
    }
    
    func (x *xlMetaV2) getIdx(idx int) (ver *xlMetaV2Version, err error) {
    	if idx < 0 || idx >= len(x.versions) {
    		return nil, errFileNotFound
    	}
    	var dst xlMetaV2Version
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
  3. internal/logger/target/http/http.go

    	}
    
    	return h, nil
    }
    
    // SendFromStore - reads the log from store and sends it to webhook.
    func (h *Target) SendFromStore(key store.Key) (err error) {
    	var eventData []byte
    	eventData, err = h.store.GetRaw(key.Name)
    	if err != nil {
    		if os.IsNotExist(err) {
    			return nil
    		}
    		return err
    	}
    
    	if err := h.send(context.Background(), eventData, h.payloadType, webhookCallTimeout); err != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  4. cmd/xl-storage-format-v2_test.go

    			return xl.versions[i].header.ModTime > xl.versions[j].header.ModTime
    		}) {
    			t.Errorf("Contents not sorted")
    		}
    		for i := range xl.versions {
    			hdr := xl.versions[i].header
    			ver, err := xl.getIdx(i)
    			if err != nil {
    				t.Error(err)
    				continue
    			}
    			gotHdr := ver.header()
    			if hdr != gotHdr {
    				t.Errorf("Header does not match, index: %+v != meta: %+v", hdr, gotHdr)
    			}
    		}
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Mar 08 17:50:48 GMT 2024
    - 36.4K bytes
    - Viewed (0)
  5. internal/store/queuestore.go

    	}
    	// Generate a new UUID for the key.
    	key, err := uuid.NewRandom()
    	if err != nil {
    		return err
    	}
    	return store.write(key.String(), item)
    }
    
    // GetRaw - gets an item from the store.
    func (store *QueueStore[I]) GetRaw(key string) (raw []byte, err error) {
    	store.RLock()
    
    	defer func(store *QueueStore[I]) {
    		store.RUnlock()
    		if err != nil {
    			// Upon error we remove the entry.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  6. internal/store/store.go

    	Name() string
    	SendFromStore(key Key) error
    }
    
    // Store - Used to persist items.
    type Store[I any] interface {
    	Put(item I) error
    	PutMultiple(item []I) error
    	Get(key string) (I, error)
    	GetRaw(key string) ([]byte, error)
    	Len() int
    	List() ([]string, error)
    	Del(key string) error
    	DelList(key []string) error
    	Open() error
    	Delete() error
    	Extension() string
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 3.5K bytes
    - Viewed (0)
Back to top