X-Git-Url: https://git.arvados.org/lightning.git/blobdiff_plain/4b2768ea08e31c85ea09b1b183c391aaeb933d6c..HEAD:/gob.go diff --git a/gob.go b/gob.go deleted file mode 100644 index 907c7befcb..0000000000 --- a/gob.go +++ /dev/null @@ -1,68 +0,0 @@ -package main - -import ( - "bufio" - "encoding/gob" - "io" - "io/ioutil" - _ "net/http/pprof" - - "github.com/klauspost/pgzip" - "golang.org/x/crypto/blake2b" -) - -type CompactGenome struct { - Name string - Variants []tileVariantID -} - -type CompactSequence struct { - Name string - TileSequences map[string][]tileLibRef -} - -type TileVariant struct { - Tag tagID - Variant tileVariantID - Blake2b [blake2b.Size256]byte - Sequence []byte -} - -type LibraryEntry struct { - TagSet [][]byte - CompactGenomes []CompactGenome - CompactSequences []CompactSequence - TileVariants []TileVariant -} - -func ReadCompactGenomes(rdr io.Reader, gz bool) ([]CompactGenome, error) { - var ret []CompactGenome - err := DecodeLibrary(rdr, gz, func(ent *LibraryEntry) error { - ret = append(ret, ent.CompactGenomes...) - return nil - }) - return ret, err -} - -func DecodeLibrary(rdr io.Reader, gz bool, cb func(*LibraryEntry) error) error { - zrdr := ioutil.NopCloser(rdr) - var err error - if gz { - zrdr, err = pgzip.NewReader(bufio.NewReaderSize(rdr, 1<<26)) - if err != nil { - return err - } - } - dec := gob.NewDecoder(zrdr) - for err == nil { - var ent LibraryEntry - err = dec.Decode(&ent) - if err == nil { - err = cb(&ent) - } - } - if err != io.EOF { - return err - } - return zrdr.Close() -}