Method: Rubcask::DataFile#append

Defined in:
lib/rubcask/data_file.rb

#append(entry) ⇒ AppendResult

Note:

Calling this method will not change pos of the file

Append an entry at the end of the file

Parameters:

  • entry (DataEntry) —

    Entry to write to the file

Returns:

  • (AppendResult) —

    struct containing position and size of the entry



96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
 
# File 'lib/rubcask/data_file.rb', line 96

def append(entry)
  current_pos = @write_pos

  key_size = entry.key.bytesize
  value_size = entry.value.bytesize
  timestamp_with_deleted = entry.expire_timestamp
  timestamp_with_deleted |= DELETED_MASK if entry.deleted?
  crc = Zlib.crc32([
    timestamp_with_deleted,
    key_size,
    value_size
  ].pack(HEADER_WITHOUT_CRC_FORMAT) + entry.key + entry.value)
  @write_pos += @file.write(
    [crc, timestamp_with_deleted, key_size, value_size].pack(HEADER_FORMAT),
    entry.key,
    entry.value
  )
  @file.flush
  AppendResult.new(current_pos, @write_pos - current_pos)
end