Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 162 for amqp (0.17 sec)

  1. internal/event/target/amqp.go

    	EnvAMQPEnable            = "MINIO_NOTIFY_AMQP_ENABLE"
    	EnvAMQPURL               = "MINIO_NOTIFY_AMQP_URL"
    	EnvAMQPExchange          = "MINIO_NOTIFY_AMQP_EXCHANGE"
    	EnvAMQPRoutingKey        = "MINIO_NOTIFY_AMQP_ROUTING_KEY"
    	EnvAMQPExchangeType      = "MINIO_NOTIFY_AMQP_EXCHANGE_TYPE"
    	EnvAMQPDeliveryMode      = "MINIO_NOTIFY_AMQP_DELIVERY_MODE"
    	EnvAMQPMandatory         = "MINIO_NOTIFY_AMQP_MANDATORY"
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 10K bytes
    - Viewed (0)
  2. 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Mar 07 16:12:41 GMT 2023
    - 3.9K bytes
    - Viewed (0)
  3. 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 3.9K bytes
    - Viewed (0)
  4. 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"`
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 2.8K bytes
    - Viewed (0)
  5. 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},
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 8.8K bytes
    - Viewed (0)
  6. 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()},
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Jan 05 18:43:06 GMT 2024
    - 6.8K bytes
    - Viewed (0)
  7. docs/bucket/notifications/README.md

    ```
    KEY:
    notify_amqp[:name]  publish bucket notifications to AMQP endpoints
    
    ARGS:
    MINIO_NOTIFY_AMQP_ENABLE*        (on|off)    enable notify_amqp target, default is 'off'
    MINIO_NOTIFY_AMQP_URL*           (url)       AMQP server endpoint e.g. `amqp://myuser:mypassword@localhost:5672`
    MINIO_NOTIFY_AMQP_EXCHANGE       (string)    name of the AMQP exchange
    MINIO_NOTIFY_AMQP_EXCHANGE_TYPE  (string)    AMQP exchange type
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 84K bytes
    - Viewed (2)
  8. internal/config/notify/help.go

    			Description: "AMQP server endpoint e.g. `amqp://myuser:mypassword@localhost:5672`",
    			Type:        "url",
    			Sensitive:   true,
    		},
    		config.HelpKV{
    			Key:         target.AmqpExchange,
    			Description: "name of the AMQP exchange",
    			Optional:    true,
    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         target.AmqpExchangeType,
    			Description: "AMQP exchange type",
    			Optional:    true,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Mar 19 04:37:54 GMT 2024
    - 18.8K bytes
    - Viewed (0)
  9. internal/event/config_test.go

    		{config2, "", []ARN{{TargetID{"1", "webhook"}, ""}}},
    		{config3, "us-east-1", []ARN{{TargetID{"1", "webhook"}, "us-east-1"}, {TargetID{"2", "amqp"}, "us-east-1"}}},
    		{config3, "", []ARN{{TargetID{"1", "webhook"}, ""}, {TargetID{"2", "amqp"}, ""}}},
    	}
    
    	for i, testCase := range testCases {
    		testCase.config.SetRegion(testCase.region)
    		result := []ARN{}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Dec 05 10:16:33 GMT 2023
    - 29K bytes
    - Viewed (0)
  10. 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Oct 18 18:05:24 GMT 2023
    - 5.4K bytes
    - Viewed (0)
Back to top