Versions in this module Expand all Collapse all v0 v0.0.2 Oct 31, 2023 v0.0.1 Oct 30, 2023 Changes in this version + var ErrBodyTypeAssertion = errors.New("elasticsearch - body type assertion failed") + var ErrCannotCreateIndex = errors.New("cannot create elasitc index") + var ErrEmptyPassword = errors.New("password is empty") + var ErrEmptyUserName = errors.New("user name is empty") + var ErrNilPubkeyConverter = errors.New("nil pubkey converter") + var ErrNoHeader = errors.New("elasticsearch - no header") + var ErrNoMiniblocks = errors.New("elasticsearch - no miniblocks") + type Block struct + Epoch uint32 + Hash string + MiniBlocksHashes []string + Nonce uint64 + NotarizedBlocksHashes []string + PrevHash string + Proposer uint64 + PubKeyBitmap string + Round uint64 + ShardID uint32 + Size int64 + SizeTxs int64 + StateRootHash string + Timestamp time.Duration + TxCount uint32 + Validators []uint64 + type ElasticIndexerArgs struct + AddressPubkeyConverter core.PubkeyConverter + EpochStartNotifier sharding.EpochStartEventNotifier + Hasher hashing.Hasher + Marshalizer marshal.Marshalizer + NodesCoordinator sharding.NodesCoordinator + Options *Options + Password string + ShardId uint32 + Url string + UserName string + ValidatorPubkeyConverter core.PubkeyConverter + type Event struct + Address string + Data string + Identifier string + Topics []string + type Indexer interface + IsInterfaceNil func() bool + IsNilIndexer func() bool + SaveBlock func(body data.BodyHandler, header data.HeaderHandler, ...) + SaveRoundsInfos func(roundsInfos []RoundInfo) + SaveValidatorsPubKeys func(validatorsPubKeys map[uint32][][]byte, epoch uint32) + SaveValidatorsRating func(indexID string, infoRating []ValidatorRatingInfo) + SetTxLogsProcessor func(txLogsProc process.TransactionLogProcessorDatabase) + UpdateTPS func(tpsBenchmark statistics.TPSBenchmark) + func NewElasticIndexer(arguments ElasticIndexerArgs) (Indexer, error) + type Miniblock struct + Hash string + ReceiverBlockHash string + ReceiverShardID uint32 + SenderBlockHash string + SenderShardID uint32 + Type string + type NilIndexer struct + func NewNilIndexer() *NilIndexer + func (ni *NilIndexer) IsInterfaceNil() bool + func (ni *NilIndexer) IsNilIndexer() bool + func (ni *NilIndexer) SaveBlock(_ data.BodyHandler, _ data.HeaderHandler, _ map[string]data.TransactionHandler, ...) + func (ni *NilIndexer) SaveRoundsInfos(_ []RoundInfo) + func (ni *NilIndexer) SaveValidatorsPubKeys(_ map[uint32][][]byte, _ uint32) + func (ni *NilIndexer) SaveValidatorsRating(_ string, _ []ValidatorRatingInfo) + func (ni *NilIndexer) SetTxLogsProcessor(_ process.TransactionLogProcessorDatabase) + func (ni *NilIndexer) UpdateTPS(_ statistics.TPSBenchmark) + type Options struct + TxIndexingEnabled bool + type RoundInfo struct + BlockWasProposed bool + Index uint64 + ShardId uint32 + SignersIndexes []uint64 + Timestamp time.Duration + type ScResult struct + CallType string + Code string + CodeMetadata string + Data string + GasLimit uint64 + GasPrice uint64 + Nonce uint64 + PreTxHash string + Receiver string + ReturnMessage string + Sender string + Value string + type TPS struct + AverageBlockTxCount *big.Int + AverageTPS *big.Int + BlockNumber uint64 + CurrentBlockNonce uint64 + LastBlockTxCount uint32 + LiveTPS float64 + NrOfNodes uint32 + NrOfShards uint32 + PeakTPS float64 + RoundNumber uint64 + RoundTime uint64 + ShardID uint32 + TotalProcessedTxCount *big.Int + type Transaction struct + BlockHash string + Data string + GasLimit uint64 + GasPrice uint64 + GasUsed uint64 + Hash string + Log TxLog + MBHash string + Nonce uint64 + Receiver string + ReceiverShard uint32 + Round uint64 + Sender string + SenderShard uint32 + Signature string + SmartContractResults []ScResult + Status string + Timestamp time.Duration + Value string + type TxLog struct + Address string + Events []Event + type ValidatorRatingInfo struct + PublicKey string + Rating float32 + type ValidatorsPublicKeys struct + PublicKeys []string + type ValidatorsRatingInfo struct + ValidatorsInfos []ValidatorRatingInfo