- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for AMQP (2.16 sec)
-
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) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Fri Jan 05 18:43:06 GMT 2024 - 6.8K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 8.8K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 3.9K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 3.9K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2.8K bytes - Viewed (0) -
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) -
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) -
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) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Wed Oct 18 18:05:24 GMT 2023 - 5.4K bytes - Viewed (0)