importer

Documentation

Index

• func Backends() []string
• func Register(name string, backend func() ImporterBackend)
• type Importer
  • func NewImporter(location string) (*Importer, error)
  • func (importer *Importer) Begin(config string) error
  • func (importer *Importer) End() error
  • func (importer *Importer) Open(pathname string) (io.ReadCloser, error)
  • func (importer *Importer) Scan() (<-chan ImporterRecord, <-chan error, error)
• type ImporterBackend
• type ImporterRecord

Functions

func Backends

func Backends() []string

func Register

func Register(name string, backend func() ImporterBackend)

Types

type Importer

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

func NewImporter

func NewImporter(location string) (*Importer, error)

func (*Importer) Begin

func (importer *Importer) Begin(config string) error

func (*Importer) End

func (importer *Importer) End() error

func (*Importer) Open

func (importer *Importer) Open(pathname string) (io.ReadCloser, error)

func (*Importer) Scan

func (importer *Importer) Scan() (<-chan ImporterRecord, <-chan error, error)

type ImporterBackend

type ImporterBackend interface {
	Begin(config string) error
	Scan() (<-chan ImporterRecord, <-chan error, error)
	Open(pathname string) (io.ReadCloser, error)
	End() error
}

type ImporterRecord

type ImporterRecord struct {
	Pathname string
	Stat     fs.FileInfo
}