- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,338 for silent (0.16 sec)
-
cmd/warm-backend-gcs.go
"google.golang.org/api/googleapi" "google.golang.org/api/iterator" "google.golang.org/api/option" xioutil "github.com/minio/minio/internal/ioutil" ) type warmBackendGCS struct { client *storage.Client Bucket string Prefix string StorageClass string } func (gcs *warmBackendGCS) getDest(object string) string { destObj := object if gcs.Prefix != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 5.9K bytes - Viewed (0) -
cmd/bucket-targets.go
} } } // GetRemoteTargetClient returns minio-go client for replication target instance func (sys *BucketTargetSys) GetRemoteTargetClient(bucket, arn string) *TargetClient { sys.RLock() tgt := sys.arnRemotesMap[arn] sys.RUnlock() if tgt.Client != nil { return tgt.Client } defer func() { // lazy refresh remote targets
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
brokers = append(brokers, broker.String()) } client, err := sarama.NewClient(brokers, sconfig) if err != nil { return err } producer, err := sarama.NewSyncProducerFromClient(client) if err != nil { return err } h.client = client h.producer = producer if len(h.client.Brokers()) > 0 { // Refer https://github.com/IBM/sarama/issues/1341
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
cmd/speedtest.go
result.Servers = len(globalNotificationSys.peerClients) + 1 result.Version = Version result.Concurrent = concurrency select { case ch <- result: case <-ctx.Done(): return } } for { select { case <-ctx.Done(): // If the client got disconnected stop the speedtest. return default: } sopts := speedTestOpts{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 9K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
recvCfg, err := serverVerifyHandler.Call(ctx, client.gridConn, grid.NewMSS()) if err != nil { return err } // We do not need the response after returning. defer serverVerifyHandler.PutResponse(recvCfg) return srcCfg.Diff(recvCfg) } // Stringer provides a canonicalized representation of node. func (client *bootstrapRESTClient) String() string { return client.gridConn.String() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
internal/grid/grid_test.go
} err = resp.Err } t.Log("Client Context canceled. err state:", err) clientCanceled <- time.Now() }(t) start := time.Now() cancel() <-serverCanceled t.Log("server cancel time:", time.Since(start)) clientEnd := <-clientCanceled if !errors.Is(err, context.Canceled) { t.Error("expected context.Canceled, got", err) } t.Log("client after", time.Since(clientEnd)) }
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) -
cmd/iam-etcd-store.go
type IAMEtcdStore struct { sync.RWMutex *iamCache usersSysType UsersSysType client *etcd.Client } func newIAMEtcdStore(client *etcd.Client, usersSysType UsersSysType) *IAMEtcdStore { return &IAMEtcdStore{ iamCache: newIamCache(), client: client, usersSysType: usersSysType, } } func (ies *IAMEtcdStore) rlock() *iamCache { ies.RLock() return ies.iamCache
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractBehavior.java
import org.opensearch.action.search.SearchRequestBuilder; import org.opensearch.action.search.SearchResponse; import org.opensearch.action.update.UpdateRequestBuilder; import org.opensearch.client.Client; import org.opensearch.core.action.ActionListener; import org.opensearch.index.seqno.SequenceNumbers; import org.opensearch.search.SearchHit; import org.opensearch.search.SearchHits; /**
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 26.4K bytes - Viewed (0) -
README.md
OkHttp is an HTTP client that’s efficient by default: * HTTP/2 support allows all requests to the same host to share a socket. * Connection pooling reduces request latency (if HTTP/2 isn’t available). * Transparent GZIP shrinks download sizes. * Response caching avoids the network completely for repeat requests. OkHttp perseveres when the network is troublesome: it will silently recover from common connection
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 6.2K bytes - Viewed (0) -
cmd/bucket-replication.go
} req, err := http.NewRequestWithContext(ctx, http.MethodGet, reqURL.String(), nil) if err != nil { return err } client := &http.Client{ Transport: globalRemoteTargetTransport, Timeout: 10 * time.Second, } resp, err := client.Do(req) if err != nil { return err } if err == nil { // Drain the connection. xhttp.DrainBody(resp.Body) } if resp != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1)