vfs

package
v0.0.0-...-2f6f43d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 7, 2026 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCSVReader

func NewCSVReader(r io.Reader) (*csv.Reader, error)

func NewReader

func NewReader(r Reader, info fs.FileInfo) (pr *parquet.GenericReader[map[string]any], err error)

Types

type FileReader

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

func NewFileReader

func NewFileReader(name string, r Reader, info fs.FileInfo, format entity.FileFormat) (*FileReader, error)

func (*FileReader) GetCursor

func (r *FileReader) GetCursor() int64

func (*FileReader) GetName

func (r *FileReader) GetName() string

func (*FileReader) Next

func (r *FileReader) Next() (map[string]any, error)

func (*FileReader) SeekToOffset

func (r *FileReader) SeekToOffset(offset int64) error

func (*FileReader) SetCursor

func (r *FileReader) SetCursor(cursor int64)

func (*FileReader) SetName

func (r *FileReader) SetName(name string)

type FileSystem

type FileSystem interface {
	Stat(ctx context.Context, name string) (fs.FileInfo, error)
	MkdirAll(ctx context.Context, name string, perm os.FileMode) error
	ReadDir(ctx context.Context, name string) ([]fs.DirEntry, error)

	ReadFile(ctx context.Context, name string) (Reader, error)
	WriteFile(ctx context.Context, name string, r io.Reader, size int64) error
}

type IUnionFS

type IUnionFS interface {
	StatFile(ctx context.Context, provider entity.Provider, path string) (fs.FileInfo, error)
	GetROFileSystem(provider entity.Provider) (ROFileSystem, error)
}

type ROFileSystem

type ROFileSystem interface {
	Stat(ctx context.Context, name string) (fs.FileInfo, error)
	ReadDir(ctx context.Context, name string) ([]fs.DirEntry, error)
	ReadFile(ctx context.Context, name string) (Reader, error)
}

type Reader

type Reader interface {
	io.ReadCloser
	io.ReaderAt
}

Reader readable file interface.

Directories

Path Synopsis
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL