Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 236 for seni (0.06 sec)

  1. internal/event/target/mqtt.go

    		return err
    	}
    
    	// Do not send if the connection is not active.
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    
    	eventData, err := target.store.Get(key)
    	if err != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(err) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  2. docs/tr/docs/features.md

    ![ReDoc](https://fastapi.tiangolo.com/img/index/index-06-redoc-02.png)
    
    ### Sadece modern Python
    
    Tamamiyle standartlar **Python 3.8**'nın type hintlerine dayanıyor (Pydantic'in sayesinde). Yeni bir syntax öğrenmene gerek yok. Sadece modern Python.
    
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. internal/event/target/nsq.go

    	}
    
    	if err := target.init(); err != nil {
    		return err
    	}
    
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    	return target.send(eventData)
    }
    
    // send - sends an event to the NSQ.
    func (target *NSQTarget) send(eventData event.Event) error {
    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    	if err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  4. internal/logger/target/http/http.go

    			// Even if there is nothing in the queue.
    			if h.batchSize > 1 && time.Since(lastBatchProcess) < time.Second {
    				continue
    			}
    		}
    
    		// if we have reached the count send at once
    		// or we have crossed last second before batch was sent, send at once
    		lastBatchProcess = time.Now()
    
    		var retries int
    		retryIntvl := h.config.RetryIntvl
    		if retryIntvl <= 0 {
    			retryIntvl = 3 * time.Second
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  5. internal/event/target/webhook.go

    		return err
    	}
    	if err := target.init(); err != nil {
    		return err
    	}
    	err := target.send(eventData)
    	if err != nil {
    		if xnet.IsNetworkOrHostDown(err, false) {
    			return store.ErrNotConnected
    		}
    	}
    	return err
    }
    
    // send - sends an event to the webhook.
    func (target *WebhookTarget) send(eventData event.Event) error {
    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  6. internal/event/target/mysql.go

    	}
    	if err := target.init(); err != nil {
    		return err
    	}
    
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    	return target.send(eventData)
    }
    
    // send - sends an event to the mysql.
    func (target *MySQLTarget) send(eventData event.Event) error {
    	if target.args.Format == event.NamespaceFormat {
    		objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  7. fastapi/security/oauth2.py

                ),
            ] = "",
            client_id: Annotated[
                Union[str, None],
                Form(),
                Doc(
                    """
                    If there's a `client_id`, it can be sent as part of the form fields.
                    But the OAuth2 specification recommends sending the `client_id` and
                    `client_secret` (if any) using HTTP Basic auth.
                    """
                ),
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Oct 23 18:30:18 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  8. internal/event/target/nats.go

    	}
    
    	if err := target.init(); err != nil {
    		return err
    	}
    
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    	return target.send(eventData)
    }
    
    // send - sends an event to the Nats.
    func (target *NATSTarget) send(eventData event.Event) error {
    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    	if err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  9. internal/event/target/kafka.go

    		}
    		_, err := target.store.Put(eventData)
    		return err
    	}
    	if err := target.init(); err != nil {
    		return err
    	}
    	return target.send(eventData)
    }
    
    // send - sends an event to the kafka.
    func (target *KafkaTarget) send(eventData event.Event) error {
    	if target.producer == nil {
    		return store.ErrNotConnected
    	}
    	msg, err := target.toProducerMessage(eventData)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  10. docs/en/docs/tutorial/cookie-param-models.md

    ```
    
    ////
    
    If a client tries to send some **extra cookies**, they will receive an **error** response.
    
    Poor cookie banners with all their effort to get your consent for the <abbr title="This is another joke. Don't pay attention to me. Have some coffee for your cookie. ☕">API to reject it</abbr>. 🍪
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 4K bytes
    - Viewed (0)
Back to top