- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 580 for Shan (0.14 sec)
-
cmd/metacache-set.go
// The returned function will return the results once there is enough or input is closed, // or the context is canceled. func (o *listPathOptions) gatherResults(ctx context.Context, in <-chan metaCacheEntry) func() (metaCacheEntriesSorted, error) { resultsDone := make(chan metaCacheEntriesSorted) // Copy so we can mutate resCh := resultsDone var done bool var mu sync.Mutex resErr := io.EOF go func() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
internal/event/target/postgresql.go
if p.QueueDir != "" { if !filepath.IsAbs(p.QueueDir) { return errors.New("queueDir path should be absolute") } } if p.MaxOpenConnections < 0 { return errors.New("maxOpenConnections cannot be less than zero") } return nil } // PostgreSQLTarget - PostgreSQL target. type PostgreSQLTarget struct { initOnce once.Init id event.TargetID args PostgreSQLArgs
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0) -
internal/kms/kes.go
// to authenticate to KMS via mTLS. Certificate *certs.Certificate // ReloadCertEvents is an event channel that receives // the reloaded client certificate. ReloadCertEvents <-chan tls.Certificate // RootCAs is a set of root CA certificates // to verify the KMS server TLS certificate. RootCAs *x509.CertPool } // NewWithConfig returns a new KMS using the given // configuration.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0) -
internal/event/target/mysql.go
if m.QueueDir != "" { if !filepath.IsAbs(m.QueueDir) { return errors.New("queueDir path should be absolute") } } if m.MaxOpenConnections < 0 { return errors.New("maxOpenConnections cannot be less than zero") } return nil } // MySQLTarget - MySQL target. type MySQLTarget struct { initOnce once.Init id event.TargetID args MySQLArgs updateStmt *sql.Stmt
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 11.5K bytes - Viewed (0) -
cmd/storage-rest-server.go
if !s.checkID(params.DiskID) { return grid.NewRemoteErr(errDiskNotFound) } if params.Cache == nil { return grid.NewRemoteErrString("NSScannerHandler: provided cache is nil") } // Collect updates, stream them before the full cache is sent. updates := make(chan dataUsageEntry, 1) var wg sync.WaitGroup wg.Add(1)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableSortedSet.java
import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * GWT emulation of {@link com.google.common.collect.ImmutableSortedSet}. * * @author Hayward Chan */ @ElementTypesAreNonnullByDefault public abstract class ImmutableSortedSet<E> extends ForwardingImmutableSet<E> implements SortedSet<E>, SortedIterable<E> {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 27 19:19:19 GMT 2024 - 15.3K bytes - Viewed (0) -
doc/go_mem.html
may be implemented as a write of each individual sub-value, in any order. </p> <p> A read <i>r</i> of a memory location <i>x</i> holding a value that is not larger than a machine word must observe some write <i>w</i> such that <i>r</i> does not happen before <i>w</i> and there is no write <i>w'</i> such that <i>w</i> happens before <i>w'</i> and <i>w'</i> happens before <i>r</i>.
HTML - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Mon Mar 04 15:54:42 GMT 2024 - 26.6K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K 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) -
internal/grid/grid_test.go
remoteHost := remote.HostName() // 1: Echo serverSent := make(chan struct{}) serverCanceled := make(chan struct{}) register := func(manager *Manager) { errFatal(manager.RegisterStreamingHandler(handlerTest, StreamHandler{ Handle: func(ctx context.Context, payload []byte, _ <-chan []byte, resp chan<- []byte) *RemoteErr { // Send many responses. // Test that this doesn't block.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0)