file

Documentation

Index

• Variables
• func NewFileSource(opt shared.OptionMap, cce chan *shared.ChangeEvent, wg *sync.WaitGroup, ...) (sources.Source, error)
• type FileSource
  • func (fs *FileSource) Initialise() error
  • func (fs *FileSource) Start()
  • func (fs *FileSource) Stop()

Variables

var (
	MissingFilepathError = errors.New("path not specified")
)

Functions

func NewFileSource

func NewFileSource(
	opt shared.OptionMap,
	cce chan *shared.ChangeEvent,
	wg *sync.WaitGroup,
	sc chan bool,
) (
	sources.Source,
	error,
)

Types

type FileSource

type FileSource struct {
	// contains filtered or unexported fields
}

func (*FileSource) Initialise

func (fs *FileSource) Initialise() error

func (*FileSource) Start

func (fs *FileSource) Start()

func (*FileSource) Stop

func (fs *FileSource) Stop()