uploader

type AbortMultipartParam struct {
	Bucket    string
	Key       string
	UploadID  string
	SessionID string
}

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

type CompleteMultipartParam struct {
	Bucket             string
	Key                string
	UploadID           string
	CompletedPartsInfo []s3Types.CompletedPart
}

type IUploader interface {
	CreateChunkUploadSession(sessionInfo *types.SessionInfo) error

	Upload(sessionInfo *types.SessionInfo, file []byte) (*UploadAck, error)
	CompletePartUpload(sessionInfo *types.SessionInfo, file []byte) (*UploadAck, error)

	HandlePartUpload(sessionInfo *types.SessionInfo, file []byte) error

	CancelUploadSession(sessionInfo *types.SessionInfo) error

	DeleteUpload(uploadInfo *db.DeleteDocumentsByIdsRow) error
}

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

type LocalUploaderCompleteRes struct {
	FilePath string
	Checkum  string
}

type Metadata struct {
	Key    string `json:"key"`
	Etag   string `json:"etag"`
	Bucket string `json:"bucket"`
}

type MultipartSessionInfo struct {
	UploadInfo *s3.CreateMultipartUploadOutput
	Parts      s3Types.CompletedMultipartUpload
}

type UploadAck struct {
	Provider         types.UploaderProvider
	ProviderMetadata interface{}
	Checksum         string
	FilePath         string
}

type UploadFullFileParam struct {
	Bucket string
	Key    string
	File   io.Reader
}

type UploadPartParam struct {
	Bucket   string
	Key      string
	Part     int32
	Body     *bytes.Reader
	UploadID string
}

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