- Sort Score
- Num 10 results
- Language All
Results 181 - 190 of 261 for chain (0.03 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
guava-testlib/src/com/google/common/collect/testing/google/ListGenerators.java
import com.google.common.primitives.Chars; import java.util.Collections; import java.util.List; import org.jspecify.annotations.NullMarked; /** * Common generators of different types of lists. * * @author Hayward Chan */ @GwtCompatible @NullMarked public final class ListGenerators { private ListGenerators() {} public static class ImmutableListOfGenerator extends TestStringListGenerator { @OverrideCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 20:54:16 GMT 2025 - 5K bytes - Click Count (0) -
internal/s3select/jstream/decoder.go
// JSON values type Decoder struct { *scanner emitDepth int maxDepth int emitKV bool emitRecursive bool objectAsKVS bool depth int scratch *scratch metaCh chan *MetaValue err error // follow line position to add context to errors lineNo int lineStart int64 } // NewDecoder creates new Decoder to read JSON values at the providedCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 13.4K bytes - Click Count (0) -
internal/event/target/postgresql.go
updateStmt *sql.Stmt deleteStmt *sql.Stmt insertStmt *sql.Stmt db *sql.DB store store.Store[event.Event] firstPing bool connString string loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *PostgreSQLTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 13.3K bytes - Click Count (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ForwardingImmutableMap.java
import java.util.Collections; import java.util.Map; import java.util.Set; import org.jspecify.annotations.Nullable; /** * GWT implementation of {@link ImmutableMap} that forwards to another map. * * @author Hayward Chan */ public abstract class ForwardingImmutableMap<K, V> extends ImmutableMap<K, V> { final transient Map<K, V> delegate; ForwardingImmutableMap(Map<? extends K, ? extends V> delegate) {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Aug 06 18:32:41 GMT 2025 - 4K bytes - Click Count (0) -
internal/event/targetlist.go
currentSendCalls atomic.Int64 totalEvents atomic.Int64 eventsSkipped atomic.Int64 eventsErrorsTotal atomic.Int64 sync.RWMutex targets map[TargetID]Target queue chan asyncEvent ctx context.Context statLock sync.RWMutex targetStats map[TargetID]targetStat } type targetStat struct { // The number of concurrent async Send calls per targets currentSendCalls int64
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 9.2K bytes - Click Count (0) -
internal/lru/lru.go
type LRU[K comparable, V any] struct { size int evictList *LruList[K, V] items map[K]*Entry[K, V] onEvict EvictCallback[K, V] // expirable options mu sync.Mutex ttl time.Duration done chan struct{} // buckets for expiration buckets []bucket[K, V] // uint8 because it's number between 0 and numBuckets nextCleanupBucket uint8 } // bucket is a container for holding entries to be expired
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Fri Apr 25 08:22:26 GMT 2025 - 12.5K bytes - Click Count (0) -
internal/event/target/mysql.go
args MySQLArgs updateStmt *sql.Stmt deleteStmt *sql.Stmt insertStmt *sql.Stmt db *sql.DB store store.Store[event.Event] firstPing bool loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *MySQLTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target. func (target *MySQLTarget) Name() string {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 11.6K bytes - Click Count (0) -
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)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Sep 03 18:23:41 GMT 2024 - 16.2K bytes - Click Count (1) -
cmd/callhome.go
internalLogIf(ctx, errors.New("Callhome: object layer not ready")) return } healthCtx, healthCancel := context.WithTimeout(ctx, deadline) defer healthCancel() healthInfoCh := make(chan madmin.HealthInfo) query := url.Values{} for _, k := range madmin.HealthDataTypesList { query.Set(string(k), "true") } healthInfo := madmin.HealthInfo{ TimeStamp: time.Now().UTC(),
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.3K bytes - Click Count (0) -
internal/s3select/json/reader.go
const maxDocumentSize = 10 << 20 // Reader - JSON record reader for S3Select. type Reader struct { args *ReaderArgs decoder *jstream.Decoder valueCh chan *jstream.MetaValue readCloser io.ReadCloser } // Read - reads single record. func (r *Reader) Read(dst sql.Record) (sql.Record, error) { v, ok := <-r.valueCh if !ok { if err := r.decoder.Err(); err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 3.2K bytes - Click Count (0)