bundlr

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

type Decoder interface {
	Decode(record interface{}) error
	Close() error
}

type DecoderClosure struct {
	DecodeFunc func(record interface{}) error
	CloseFunc  func() error
}

type DecoderMaker interface {
	Make(File) (Decoder, error)
}

type DecoderMakerFunc func(f File) (Decoder, error)

type Encoder interface {
	Encode(record interface{}) error
	Close() error
}

type EncoderClosure struct {
	EncodeFunc func(record interface{}) error
	CloseFunc  func() error
}

type EncoderMaker interface {
	Make(File) (Encoder, error)
}

type EncoderMakerFunc func(f File) (Encoder, error)

type File interface {
	afero.File
}

type Manifest struct {
	Version  string   `json:"version"`
	UserData UserData `json:"userdata"`
}

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

type SourceFilter interface {
	Filter([]os.FileInfo) []os.FileInfo
}

type UserData map[string]interface{}

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