Packages

rocksdb

3.1.2
3.1.2 3.1.1 3.1.0 3.0.0 2.6.2 2.6.1 retired 2.6.0 retired 2.5.0 2.4.1 2.4.0 2.3.0 2.2.0 2.1.0 2.0.0 1.9.0 1.8.0 1.7.0 1.6.0 1.5.1 1.5.0 1.4.0 1.3.2 1.3.1 1.3.0 1.2.0 1.1.1 1.1.0 1.0.0 0.26.2 0.26.1 0.26.0 0.25.0 0.24.0 0.23.3 0.23.2 0.23.1 0.23.0 0.22.0 0.21.0 0.20.1 0.20.0 0.19.0 0.18.0 0.17.0 0.16.0 0.15.0 0.14.0 0.13.1 0.13.0 0.12.0 0.11.0 0.10.0 0.9.1 0.9.0 0.8.2 0.8.1 0.8.0 0.7.1 0.7.0 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0

RocksDB for Erlang

HexDocs

Current section

Files

Jump to
Readme
64 Versions
0 Dependencies
Dependants
Files
Activity
rocksdb deps rocksdb db blob blob_read_request.h
Raw

deps/rocksdb/db/blob/blob_read_request.h 

//  Copyright (c) Meta Platforms, Inc. and affiliates.

//  This source code is licensed under both the GPLv2 (found in the

//  COPYING file in the root directory) and Apache 2.0 License

//  (found in the LICENSE.Apache file in the root directory).



#pragma once



#include <cinttypes>



#include "rocksdb/compression_type.h"

#include "rocksdb/slice.h"

#include "rocksdb/status.h"

#include "util/autovector.h"



namespace ROCKSDB_NAMESPACE {



// A read Blob request structure for use in BlobSource::MultiGetBlob and

// BlobFileReader::MultiGetBlob.

struct BlobReadRequest {

  // User key to lookup the paired blob

  const Slice* user_key = nullptr;



  // File offset in bytes

  uint64_t offset = 0;



  // Length to read in bytes

  size_t len = 0;



  // Blob compression type

  CompressionType compression = kNoCompression;



  // Output parameter set by MultiGetBlob() to point to the data buffer, and

  // the number of valid bytes

  PinnableSlice* result = nullptr;



  // Status of read

  Status* status = nullptr;



  BlobReadRequest(const Slice& _user_key, uint64_t _offset, size_t _len,

                  CompressionType _compression, PinnableSlice* _result,

                  Status* _status)

      : user_key(&_user_key),

        offset(_offset),

        len(_len),

        compression(_compression),

        result(_result),

        status(_status) {}



  BlobReadRequest() = default;

  BlobReadRequest(const BlobReadRequest& other) = default;

  BlobReadRequest& operator=(const BlobReadRequest& other) = default;

};



using BlobFileReadRequests =

    std::tuple<uint64_t /* file_number */, uint64_t /* file_size */,

               autovector<BlobReadRequest>>;



}  // namespace ROCKSDB_NAMESPACE