s3

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

type Client interface {
	// UploadFile uploads data under a given s3 path.
	UploadFile(ctx context.Context, upload *Upload, options ...UploadOption) (*UploadInfo, error)

	// GetFile returns the file from given s3 path.
	GetFile(ctx context.Context, path string, options ...GetOption) (File, error)

	// GetObjectInfo returns an minio.ObjectInfo for the given s3 path.
	GetFileInfo(ctx context.Context, path string) (*FileInfo, error)

	// GetDirectory returns a list of files from given s3 folder.
	GetDirectory(ctx context.Context, path string, options ...GetDirectoryOption) ([]File, error)

	// GetDirectoryInfos returns a list of file infos for all files from given s3 folder.
	GetDirectoryInfos(ctx context.Context, path string) ([]*FileInfo, error)

	// DownloadFile downloads the requested file to the file system under given localPath.
	DownloadFile(ctx context.Context, path, localPath string, options ...DownloadOption) error

	// DownloadDirectory downloads the requested folder to the file system.
	// The recursive option also downloads all sub folders.
	DownloadDirectory(ctx context.Context, path, localPath string, recursive bool, options ...DownloadOption) error

	// RemoveFile deletes the file under given s3 path.
	RemoveFile(ctx context.Context, path string, options ...RemoveOption) error

	// AddLifeCycleRule adds a lifecycle rule to the given folder.
	AddLifeCycleRule(ctx context.Context, ruleID, folderPath string, daysToExpiry int) error

	// CreateFileLink creates a link with expiration for a file under the given path.
	CreateFileLink(ctx context.Context, path string, expiration time.Duration) (*url.URL, error)

	// Close closes the s3 client.
	Close()

	// IsOnline reports true if the client is online. If the health-check has not been enabled this will always return true.
	IsOnline() bool

	// IsHealthy reports true if the client is online. If the health-check has not been enabled this will always return true.
	IsHealthy() bool

	// GetName returns the name of the client.
	GetName() string
}

type ClientDetails struct {
	Host         string
	AccessKey    string
	AccessSecret string
	BucketName   string
	Secure       bool
}

type ClientGetOptions minio.GetObjectOptions

type ClientOption func(*client) error

type ClientRemoveOptions minio.RemoveObjectOptions

type ClientUploadOptions minio.PutObjectOptions

type DownloadOption func(*downloadOptions)

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

type File interface {
	io.ReadCloser
	// Info returns the file information.
	Info() *FileInfo
	// Bytes reads the entire file and returns its content as a byte slice.
	//
	// Note: The file is closed and must not be read after using this function!
	Bytes() ([]byte, error)
}

type FileInfo struct {
	Name         string
	Path         string
	Size         int64
	ContentType  string
	MetaData     map[string]string
	ModifiedDate time.Time
	Integrity
}

type GetDirectoryOption func(*getDirectoryOptions)

type GetOption func(*getOptions)

type Integrity struct {
	ChecksumCRC32C string // When CRC32C integrity support is disabled, ChecksumCRC32C will be empty if no explicit integrity check was requested via option
	ChecksumMD5    string // When MD5 integrity support is disabled, ChecksumMD5 will be empty if no explicit integrity check was requested via option
}

type RemoveOption func(*removeOptions)

type Upload struct {
	io.ReadSeeker
	Path        string
	ContentType string
	MetaData    map[string]string
	Size        *int64
}

type UploadInfo struct {
	Size int64
	Integrity
}

type UploadOption func(*uploadOptions)