broker

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

type Exchange interface {
	/** Connect to the broker using local as exchangesFolder where download/upload files are */
	Connect(onUpdate chan Update) error
	Disconnect()

	Status() Status

	/** List lists all the entries at the provided bucket */
	List(bucket string) ([]os.FileInfo, error)

	/** Push the file to the bucket */
	Put(bucket string, info os.FileInfo, reader io.Reader) error

	/** Get a file content from the bucket */
	Get(bucket string, info os.FileInfo, writer io.Writer) error

	/** Purge all files older than the specified timestamp*/
	Delete(bucket string, info os.FileInfo) error

	String() string
}

type FTPConfig struct {
	URL      string `json:"url" yaml:"url"`
	Username string `json:"username" yaml:"username"`
	Password string `json:"password" yaml:"password"`
	Timeout  int    `json:"timeout" yaml:"timeout"`
}

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

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

type S3Config struct {
	Name      string `json:"name" yaml:"name"`
	Endpoint  string `json:"endpoint" yaml:"endpoint"`
	Bucket    string `json:"bucket" yaml:"bucket"`
	AccessKey string `json:"accessKey" yaml:"accessKey"`
	Secret    string `json:"secret" yaml:"secret"`
	UseSSL    bool   `json:"useSSL" yaml:"useSSL"`
	Location  string `json:"location" yaml:"location"`
}

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

type Status struct {
	Err         error
	SupportList bool
}

type USBConfig struct {
	Name   string `json:"name" yaml:"name"`
	Folder string `json:"folder" yaml:"folder"`
}

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

type Update struct {
	Exchange Exchange
	Bucket   string
	Info     os.FileInfo
	Reader   io.Reader
}