Fantom-foundation/go-lachesis

package gossip

import (
    "github.com/Fantom-foundation/go-lachesis/kvdb"
    "github.com/Fantom-foundation/go-lachesis/kvdb/flushable"
    "github.com/Fantom-foundation/go-lachesis/kvdb/table"
)

type asyncStore struct {
    dbs    *flushable.SyncedPool
    mainDb kvdb.KeyValueStore
    table  struct {
        // Network tables
        Peers kvdb.KeyValueStore `table:"Z"`
    }
}

func newAsyncStore(dbs *flushable.SyncedPool) *asyncStore {
    s := &asyncStore{
        dbs:    dbs,
        mainDb: dbs.GetDb("gossip-async"),
    }

    table.MigrateTables(&s.table, s.mainDb)

    return s
}

// Close leaves underlying database.
func (s *asyncStore) Close() {
    table.MigrateTables(&s.table, nil)

    s.mainDb.Close()
}