forkers

Documentation

Index

• type ForkersPool
  • func (fp *ForkersPool) Run(out1queue int, out2queue int, finished *sync.WaitGroup) (out1 chan *file.FileLink, out2 chan *file.FileInfo)
• type InToFileInfo
• type InToFileLink

Types

type ForkersPool

type ForkersPool struct {
	In             chan *file.PreparedFile
	Out1           chan *file.FileLink
	Out2           chan *file.FileInfo
	Done           chan struct{}
	ForkToFileLink InToFileLink
	ForkToFileInfo InToFileInfo
	WorkersNumber  int
}

func (*ForkersPool) Run

func (fp *ForkersPool) Run(out1queue int, out2queue int, finished *sync.WaitGroup) (out1 chan *file.FileLink, out2 chan *file.FileInfo)

type InToFileInfo

type InToFileInfo func(result *file.PreparedFile) (*file.FileInfo, error)

type InToFileLink

type InToFileLink func(*file.PreparedFile) (*file.FileLink, error)