sources

Feb 17, 2021

Changes in this version

+ func ToDir(path string) string

type File

+ func (f File) Resolve(ctx context.Context, u *url.URL) (onNext <-chan File, onError <-chan Error)

Oct 28, 2020

Changes in this version

type Aggregate

+ func (a *Aggregate) Resolve(_ context.Context, _ url.URL) (<-chan File, <-chan Error)

+ type Error struct

+ Filename string

+ Message string

+ func NewError(filename string, message string) Error

+ func NewErrorFrom(filename string, err error) Error

+ func (e Error) Error() string

type File

+ Source Source

type FileSystem

+ func (fs *FileSystem) Resolve(ctx context.Context, u url.URL) (<-chan File, <-chan Error)

type Git

+ func (g *Git) Resolve(ctx context.Context, u url.URL) (<-chan File, <-chan Error)

+ type HTTP struct

+ func (src *HTTP) Read(ctx context.Context) (<-chan File, <-chan Error)

+ func (src *HTTP) Resolve(ctx context.Context, u url.URL) (<-chan File, <-chan Error)

type Noop

+ func (n Noop) Resolve(ctx context.Context, _ url.URL) (<-chan File, <-chan Error)

type Source

+ func Create(str string) (Source, error)

+ func CreateFrom(u url.URL) (Source, error)

+ func NewGitFrom(repo *git.Repository, filter glob.Glob) (Source, error)

+ func NewHTTP(u url.URL) (Source, error)

+ Resolve func(ctx context.Context, url url.URL) (onNext <-chan File, onError <-chan Error)

+ type SourceFactory func(u url.URL) (Source, error)

+ type SourceType int

+ const SourceTypeFS

+ const SourceTypeGIT

+ const SourceTypeHTTP

+ const SourceTypeUnknown

+ func GetType(u url.URL) SourceType

May 30, 2020

Changes in this version

+ func IsSupportedFile(name string) bool

Feb 17, 2020

Changes in this version

+ type Aggregate struct

+ func NewAggregate(sources ...Source) *Aggregate

+ func (a *Aggregate) Add(src Source)

+ func (a *Aggregate) Read(ctx context.Context) Stream

+ type File struct

+ Content []byte

+ Error error

+ Name string

+ type FileSystem struct

+ func NewFileSystem(path string) (*FileSystem, error)

+ func (fs *FileSystem) Read(ctx context.Context) Stream

+ func (fs *FileSystem) SetFilter(pattern string) error

+ type Git struct

+ func NewGit(url string) *Git

+ func (g Git) Read(ctx context.Context) Stream

+ type Noop struct

+ func NewNoop() *Noop

+ func (n Noop) Read(_ context.Context) Stream

+ type Source interface

+ Read func(ctx context.Context) Stream

+ func New(locations ...string) (Source, error)

+ type Stream struct

+ Errors <-chan error

+ Files <-chan File