s3

Documentation

Index

• type BucketMethods
  • func (bm *BucketMethods) Client() *Client
  • func (bm *BucketMethods) Delete(ctx context.Context, documents ...*DeleteRequest) DeleteResponse
  • func (bm *BucketMethods) Get(ctx context.Context, documents ...*GetRequest) GetResponse
  • func (bm *BucketMethods) Put(ctx context.Context, documents ...*PutRequest) PutResponse
• type Client
  • func New(tls bool, endpoint, accessKey, secretKey string) (*Client, error)
  • func (c *Client) Bucket(name string) *BucketMethods
• type DeleteRequest
  • func NewDeleteRequest(path string) *DeleteRequest
• type DeleteResponse
  • func (d DeleteResponse) Err() error
• type DeleteResponseItem
• type GetRequest
  • func NewGetRequest(path string) *GetRequest
  • func (g *GetRequest) SetOptions(configure func(*minio.GetObjectOptions)) *GetRequest
• type GetResponse
  • func (g GetResponse) Close() error
  • func (g GetResponse) Err() error
• type GetResponseItem
• type Options
  • func (o *Options) MustNewClient() *Client
  • func (o *Options) NewClient() (*Client, error)
• type PutRequest
  • func NewPutRequest(reader io.Reader) *PutRequest
  • func (p *PutRequest) SetName(name string) *PutRequest
  • func (p *PutRequest) SetOptions(configure func(*minio.PutObjectOptions)) *PutRequest
  • func (p *PutRequest) SetSize(size int64) *PutRequest
• type PutResponse
  • func (p PutResponse) Err() error
• type PutResponseItem

Types

type BucketMethods

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

func (*BucketMethods) Client

func (bm *BucketMethods) Client() *Client

func (*BucketMethods) Delete

func (bm *BucketMethods) Delete(ctx context.Context, documents ...*DeleteRequest) DeleteResponse

func (*BucketMethods) Get

func (bm *BucketMethods) Get(ctx context.Context, documents ...*GetRequest) GetResponse

func (*BucketMethods) Put

func (bm *BucketMethods) Put(ctx context.Context, documents ...*PutRequest) PutResponse

type Client

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

func New

func New(tls bool, endpoint, accessKey, secretKey string) (*Client, error)

func (*Client) Bucket

func (c *Client) Bucket(name string) *BucketMethods

type DeleteRequest

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

func NewDeleteRequest

func NewDeleteRequest(path string) *DeleteRequest

type DeleteResponse

type DeleteResponse []DeleteResponseItem

func (DeleteResponse) Err

func (d DeleteResponse) Err() error

type DeleteResponseItem

type DeleteResponseItem struct {
	Path string
	Err  error
}

type GetRequest

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

func NewGetRequest

func NewGetRequest(path string) *GetRequest

func (*GetRequest) SetOptions

func (g *GetRequest) SetOptions(configure func(*minio.GetObjectOptions)) *GetRequest

type GetResponse

type GetResponse []GetResponseItem

func (GetResponse) Close

func (g GetResponse) Close() error

func (GetResponse) Err

func (g GetResponse) Err() error

type GetResponseItem

type GetResponseItem struct {
	Path   string
	Err    error
	Object *minio.Object
}

type Options

type Options struct {
	S3 struct {
		Endpoint  string `long:"endpoint" env:"ENDPOINT" description:"s3 storage endpoint"`
		AccessKey string `long:"access-key" env:"ACCESS_KEY" description:"s3 access key"`
		SecretKey string `long:"secret-key" env:"SECRET_KEY" description:"s3 secret key"`
		TLS       bool   `long:"tls" env:"TLS" description:"s3 tls connection"`
	} `group:"s3" namespace:"s3" env-namespace:"S3"`
}

func (*Options) MustNewClient

func (o *Options) MustNewClient() *Client

func (*Options) NewClient

func (o *Options) NewClient() (*Client, error)

type PutRequest

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

func NewPutRequest

func NewPutRequest(reader io.Reader) *PutRequest

func (*PutRequest) SetName

func (p *PutRequest) SetName(name string) *PutRequest

func (*PutRequest) SetOptions

func (p *PutRequest) SetOptions(configure func(*minio.PutObjectOptions)) *PutRequest

func (*PutRequest) SetSize

func (p *PutRequest) SetSize(size int64) *PutRequest

type PutResponse

type PutResponse []PutResponseItem

func (PutResponse) Err

func (p PutResponse) Err() error

type PutResponseItem

type PutResponseItem struct {
	Name  string
	Info  minio.UploadInfo
	Error error
}