Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for inverse (0.16 sec)

  1. cmd/update.go

    	uaAppend(" ", CommitID)
    	if IsDCOS() {
    		universePkgVersion := env.Get("MARATHON_APP_LABEL_DCOS_PACKAGE_VERSION", "")
    		// On DC/OS environment try to the get universe package version.
    		if universePkgVersion != "" {
    			uaAppend(" universe-", universePkgVersion)
    		}
    	}
    
    	if IsKubernetes() {
    		// In Kubernetes environment, try to fetch the helm package version
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-rebalance.go

    			fivs, err := entry.fileInfoVersions(bucket)
    			if err != nil {
    				return
    			}
    
    			// We need a reversed order for rebalance,
    			// to create the appropriate stack.
    			versionsSorter(fivs.Versions).reverse()
    
    			var rebalanced, expired int
    			for _, version := range fivs.Versions {
    				// Skip transitioned objects for now. TBD
    				if version.IsRemote() {
    					continue
    				}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool.go

    			fivs, err := entry.fileInfoVersions(bucket)
    			if err != nil {
    				return
    			}
    
    			// Note: entry.fileInfoVersions returns versions sorted in reverse chronological order based on ModTime
    			if opts.VersionsSort == WalkVersionsSortAsc {
    				versionsSorter(fivs.Versions).reverse()
    			}
    
    			for _, version := range fivs.Versions {
    				if opts.Filter != nil {
    					if opts.Filter(version) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  4. docs/debugging/inspect/export.go

    				// Read metadata CRC (added in v2, ignore if not found)
    				b = nbuf
    			}
    
    			nVers, v, e := decodeXLHeaders(v)
    			if e != nil {
    				return nil, e
    			}
    			type version struct {
    				Idx      int
    				Header   json.RawMessage
    				Metadata json.RawMessage
    			}
    			versions := make([]version, nVers)
    			e = decodeVersions(v, nVers, func(idx int, hdr, meta []byte) error {
    				var header xlMetaV2VersionHeaderV2
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 08 15:58:02 GMT 2022
    - 9.1K bytes
    - Viewed (0)
  5. cmd/object-api-utils.go

    				ObjInfo:    oi,
    				Reader:     inputReader,
    				cleanUpFns: cFns,
    			}
    			return r, nil
    		}
    	}
    	return fn, off, length, nil
    }
    
    // Close - calls the cleanup actions in reverse order
    func (g *GetObjectReader) Close() error {
    	if g == nil {
    		return nil
    	}
    	// sync.Once is used here to ensure that Close() is
    	// idempotent.
    	g.once.Do(func() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
  6. internal/grid/connection.go

    }
    
    // String returns a string representation of the connection.
    func (c *Connection) String() string {
    	return fmt.Sprintf("%s->%s", c.Local, c.Remote)
    }
    
    // StringReverse returns a string representation of the reverse connection.
    func (c *Connection) StringReverse() string {
    	return fmt.Sprintf("%s->%s", c.Remote, c.Local)
    }
    
    // State is a connection state.
    type State uint32
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  7. internal/kms/identity-manager.go

    	DescribeIdentity(ctx context.Context, identity string) (*kes.IdentityInfo, error)
    
    	// DescribeSelfIdentity describes the identity issuing the request.
    	// It infers the identity from the TLS client certificate used to authenticate.
    	// It returns the identity and policy information for the client identity.
    	DescribeSelfIdentity(ctx context.Context) (*kes.IdentityInfo, *kes.Policy, error)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 1.6K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-decom.go

    	}
    	return err
    }
    
    // versionsSorter sorts FileInfo slices by version.
    //
    //msgp:ignore versionsSorter
    type versionsSorter []FileInfo
    
    func (v versionsSorter) reverse() {
    	sort.Slice(v, func(i, j int) bool {
    		return v[i].ModTime.Before(v[j].ModTime)
    	})
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  9. internal/kms/kes.go

    	c.lock.RLock()
    	defer c.lock.RUnlock()
    
    	return c.client.DescribeIdentity(ctx, kes.Identity(identity))
    }
    
    // DescribeSelfIdentity describes the identity issuing the request.
    // It infers the identity from the TLS client certificate used to authenticate.
    // It returns the identity and policy information for the client identity.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 16 15:43:39 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  10. cmd/update_test.go

    			envName:     "MESOS_CONTAINER_NAME",
    			envValue:    "mesos-11111",
    			mode:        globalMinioModeErasure,
    			expectedStr: fmt.Sprintf("MinIO (%s; %s; %s; %s; source DEVELOPMENT.GOGET DEVELOPMENT.GOGET DEVELOPMENT.GOGET universe-%s", runtime.GOOS, runtime.GOARCH, globalMinioModeErasure, "dcos", "mesos-1111"),
    		},
    		{
    			envName:     "KUBERNETES_SERVICE_HOST",
    			envValue:    "10.11.148.5",
    			mode:        globalMinioModeErasure,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Mar 09 03:07:08 GMT 2024
    - 10.7K bytes
    - Viewed (0)
Back to top