Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 171 - 180 of 502 for channel (0.19 seconds)

  1. 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)"),
                )
            }
        }
    
        @Test
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed Dec 24 14:15:15 GMT 2025
    - 26.2K bytes
    - Click Count (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top