- Sort Score
- Num 10 results
- Language All
Results 521 - 530 of 1,048 for Pool (0.01 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)