- Sort Score
- Num 10 results
- Language All
Results 131 - 140 of 147 for Del (0.01 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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 | ConsejoCreated: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 6.4K bytes - Click Count (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)