- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 2,160 for silent (0.23 sec)
-
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) -
cmd/perf-tests.go
req, err := http.NewRequestWithContext(ctx, http.MethodPost, reqURL.String(), reader) if err != nil { result.Error = err.Error() return } client := &http.Client{ Transport: globalRemoteTargetTransport, } resp, err := client.Do(req) if err != nil { result.Error = err.Error() return } defer xhttp.DrainBody(resp.Body) err = gob.NewDecoder(resp.Body).Decode(&result)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 11.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/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) -
src/main/java/org/codelibs/fess/es/user/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) -
cmd/listen-notification-handlers.go
return } } rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()}) setEventStreamHeaders(w) // Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers. // Use buffered channel to take care of burst sends or slow w.Write()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/metrics-v2_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "testing" "time" "github.com/prometheus/client_golang/prometheus" ) func TestGetHistogramMetrics(t *testing.T) { histBuckets := []float64{0.05, 0.1, 0.25, 0.5, 0.75} labels := []string{"GetObject", "PutObject", "CopyObject", "CompleteMultipartUpload"}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 2.3K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus_test.go
ctx := cli.NewFakeContext(&cli.NewFakeContextOption{ IstioNamespace: "istio-system", }) if !c.noIstiod { client, err := ctx.CLIClientWithRevision(c.revision) assert.NoError(t, err) _, err = client.Kube().CoreV1().Pods("istio-system").Create(context.TODO(), &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "istiod-test", Namespace: "istio-system",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 5.5K bytes - Viewed (0)