Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 18 for amqp (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/config/lambda/event/targetidset_test.go

    		{NewTargetIDSet(TargetID{"1", "webhook"}), NewTargetIDSet(), NewTargetIDSet(TargetID{"1", "webhook"})},
    		{NewTargetIDSet(TargetID{"1", "webhook"}), NewTargetIDSet(TargetID{"2", "amqp"}), NewTargetIDSet(TargetID{"1", "webhook"}, TargetID{"2", "amqp"})},
    		{NewTargetIDSet(TargetID{"1", "webhook"}), NewTargetIDSet(TargetID{"1", "webhook"}), NewTargetIDSet(TargetID{"1", "webhook"})},
    	}
    
    	for i, testCase := range testCases {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Mar 07 16:12:41 GMT 2023
    - 3.9K bytes
    - Click Count (0)
  2. internal/event/rules_test.go

    		{rulesCase2, NewPattern("*", ""), TargetID{"2", "amqp"}, 2},
    		{rulesCase3, NewPattern("2010*", ""), TargetID{"1", "webhook"}, 1},
    		{rulesCase4, NewPattern("*", ""), TargetID{"1", "webhook"}, 2},
    		{rulesCase5, NewPattern("", "*.jpg"), TargetID{"1", "webhook"}, 1},
    		{rulesCase6, NewPattern("", "*"), TargetID{"2", "amqp"}, 2},
    		{rulesCase7, NewPattern("", "*.jpg"), TargetID{"1", "webhook"}, 1},
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 8.8K bytes
    - Click Count (0)
  3. internal/config/notify/config.go

    import (
    	"github.com/minio/minio/internal/event/target"
    )
    
    // Config - notification target configuration structure, holds
    // information about various notification targets.
    type Config struct {
    	AMQP          map[string]target.AMQPArgs          `json:"amqp"`
    	Elasticsearch map[string]target.ElasticsearchArgs `json:"elasticsearch"`
    	Kafka         map[string]target.KafkaArgs         `json:"kafka"`
    	MQTT          map[string]target.MQTTArgs          `json:"mqtt"`
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 2.8K bytes
    - Click Count (0)
  4. internal/event/rulesmap_test.go

    	rulesMapCase4 := NewRulesMap([]Name{ObjectCreatedAll}, "2010*.jpg", TargetID{"1", "webhook"})
    	rulesMapCase4.add([]Name{ObjectCreatedAll}, "*", TargetID{"2", "amqp"})
    
    	testCases := []struct {
    		rulesMap       RulesMap
    		eventName      Name
    		objectName     string
    		expectedResult TargetIDSet
    	}{
    		{rulesMapCase1, ObjectCreatedPut, "2010/photo.jpg", NewTargetIDSet()},
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jan 05 18:43:06 GMT 2024
    - 6.8K bytes
    - Click Count (0)
  5. cmd/config-migrate.go

    	}
    
    	xldap.SetIdentityLDAP(newCfg, cfg.LDAPServerConfig)
    	opa.SetPolicyOPAConfig(newCfg, cfg.Policy.OPA)
    	compress.SetCompressionConfig(newCfg, cfg.Compression)
    
    	for k, args := range cfg.Notify.AMQP {
    		notify.SetNotifyAMQP(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.Elasticsearch {
    		notify.SetNotifyES(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.Kafka {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  6. .idea/scopes/Gradle_public_API.xml

        <scope name="Gradle public API"
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Jul 18 15:08:47 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  7. compat/maven-compat/src/test/java/org/apache/maven/project/inheritance/t09/ProjectInheritanceTest.java

         *
         * 1. dependencyManagement lists dependencies on a &amp; b,
         *    with an exclusion on c in b.
         * 2. the child project lists a dependency on project a only
         * 3. a depends on b (which is transitive to the child project),
         *    and b depends on c.
         *
         * We should see that the resulting size of collected artifacts is two:
         * a &amp; b only.
         */
        @Test
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jul 23 17:27:08 GMT 2025
    - 5K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/xml/XmlEscapersTest.java

        // Simple examples (smoke tests)
        assertThat(xmlEscaper.escape("xxx")).isEqualTo("xxx");
        assertThat(xmlEscaper.escape("test & test & test")).isEqualTo("test &amp; test &amp; test");
        assertThat(xmlEscaper.escape("test << 1")).isEqualTo("test &lt;&lt; 1");
        assertThat(xmlEscaper.escape("test >> 1")).isEqualTo("test &gt;&gt; 1");
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 5K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/escape/ArrayBasedUnicodeEscaper.java

     * general way.
     *
     * <p>A good example of usage of this class is for HTML escaping where the replacement array
     * contains information about the named HTML entities such as {@code &amp;} and {@code &quot;} while
     * {@link #escapeUnsafe} is overridden to handle general escaping of the form {@code &#NNNNN;}.
     *
     * <p>The size of the data structure used by {@link ArrayBasedUnicodeEscaper} is proportional to the
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Feb 13 15:45:16 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/helper/MarkdownRenderer.java

         * @return HTML-escaped text
         */
        private String escapeHtml(final String text) {
            if (text == null) {
                return "";
            }
            return text.replace("&", "&amp;").replace("<", "&lt;").replace(">", "&gt;").replace("\"", "&quot;").replace("'", "&#39;");
        }
    
        /**
         * Checks if the renderer is properly initialized.
         *
         * @return true if initialized
         */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Jan 12 10:32:40 GMT 2026
    - 5.3K bytes
    - Click Count (0)
Back to Top