- Sort Score
- Num 10 results
- Language All
Results 151 - 160 of 198 for channel1 (0.35 seconds)
-
internal/event/target/elasticsearch.go
err := target.checkAndInitClient(ctx) 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 }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 15K bytes - Click Count (0) -
src/cmd/cgo/doc.go
(which implies that it may not return a string, slice, channel, and so forth). A Go function called by C code may take C pointers as arguments, and it may store non-pointer data, C pointers, or Go pointers to pinned memory through those pointers. It may not store a Go pointer to unpinned memory in memory pointed to by a C pointer (which again, implies that it may not store a string, slice, channel, and so forth). A Go function
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Dec 08 22:37:14 GMT 2025 - 43.9K bytes - Click Count (0) -
docs/ko/docs/deployment/manually.md
다음을 포함해 여러 대안이 있습니다: * [Uvicorn](https://www.uvicorn.dev/): 고성능 ASGI 서버. * [Hypercorn](https://hypercorn.readthedocs.io/): HTTP/2 및 Trio 등 여러 기능과 호환되는 ASGI 서버. * [Daphne](https://github.com/django/daphne): Django Channels를 위해 만들어진 ASGI 서버. * [Granian](https://github.com/emmett-framework/granian): Python 애플리케이션을 위한 Rust HTTP 서버. * [NGINX Unit](https://unit.nginx.org/howto/fastapi/): NGINX Unit은 가볍고 다용도로 사용할 수 있는 웹 애플리케이션 런타임입니다.
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 14:06:26 GMT 2026 - 7.4K bytes - Click Count (0) -
internal/rest/client.go
c.dumpHTTP(req, resp) } if resp.StatusCode != http.StatusOK { // If server returns 412 pre-condition failed, it would // mean that authentication succeeded, but another // side-channel check has failed, we shall take // the client offline in such situations. // generally all implementations should simply return // 403, but in situations where there is a dependency
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 14.7K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/FilesTest.java
import java.io.FileNotFoundException; import java.io.IOException; import java.io.PrintWriter; import java.io.RandomAccessFile; import java.nio.ByteBuffer; import java.nio.MappedByteBuffer; import java.nio.channels.FileChannel.MapMode; import java.util.ArrayList; import java.util.List; import java.util.Random; import junit.framework.TestSuite; import org.jspecify.annotations.NullUnmarked; /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 19 18:53:45 GMT 2026 - 22.8K bytes - Click Count (0) -
cmd/metacache-set.go
return triggerExpiryAndRepl(ctx, *o, entry) } return false } // gatherResults will collect all results on the input channel and filter results according // to the options or to the current bucket ILM expiry rules. // Caller should close the channel when done. // The returned function will return the results once there is enough or input is closed, // or the context is canceled.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 30.7K bytes - Click Count (0) -
cmd/data-usage-cache.go
// should skip healing the disk SkipHealing bool // Active lifecycle, if any on the bucket lifeCycle *lifecycle.Lifecycle `msg:"-"` // optional updates channel. // If set updates will be sent regularly to this channel. // Will not be closed when returned. updates chan<- dataUsageEntry `msg:"-"` replication replicationConfig `msg:"-"` }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.7K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/io/Smb2WriteRequestTest.java
assertArrayEquals(testFileId, Arrays.copyOfRange(buffer, headerStart + 16, headerStart + 32)); // File ID assertEquals(0, SMBUtil.readInt4(buffer, headerStart + 32)); // Channel assertEquals(500, SMBUtil.readInt4(buffer, headerStart + 36)); // Remaining bytes assertEquals(0, SMBUtil.readInt2(buffer, headerStart + 40)); // WriteChannelInfoOffset
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 22.4K bytes - Click Count (0) -
internal/s3select/jstream/decoder.go
// containing those values is emitted. func (d *Decoder) Recursive() *Decoder { d.emitRecursive = true return d } // Stream begins decoding from the underlying reader and returns a // streaming MetaValue channel for JSON values at the configured emitDepth. func (d *Decoder) Stream() chan *MetaValue { go d.decode() return d.metaCh } // Pos returns the number of bytes consumed from the underlying reader
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 13.4K bytes - Click Count (0) -
CONTRIBUTING.md
If you use AI tools when contributing to Gradle, please review our [AI Policy](AI_POLICY.md). ### Additional help If you run into any trouble, please reach out to us on the issue you are working on. There is a `#contributing` channel on the community Slack which you can use to ask any questions. ## Finding issues to work on
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Fri Mar 27 18:43:39 GMT 2026 - 19.1K bytes - Click Count (0)