Versions in this module Expand all Collapse all v7 v7.0.65 Nov 22, 2023 Changes in this version + const CSVFileHeaderInfoIgnore + const CSVFileHeaderInfoNone + const CSVFileHeaderInfoUse + const Enabled + const MaxJitter + const NoJitter + const SelectCompressionBZIP + const SelectCompressionGZIP + const SelectCompressionNONE + const SelectObjectTypeCSV + const SelectObjectTypeJSON + const SelectObjectTypeParquet + const Suspended + var DefaultRetryCap = time.Second + var DefaultRetryUnit = 200 * time.Millisecond + var DefaultTransport = func(secure bool) (*http.Transport, error) + var MaxRetry = 10 + func OptimalPartInfo(objectSize int64, configuredPartSize uint64) (totalPartsCount int, partSize int64, lastPartSize int64, err error) + type AdvancedGetOptions struct + ReplicationDeleteMarker bool + ReplicationProxyRequest string + type AdvancedPutOptions struct + ReplicationRequest bool + ReplicationStatus ReplicationStatus + SourceETag string + SourceMTime time.Time + SourceVersionID string + 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 BucketVersioningConfiguration struct + MFADelete string + Status string + XMLName xml.Name + func (b BucketVersioningConfiguration) Enabled() bool + func (b BucketVersioningConfiguration) Suspended() bool + type CSVFileHeaderInfo string + 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 Client struct + func New(endpoint string, opts *Options) (*Client, error) + func (c *Client) EndpointURL() *url.URL + func (c *Client) SetAppInfo(appName string, appVersion string) + func (c *Client) SetS3TransferAccelerate(accelerateEndpoint string) + 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) BucketExists(ctx context.Context, bucketName string) (bool, 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) 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) 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) 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) 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) Presign(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) 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) 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) SelectObjectContent(ctx context.Context, bucketName, objectName string, opts SelectObjectOptions) (*SelectResults, error) + 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) StatObject(ctx context.Context, bucketName, objectName string, opts StatObjectOptions) (ObjectInfo, error) + func (c Client) SuspendVersioning(ctx context.Context, bucketName string) error + type CommonPrefix struct + Prefix string + type CompletePart struct + ETag string + PartNumber int + XMLName xml.Name + 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) (string, 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, continuationToken string, fetchOwner bool, ...) (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) + func (c Core) StatObject(ctx context.Context, bucketName, objectName string, opts StatObjectOptions) (ObjectInfo, error) + type ErrorResponse struct + BucketName string + Code string + HostID string + Key string + Message string + Region string + RequestID string + Server string + StatusCode int + XMLName xml.Name + func ToErrorResponse(err error) ErrorResponse + func (e ErrorResponse) Error() string + type GetObjectLegalHoldOptions struct + VersionID string + type GetObjectOptions struct + Internal AdvancedGetOptions + ServerSideEncryption encrypt.ServerSide + VersionID 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) SetUnmodified(modTime time.Time) error + func (o GetObjectOptions) Header() http.Header + type GetObjectTaggingOptions struct + VersionID string + 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 + UseV1 bool + WithMetadata bool + WithVersions bool + 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, start xml.StartElement) (err error) + type MakeBucketOptions struct + ObjectLocking bool + Region string + 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 + ContentType string + ETag string + Err error + Expiration time.Time + ExpirationRuleID string + Expires time.Time + Grant []struct{ ... } + IsDeleteMarker bool + IsLatest bool + Key string + LastModified time.Time + Metadata http.Header + Owner Owner + ReplicationStatus string + Size int64 + StorageClass string + UserMetadata StringMap + UserTagCount int + UserTags map[string]string + 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 + ETag string + LastModified time.Time + PartNumber int + Size int64 + type Options struct + BucketLookup BucketLookupType + Creds *credentials.Credentials + CustomMD5 func() md5simd.Hasher + CustomSHA256 func() md5simd.Hasher + Region string + Secure bool + Transport http.RoundTripper + type Owner struct + DisplayName string + ID string + type ParquetInputOptions struct + type PostPolicy struct + func NewPostPolicy() *PostPolicy + func (p *PostPolicy) SetBucket(bucketName string) error + 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) 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 PutObjectLegalHoldOptions struct + Status *LegalHoldStatus + VersionID string + type PutObjectOptions struct + CacheControl string + ContentDisposition string + ContentEncoding string + ContentLanguage string + ContentType string + 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) Header() (header 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 RemoveObjectError struct + Err error + ObjectName string + VersionID string + type RemoveObjectOptions struct + GovernanceBypass bool + Internal AdvancedRemoveOptions + VersionID 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 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 SelectCompressionType string + 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 + 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 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, start xml.StartElement) error + type UploadInfo struct + Bucket 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 + VersionID string v7.0.65-beta2 Nov 22, 2023 Other modules containing this package github.com/weka/minio-go