Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 131 - 140 of 147 for Del (0.01 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. docs/es/docs/tutorial/path-params-numeric-validations.md

    {* ../../docs_src/path_params_numeric_validations/tutorial001_an_py310.py hl[10] *}
    
    /// note | Nota
    
    Un parámetro de path siempre es requerido ya que tiene que formar parte del path. Incluso si lo declaras con `None` o le asignas un valor por defecto, no afectará en nada, siempre será requerido.
    
    ///
    
    ## Ordena los parámetros como necesites { #order-the-parameters-as-you-need }
    
    /// tip | Consejo
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 6.4K bytes
    - Click Count (0)
  2. docs/es/docs/tutorial/metadata.md

    nombre de la licencia utilizada para la API.</td></tr><tr><td><code>identifier</code></td><td><code>str</code></td><td>Una expresión de licencia [SPDX](https://spdx.org/licenses/) para la API. El campo <code>identifier</code> es mutuamente excluyente del campo <code>url</code>. <small>Disponible desde OpenAPI 3.1.0, FastAPI 0.99.0.</small></td></tr><tr><td><code>url</code></td><td><code>str</code></td><td>Una URL a la licencia utilizada para la API. DEBE tener el formato de una URL.</td></tr></tbod...
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 6.3K bytes
    - Click Count (0)
  3. internal/event/target/mqtt.go

    		if os.IsNotExist(err) {
    			return nil
    		}
    		return err
    	}
    
    	if err = target.send(eventData); err != nil {
    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Save - saves the events to the store if queuestore is configured, which will
    // be replayed when the mqtt connection is active.
    func (target *MQTTTarget) Save(eventData event.Event) error {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 8.2K bytes
    - Click Count (0)
  4. internal/event/target/kafka.go

    		}
    		err = target.sendMultiple(events)
    	}
    	if err != nil {
    		if isKafkaConnErr(err) {
    			return store.ErrNotConnected
    		}
    		return err
    	}
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    func (target *KafkaTarget) toProducerMessage(eventData event.Event) (*sarama.ProducerMessage, error) {
    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    	if err != nil {
    		return nil, err
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 13.6K bytes
    - Click Count (0)
  5. internal/event/target/redis.go

    	}
    
    	if err := target.send(eventData); err != nil {
    		if xnet.IsConnRefusedErr(err) {
    			return store.ErrNotConnected
    		}
    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Close - releases the resources used by the pool.
    func (target *RedisTarget) Close() error {
    	close(target.quitCh)
    	if target.pool != nil {
    		return target.pool.Close()
    	}
    	return nil
    }
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  6. internal/event/target/postgresql.go

    	}
    
    	if err := target.send(eventData); err != nil {
    		if IsConnErr(err) {
    			return store.ErrNotConnected
    		}
    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Close - closes underneath connections to PostgreSQL database.
    func (target *PostgreSQLTarget) Close() error {
    	close(target.quitCh)
    	if target.updateStmt != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  7. internal/event/target/amqp.go

    			return nil
    		}
    		return eErr
    	}
    
    	if err := target.send(eventData, ch, confirms); err != nil {
    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Close - does nothing and available for interface compatibility.
    func (target *AMQPTarget) Close() error {
    	close(target.quitCh)
    	if target.conn != nil {
    		return target.conn.Close()
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 21 04:25:07 GMT 2025
    - 10K bytes
    - Click Count (0)
  8. internal/event/target/mysql.go

    	}
    
    	if err := target.send(eventData); err != nil {
    		if IsConnErr(err) {
    			return store.ErrNotConnected
    		}
    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Close - closes underneath connections to MySQL database.
    func (target *MySQLTarget) Close() error {
    	close(target.quitCh)
    	if target.updateStmt != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  9. internal/logger/target/kafka/kafka.go

    		return err
    	}
    	atomic.AddInt64(&h.totalMessages, 1)
    	err = h.send(auditEntry)
    	if err != nil {
    		atomic.AddInt64(&h.failedMessages, 1)
    		return err
    	}
    	// Delete the event from store.
    	return h.store.Del(key)
    }
    
    // Cancel - cancels the target
    func (h *Target) Cancel() {
    	// If queuestore is configured, cancel it's context to
    	// stop the replay go-routine.
    	if h.store != nil {
    		h.storeCtxCancel()
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  10. cmd/signature-v2.go

    	if !compareSignatureV2(gotSignature, expectedSignature) {
    		return ErrSignatureDoesNotMatch
    	}
    
    	r.Form.Del(xhttp.Expires)
    
    	return ErrNone
    }
    
    func getReqAccessKeyV2(r *http.Request) (auth.Credentials, bool, APIErrorCode) {
    	if accessKey := r.Form.Get(xhttp.AmzAccessKeyID); accessKey != "" {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.2K bytes
    - Click Count (0)
Back to Top