Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

minio

package module

Go to main page

Versions in this module

v7

v7.1.5

Jun 15, 2023

v7.1.4

Jun 15, 2023

v7.1.3

May 27, 2023

v7.1.2

May 27, 2023

Changes in this version

+ type IObjectPartsStore interface

+ Get func(int) (*ObjectPartData, bool)

+ Set func(*ObjectPartData) error

+ type ObjectPartData struct

+ CrcByte []byte

+ PartSeq int

+ PartsInfo ObjectPart

v7.1.1

May 26, 2023

Changes in this version

+ const Enabled

+ const MaxJitter

+ const NoJitter

+ const RestoreSelect

+ const Suspended

+ const TierBulk

+ const TierExpedited

+ const TierStandard

+ var DefaultRetryCap = time.Second

+ var DefaultRetryUnit = 200 * time.Millisecond

+ var DefaultTransport = func(secure bool) (*http.Transport, error)

+ var MaxRetry = 10

+ func IsNetworkOrHostDown(err error, expectTimeouts bool) bool

+ func OptimalPartInfo(objectSize int64, configuredPartSize uint64) (totalPartsCount int, partSize int64, lastPartSize int64, err error)

+ type AccessControlList struct

+ Grant []Grant

+ Permission string

+ XMLName xml.Name

+ type AdvancedGetOptions struct

+ IsReplicationReadyForDeleteMarker bool

+ ReplicationDeleteMarker bool

+ ReplicationProxyRequest string

+ type AdvancedPutOptions struct

+ LegalholdTimestamp time.Time

+ ReplicationRequest bool

+ ReplicationStatus ReplicationStatus

+ RetentionTimestamp time.Time

+ SourceETag string

+ SourceMTime time.Time

+ SourceVersionID string

+ TaggingTimestamp time.Time

+ type AdvancedRemoveOptions struct

+ ReplicationDeleteMarker bool

+ ReplicationMTime time.Time

+ ReplicationRequest bool

+ ReplicationStatus ReplicationStatus

+ type BucketInfo struct

+ CreationDate time.Time

+ Name string

+ type BucketLookupType int

+ const BucketLookupAuto

+ const BucketLookupDNS

+ const BucketLookupPath

+ type BucketOptions = RemoveBucketOptions

+ type BucketVersioningConfiguration struct

+ ExcludeFolders bool

+ ExcludedPrefixes []ExcludedPrefix

+ MFADelete string

+ Status string

+ XMLName xml.Name

+ func (b BucketVersioningConfiguration) Enabled() bool

+ func (b BucketVersioningConfiguration) Suspended() bool

+ type CSVFileHeaderInfo string

+ const CSVFileHeaderInfoIgnore

+ const CSVFileHeaderInfoNone

+ const CSVFileHeaderInfoUse

+ type CSVInputOptions struct

+ Comments string

+ FieldDelimiter string

+ FileHeaderInfo CSVFileHeaderInfo

+ QuoteCharacter string

+ QuoteEscapeCharacter string

+ RecordDelimiter string

+ func (c *CSVInputOptions) SetComments(val string)

+ func (c *CSVInputOptions) SetFieldDelimiter(val string)

+ func (c *CSVInputOptions) SetFileHeaderInfo(val CSVFileHeaderInfo)

+ func (c *CSVInputOptions) SetQuoteCharacter(val string)

+ func (c *CSVInputOptions) SetQuoteEscapeCharacter(val string)

+ func (c *CSVInputOptions) SetRecordDelimiter(val string)

+ func (c CSVInputOptions) MarshalXML(e *xml.Encoder, start xml.StartElement) error

+ type CSVOutputOptions struct

+ FieldDelimiter string

+ QuoteCharacter string

+ QuoteEscapeCharacter string

+ QuoteFields CSVQuoteFields

+ RecordDelimiter string

+ func (c *CSVOutputOptions) SetFieldDelimiter(val string)

+ func (c *CSVOutputOptions) SetQuoteCharacter(val string)

+ func (c *CSVOutputOptions) SetQuoteEscapeCharacter(val string)

+ func (c *CSVOutputOptions) SetQuoteFields(val CSVQuoteFields)

+ func (c *CSVOutputOptions) SetRecordDelimiter(val string)

+ func (c CSVOutputOptions) MarshalXML(e *xml.Encoder, start xml.StartElement) error

+ type CSVQuoteFields string

+ const CSVQuoteFieldsAlways

+ const CSVQuoteFieldsAsNeeded

+ type Checksum struct

+ Type ChecksumType

+ func NewChecksum(t ChecksumType, b []byte) Checksum

+ func NewChecksumString(t ChecksumType, s string) Checksum

+ func (c Checksum) Encoded() string

+ func (c Checksum) IsSet() bool

+ func (c Checksum) Raw() []byte

+ type ChecksumType uint32

+ const ChecksumCRC32

+ const ChecksumCRC32C

+ const ChecksumNone

+ const ChecksumSHA1

+ const ChecksumSHA256

+ func (c ChecksumType) ChecksumBytes(b []byte) Checksum

+ func (c ChecksumType) ChecksumReader(r io.Reader) (Checksum, error)

+ func (c ChecksumType) Hasher() hash.Hash

+ func (c ChecksumType) Is(t ChecksumType) bool

+ func (c ChecksumType) IsSet() bool

+ func (c ChecksumType) Key() string

+ func (c ChecksumType) RawByteLen() int

+ func (c ChecksumType) String() string

+ type Client struct

+ func New(endpoint string, opts *Options) (*Client, error)

+ func (c *Client) BucketExists(ctx context.Context, bucketName string) (bool, error)

+ func (c *Client) CancelMultipartUploader(ctx context.Context, bucketName, objectName, uploadID string) error

+ func (c *Client) ComposeObject(ctx context.Context, dst CopyDestOptions, srcs ...CopySrcOptions) (UploadInfo, error)

+ func (c *Client) CopyObject(ctx context.Context, dst CopyDestOptions, src CopySrcOptions) (UploadInfo, error)

+ func (c *Client) EnableVersioning(ctx context.Context, bucketName string) error

+ func (c *Client) EndpointURL() *url.URL

+ func (c *Client) FGetObject(ctx context.Context, bucketName, objectName, filePath string, ...) error

+ func (c *Client) FPutObject(ctx context.Context, bucketName, objectName, filePath string, ...) (info UploadInfo, err error)

+ func (c *Client) GetBucketEncryption(ctx context.Context, bucketName string) (*sse.Configuration, error)

+ func (c *Client) GetBucketLifecycle(ctx context.Context, bucketName string) (*lifecycle.Configuration, error)

+ func (c *Client) GetBucketLifecycleWithInfo(ctx context.Context, bucketName string) (*lifecycle.Configuration, time.Time, error)

+ func (c *Client) GetBucketLocation(ctx context.Context, bucketName string) (string, error)

+ func (c *Client) GetBucketNotification(ctx context.Context, bucketName string) (bucketNotification notification.Configuration, err error)

+ func (c *Client) GetBucketObjectLockConfig(ctx context.Context, bucketName string) (mode *RetentionMode, validity *uint, unit *ValidityUnit, err error)

+ func (c *Client) GetBucketPolicy(ctx context.Context, bucketName string) (string, error)

+ func (c *Client) GetBucketReplication(ctx context.Context, bucketName string) (cfg replication.Config, err error)

+ func (c *Client) GetBucketReplicationMetrics(ctx context.Context, bucketName string) (s replication.Metrics, err error)

+ func (c *Client) GetBucketReplicationResyncStatus(ctx context.Context, bucketName, arn string) (rinfo replication.ResyncTargetsInfo, err error)

+ func (c *Client) GetBucketTagging(ctx context.Context, bucketName string) (*tags.Tags, error)

+ func (c *Client) GetBucketVersioning(ctx context.Context, bucketName string) (BucketVersioningConfiguration, error)

+ func (c *Client) GetObject(ctx context.Context, bucketName, objectName string, opts GetObjectOptions) (*Object, error)

+ func (c *Client) GetObjectACL(ctx context.Context, bucketName, objectName string) (*ObjectInfo, error)

+ func (c *Client) GetObjectLegalHold(ctx context.Context, bucketName, objectName string, ...) (status *LegalHoldStatus, err error)

+ func (c *Client) GetObjectLockConfig(ctx context.Context, bucketName string) (objectLock string, mode *RetentionMode, validity *uint, unit *ValidityUnit, ...)

+ func (c *Client) GetObjectRetention(ctx context.Context, bucketName, objectName, versionID string) (mode *RetentionMode, retainUntilDate *time.Time, err error)

+ func (c *Client) GetObjectTagging(ctx context.Context, bucketName, objectName string, ...) (*tags.Tags, error)

+ func (c *Client) HealthCheck(hcDuration time.Duration) (context.CancelFunc, error)

+ func (c *Client) IsOffline() bool

+ func (c *Client) IsOnline() bool

+ func (c *Client) ListBuckets(ctx context.Context) ([]BucketInfo, error)

+ func (c *Client) ListIncompleteUploads(ctx context.Context, bucketName, objectPrefix string, recursive bool) <-chan ObjectMultipartInfo

+ func (c *Client) ListObjects(ctx context.Context, bucketName string, opts ListObjectsOptions) <-chan ObjectInfo

+ func (c *Client) ListenBucketNotification(ctx context.Context, bucketName, prefix, suffix string, events []string) <-chan notification.Info

+ func (c *Client) ListenNotification(ctx context.Context, prefix, suffix string, events []string) <-chan notification.Info

+ func (c *Client) MakeBucket(ctx context.Context, bucketName string, opts MakeBucketOptions) (err error)

+ func (c *Client) NewUploadID(ctx context.Context, bucketName, objectName string, objectSize int64, ...) (*MultipartUploader, error)

+ func (c *Client) Presign(ctx context.Context, method string, bucketName string, objectName string, ...) (u *url.URL, err error)

+ func (c *Client) PresignHeader(ctx context.Context, method string, bucketName string, objectName string, ...) (u *url.URL, err error)

+ func (c *Client) PresignedGetObject(ctx context.Context, bucketName string, objectName string, ...) (u *url.URL, err error)

+ func (c *Client) PresignedHeadObject(ctx context.Context, bucketName string, objectName string, ...) (u *url.URL, err error)

+ func (c *Client) PresignedPostPolicy(ctx context.Context, p *PostPolicy) (u *url.URL, formData map[string]string, err error)

+ func (c *Client) PresignedPutObject(ctx context.Context, bucketName string, objectName string, ...) (u *url.URL, err error)

+ func (c *Client) PutObject(ctx context.Context, bucketName, objectName string, reader io.Reader, ...) (info UploadInfo, err error)

+ func (c *Client) PutObjectFanOut(ctx context.Context, bucket string, fanOutData io.Reader, ...) ([]PutObjectFanOutResponse, error)

+ func (c *Client) PutObjectLegalHold(ctx context.Context, bucketName, objectName string, ...) error

+ func (c *Client) PutObjectRetention(ctx context.Context, bucketName, objectName string, ...) error

+ func (c *Client) PutObjectTagging(ctx context.Context, bucketName, objectName string, otags *tags.Tags, ...) error

+ func (c *Client) RemoveAllBucketNotification(ctx context.Context, bucketName string) error

+ func (c *Client) RemoveBucket(ctx context.Context, bucketName string) error

+ func (c *Client) RemoveBucketEncryption(ctx context.Context, bucketName string) error

+ func (c *Client) RemoveBucketReplication(ctx context.Context, bucketName string) error

+ func (c *Client) RemoveBucketTagging(ctx context.Context, bucketName string) error

+ func (c *Client) RemoveBucketWithOptions(ctx context.Context, bucketName string, opts RemoveBucketOptions) error

+ func (c *Client) RemoveIncompleteUpload(ctx context.Context, bucketName, objectName string) error

+ func (c *Client) RemoveObject(ctx context.Context, bucketName, objectName string, opts RemoveObjectOptions) error

+ func (c *Client) RemoveObjectTagging(ctx context.Context, bucketName, objectName string, ...) error

+ func (c *Client) RemoveObjects(ctx context.Context, bucketName string, objectsCh <-chan ObjectInfo, ...) <-chan RemoveObjectError

+ func (c *Client) RemoveObjectsWithResult(ctx context.Context, bucketName string, objectsCh <-chan ObjectInfo, ...) <-chan RemoveObjectResult

+ func (c *Client) ResetBucketReplication(ctx context.Context, bucketName string, olderThan time.Duration) (rID string, err error)

+ func (c *Client) ResetBucketReplicationOnTarget(ctx context.Context, bucketName string, olderThan time.Duration, tgtArn string) (replication.ResyncTargetsInfo, error)

+ func (c *Client) RestoreObject(ctx context.Context, bucketName, objectName, versionID string, ...) error

+ func (c *Client) SelectObjectContent(ctx context.Context, bucketName, objectName string, opts SelectObjectOptions) (*SelectResults, error)

+ func (c *Client) SetAppInfo(appName string, appVersion string)

+ func (c *Client) SetBucketEncryption(ctx context.Context, bucketName string, config *sse.Configuration) error

+ func (c *Client) SetBucketLifecycle(ctx context.Context, bucketName string, config *lifecycle.Configuration) error

+ func (c *Client) SetBucketNotification(ctx context.Context, bucketName string, config notification.Configuration) error

+ func (c *Client) SetBucketObjectLockConfig(ctx context.Context, bucketName string, mode *RetentionMode, validity *uint, ...) error

+ func (c *Client) SetBucketPolicy(ctx context.Context, bucketName, policy string) error

+ func (c *Client) SetBucketReplication(ctx context.Context, bucketName string, cfg replication.Config) error

+ func (c *Client) SetBucketTagging(ctx context.Context, bucketName string, tags *tags.Tags) error

+ func (c *Client) SetBucketVersioning(ctx context.Context, bucketName string, config BucketVersioningConfiguration) error

+ func (c *Client) SetObjectLockConfig(ctx context.Context, bucketName string, mode *RetentionMode, validity *uint, ...) error

+ func (c *Client) SetS3TransferAccelerate(accelerateEndpoint string)

+ func (c *Client) StatObject(ctx context.Context, bucketName, objectName string, opts StatObjectOptions) (ObjectInfo, error)

+ func (c *Client) SuspendVersioning(ctx context.Context, bucketName string) error

+ func (c *Client) TraceErrorsOnlyOff()

+ func (c *Client) TraceErrorsOnlyOn(outputStream io.Writer)

+ func (c *Client) TraceOff()

+ func (c *Client) TraceOn(outputStream io.Writer)

+ func (c Client) PutObjectsSnowball(ctx context.Context, bucketName string, opts SnowballOptions, ...) (err error)

+ type CommonPrefix struct

+ Prefix string

+ type CompletePart struct

+ ChecksumCRC32 string

+ ChecksumCRC32C string

+ ChecksumSHA1 string

+ ChecksumSHA256 string

+ ETag string

+ PartNumber int

+ type CopyDestOptions struct

+ Bucket string

+ Encryption encrypt.ServerSide

+ LegalHold LegalHoldStatus

+ Mode RetentionMode

+ Object string

+ Progress io.Reader

+ ReplaceMetadata bool

+ ReplaceTags bool

+ RetainUntilDate time.Time

+ Size int64

+ UserMetadata map[string]string

+ UserTags map[string]string

+ func (opts CopyDestOptions) Marshal(header http.Header)

+ type CopySrcOptions struct

+ Bucket string

+ Encryption encrypt.ServerSide

+ End int64

+ MatchETag string

+ MatchModifiedSince time.Time

+ MatchRange bool

+ MatchUnmodifiedSince time.Time

+ NoMatchETag string

+ Object string

+ Start int64

+ VersionID string

+ func (opts CopySrcOptions) Marshal(header http.Header)

+ type Core struct

+ func NewCore(endpoint string, opts *Options) (*Core, error)

+ func (c Core) AbortMultipartUpload(ctx context.Context, bucket, object, uploadID string) error

+ func (c Core) CompleteMultipartUpload(ctx context.Context, bucket, object, uploadID string, parts []CompletePart, ...) (UploadInfo, error)

+ func (c Core) CopyObject(ctx context.Context, sourceBucket, sourceObject, destBucket, destObject string, ...) (ObjectInfo, error)

+ func (c Core) CopyObjectPart(ctx context.Context, srcBucket, srcObject, destBucket, destObject string, ...) (p CompletePart, err error)

+ func (c Core) GetBucketPolicy(ctx context.Context, bucket string) (string, error)

+ func (c Core) GetObject(ctx context.Context, bucketName, objectName string, opts GetObjectOptions) (io.ReadCloser, ObjectInfo, http.Header, error)

+ func (c Core) ListMultipartUploads(ctx context.Context, ...) (result ListMultipartUploadsResult, err error)

+ func (c Core) ListObjectParts(ctx context.Context, bucket, object, uploadID string, partNumberMarker int, ...) (result ListObjectPartsResult, err error)

+ func (c Core) ListObjects(bucket, prefix, marker, delimiter string, maxKeys int) (result ListBucketResult, err error)

+ func (c Core) ListObjectsV2(bucketName, objectPrefix, startAfter, continuationToken, delimiter string, ...) (ListBucketV2Result, error)

+ func (c Core) NewMultipartUpload(ctx context.Context, bucket, object string, opts PutObjectOptions) (uploadID string, err error)

+ func (c Core) PutBucketPolicy(ctx context.Context, bucket, bucketPolicy string) error

+ func (c Core) PutObject(ctx context.Context, bucket, object string, data io.Reader, size int64, ...) (UploadInfo, error)

+ func (c Core) PutObjectPart(ctx context.Context, bucket, object, uploadID string, partID int, ...) (ObjectPart, error)

+ type Encryption struct

+ EncryptionType string

+ KMSContext string

+ KMSKeyID string

+ type ErrorResponse struct

+ BucketName string

+ Code string

+ HostID string

+ Key string

+ Message string

+ Region string

+ RequestID string

+ Resource string

+ Server string

+ StatusCode int

+ XMLName xml.Name

+ func ToErrorResponse(err error) ErrorResponse

+ func (e ErrorResponse) Error() string

+ type ExcludedPrefix struct

+ Prefix string

+ type GetObjectLegalHoldOptions struct

+ VersionID string

+ type GetObjectOptions struct

+ Checksum bool

+ Internal AdvancedGetOptions

+ PartNumber int

+ ServerSideEncryption encrypt.ServerSide

+ VersionID string

+ func (o *GetObjectOptions) AddReqParam(key, value string)

+ func (o *GetObjectOptions) Set(key, value string)

+ func (o *GetObjectOptions) SetMatchETag(etag string) error

+ func (o *GetObjectOptions) SetMatchETagExcept(etag string) error

+ func (o *GetObjectOptions) SetModified(modTime time.Time) error

+ func (o *GetObjectOptions) SetRange(start, end int64) error

+ func (o *GetObjectOptions) SetReqParam(key, value string)

+ func (o *GetObjectOptions) SetUnmodified(modTime time.Time) error

+ func (o GetObjectOptions) Header() http.Header

+ type GetObjectTaggingOptions struct

+ VersionID string

+ type GlacierJobParameters struct

+ Tier TierType

+ type Grant struct

+ Grantee Grantee

+ Permission string

+ XMLName xml.Name

+ type Grantee struct

+ DisplayName string

+ ID string

+ URI string

+ XMLName xml.Name

+ type JSONInputOptions struct

+ Type JSONType

+ func (j *JSONInputOptions) SetType(typ JSONType)

+ func (j JSONInputOptions) MarshalXML(e *xml.Encoder, start xml.StartElement) error

+ type JSONOutputOptions struct

+ RecordDelimiter string

+ func (j *JSONOutputOptions) SetRecordDelimiter(val string)

+ func (j JSONOutputOptions) MarshalXML(e *xml.Encoder, start xml.StartElement) error

+ type JSONType string

+ const JSONDocumentType

+ const JSONLinesType

+ type LegalHoldStatus string

+ const LegalHoldDisabled

+ const LegalHoldEnabled

+ func (r LegalHoldStatus) IsValid() bool

+ func (r LegalHoldStatus) String() string

+ type ListBucketResult struct

+ CommonPrefixes []CommonPrefix

+ Contents []ObjectInfo

+ Delimiter string

+ EncodingType string

+ IsTruncated bool

+ Marker string

+ MaxKeys int64

+ Name string

+ NextMarker string

+ Prefix string

+ type ListBucketV2Result struct

+ CommonPrefixes []CommonPrefix

+ Contents []ObjectInfo

+ ContinuationToken string

+ Delimiter string

+ EncodingType string

+ FetchOwner string

+ IsTruncated bool

+ MaxKeys int64

+ Name string

+ NextContinuationToken string

+ Prefix string

+ StartAfter string

+ type ListMultipartUploadsResult struct

+ Bucket string

+ CommonPrefixes []CommonPrefix

+ Delimiter string

+ EncodingType string

+ IsTruncated bool

+ KeyMarker string

+ MaxUploads int64

+ NextKeyMarker string

+ NextUploadIDMarker string

+ Prefix string

+ UploadIDMarker string

+ Uploads []ObjectMultipartInfo

+ type ListObjectPartsResult struct

+ Bucket string

+ EncodingType string

+ Initiator initiator

+ IsTruncated bool

+ Key string

+ MaxParts int

+ NextPartNumberMarker int

+ ObjectParts []ObjectPart

+ Owner owner

+ PartNumberMarker int

+ StorageClass string

+ UploadID string

+ type ListObjectsOptions struct

+ MaxKeys int

+ Prefix string

+ Recursive bool

+ StartAfter string

+ UseV1 bool

+ WithMetadata bool

+ WithVersions bool

+ func (o *ListObjectsOptions) Set(key, value string)

+ type ListVersionsResult struct

+ CommonPrefixes []CommonPrefix

+ Delimiter string

+ EncodingType string

+ IsTruncated bool

+ KeyMarker string

+ MaxKeys int64

+ Name string

+ NextKeyMarker string

+ NextVersionIDMarker string

+ Prefix string

+ VersionIDMarker string

+ Versions []Version

+ func (l *ListVersionsResult) UnmarshalXML(d *xml.Decoder, _ xml.StartElement) (err error)

+ type MakeBucketOptions struct

+ ObjectLocking bool

+ Region string

+ type MetadataEntry struct

+ Name string

+ Value string

+ type MultipartUploader struct

+ BucketName string

+ ObjectName string

+ ObjectSize int64

+ PartSize int64

+ TotalPartsCount int

+ TotalUploadedSize int64

+ UploadID string

+ func (p *MultipartUploader) CompleteMultipartUpload(ctx context.Context) (*UploadInfo, error)

+ func (p *MultipartUploader) UploadPart(ctx context.Context, reader io.Reader, partNumber int, bodySize int64, ...) error

+ type Object struct

+ func (o *Object) Close() (err error)

+ func (o *Object) Read(b []byte) (n int, err error)

+ func (o *Object) ReadAt(b []byte, offset int64) (n int, err error)

+ func (o *Object) Seek(offset int64, whence int) (n int64, err error)

+ func (o *Object) Stat() (ObjectInfo, error)

+ type ObjectInfo struct

+ ChecksumCRC32 string

+ ChecksumCRC32C string

+ ChecksumSHA1 string

+ ChecksumSHA256 string

+ ContentType string

+ ETag string

+ Err error

+ Expiration time.Time

+ ExpirationRuleID string

+ Expires time.Time

+ Grant []Grant

+ IsDeleteMarker bool

+ IsLatest bool

+ Key string

+ LastModified time.Time

+ Metadata http.Header

+ Owner Owner

+ ReplicationReady bool

+ ReplicationStatus string

+ Restore *RestoreInfo

+ Size int64

+ StorageClass string

+ UserMetadata StringMap

+ UserTagCount int

+ UserTags URLMap

+ VersionID string

+ func ToObjectInfo(bucketName string, objectName string, h http.Header) (ObjectInfo, error)

+ type ObjectMultipartInfo struct

+ Err error

+ Initiated time.Time

+ Initiator initiator

+ Key string

+ Owner owner

+ Size int64

+ StorageClass string

+ UploadID string

+ type ObjectPart struct

+ ChecksumCRC32 string

+ ChecksumCRC32C string

+ ChecksumSHA1 string

+ ChecksumSHA256 string

+ ETag string

+ LastModified time.Time

+ PartNumber int

+ Size int64

+ type Options struct

+ BucketLookup BucketLookupType

+ Creds *credentials.Credentials

+ CustomMD5 func() md5simd.Hasher

+ CustomRegionViaURL func(u url.URL) string

+ CustomSHA256 func() md5simd.Hasher

+ Region string

+ Secure bool

+ TrailingHeaders bool

+ Transport http.RoundTripper

+ type OutputLocation struct

+ S3 S3

+ XMLName xml.Name

+ type Owner struct

+ DisplayName string

+ ID string

+ XMLName xml.Name

+ type ParquetInputOptions struct

+ type PostPolicy struct

+ func NewPostPolicy() *PostPolicy

+ func (p *PostPolicy) SetBucket(bucketName string) error

+ func (p *PostPolicy) SetChecksum(c Checksum)

+ func (p *PostPolicy) SetCondition(matchType, condition, value string) error

+ func (p *PostPolicy) SetContentLengthRange(min, max int64) error

+ func (p *PostPolicy) SetContentType(contentType string) error

+ func (p *PostPolicy) SetContentTypeStartsWith(contentTypeStartsWith string) error

+ func (p *PostPolicy) SetEncryption(sse encrypt.ServerSide)

+ func (p *PostPolicy) SetExpires(t time.Time) error

+ func (p *PostPolicy) SetKey(key string) error

+ func (p *PostPolicy) SetKeyStartsWith(keyStartsWith string) error

+ func (p *PostPolicy) SetSuccessActionRedirect(redirect string) error

+ func (p *PostPolicy) SetSuccessStatusAction(status string) error

+ func (p *PostPolicy) SetUserData(key string, value string) error

+ func (p *PostPolicy) SetUserMetadata(key string, value string) error

+ func (p PostPolicy) String() string

+ type ProgressMessage struct

+ XMLName xml.Name

+ type PutObjectFanOutEntry struct

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentType string

+ Key string

+ RetainUntilDate *time.Time

+ Retention RetentionMode

+ UserMetadata map[string]string

+ UserTags map[string]string

+ type PutObjectFanOutRequest struct

+ Checksum Checksum

+ Entries []PutObjectFanOutEntry

+ SSE encrypt.ServerSide

+ type PutObjectFanOutResponse struct

+ ETag string

+ Error error

+ Key string

+ LastModified *time.Time

+ VersionID string

+ type PutObjectLegalHoldOptions struct

+ Status *LegalHoldStatus

+ VersionID string

+ type PutObjectOptions struct

+ CacheControl string

+ ConcurrentStreamParts bool

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentType string

+ DisableContentSha256 bool

+ DisableMultipart bool

+ Internal AdvancedPutOptions

+ LegalHold LegalHoldStatus

+ Mode RetentionMode

+ NumThreads uint

+ PartSize uint64

+ Progress io.Reader

+ RetainUntilDate time.Time

+ SendContentMd5 bool

+ ServerSideEncryption encrypt.ServerSide

+ StorageClass string

+ UserMetadata map[string]string

+ UserTags map[string]string

+ WebsiteRedirectLocation string

+ func (opts *PutObjectOptions) SetMatchETag(etag string)

+ func (opts *PutObjectOptions) SetMatchETagExcept(etag string)

+ func (opts PutObjectOptions) Header() (header http.Header)

+ type PutObjectPartOptions struct

+ CustomHeader http.Header

+ Md5Base64 string

+ SSE encrypt.ServerSide

+ Sha256Hex string

+ Trailer http.Header

+ type PutObjectRetentionOptions struct

+ GovernanceBypass bool

+ Mode *RetentionMode

+ RetainUntilDate *time.Time

+ VersionID string

+ type PutObjectTaggingOptions struct

+ VersionID string

+ type QueryExpressionType string

+ const QueryExpressionTypeSQL

+ type RemoveBucketOptions struct

+ ForceDelete bool

+ type RemoveObjectError struct

+ Err error

+ ObjectName string

+ VersionID string

+ type RemoveObjectOptions struct

+ ForceDelete bool

+ GovernanceBypass bool

+ Internal AdvancedRemoveOptions

+ VersionID string

+ type RemoveObjectResult struct

+ DeleteMarker bool

+ DeleteMarkerVersionID string

+ Err error

+ ObjectName string

+ ObjectVersionID string

+ type RemoveObjectTaggingOptions struct

+ VersionID string

+ type RemoveObjectsOptions struct

+ GovernanceBypass bool

+ type ReplicationStatus string

+ const ReplicationStatusComplete

+ const ReplicationStatusFailed

+ const ReplicationStatusPending

+ const ReplicationStatusReplica

+ func (r ReplicationStatus) Empty() bool

+ type RestoreInfo struct

+ ExpiryTime time.Time

+ OngoingRestore bool

+ type RestoreRequest struct

+ Days *int

+ Description *string

+ GlacierJobParameters *GlacierJobParameters

+ OutputLocation *OutputLocation

+ SelectParameters *SelectParameters

+ Tier *TierType

+ Type *RestoreType

+ XMLName xml.Name

+ func (r *RestoreRequest) SetDays(v int)

+ func (r *RestoreRequest) SetDescription(v string)

+ func (r *RestoreRequest) SetGlacierJobParameters(v GlacierJobParameters)

+ func (r *RestoreRequest) SetOutputLocation(v OutputLocation)

+ func (r *RestoreRequest) SetSelectParameters(v SelectParameters)

+ func (r *RestoreRequest) SetTier(v TierType)

+ func (r *RestoreRequest) SetType(v RestoreType)

+ type RestoreType string

+ type Retention struct

+ Mode RetentionMode

+ Validity time.Duration

+ func (r Retention) IsEmpty() bool

+ func (r Retention) String() string

+ type RetentionMode string

+ const Compliance

+ const Governance

+ func (r RetentionMode) IsValid() bool

+ func (r RetentionMode) String() string

+ type S3 struct

+ AccessControlList *AccessControlList

+ BucketName string

+ CannedACL *string

+ Encryption *Encryption

+ Prefix string

+ StorageClass *string

+ Tagging *tags.Tags

+ UserMetadata *MetadataEntry

+ type SelectCompressionType string

+ const SelectCompressionBZIP

+ const SelectCompressionGZIP

+ const SelectCompressionLZ4

+ const SelectCompressionNONE

+ const SelectCompressionS2

+ const SelectCompressionSNAPPY

+ const SelectCompressionZSTD

+ type SelectObjectInputSerialization struct

+ CSV *CSVInputOptions

+ CompressionType SelectCompressionType

+ JSON *JSONInputOptions

+ Parquet *ParquetInputOptions

+ type SelectObjectOptions struct

+ Expression string

+ ExpressionType QueryExpressionType

+ InputSerialization SelectObjectInputSerialization

+ OutputSerialization SelectObjectOutputSerialization

+ RequestProgress struct{ ... }

+ ServerSideEncryption encrypt.ServerSide

+ XMLName xml.Name

+ func (o SelectObjectOptions) Header() http.Header

+ type SelectObjectOutputSerialization struct

+ CSV *CSVOutputOptions

+ JSON *JSONOutputOptions

+ type SelectObjectType string

+ const SelectObjectTypeCSV

+ const SelectObjectTypeJSON

+ const SelectObjectTypeParquet

+ type SelectParameters struct

+ Expression string

+ ExpressionType QueryExpressionType

+ InputSerialization SelectObjectInputSerialization

+ OutputSerialization SelectObjectOutputSerialization

+ XMLName xml.Name

+ type SelectResults struct

+ func NewSelectResults(resp *http.Response, bucketName string) (*SelectResults, error)

+ func (s *SelectResults) Close() error

+ func (s *SelectResults) Progress() *ProgressMessage

+ func (s *SelectResults) Read(b []byte) (n int, err error)

+ func (s *SelectResults) Stats() *StatsMessage

+ type SnowballObject struct

+ Close func()

+ Content io.Reader

+ Key string

+ ModTime time.Time

+ Size int64

+ type SnowballOptions struct

+ Compress bool

+ InMemory bool

+ Opts PutObjectOptions

+ type StatObjectOptions = GetObjectOptions

+ type StatsMessage struct

+ BytesProcessed int64

+ BytesReturned int64

+ BytesScanned int64

+ XMLName xml.Name

+ type StringMap map[string]string

+ func (m *StringMap) UnmarshalXML(d *xml.Decoder, _ xml.StartElement) error

+ type TierType string

+ type URLMap map[string]string

+ func (m *URLMap) UnmarshalXML(d *xml.Decoder, se xml.StartElement) error

+ type UploadInfo struct

+ Bucket string

+ ChecksumCRC32 string

+ ChecksumCRC32C string

+ ChecksumSHA1 string

+ ChecksumSHA256 string

+ ETag string

+ Expiration time.Time

+ ExpirationRuleID string

+ Key string

+ LastModified time.Time

+ Location string

+ Size int64

+ VersionID string

+ type ValidityUnit string

+ const Days

+ const Years

+ func (unit ValidityUnit) String() string

+ type Version struct

+ ETag string

+ IsLatest bool

+ Key string

+ LastModified time.Time

+ Owner Owner

+ Size int64

+ StorageClass string

+ UserMetadata StringMap

+ UserTags URLMap

+ VersionID string

Other modules containing this package

github.com/imkos/minio-go