- Sort Score
- Result 10 results
- Languages All
Results 1001 - 1010 of 1,121 for readyz (0.14 sec)
-
cmd/iam-store.go
for _, v := range policy.DefaultPolicies { if _, ok := policies[v.Name]; !ok { policies[v.Name] = defaultPolicyDoc(v.Definition) } } } // LoadIAMCache reads all IAM items and populates a new iamCache object and // replaces the in-memory cache object. func (store *IAMStoreSys) LoadIAMCache(ctx context.Context, firstTime bool) error { bootstrapTraceMsgFirstTime := func(s string) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Oct 14 16:35:37 UTC 2024 - 83.2K bytes - Viewed (0) -
cmd/auth-handler_test.go
"context" "io" "net/http" "net/url" "os" "testing" "time" "github.com/minio/minio/internal/auth" "github.com/minio/pkg/v3/policy" ) type nullReader struct{} func (r *nullReader) Read(b []byte) (int, error) { return len(b), nil } // Test get request auth type. func TestGetRequestAuthType(t *testing.T) { type testCase struct { req *http.Request authT authType }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.4K bytes - Viewed (0) -
cmd/erasure-object_test.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 36.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
private static final class InCompletionOrderState<T extends @Nullable Object> { // A happens-before edge between the writes of these fields and their reads exists, because // in order to read these fields, the corresponding write to incompleteOutputCount must have // been read. private boolean wasCancelled = false; private boolean shouldInterrupt = true; private final AtomicInteger incompleteOutputCount;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
final int httpStatusCode = response.getHttpStatusCode(); if (httpStatusCode == 200) { logger.info("ConfigSync is ready."); return; } final String message = "Configsync is not available. HTTP Status is " + httpStatusCode; if (response.getContentException() != null) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sun Oct 20 02:08:03 UTC 2024 - 86.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
private final ListenerCallQueue<Listener> listeners = new ListenerCallQueue<>(); /** * The current state of the service. This should be written with the lock held but can be read * without it because it is an immutable object in a volatile field. This is desirable so that * methods like {@link #state}, {@link #failureCause} and notably {@link #toString} can be run * without grabbing the lock.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.4K bytes - Viewed (0) -
internal/grid/muxclient.go
dst = binary.LittleEndian.AppendUint32(dst, uint32(h)) } return m.parent.send(m.ctx, dst) } // RequestStateless will send a single payload request and stream back results. // req may not be read/written to after calling. // TODO: Not implemented func (m *muxClient) RequestStateless(h HandlerID, req []byte, out chan<- Response) { if m.init { out <- Response{Err: errors.New("mux client already used")} }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/FilesTest.java
assertTrue(Arrays.equals(I18N.getBytes(UTF_8), Files.toByteArray(i18nFile))); assertTrue(Arrays.equals(I18N.getBytes(UTF_8), Files.asByteSource(i18nFile).read())); } /** A {@link File} that provides a specialized value for {@link File#length()}. */ private static class BadLengthFile extends File { private final long badLength;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jul 23 14:22:54 UTC 2024 - 22.1K bytes - Viewed (0) -
helm-releases/minio-4.0.12.tgz
(prefixed with !). Only one pattern per line. .DS_Store # Common VCS dirs .git/ .gitignore .bzr/ .bzrignore .hg/ .hgignore .svn/ # Common backup files *.swp *.bak *.tmp *~ # Various IDEs .project .idea/ *.tmproj # OWNERS file for Kubernetes OWNERS minio/README.md # MinIO Helm Chart [![Slack](https://slack.min.io/slack?type=svg)](https://slack.min.io) [![license](https://img.shields.io/badge/license-AGPL%20V3-blue)](https://github.com/minio/minio/blob/master/LICENSE) MinIO is a High Performance Object Storage...
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Aug 14 05:50:43 UTC 2022 - 19.4K bytes - Viewed (0) -
helm-releases/minio-4.0.13.tgz
(prefixed with !). Only one pattern per line. .DS_Store # Common VCS dirs .git/ .gitignore .bzr/ .bzrignore .hg/ .hgignore .svn/ # Common backup files *.swp *.bak *.tmp *~ # Various IDEs .project .idea/ *.tmproj # OWNERS file for Kubernetes OWNERS minio/README.md # MinIO Helm Chart [![Slack](https://slack.min.io/slack?type=svg)](https://slack.min.io) [![license](https://img.shields.io/badge/license-AGPL%20V3-blue)](https://github.com/minio/minio/blob/master/LICENSE) MinIO is a High Performance Object Storage...
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 23 18:18:14 UTC 2022 - 19.5K bytes - Viewed (0)