Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for AMQP (0.6 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 May 05 19:28:20 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 10K bytes
    - Viewed (0)
  2. cmd/config-current.go

    			Description:     "publish bucket notifications to webhook endpoints",
    			MultipleTargets: true,
    		},
    		config.HelpKV{
    			Key:             config.NotifyAMQPSubSys,
    			Description:     "publish bucket notifications to AMQP endpoints",
    			MultipleTargets: true,
    		},
    		config.HelpKV{
    			Key:             config.NotifyKafkaSubSys,
    			Description:     "publish bucket notifications to Kafka endpoints",
    			MultipleTargets: true,
    		},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 30.8K bytes
    - Viewed (0)
  3. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 04:37:54 GMT 2024
    - 18.8K bytes
    - Viewed (0)
  4. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Tue Dec 05 10:16:33 GMT 2023
    - 29K bytes
    - Viewed (0)
  5. internal/config/notify/parse.go

    		}
    		if err = esArgs.Validate(); err != nil {
    			return nil, err
    		}
    		esTargets[k] = esArgs
    	}
    	return esTargets, nil
    }
    
    // DefaultAMQPKVS - default KV for AMQP config
    var (
    	DefaultAMQPKVS = config.KVS{
    		config.KV{
    			Key:   config.Enable,
    			Value: config.EnableOff,
    		},
    		config.KV{
    			Key:   target.AmqpURL,
    			Value: "",
    		},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 46.4K bytes
    - Viewed (0)
Back to top