request

type Az struct {
	Account   string
	Container string
	KeyPrefix string
}

type CanSetSecret interface {
	SetSecret(dmfr.Secret) error
}

type Downloader interface {
	Download(context.Context, string) (io.ReadCloser, int, error)
	DownloadAuth(context.Context, string, dmfr.FeedAuthorization) (io.ReadCloser, int, error)
}

type FetchResponse struct {
	ResponseSize   int
	ResponseCode   int
	ResponseTimeMs int
	ResponseTtfbMs int
	ResponseSHA1   string
	FetchError     error
}

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

type Http struct {

	// MaxRetries sets the maximum number of retry attempts for a request.
	// If MaxRetries is zero or negative, a default value (defaultMaxRetries) is used.
	MaxRetries int
	// BackoffSchedule defines the backoff duration for each retry attempt.
	// If nil or empty, defaultBackoffSchedule is used.
	BackoffSchedule []time.Duration
	// contains filtered or unexported fields
}

type Local struct {
	Directory string
}

type Presigner interface {
	CreateSignedUrl(context.Context, string, string) (string, error)
}

type Request struct {
	URL        string
	AllowFTP   bool
	AllowLocal bool
	AllowS3    bool
	MaxSize    uint64
	Secret     dmfr.Secret
	Auth       dmfr.FeedAuthorization
}

type RequestOption func(*Request)

type S3 struct {
	Bucket    string
	KeyPrefix string
	// contains filtered or unexported fields
}

type Store interface {
	Downloader
	Uploader
	CanSetSecret
	ListKeys(ctx context.Context, prefix string) ([]string, error)
}

type Uploader interface {
	Upload(context.Context, string, io.Reader) error
}