files

Documentation

Index

• func DecodeMetadata(metadata string) (map[string]string, error)
• func EncodeMetadata(metadata map[string]string) string
• type File
  • func (f *File) Download(fm *FileManager) (downloadFileResult, error)
• type FileManager
  • func NewFileManager(db *db.Database, sftp *sftp.SFTPClient) *FileManager
  • func (fm *FileManager) GetFile(id string) (*File, error)
  • func (fm *FileManager) ProcessFile(req FileProcessRequest) *FileQueueEntry
  • func (fm *FileManager) StartWorkers()
  • func (fm *FileManager) StopWorkers()
  • func (fm *FileManager) WaitForFile(id string)
• type FileProcessRequest
• type FileQueueEntry

Functions

func DecodeMetadata

func DecodeMetadata(metadata string) (map[string]string, error)

func EncodeMetadata

func EncodeMetadata(metadata map[string]string) string

Types

type File

type File struct {
	ID                string
	CreatedAt         time.Time
	OriginalURL       string
	OriginalExpiresAt null.Time
	ExpiresAt         null.Time
	Size              int
	Hash              null.String
	ContentType       null.String
	Metadata          map[string]string
}

func (*File) Download

func (f *File) Download(fm *FileManager) (downloadFileResult, error)

type FileManager

type FileManager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewFileManager

func NewFileManager(db *db.Database, sftp *sftp.SFTPClient) *FileManager

func (*FileManager) GetFile

func (fm *FileManager) GetFile(id string) (*File, error)

func (*FileManager) ProcessFile

func (fm *FileManager) ProcessFile(req FileProcessRequest) *FileQueueEntry

func (*FileManager) StartWorkers

func (fm *FileManager) StartWorkers()

func (*FileManager) StopWorkers

func (fm *FileManager) StopWorkers()

func (*FileManager) WaitForFile

func (fm *FileManager) WaitForFile(id string)

type FileProcessRequest

type FileProcessRequest struct {
	OriginalURL       string
	OriginalExpiresAt null.Time
	ExpiresAt         null.Time         `json:"expires_at"`
	Size              null.Int          `json:"size"`
	MaxSize           null.Int          `json:"max_size"`
	Metadata          map[string]string `json:"metadata"`
}

type FileQueueEntry

type FileQueueEntry struct {
	ID                string
	OriginalURL       string
	OriginalExpiresAt null.Time
	ExpiresAt         null.Time
	Size              null.Int
	MaxSize           null.Int
	Metadata          map[string]string

	Done chan struct{}
}