- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 277 for mkchan (0.05 sec)
-
cmd/signals.go
- "strings"
- "time"
- "github.com/coreos/go-systemd/v22/daemon"
- "github.com/minio/minio/internal/logger"
- )
- func shutdownHealMRFWithTimeout() {
- const shutdownTimeout = time.Minute
- finished := make(chan struct{})
- go func() {
- globalMRFState.shutdown()
- close(finished)
- }()
- select {
- case <-time.After(shutdownTimeout):
- case <-finished:
- }
- }
- func handleSignals() {
- // Custom exit function
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 04 17:02:39 UTC 2024 - 3.2K bytes - Viewed (0) -
cmd/perf-tests.go
- defer n.Unlock()
- n.RX = 0
- n.RXSample = 0
- n.lastToConnect = time.Time{}
- n.firstToDisconnect = time.Time{}
- }
- // Reader to read random data.
- type netperfReader struct {
- n uint64
- eof chan struct{}
- buf []byte
- }
- func (m *netperfReader) Read(b []byte) (int, error) {
- select {
- case <-m.eof:
- return 0, io.EOF
- default:
- }
- n := copy(b, m.buf)
- atomic.AddUint64(&m.n, uint64(n))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.8K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ForwardingImmutableCollection.java
- import org.checkerframework.checker.nullness.qual.Nullable;
- /**
- * A GWT-only class only used by GWT emulations. It is used to consolidate the definitions of method
- * delegation to save code size.
- *
- * @author Hayward Chan
- */
- // TODO: Make this class GWT serializable.
- @ElementTypesAreNonnullByDefault
- class ForwardingImmutableCollection<E> extends ImmutableCollection<E> {
- final transient Collection<E> delegate;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jan 23 18:43:40 UTC 2024 - 1.9K bytes - Viewed (0) -
cmd/naughty-disk_test.go
- return d.disk.GetDiskID()
- }
- func (d *naughtyDisk) SetDiskID(id string) {
- d.disk.SetDiskID(id)
- }
- func (d *naughtyDisk) NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, weSleep func() bool) (info dataUsageCache, err error) {
- if err := d.calcError(); err != nil {
- return info, err
- }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 10.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/ForwardingCollectionTest.java
- import junit.framework.Test;
- import junit.framework.TestCase;
- import junit.framework.TestSuite;
- /**
- * Tests for {@link ForwardingCollection}.
- *
- * @author Robert Konigsberg
- * @author Hayward Chan
- * @author Louis Wasserman
- */
- public class ForwardingCollectionTest extends TestCase {
- static final class StandardImplForwardingCollection<T> extends ForwardingCollection<T> {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 4.7K bytes - Viewed (0) -
docs/de/docs/tutorial/response-model.md
- Hierbei können Sie **Typannotationen** genauso verwenden, wie Sie es bei Werten von Funktions-**Parametern** machen; verwenden Sie Pydantic-Modelle, Listen, Dicts und skalare Werte wie Nummern, Booleans, usw.
- //// tab | Python 3.10+
- ```Python hl_lines="16 21"
- {!> ../../docs_src/response_model/tutorial001_01_py310.py!}
- ```
- ////
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 19.8K bytes - Viewed (0) -
internal/event/target/kafka.go
- client sarama.Client
- producer sarama.SyncProducer
- config *sarama.Config
- store store.Store[event.Event]
- batch *store.Batch[event.Event]
- loggerOnce logger.LogOnce
- quitCh chan struct{}
- }
- // ID - returns target ID.
- func (target *KafkaTarget) ID() event.TargetID {
- return target.id
- }
- // Name - returns the Name of the target.
- func (target *KafkaTarget) Name() string {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.6K bytes - Viewed (0) -
docs/de/docs/advanced/path-operation-advanced-configuration.md
- Das könnte man mit `openapi_extra` machen:
- ```Python hl_lines="20-37 39-40"
- {!../../docs_src/path_operation_advanced_configuration/tutorial006.py!}
- ```
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 8.5K bytes - Viewed (0) -
cmd/storage-interface.go
- // has never been replaced.
- Healing() *healingTracker
- DiskInfo(ctx context.Context, opts DiskInfoOptions) (info DiskInfo, err error)
- NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, shouldSleep func() bool) (dataUsageCache, error)
- // Volume operations.
- MakeVol(ctx context.Context, volume string) (err error)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 5.2K bytes - Viewed (0) -
docs/es/docs/index.md
- * Seguridad y autenticación incluyendo soporte para **OAuth2** con **JWT tokens** y **HTTP Basic** auth.
- * Técnicas más avanzadas, pero igual de fáciles, para declarar **modelos de JSON profundamente anidados** (gracias a Pydantic).
- * Muchas características extra (gracias a Starlette) como:
- * **WebSockets**
- * **GraphQL**
- * pruebas extremadamente fáciles con HTTPX y `pytest`
- * **CORS**
- * **Cookie Sessions**
- * ...y mucho más.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 20 19:20:23 UTC 2024 - 19K bytes - Viewed (0)