Method StoreLogs

lib/datastore/flydb.go:69–93

StoreLogs is a method on FlyDbStore that stores multiple log entries since FlyDB currently does not support transactions, please be aware that in case of errors, already written data will persist.

(logs []*raft.Log)

// since FlyDB currently does not support transactions,
// please be aware that in case of errors, already written data will persist.
func (fds *FlyDbStore) StoreLogs(logs []*raft.Log) error {

	for _, log := range logs {
		var (
			key []byte
			val []byte
		)

		key = uint64ToBytes(log.Index)              // Convert the index to bytes
		val, err := encoding.EncodeMessagePack(log) // Encode the log entry
		if err != nil {
			break
		}
		err = fds.conn.Put(key[:], val)
		if err != nil {
			return err
		}
		if log.Index > fds.lastIndex {
			fds.lastIndex = log.Index
		} else if log.Index < fds.firstIndex || fds.firstIndex == 0 {
			fds.firstIndex = log.Index
		}
	}
	return nil
}

// DeleteRange is a method on FlyDbStore that deletes a range of log entries
func (fds *FlyDbStore) DeleteRange(min, max uint64) error {