Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 464 for Runnable (0.17 sec)

  1. cmd/bucket-targets.go

    func newHCClient() *madmin.AnonymousClient {
    	clnt, e := madmin.NewAnonymousClientNoEndpoint()
    	if e != nil {
    		bugLogIf(GlobalContext, errors.New("Unable to initialize health check client"))
    		return nil
    	}
    	clnt.SetCustomTransport(globalRemoteTargetTransport)
    	return clnt
    }
    
    // heartBeat performs liveness check on remote endpoints.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  2. istioctl/pkg/kubeinject/kubeinject.go

    		return nil, fmt.Errorf("missing configuration map key %q in %q",
    			injectConfigMapKey, injectConfigMapName)
    	}
    	injectConfig, err := inject.UnmarshalConfig([]byte(injectData))
    	if err != nil {
    		return nil, fmt.Errorf("unable to convert data from configmap %q: %v",
    			injectConfigMapName, err)
    	}
    	log.Debugf("using inject template from configmap %q", injectConfigMapName)
    	return injectConfig.RawTemplates, nil
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 21K bytes
    - Viewed (0)
  3. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/DefaultRepositoryMetadataManager.java

            try {
                mergeMetadata(metadata, remoteRepositories, localRepo);
            } catch (RepositoryMetadataStoreException e) {
                throw new RepositoryMetadataResolutionException(
                        "Unable to store local copy of metadata: " + e.getMessage(), e);
            }
        }
    
        private Date getLocalCopyLastModified(ArtifactRepository localRepository, RepositoryMetadata metadata) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 18.9K bytes
    - Viewed (0)
  4. src/cmd/asm/internal/asm/endtoend_test.go

    		if printed == "" || strings.HasSuffix(printed, ":") { // empty or label
    			continue
    		}
    		seq++
    
    		var hexes string
    		switch len(parts) {
    		default:
    			t.Errorf("%s:%d: unable to understand comments: %s", input, lineno, line)
    		case 1:
    			// no comment
    		case 2:
    			// might be printed form or hex
    			note := strings.TrimSpace(parts[1])
    			if isHexes(note) {
    				hexes = note
    			} else {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Dec 07 18:42:59 UTC 2023
    - 11.6K bytes
    - Viewed (0)
  5. internal/event/target/mysql.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 MySQL `%s`: %w", id, err)
    		}
    	}
    
    	if args.DSN == "" {
    		config := mysql.Config{
    			User:                 args.User,
    			Passwd:               args.Password,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/net/InetAddresses.java

        return ipStringToBytes(ipString, null) != null;
      }
    
      private static final class Scope {
        private String scope;
      }
    
      /** Returns {@code null} if unable to parse into a {@code byte[]}. */
      @CheckForNull
      private static byte[] ipStringToBytes(String ipStringParam, @Nullable Scope scope) {
        String ipString = ipStringParam;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  7. internal/logger/logger.go

    	for _, t := range systemTgts {
    		if err := t.Send(ctx, entry); err != nil {
    			if consoleTgt != nil { // Sending to the console never fails
    				consoleTgt.Send(ctx, errToEntry(ctx, "logging", fmt.Errorf("unable to send log event to Logger target (%s): %v", t.String(), err), entry.Level))
    			}
    		}
    	}
    }
    
    // Event sends a event log to  log targets
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 09:43:48 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  8. cmd/metacache-server-pool.go

    			if err := renameAll(pathJoin(epPath, minioMetaBucket, metacachePrefixForID(name, slashSeparator)),
    				tmpMetacacheOld, epPath); err != nil && err != errFileNotFound {
    				return fmt.Errorf("unable to rename (%s -> %s) %w",
    					pathJoin(epPath, minioMetaBucket+metacachePrefixForID(minioMetaBucket, slashSeparator)),
    					tmpMetacacheOld,
    					osErrToFileErr(err))
    			}
    		}
    		return nil
    	})
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool.go

    			err = z.Init(ctx) // Initializes all pools.
    		})
    		if err != nil {
    			if !configRetriableErrors(err) {
    				logger.Fatal(err, "Unable to initialize backend")
    			}
    			retry := time.Duration(r.Float64() * float64(5*time.Second))
    			storageLogIf(ctx, fmt.Errorf("Unable to initialize backend: %w, retrying in %s", err, retry))
    			time.Sleep(retry)
    			attempt++
    			continue
    		}
    		break
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  10. internal/event/target/nats.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 NATS `%s`: %w", id, err)
    		}
    	}
    
    	target := &NATSTarget{
    		id:         event.TargetID{ID: id, Name: "nats"},
    		args:       args,
    		loggerOnce: loggerOnce,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
Back to top