Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FileInputHandler ¶
type FileInputHandler struct {
// contains filtered or unexported fields
}
func NewFileInputHandler ¶
func NewFileInputHandler(filepath string) *FileInputHandler
func (*FileInputHandler) FeedChannel ¶
func (h *FileInputHandler) FeedChannel(in chan<- interface{}, wg *sync.WaitGroup) error
type FileOutputHandler ¶
type FileOutputHandler struct {
// contains filtered or unexported fields
}
func NewFileOutputHandler ¶
func NewFileOutputHandler(filepath string) *FileOutputHandler
func (*FileOutputHandler) WriteResults ¶
func (h *FileOutputHandler) WriteResults(results <-chan string, wg *sync.WaitGroup) error
type StreamInputHandler ¶
type StreamInputHandler struct {
// contains filtered or unexported fields
}
func NewStreamInputHandler ¶
func NewStreamInputHandler(r io.Reader) *StreamInputHandler
func (*StreamInputHandler) FeedChannel ¶
func (h *StreamInputHandler) FeedChannel(in chan<- interface{}, wg *sync.WaitGroup) error
type StreamOutputHandler ¶
type StreamOutputHandler struct {
// contains filtered or unexported fields
}
func NewStreamOutputHandler ¶
func NewStreamOutputHandler(w io.Writer) *StreamOutputHandler
func (*StreamOutputHandler) WriteResults ¶
func (h *StreamOutputHandler) WriteResults(results <-chan string, wg *sync.WaitGroup) error
Source Files
Click to show internal directories.
Click to hide internal directories.