PixelWorldStreaming.h

浏览该文件的文档.

#pragma once
#include "common/Export.h"
 
 
#include "common/Result.h"
#include "common/Snapshot.h"
#include "pixelworld/PixelWorld.h"
 
#include <cstdint>
#include <set>
#include <utility>
 
namespace eve::pixelworld_streaming {
 
enum class PixelChunkArchiveCodec : std::uint8_t { None = 0, Zstd = 1 };
 
[[nodiscard]] EVENGINE_API_PLATFORM eve::Result<eve::SnapshotEnvelope> archiveChunkBatch(
    const eve::pixelworld::PixelChunkBatch& batch, eve::PersistentId instanceId, PixelChunkArchiveCodec codec,
    const eve::SnapshotHashProvider& hashProvider);
 
[[nodiscard]] EVENGINE_API_PLATFORM eve::Result<eve::pixelworld::PixelChunkBatch> decodeChunkBatchArchive(
    const eve::SnapshotEnvelope& snapshot, const eve::SnapshotHashProvider& hashProvider);
 
struct PixelChunkStreamUpdate {
    eve::pixelworld::PixelChunkBatch batch;
    bool fullResync = false;
    std::uint32_t chunksEntered = 0;
    std::uint32_t chunksEvicted = 0;
};
 
class EVENGINE_API_PLATFORM PixelChunkStreamCursor {
public:
    [[nodiscard]] eve::Result<PixelChunkStreamUpdate> capture(
        const eve::pixelworld::PixelWorld& source, eve::pixelworld::PixelChunkRegion interest);
 
    void reset() noexcept;
 
    [[nodiscard]] std::uint64_t revision() const noexcept { return revision_; }
    [[nodiscard]] std::size_t knownChunkCount() const noexcept { return known_.size(); }
 
private:
    eve::pixelworld::PixelWorldLink source_{};
    std::uint64_t revision_ = 0;
    std::set<std::pair<int, int>> known_;
};
 
}  // namespace eve::pixelworld_streaming