Search Options

Results per page
Sort
Preferred Languages
Advance

Results 691 - 700 of 1,002 for Struct (0.04 sec)

  1. cmd/erasure-metadata.go

    	}
    
    	if maxCount < quorum {
    		return FileInfo{}, InsufficientReadQuorum{Err: errErasureReadQuorum, Type: RQInconsistentMeta}
    	}
    
    	// objProps represents properties that go beyond a single version
    	type objProps struct {
    		succModTime time.Time
    		numVersions int
    	}
    	// Find the successor mod time and numVersions in quorum, otherwise leave the
    	// candidate as found
    	otherPropsMap := make(counterMap[objProps])
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 21.3K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    	case grid.ErrUnknownHandler.Error():
    		return errInconsistentDisk
    	case grid.ErrDisconnected.Error():
    		return errDiskNotFound
    	}
    	return err
    }
    
    // Abstracts a remote disk.
    type storageRESTClient struct {
    	endpoint   Endpoint
    	restClient *rest.Client
    	gridConn   *grid.Subroute
    	diskID     atomic.Pointer[string]
    
    	diskInfoCache *cachevalue.Cache[DiskInfo]
    }
    
    // Retrieve location indexes.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  3. cmd/generic-handlers.go

    				// Employ a temporary re-direct.
    				http.Redirect(w, r, u.String(), http.StatusTemporaryRedirect)
    				return
    			}
    		}
    		h.ServeHTTP(w, r)
    	})
    }
    
    var redirectPrefixes = map[string]struct{}{
    	"favicon-16x16.png": {},
    	"favicon-32x32.png": {},
    	"favicon-96x96.png": {},
    	"index.html":        {},
    	minioReservedBucket: {},
    }
    
    // Fetch redirect location if urlPath satisfies certain
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.7K bytes
    - Viewed (1)
  4. cmd/erasure-healing_test.go

    func TestIsObjectDangling(t *testing.T) {
    	fi := newFileInfo("test-object", 2, 2)
    	fi.Erasure.Index = 1
    
    	ifi := newFileInfo("test-object", 2, 2)
    	ifi.SetInlineData()
    	ifi.Erasure.Index = 1
    
    	testCases := []struct {
    		name             string
    		metaArr          []FileInfo
    		errs             []error
    		dataErrs         map[int][]int
    		expectedMeta     FileInfo
    		expectedDangling bool
    	}{
    		{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v2_gen.go

    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "ObjectV2")
    					return
    				}
    				z.ObjectV2 = nil
    			} else {
    				if z.ObjectV2 == nil {
    					z.ObjectV2 = new(struct {
    						DataDir [16]byte `msg:"DDir"`
    					})
    				}
    				var zb0002 uint32
    				zb0002, err = dc.ReadMapHeader()
    				if err != nil {
    					err = msgp.WrapError(err, "ObjectV2")
    					return
    				}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 55.8K bytes
    - Viewed (0)
  6. cmd/iam-object-store.go

    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/sync/errgroup"
    	"github.com/puzpuzpuz/xsync/v3"
    )
    
    // IAMObjectStore implements IAMStorageAPI
    type IAMObjectStore struct {
    	// Protect access to storage within the current server.
    	sync.RWMutex
    
    	*iamCache
    
    	usersSysType UsersSysType
    
    	objAPI ObjectLayer
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  7. cmd/peer-rest-client.go

    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/rest"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    // client to talk to peer Nodes.
    type peerRESTClient struct {
    	host       *xnet.Host
    	restClient *rest.Client
    	gridHost   string
    	// Function that returns the grid connection for this peer when initialized.
    	// Will return nil if the grid connection is not initialized yet.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 26.1K bytes
    - Viewed (0)
  8. cmd/sts-handlers.go

    	}
    
    	c[policy.SessionPolicyName] = base64.StdEncoding.EncodeToString(policyBuf)
    	return nil
    }
    
    // stsAPIHandlers implements and provides http handlers for AWS STS API.
    type stsAPIHandlers struct{}
    
    // registerSTSRouter - registers AWS STS compatible APIs.
    func registerSTSRouter(router *mux.Router) {
    	// Initialize STS.
    	sts := &stsAPIHandlers{}
    
    	// STS Router
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 36.6K bytes
    - Viewed (0)
  9. cmd/admin-bucket-handlers.go

    					return
    				}
    				rawDataFn(bytes.NewReader(configData), cfgPath, len(configData))
    			}
    		}
    	}
    }
    
    type importMetaReport struct {
    	madmin.BucketMetaImportErrs
    }
    
    func (i *importMetaReport) SetStatus(bucket, fname string, err error) {
    	st := i.Buckets[bucket]
    	var errMsg string
    	if err != nil {
    		errMsg = err.Error()
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 33.3K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.32.md

    - The getters for the field name and typeDescription of the Reflector struct were renamed. ([#128035](https://github.com/kubernetes/kubernetes/pull/128035), [@alexanderstephan](https://github.com/alexanderstephan)) [SIG API Machinery]
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Tue Dec 16 18:27:41 UTC 2025
    - 448.1K bytes
    - Viewed (0)
Back to top