storage

type ComposedStorageProvider struct {
	StorageProvider StorageProvider
}

type Content struct {
	Length int
	Stream chan []byte
}

type Destination struct {
	Destination IDestination
}

type GftProvider struct {
	StorageProvider
	// contains filtered or unexported fields
}

type GftpDestination struct {
	Destination
	// contains filtered or unexported fields
}

type GftpDriver interface {
}

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

type IDestination interface {
	UploadUrl() string
	DownloadStream() (*Content, error)
	DownloadFile(ctx context.Context, destPath string)
	DownloadBytes(ctx context.Context, limit int, resultFunc func(interface{}), errFunc func(error))
}

type InputStorage struct {
	InputStorageProvider
}

type InputStorageProvider interface {
	UploadStream(length int, stream []byte) (Source, error)
	UploadBytes(data []byte) (Source, error)
	UploadFile(filePath string) (Source, error)
}

type OutputStorageProvider interface {
	NewDestination(destFile string) IDestination
}

type PubLink struct {
	File string
	Url  string
}

type Source interface {
	DownloadUrl() string
	ContentLength() int
}

type StorageProvider interface {
	InputStorageProvider
	OutputStorageProvider
}