Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 521 - 530 of 1,048 for Pool (0.01 seconds)

  1. cmd/net_test.go

    		case testCase.expectedErr.Error() != err.Error():
    			t.Fatalf("error: expected = %v, got = %v", testCase.expectedErr, err)
    		}
    
    		if testCase.expectedIPList != nil {
    			var found bool
    			for _, ip := range ipList.ToSlice() {
    				if testCase.expectedIPList.Contains(ip) {
    					found = true
    				}
    			}
    			if !found {
    				t.Fatalf("host: expected = %v, got = %v", testCase.expectedIPList, ipList)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  2. internal/event/target/webhook.go

    func (target *WebhookTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    	return target.isActive()
    }
    
    // Store returns any underlying store if set.
    func (target *WebhookTarget) Store() event.TargetStore {
    	return target.store
    }
    
    func (target *WebhookTarget) isActive() (bool, error) {
    	conn, err := net.DialTimeout("tcp", target.addr, 5*time.Second)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 8.8K bytes
    - Click Count (0)
  3. src/cmd/api/api_test.go

    	"slices"
    	"strings"
    	"sync"
    	"testing"
    )
    
    var flagCheck = flag.Bool("check", false, "run API checks")
    
    func TestMain(m *testing.M) {
    	flag.Parse()
    	for _, c := range contexts {
    		c.Compiler = build.Default.Compiler
    	}
    	build.Default.GOROOT = testenv.GOROOT(nil)
    
    	os.Exit(m.Run())
    }
    
    var (
    	updateGolden = flag.Bool("updategolden", false, "update golden files")
    )
    
    func TestGolden(t *testing.T) {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri May 02 17:06:27 GMT 2025
    - 7.6K bytes
    - Click Count (0)
  4. internal/etag/etag.go

    	if e.IsMultipart() {
    		return hex.EncodeToString(e[:16]) + string(e[16:])
    	}
    	return hex.EncodeToString(e)
    }
    
    // IsEncrypted reports whether the ETag is encrypted.
    func (e ETag) IsEncrypted() bool {
    	// An encrypted ETag must be at least 32 bytes long.
    	// It contains the encrypted ETag value + an authentication
    	// code generated by the AEAD cipher.
    	//
    	// Here is an incorrect implementation of IsEncrypted:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 13.2K bytes
    - Click Count (0)
  5. internal/config/identity/openid/openid.go

    	v, err := arn.NewIAMRoleARN("dummy-internal", "")
    	if err != nil {
    		panic("should not happen!")
    	}
    	return v
    }()
    
    // Config - OpenID Config
    type Config struct {
    	Enabled bool
    
    	// map of roleARN to providerCfg's
    	arnProviderCfgsMap map[arn.ARN]*providerCfg
    
    	// map of config names to providerCfg's
    	ProviderCfgs map[string]*providerCfg
    
    	pubKeys          publicKeys
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 17.3K bytes
    - Click Count (0)
  6. cmd/encryption-v1_test.go

    		},
    		metadata: map[string]string{
    			xhttp.AmzServerSideEncryptionCustomerKey: "XAm0dRrJsEsyPb1UuFNezv1bl9hxuYsgUVC/MUctE2k=",
    		},
    	},
    }
    
    func TestEncryptRequest(t *testing.T) {
    	defer func(flag bool) { globalIsTLS = flag }(globalIsTLS)
    	globalIsTLS = true
    	for i, test := range encryptRequestTests {
    		content := bytes.NewReader(make([]byte, 64))
    		req := &http.Request{Header: http.Header{}}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 19.9K bytes
    - Click Count (0)
  7. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/package-info.java

     * KIND, either express or implied.  See the License for the
     * specific language governing permissions and limitations
     * under the License.
     */
    
    /**
     * This package contains the {@code mvn} tool implementation.
     */
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Nov 13 14:14:56 GMT 2024
    - 923 bytes
    - Click Count (0)
  8. internal/http/transports.go

    	DialTimeout time.Duration
    
    	// TLS Settings
    	RootCAs          *x509.CertPool
    	CipherSuites     []uint16
    	CurvePreferences []tls.CurveID
    
    	// HTTP2
    	EnableHTTP2 bool
    
    	// TCP Options
    	TCPOptions TCPOptions
    }
    
    func (s ConnSettings) getDefaultTransport(maxIdleConnsPerHost int) *http.Transport {
    	if maxIdleConnsPerHost <= 0 {
    		maxIdleConnsPerHost = 1024
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 08 17:51:53 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  9. internal/deadlineconn/deadlineconn.go

    	writeDeadline           time.Duration // sets the write deadline on a connection.
    	writeSetAt              time.Time
    	abortReads, abortWrites atomic.Bool // A deadline was set to indicate caller wanted the conn to time out.
    	infReads, infWrites     atomic.Bool
    	mu                      sync.Mutex
    }
    
    // Unwrap will unwrap the connection and remove the deadline if applied.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Dec 02 13:21:17 GMT 2024
    - 5.1K bytes
    - Click Count (0)
  10. README.md

    You can also connect using any S3-compatible tool, such as the MinIO Client `mc` commandline tool:
    
    ```sh
    mc alias set local http://localhost:9000 minioadmin minioadmin
    mc admin info local
    ```
    
    See [Test using MinIO Client `mc`](#test-using-minio-client-mc) for more information on using the `mc` commandline tool.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Dec 03 08:13:11 GMT 2025
    - 9K bytes
    - Click Count (0)
Back to Top