- Sort Score
- Num 10 results
- Language All
Results 51 - 60 of 381 for Sending (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
docs/en/docs/tutorial/handling-errors.md
You could use it while developing your app to log the body and debug it, return it to the user, etc. {* ../../docs_src/handling_errors/tutorial005_py310.py hl[14] *} Now try sending an invalid item like: ```JSON { "title": "towel", "size": "XL" } ``` You will receive a response telling you that the data is invalid containing the received body:Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 8.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/IndexingHelper.java
import org.opensearch.index.query.QueryBuilder; import org.opensearch.index.query.QueryBuilders; /** * Helper class for indexing operations in the Fess search engine. * This class provides functionality for sending documents to the search engine, * managing document lifecycle operations (create, update, delete), and handling * thumbnail processing during indexing. *
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 26.1K bytes - Click Count (0) -
cmd/metacache-walk.go
if !skipAccessChecks(opts.Bucket) { // Stat a volume entry. if err = Access(volumeDir); err != nil { return convertAccessError(err, errVolumeAccessDenied) } } // Use a small block size to start sending quickly w := newMetacacheWriter(wr, 16<<10) w.reuseBlocks = true // We are not sharing results, so reuse buffers. defer w.Close() out, err := w.stream() if err != nil { return err }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon May 26 07:06:43 GMT 2025 - 12.6K bytes - Click Count (0) -
internal/event/targetlist.go
// any for the associated TargetID type TargetIDResult struct { // ID where the remove or send were initiated. ID TargetID // Stores any error while removing a target or while sending an event. Err error } // Remove - closes and removes targets by given target IDs. func (list *TargetList) Remove(targetIDSet TargetIDSet) { list.Lock() defer list.Unlock()Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 9.2K bytes - Click Count (0) -
internal/logger/logger.go
if len(systemTgts) == 0 { return } // Iterate over all logger targets to send the log entry for _, t := range systemTgts { if err := t.Send(ctx, entry); err != nil { if consoleTgt != nil { // Sending to the console never fails consoleTgt.Send(ctx, errToEntry(ctx, "logging", fmt.Errorf("unable to send log event to Logger target (%s): %v", t.String(), err), entry.Level)) } } } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12.4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheStrategy.kt
return receivedAge + responseDuration + residentDuration } /** * Returns true if the request contains conditions that save the server from sending a response * that the client has locally. When a request is enqueued with its own conditions, the built-in * response cache won't be used. */ private fun hasConditions(request: Request): Boolean =Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 12.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
/** * Returns a request that creates a TLS tunnel via an HTTP proxy. Everything in the tunnel request * is sent unencrypted to the proxy server, so tunnels include only the minimum set of headers. * This avoids sending potentially sensitive data like HTTP cookies to the proxy unencrypted. * * In order to support preemptive authentication we pass a fake "Auth Failed" response to the
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 12.1K bytes - Click Count (0) -
internal/s3select/message.go
// in Finish() quitFlag := false for !quitFlag { select { case data := <-writer.errCh: quitFlag = true // Flush collected records before sending error message if !writer.flushRecords() { break } writer.write(data) case payload, ok := <-writer.payloadCh: if !ok { // payloadCh is closed by caller to
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 15.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/general/AdminGeneralAction.java
}); } /** * Sends a test mail using the provided notification settings. * * @param form the mail form containing notification settings * @return HTML response after sending test mail */ @Execute @Secured({ ROLE }) public HtmlResponse sendmail(final MailForm form) { validate(form, messages -> {}, () -> asHtml(path_AdminGeneral_AdminGeneralJsp));Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 05:54:31 GMT 2026 - 27.2K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/job/PingSearchEngineJobTest.java
// Execute String result = pingSearchEngineJob.execute(); // Assert assertEquals("Status of test-cluster is changed to RED.", result); // Note: Notification sending is tested but we don't verify the mock since it uses complex callback mechanism } // Test state change with empty notification addresses @TestCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 18.9K bytes - Click Count (0)