store

type Config struct {
	MaxConnections      int
	DefaultTimeout      time.Duration
	DrainTimeout        time.Duration
	KeysDontNeedSorting bool
}

type CurrentFile struct {
	FileName      string `json:"filename"`
	IndexFileName string `json:"index_filename"`
}

type ErrCreatingPool struct {
	Err error
}

type ErrReadingIndex struct {
	Err error
}

type ErrReadingRecordFromDisk struct {
	Err error
}

type HashRecord struct {
	Fields map[string]string `json:"fields"`
}

type IndexRecord struct {
	Key    string `json:"key"`
	Offset int64  `json:"offset"`
	Len    int    `json:"len"`
	Type   string `json:"type"`
}

type ListRecord struct {
	Elements []string `json:"elements"`
}

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

type OpenReaderSeekCloser func() (io.ReadSeekCloser, error)

type OrderedSetElement struct {
	Value string  `json:"value"`
	Score float64 `json:"score"`
}

type OrderedSetRecord struct {
	Elements []OrderedSetElement `json:"elements"`
}

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

type Record struct {
	Key  string `json:"key"`
	Type string `json:"type"`

	StringRecord    *StringRecord     `json:"string_record,omitempty"`
	HashRecord      *HashRecord       `json:"hash_record,omitempty"`
	ListRecord      *ListRecord       `json:"list_record,omitempty"`
	OrdderSetRecord *OrderedSetRecord `json:"ordered_set_record,omitempty"`
}

type Store struct {
	StoreIndex *StoreIndex
	// contains filtered or unexported fields
}

type StoreIndex struct {
	SortedKeys []string
	Index      map[string]IndexRecord
}

type StringRecord struct {
	Value string `json:"value"`
}