Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 23 for amqp (0.02 seconds)

  2. github.com/minio/minio

    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)
  3. github.com/minio/minio

    internal/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 Jun 01 21:59:40 GMT 2021
    - 3.9K bytes
    - Click Count (0)
  4. github.com/minio/minio

    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)
  5. github.com/minio/minio

    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)
  6. github.com/minio/minio

    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)
  7. github.com/minio/minio

    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)
  8. github.com/gradle/gradle

    .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)
  9. github.com/codelibs/fess

    src/main/webapp/js/admin/plugins/form-validator/sanitize.js 

    c:"\\"+c,"g");b=b.replace(d,"")}),b},escape:function(b,c){var d=c.valAttr("is-escaped"),e={"<":"__%AMP%__lt;",">":"__%AMP%__gt;","&":"__%AMP%__amp;","'":"__%AMP%__#8217;",'"':"__%AMP%__quot;"};return"yes"===d?b:(c.valAttr("is-escaped","yes"),c.one("keyup",function(a){9!==a.keyCode&&c.valAttr("is-escaped","no")}),a.each(e,function(a,c){b=b.replace(new RegExp(a,"g"),c)}),b.replace(new RegExp("__%AMP%__","g"),"&"))}},e=function(b,e,f){e||(e=a("form")),e.each||(e=a(e));var g=function(){var b=a(this)...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Jan 01 05:12:47 GMT 2018
    - 2.7K bytes
    - Click Count (0)
  10. github.com/square/okhttp

    .junit.run/Not Slow.run.xml 

        <option name="PARAMETERS" value="" />
    <option name="TEST_SEARCH_SCOPE">
      <value defaultName="wholeProject" />
    </option>
    <tag value="!Slow &amp; !Slowish &amp; !Remote &amp; !Android" />
    <method v="2">
      <option name="Make" enabled="true" />
    </method>
  </configuration>
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Nov 21 13:28:45 GMT 2020
    - 730 bytes
    - Click Count (0)
  11. github.com/apache/maven

    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)
Back to Top