request

Feb 24, 2026

Changes in this version

type Az

+ VerifyUpload bool

Jan 6, 2026

Changes in this version

type Http

+ BackoffSchedule []time.Duration

+ MaxRetries int

Jun 24, 2025

Changes in this version

type S3

+ func (r *S3) SetAcl(acl string)

Mar 11, 2025

Changes in this version

+ func DownloadAll(ctx context.Context, r Store, outDir string, prefix string, ...) ([]string, error)

+ func Upload(ctx context.Context, r Uploader, fn string, key string) error

+ func UploadAll(ctx context.Context, r Uploader, srcDir string, prefix string, ...) error

type Az

+ func (r *Az) SetSecret(secret dmfr.Secret) error

+ func (r Az) DownloadAuth(ctx context.Context, key string, auth dmfr.FeedAuthorization) (io.ReadCloser, int, error)

+ func (r Az) ListKeys(ctx context.Context, prefix string) ([]string, error)

+ type CanSetSecret interface

+ SetSecret func(dmfr.Secret) error

type Downloader

+ DownloadAuth func(context.Context, string, dmfr.FeedAuthorization) (io.ReadCloser, int, error)

type FetchResponse

+ ResponseTimeMs int

+ ResponseTtfbMs int

type Ftp

+ func (r *Ftp) SetSecret(secret dmfr.Secret) error

+ func (r Ftp) DownloadAuth(ctx context.Context, ustr string, auth dmfr.FeedAuthorization) (io.ReadCloser, int, error)

type Http

+ func (r *Http) SetSecret(secret dmfr.Secret) error

+ func (r Http) DownloadAuth(ctx context.Context, ustr string, auth dmfr.FeedAuthorization) (io.ReadCloser, int, error)

type Local

+ func (r *Local) ListKeys(ctx context.Context, prefix string) ([]string, error)

+ func (r *Local) SetSecret(secret dmfr.Secret) error

+ func (r Local) DownloadAuth(ctx context.Context, key string, auth dmfr.FeedAuthorization) (io.ReadCloser, int, error)

type S3

+ func (r *S3) SetSecret(secret dmfr.Secret) error

+ func (r S3) DownloadAuth(ctx context.Context, key string, auth dmfr.FeedAuthorization) (io.ReadCloser, int, error)

+ func (r S3) ListKeys(ctx context.Context, prefix string) ([]string, error)

type Store

+ ListKeys func(ctx context.Context, prefix string) ([]string, error)

Oct 16, 2024

Changes in this version

+ func Download(storage string, key string) (io.ReadCloser, error)

+ func UploadFile(storage string, src string, dst string) error

+ func WithAllowFTP(req *Request)

+ func WithAllowLocal(req *Request)

+ func WithAllowS3(req *Request)

+ func WithAuth(secret dmfr.Secret, auth dmfr.FeedAuthorization) func(req *Request)

+ type Az struct

+ Account string

+ Container string

+ KeyPrefix string

+ func NewAzFromUrl(ustr string) (*Az, error)

+ func (r Az) CreateSignedUrl(ctx context.Context, key string, contentDisposition string, secret dmfr.Secret) (string, error)

+ func (r Az) Download(ctx context.Context, key string, secret dmfr.Secret, ...) (io.ReadCloser, int, error)

+ func (r Az) Upload(ctx context.Context, key string, secret dmfr.Secret, uploadFile io.Reader) error

+ type Downloader interface

+ Download func(context.Context, string, dmfr.Secret, dmfr.FeedAuthorization) (io.ReadCloser, int, error)

+ type FetchResponse struct

+ Data []byte

+ FetchError error

+ Filename string

+ ResponseCode int

+ ResponseSHA1 string

+ ResponseSize int

+ func AuthenticatedRequest(address string, opts ...RequestOption) (FetchResponse, error)

+ func AuthenticatedRequestDownload(address string, opts ...RequestOption) (FetchResponse, error)

+ type Ftp struct

+ func (Ftp) Download(ctx context.Context, ustr string, secret dmfr.Secret, ...) (io.ReadCloser, int, error)

+ type Http struct

+ func (r Http) Download(ctx context.Context, ustr string, secret dmfr.Secret, ...) (io.ReadCloser, int, error)

+ type Local struct

+ Directory string

+ func (r Local) Download(ctx context.Context, ustr string, secret dmfr.Secret, ...) (io.ReadCloser, int, error)

+ func (r Local) Exists(ctx context.Context, key string) bool

+ func (r Local) Upload(ctx context.Context, key string, secret dmfr.Secret, uploadFile io.Reader) error

+ type Presigner interface

+ CreateSignedUrl func(context.Context, string, string, dmfr.Secret) (string, error)

+ type Request struct

+ AllowFTP bool

+ AllowLocal bool

+ AllowS3 bool

+ Auth dmfr.FeedAuthorization

+ MaxSize uint64

+ Secret dmfr.Secret

+ URL string

+ func NewRequest(address string, opts ...RequestOption) *Request

+ func (req *Request) Request(ctx context.Context) (io.ReadCloser, int, error)

+ type RequestOption func(*Request)

+ func WithMaxSize(s uint64) RequestOption

+ type S3 struct

+ Bucket string

+ KeyPrefix string

+ func NewS3FromUrl(ustr string) (*S3, error)

+ func (r S3) CreateSignedUrl(ctx context.Context, key string, contentDisposition string, secret dmfr.Secret) (string, error)

+ func (r S3) Download(ctx context.Context, key string, secret dmfr.Secret, ...) (io.ReadCloser, int, error)

+ func (r S3) Upload(ctx context.Context, key string, secret dmfr.Secret, uploadFile io.Reader) error

+ type Store interface

+ func GetStore(ustr string) (Store, error)

+ type Uploader interface

+ Upload func(context.Context, string, dmfr.Secret, io.Reader) error