minio

Mar 10, 2024

Changes in this version

type Client

+ func (c *Client) SetS3EnableDualstack(enabled bool)

Feb 10, 2024

Changes in this version

+ const ETag

+ const GetObjectAttributesMaxParts

+ const GetObjectAttributesTags

type Client

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

+ type ObjectAttributePart struct

+ ChecksumCRC32 string

+ ChecksumCRC32C string

+ ChecksumSHA1 string

+ ChecksumSHA256 string

+ PartNumber int

+ Size int

+ type ObjectAttributes struct

+ LastModified time.Time

+ VersionID string

+ type ObjectAttributesOptions struct

+ MaxParts int

+ PartNumberMarker int

+ ServerSideEncryption encrypt.ServerSide

+ VersionID string

+ type ObjectAttributesResponse struct

+ Checksum struct{ ... }

+ ETag string

+ ObjectParts struct{ ... }

+ ObjectSize int

+ StorageClass string

Dec 14, 2023

Changes in this version

+ type AdvancedObjectTaggingOptions struct

+ ReplicationProxyRequest string

type GetObjectTaggingOptions

+ Internal AdvancedObjectTaggingOptions

type PutObjectTaggingOptions

+ Internal AdvancedObjectTaggingOptions

type RemoveObjectTaggingOptions

+ Internal AdvancedObjectTaggingOptions

Nov 20, 2023

Changes in this version

type PutObjectOptions

+ Expires time.Time

type SnowballObject

+ Headers http.Header

+ VersionID string

Aug 24, 2023

Changes in this version

type SnowballOptions

+ SkipErrs bool

Jul 17, 2023

Changes in this version

type Options

+ Trace *httptrace.ClientTrace

Jul 11, 2023

Changes in this version

type ObjectInfo

+ Internal ...

type Version

+ Internal ...

Jun 29, 2023

Changes in this version

type AdvancedPutOptions

+ ReplicationValidityCheck bool

type AdvancedRemoveOptions

+ ReplicationValidityCheck bool

type Client

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

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

May 25, 2023

Changes in this version

+ 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

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

type PostPolicy

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

type PutObjectFanOutRequest

+ Checksum Checksum

May 24, 2023

Changes in this version

type PostPolicy

+ func (p *PostPolicy) SetChecksums(cksum map[string]string)

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

+ 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

+ Checksums map[string]string

+ Entries []PutObjectFanOutEntry

+ SSE encrypt.ServerSide

May 19, 2023

Changes in this version

type Client

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

+ type PutObjectFanOutRequest 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 PutObjectFanOutResponse struct

+ ETag string

+ Error error

+ Key string

+ LastModified *time.Time

+ VersionID string

Apr 7, 2023

Changes in this version

+ type URLMap map[string]string

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

type Version

+ UserMetadata StringMap

+ UserTags URLMap

Mar 24, 2023

Changes in this version

type Options

+ CustomRegionViaURL func(u url.URL) string

+ type PutObjectPartOptions struct

+ CustomHeader http.Header

+ Md5Base64 string

+ SSE encrypt.ServerSide

+ Sha256Hex string

+ Trailer http.Header

Feb 18, 2023

Changes in this version

type PutObjectOptions

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

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

Feb 9, 2023

Changes in this version

type GetObjectOptions

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

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

Jan 6, 2023

Changes in this version

type PutObjectOptions

+ ConcurrentStreamParts bool

Oct 26, 2022

Changes in this version

type AdvancedGetOptions

+ IsReplicationReadyForDeleteMarker bool

Oct 20, 2022

Changes in this version

type Options

+ TrailingHeaders bool

Oct 14, 2022

Changes in this version

type ObjectInfo

+ ReplicationReady bool

Sep 16, 2022

Changes in this version

type CompletePart

+ ChecksumCRC32 string

+ ChecksumCRC32C string

+ ChecksumSHA1 string

+ ChecksumSHA256 string

type GetObjectOptions

+ Checksum bool

type ObjectInfo

+ ChecksumCRC32 string

+ ChecksumCRC32C string

+ ChecksumSHA1 string

+ ChecksumSHA256 string

type ObjectPart

+ ChecksumCRC32 string

+ ChecksumCRC32C string

+ ChecksumSHA1 string

+ ChecksumSHA256 string

type UploadInfo

+ ChecksumCRC32 string

+ ChecksumCRC32C string

+ ChecksumSHA1 string

+ ChecksumSHA256 string

Jun 28, 2022

Changes in this version

type PutObjectOptions

+ DisableContentSha256 bool

May 7, 2022

Changes in this version

type BucketVersioningConfiguration

+ ExcludeFolders bool

+ ExcludedPrefixes []ExcludedPrefix

+ type ExcludedPrefix struct

+ Prefix string

Feb 10, 2022

Changes in this version

type Client

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

Dec 22, 2021

Changes in this version

type ErrorResponse

+ Resource string

Dec 8, 2021

Changes in this version

type Client

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

type GetObjectOptions

+ PartNumber int

+ type RemoveObjectResult struct

+ DeleteMarker bool

+ DeleteMarkerVersionID string

+ Err error

+ ObjectName string

+ ObjectVersionID string

Nov 17, 2021

Changes in this version

type Client

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

+ type RemoveBucketOptions struct

+ ForceDelete bool

Oct 18, 2021

Changes in this version

type Client

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

+ type SnowballObject struct

+ Close func()

+ Content io.Reader

+ Key string

+ ModTime time.Time

+ Size int64

+ type SnowballOptions struct

+ Compress bool

+ InMemory bool

+ Opts PutObjectOptions

Sep 14, 2021

Changes in this version

+ const RestoreSelect

+ const SelectCompressionLZ4

+ const SelectCompressionS2

+ const SelectCompressionSNAPPY

+ const SelectCompressionZSTD

+ const TierBulk

+ const TierExpedited

+ const TierStandard

+ func IsNetworkOrHostDown(err error, expectTimeouts bool) bool

+ type AccessControlList struct

+ Grant []Grant

+ Permission string

+ XMLName xml.Name

type AdvancedPutOptions

+ LegalholdTimestamp time.Time

+ RetentionTimestamp time.Time

+ TaggingTimestamp time.Time

type Client

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

+ func (c *Client) IsOffline() bool

+ func (c *Client) IsOnline() bool

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

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

+ type Encryption struct

+ EncryptionType string

+ KMSContext string

+ KMSKeyID 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 MetadataEntry struct

+ Name string

+ Value string

type ObjectInfo

+ Restore *RestoreInfo

+ type OutputLocation struct

+ S3 S3

+ XMLName xml.Name

type Owner

+ XMLName xml.Name

+ 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 S3 struct

+ AccessControlList *AccessControlList

+ BucketName string

+ CannedACL *string

+ Encryption *Encryption

+ Prefix string

+ StorageClass *string

+ Tagging *tags.Tags

+ UserMetadata *MetadataEntry

+ type SelectParameters struct

+ Expression string

+ ExpressionType QueryExpressionType

+ InputSerialization SelectObjectInputSerialization

+ OutputSerialization SelectObjectOutputSerialization

+ XMLName xml.Name

+ type TierType string

Aug 23, 2021

Changes in this version

+ type BucketOptions struct

+ ForceDelete bool

type Client

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

type ListObjectsOptions

+ StartAfter string

type RemoveObjectOptions

+ ForceDelete bool

Jun 22, 2021

Changes in this version

type ListObjectsOptions

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

Jun 11, 2021

Changes in this version

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

type AdvancedPutOptions

+ ReplicationRequest bool

type AdvancedRemoveOptions

+ ReplicationRequest bool

type Client

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

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

Jan 7, 2021

Changes in this version

type AdvancedGetOptions

+ ReplicationProxyRequest bool

type PostPolicy

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

Nov 28, 2020

Changes in this version

+ const Enabled

+ const Suspended

+ type AdvancedGetOptions struct

+ ReplicationDeleteMarker bool

+ type AdvancedPutOptions struct

+ ReplicationStatus ReplicationStatus

+ SourceETag string

+ SourceMTime time.Time

+ SourceVersionID string

+ type AdvancedRemoveOptions struct

+ ReplicationDeleteMarker bool

+ ReplicationMTime time.Time

+ ReplicationStatus ReplicationStatus

type BucketVersioningConfiguration

+ func (b BucketVersioningConfiguration) Enabled() bool

+ func (b BucketVersioningConfiguration) Suspended() bool

type GetObjectOptions

+ Internal AdvancedGetOptions

type PutObjectOptions

+ Internal AdvancedPutOptions

type RemoveObjectOptions

+ Internal AdvancedRemoveOptions

Aug 19, 2020

Changes in this version

type PutObjectOptions

+ ReplicationETag string

Jul 24, 2020

Changes in this version

type Client

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

type ObjectInfo

+ Expiration time.Time

+ ExpirationRuleID string

+ ReplicationStatus string

+ UserTagCount int

type UploadInfo

+ ExpirationRuleID string

Jul 17, 2020

Changes in this version

+ const CSVFileHeaderInfoIgnore

+ const CSVFileHeaderInfoNone

+ const CSVFileHeaderInfoUse

+ const DefaultRetryCap

+ const DefaultRetryUnit

+ const MaxJitter

+ const NoJitter

+ const SelectCompressionBZIP

+ const SelectCompressionGZIP

+ const SelectCompressionNONE

+ const SelectObjectTypeCSV

+ const SelectObjectTypeJSON

+ const SelectObjectTypeParquet

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

+ var MaxRetry = 10

+ 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

+ 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) 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) 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

+ 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

+ Expires time.Time

+ Grant []struct{ ... }

+ IsDeleteMarker bool

+ IsLatest bool

+ Key string

+ LastModified time.Time

+ Metadata http.Header

+ Owner Owner

+ Size int64

+ StorageClass string

+ UserMetadata StringMap

+ 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.Transport

+ 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) 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

+ LegalHold LegalHoldStatus

+ Mode RetentionMode

+ NumThreads uint

+ PartSize uint64

+ Progress io.Reader

+ ReplicationMTime time.Time

+ ReplicationStatus ReplicationStatus

+ ReplicationVersionID string

+ 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

+ 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

+ 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