- Sort Score
- Num 10 results
- Language All
Results 131 - 140 of 382 for sont (0.01 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/storage-errors.go
var errLessData = StorageErr("less data available than what was requested") // errMoreData = returned when more data was sent by the caller than what it was supposed to. var errMoreData = StorageErr("more data was sent than what was advertised") // indicates readDirFn to return without further applying the fn() var errDoneForNow = errors.New("done for now")
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Click Count (0) -
docs/en/docs/_llm-test.md
```bash # Print a greeting to the universe echo "Hello universe" ``` ...and a console code example... ```console $ <font color="#4E9A06">fastapi</font> run <u style="text-decoration-style:solid">main.py</u> <span style="background-color:#009485"><font color="#D3D7CF"> FastAPI </font></span> Starting server Searching for package file structure ``` ...and another console code example... ```console
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Thu Dec 11 14:48:47 GMT 2025 - 11.4K bytes - Click Count (0) -
docs/extensions/fan-out/README.md
method of facilitating time-shifted playback of television signaling, and media content. MinIO implements an S3 extension to the [PostUpload](https://docs.aws.amazon.com/AmazonS3/latest/API/RESTObjectPOST.html) where in a special fan-out list is sent along with the TSB's for MinIO make multiple uploads from a single source stream. Optionally supports custom metadata, tags and other retention settings. All objects are also readable independently once upload is completed via the regular S3 [GetO...
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu May 25 05:51:07 GMT 2023 - 1.4K bytes - Click Count (0) -
cmd/admin-server-info.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "math" "net/http" "os" "runtime" "runtime/debug" "sort" "strings" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/config" "github.com/minio/minio/internal/kms" xnet "github.com/minio/pkg/v3/net" )
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 4.9K bytes - Click Count (1) -
internal/s3select/genmessage.go
// ==================== // Header specification // -------------------- // Continuation messages contain two headers, as follows: // https://docs.aws.amazon.com/AmazonS3/latest/API/images/s3select-frame-diagram-cont.png // // Payload specification // --------------------- // Continuation messages have no payload. func genContinuationMessage() { buf := new(bytes.Buffer) buf.WriteByte(13) buf.WriteString(":message-type")
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 4.4K bytes - Click Count (0) -
internal/event/target/nsq.go
if err != nil { return err } eventData, eErr := target.store.Get(key) if eErr != 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(eErr) { return nil } return eErr } if err := target.send(eventData); err != nil { return err }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7.1K bytes - Click Count (0) -
docs_src/dependencies/tutorial008e_an_py39.py
from typing import Annotated from fastapi import Depends, FastAPI app = FastAPI() def get_username(): try: yield "Rick" finally: print("Cleanup up before response is sent") @app.get("/users/me") def get_user_me(username: Annotated[str, Depends(get_username, scope="function")]):
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Mon Nov 03 10:12:49 GMT 2025 - 329 bytes - Click Count (0) -
cmd/leak-detect_test.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "runtime/debug" "sort" "strings" "time" ) const ( // deadline (in seconds) up to which the go routine leak detection has to be retried. leakDetectDeadline = 5
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.2K bytes - Click Count (0) -
cmd/metrics-v3-audit.go
targetID) auditTargetQueueLengthMD = NewGaugeMD(auditTargetQueueLength, "Number of unsent messages in queue for target", targetID) auditTotalMessagesMD = NewCounterMD(auditTotalMessages, "Total number of messages sent since start", targetID) ) // loadAuditMetrics - `MetricsLoaderFn` for audit // such as failed messages and total messages. func loadAuditMetrics(_ context.Context, m MetricValues, c *metricsCache) error {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 10 14:50:39 GMT 2024 - 1.9K bytes - Click Count (0) -
src/bufio/net_test.go
if err != nil { t.Skipf("skipping test because opening a unixpacket socket failed: %v", err) } // Start a goroutine for the server to accept one connection // and read all the data sent on the connection, // reporting the number of bytes read on ch. ch := make(chan int, 1) var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() tot := 0 defer func() { ch <- tot }()Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Feb 07 19:37:07 GMT 2025 - 1.9K bytes - Click Count (0)