Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 361 - 370 of 506 for runnable (0.06 seconds)

  1. cmd/jwt_test.go

    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    		t.Fatal(err)
    	}
    
    	creds := globalActiveCred
    	token, err := getTokenString(creds.AccessKey, creds.SecretKey)
    	if err != nil {
    		t.Fatalf("unable get token %s", err)
    	}
    	testCases := []struct {
    		req         *http.Request
    		expectedErr error
    	}{
    		// Set valid authorization header.
    		{
    			req: &http.Request{
    				Header: http.Header{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  2. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/DefaultLegacyArtifactCollector.java

                                                throw new ArtifactResolutionException(
                                                        "Unable to get dependency information: " + e.getMessage(),
                                                        resetArtifact,
                                                        request.getRemoteRepositories(),
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 36.5K bytes
    - Click Count (0)
  3. build-conventions/src/main/java/org/elasticsearch/gradle/internal/conventions/info/GitInfo.java

            } catch (final IOException e) {
                // for now, do not be lenient until we have better understanding of real-world scenarios where this happens
                throw new GradleException("unable to read the git revision", e);
            }
        }
    
    
        private static String findOriginUrl(final Path configFile) throws IOException {
            Map<String, String> props = new HashMap<>();
    
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 7.8K bytes
    - Click Count (0)
  4. internal/event/target/webhook.go

    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			cancel()
    			return nil, fmt.Errorf("unable to initialize the queue store of Webhook `%s`: %w", id, err)
    		}
    	}
    
    	target := &WebhookTarget{
    		id:         event.TargetID{ID: id, Name: "webhook"},
    		args:       args,
    		loggerOnce: loggerOnce,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 8.8K bytes
    - Click Count (0)
  5. cmd/bucket-lifecycle_test.go

    		}
    	}
    }
    
    func TestObjectIsRemote(t *testing.T) {
    	fi := newFileInfo("object", 8, 8)
    	fi.Erasure.Index = 1
    	if !fi.IsValid() {
    		t.Fatalf("unable to get xl meta")
    	}
    
    	testCases := []struct {
    		meta   map[string]string
    		remote bool
    	}{
    		{
    			// restore in progress
    			meta: map[string]string{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 31 09:57:57 GMT 2022
    - 7K bytes
    - Click Count (0)
  6. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/InternalDistributionArchiveCheckPlugin.java

                        );
                    }
                    line++;
                }
            } catch (IOException ioException) {
                throw new GradleException("Unable to read from file " + path, ioException);
            }
        }
    
        private static boolean toolExists(Project project) {
            if (project.getName().contains("tar")) {
                return tarExists();
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 10.6K bytes
    - Click Count (0)
  7. cmd/metrics-v3-cluster-usage.go

    	for bucket, usage := range dataUsageInfo.BucketsUsage {
    		quota, err := globalBucketQuotaSys.Get(ctx, bucket)
    		if err != nil {
    			// Log and continue if we are unable to retrieve metrics for this
    			// bucket.
    			metricsLogIf(ctx, err)
    			continue
    		}
    
    		m.Set(usageBucketTotalBytes, float64(usage.Size), "bucket", bucket)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  8. internal/crypto/error.go

    )
    
    // errOutOfEntropy indicates that the a source of randomness (PRNG) wasn't able
    // to produce enough random data. This is fatal error and should cause a panic.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  9. internal/event/target/nsq.go

    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of NSQ `%s`: %w", id, err)
    		}
    	}
    
    	target := &NSQTarget{
    		id:         event.TargetID{ID: id, Name: "nsq"},
    		args:       args,
    		loggerOnce: loggerOnce,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  10. CONTRIBUTING.md

    #### Merging pull requests ####
    
    Due to Guava's nature as a subset of Google's internal codebase which is
    automatically synced to the public GitHub repository, we are unable to merge
    pull requests directly into the master branch. Instead, once a pull request is
    ready for merging, we'll make the appropriate changes in the internal codebase
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 17:53:05 GMT 2026
    - 4.3K bytes
    - Click Count (0)
Back to Top