definitely rename Rewrite cleaner to operate on a leveldb directly if it is impossible to query on topic+timestamp(big endian) for purging store an additional key.

NewServer creates instance of the server.

NewStorage creates instance of the storage.

TopicPart looks for TopicBodyDelimiter and returns topic prefix from the same key.

Server provides rendezbous service over libp2p stream.

Storage manages records.

Decoder is a decoder!.