source

Documentation

Index

• type Event
• type Source
  • func NewFileSource(path string, cfg appconfig.SourceConfig) (Source, error)
  • func NewStdinSource(file *os.File, cfg appconfig.InputConfig) Source
  • func NewTailedFileSource(path string, cfg appconfig.SourceConfig) (Source, error)
  • func Open(inputPath string, stdin *os.File, cfg *appconfig.Config) (Source, error)

Types

type Event

type Event struct {
	Line *string
	Err  error
	Done bool
}

type Source

type Source interface {
	Name() string
	Events() <-chan Event
	Close() error
}

func NewFileSource

func NewFileSource(path string, cfg appconfig.SourceConfig) (Source, error)

func NewStdinSource

func NewStdinSource(file *os.File, cfg appconfig.InputConfig) Source

func NewTailedFileSource

func NewTailedFileSource(path string, cfg appconfig.SourceConfig) (Source, error)

func Open

func Open(inputPath string, stdin *os.File, cfg *appconfig.Config) (Source, error)