minio

package module

Go to main page

Versions in this module

v2

v2.1.0

May 7, 2017

Changes in this version

+ const DefaultRetryCap

+ const DefaultRetryUnit

+ const ObjectAccessedAll

+ const ObjectAccessedGet

+ const ObjectAccessedHead

+ const ObjectCreatedPut

type Client

+ func NewWithRegion(endpoint, accessKeyID, secretAccessKey string, secure bool, region string) (*Client, error)

+ func (c Client) GetEncryptedObject(bucketName, objectName string, encryptMaterials encrypt.Materials) (io.Reader, error)

+ func (c Client) PutEncryptedObject(bucketName, objectName string, reader io.Reader, ...) (n int64, err error)

+ func (c Client) PutObjectStreaming(bucketName, objectName string, reader io.Reader) (n int64, err error)

+ func (c Client) PutObjectStreamingWithMetadata(bucketName, objectName string, reader io.Reader, metadata map[string][]string) (n int64, err error)

+ func (c Client) PutObjectStreamingWithProgress(bucketName, objectName string, reader io.Reader, metadata map[string][]string, ...) (n int64, err error)

+ type CompletePart struct

+ ETag string

+ PartNumber int

+ XMLName xml.Name

+ type Core struct

+ func NewCore(endpoint string, accessKeyID, secretAccessKey string, secure bool) (*Core, error)

+ func (c Core) AbortMultipartUpload(bucket, object, uploadID string) error

+ func (c Core) CompleteMultipartUpload(bucket, object, uploadID string, parts []CompletePart) error

+ func (c Core) GetBucketPolicy(bucket string) (policy.BucketAccessPolicy, error)

+ func (c Core) GetObject(bucketName, objectName string, reqHeaders RequestHeaders) (io.ReadCloser, ObjectInfo, error)

+ func (c Core) ListMultipartUploads(bucket, prefix, keyMarker, uploadIDMarker, delimiter string, maxUploads int) (result ListMultipartUploadsResult, err error)

+ func (c Core) ListObjectParts(bucket, object, uploadID string, partNumberMarker int, maxParts 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(bucket, object string, metadata map[string][]string) (uploadID string, err error)

+ func (c Core) PutBucketPolicy(bucket string, bucketPolicy policy.BucketAccessPolicy) error

+ func (c Core) PutObject(bucket, object string, size int64, data io.Reader, md5Sum, sha256Sum []byte, ...) (ObjectInfo, error)

+ func (c Core) PutObjectPart(bucket, object, uploadID string, partID int, size int64, data io.Reader, ...) (ObjectPart, error)

+ func (c Core) StatObject(bucketName, objectName string, reqHeaders RequestHeaders) (ObjectInfo, error)

type ErrorResponse

+ Headers http.Header

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

+ Source sourceInfo

+ type ObjectPart struct

+ ETag string

+ LastModified time.Time

+ PartNumber int

+ Size int64

+ type RequestHeaders struct

+ func NewGetReqHeaders() RequestHeaders

+ func NewHeadReqHeaders() RequestHeaders

+ func (c RequestHeaders) SetMatchETag(etag string) error

+ func (c RequestHeaders) SetMatchETagExcept(etag string) error

+ func (c RequestHeaders) SetModified(modTime time.Time) error

+ func (c RequestHeaders) SetRange(start, end int64) error

+ func (c RequestHeaders) SetUnmodified(modTime time.Time) error

type SignatureType

+ const SignatureV4Streaming

v2.0.4

Feb 6, 2017

Changes in this version

+ func ErrTransferAccelerationBucket(bucketName string) error

type Client

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

v2.0.3

Jan 1, 2017

Changes in this version

type Client

+ func (c Client) PutObjectWithMetadata(bucketName, objectName string, reader io.Reader, metaData map[string][]string, ...) (n int64, err error)

type NotificationConfig

+ ID string

type ObjectInfo

+ Metadata http.Header

type PostPolicy

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

v2.0.2

Oct 10, 2016

Changes in this version

+ const ObjectCreatePut

+ const ObjectCreatedAll

+ const ObjectCreatedCompleteMultipartUpload

+ const ObjectCreatedCopy

+ const ObjectCreatedPost

+ const ObjectReducedRedundancyLostObject

+ const ObjectRemovedAll

+ const ObjectRemovedDelete

+ const ObjectRemovedDeleteMarkerCreated

+ func ErrAPINotSupported(message string) error

+ type Arn struct

+ AccountID string

+ Partition string

+ Region string

+ Resource string

+ Service string

+ func NewArn(partition, service, region, accountID, resource string) Arn

+ func (arn Arn) String() string

+ type BucketNotification struct

+ LambdaConfigs []LambdaConfig

+ QueueConfigs []QueueConfig

+ TopicConfigs []TopicConfig

+ XMLName xml.Name

+ func (b *BucketNotification) AddLambda(lambdaConfig NotificationConfig)

+ func (b *BucketNotification) AddQueue(queueConfig NotificationConfig)

+ func (b *BucketNotification) AddTopic(topicConfig NotificationConfig)

+ func (b *BucketNotification) RemoveLambdaByArn(arn Arn)

+ func (b *BucketNotification) RemoveQueueByArn(arn Arn)

+ func (b *BucketNotification) RemoveTopicByArn(arn Arn)

type Client

+ func (c Client) GetBucketLocation(bucketName string) (string, error)

+ func (c Client) GetBucketNotification(bucketName string) (bucketNotification BucketNotification, err error)

+ func (c Client) ListBucketPolicies(bucketName, objectPrefix string) (bucketPolicies map[string]policy.BucketPolicy, err error)

+ func (c Client) ListenBucketNotification(bucketName, prefix, suffix string, events []string, doneCh <-chan struct{}) <-chan NotificationInfo

+ func (c Client) RemoveAllBucketNotification(bucketName string) error

+ func (c Client) RemoveObjects(bucketName string, objectsCh <-chan string) <-chan RemoveObjectError

+ func (c Client) SetBucketNotification(bucketName string, bucketNotification BucketNotification) error

+ type Filter struct

+ S3Key S3Key

+ type FilterRule struct

+ Name string

+ Value string

+ type LambdaConfig struct

+ Lambda string

+ type NotificationConfig struct

+ Arn Arn

+ Events []NotificationEventType

+ Filter *Filter

+ Id string

+ func NewNotificationConfig(arn Arn) NotificationConfig

+ func (t *NotificationConfig) AddEvents(events ...NotificationEventType)

+ func (t *NotificationConfig) AddFilterPrefix(prefix string)

+ func (t *NotificationConfig) AddFilterSuffix(suffix string)

+ type NotificationEvent struct

+ AwsRegion string

+ EventName string

+ EventSource string

+ EventTime string

+ EventVersion string

+ RequestParameters map[string]string

+ ResponseElements map[string]string

+ S3 eventMeta

+ UserIdentity identity

+ type NotificationEventType string

+ type NotificationInfo struct

+ Err error

+ Records []NotificationEvent

+ type QueueConfig struct

+ Queue string

+ type RemoveObjectError struct

+ Err error

+ ObjectName string

+ type S3Key struct

+ FilterRules []FilterRule

+ type TopicConfig struct

+ Topic string

v2.0.1

Jul 19, 2016

v2.0.0

Jul 19, 2016

Changes in this version

+ const BucketPolicyNone

+ const BucketPolicyReadOnly

+ const BucketPolicyReadWrite

+ const BucketPolicyWriteOnly

+ const MaxJitter

+ const NoJitter

+ var ErrInvalidObjectPrefix = ErrInvalidObjectName

+ var MaxRetry = 5

+ func ErrEntityTooLarge(totalSize, maxObjectSize int64, bucketName, objectName string) error

+ func ErrEntityTooSmall(totalSize int64, bucketName, objectName string) error

+ func ErrInvalidArgument(message string) error

+ func ErrInvalidBucketName(message string) error

+ func ErrInvalidObjectName(message string) error

+ func ErrInvalidParts(expectedParts, uploadedParts int) error

+ func ErrNoSuchBucketPolicy(message string) error

+ func ErrUnexpectedEOF(totalRead, totalSize int64, bucketName, objectName string) error

+ type BucketAccessPolicy struct

+ Statements []Statement

+ Version string

+ type BucketInfo struct

+ CreationDate time.Time

+ Name string

+ type BucketPolicy string

+ type Client struct

+ func New(endpoint string, accessKeyID, secretAccessKey string, secure bool) (*Client, error)

+ func NewV2(endpoint string, accessKeyID, secretAccessKey string, secure bool) (*Client, error)

+ func NewV4(endpoint string, accessKeyID, secretAccessKey string, secure bool) (*Client, error)

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

+ func (c *Client) SetCustomTransport(customHTTPTransport http.RoundTripper)

+ func (c *Client) TraceOff()

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

+ func (c Client) BucketExists(bucketName string) error

+ func (c Client) CopyObject(bucketName string, objectName string, objectSource string, ...) error

+ func (c Client) FGetObject(bucketName, objectName, filePath string) error

+ func (c Client) FPutObject(bucketName, objectName, filePath, contentType string) (n int64, err error)

+ func (c Client) GetBucketPolicy(bucketName, objectPrefix string) (bucketPolicy BucketPolicy, err error)

+ func (c Client) GetObject(bucketName, objectName string) (*Object, error)

+ func (c Client) ListBuckets() ([]BucketInfo, error)

+ func (c Client) ListIncompleteUploads(bucketName, objectPrefix string, recursive bool, doneCh <-chan struct{}) <-chan ObjectMultipartInfo

+ func (c Client) ListObjects(bucketName, objectPrefix string, recursive bool, doneCh <-chan struct{}) <-chan ObjectInfo

+ func (c Client) ListObjectsV2(bucketName, objectPrefix string, recursive bool, doneCh <-chan struct{}) <-chan ObjectInfo

+ func (c Client) MakeBucket(bucketName string, location string) error

+ func (c Client) PresignedGetObject(bucketName string, objectName string, expires time.Duration, ...) (u *url.URL, err error)

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

+ func (c Client) PresignedPutObject(bucketName string, objectName string, expires time.Duration) (u *url.URL, err error)

+ func (c Client) PutObject(bucketName, objectName string, reader io.Reader, contentType string) (n int64, err error)

+ func (c Client) PutObjectWithProgress(bucketName, objectName string, reader io.Reader, contentType string, ...) (n int64, err error)

+ func (c Client) RemoveBucket(bucketName string) error

+ func (c Client) RemoveIncompleteUpload(bucketName, objectName string) error

+ func (c Client) RemoveObject(bucketName, objectName string) error

+ func (c Client) SetBucketPolicy(bucketName string, objectPrefix string, bucketPolicy BucketPolicy) error

+ func (c Client) StatObject(bucketName, objectName string) (ObjectInfo, error)

+ type CopyConditions struct

+ func NewCopyConditions() CopyConditions

+ func (c CopyConditions) SetMatchETag(etag string) error

+ func (c CopyConditions) SetMatchETagExcept(etag string) error

+ func (c CopyConditions) SetModified(modTime time.Time) error

+ func (c CopyConditions) SetUnmodified(modTime time.Time) error

+ type ErrorResponse struct

+ BucketName string

+ Code string

+ HostID string

+ Key string

+ Message string

+ Region string

+ RequestID string

+ XMLName xml.Name

+ func ToErrorResponse(err error) ErrorResponse

+ func (e ErrorResponse) Error() 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

+ Key string

+ LastModified time.Time

+ Owner struct{ ... }

+ Size int64

+ StorageClass string

+ type ObjectMultipartInfo struct

+ Err error

+ Initiated time.Time

+ Initiator initiator

+ Key string

+ Owner owner

+ Size int64

+ StorageClass string

+ UploadID string

+ type PostPolicy struct

+ func NewPostPolicy() *PostPolicy

+ func (p *PostPolicy) SetBucket(bucketName 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) String() string

+ type SignatureType int

+ const Latest

+ const SignatureV2

+ const SignatureV4

+ type Statement struct

+ Actions []string

+ Conditions map[string]map[string]string

+ Effect string

+ Principal User

+ Resources []string

+ Sid string

+ type User struct

+ AWS []string

Other modules containing this package

gopkg.in/minio/minio-go.v0

gopkg.in/minio/minio-go.v1

gopkg.in/minio/minio-go.v3

gopkg.in/minio/minio-go.v6

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL