s3

Documentation

Index

• Constants
• type FSMeta
• type S3Client
  • func CreateClient(cfg *config.DriverConfig, secret map[string]string) (*S3Client, error)
  • func CreateClientFromConfig(cfg *S3Config) (*S3Client, error)
  • func (c *S3Client) BucketExists(ctx context.Context, bucketName string) (bool, error)
  • func (c *S3Client) CreateBucket(ctx context.Context, bucketName string) error
  • func (c *S3Client) CreatePrefix(ctx context.Context, bucketName string, prefix string) error
  • func (c *S3Client) GetFSMeta(ctx context.Context, bucketName, prefix string) (*FSMeta, error)
  • func (c *S3Client) RemoveBucket(ctx context.Context, bucketName string) error
  • func (c *S3Client) RemoveObjects(ctx context.Context, bucketName, prefix string) error
  • func (c *S3Client) RemoveObjectsOneByOne(ctx context.Context, bucketName, prefix string) error
  • func (c *S3Client) RemovePrefix(ctx context.Context, bucketName string, prefix string) error
  • func (c *S3Client) SetFSMeta(ctx context.Context, meta *FSMeta) error
• type S3Config

Constants

const (
	MetadataName = ".metadata.json"
)

Types

type FSMeta

type FSMeta struct {
	BucketName    string `json:"name"`
	Prefix        string `json:"prefix"`
	UsePrefix     bool   `json:"useprefix"`
	Mounter       string `json:"mounter"`
	FSPath        string `json:"fspath"`
	CapacityBytes int64  `json:"capacitybytes"`
}

type S3Client

type S3Client struct {
	Config *S3Config
	Minio  *minio.Client
}

func CreateClient

func CreateClient(cfg *config.DriverConfig, secret map[string]string) (*S3Client, error)

func CreateClientFromConfig

func CreateClientFromConfig(cfg *S3Config) (*S3Client, error)

func (*S3Client) BucketExists

func (c *S3Client) BucketExists(ctx context.Context, bucketName string) (bool, error)

func (*S3Client) CreateBucket

func (c *S3Client) CreateBucket(ctx context.Context, bucketName string) error

func (*S3Client) CreatePrefix

func (c *S3Client) CreatePrefix(ctx context.Context, bucketName string, prefix string) error

func (*S3Client) GetFSMeta

func (c *S3Client) GetFSMeta(ctx context.Context, bucketName, prefix string) (*FSMeta, error)

func (*S3Client) RemoveBucket

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

func (*S3Client) RemoveObjects

func (c *S3Client) RemoveObjects(ctx context.Context, bucketName, prefix string) error

func (*S3Client) RemoveObjectsOneByOne

func (c *S3Client) RemoveObjectsOneByOne(ctx context.Context, bucketName, prefix string) error

func (*S3Client) RemovePrefix

func (c *S3Client) RemovePrefix(ctx context.Context, bucketName string, prefix string) error

func (*S3Client) SetFSMeta

func (c *S3Client) SetFSMeta(ctx context.Context, meta *FSMeta) error

type S3Config

type S3Config struct {
	Endpoint        string `json:"endpoint"`
	Region          string `json:"region"`
	AccessKeyID     string `json:"accesskey"`
	SecretAccessKey string `json:"secretkey"`
	Mounter         string `json:"mounter"`
}