Versions in this module Expand all Collapse all v1 v1.999.0 Nov 17, 2022 Changes in this version + var ErrIntOverflowEpochByHash = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowMiniblockMetadata = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowResultsHashesByTxHash = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthEpochByHash = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthMiniblockMetadata = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthResultsHashesByTxHash = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrNotFoundInStorage = errors.New("not found in storage") + var ErrUnexpectedEndOfGroupEpochByHash = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupMiniblockMetadata = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupResultsHashesByTxHash = fmt.Errorf("proto: unexpected end of group") + func NewHistoryRepository(arguments HistoryRepositoryArguments) (*historyRepository, error) + type BlockTracker interface + IsInterfaceNil func() bool + RegisterCrossNotarizedHeadersHandler func(func(shardID uint32, headers []data.HeaderHandler, headersHashes [][]byte)) + RegisterFinalMetachainHeadersHandler func(func(shardID uint32, headers []data.HeaderHandler, headersHashes [][]byte)) + RegisterSelfNotarizedFromCrossHeadersHandler func(func(shardID uint32, headers []data.HeaderHandler, headersHashes [][]byte)) + RegisterSelfNotarizedHeadersHandler func(func(shardID uint32, headers []data.HeaderHandler, headersHashes [][]byte)) + type EpochByHash struct + Epoch uint32 + func (*EpochByHash) Descriptor() ([]byte, []int) + func (*EpochByHash) ProtoMessage() + func (m *EpochByHash) GetEpoch() uint32 + func (m *EpochByHash) Marshal() (dAtA []byte, err error) + func (m *EpochByHash) MarshalTo(dAtA []byte) (int, error) + func (m *EpochByHash) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EpochByHash) Reset() + func (m *EpochByHash) Size() (n int) + func (m *EpochByHash) Unmarshal(dAtA []byte) error + func (m *EpochByHash) XXX_DiscardUnknown() + func (m *EpochByHash) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EpochByHash) XXX_Merge(src proto.Message) + func (m *EpochByHash) XXX_Size() int + func (m *EpochByHash) XXX_Unmarshal(b []byte) error + func (this *EpochByHash) Equal(that interface{}) bool + func (this *EpochByHash) GoString() string + func (this *EpochByHash) String() string + type HistoryRepository interface + GetESDTSupply func(token string) (*esdtSupply.SupplyESDT, error) + GetEpochByHash func(hash []byte) (uint32, error) + GetMiniblockMetadataByTxHash func(hash []byte) (*MiniblockMetadata, error) + GetResultsHashesByTxHash func(txHash []byte, epoch uint32) (*ResultsHashesByTxHash, error) + IsEnabled func() bool + IsInterfaceNil func() bool + OnNotarizedBlocks func(shardID uint32, headers []data.HeaderHandler, headersHashes [][]byte) + RecordBlock func(blockHeaderHash []byte, blockHeader data.HeaderHandler, ...) error + RevertBlock func(blockHeader data.HeaderHandler, blockBody data.BodyHandler) error + type HistoryRepositoryArguments struct + BlockHashByRound storage.Storer + ESDTSuppliesHandler SuppliesHandler + EpochByHashStorer storage.Storer + EventsHashesByTxHashStorer storage.Storer + Hasher hashing.Hasher + Marshalizer marshal.Marshalizer + MiniblockHashByTxHashStorer storage.Storer + MiniblocksMetadataStorer storage.Storer + SelfShardID uint32 + Uint64ByteSliceConverter typeConverters.Uint64ByteSliceConverter + type HistoryRepositoryFactory interface + Create func() (HistoryRepository, error) + IsInterfaceNil func() bool + type MiniblockMetadata struct + DeprecatedStatus []byte + DestinationShardID uint32 + Epoch uint32 + HeaderHash []byte + HeaderNonce uint64 + MiniblockHash []byte + NotarizedAtDestinationInMetaHash []byte + NotarizedAtDestinationInMetaNonce uint64 + NotarizedAtSourceInMetaHash []byte + NotarizedAtSourceInMetaNonce uint64 + Round uint64 + SourceShardID uint32 + Type int32 + func (*MiniblockMetadata) Descriptor() ([]byte, []int) + func (*MiniblockMetadata) ProtoMessage() + func (m *MiniblockMetadata) GetDeprecatedStatus() []byte + func (m *MiniblockMetadata) GetDestinationShardID() uint32 + func (m *MiniblockMetadata) GetEpoch() uint32 + func (m *MiniblockMetadata) GetHeaderHash() []byte + func (m *MiniblockMetadata) GetHeaderNonce() uint64 + func (m *MiniblockMetadata) GetMiniblockHash() []byte + func (m *MiniblockMetadata) GetNotarizedAtDestinationInMetaHash() []byte + func (m *MiniblockMetadata) GetNotarizedAtDestinationInMetaNonce() uint64 + func (m *MiniblockMetadata) GetNotarizedAtSourceInMetaHash() []byte + func (m *MiniblockMetadata) GetNotarizedAtSourceInMetaNonce() uint64 + func (m *MiniblockMetadata) GetRound() uint64 + func (m *MiniblockMetadata) GetSourceShardID() uint32 + func (m *MiniblockMetadata) GetType() int32 + func (m *MiniblockMetadata) Marshal() (dAtA []byte, err error) + func (m *MiniblockMetadata) MarshalTo(dAtA []byte) (int, error) + func (m *MiniblockMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MiniblockMetadata) Reset() + func (m *MiniblockMetadata) Size() (n int) + func (m *MiniblockMetadata) Unmarshal(dAtA []byte) error + func (m *MiniblockMetadata) XXX_DiscardUnknown() + func (m *MiniblockMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MiniblockMetadata) XXX_Merge(src proto.Message) + func (m *MiniblockMetadata) XXX_Size() int + func (m *MiniblockMetadata) XXX_Unmarshal(b []byte) error + func (this *MiniblockMetadata) Equal(that interface{}) bool + func (this *MiniblockMetadata) GoString() string + func (this *MiniblockMetadata) String() string + type ResultsHashesByTxHash struct + ReceiptsHash []byte + ScResultsHashesAndEpoch []*ScResultsHashesAndEpoch + func (*ResultsHashesByTxHash) Descriptor() ([]byte, []int) + func (*ResultsHashesByTxHash) ProtoMessage() + func (m *ResultsHashesByTxHash) GetReceiptsHash() []byte + func (m *ResultsHashesByTxHash) GetScResultsHashesAndEpoch() []*ScResultsHashesAndEpoch + func (m *ResultsHashesByTxHash) Marshal() (dAtA []byte, err error) + func (m *ResultsHashesByTxHash) MarshalTo(dAtA []byte) (int, error) + func (m *ResultsHashesByTxHash) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResultsHashesByTxHash) Reset() + func (m *ResultsHashesByTxHash) Size() (n int) + func (m *ResultsHashesByTxHash) Unmarshal(dAtA []byte) error + func (m *ResultsHashesByTxHash) XXX_DiscardUnknown() + func (m *ResultsHashesByTxHash) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResultsHashesByTxHash) XXX_Merge(src proto.Message) + func (m *ResultsHashesByTxHash) XXX_Size() int + func (m *ResultsHashesByTxHash) XXX_Unmarshal(b []byte) error + func (this *ResultsHashesByTxHash) Equal(that interface{}) bool + func (this *ResultsHashesByTxHash) GoString() string + func (this *ResultsHashesByTxHash) String() string + type ScResultsHashesAndEpoch struct + Epoch uint32 + ScResultsHashes [][]byte + func (*ScResultsHashesAndEpoch) Descriptor() ([]byte, []int) + func (*ScResultsHashesAndEpoch) ProtoMessage() + func (m *ScResultsHashesAndEpoch) GetEpoch() uint32 + func (m *ScResultsHashesAndEpoch) GetScResultsHashes() [][]byte + func (m *ScResultsHashesAndEpoch) Marshal() (dAtA []byte, err error) + func (m *ScResultsHashesAndEpoch) MarshalTo(dAtA []byte) (int, error) + func (m *ScResultsHashesAndEpoch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ScResultsHashesAndEpoch) Reset() + func (m *ScResultsHashesAndEpoch) Size() (n int) + func (m *ScResultsHashesAndEpoch) Unmarshal(dAtA []byte) error + func (m *ScResultsHashesAndEpoch) XXX_DiscardUnknown() + func (m *ScResultsHashesAndEpoch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ScResultsHashesAndEpoch) XXX_Merge(src proto.Message) + func (m *ScResultsHashesAndEpoch) XXX_Size() int + func (m *ScResultsHashesAndEpoch) XXX_Unmarshal(b []byte) error + func (this *ScResultsHashesAndEpoch) Equal(that interface{}) bool + func (this *ScResultsHashesAndEpoch) GoString() string + func (this *ScResultsHashesAndEpoch) String() string + type SuppliesHandler interface + GetESDTSupply func(token string) (*esdtSupply.SupplyESDT, error) + IsInterfaceNil func() bool + ProcessLogs func(blockNonce uint64, logs []*data.LogData) error + RevertChanges func(header data.HeaderHandler, body data.BodyHandler) error