Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for kinase (0.24 sec)

  1. cmd/warm-backend-s3.go

    	if rv != "" {
    		ropts.VersionID = string(rv)
    	}
    	err := s3.client.RemoveObject(ctx, s3.Bucket, s3.getDest(object), ropts)
    	return s3.ToObjectError(err, object)
    }
    
    func (s3 *warmBackendS3) InUse(ctx context.Context) (bool, error) {
    	result, err := s3.core.ListObjectsV2(s3.Bucket, s3.Prefix, "", "", slashSeparator, 1)
    	if err != nil {
    		return false, s3.ToObjectError(err)
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  2. cmd/xl-storage-format-v2.go

    	binary.LittleEndian.PutUint16(xlVersionCurrent[2:4], xlVersionMinor)
    }
    
    // The []journal contains all the different versions of the object.
    //
    // This array can have 3 kinds of objects:
    //
    // ``object``: If the object is uploaded the usual way: putobject, multipart-put, copyobject
    //
    // ``delete``: This is the delete-marker
    //
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
  3. internal/http/dial_linux.go

    			if opts.Interface != "" {
    				if h, _, err := net.SplitHostPort(address); err == nil {
    					address = h
    				}
    				// Create socket on specific vrf device.
    				// To catch all kinds of special cases this filters specifically for loopback networks.
    				if ip := net.ParseIP(address); ip != nil && !ip.IsLoopback() {
    					_ = syscall.SetsockoptString(fd, syscall.SOL_SOCKET, syscall.SO_BINDTODEVICE, opts.Interface)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Jun 07 16:53:05 GMT 2023
    - 4.4K bytes
    - Viewed (3)
  4. cmd/warm-backend-gcs.go

    	err := gcs.client.Bucket(gcs.Bucket).Object(gcs.getDest(key)).Delete(ctx)
    	return gcsToObjectError(err, gcs.Bucket, key)
    }
    
    func (gcs *warmBackendGCS) InUse(ctx context.Context) (bool, error) {
    	it := gcs.client.Bucket(gcs.Bucket).Objects(ctx, &storage.Query{
    		Delimiter: "/",
    		Prefix:    gcs.Prefix,
    		Versions:  false,
    	})
    	pager := iterator.NewPager(it, 1, "")
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  5. CREDITS

     of this license document, but changing it is not allowed.
    
                                Preamble
    
      The GNU Affero General Public License is a free, copyleft license for
    software and other kinds of works, specifically designed to ensure
    cooperation with the community in the case of network server software.
    
      The licenses for most software and other practical works are designed
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:31:35 GMT 2024
    - 1.6M bytes
    - Viewed (0)
  6. buildscripts/checkdeps.sh

    #!/usr/bin/env bash
    #
    
    _init() {
    
    	shopt -s extglob
    
    	## Minimum required versions for build dependencies
    	GIT_VERSION="1.0"
    	GO_VERSION="1.16"
    	OSX_VERSION="10.8"
    	KNAME=$(uname -s)
    	ARCH=$(uname -m)
    	case "${KNAME}" in
    	SunOS)
    		ARCH=$(isainfo -k)
    		;;
    	esac
    }
    
    ## FIXME:
    ## In OSX, 'readlink -f' option does not exist, hence
    ## we have our own readlink -f behavior here.
    Shell Script
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri May 26 05:07:25 GMT 2023
    - 3.4K bytes
    - Viewed (0)
  7. cmd/warm-backend-azure.go

    	_, err := blob.Delete(ctx, azblob.DeleteSnapshotsOptionNone, azblob.BlobAccessConditions{})
    	return azureToObjectError(err, az.Bucket, object)
    }
    
    func (az *warmBackendAzure) InUse(ctx context.Context) (bool, error) {
    	containerURL := az.serviceURL.NewContainerURL(az.Bucket)
    	resp, err := containerURL.ListBlobsHierarchySegment(ctx, azblob.Marker{}, "/", azblob.ListBlobsSegmentOptions{
    		Prefix:     az.Prefix,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Mar 05 16:44:08 GMT 2024
    - 7.8K bytes
    - Viewed (1)
  8. LICENSE

     of this license document, but changing it is not allowed.
    
                                Preamble
    
      The GNU Affero General Public License is a free, copyleft license for
    software and other kinds of works, specifically designed to ensure
    cooperation with the community in the case of network server software.
    
      The licenses for most software and other practical works are designed
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 33.7K bytes
    - Viewed (0)
  9. internal/http/server.go

    		// If server is in shutdown.
    		if atomic.LoadUint32(&srv.inShutdown) != 0 {
    			// To indicate disable keep-alive, server is shutting down.
    			w.Header().Set("Connection", "close")
    
    			// Add 1 minute retry header, incase-client wants to honor it
    			w.Header().Set(RetryAfter, "60")
    
    			w.WriteHeader(http.StatusServiceUnavailable)
    			w.Write([]byte(http.ErrServerClosed.Error()))
    			return
    		}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  10. cmd/tier.go

    	d, err := newWarmBackend(ctx, tier, true)
    	if err != nil {
    		return err
    	}
    
    	if !ignoreInUse {
    		// Check if warmbackend is in use by other MinIO tenants
    		inUse, err := d.InUse(ctx)
    		if err != nil {
    			return err
    		}
    		if inUse {
    			return errTierBackendInUse
    		}
    	}
    
    	config.Tiers[tierName] = tier
    	config.drivercache[tierName] = d
    
    	return nil
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
Back to top