FasterLog v2pre sandbox

FasterLogV2PreTest.cs

using FASTER.core;

using var x = Devices.CreateLogDevice("xlog");
var flsetting = new FasterLogSettings("hoge");
using var fl = new FasterLog(new FasterLogSettings("hoge")
// {
//     FastCommitMode = true,
//     LogCommitDir = "xlog-commits"
// }
);

var data = new byte[256];
for (int i = 0; i < 100; i++)
{
    fl.Enqueue(data);
}

fl.CommitStrongly(out var tail, out var commitNum);
Console.WriteLine($"{tail},{commitNum}");
fl.CommitStrongly(out tail, out commitNum);
fl.Commit(true);
fl.Commit(true);

using var iter = fl.Scan(fl.BeginAddress, fl.TailAddress);
long totalNum = 0;
long totalBytes = 0;
await foreach(var item in iter.GetAsyncEnumerable())
{
    totalNum++;
    totalBytes += item.entryLength;
}
Console.WriteLine($"{totalNum}, {totalBytes}");

class Hoge : ILogEnqueueEntry
{
    public int SerializedLength => throw new NotImplementedException();

    public void SerializeTo(Span<byte> dest)
    {
    }
}