Documentation ¶
Index ¶
- Variables
- func BuildLocalPath(f *file.FileBasic) string
- func CastFromDownloadedFile(df *file.DownloadedFile) (*file.CompleteFile, error)
- func CastFromRecognizedPhoto(rp *recognizers.RecognizedPhoto) (*file.CompleteFile, error)
- func CastToFileInfo(pf *file.PreparedFile) (*file.FileInfo, error)
- func CastToFileLink(pf *file.PreparedFile) (*file.FileLink, error)
- func NonBlockingNotify(errorc chan error, err error)
- type DbStoragesPool
- type FileDownloadersPool
- type FilePreparationsPool
- type RequestHandler
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrWrongForkPath = errors.New("wrong fork path") ErrBadDeforkAttempt = errors.New("bad defork attempt") )
Functions ¶
func BuildLocalPath ¶
func CastFromDownloadedFile ¶
func CastFromDownloadedFile(df *file.DownloadedFile) (*file.CompleteFile, error)
func CastFromRecognizedPhoto ¶
func CastFromRecognizedPhoto(rp *recognizers.RecognizedPhoto) (*file.CompleteFile, error)
func CastToFileInfo ¶
func CastToFileInfo(pf *file.PreparedFile) (*file.FileInfo, error)
func CastToFileLink ¶
func CastToFileLink(pf *file.PreparedFile) (*file.FileLink, error)
func NonBlockingNotify ¶
Types ¶
type DbStoragesPool ¶
type DbStoragesPool struct { In chan *file.CompleteFile WorkersNumber int }
func (*DbStoragesPool) Run ¶
func (dsp *DbStoragesPool) Run(finished *sync.WaitGroup)
type FileDownloadersPool ¶
type FileDownloadersPool struct { In chan *file.FileLink Out chan *file.DownloadedFile Done chan struct{} WorkersNumber int }
func (*FileDownloadersPool) Run ¶
func (fdp *FileDownloadersPool) Run(queueSize int, finished *sync.WaitGroup) chan *file.DownloadedFile
type FilePreparationsPool ¶
type FilePreparationsPool struct { In chan *file.FileBasic Out chan *file.PreparedFile Done chan struct{} WorkersNumber int }
func (*FilePreparationsPool) Run ¶
func (fpp *FilePreparationsPool) Run(outBufferSize int, finished *sync.WaitGroup) chan *file.PreparedFile
type RequestHandler ¶
type RequestHandler struct {
// contains filtered or unexported fields
}
func NewRequestHandler ¶
func NewRequestHandler() *RequestHandler
func (*RequestHandler) RegisterHandlers ¶
func (r *RequestHandler) RegisterHandlers()
func (*RequestHandler) ServeHTTP ¶
func (r *RequestHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)
Source Files ¶
Click to show internal directories.
Click to hide internal directories.