Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 55 for nuts (0.02 sec)

  1. internal/event/target/nats.go

    	}
    
    	return nil
    }
    
    // To obtain a nats connection from args.
    func (n NATSArgs) connectNats() (*nats.Conn, error) {
    	connOpts := []nats.Option{nats.Name("Minio Notification"), nats.MaxReconnects(-1)}
    	if n.Username != "" && n.Password != "" {
    		connOpts = append(connOpts, nats.UserInfo(n.Username, n.Password))
    	}
    	if n.UserCredentials != "" {
    		connOpts = append(connOpts, nats.UserCredentials(n.UserCredentials))
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  2. go.mod

    	github.com/minio/simdjson-go v0.4.5
    	github.com/minio/sio v0.4.1
    	github.com/minio/xxml v0.0.3
    	github.com/minio/zipindex v0.3.1
    	github.com/mitchellh/go-homedir v1.1.0
    	github.com/nats-io/nats-server/v2 v2.9.23
    	github.com/nats-io/nats.go v1.37.0
    	github.com/nats-io/stan.go v0.10.4
    	github.com/ncw/directio v1.0.5
    	github.com/nsqio/go-nsq v1.1.0
    	github.com/philhofer/fwd v1.1.3-0.20240916144458-20a13a1f6b7c
    	github.com/pierrec/lz4/v4 v4.1.21
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. guava/src/com/google/common/math/BigIntegerMath.java

      }
    
      static BigInteger listProduct(List<BigInteger> nums) {
        return listProduct(nums, 0, nums.size());
      }
    
      static BigInteger listProduct(List<BigInteger> nums, int start, int end) {
        switch (end - start) {
          case 0:
            return BigInteger.ONE;
          case 1:
            return nums.get(start);
          case 2:
            return nums.get(start).multiply(nums.get(start + 1));
          case 3:
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 17:21:56 UTC 2024
    - 18.8K bytes
    - Viewed (0)
  4. internal/config/notify/help.go

    			Key:         target.NATSAddress,
    			Description: "NATS server address e.g. '0.0.0.0:4222'",
    			Type:        "address",
    			Sensitive:   true,
    		},
    		config.HelpKV{
    			Key:         target.NATSSubject,
    			Description: "NATS subscription subject",
    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         target.NATSUsername,
    			Description: "NATS username",
    			Optional:    true,
    			Type:        "string",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  5. go.sum

    github.com/nats-io/nats.go v1.14.0/go.mod h1:BPko4oXsySz4aSWeFgOHLZs3G4Jq4ZAyE6/zMCxRT6w=
    github.com/nats-io/nats.go v1.15.0/go.mod h1:BPko4oXsySz4aSWeFgOHLZs3G4Jq4ZAyE6/zMCxRT6w=
    github.com/nats-io/nats.go v1.22.1/go.mod h1:tLqubohF7t4z3du1QDPYJIQQyhb4wl6DhjxEajSI7UA=
    github.com/nats-io/nats.go v1.37.0 h1:07rauXbVnnJvv1gfIyghFEo6lUcYRY0WXc3x7x0vUxE=
    github.com/nats-io/nats.go v1.37.0/go.mod h1:Ubdu4Nh9exXdSz0RVWRFBbRfrbSxOYd26oF0wkWclB8=
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 78K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/mylasta/direction/sponsor/FessMultipartRequestHandler.java

    import org.lastaflute.core.message.UserMessages;
    import org.lastaflute.web.exception.Forced404NotFoundException;
    import org.lastaflute.web.ruts.multipart.MultipartFormFile;
    import org.lastaflute.web.ruts.multipart.MultipartRequestHandler;
    import org.lastaflute.web.ruts.multipart.MultipartRequestWrapper;
    import org.lastaflute.web.ruts.multipart.exception.MultipartExceededException;
    import org.lastaflute.web.util.LaServletContextUtil;
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Wed Oct 23 13:27:21 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  7. internal/store/queuestore.go

    		}
    	}
    
    	return nil
    }
    
    // Delete - Remove the store directory from disk
    func (store *QueueStore[_]) Delete() error {
    	return os.Remove(store.directory)
    }
    
    // PutMultiple - puts an item to the store.
    func (store *QueueStore[I]) PutMultiple(items []I) (Key, error) {
    	// Generate a new UUID for the key.
    	uid, err := uuid.NewRandom()
    	if err != nil {
    		return Key{}, err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  8. compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/MetadataGraph.java

                    }
                } else {
                    sb.append("      no entries\n");
                }
    
                List<MetadataGraphEdge> outs = getExcidentEdges(v);
                if (outs != null) {
                    for (MetadataGraphEdge e : outs) {
                        sb.append("        to :  ").append(e.toString()).append('\n');
                    }
                } else {
                    sb.append("      no exit\n");
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  9. impl/maven-core/src/main/java/org/apache/maven/artifact/repository/RepositoryCache.java

    @Deprecated
    //
    // Used by Tycho and will break users and force them to upgrade to Maven 3.1 so we should really leave
    // this here, possibly indefinitely.
    //
    public interface RepositoryCache {
    
        /**
         * Puts the specified data into the cache. <strong>Warning:</strong> The cache will directly save the provided
         * reference. If the cached data is mutable, i.e. could be modified after being put into the cache, the caller is
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  10. ci/official/utilities/rename_and_verify_wheels.sh

    # ==============================================================================
    #
    # Usage: rename_and_verify_wheels.sh
    # This script is aware of TFCI_ variables, so it doesn't need any arguments.
    # Puts new wheel through auditwheel to rename and verify it, deletes the old
    # one, checks the filesize, and then ensures the new wheel is installable.
    set -euxo pipefail
    
    cd "$TFCI_OUTPUT_DIR"
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Oct 02 21:18:17 UTC 2024
    - 4.3K bytes
    - Viewed (0)
Back to top