Function LoadRecords

storage/records.go:19–34

LoadRecords loads and indexes raw protobuf records from the data files found in a given path.

(dataPath string)

// LoadRecords loads and indexes raw protobuf records from
// the data files found in a given path.
func LoadRecords(dataPath string) (*Records, error) {
	recs := &Records{
		Index:  WithDriver(dataPath, RecordDriver{}),
		metaBy: make(map[string]metaIndex),
	}

	if err := recs.Load(); err != nil {
		return nil, err
	}

	for _, m := range recs.index {
		recs.metaIndexCreate(m.(*pb.Record))
	}

	return recs, nil
}

func (r *Records) metaIndexCreate(rec *pb.Record) {
	r.Lock()