Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 205 for seni (0.03 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. 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)
  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. 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)
  6. 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)
  7. internal/event/target/postgresql.go

    		return err
    	}
    	return target.send(eventData)
    }
    
    // IsConnErr - To detect a connection error.
    func IsConnErr(err error) bool {
    	return xnet.IsConnRefusedErr(err) || err.Error() == "sql: database is closed" || err.Error() == "sql: statement is closed" || err.Error() == "invalid connection"
    }
    
    // send - sends an event to the PostgreSQL.
    func (target *PostgreSQLTarget) send(eventData event.Event) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. internal/event/target/redis.go

    		return err
    	}
    	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 redis.
    func (target *RedisTarget) send(eventData event.Event) error {
    	conn := target.pool.Get()
    	defer conn.Close()
    
    	if target.args.Format == event.NamespaceFormat {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top