Versions in this module Expand all Collapse all v1 v1.0.0 Jan 25, 2023 Changes in this version + const DELETE + const DefaultBitrotAlgorithm + const DefaultSkewTime + const EnvAutoEncryption + const EnvKMSMasterKey + const EnvVaultAppRoleID + const EnvVaultAppSecretID + const EnvVaultAuthType + const EnvVaultCAPath + const EnvVaultEndpoint + const EnvVaultKeyName + const EnvVaultKeyVersion + const EnvVaultNamespace + const GET + const GatewayMinioSysTmp + const GlobalMultipartCleanupInterval + const GlobalMultipartExpiry + const HEAD + const MaxJitter + const NoJitter + const POST + const PUT + const ReservedMetadataPrefix + const SSECustomerKeySize + const SSEDAREPackageBlockSize + const SSEDAREPackageMetaSize + const SSEIVSize + const SSESealAlgorithmDareSha256 + const SSESealAlgorithmDareV2HmacSha256 + const TLSPrivateKeyPassword + var CanonicalizeETag = canonicalizeETag + var CleanMetadataKeys = cleanMetadataKeys + var CommitID = goGetTag + var Environment = environment + var GOPATH = "" + var GOROOT = "" + var GlobalGatewaySSE gatewaySSE + var GlobalKMS crypto.KMS + var GlobalServiceDoneCh chan struct + var MustGetUUID = mustGetUUID + var ReleaseTag = goGetTag + var ShortCommitID = CommitID[:12] + var Version = goGetTag + func AnonErrToObjectErr(statusCode int, params ...string) error + func BucketAccessPolicyToPolicy(policyInfo *miniogopolicy.BucketAccessPolicy) (*policy.Policy, error) + func CheckLocalServerAddr(serverAddr string) error + func CleanMinioInternalMetadataKeys(metadata map[string]string) map[string]string + func CreateEndpoints(serverAddr string, args ...[]string) (string, EndpointList, SetupType, error) + func DecryptAllBlocksCopyRequest(client io.Writer, r *http.Request, bucket, object string, objInfo ObjectInfo) (io.WriteCloser, int64, error) + func DecryptBlocksRequest(client io.Writer, r *http.Request, bucket, object string, ...) (io.WriteCloser, int64, int64, error) + func DecryptBlocksRequestR(inputReader io.Reader, h http.Header, offset, length int64, seqNumber uint32, ...) (io.Reader, error) + func DecryptCopyRequest(client io.Writer, r *http.Request, bucket, object string, ...) (io.WriteCloser, error) + func DecryptCopyRequestR(client io.Reader, h http.Header, bucket, object string, seqNumber uint32, ...) (io.Reader, error) + func DecryptObjectInfo(info *ObjectInfo, headers http.Header) (encrypted bool, err error) + func DecryptRequest(client io.Writer, r *http.Request, bucket, object string, ...) (io.WriteCloser, error) + func DecryptRequestWithSequenceNumber(client io.Writer, r *http.Request, bucket, object string, seqNumber uint32, ...) (io.WriteCloser, error) + func DecryptRequestWithSequenceNumberR(client io.Reader, h http.Header, bucket, object string, seqNumber uint32, ...) (io.Reader, error) + func DownloadReleaseData(timeout time.Duration, mode string) (data string, err error) + func EncryptRequest(content io.Reader, r *http.Request, bucket, object string, ...) (reader io.Reader, objEncKey []byte, err error) + func ErrorRespToObjectError(err error, params ...string) error + func Fallocate(fd int, offset int64, len int64) error + func FromMinioClientMetadata(metadata map[string][]string) map[string]string + func GenETag() string + func GetCurrentReleaseTime() (releaseTime time.Time, err error) + func GetLocalPeer(endpoints EndpointList) (localPeer string) + func GetRemotePeers(endpoints EndpointList) []string + func GetVersion(configFile string) (string, error) + func IsBOSH() bool + func IsDCOS() bool + func IsDocker() bool + func IsErr(err error, errs ...error) bool + func IsErrIgnored(err error, ignoredErrs ...error) bool + func IsKubernetes() bool + func IsSourceBuild() bool + func IsValidBucketName(bucket string) bool + func IsValidObjectName(object string) bool + func IsValidObjectPrefix(object string) bool + func KVNSEntryMarshal(entry KVNSEntry, buf []byte) ([]byte, error) + func KVNSEntryUnmarshal(b []byte, entry *KVNSEntry) error + func LivenessCheckHandler(w http.ResponseWriter, r *http.Request) + func Load(configFile string, data interface{}) (quick.Config, error) + func Main(args []string) + func NewCustomHTTPTransport() *http.Transport + func NewLockRPCServer() (*xrpc.Server, error) + func ParseGatewayEndpoint(arg string) (endPoint string, secure bool, err error) + func ParseSSECopyCustomerRequest(h http.Header, metadata map[string]string) (key []byte, err error) + func ParseSSECustomerHeader(header http.Header) (key []byte, err error) + func ParseSSECustomerRequest(r *http.Request) (key []byte, err error) + func PolicyToBucketAccessPolicy(bucketPolicy *policy.Policy) (*miniogopolicy.BucketAccessPolicy, error) + func ReadinessCheckHandler(w http.ResponseWriter, r *http.Request) + func RegisterGatewayCommand(cmd cli.Command) error + func RemoveListener(objAPI ObjectLayer, bucketName string, targetID event.TargetID, addr xnet.Host) error + func Save(configFile string, data interface{}) error + func SaveListener(objAPI ObjectLayer, bucketName string, eventNames []event.Name, pattern string, ...) error + func StartGateway(ctx *cli.Context, gw Gateway) + func StorageReader(storage StorageAPI, volume, path string, offset int64) io.Reader + func StorageWriter(storage StorageAPI, volume, path string) io.Writer + func ToMinioClientCompletePart(part CompletePart) minio.CompletePart + func ToMinioClientCompleteParts(parts []CompletePart) []minio.CompletePart + func ToMinioClientMetadata(metadata map[string]string) map[string]string + func ToMinioClientObjectInfoMetadata(metadata map[string]string) map[string][]string + func ToS3ETag(etag string) string + func UTCNow() time.Time + func ValidateGatewayArguments(serverAddr, endpointAddr string) error + type APIError struct + Code string + Description string + HTTPStatusCode int + type APIErrorCode int + const ErrARNNotification + const ErrAccessDenied + const ErrAddUserInvalidArgument + const ErrAdminConfigBadJSON + const ErrAdminConfigDuplicateKeys + const ErrAdminConfigNoQuorum + const ErrAdminConfigNotificationTargetsFailed + const ErrAdminConfigTooLarge + const ErrAdminCredentialsMismatch + const ErrAdminInvalidAccessKey + const ErrAdminInvalidArgument + const ErrAdminInvalidSecretKey + const ErrAdminNoSuchPolicy + const ErrAdminNoSuchUser + const ErrAdminProfilerNotEnabled + const ErrAllAccessDisabled + const ErrAuthHeaderEmpty + const ErrAuthorizationHeaderMalformed + const ErrBackendDown + const ErrBadDigest + const ErrBadRequest + const ErrBucketAlreadyExists + const ErrBucketAlreadyOwnedByYou + const ErrBucketNotEmpty + const ErrBusy + const ErrCastFailed + const ErrContentSHA256Mismatch + const ErrCredMalformed + const ErrEmptyRequestBody + const ErrEntityTooLarge + const ErrEntityTooSmall + const ErrEvaluatorBindingDoesNotExist + const ErrEvaluatorInvalidArguments + const ErrEvaluatorInvalidTimestampFormatPattern + const ErrEvaluatorInvalidTimestampFormatPatternSymbol + const ErrEvaluatorInvalidTimestampFormatPatternSymbolForParsing + const ErrEvaluatorInvalidTimestampFormatPatternToken + const ErrEvaluatorTimestampFormatPatternDuplicateFields + const ErrEvaluatorTimestampFormatPatternHourClockAmPmMismatch + const ErrEvaluatorUnterminatedTimestampFormatPatternToken + const ErrEventNotification + const ErrExpiredPresignRequest + const ErrExpressionTooLong + const ErrFilterNameInvalid + const ErrFilterNamePrefix + const ErrFilterNameSuffix + const ErrFilterValueInvalid + const ErrHealAlreadyRunning + const ErrHealInvalidClientToken + const ErrHealMissingBucket + const ErrHealNoSuchProcess + const ErrHealNotImplemented + const ErrHealOverlappingPaths + const ErrIllegalSQLFunctionArgument + const ErrIncompatibleEncryptionMethod + const ErrIncompleteBody + const ErrIncorrectContinuationToken + const ErrIncorrectSQLFunctionArgumentType + const ErrInsecureClientRequest + const ErrInsecureSSECustomerRequest + const ErrIntegerOverflow + const ErrInternalError + const ErrInvalidAccessKeyID + const ErrInvalidBucketName + const ErrInvalidCast + const ErrInvalidColumnIndex + const ErrInvalidCompressionFormat + const ErrInvalidCopyDest + const ErrInvalidCopyPartRange + const ErrInvalidCopyPartRangeSource + const ErrInvalidCopySource + const ErrInvalidDataSource + const ErrInvalidDataType + const ErrInvalidDecompressedSize + const ErrInvalidDigest + const ErrInvalidDuration + const ErrInvalidEncodingMethod + const ErrInvalidEncryptionMethod + const ErrInvalidEncryptionParameters + const ErrInvalidExpressionType + const ErrInvalidFileHeaderInfo + const ErrInvalidJSONType + const ErrInvalidKeyPath + const ErrInvalidMaxKeys + const ErrInvalidMaxParts + const ErrInvalidMaxUploads + const ErrInvalidMetadataDirective + const ErrInvalidObjectName + const ErrInvalidObjectState + const ErrInvalidPart + const ErrInvalidPartNumberMarker + const ErrInvalidPartOrder + const ErrInvalidPolicyDocument + const ErrInvalidPrefixMarker + const ErrInvalidQueryParams + const ErrInvalidQuerySignatureAlgo + const ErrInvalidQuoteFields + const ErrInvalidRange + const ErrInvalidRegion + const ErrInvalidRequest + const ErrInvalidRequestBody + const ErrInvalidRequestParameter + const ErrInvalidRequestVersion + const ErrInvalidResourceName + const ErrInvalidSSECustomerAlgorithm + const ErrInvalidSSECustomerKey + const ErrInvalidSSECustomerParameters + const ErrInvalidService + const ErrInvalidStorageClass + const ErrInvalidTableAlias + const ErrInvalidTextEncoding + const ErrInvalidToken + const ErrKMSAuthFailure + const ErrKMSNotConfigured + const ErrLexerInvalidChar + const ErrLexerInvalidIONLiteral + const ErrLexerInvalidLiteral + const ErrLexerInvalidOperator + const ErrLikeInvalidInputs + const ErrMalformedCredentialDate + const ErrMalformedCredentialRegion + const ErrMalformedDate + const ErrMalformedExpires + const ErrMalformedJSON + const ErrMalformedPOSTRequest + const ErrMalformedPolicy + const ErrMalformedPresignedDate + const ErrMalformedXML + const ErrMaximumExpires + const ErrMetadataTooLarge + const ErrMethodNotAllowed + const ErrMissingContentLength + const ErrMissingContentMD5 + const ErrMissingCredTag + const ErrMissingDateHeader + const ErrMissingFields + const ErrMissingHeaders + const ErrMissingRequestBodyError + const ErrMissingRequiredParameter + const ErrMissingSSECustomerKey + const ErrMissingSSECustomerKeyMD5 + const ErrMissingSignHeadersTag + const ErrMissingSignTag + const ErrNegativeExpires + const ErrNoAccessKey + const ErrNoSuchBucket + const ErrNoSuchBucketPolicy + const ErrNoSuchKey + const ErrNoSuchUpload + const ErrNoSuchVersion + const ErrNone + const ErrNotImplemented + const ErrObjectExistsAsDirectory + const ErrObjectSerializationConflict + const ErrObjectTampered + const ErrOperationTimedOut + const ErrOverlappingConfigs + const ErrOverlappingFilterNotification + const ErrPOSTFileRequired + const ErrParseAsteriskIsNotAloneInSelectList + const ErrParseCannotMixSqbAndWildcardInSelectList + const ErrParseCastArity + const ErrParseEmptySelect + const ErrParseExpected2TokenTypes + const ErrParseExpectedArgumentDelimiter + const ErrParseExpectedDatePart + const ErrParseExpectedExpression + const ErrParseExpectedIdentForAlias + const ErrParseExpectedIdentForAt + const ErrParseExpectedIdentForGroupName + const ErrParseExpectedKeyword + const ErrParseExpectedLeftParenAfterCast + const ErrParseExpectedLeftParenBuiltinFunctionCall + const ErrParseExpectedLeftParenValueConstructor + const ErrParseExpectedMember + const ErrParseExpectedNumber + const ErrParseExpectedRightParenBuiltinFunctionCall + const ErrParseExpectedTokenType + const ErrParseExpectedTypeName + const ErrParseExpectedWhenClause + const ErrParseInvalidContextForWildcardInSelectList + const ErrParseInvalidTypeParam + const ErrParseMalformedJoin + const ErrParseMissingIdentAfterAt + const ErrParseNonUnaryAgregateFunctionCall + const ErrParseSelectMissingFrom + const ErrParseUnexpectedKeyword + const ErrParseUnexpectedOperator + const ErrParseUnexpectedTerm + const ErrParseUnexpectedToken + const ErrParseUnknownOperator + const ErrParseUnsupportedAlias + const ErrParseUnsupportedCallWithStar + const ErrParseUnsupportedCase + const ErrParseUnsupportedCaseClause + const ErrParseUnsupportedLiteralsGroupBy + const ErrParseUnsupportedSelect + const ErrParseUnsupportedSyntax + const ErrParseUnsupportedToken + const ErrPolicyNesting + const ErrPreconditionFailed + const ErrReadQuorum + const ErrRegionNotification + const ErrRequestBodyParse + const ErrRequestNotReadyYet + const ErrRequestTimeTooSkewed + const ErrSSECustomerKeyMD5Mismatch + const ErrSSEEncryptedObject + const ErrSSEMultipartEncrypted + const ErrServerNotInitialized + const ErrSignatureDoesNotMatch + const ErrSignatureVersionNotSupported + const ErrSlowDown + const ErrStorageFull + const ErrUnauthorizedAccess + const ErrUnsignedHeaders + const ErrUnsupportedFunction + const ErrUnsupportedMetadata + const ErrUnsupportedNotification + const ErrUnsupportedRangeHeader + const ErrUnsupportedSQLOperation + const ErrUnsupportedSQLStructure + const ErrUnsupportedSyntax + const ErrValueParseFailure + const ErrWriteQuorum + func DecryptCopyObjectInfo(info *ObjectInfo, headers http.Header) (errCode APIErrorCode, encrypted bool) + type APIErrorResponse struct + BucketName string + Code string + HostID string + Key string + Message string + RequestID string + Resource string + XMLName xml.Name + type AllAccessDisabled GenericError + func (e AllAccessDisabled) Error() string + type AssumeRoleResponse struct + ResponseMetadata struct{ ... } + Result AssumeRoleResult + XMLName xml.Name + type AssumeRoleResult struct + AssumedRoleUser AssumedRoleUser + Credentials auth.Credentials + PackedPolicySize int + type AssumeRoleWithClientGrantsResponse struct + ResponseMetadata struct{ ... } + Result ClientGrantsResult + XMLName xml.Name + type AssumeRoleWithWebIdentityResponse struct + ResponseMetadata struct{ ... } + Result WebIdentityResult + XMLName xml.Name + type AssumedRoleUser struct + Arn string + AssumedRoleID string + type AuthArgs struct + RPCVersion RPCVersion + RequestTime time.Time + Token string + func (args *AuthArgs) SetAuthArgs(authArgs AuthArgs) + func (args AuthArgs) Authenticate() error + type BackendDown struct + func (e BackendDown) Error() string + type BackendType int + const BackendErasure + const BackendFS + const Unknown + type BitrotAlgorithm uint + const BLAKE2b512 + const HighwayHash256 + const HighwayHash256S + const SHA256 + func BitrotAlgorithmFromString(s string) (a BitrotAlgorithm) + func (a BitrotAlgorithm) Available() bool + func (a BitrotAlgorithm) New() hash.Hash + func (a BitrotAlgorithm) String() string + type BitrotVerifier struct + func NewBitrotVerifier(algorithm BitrotAlgorithm, checksum []byte) *BitrotVerifier + type BoolFlag bool + func ParseBoolFlag(s string) (bf BoolFlag, err error) + func (bf *BoolFlag) UnmarshalJSON(data []byte) (err error) + func (bf BoolFlag) MarshalJSON() ([]byte, error) + func (bf BoolFlag) String() string + type Bucket struct + CreationDate string + Name string + type BucketAccessPolicy struct + Bucket string + Policy miniogopolicy.BucketPolicy + Prefix string + type BucketAlreadyExists GenericError + func (e BucketAlreadyExists) Error() string + type BucketAlreadyOwnedByYou GenericError + func (e BucketAlreadyOwnedByYou) Error() string + type BucketExists GenericError + func (e BucketExists) Error() string + type BucketInfo struct + Created time.Time + Name string + type BucketNameInvalid GenericError + func (e BucketNameInvalid) Error() string + type BucketNotEmpty GenericError + func (e BucketNotEmpty) Error() string + type BucketNotFound GenericError + func (e BucketNotFound) Error() string + type BucketPolicyNotFound GenericError + func (e BucketPolicyNotFound) Error() string + type CacheConfig struct + Drives []string + Exclude []string + Expiry int + MaxUse int + func (cfg *CacheConfig) UnmarshalJSON(data []byte) (err error) + type CacheObjectLayer interface + AbortMultipartUpload func(ctx context.Context, bucket, object, uploadID string) error + CompleteMultipartUpload func(ctx context.Context, bucket, object, uploadID string, ...) (objInfo ObjectInfo, err error) + DeleteBucket func(ctx context.Context, bucket string) error + DeleteObject func(ctx context.Context, bucket, object string) error + GetBucketInfo func(ctx context.Context, bucket string) (bucketInfo BucketInfo, err error) + GetObject func(ctx context.Context, bucket, object string, startOffset int64, length int64, ...) (err error) + GetObjectInfo func(ctx context.Context, bucket, object string, opts ObjectOptions) (objInfo ObjectInfo, err error) + GetObjectNInfo func(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, ...) (gr *GetObjectReader, err error) + ListBuckets func(ctx context.Context) (buckets []BucketInfo, err error) + ListObjects func(ctx context.Context, bucket, prefix, marker, delimiter string, maxKeys int) (result ListObjectsInfo, err error) + ListObjectsV2 func(ctx context.Context, bucket, prefix, continuationToken, delimiter string, ...) (result ListObjectsV2Info, err error) + NewMultipartUpload func(ctx context.Context, bucket, object string, opts ObjectOptions) (uploadID string, err error) + PutObject func(ctx context.Context, bucket, object string, data *PutObjReader, ...) (objInfo ObjectInfo, err error) + PutObjectPart func(ctx context.Context, bucket, object, uploadID string, partID int, ...) (info PartInfo, err error) + StorageInfo func(ctx context.Context) CacheStorageInfo + type CacheStorageInfo struct + Free uint64 + Total uint64 + type CheckCopyPreconditionFn func(o ObjectInfo, encETag string) bool + type ChecksumInfo struct + Algorithm BitrotAlgorithm + Hash []byte + Name string + func (c *ChecksumInfo) UnmarshalJSON(data []byte) error + func (c ChecksumInfo) MarshalJSON() ([]byte, error) + type ClientGrantsResult struct + AssumedRoleUser AssumedRoleUser + Audience string + Credentials auth.Credentials + PackedPolicySize int + Provider string + SubjectFromToken string + type CommonPrefix struct + Prefix string + type CompleteMultipartUpload struct + Parts []CompletePart + type CompleteMultipartUploadResponse struct + Bucket string + ETag string + Key string + Location string + XMLName xml.Name + type CompletePart struct + ETag string + PartNumber int + type CompletedParts []CompletePart + func (a CompletedParts) Len() int + func (a CompletedParts) Less(i, j int) bool + func (a CompletedParts) Swap(i, j int) + type ConfigDir struct + func (dir *ConfigDir) Get() string + type ConfigSys struct + func NewConfigSys() *ConfigSys + func (sys *ConfigSys) Init(objAPI ObjectLayer) error + func (sys *ConfigSys) Load(objAPI ObjectLayer) error + type ConnStats struct + type ConsoleLogger struct + Enable bool + type CopyObjectPartResponse struct + ETag string + LastModified string + XMLName xml.Name + type CopyObjectResponse struct + ETag string + LastModified string + XMLName xml.Name + type DecryptBlocksReader struct + func (d *DecryptBlocksReader) Read(p []byte) (int, error) + type DecryptBlocksWriter struct + func (w *DecryptBlocksWriter) Close() error + func (w *DecryptBlocksWriter) Write(p []byte) (int, error) + type DeleteError struct + Code string + Key string + Message string + type DeleteObjectsRequest struct + Objects []ObjectIdentifier + Quiet bool + type DeleteObjectsResponse struct + DeletedObjects []ObjectIdentifier + Errors []DeleteError + XMLName xml.Name + type DiskInfo struct + Free uint64 + RootDisk bool + Total uint64 + Used uint64 + type DownloadZipArgs struct + BucketName string + Objects []string + Prefix string + type Endpoint struct + IsLocal bool + SetIndex int + func NewEndpoint(arg string) (ep Endpoint, e error) + func (endpoint Endpoint) IsHTTPS() bool + func (endpoint Endpoint) String() string + func (endpoint Endpoint) Type() EndpointType + type EndpointList []Endpoint + func NewEndpointList(args ...string) (endpoints EndpointList, err error) + func (endpoints EndpointList) GetString(i int) string + func (endpoints EndpointList) IsHTTPS() bool + func (endpoints EndpointList) Nodes() int + type EndpointType int + const PathEndpointType + const URLEndpointType + type Erasure struct + func NewErasure(ctx context.Context, dataBlocks, parityBlocks int, blockSize int64) (e Erasure, err error) + func (e *Erasure) DecodeDataAndParityBlocks(ctx context.Context, data [][]byte) error + func (e *Erasure) DecodeDataBlocks(data [][]byte) error + func (e *Erasure) Encode(ctx context.Context, src io.Reader, writers []io.Writer, buf []byte, ...) (total int64, err error) + func (e *Erasure) EncodeData(ctx context.Context, data []byte) ([][]byte, error) + func (e *Erasure) ShardFileSize(totalLength int64) int64 + func (e *Erasure) ShardFileTillOffset(startOffset, length, totalLength int64) int64 + func (e *Erasure) ShardSize() int64 + func (e Erasure) Decode(ctx context.Context, writer io.Writer, readers []io.ReaderAt, ...) error + func (e Erasure) Heal(ctx context.Context, readers []io.ReaderAt, writers []io.Writer, size int64) error + type ErasureInfo struct + Algorithm string + BlockSize int64 + Checksums []ChecksumInfo + DataBlocks int + Distribution []int + Index int + ParityBlocks int + func (e *ErasureInfo) AddChecksumInfo(ckSumInfo ChecksumInfo) + func (e ErasureInfo) GetChecksumInfo(partName string) (ckSum ChecksumInfo) + type FSChecksumInfoV1 struct + Algorithm string + Blocksize int64 + Hashes [][]byte + func (c *FSChecksumInfoV1) UnmarshalJSON(data []byte) error + func (c FSChecksumInfoV1) MarshalJSON() ([]byte, error) + type FSObjects struct + func (fs *FSObjects) AbortMultipartUpload(ctx context.Context, bucket, object, uploadID string) error + func (fs *FSObjects) CompleteMultipartUpload(ctx context.Context, bucket string, object string, uploadID string, ...) (oi ObjectInfo, e error) + func (fs *FSObjects) CopyObject(ctx context.Context, srcBucket, srcObject, dstBucket, dstObject string, ...) (oi ObjectInfo, e error) + func (fs *FSObjects) CopyObjectPart(ctx context.Context, ...) (pi PartInfo, e error) + func (fs *FSObjects) DeleteBucket(ctx context.Context, bucket string) error + func (fs *FSObjects) DeleteBucketPolicy(ctx context.Context, bucket string) error + func (fs *FSObjects) DeleteObject(ctx context.Context, bucket, object string) error + func (fs *FSObjects) GetBucketInfo(ctx context.Context, bucket string) (bi BucketInfo, e error) + func (fs *FSObjects) GetBucketPolicy(ctx context.Context, bucket string) (*policy.Policy, error) + func (fs *FSObjects) GetObject(ctx context.Context, bucket, object string, offset int64, length int64, ...) (err error) + func (fs *FSObjects) GetObjectInfo(ctx context.Context, bucket, object string, opts ObjectOptions) (oi ObjectInfo, e error) + func (fs *FSObjects) GetObjectNInfo(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, ...) (gr *GetObjectReader, err error) + func (fs *FSObjects) HealBucket(ctx context.Context, bucket string, dryRun, remove bool) (madmin.HealResultItem, error) + func (fs *FSObjects) HealFormat(ctx context.Context, dryRun bool) (madmin.HealResultItem, error) + func (fs *FSObjects) HealObject(ctx context.Context, bucket, object string, dryRun, remove bool, ...) (res madmin.HealResultItem, err error) + func (fs *FSObjects) HealObjects(ctx context.Context, bucket, prefix string, fn func(string, string) error) (e error) + func (fs *FSObjects) IsCompressionSupported() bool + func (fs *FSObjects) IsEncryptionSupported() bool + func (fs *FSObjects) IsListenBucketSupported() bool + func (fs *FSObjects) IsNotificationSupported() bool + func (fs *FSObjects) ListBuckets(ctx context.Context) ([]BucketInfo, error) + func (fs *FSObjects) ListBucketsHeal(ctx context.Context) ([]BucketInfo, error) + func (fs *FSObjects) ListMultipartUploads(ctx context.Context, ...) (result ListMultipartsInfo, e error) + func (fs *FSObjects) ListObjectParts(ctx context.Context, bucket, object, uploadID string, ...) (result ListPartsInfo, e error) + func (fs *FSObjects) ListObjects(ctx context.Context, bucket, prefix, marker, delimiter string, maxKeys int) (loi ListObjectsInfo, e error) + func (fs *FSObjects) ListObjectsV2(ctx context.Context, bucket, prefix, continuationToken, delimiter string, ...) (result ListObjectsV2Info, err error) + func (fs *FSObjects) MakeBucketWithLocation(ctx context.Context, bucket, location string) error + func (fs *FSObjects) NewMultipartUpload(ctx context.Context, bucket, object string, opts ObjectOptions) (string, error) + func (fs *FSObjects) PutObject(ctx context.Context, bucket string, object string, r *PutObjReader, ...) (objInfo ObjectInfo, retErr error) + func (fs *FSObjects) PutObjectPart(ctx context.Context, bucket, object, uploadID string, partID int, ...) (pi PartInfo, e error) + func (fs *FSObjects) ReloadFormat(ctx context.Context, dryRun bool) error + func (fs *FSObjects) SetBucketPolicy(ctx context.Context, bucket string, policy *policy.Policy) error + func (fs *FSObjects) Shutdown(ctx context.Context) error + func (fs *FSObjects) StorageInfo(ctx context.Context) StorageInfo + type FileInfo struct + ModTime time.Time + Mode os.FileMode + Name string + Size int64 + Volume string + type FileLogger struct + Enable bool + Filename string + type Gateway interface + Name func() string + NewGatewayLayer func(creds auth.Credentials) (ObjectLayer, error) + Production func() bool + type GatewayUnsupported struct + func (a GatewayUnsupported) AbortMultipartUpload(ctx context.Context, bucket string, object string, uploadID string) error + func (a GatewayUnsupported) CompleteMultipartUpload(ctx context.Context, bucket string, object string, uploadID string, ...) (oi ObjectInfo, err error) + func (a GatewayUnsupported) CopyObject(ctx context.Context, srcBucket string, srcObject string, destBucket string, ...) (objInfo ObjectInfo, err error) + func (a GatewayUnsupported) CopyObjectPart(ctx context.Context, ...) (pi PartInfo, err error) + func (a GatewayUnsupported) DeleteBucketPolicy(ctx context.Context, bucket string) error + func (a GatewayUnsupported) GetBucketPolicy(ctx context.Context, bucket string) (bucketPolicy *policy.Policy, err error) + func (a GatewayUnsupported) HealBucket(ctx context.Context, bucket string, dryRun, remove bool) (madmin.HealResultItem, error) + func (a GatewayUnsupported) HealFormat(ctx context.Context, dryRun bool) (madmin.HealResultItem, error) + func (a GatewayUnsupported) HealObject(ctx context.Context, bucket, object string, dryRun, remove bool, ...) (h madmin.HealResultItem, e error) + func (a GatewayUnsupported) HealObjects(ctx context.Context, bucket, prefix string, fn func(string, string) error) (e error) + func (a GatewayUnsupported) IsCompressionSupported() bool + func (a GatewayUnsupported) IsEncryptionSupported() bool + func (a GatewayUnsupported) IsListenBucketSupported() bool + func (a GatewayUnsupported) IsNotificationSupported() bool + func (a GatewayUnsupported) ListBucketsHeal(ctx context.Context) (buckets []BucketInfo, err error) + func (a GatewayUnsupported) ListMultipartUploads(ctx context.Context, bucket string, prefix string, keyMarker string, ...) (lmi ListMultipartsInfo, err error) + func (a GatewayUnsupported) ListObjectParts(ctx context.Context, bucket string, object string, uploadID string, ...) (lpi ListPartsInfo, err error) + func (a GatewayUnsupported) ListObjectsV2(ctx context.Context, bucket, prefix, continuationToken, delimiter string, ...) (result ListObjectsV2Info, err error) + func (a GatewayUnsupported) NewMultipartUpload(ctx context.Context, bucket string, object string, opts ObjectOptions) (uploadID string, err error) + func (a GatewayUnsupported) PutObjectPart(ctx context.Context, bucket string, object string, uploadID string, partID int, ...) (pi PartInfo, err error) + func (a GatewayUnsupported) RefreshBucketPolicy(ctx context.Context, bucket string) error + func (a GatewayUnsupported) ReloadFormat(ctx context.Context, dryRun bool) error + func (a GatewayUnsupported) SetBucketPolicy(ctx context.Context, bucket string, bucketPolicy *policy.Policy) error + type GenerateAuthReply struct + AccessKey string + SecretKey string + UIVersion string + type GenericError struct + Bucket string + Object string + type GetAuthReply struct + AccessKey string + SecretKey string + UIVersion string + type GetBucketPolicyArgs struct + BucketName string + Prefix string + type GetBucketPolicyRep struct + Policy miniogopolicy.BucketPolicy + UIVersion string + type GetLocksResp map[string][]lockRequesterInfo + type GetObjectReader struct + ObjInfo ObjectInfo + func NewGetObjectReaderFromReader(r io.Reader, oi ObjectInfo, pcfn CheckCopyPreconditionFn, cleanupFns ...func()) (*GetObjectReader, error) + func (g *GetObjectReader) Close() error + func (g *GetObjectReader) Read(p []byte) (n int, err error) + type HTTPMethodStats struct + Counter atomic.Uint64 + Duration atomic.Float64 + type HTTPRangeSpec struct + End int64 + IsSuffixLength bool + Start int64 + func (h *HTTPRangeSpec) GetLength(resourceSize int64) (rangeLength int64, err error) + func (h *HTTPRangeSpec) GetOffsetLength(resourceSize int64) (start, length int64, err error) + type HTTPStats struct + type HandlerFunc func(http.Handler) http.Handler + type IAMSys struct + func NewIAMSys() *IAMSys + func (sys *IAMSys) DeleteCannedPolicy(policyName string) error + func (sys *IAMSys) DeleteUser(accessKey string) error + func (sys *IAMSys) GetUser(accessKey string) (cred auth.Credentials, ok bool) + func (sys *IAMSys) GetUserPolicy(accessKey string) (policyName string, err error) + func (sys *IAMSys) Init(objAPI ObjectLayer) error + func (sys *IAMSys) IsAllowed(args iampolicy.Args) bool + func (sys *IAMSys) ListCannedPolicies() (map[string][]byte, error) + func (sys *IAMSys) ListUsers() (map[string]madmin.UserInfo, error) + func (sys *IAMSys) Load(objAPI ObjectLayer) error + func (sys *IAMSys) SetCannedPolicy(policyName string, p iampolicy.Policy) error + func (sys *IAMSys) SetTempUser(accessKey string, cred auth.Credentials, policyName string) error + func (sys *IAMSys) SetUser(accessKey string, uinfo madmin.UserInfo) error + func (sys *IAMSys) SetUserPolicy(accessKey, policyName string) error + func (sys *IAMSys) SetUserStatus(accessKey string, status madmin.AccountStatus) error + type IncompleteBody GenericError + func (e IncompleteBody) Error() string + type InitiateMultipartUploadResponse struct + Bucket string + Key string + UploadID string + XMLName xml.Name + type Initiator Owner + type InsufficientReadQuorum struct + func (e InsufficientReadQuorum) Error() string + type InsufficientWriteQuorum struct + func (e InsufficientWriteQuorum) Error() string + type InvalidETag struct + func (e InvalidETag) Error() string + type InvalidMarkerPrefixCombination struct + Marker string + Prefix string + func (e InvalidMarkerPrefixCombination) Error() string + type InvalidPart struct + ExpETag string + GotETag string + PartNumber int + func (e InvalidPart) Error() string + type InvalidRange struct + OffsetBegin int64 + OffsetEnd int64 + ResourceSize int64 + func (e InvalidRange) Error() string + type InvalidUploadID struct + UploadID string + func (e InvalidUploadID) Error() string + type InvalidUploadIDKeyCombination struct + KeyMarker string + UploadIDMarker string + func (e InvalidUploadIDKeyCombination) Error() string + type KV struct + func (k *KV) Delete(keyStr string) error + func (k *KV) DiskInfo() (DiskInfo, error) + func (k *KV) Get(keyStr string, value []byte) ([]byte, error) + func (k *KV) List(keyStr string, b []byte) ([]string, error) + func (k *KV) Put(keyStr string, value []byte) error + func (k *KV) UpdateStats() error + type KVEmulator struct + func (k *KVEmulator) Delete(keyStr string) error + func (k *KVEmulator) DiskInfo() (DiskInfo, error) + func (k *KVEmulator) Get(keyStr string, value []byte) ([]byte, error) + func (k *KVEmulator) List(prefix string, buf []byte) ([]string, error) + func (k *KVEmulator) Put(keyStr string, value []byte) error + func (k *KVEmulator) UpdateStats() error + type KVInterface interface + Delete func(keyStr string) error + DiskInfo func() (DiskInfo, error) + Get func(keyStr string, value []byte) ([]byte, error) + List func(prefix string, buf []byte) ([]string, error) + Put func(keyStr string, value []byte) error + UpdateStats func() error + type KVNSEntry struct + IDs []string + Key string + ModTime time.Time + Size int64 + type KVStorage struct + func (k *KVStorage) AppendFile(volume string, path string, buf []byte) (err error) + func (k *KVStorage) Close() error + func (k *KVStorage) CreateDir(volume, dirPath string) error + func (k *KVStorage) CreateFile(volume, filePath string, size int64, reader io.Reader) error + func (k *KVStorage) DataKey(id string) string + func (k *KVStorage) DeleteDir(volume, dirPath string) error + func (k *KVStorage) DeleteFile(volume string, path string) (err error) + func (k *KVStorage) DeleteVol(volume string) (err error) + func (k *KVStorage) DiskInfo() (info DiskInfo, err error) + func (k *KVStorage) IsOnline() bool + func (k *KVStorage) LastError() error + func (k *KVStorage) ListDir(volume, dirPath string, count int) ([]string, error) + func (k *KVStorage) ListDirForRename(volume, dirPath string, count int) ([]string, error) + func (k *KVStorage) ListVols() (vols []VolInfo, err error) + func (k *KVStorage) MakeVol(volume string) (err error) + func (k *KVStorage) ReadAll(volume string, filePath string) (buf []byte, err error) + func (k *KVStorage) ReadAndCopy(volume string, filePath string, writer io.Writer) (err error) + func (k *KVStorage) ReadFile(volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error) + func (k *KVStorage) ReadFileStream(volume, filePath string, offset, length int64) (io.ReadCloser, error) + func (k *KVStorage) RenameFile(srcVolume, srcPath, dstVolume, dstPath string) error + func (k *KVStorage) StatDir(volume, dirPath string) error + func (k *KVStorage) StatFile(volume string, path string) (fi FileInfo, err error) + func (k *KVStorage) StatVol(volume string) (vol VolInfo, err error) + func (k *KVStorage) String() string + func (k *KVStorage) SyncVolumes() (err error) + func (k *KVStorage) UpdateStats() error + func (k *KVStorage) WriteAll(volume string, filePath string, buf []byte) (err error) + type ListAllBucketPoliciesArgs struct + BucketName string + type ListAllBucketPoliciesRep struct + Policies []BucketAccessPolicy + UIVersion string + type ListBucketsRep struct + Buckets []WebBucketInfo + UIVersion string + type ListBucketsResponse struct + Buckets struct{ ... } + Owner Owner + XMLName xml.Name + type ListMultipartUploadsResponse struct + Bucket string + CommonPrefixes []CommonPrefix + Delimiter string + EncodingType string + IsTruncated bool + KeyMarker string + MaxUploads int + NextKeyMarker string + NextUploadIDMarker string + Prefix string + UploadIDMarker string + Uploads []Upload + XMLName xml.Name + type ListMultipartsInfo struct + CommonPrefixes []string + Delimiter string + EncodingType string + IsTruncated bool + KeyMarker string + MaxUploads int + NextKeyMarker string + NextUploadIDMarker string + Prefix string + UploadIDMarker string + Uploads []MultipartInfo + func FromMinioClientListMultipartsInfo(lmur minio.ListMultipartUploadsResult) ListMultipartsInfo + type ListObjectsArgs struct + BucketName string + Marker string + Prefix string + type ListObjectsInfo struct + IsTruncated bool + NextMarker string + Objects []ObjectInfo + Prefixes []string + func FromMinioClientListBucketResult(bucket string, result minio.ListBucketResult) ListObjectsInfo + type ListObjectsRep struct + IsTruncated bool + NextMarker string + Objects []WebObjectInfo + UIVersion string + Writable bool + type ListObjectsResponse struct + CommonPrefixes []CommonPrefix + Contents []Object + Delimiter string + EncodingType string + IsTruncated bool + Marker string + MaxKeys int + Name string + NextMarker string + Prefix string + XMLName xml.Name + type ListObjectsV2Info struct + ContinuationToken string + IsTruncated bool + NextContinuationToken string + Objects []ObjectInfo + Prefixes []string + func FromMinioClientListBucketResultToV2Info(bucket string, result minio.ListBucketResult) ListObjectsV2Info + func FromMinioClientListBucketV2Result(bucket string, result minio.ListBucketV2Result) ListObjectsV2Info + type ListObjectsV2Response struct + CommonPrefixes []CommonPrefix + Contents []Object + ContinuationToken string + Delimiter string + EncodingType string + IsTruncated bool + KeyCount int + MaxKeys int + Name string + NextContinuationToken string + Prefix string + StartAfter string + XMLName xml.Name + type ListPartsInfo struct + Bucket string + EncodingType string + IsTruncated bool + MaxParts int + NextPartNumberMarker int + Object string + PartNumberMarker int + Parts []PartInfo + StorageClass string + UploadID string + UserDefined map[string]string + func FromMinioClientListPartsInfo(lopr minio.ListObjectPartsResult) ListPartsInfo + type ListPartsResponse struct + Bucket string + Initiator Initiator + IsTruncated bool + Key string + MaxParts int + NextPartNumberMarker int + Owner Owner + PartNumberMarker int + Parts []Part + StorageClass string + UploadID string + XMLName xml.Name + type ListenBucketNotificationArgs struct + Addr xnet.Host + BucketName string + EventNames []event.Name + Pattern string + TargetID event.TargetID + type LocationResponse struct + Location string + XMLName xml.Name + type LockArgs struct + LockArgs dsync.LockArgs + type LockRPCClient struct + func NewLockRPCClient(host *xnet.Host) (*LockRPCClient, error) + func (lockRPC *LockRPCClient) Expired(args dsync.LockArgs) (reply bool, err error) + func (lockRPC *LockRPCClient) ForceUnlock(args dsync.LockArgs) (reply bool, err error) + func (lockRPC *LockRPCClient) Lock(args dsync.LockArgs) (reply bool, err error) + func (lockRPC *LockRPCClient) RLock(args dsync.LockArgs) (reply bool, err error) + func (lockRPC *LockRPCClient) RUnlock(args dsync.LockArgs) (reply bool, err error) + func (lockRPC *LockRPCClient) ServerAddr() string + func (lockRPC *LockRPCClient) ServiceEndpoint() string + func (lockRPC *LockRPCClient) Unlock(args dsync.LockArgs) (reply bool, err error) + type LockType int + type LoginArgs struct + Password string + Username string + type LoginRep struct + Token string + UIVersion string + type MakeBucketArgs struct + BucketName string + type MalformedUploadID struct + UploadID string + func (e MalformedUploadID) Error() string + type MultipartInfo struct + Initiated time.Time + Object string + StorageClass string + UploadID string + type NotImplemented struct + func (e NotImplemented) Error() string + type NotificationGroup struct + func WithNPeers(nerrs int) *NotificationGroup + func (g *NotificationGroup) Go(ctx context.Context, f func() error, index int, addr xnet.Host) + func (g *NotificationGroup) Wait() []NotificationPeerErr + type NotificationPeerErr struct + Err error + Host xnet.Host + type NotificationSys struct + func NewNotificationSys(config *serverConfig, endpoints EndpointList) *NotificationSys + func (sys *NotificationSys) AddRemoteTarget(bucketName string, target event.Target, rulesMap event.RulesMap) error + func (sys *NotificationSys) AddRulesMap(bucketName string, rulesMap event.RulesMap) + func (sys *NotificationSys) CPULoadInfo() []ServerCPULoadInfo + func (sys *NotificationSys) DeleteBucket(ctx context.Context, bucketName string) + func (sys *NotificationSys) DownloadProfilingData(ctx context.Context, writer io.Writer) bool + func (sys *NotificationSys) DrivePerfInfo() []ServerDrivesPerfInfo + func (sys *NotificationSys) GetARNList() []string + func (sys *NotificationSys) GetLocks(ctx context.Context) []*PeerLocks + func (sys *NotificationSys) Init(objAPI ObjectLayer) error + func (sys *NotificationSys) ListenBucketNotification(ctx context.Context, bucketName string, eventNames []event.Name, ...) + func (sys *NotificationSys) LoadCredentials() []NotificationPeerErr + func (sys *NotificationSys) LoadUsers() []NotificationPeerErr + func (sys *NotificationSys) MemUsageInfo() []ServerMemUsageInfo + func (sys *NotificationSys) PutBucketNotification(ctx context.Context, bucketName string, rulesMap event.RulesMap) + func (sys *NotificationSys) ReloadFormat(dryRun bool) []NotificationPeerErr + func (sys *NotificationSys) RemoteTargetExist(bucketName string, targetID event.TargetID) bool + func (sys *NotificationSys) RemoveAllRemoteTargets() + func (sys *NotificationSys) RemoveBucketPolicy(ctx context.Context, bucketName string) + func (sys *NotificationSys) RemoveNotification(bucketName string) + func (sys *NotificationSys) RemoveRemoteTarget(bucketName string, targetID event.TargetID) + func (sys *NotificationSys) RemoveRulesMap(bucketName string, rulesMap event.RulesMap) + func (sys *NotificationSys) Send(args eventArgs) []event.TargetIDErr + func (sys *NotificationSys) ServerInfo(ctx context.Context) []ServerInfo + func (sys *NotificationSys) SetBucketPolicy(ctx context.Context, bucketName string, bucketPolicy *policy.Policy) + func (sys *NotificationSys) SignalService(sig serviceSignal) []NotificationPeerErr + func (sys *NotificationSys) StartProfiling(profiler string) []NotificationPeerErr + type ObjReaderFn func(inputReader io.Reader, h http.Header, pcfn CheckCopyPreconditionFn, ...) (r *GetObjectReader, err error) + func NewGetObjectReader(rs *HTTPRangeSpec, oi ObjectInfo, pcfn CheckCopyPreconditionFn, ...) (fn ObjReaderFn, off, length int64, err error) + type Object struct + ETag string + Key string + LastModified string + Owner Owner + Size int64 + StorageClass string + type ObjectAlreadyExists GenericError + func (e ObjectAlreadyExists) Error() string + type ObjectExistsAsDirectory GenericError + func (e ObjectExistsAsDirectory) Error() string + type ObjectIdentifier struct + ObjectName string + type ObjectInfo struct + AccTime time.Time + Bucket string + ContentEncoding string + ContentType string + ETag string + Expires time.Time + IsDir bool + ModTime time.Time + Name string + Parts []ObjectPartInfo + PutObjReader *PutObjReader + Reader *hash.Reader + Size int64 + StorageClass string + UserDefined map[string]string + Writer io.WriteCloser + func FromMinioClientObjectInfo(bucket string, oi minio.ObjectInfo) ObjectInfo + func (o *ObjectInfo) DecryptedSize() (int64, error) + func (o *ObjectInfo) EncryptedSize() int64 + func (o *ObjectInfo) GetDecryptedRange(rs *HTTPRangeSpec) (encOff, encLength, skipLen int64, seqNumber uint32, partStart int, err error) + func (o ObjectInfo) GetActualSize() int64 + func (o ObjectInfo) IsCacheable() bool + func (o ObjectInfo) IsCompressed() bool + type ObjectLayer interface + AbortMultipartUpload func(ctx context.Context, bucket, object, uploadID string) error + CompleteMultipartUpload func(ctx context.Context, bucket, object, uploadID string, ...) (objInfo ObjectInfo, err error) + CopyObject func(ctx context.Context, srcBucket, srcObject, destBucket, destObject string, ...) (objInfo ObjectInfo, err error) + CopyObjectPart func(ctx context.Context, srcBucket, srcObject, destBucket, destObject string, ...) (info PartInfo, err error) + DeleteBucket func(ctx context.Context, bucket string) error + DeleteBucketPolicy func(context.Context, string) error + DeleteObject func(ctx context.Context, bucket, object string) error + GetBucketInfo func(ctx context.Context, bucket string) (bucketInfo BucketInfo, err error) + GetBucketPolicy func(context.Context, string) (*policy.Policy, error) + GetObject func(ctx context.Context, bucket, object string, startOffset int64, length int64, ...) (err error) + GetObjectInfo func(ctx context.Context, bucket, object string, opts ObjectOptions) (objInfo ObjectInfo, err error) + GetObjectNInfo func(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, ...) (reader *GetObjectReader, err error) + HealBucket func(ctx context.Context, bucket string, dryRun, remove bool) (madmin.HealResultItem, error) + HealFormat func(ctx context.Context, dryRun bool) (madmin.HealResultItem, error) + HealObject func(ctx context.Context, bucket, object string, dryRun, remove bool, ...) (madmin.HealResultItem, error) + HealObjects func(ctx context.Context, bucket, prefix string, ...) error + IsCompressionSupported func() bool + IsEncryptionSupported func() bool + IsListenBucketSupported func() bool + IsNotificationSupported func() bool + ListBuckets func(ctx context.Context) (buckets []BucketInfo, err error) + ListBucketsHeal func(ctx context.Context) (buckets []BucketInfo, err error) + ListMultipartUploads func(ctx context.Context, ...) (result ListMultipartsInfo, err error) + ListObjectParts func(ctx context.Context, bucket, object, uploadID string, partNumberMarker int, ...) (result ListPartsInfo, err error) + ListObjects func(ctx context.Context, bucket, prefix, marker, delimiter string, maxKeys int) (result ListObjectsInfo, err error) + ListObjectsV2 func(ctx context.Context, bucket, prefix, continuationToken, delimiter string, ...) (result ListObjectsV2Info, err error) + MakeBucketWithLocation func(ctx context.Context, bucket string, location string) error + NewMultipartUpload func(ctx context.Context, bucket, object string, opts ObjectOptions) (uploadID string, err error) + PutObject func(ctx context.Context, bucket, object string, data *PutObjReader, ...) (objInfo ObjectInfo, err error) + PutObjectPart func(ctx context.Context, bucket, object, uploadID string, partID int, ...) (info PartInfo, err error) + ReloadFormat func(ctx context.Context, dryRun bool) error + SetBucketPolicy func(context.Context, string, *policy.Policy) error + Shutdown func(context.Context) error + StorageInfo func(context.Context) StorageInfo + func NewFSObjectLayer(fsPath string) (ObjectLayer, error) + type ObjectNameInvalid GenericError + func (e ObjectNameInvalid) Error() string + type ObjectNotFound GenericError + func (e ObjectNotFound) Error() string + type ObjectOptions struct + CheckCopyPrecondFn CheckCopyPreconditionFn + ServerSideEncryption encrypt.ServerSide + UserDefined map[string]string + type ObjectPartInfo struct + ActualSize int64 + ETag string + Name string + Number int + Size int64 + type ObjectTooLarge GenericError + func (e ObjectTooLarge) Error() string + type ObjectTooSmall GenericError + func (e ObjectTooSmall) Error() string + type OperationTimedOut struct + Path string + func (e OperationTimedOut) Error() string + type Owner struct + DisplayName string + ID string + type Part struct + ETag string + LastModified string + PartNumber int + Size int64 + type PartInfo struct + ActualSize int64 + ETag string + LastModified time.Time + PartNumber int + Size int64 + func FromMinioClientObjectPart(op minio.ObjectPart) PartInfo + type PartTooBig struct + func (e PartTooBig) Error() string + type PartTooSmall struct + PartETag string + PartNumber int + PartSize int64 + func (e PartTooSmall) Error() string + type PeerLocks struct + Addr string + Locks GetLocksResp + type PeerRESTClientTarget struct + func NewPeerRESTClientTarget(bucketName string, targetID event.TargetID, restClient *peerRESTClient) *PeerRESTClientTarget + func (target *PeerRESTClientTarget) Close() error + func (target *PeerRESTClientTarget) ID() event.TargetID + func (target *PeerRESTClientTarget) Send(eventData event.Event) error + type PolicyNesting struct + func (e PolicyNesting) Error() string + type PolicySys struct + func NewPolicySys() *PolicySys + func (sys *PolicySys) Init(objAPI ObjectLayer) error + func (sys *PolicySys) IsAllowed(args policy.Args) bool + func (sys *PolicySys) Remove(bucketName string) + func (sys *PolicySys) Set(bucketName string, policy policy.Policy) + type PostPolicyForm struct + Conditions struct{ ... } + Expiration time.Time + type PostResponse struct + Bucket string + ETag string + Key string + Location string + type PreConditionFailed struct + func (e PreConditionFailed) Error() string + type PrefixAccessDenied GenericError + func (e PrefixAccessDenied) Error() string + type PresignedGetArgs struct + BucketName string + Expiry int64 + HostName string + ObjectName string + type PresignedGetRep struct + UIVersion string + URL string + type PutObjReader struct + func NewPutObjReader(rawReader *hash.Reader, encReader *hash.Reader, encKey []byte) *PutObjReader + func (p *PutObjReader) MD5CurrentHexString() string + func (p *PutObjReader) Size() int64 + type RPCClient struct + func NewRPCClient(args RPCClientArgs) (*RPCClient, error) + func (client *RPCClient) Call(serviceMethod string, args interface{ ... }, reply interface{}) (err error) + func (client *RPCClient) Close() error + func (client *RPCClient) ServiceURL() *xnet.URL + type RPCClientArgs struct + NewAuthTokenFunc func() string + RPCVersion RPCVersion + ServiceName string + ServiceURL *xnet.URL + TLSConfig *tls.Config + type RPCVersion struct + Major uint64 + Minor uint64 + Patch uint64 + func (v RPCVersion) Compare(o RPCVersion) int + func (v RPCVersion) String() string + type RWLocker interface + GetLock func(timeout *dynamicTimeout) (timedOutErr error) + GetRLock func(timeout *dynamicTimeout) (timedOutErr error) + RUnlock func() + Unlock func() + type RWLockerSync interface + GetLock func(id, source string, timeout time.Duration) bool + GetRLock func(id, source string, timeout time.Duration) bool + RUnlock func() + Unlock func() + type Reader struct + func NewReader_kv(key string, k *KVStorage, entry KVNSEntry, offset, length int64) *Reader + func (r *Reader) Close() error + func (r *Reader) Read(p []byte) (n int, err error) + type RemoveBucketArgs struct + BucketName string + type RemoveObjectArgs struct + BucketName string + Objects []string + type STSError struct + Code string + Description string + HTTPStatusCode int + type STSErrorCode int + const ErrSTSAccessDenied + const ErrSTSClientGrantsExpiredToken + const ErrSTSInternalError + const ErrSTSInvalidClientGrantsToken + const ErrSTSInvalidParameterValue + const ErrSTSMalformedPolicyDocument + const ErrSTSMissingParameter + const ErrSTSNone + const ErrSTSNotInitialized + const ErrSTSWebIdentityExpiredToken + type STSErrorResponse struct + Error struct{ ... } + RequestID string + XMLName xml.Name + type SealMD5CurrFn func([]byte) []byte + type ServerCPULoadInfo struct + Addr string + Error string + HistoricLoad []cpu.Load + Load []cpu.Load + type ServerConnStats struct + Throughput uint64 + TotalInputBytes uint64 + TotalOutputBytes uint64 + type ServerDrivesPerfInfo struct + Addr string + Error string + Perf []disk.Performance + type ServerHTTPMethodStats struct + AvgDuration string + Count uint64 + type ServerHTTPStats struct + SuccessDELETEStats ServerHTTPMethodStats + SuccessGETStats ServerHTTPMethodStats + SuccessHEADStats ServerHTTPMethodStats + SuccessPOSTStats ServerHTTPMethodStats + SuccessPUTStats ServerHTTPMethodStats + TotalDELETEStats ServerHTTPMethodStats + TotalGETStats ServerHTTPMethodStats + TotalHEADStats ServerHTTPMethodStats + TotalPOSTStats ServerHTTPMethodStats + TotalPUTStats ServerHTTPMethodStats + type ServerInfo struct + Addr string + Data *ServerInfoData + Error string + type ServerInfoData struct + ConnStats ServerConnStats + HTTPStats ServerHTTPStats + Properties ServerProperties + StorageInfo StorageInfo + type ServerInfoRep struct + MinioGlobalInfo map[string]interface{} + MinioMemory string + MinioPlatform string + MinioRuntime string + MinioVersion string + UIVersion string + type ServerMemUsageInfo struct + Addr string + Error string + HistoricUsage []mem.Usage + Usage []mem.Usage + type ServerProperties struct + CommitID string + Region string + SQSARN []string + Uptime time.Duration + Version string + type SetAuthArgs struct + AccessKey string + SecretKey string + type SetAuthReply struct + PeerErrMsgs map[string]string + Token string + UIVersion string + type SetBucketPolicyWebArgs struct + BucketName string + Policy string + Prefix string + type SetupType int + const DistXLSetupType + const FSSetupType + const GatewaySetupType + const XLSetupType + func (setupType SetupType) String() string + type SignatureDoesNotMatch struct + func (e SignatureDoesNotMatch) Error() string + type StartProfilingResult struct + Error string + NodeName string + Success bool + type StatInfo struct + type StorageAPI interface + AppendFile func(volume string, path string, buf []byte) (err error) + Close func() error + CreateDir func(volume, dir string) error + CreateFile func(volume, path string, size int64, reader io.Reader) error + DeleteDir func(volume, dir string) error + DeleteFile func(volume string, path string) (err error) + DeleteVol func(volume string) (err error) + DiskInfo func() (info DiskInfo, err error) + IsOnline func() bool + LastError func() error + ListDir func(volume, dirPath string, count int) ([]string, error) + ListVols func() (vols []VolInfo, err error) + MakeVol func(volume string) (err error) + ReadAll func(volume string, path string) (buf []byte, err error) + ReadAndCopy func(volume string, path string, writer io.Writer) (err error) + ReadFile func(volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error) + ReadFileStream func(volume, path string, offset, length int64) (io.ReadCloser, error) + RenameFile func(srcVolume, srcPath, dstVolume, dstPath string) error + StatDir func(volume, dir string) error + StatFile func(volume string, path string) (file FileInfo, err error) + StatVol func(volume string) (vol VolInfo, err error) + String func() string + SyncVolumes func() (err error) + UpdateStats func() error + WriteAll func(volume string, path string, buf []byte) (err error) + var OfflineDisk StorageAPI + type StorageFull struct + func (e StorageFull) Error() string + type StorageInfo struct + Backend struct{ ... } + Used uint64 + type StorageInfoRep struct + StorageInfo StorageInfo + UIVersion string + type URLTokenReply struct + Token string + UIVersion string + type UnsupportedDelimiter struct + Delimiter string + func (e UnsupportedDelimiter) Error() string + type UnsupportedMetadata struct + func (e UnsupportedMetadata) Error() string + type Upload struct + Initiated string + Initiator Initiator + Key string + Owner Owner + StorageClass string + UploadID string + type VoidReply struct + type VolInfo struct + Created time.Time + Name string + type WebBucketInfo struct + CreationDate time.Time + Name string + type WebGenericArgs struct + type WebGenericRep struct + UIVersion string + type WebIdentityResult struct + AssumedRoleUser AssumedRoleUser + Audience string + Credentials auth.Credentials + PackedPolicySize int + Provider string + SubjectFromWebIdentityToken string + type WebObjectInfo struct + ContentType string + Key string + LastModified time.Time + Size int64 Incompatible versions in this module v3.0.0+incompatible Nov 17, 2023 v2.0.0+incompatible May 16, 2023