stream

Documentation

Index

• Variables
• type FolderReader
  • func NewFolderReader(folder string, prefix string, exclusions []string, duration time.Duration, ...) FolderReader

Variables

var InputContainerRegex = regexp.MustCompile(`^i\d+$`)

InputContainerRegex represents the regex of input container name.

var OutputContainerRegex = regexp.MustCompile(`^csc-o\d+$`)

OutputContainerRegex represents the regex of output container name.

Types

type FolderReader

type FolderReader interface {
	ReadBytes(delim byte) ([]byte, error)
	io.ReadCloser
	Watch(interval time.Duration)
}

FolderReader reads file content from a folder, it simulates single file reader and will read content from all files. Sub-folder will be ignored.

func NewFolderReader

func NewFolderReader(folder string, prefix string, exclusions []string, duration time.Duration, eofCallback context.CancelFunc) FolderReader

NewFolderReader creates a folder content reader. - folder Path of the folder - prefix Only file names with given prefix would be read - exclusions Exclude given files