Versions in this module Expand all Collapse all v0 v0.0.6 Dec 9, 2021 Changes in this version + func InitDB(dst string) (*sql.DB, error) + func InsertArchives(db *sql.DB, archives []*Archive) error + func InsertStream(db *sql.DB, archiveID, byteBegin, byteEnd int64, pageIDs []int64, ...) error + func MarkArchiveProcessed(db *sql.DB, id int64) error + func SearchPageName(db *sql.DB, name string) ([]int64, error) + func SelectPage(db *sql.DB, pageID int64) (int64, error) + func SelectPages(db *sql.DB, pageIDs []int64) ([]int64, error) + type Archive struct + FilePath string + FileSize int64 + ID int64 + IndexPath string + func SelectArchives(db *sql.DB) ([]*Archive, error) + type Stream struct + ByteBegin int64 + ByteEnd int64 + ID int64 + Path string + func SelectArchiveStreams(db *sql.DB, archivePath string) ([]*Stream, error) + func SelectStream(db *sql.DB, streamID int64) (*Stream, error) + func SelectStreams(db *sql.DB, streamIDs []int64) ([]*Stream, error)