requestHandler

package
v0.0.0-...-9e7b976 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 29, 2017 License: MIT Imports: 16 Imported by: 1

Documentation

Index

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 BuildLocalPath(f *file.FileBasic) string

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(pf *file.PreparedFile) (*file.FileLink, error)

func NonBlockingNotify

func NonBlockingNotify(errorc chan error, err error)

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)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL