28a299efa8
* Initial rocksdb commit Basic reading from rocksdb works * Try github action thing * try local dockerfile * asdf * qwer * asdf * Try adding test db with git-lfs * update action * cleanup * Don't hardcode stop on read * Progress of reading rocksdb * fixes and arg test * asdf * Fix rocksdb iterator and tests * update script * asdf * Better iterator. Need to implement a lot of keys next, and tests, maybe tests needed. * asdf * asdf * asdf * Implementation, testing, and cleanup. Implemented more prefixes. Figured out a good test that should work for all prefixes. Removed binary databases so we can just store human readable csv files. * more tests, prefixes and small refactor * Another prefix * EffectiveAmount * ActiveAmount * ActivatedClaimAndSupport * PendingActivation * ClaimTakeover * ClaimExpiration * SupportToClaim * ClaimToSupport * Fix bug with variable length keys * ChannelToClaim * ClaimToChannel * ClaimShortID * TXOToClaim * ClaimToTXO * BlockHeader * BlockHash * Undo * HashXHistory * Tx and big refactor * rest the the keys * Refactor and starting to add resolve * asdf * Refactor tests and add column families * changes * more work on implementing resolve * code cleanup, function tests * small code refactoring * start building pieces of the test data set for full resolve. * Export constant, add test * another test * TestGetTxHash * more tests * more tests * More tests * Refactor db functions into three files * added slice backed stack, need to fix tests * fix some issues with test suite * some cleanup and adding arguments and db load / refresh to server command * fix some bugs, start using logrus for leveled logging, upgrade to go 1.17, run go mod tidy * logrus, protobuf updates, resolve grpc endpoint * don't run integration test with unit tests * signal handling and cleanup functions * signal handling code files * Unit tests for db stack * reorganize bisect function so we lock it properly * fix txcounts loading * cleanup some logic around iterators and fix a bug where I was running two detect changes threads * add some metrics * cleanup * blocking and filtering implemented * add params for blocking and filtering channels and streams * updates and fixes for integration tests * use newer version of lbry.go when possible * Add height endpoint and move string functions internal * remove gitattributes, unused * some cleanup * more cleanup / refactor. almost ready for another review * More cleanup * use chainhash.Hash types from lbcd where appropriate * update github action to go-1.17.8 * update go version needed * trying to fix these builds * cleanup * trying to fix memory leak * fix memory leak (iterator never finished so cleanup didn't run) * changes per code review * remove lbry.go v2 * rename sort.go search.go * fix test
78 lines
4.3 KiB
Python
78 lines
4.3 KiB
Python
# -*- coding: utf-8 -*-
|
|
# Generated by the protocol buffer compiler. DO NOT EDIT!
|
|
# source: result.proto
|
|
"""Generated protocol buffer code."""
|
|
from google.protobuf import descriptor as _descriptor
|
|
from google.protobuf import descriptor_pool as _descriptor_pool
|
|
from google.protobuf import message as _message
|
|
from google.protobuf import reflection as _reflection
|
|
from google.protobuf import symbol_database as _symbol_database
|
|
# @@protoc_insertion_point(imports)
|
|
|
|
_sym_db = _symbol_database.Default()
|
|
|
|
|
|
|
|
|
|
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0cresult.proto\x12\x02pb\"\x97\x01\n\x07Outputs\x12\x18\n\x04txos\x18\x01 \x03(\x0b\x32\n.pb.Output\x12\x1e\n\nextra_txos\x18\x02 \x03(\x0b\x32\n.pb.Output\x12\r\n\x05total\x18\x03 \x01(\r\x12\x0e\n\x06offset\x18\x04 \x01(\r\x12\x1c\n\x07\x62locked\x18\x05 \x03(\x0b\x32\x0b.pb.Blocked\x12\x15\n\rblocked_total\x18\x06 \x01(\r\"{\n\x06Output\x12\x0f\n\x07tx_hash\x18\x01 \x01(\x0c\x12\x0c\n\x04nout\x18\x02 \x01(\r\x12\x0e\n\x06height\x18\x03 \x01(\r\x12\x1e\n\x05\x63laim\x18\x07 \x01(\x0b\x32\r.pb.ClaimMetaH\x00\x12\x1a\n\x05\x65rror\x18\x0f \x01(\x0b\x32\t.pb.ErrorH\x00\x42\x06\n\x04meta\"\xe6\x02\n\tClaimMeta\x12\x1b\n\x07\x63hannel\x18\x01 \x01(\x0b\x32\n.pb.Output\x12\x1a\n\x06repost\x18\x02 \x01(\x0b\x32\n.pb.Output\x12\x11\n\tshort_url\x18\x03 \x01(\t\x12\x15\n\rcanonical_url\x18\x04 \x01(\t\x12\x16\n\x0eis_controlling\x18\x05 \x01(\x08\x12\x18\n\x10take_over_height\x18\x06 \x01(\r\x12\x17\n\x0f\x63reation_height\x18\x07 \x01(\r\x12\x19\n\x11\x61\x63tivation_height\x18\x08 \x01(\r\x12\x19\n\x11\x65xpiration_height\x18\t \x01(\r\x12\x19\n\x11\x63laims_in_channel\x18\n \x01(\r\x12\x10\n\x08reposted\x18\x0b \x01(\r\x12\x18\n\x10\x65\x66\x66\x65\x63tive_amount\x18\x14 \x01(\x04\x12\x16\n\x0esupport_amount\x18\x15 \x01(\x04\x12\x16\n\x0etrending_score\x18\x16 \x01(\x01\"\x94\x01\n\x05\x45rror\x12\x1c\n\x04\x63ode\x18\x01 \x01(\x0e\x32\x0e.pb.Error.Code\x12\x0c\n\x04text\x18\x02 \x01(\t\x12\x1c\n\x07\x62locked\x18\x03 \x01(\x0b\x32\x0b.pb.Blocked\"A\n\x04\x43ode\x12\x10\n\x0cUNKNOWN_CODE\x10\x00\x12\r\n\tNOT_FOUND\x10\x01\x12\x0b\n\x07INVALID\x10\x02\x12\x0b\n\x07\x42LOCKED\x10\x03\"5\n\x07\x42locked\x12\r\n\x05\x63ount\x18\x01 \x01(\r\x12\x1b\n\x07\x63hannel\x18\x02 \x01(\x0b\x32\n.pb.OutputB&Z$github.com/lbryio/hub/protobuf/go/pbb\x06proto3')
|
|
|
|
|
|
|
|
_OUTPUTS = DESCRIPTOR.message_types_by_name['Outputs']
|
|
_OUTPUT = DESCRIPTOR.message_types_by_name['Output']
|
|
_CLAIMMETA = DESCRIPTOR.message_types_by_name['ClaimMeta']
|
|
_ERROR = DESCRIPTOR.message_types_by_name['Error']
|
|
_BLOCKED = DESCRIPTOR.message_types_by_name['Blocked']
|
|
_ERROR_CODE = _ERROR.enum_types_by_name['Code']
|
|
Outputs = _reflection.GeneratedProtocolMessageType('Outputs', (_message.Message,), {
|
|
'DESCRIPTOR' : _OUTPUTS,
|
|
'__module__' : 'result_pb2'
|
|
# @@protoc_insertion_point(class_scope:pb.Outputs)
|
|
})
|
|
_sym_db.RegisterMessage(Outputs)
|
|
|
|
Output = _reflection.GeneratedProtocolMessageType('Output', (_message.Message,), {
|
|
'DESCRIPTOR' : _OUTPUT,
|
|
'__module__' : 'result_pb2'
|
|
# @@protoc_insertion_point(class_scope:pb.Output)
|
|
})
|
|
_sym_db.RegisterMessage(Output)
|
|
|
|
ClaimMeta = _reflection.GeneratedProtocolMessageType('ClaimMeta', (_message.Message,), {
|
|
'DESCRIPTOR' : _CLAIMMETA,
|
|
'__module__' : 'result_pb2'
|
|
# @@protoc_insertion_point(class_scope:pb.ClaimMeta)
|
|
})
|
|
_sym_db.RegisterMessage(ClaimMeta)
|
|
|
|
Error = _reflection.GeneratedProtocolMessageType('Error', (_message.Message,), {
|
|
'DESCRIPTOR' : _ERROR,
|
|
'__module__' : 'result_pb2'
|
|
# @@protoc_insertion_point(class_scope:pb.Error)
|
|
})
|
|
_sym_db.RegisterMessage(Error)
|
|
|
|
Blocked = _reflection.GeneratedProtocolMessageType('Blocked', (_message.Message,), {
|
|
'DESCRIPTOR' : _BLOCKED,
|
|
'__module__' : 'result_pb2'
|
|
# @@protoc_insertion_point(class_scope:pb.Blocked)
|
|
})
|
|
_sym_db.RegisterMessage(Blocked)
|
|
|
|
if _descriptor._USE_C_DESCRIPTORS == False:
|
|
|
|
DESCRIPTOR._options = None
|
|
DESCRIPTOR._serialized_options = b'Z$github.com/lbryio/hub/protobuf/go/pb'
|
|
_OUTPUTS._serialized_start=21
|
|
_OUTPUTS._serialized_end=172
|
|
_OUTPUT._serialized_start=174
|
|
_OUTPUT._serialized_end=297
|
|
_CLAIMMETA._serialized_start=300
|
|
_CLAIMMETA._serialized_end=658
|
|
_ERROR._serialized_start=661
|
|
_ERROR._serialized_end=809
|
|
_ERROR_CODE._serialized_start=744
|
|
_ERROR_CODE._serialized_end=809
|
|
_BLOCKED._serialized_start=811
|
|
_BLOCKED._serialized_end=864
|
|
# @@protoc_insertion_point(module_scope)
|