datafile

Jul 5, 2022

Changes in this version

+ const FileIDByteSize

+ func IsDatafile(fileName string) bool

+ type EOFType bool

type FileID

+ Rand int64

+ Time int64

+ func CreateFileID(t, r int64) FileID

+ func GrepFileIds(fileNames []string) []FileID

+ func GrepFileIdsFromDatafilePath(path string) ([]FileID, error)

+ func NextFileID() FileID

+ func (f FileID) Equal(target FileID) bool

+ func (f FileID) IsZero() bool

+ func (f FileID) Newer(target FileID) bool

+ func (f FileID) String() string

Jun 20, 2022

Changes in this version

+ const IsEOF

+ const IsNotEOF

+ var ErrChecksumFailed = errors.New("error: checksum failed")

+ func CopyTempThreshold(threshold int64) datafileOptFunc

+ func FileID(id int32) datafileOptFunc

+ func FileMode(mode os.FileMode) datafileOptFunc

+ func Open(funcs ...datafileOptFunc) (*datafile, error)

+ func OpenReadonly(funcs ...datafileOptFunc) (*datafile, error)

+ func ParseIds(fns []string) ([]int32, error)

+ func ParseIdsFromDatafiles(path string) ([]int32, error)

+ func Path(path string) datafileOptFunc

+ func RuntimeContext(ctx runtime.Context) datafileOptFunc

+ func TempDir(dir string) datafileOptFunc

+ func ValueOnMemoryThreshold(threshold int64) datafileOptFunc

+ type Datafile interface

+ Close func() error

+ FileID func() int32

+ Name func() string

+ Read func() (*Entry, error)

+ ReadAt func(index, size int64) (*Entry, error)

+ ReadAtHeader func(index int64) (*Header, bool, error)

+ Size func() int64

+ Sync func() error

+ Write func(key []byte, value io.Reader, expiry time.Time) (int64, int64, error)

+ type Entry struct

+ Checksum uint32

+ Expiry time.Time

+ Key []byte

+ TotalSize int64

+ Value io.Reader

+ ValueSize int64

+ func (e *Entry) Close() error

+ func (e *Entry) Read(p []byte) (int, error)

+ func (e *Entry) Validate(ctx runtime.Context) error

+ type Header struct

+ Checksum uint32

+ Expiry time.Time

+ KeySize int32

+ TotalSize int64

+ ValueSize int64