stream

package
v1.2.0 Latest Latest
Warning

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

Go to latest
Published: Jan 28, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

InputContainerRegex represents the regex of input container name.

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

OutputContainerRegex represents the regex of output container name.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

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