Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 245 for saves (0.05 sec)

  1. okhttp/src/main/kotlin/okhttp3/CookieJar.kt

     * updating and expiring cookies.
     *
     * [rfc_6265_53]: https://tools.ietf.org/html/rfc6265#section-5.3
     */
    interface CookieJar {
      /**
       * Saves [cookies] from an HTTP response to this store according to this jar's policy.
       *
       * Note that this method may be called a second time for a single HTTP response if the response
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  2. compat/maven-model-builder/src/main/java/org/apache/maven/model/normalization/DefaultModelNormalizer.java

             * the first occurrence. So when we're in lenient/compat mode, we have to deal with such broken POMs and mimic
             * the way 2.x works. When we're in strict mode, the removal of duplicates just saves other merging steps from
             * aftereffects and bogus error messages.
             */
            List<Dependency> dependencies = model.getDependencies();
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  3. internal/event/target/webhook.go

    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	defer conn.Close()
    	return true, nil
    }
    
    // Save - saves the events to the store if queuestore is configured,
    // which will be replayed when the webhook connection is active.
    func (target *WebhookTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  4. internal/event/target/nsq.go

    		if xnet.IsConnRefusedErr(err) {
    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store which will be replayed when the nsq connection is active.
    func (target *NSQTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    
    	if err := target.init(); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  5. internal/event/target/mqtt.go

    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Save - saves the events to the store if queuestore is configured, which will
    // be replayed when the mqtt connection is active.
    func (target *MQTTTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  6. internal/event/target/kafka.go

    	brokers := target.client.Brokers()
    	if len(brokers) == 0 {
    		return false, store.ErrNotConnected
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store which will be replayed when the Kafka connection is active.
    func (target *KafkaTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		if target.batch != nil {
    			return target.batch.Add(eventData)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  7. docs/changelogs/changelog_4x.md

        compresses messages of size 1 KiB and larger. (Inbound messages are compressed or not based on
        the web socket server's configuration.)
     *  New: Defer constructing `Inflater` and `Deflater` instances until they are needed. This saves
        memory if web socket compression is negotiated but not used.
    
    
    ## Version 4.5.0-RC1
    
    _2020-03-17_
    
    **This release candidate turns on web socket compression.**
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  8. internal/event/target/postgresql.go

    		if IsConnErr(err) {
    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store if questore is configured, which will be replayed when the PostgreSQL connection is active.
    func (target *PostgreSQLTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/collect/testing/AbstractMapTester.java

        }
      }
    
      private static boolean equal(@Nullable Object a, @Nullable Object b) {
        return a == b || (a != null && a.equals(b));
      }
    
      // This one-liner saves us from some ugly casts
      protected Entry<K, V> entry(K key, V value) {
        return mapEntry(key, value);
      }
    
      @Override
      protected void expectContents(Collection<Entry<K, V>> expected) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/AtomicDoubleArray.java

          b.append(longBitsToDouble(longs.get(i)));
          if (i == iMax) {
            return b.append(']').toString();
          }
          b.append(',').append(' ');
        }
      }
    
      /**
       * Saves the state to a stream (that is, serializes it).
       *
       * @serialData The length of the array is emitted (int), followed by all of its elements (each a
       *     {@code double}) in the proper order.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 17:55:55 UTC 2024
    - 10.3K bytes
    - Viewed (0)
Back to top