Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 7 of 7 for GetRaw (0.34 seconds)

  1. compat/maven-embedder/src/test/java/org/apache/maven/cli/props/MavenPropertiesTest.java

            StringWriter sw = new StringWriter();
            properties.save(sw);
            String msg = sw.toString();
            assertTrue(sw.toString().endsWith(RESULT3), msg);
            List<String> rawValue = properties.getRaw(KEY1);
            assertEquals(2, (Object) rawValue.size());
            assertEquals(KEY1A + " = " + VALUE1, rawValue.get(0));
            assertEquals(VALUE1, rawValue.get(1));
        }
    
        @Test
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Oct 16 06:12:36 GMT 2025
    - 16.4K bytes
    - Click Count (0)
  2. internal/store/queuestore.go

    	if err != nil {
    		return Key{}, err
    	}
    	key := Key{
    		Name:      uid.String(),
    		Extension: store.fileExt,
    	}
    	return key, store.writeBytes(key, b)
    }
    
    // GetRaw - gets an item from the store.
    func (store *QueueStore[I]) GetRaw(key Key) (raw []byte, err error) {
    	store.RLock()
    
    	defer func(store *QueueStore[I]) {
    		store.RUnlock()
    		if err != nil && !os.IsNotExist(err) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  3. internal/store/store.go

    }
    
    // Store - Used to persist items.
    type Store[I any] interface {
    	Put(item I) (Key, error)
    	PutMultiple(item []I) (Key, error)
    	Get(key Key) (I, error)
    	GetMultiple(key Key) ([]I, error)
    	GetRaw(key Key) ([]byte, error)
    	PutRaw(b []byte) (Key, error)
    	Len() int
    	List() []Key
    	Del(key Key) error
    	Open() error
    	Delete() error
    }
    
    // Key denotes the key present in the store.
    type Key struct {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  4. internal/store/queuestore_test.go

    	key := keys[0]
    	if !key.Compress {
    		t.Fatal("expected the item to be compressed")
    	}
    	if key.ItemCount != 10 {
    		t.Fatalf("expected itemcount=10 but found %v", key.ItemCount)
    	}
    
    	raw, err := store.GetRaw(key)
    	if err != nil {
    		t.Fatalf("unable to get multiple items; %v", err)
    	}
    
    	if !bytes.Equal(buf.Bytes(), raw) {
    		t.Fatalf("expected bytes: %d vs read bytes is wrong %d", len(buf.Bytes()), len(raw))
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  5. impl/maven-cli/src/main/java/org/apache/maven/cling/props/MavenProperties.java

            for (String key : properties.keySet()) {
                String v = this.get(key);
                List<String> comments = properties.getComments(key);
                List<String> value = properties.getRaw(key);
                if (v == null) {
                    this.put(key, comments, value);
                    modified = true;
                } else if (!v.equals(properties.get(key))) {
                    if (comments.isEmpty()) {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Oct 16 09:03:48 GMT 2025
    - 38.5K bytes
    - Click Count (0)
  6. compat/maven-embedder/src/main/java/org/apache/maven/cli/props/MavenProperties.java

            for (String key : properties.keySet()) {
                String v = this.get(key);
                List<String> comments = properties.getComments(key);
                List<String> value = properties.getRaw(key);
                if (v == null) {
                    this.put(key, comments, value);
                    modified = true;
                } else if (!v.equals(properties.get(key))) {
                    if (comments.isEmpty()) {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Jul 23 17:27:08 GMT 2025
    - 38.4K bytes
    - Click Count (0)
  7. 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)
    	if err != nil {
    		if os.IsNotExist(err) {
    			return nil
    		}
    		return err
    	}
    
    	count := 1
    	v := strings.Split(key.Name, ":")
    	if len(v) == 2 {
    		count, err = strconv.Atoi(v[0])
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
Back to Top