Versions in this module Expand all Collapse all v0 v0.6.0 Oct 27, 2021 v0.5.1 Jul 18, 2020 Changes in this version + const MaxTableSize + const MaxValueLogEntries + const MaxValueLogFileSize + func CreateHashValue(ids [][]byte, unique bool) ([]byte, []byte) + func NewAATable() (map[[2]rune]uint32, map[uint32][2]rune) + func NewKVStore(kv *KVStore, options badger.Options, flushSize int, nbOfThreads int) + func RemoveDuplicatesFromSlice(s [][]byte) [][]byte + func SplitHashValue(hashValue []byte) ([][]byte, error) + type KC_ struct + func KC_New(opts badger.Options, flushSize int, nbOfThreads int) *KC_ + func (kc *KC_) CreateKCKeyValue(keys [][]byte) ([]byte, []byte) + type KComb struct + Count uint32 + ProteinKeys []uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KComb) Descriptor() ([]byte, []int) + func (*KComb) ProtoMessage() + func (m *KComb) GetCount() uint32 + func (m *KComb) GetProteinKeys() []uint32 + func (m *KComb) Reset() + func (m *KComb) String() string + func (m *KComb) XXX_DiscardUnknown() + func (m *KComb) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KComb) XXX_Merge(src proto.Message) + func (m *KComb) XXX_Size() int + func (m *KComb) XXX_Unmarshal(b []byte) error + type KSettings struct + CreationDate string + DatabaseIndexed bool + IDsIndexed bool + Name string + NamesIndexed bool + OriginalFile string + Port int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KSettings) Descriptor() ([]byte, []int) + func (*KSettings) ProtoMessage() + func (m *KSettings) GetCreationDate() string + func (m *KSettings) GetDatabaseIndexed() bool + func (m *KSettings) GetIDsIndexed() bool + func (m *KSettings) GetName() string + func (m *KSettings) GetNamesIndexed() bool + func (m *KSettings) GetOriginalFile() string + func (m *KSettings) GetPort() int32 + func (m *KSettings) Reset() + func (m *KSettings) String() string + func (m *KSettings) XXX_DiscardUnknown() + func (m *KSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KSettings) XXX_Merge(src proto.Message) + func (m *KSettings) XXX_Size() int + func (m *KSettings) XXX_Unmarshal(b []byte) error + type KStats struct + Features []string + NumberOfAA uint64 + NumberOfKCombSets uint64 + NumberOfKmers uint64 + NumberOfProteins uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KStats) Descriptor() ([]byte, []int) + func (*KStats) ProtoMessage() + func (m *KStats) GetFeatures() []string + func (m *KStats) GetNumberOfAA() uint64 + func (m *KStats) GetNumberOfKCombSets() uint64 + func (m *KStats) GetNumberOfKmers() uint64 + func (m *KStats) GetNumberOfProteins() uint64 + func (m *KStats) Reset() + func (m *KStats) String() string + func (m *KStats) XXX_DiscardUnknown() + func (m *KStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KStats) XXX_Merge(src proto.Message) + func (m *KStats) XXX_Size() int + func (m *KStats) XXX_Unmarshal(b []byte) error + type KV struct + Key []byte + Unique bool + Val []byte + type KVStore struct + BatchCounter uint64 + DB *badger.DB + FlushSize int + Mu sync.Mutex + NbOfThreads int + NilVal []byte + TxBatchChannel []TxBatch + TxBatchChannelJobs chan KV + TxBatchChannelWG *sync.WaitGroup + func (kv *KVStore) AddValueChanWorker() + func (kv *KVStore) AddValueToChannel(key []byte, newVal []byte, unique bool) + func (kv *KVStore) Close() + func (kv *KVStore) CloseInsertChannel() + func (kv *KVStore) Flush() + func (kv *KVStore) GarbageCollect(count int, ratio float64) + func (kv *KVStore) GetValue(key []byte) ([]byte, bool) + func (kv *KVStore) GetValueFromBadger(key []byte) ([]byte, error) + func (kv *KVStore) GetValues(key []byte) ([][]byte, error) + func (kv *KVStore) MergeCombinationKeys(combKeys [][]byte, threadId int) []byte + func (kv *KVStore) OpenInsertChannel() + func (kv *KVStore) UpdateValue(key []byte, val []byte) + type KVStores struct + KCombStore *KC_ + KmerStore *K_ + ProteinStore *P_ + func KVStoresNew(dbPath string, nbOfThreads int, tableLoadingMode options.FileLoadingMode, ...) *KVStores + func (kvStores *KVStores) Close() + func (kvStores *KVStores) CloseInsertChannel() + func (kvStores *KVStores) Flush() + func (kvStores *KVStores) OpenInsertChannel() + type KVsToMerge struct + Key []byte + Values [][]byte + type K_ struct + func K_New(opts badger.Options, flushSize int, nbOfThreads int) *K_ + func (k *K_) CreateBytesKey(kmer string) []byte + func (k *K_) CreateBytesVal(entry string) []byte + func (k *K_) DecodeKmer(key []byte) string + func (k *K_) EncodeEntry(kmer string) uint32 + func (k *K_) EncodeKmer(kmer string) uint32 + type P_ struct + func P_New(opts badger.Options, flushSize int, nbOfThreads int) *P_ + type Protein struct + EntryId string + Features map[string]string + Length int32 + Sequence string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Protein) Descriptor() ([]byte, []int) + func (*Protein) ProtoMessage() + func (m *Protein) GetEntryId() string + func (m *Protein) GetFeatures() map[string]string + func (m *Protein) GetLength() int32 + func (m *Protein) GetSequence() string + func (m *Protein) Reset() + func (m *Protein) String() string + func (m *Protein) XXX_DiscardUnknown() + func (m *Protein) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Protein) XXX_Merge(src proto.Message) + func (m *Protein) XXX_Size() int + func (m *Protein) XXX_Unmarshal(b []byte) error + type TxBatch struct + Entries map[string]KV + Mu sync.Mutex + NbOfTx int + TxBufferSize int
Go to main page