filesystem

Documentation

Index

• type FileSystem
  • func (f *FileSystem) Create(inputFiles <-chan *betav1.FileInfo) (<-chan *betav1.FileInfo, error)
  • func (s *FileSystem) Get(inputFiles <-chan *betav1.FileInfo) (<-chan *betav1.FileInfo, error)
  • func (f *FileSystem) List() (<-chan *betav1.FileInfo, error)
  • func (f *FileSystem) Verify(inputFiles <-chan *betav1.FileInfo) (<-chan *betav1.FileInfo, error)

Types

type FileSystem

type FileSystem struct {
	SyncDir string
}

FileSystem is the implementation for betav1/SyncObject for the FileSystem

func (*FileSystem) Create

func (f *FileSystem) Create(inputFiles <-chan *betav1.FileInfo) (<-chan *betav1.FileInfo, error)

Create accepts a channel of files to create

func (*FileSystem) Get

func (s *FileSystem) Get(inputFiles <-chan *betav1.FileInfo) (<-chan *betav1.FileInfo, error)

Get downloads the content for incoming FileInfo and passes them to the next step

func (*FileSystem) List

func (f *FileSystem) List() (<-chan *betav1.FileInfo, error)

List all local files and passes them to the next step

func (*FileSystem) Verify

func (f *FileSystem) Verify(inputFiles <-chan *betav1.FileInfo) (<-chan *betav1.FileInfo, error)

Verify checks to see if the FileInfo exists on the filesystem already and the md5 matches if it doesn't it passes them to the next step to be downloaded