- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 578 for Chan (0.14 sec)
-
cmd/globals.go
globalIsTLS bool globalTLSCerts *certs.Manager globalHTTPServer *xhttp.Server globalTCPOptions xhttp.TCPOptions globalHTTPServerErrorCh = make(chan error) globalOSSignalCh = make(chan os.Signal, 1) // global Trace system to send HTTP request/response // and Storage/OS calls info to registered listeners. globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 16.5K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
type ElasticsearchTarget struct { initOnce once.Init id event.TargetID args ElasticsearchArgs client esClient store store.Store[event.Event] loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *ElasticsearchTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
cmd/admin-heal-ops.go
settings madmin.HealOpts // current accumulated status of the heal sequence currentStatus healSequenceStatus // channel signaled by background routine when traversal has // completed traverseAndHealDoneCh chan error // canceler to cancel heal sequence. cancelCtx context.CancelFunc // the last result index sent to client lastSentResultIndex int64 // Number of total items scanned against item type
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/metrics-v3-types.go
} // Describe - implements prometheus.Collector interface. func (mg *MetricsGroup) Describe(ch chan<- *prometheus.Desc) { for _, desc := range mg.Descriptors { ch <- desc.toPromDesc(mg.CollectorPath.metricPrefix(), mg.ExtraLabels) } } // Collect - implements prometheus.Collector interface. func (mg *MetricsGroup) Collect(ch chan<- prometheus.Metric) { metricValues := newMetricValues(mg.descriptorMap) var err error
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 14.6K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
rng.Shuffle(len(vers), func(i, j int) { vers[i], vers[j] = vers[j], vers[i] }) var entries []chan metaCacheEntry for _, v := range vers { v.cached = nil ch := make(chan metaCacheEntry, 1) ch <- v close(ch) entries = append(entries, ch) } out := make(chan metaCacheEntry, 1) err := mergeEntryChannels(context.Background(), entries, out, 1) if err != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 36.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ForwardingMultisetTest.java
import junit.framework.TestCase; import junit.framework.TestSuite; import org.checkerframework.checker.nullness.qual.Nullable; /** * Tests for {@link ForwardingMultiset}. * * @author Hayward Chan * @author Louis Wasserman */ public class ForwardingMultisetTest extends TestCase { static final class StandardImplForwardingMultiset<T> extends ForwardingMultiset<T> { private final Multiset<T> backingCollection;
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Apr 17 15:49:06 GMT 2023 - 11.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/ForwardingMultisetTest.java
import junit.framework.TestCase; import junit.framework.TestSuite; import org.checkerframework.checker.nullness.qual.Nullable; /** * Tests for {@link ForwardingMultiset}. * * @author Hayward Chan * @author Louis Wasserman */ public class ForwardingMultisetTest extends TestCase { static final class StandardImplForwardingMultiset<T> extends ForwardingMultiset<T> { private final Multiset<T> backingCollection;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 17 15:49:06 GMT 2023 - 11.8K bytes - Viewed (0) -
internal/event/target/kafka.go
producer sarama.SyncProducer config *sarama.Config store store.Store[event.Event] batch *store.Batch[string, *sarama.ProducerMessage] 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 {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
internal/event/target/nats.go
id event.TargetID args NATSArgs natsConn *nats.Conn stanConn stan.Conn jstream nats.JetStream store store.Store[event.Event] loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *NATSTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target. func (target *NATSTarget) Name() string {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/google/SetGenerators.java
import java.util.Set; import java.util.SortedSet; /** * Generators of different types of sets and derived collections from sets. * * @author Kevin Bourrillion * @author Jared Levy * @author Hayward Chan */ @GwtCompatible(emulated = true) @ElementTypesAreNonnullByDefault public class SetGenerators { public static class ImmutableSetCopyOfGenerator extends TestStringSetGenerator { @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Feb 21 16:49:06 GMT 2024 - 15.5K bytes - Viewed (0)