Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 90 for amqp (0.04 sec)

  1. internal/event/target/amqp.go

    		return err
    	}
    	target.conn = conn
    
    	return nil
    }
    
    // NewAMQPTarget - creates new AMQP target.
    func NewAMQPTarget(id string, args AMQPArgs, loggerOnce logger.LogOnce) (*AMQPTarget, error) {
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-amqp-"+id)
    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  2. 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,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  3. 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: "",
    		},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  4. 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,
    		},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
  5. compat/maven-model-builder/src/test/resources/dag.txt

    	quarkus/test-framework/security/pom.xml
    	quarkus/extensions/oidc/runtime/pom.xml
    quarkus/extensions/smallrye-reactive-messaging-amqp/deployment/pom.xml
    	quarkus/core/deployment/pom.xml
    	quarkus/extensions/smallrye-reactive-messaging/deployment/pom.xml
    	quarkus/extensions/smallrye-reactive-messaging-amqp/runtime/pom.xml
    	quarkus/extensions/reactive-streams-operators/mutiny-reactive-streams-operators/deployment/pom.xml
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 224K bytes
    - Viewed (0)
  6. docs/em/docs/tutorial/response-model.md

    ...โœ‹๏ธ ๐Ÿ˜ฃ ๐Ÿ‘‚ ๐Ÿ”› ๐Ÿ‘€ โ” โŽ ๐Ÿ‘ˆ.
    
    ## ๐Ÿ“จ ๐Ÿ†Ž & ๐Ÿ’ฝ ๐Ÿ–ฅ
    
    โžก๏ธ ๐Ÿ˜ฃ โšช๏ธโžก๏ธ โฎ๏ธ ๐Ÿ–ผ. ๐Ÿ‘ฅ ๐Ÿ’š **โœ ๐Ÿ”ข โฎ๏ธ 1๏ธโƒฃ ๐Ÿ†Ž** โœ‹๏ธ ๐Ÿ“จ ๐Ÿ•ณ ๐Ÿ‘ˆ ๐Ÿ”Œ **๐ŸŒ… ๐Ÿ’ฝ**.
    
    ๐Ÿ‘ฅ ๐Ÿ’š FastAPI ๐Ÿšง **๐Ÿ–ฅ** ๐Ÿ“Š โš™๏ธ ๐Ÿ“จ ๐Ÿท.
    
    โฎ๏ธ ๐Ÿ–ผ, โ†ฉ๏ธ ๐ŸŽ“ ๐ŸŽ, ๐Ÿ‘ฅ โœ”๏ธ โš™๏ธ `response_model` ๐Ÿ”ข. โœ‹๏ธ ๐Ÿ‘ˆ โ›“ ๐Ÿ‘ˆ ๐Ÿ‘ฅ ๐Ÿšซ ๐Ÿคš ๐Ÿ•โ€๐Ÿฆบ โšช๏ธโžก๏ธ ๐Ÿ‘จโ€๐ŸŽจ & ๐Ÿงฐ โœ… ๐Ÿ”ข ๐Ÿ“จ ๐Ÿ†Ž.
    
    โœ‹๏ธ ๐ŸŒ… ๐Ÿ’ผ ๐ŸŒโ” ๐Ÿ‘ฅ ๐Ÿ’ช ๐Ÿ•ณ ๐Ÿ’– ๐Ÿ‘‰, ๐Ÿ‘ฅ ๐Ÿ’š ๐Ÿท **โ›ฝ/โŽ** ๐Ÿ“Š ๐Ÿ‘‰ ๐Ÿ–ผ.
    
    & ๐Ÿ‘ˆ ๐Ÿ’ผ, ๐Ÿ‘ฅ ๐Ÿ’ช โš™๏ธ ๐ŸŽ“ & ๐Ÿงฌ โœŠ ๐Ÿ“ˆ ๐Ÿ”ข **๐Ÿ†Ž โœ** ๐Ÿคš ๐Ÿ‘ ๐Ÿ•โ€๐Ÿฆบ ๐Ÿ‘จโ€๐ŸŽจ & ๐Ÿงฐ, & ๐Ÿคš FastAPI **๐Ÿ’ฝ ๐Ÿ–ฅ**.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  7. docs/em/docs/tutorial/body-multiple-params.md

    ๐Ÿ”œ ๐Ÿ‘ˆ ๐Ÿ‘ฅ โœ”๏ธ ๐Ÿ‘€ โ” โš™๏ธ `Path` & `Query`, โžก๏ธ ๐Ÿ‘€ ๐ŸŒ… ๐Ÿง โš™๏ธ ๐Ÿ“จ ๐Ÿ’ช ๐Ÿ“„.
    
    ## ๐ŸŒ€ `Path`, `Query` & ๐Ÿ’ช ๐Ÿ”ข
    
    ๐Ÿฅ‡, โ†—๏ธ, ๐Ÿ‘† ๐Ÿ’ช ๐ŸŒ€ `Path`, `Query` & ๐Ÿ“จ ๐Ÿ’ช ๐Ÿ”ข ๐Ÿ“„ โžก & **FastAPI** ๐Ÿ”œ ๐Ÿ’ญ โšซ๏ธโ”.
    
    & ๐Ÿ‘† ๐Ÿ’ช ๐Ÿ“ฃ ๐Ÿ’ช ๐Ÿ”ข ๐Ÿ“ฆ, โš’ ๐Ÿ”ข `None`:
    
    //// tab | ๐Ÿ 3๏ธโƒฃ.6๏ธโƒฃ & ๐Ÿ”›
    
    ```Python hl_lines="19-21"
    {!> ../../docs_src/body_multiple_params/tutorial001.py!}
    ```
    
    ////
    
    //// tab | ๐Ÿ 3๏ธโƒฃ.1๏ธโƒฃ0๏ธโƒฃ & ๐Ÿ”›
    
    ```Python hl_lines="17-19"
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 5K bytes
    - Viewed (0)
  8. docs/em/docs/tutorial/security/get-current-user.md

    ๐Ÿ‘‰ ๐Ÿ–ผ 5๏ธโƒฃ๐Ÿ“† ๐Ÿ˜‘ ๐Ÿ”. โœ”๏ธ ๐Ÿคฏ ๐Ÿ‘ˆ ๐Ÿ‘ฅ ๐ŸŒ€ ๐Ÿ’‚โ€โ™‚, ๐Ÿ“Š ๐Ÿท, ๐Ÿš™ ๐Ÿ”ข & *โžก ๐Ÿ› ๏ธ* ๐ŸŽ ๐Ÿ“.
    
    โœ‹๏ธ ๐Ÿ“ฅ ๐Ÿ”‘ โ˜.
    
    ๐Ÿ’‚โ€โ™‚ & ๐Ÿ”— ๐Ÿ’‰ ๐Ÿ’ฉ โœ ๐Ÿ•.
    
    & ๐Ÿ‘† ๐Ÿ’ช โš’ โšซ๏ธ ๐Ÿ— ๐Ÿ‘† ๐Ÿ’š. & , โœ”๏ธ โšซ๏ธ โœ ๐Ÿ•ด ๐Ÿ•, ๐Ÿ‘ ๐Ÿฅ‰. โฎ๏ธ ๐ŸŒ ๐Ÿ’ช.
    
    โœ‹๏ธ ๐Ÿ‘† ๐Ÿ’ช โœ”๏ธ ๐Ÿ’ฏ ๐Ÿ”— (*โžก ๐Ÿ› ๏ธ*) โš™๏ธ ๐ŸŽ ๐Ÿ’‚โ€โ™‚ โš™๏ธ.
    
    & ๐ŸŒ ๐Ÿ‘ซ (โš–๏ธ ๐Ÿ™† โ†” ๐Ÿ‘ซ ๐Ÿ‘ˆ ๐Ÿ‘† ๐Ÿ’š) ๐Ÿ’ช โœŠ ๐Ÿ“ˆ ๐Ÿค-โš™๏ธ ๐Ÿ‘ซ ๐Ÿ”— โš–๏ธ ๐Ÿ™† ๐ŸŽ ๐Ÿ”— ๐Ÿ‘† โœ.
    
    & ๐ŸŒ ๐Ÿ‘‰ ๐Ÿ’ฏ *โžก ๐Ÿ› ๏ธ* ๐Ÿ’ช ๐Ÿคช 3๏ธโƒฃ โธ:
    
    //// tab | ๐Ÿ 3๏ธโƒฃ.6๏ธโƒฃ & ๐Ÿ”›
    
    ```Python hl_lines="30-32"
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  9. docs/em/docs/advanced/response-headers.md

    ๐Ÿ‘† ๐Ÿ’ช ๐Ÿ“ฃ ๐Ÿ”ข ๐Ÿ†Ž `Response` ๐Ÿ‘† *โžก ๐Ÿ› ๏ธ ๐Ÿ”ข* (๐Ÿ‘† ๐Ÿ’ช ๐Ÿช).
    
    & โคด๏ธ ๐Ÿ‘† ๐Ÿ’ช โš’ ๐ŸŽš ๐Ÿ‘ˆ *๐Ÿ”€* ๐Ÿ“จ ๐ŸŽš.
    
    ```Python hl_lines="1  7-8"
    {!../../docs_src/response_headers/tutorial002.py!}
    ```
    
    & โคด๏ธ ๐Ÿ‘† ๐Ÿ’ช ๐Ÿ“จ ๐Ÿ™† ๐ŸŽš ๐Ÿ‘† ๐Ÿ’ช, ๐Ÿ‘† ๐Ÿ›Ž ๐Ÿ”œ ( `dict`, ๐Ÿ’ฝ ๐Ÿท, โ™’๏ธ).
    
    & ๐Ÿšฅ ๐Ÿ‘† ๐Ÿ“ฃ `response_model`, โšซ๏ธ ๐Ÿ”œ โš™๏ธ โ›ฝ & ๐Ÿ—œ ๐ŸŽš ๐Ÿ‘† ๐Ÿ“จ.
    
    **FastAPI** ๐Ÿ”œ โš™๏ธ ๐Ÿ‘ˆ *๐Ÿ”€* ๐Ÿ“จ โš— ๐ŸŽš (๐Ÿช & ๐Ÿ‘” ๐Ÿ“Ÿ), & ๐Ÿ”œ ๐Ÿšฎ ๐Ÿ‘ซ ๐Ÿ ๐Ÿ“จ ๐Ÿ‘ˆ ๐Ÿ”Œ ๐Ÿ’ฒ ๐Ÿ‘† ๐Ÿ“จ, โ›ฝ ๐Ÿ™† `response_model`.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  10. docs/em/docs/tutorial/security/oauth2-jwt.md

    ///
    
    ##  #๏ธโƒฃ & โœ” ๐Ÿ”
    
    ๐Ÿ—„ ๐Ÿงฐ ๐Ÿ‘ฅ ๐Ÿ’ช โšช๏ธโžก๏ธ `passlib`.
    
    โœ ๐Ÿ‡ธ๐Ÿ‡ฒ "๐Ÿ”‘". ๐Ÿ‘‰ โšซ๏ธโ” ๐Ÿ”œ โš™๏ธ #๏ธโƒฃ & โœ” ๐Ÿ”.
    
    /// tip
    
    ๐Ÿ‡ธ๐Ÿ‡ฒ ๐Ÿ”‘ โœ”๏ธ ๐Ÿ› ๏ธ โš™๏ธ ๐ŸŽ ๐Ÿ” ๐Ÿ“Š, ๐Ÿ”Œ ๐Ÿ˜ข ๐Ÿ— ๐Ÿ• ๐Ÿ•ด โœ” โœ” ๐Ÿ‘ซ, โ™’๏ธ.
    
    ๐Ÿ–ผ, ๐Ÿ‘† ๐Ÿ’ช โš™๏ธ โšซ๏ธ โœ & โœ” ๐Ÿ” ๐Ÿ— โž•1๏ธโƒฃ โš™๏ธ (๐Ÿ’– โœณ) โœ‹๏ธ #๏ธโƒฃ ๐Ÿ™† ๐Ÿ†• ๐Ÿ” โฎ๏ธ ๐ŸŽ ๐Ÿ“Š ๐Ÿ’– ๐Ÿก.
    
     & ๐Ÿ”— โฎ๏ธ ๐ŸŒ ๐Ÿ‘ซ ๐ŸŽ ๐Ÿ•ฐ.
    
    ///
    
    โœ ๐Ÿš™ ๐Ÿ”ข #๏ธโƒฃ ๐Ÿ” ๐Ÿ‘Ÿ โšช๏ธโžก๏ธ ๐Ÿ‘ฉโ€๐Ÿ’ป.
    
    & โž•1๏ธโƒฃ ๐Ÿš™ โœ” ๐Ÿšฅ ๐Ÿ“จ ๐Ÿ” ๐Ÿ #๏ธโƒฃ ๐Ÿช.
    
    & โž•1๏ธโƒฃ 1๏ธโƒฃ ๐Ÿ”“ & ๐Ÿ“จ ๐Ÿ‘ฉโ€๐Ÿ’ป.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 9.5K bytes
    - Viewed (0)
Back to top