- Sort Score
- Num 10 results
- Language All
Results 171 - 180 of 502 for channel (0.03 seconds)
-
build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/UpgradedPropertiesChangesTest.kt
""" ) } ) { assertHasErrors( "Method com.example.Task.getSourceCompatibility(): Is not binary compatible." to listOf("Method return type has changed", "Method is now abstract"), removed("Method", "Task.setSourceCompatibility(java.lang.String)"), ) } } @TestCreated: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed Dec 24 14:15:15 GMT 2025 - 26.2K bytes - Click Count (0) -
cmd/post-policy_test.go
// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler. // Call the ServeHTTP to execute the handler. apiRouter.ServeHTTP(rec, req) ctx, cancel := context.WithCancel(GlobalContext) defer cancel() // Now check if we actually wrote to backend (regardless of the response // returned by the server). z := obj.(*erasureServerPools) xl := z.serverPools[0].sets[0]
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 30.6K bytes - Click Count (0) -
cmd/api-errors.go
}, ErrAdminNoSuchPolicy: { Code: "XMinioAdminNoSuchPolicy", Description: "The canned policy does not exist.", HTTPStatusCode: http.StatusNotFound, }, ErrAdminPolicyChangeAlreadyApplied: { Code: "XMinioAdminPolicyChangeAlreadyApplied", Description: "The specified policy change is already in effect.", HTTPStatusCode: http.StatusBadRequest, }, ErrAdminInvalidArgument: {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 16 07:34:24 GMT 2025 - 93K bytes - Click Count (3) -
helm/minio/values.yaml
extraVolumeMounts: [] ## Additional sidecar containers extraContainers: [] ## Internal port number for MinIO S3 API container ## Change service.port to change external port number minioAPIPort: "9000" ## Internal port number for MinIO Browser Console container ## Change consoleService.port to change external port number minioConsolePort: "9001" ## Update strategy for Deployments deploymentUpdate: type: RollingUpdate
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 19.7K bytes - Click Count (1) -
cmd/admin-handlers-users_test.go
} return testCases }() const ( EnvTestEtcdBackend = "_MINIO_ETCD_TEST_SERVER" ) func (s *TestSuiteIAM) setUpEtcd(c *check, etcdServer string) { ctx, cancel := context.WithTimeout(context.Background(), testDefaultTimeout) defer cancel() configCmds := []string{ "etcd", "endpoints=" + etcdServer, "path_prefix=" + mustGetUUID(), } _, err := s.adm.SetConfigKV(ctx, strings.Join(configCmds, " "))
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 50.6K bytes - Click Count (0) -
cmd/namespace-lock.go
type LockContext struct { ctx context.Context cancel context.CancelFunc } // Context returns lock context func (l LockContext) Context() context.Context { return l.ctx } // Cancel function calls cancel() function func (l LockContext) Cancel() { if l.cancel != nil { l.cancel() } } // newNSLock - return a new name space lock map.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 9.2K bytes - Click Count (0) -
internal/http/check_port_linux.go
_ = syscall.SetsockoptString(int(fdPtr), syscall.SOL_SOCKET, syscall.SO_BINDTODEVICE, opts.Interface) } }) return nil }, } ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel() l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port)) if err != nil { return err } // As we are able to listen on this network, the port is not in use.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.9K bytes - Click Count (0) -
doc/initial/6-stdlib/99-minor/README
API changes and other small changes to the standard library go here....
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Jan 22 18:07:49 GMT 2024 - 69 bytes - Click Count (0) -
cmd/peer-s3-client.go
return BucketInfo{}, toObjectErr(errVolumeNotFound, bucket) } func (client *remotePeerS3Client) ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error) { ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout()) defer cancel() bi, err := listBucketsRPC.Call(ctx, client.gridConn(), &opts) if err != nil { return nil, toStorageErr(err) } buckets := make([]BucketInfo, 0, len(bi.Value()))Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.6K bytes - Click Count (0) -
internal/amztime/parse.go
// Package amztime implements AWS specific time parsing and deviations package amztime import ( "errors" "net/http" "time" ) // Supported amz date formats. var amzDateFormats = []string{ // Do not change this order, x-amz-date format is usually in // iso8601Format rest are meant for relaxed handling of other // odd SDKs that might be out there. "20060102T150405Z", time.RFC1123, time.RFC1123Z,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 2.5K bytes - Click Count (0)