embedded

type Config ¶

type Config struct {
	// WebDAVURL is the destination WebDAV endpoint files are uploaded to.
	WebDAVURL string `mapstructure:"webdav_url"`
	// Timeout is the per-file ceiling, in seconds.
	Timeout int `mapstructure:"embedded_transfer_timeout"`
	// IdleTimeout, in seconds, aborts a file attempt if no bytes flow for that long.
	IdleTimeout int `mapstructure:"embedded_transfer_idle_timeout"`
	// Retries is the number of attempts per file (1 = no retry).
	Retries int `mapstructure:"embedded_transfer_retries"`
}

Config holds the settings for transferring embedded share payloads.

func (c *Config) ApplyDefaults()

type NewFunc ¶

type NewFunc func(ctx context.Context, m map[string]any) (Transferrer, error)

NewFunc builds a Transferrer from its driver configuration.

type Transferrer ¶

type Transferrer interface {
	Process(ctx context.Context, payload, destination string, onComplete func(error)) error
}

Transferrer processes an embedded share payload, transferring its referenced files to a destination. Drivers register an implementation via Register.

Process returns synchronously once the transfer has been scheduled; the actual copy runs in the background. The optional onComplete callback is invoked once the transfer has finished, with a nil error on success, allowing the caller to observe completion (e.g. to advance the share state). A malformed payload is reported as a synchronous error from Process and onComplete is not called.

func New(ctx context.Context, m map[string]any) (Transferrer, error)