Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 57 for getRaw (0.14 sec)

  1. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  2. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 3.5K bytes
    - Viewed (0)
  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 May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/core/beans/impl/PropertyDescImplTest.java

            final PropertyDesc propDesc = beanDesc.getPropertyDesc("cal");
            final Date date = new Date();
            propDesc.setValue(myBean, date);
            assertThat(myBean.getCal().getTime(), is(date));
        }
    
        /**
         * @throws Exception
         */
        @Test
        public void testSetIntegerValueToString() throws Exception {
            final MyBean myBean = new MyBean();
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 11.1K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/core/beans/impl/BeanDescImplTest.java

            final BeanDesc beanDesc = new BeanDescImpl(MyBean.class);
            final MethodDesc methodDesc = beanDesc.getMethodDesc("getAaa");
            assertThat(methodDesc, is(notNullValue()));
            assertThat(methodDesc.getMethodName(), is("getAaa"));
            beanDesc.getMethodDesc("getaaa");
        }
    
        /**
         * @throws Exception
         */
        @Test
        public void testGetMethodNoException() throws Exception {
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 13.9K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/collect/testing/google/BiMapPutTester.java

        getMap().forcePut(k1(), null);
    
        expectContents(Helpers.mapEntry(k1(), (V) null));
    
        assertFalse(getMap().containsKey(k0()));
    
        assertTrue(getMap().containsKey(k1()));
        assertTrue(getMap().inverse().containsKey(null));
        assertNull(getMap().get(k1()));
        assertEquals(k1(), getMap().inverse().get(null));
        assertEquals(1, getMap().size());
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  7. guava-testlib/src/com/google/common/collect/testing/testers/ConcurrentMapReplaceEntryTester.java

      @Override
      protected ConcurrentMap<K, V> getMap() {
        return (ConcurrentMap<K, V>) super.getMap();
      }
    
      @MapFeature.Require(SUPPORTS_PUT)
      @CollectionSize.Require(absent = ZERO)
      public void testReplaceEntry_supportedPresent() {
        assertTrue(getMap().replace(k0(), v0(), v3()));
        expectReplacement(entry(k0(), v3()));
      }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Feb 21 16:49:06 GMT 2024
    - 5.3K bytes
    - Viewed (0)
  8. guava-testlib/src/com/google/common/collect/testing/testers/ConcurrentMapReplaceTester.java

    public class ConcurrentMapReplaceTester<K, V> extends AbstractMapTester<K, V> {
      @Override
      protected ConcurrentMap<K, V> getMap() {
        return (ConcurrentMap<K, V>) super.getMap();
      }
    
      @MapFeature.Require(SUPPORTS_PUT)
      @CollectionSize.Require(absent = ZERO)
      public void testReplace_supportedPresent() {
        assertEquals(v0(), getMap().replace(k0(), v3()));
        expectReplacement(entry(k0(), v3()));
      }
    
      @MapFeature.Require(SUPPORTS_PUT)
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Feb 21 16:49:06 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/collect/testing/google/AbstractBiMapTester.java

    @ElementTypesAreNonnullByDefault
    public abstract class AbstractBiMapTester<K extends @Nullable Object, V extends @Nullable Object>
        extends AbstractMapTester<K, V> {
    
      @Override
      protected BiMap<K, V> getMap() {
        return (BiMap<K, V>) super.getMap();
      }
    
      static <K extends @Nullable Object, V extends @Nullable Object> Entry<V, K> reverseEntry(
          Entry<K, V> entry) {
        return Helpers.mapEntry(entry.getValue(), entry.getKey());
      }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Feb 21 16:49:06 GMT 2024
    - 3.1K bytes
    - Viewed (0)
  10. android/guava-testlib/src/com/google/common/collect/testing/google/AbstractBiMapTester.java

    @ElementTypesAreNonnullByDefault
    public abstract class AbstractBiMapTester<K extends @Nullable Object, V extends @Nullable Object>
        extends AbstractMapTester<K, V> {
    
      @Override
      protected BiMap<K, V> getMap() {
        return (BiMap<K, V>) super.getMap();
      }
    
      static <K extends @Nullable Object, V extends @Nullable Object> Entry<V, K> reverseEntry(
          Entry<K, V> entry) {
        return Helpers.mapEntry(entry.getValue(), entry.getKey());
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 21 16:49:06 GMT 2024
    - 3.1K bytes
    - Viewed (0)
Back to top