mc

Documentation

Index

• func New(endpoint, accessKey, secretKey, signatureVersion string, secure bool, ...) (nodes.StorageClient, error)
• type Client
  • func (c *Client) AbortMultipartUpload(ctx context.Context, bucket, object, uploadID string) error
  • func (c *Client) BucketNotifications(ctx context.Context, bucketName string, prefix string, events []string) (<-chan interface{}, error)
  • func (c *Client) BucketTags(ctx context.Context, bucketName string) (map[string]string, error)
  • func (c *Client) CompleteMultipartUpload(ctx context.Context, bucket, object, uploadID string, ...) (string, error)
  • func (c *Client) CopyObject(ctx context.Context, sourceBucket, sourceObject, destBucket, destObject string, ...) (models.ObjectInfo, error)
  • func (c *Client) CopyObjectMultipart(ctx context.Context, srcObject models.ObjectInfo, ...) error
  • func (c *Client) CopyObjectMultipartThreshold() int64
  • func (c *Client) GetObject(ctx context.Context, bucketName, objectName string, opts models.ReadMeta) (io.ReadCloser, models.ObjectInfo, error)
  • func (c *Client) ListBuckets(ctx context.Context) ([]models.BucketInfo, error)
  • func (c *Client) ListMultipartUploads(ctx context.Context, ...) (result models.ListMultipartUploadsResult, err error)
  • func (c *Client) ListObjectParts(ctx context.Context, bucketName, objectName, uploadID string, ...) (models.ListObjectPartsResult, error)
  • func (c *Client) ListObjects(ctx context.Context, bucket, prefix, marker, delimiter string, max ...int) (result models.ListBucketResult, err error)
  • func (c *Client) MakeBucket(ctx context.Context, bucketName string, location string) (err error)
  • func (c *Client) NewMultipartUpload(ctx context.Context, bucket, object string, opts models.PutMeta) (uploadID string, err error)
  • func (c *Client) PutObject(ctx context.Context, bucketName, objectName string, reader io.Reader, ...) (n models.ObjectInfo, err error)
  • func (c *Client) PutObjectPart(ctx context.Context, bucket, object, uploadID string, partID int, ...) (models.MultipartObjectPart, error)
  • func (c *Client) RemoveBucket(ctx context.Context, bucketName string) error
  • func (c *Client) RemoveObject(ctx context.Context, bucketName, objectName string) error
  • func (c *Client) StatObject(ctx context.Context, bucketName, objectName string, opts models.ReadMeta) (models.ObjectInfo, error)
• type HiddenFoldersWrapper
  • func (c *HiddenFoldersWrapper) CopyObject(ctx context.Context, sourceBucket, sourceObject, destBucket, destObject string, ...) (models.ObjectInfo, error)
  • func (c *HiddenFoldersWrapper) GetObject(ctx context.Context, bucketName, objectName string, opts models.ReadMeta) (io.ReadCloser, models.ObjectInfo, error)
  • func (c *HiddenFoldersWrapper) ListObjects(ctx context.Context, bucket, prefix, marker, delimiter string, max ...int) (result models.ListBucketResult, err error)
  • func (c *HiddenFoldersWrapper) PutObject(ctx context.Context, bucketName, objectName string, reader io.Reader, ...) (n models.ObjectInfo, err error)
  • func (c *HiddenFoldersWrapper) RemoveObject(ctx context.Context, bucketName, objectName string) error
  • func (c *HiddenFoldersWrapper) StatObject(ctx context.Context, bucketName, objectName string, opts models.ReadMeta) (models.ObjectInfo, error)

Functions

func New

func New(endpoint, accessKey, secretKey, signatureVersion string, secure bool, customRegion string, other configx.Values) (nodes.StorageClient, error)

New creates a new minio.Core with the most standard options

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client wraps a minio.Core client in the nodes.StorageClient interface

func (*Client) AbortMultipartUpload

func (c *Client) AbortMultipartUpload(ctx context.Context, bucket, object, uploadID string) error

func (*Client) BucketNotifications

func (c *Client) BucketNotifications(ctx context.Context, bucketName string, prefix string, events []string) (<-chan interface{}, error)

BucketNotifications hooks to events

func (*Client) BucketTags

func (c *Client) BucketTags(ctx context.Context, bucketName string) (map[string]string, error)

func (*Client) CompleteMultipartUpload

func (c *Client) CompleteMultipartUpload(ctx context.Context, bucket, object, uploadID string, parts []models.MultipartObjectPart) (string, error)

func (*Client) CopyObject

func (c *Client) CopyObject(ctx context.Context, sourceBucket, sourceObject, destBucket, destObject string, srcMeta, metadata map[string]string, progress io.Reader) (models.ObjectInfo, error)

func (*Client) CopyObjectMultipart

func (c *Client) CopyObjectMultipart(ctx context.Context, srcObject models.ObjectInfo, srcBucket, srcPath, destBucket, destPath string, meta map[string]string, progress io.Reader) error

func (*Client) CopyObjectMultipartThreshold

func (c *Client) CopyObjectMultipartThreshold() int64

func (*Client) GetObject

func (c *Client) GetObject(ctx context.Context, bucketName, objectName string, opts models.ReadMeta) (io.ReadCloser, models.ObjectInfo, error)

func (*Client) ListBuckets

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

func (*Client) ListMultipartUploads

func (c *Client) ListMultipartUploads(ctx context.Context, bucket, prefix, keyMarker, uploadIDMarker, delimiter string, maxUploads int) (result models.ListMultipartUploadsResult, err error)

func (*Client) ListObjectParts

func (c *Client) ListObjectParts(ctx context.Context, bucketName, objectName, uploadID string, partNumberMarker, maxParts int) (models.ListObjectPartsResult, error)

func (*Client) ListObjects

func (c *Client) ListObjects(ctx context.Context, bucket, prefix, marker, delimiter string, max ...int) (result models.ListBucketResult, err error)

func (*Client) MakeBucket

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

func (*Client) NewMultipartUpload

func (c *Client) NewMultipartUpload(ctx context.Context, bucket, object string, opts models.PutMeta) (uploadID string, err error)

func (*Client) PutObject

func (c *Client) PutObject(ctx context.Context, bucketName, objectName string, reader io.Reader, objectSize int64, opts models.PutMeta) (n models.ObjectInfo, err error)

func (*Client) PutObjectPart

func (c *Client) PutObjectPart(ctx context.Context, bucket, object, uploadID string, partID int, data io.Reader, size int64, md5Base64, sha256Hex string) (models.MultipartObjectPart, error)

func (*Client) RemoveBucket

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

func (*Client) RemoveObject

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

func (*Client) StatObject

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

type HiddenFoldersWrapper

type HiddenFoldersWrapper struct {
	*Client
	// contains filtered or unexported fields
}

func (*HiddenFoldersWrapper) CopyObject

func (c *HiddenFoldersWrapper) CopyObject(ctx context.Context, sourceBucket, sourceObject, destBucket, destObject string, srcMeta, metadata map[string]string, progress io.Reader) (models.ObjectInfo, error)

func (*HiddenFoldersWrapper) GetObject

func (c *HiddenFoldersWrapper) GetObject(ctx context.Context, bucketName, objectName string, opts models.ReadMeta) (io.ReadCloser, models.ObjectInfo, error)

func (*HiddenFoldersWrapper) ListObjects

func (c *HiddenFoldersWrapper) ListObjects(ctx context.Context, bucket, prefix, marker, delimiter string, max ...int) (result models.ListBucketResult, err error)

func (*HiddenFoldersWrapper) PutObject

func (c *HiddenFoldersWrapper) PutObject(ctx context.Context, bucketName, objectName string, reader io.Reader, objectSize int64, opts models.PutMeta) (n models.ObjectInfo, err error)

func (*HiddenFoldersWrapper) RemoveObject

func (c *HiddenFoldersWrapper) RemoveObject(ctx context.Context, bucketName, objectName string) error

func (*HiddenFoldersWrapper) StatObject

func (c *HiddenFoldersWrapper) StatObject(ctx context.Context, bucketName, objectName string, opts models.ReadMeta) (models.ObjectInfo, error)