Functions — github.com/eosrio/hyperion-history-api

hub / github.com/eosrio/hyperion-history-api / functions

Functions838 in github.com/eosrio/hyperion-history-api

⨍ Functions 838◇ Types & classes 195

↓ 2 callersMethodprocessStreamRequest

( type: K, socket: Socket, data: StreamTypeMap[K]['request'], callback: (resp:

src/api/socketManager.ts:530

↓ 2 callersFunctionprocessTableRequests

( tableClientMap: Map<string, Map<string, Map<string, StreamDeltasRequest>>>, tableId: string, pay

src/api/helpers/streamFunctions.ts:27

↓ 2 callersMethodpublishApiUsage

()

src/api/server.ts:681

↓ 2 callersMethodpushToStateIndexQueue

(data: any, type: string)

src/indexer/workers/deserializer.ts:1272

↓ 2 callersFunctionreadJsonConfig

* Read and parse a JSON config file, turning fs/JSON failures into a * ConfigLoadError that names the file and the underlying problem.

src/cli/sync-modules/sync-contract-state.ts:24

↓ 2 callersMethodregisterAutoBlacklist

( contract: string, field: string, type: string, block: number, valid_

src/indexer/workers/deserializer.ts:767

↓ 2 callersMethodremoveRequestByID

(value: TrackedRequest, requestUUID: string)

src/indexer/workers/ws-router.ts:520

↓ 2 callersMethodreportMaxBlock

(maxBlockNum: number, index_name: string)

src/indexer/helpers/elastic-routes.ts:568

↓ 2 callersMethodreportMissedBlocks

(missingProd: any, lastProducedBlockNum: number, size: number)

src/indexer/modules/master.ts:1330

↓ 2 callersMethodrequestDataFromWorkers

(requestEvent: { event: string; data?: any }, responseEventType: string, timeoutSec: number = 1000)

src/indexer/modules/master.ts:1867

↓ 2 callersMethodresetCounters

()

src/indexer/helpers/elastic-routes.ts:371

↓ 2 callersMethodsaveManifest

* Save the manifest to disk.

tests/e2e/lib/load-generator.ts:319

↓ 2 callersMethodscan

()

src/cli/sync-modules/sync-proposals.ts:87

↓ 2 callersMethodscan

()

src/cli/sync-modules/sync-voters.ts:12

↓ 2 callersMethodsendToRole

(role: string, payload: any)

src/indexer/modules/master.ts:1191

↓ 2 callersFunctionsetNestedValue

(obj: any, path: string, value: any)

src/cli/hyp-config.ts:1380

↓ 2 callersFunctionsetPluginState

(pluginName: string, newState: boolean)

src/cli/hpm.ts:360

↓ 2 callersMethodsetupMongo

()

src/cli/sync-modules/sync-accounts.ts:25

↓ 2 callersMethodsetupWorkers

()

src/indexer/modules/master.ts:1054

↓ 2 callersFunctionshutdown

(signal: string)

tests/e2e/hyp-test.ts:53

↓ 2 callersMethodstart

()

src/indexer/modules/master.ts:1199

↓ 2 callersMethodstart

()

src/cli/controller-client/controller.client.ts:230

↓ 2 callersMethodstartApi

* Start the API container.

tests/e2e/lib/indexer-runner.ts:365

↓ 2 callersMethodstartIndexer

* Start the indexer container.

tests/e2e/lib/indexer-runner.ts:342

↓ 2 callersMethodstartWS

()

src/indexer/workers/state-reader.ts:1020

↓ 2 callersMethodstopApi

* Stop and remove the API container.

tests/e2e/lib/indexer-runner.ts:376

↓ 2 callersMethodstoreProposal

(data)

src/indexer/workers/deserializer.ts:1745

↓ 2 callersFunctionstreamPastCommon

( fastify: FastifyInstance, socket: Socket, requestUUID: string, data: StreamTypeMap[T]["reque

src/api/helpers/functions.ts:79

↓ 2 callersFunctionsyncAccounts

(chain: string, host?: string, contract?: string)

src/cli/hyp-control.ts:54

↓ 2 callersFunctionsyncContractState

(chain: string, host?: string, contract?: string, table?: string)

src/cli/hyp-control.ts:71

↓ 2 callersFunctionsyncPermissions

(chain: string, host?: string)

src/cli/hyp-control.ts:62

↓ 2 callersFunctionsyncProposals

(chain: string, host?: string)

src/cli/hyp-control.ts:58

↓ 2 callersFunctionsyncVoters

(chain: string, host?: string)

src/cli/hyp-control.ts:50

↓ 2 callersMethodverifyLocalType

( contract: string, type: string, block_num: number, field: string )

src/indexer/workers/deserializer.ts:786

↓ 1 callersFunctionCreateGtLT

(missing)

scripts/fix_missing_blocks/fix-missing-blocks.py:291

↓ 1 callersFunctionMagicFuzz

(missing)

scripts/fix_missing_blocks/fix-missing-blocks.py:222

↓ 1 callersMethodactivateStreaming

()

src/api/server.ts:255

↓ 1 callersMethodaddActionRequest

* Add an action request to the router * @param data * @param relay_id * @returns

src/indexer/workers/ws-router.ts:277

↓ 1 callersFunctionaddApiServer

(chainName, threads, heap, traceDeprecation, traceWarnings)

pm2/ecosystem_settings.cjs:38

↓ 1 callersFunctionaddBlockRangeOpts

( data: StreamActionsRequest | StreamDeltasRequest, search_body: BoolQuerySearchBody, fastify: Fas

src/api/helpers/functions.ts:725

↓ 1 callersFunctionaddChain

()

scripts/bootstrap.js:64

↓ 1 callersMethodaddDeltaRequest

* Add a delta request to the router * @param data * @param relay_id * @returns

src/indexer/workers/ws-router.ts:340

↓ 1 callersMethodaddDynamicRoutes

()

src/indexer/helpers/mongo-routes.ts:263

↓ 1 callersMethodaddGenericTypeParsing

()

src/api/server.ts:279

↓ 1 callersFunctionaddIndexer

(chainName, heap, traceDeprecation, traceWarnings)

pm2/ecosystem_settings.cjs:20

↓ 1 callersFunctionaddRangeQuery

(queryStruct, prop, pkey, query)

src/api/routes/v2-history/get_actions/functions.ts:61

↓ 1 callersFunctionaddSharedSchemas

(fastify: FastifyInstance)

src/api/helpers/functions.ts:1197

↓ 1 callersFunctionaddSortedBy

(query, queryBody, sort_direction)

src/api/routes/v2-history/get_actions/functions.ts:3

↓ 1 callersMethodaddStateTables

(indicesList, index_queues)

src/indexer/modules/master.ts:648

↓ 1 callersFunctionamqpConnect

( onReconnect: ([Channel, ConfirmChannel]) => void, config: AmqpConfig, onClose: () => void )

src/indexer/connections/amqp.ts:42

↓ 1 callersMethodappendDynamicContracts

(allowedDynamicContracts: Set<string>)

src/indexer/modules/loader.ts:183

↓ 1 callersMethodappendExtraMappings

(indexConfig)

src/indexer/modules/master.ts:728

↓ 1 callersFunctionapplyAccountFilters

(query, queryStruct)

src/api/routes/v2-history/get_actions/functions.ts:307

↓ 1 callersFunctionapplyCodeActionFilters

(query, queryStruct)

src/api/routes/v2-history/get_actions/functions.ts:209

↓ 1 callersFunctionapplyGenericFilters

(query, queryStruct, allowedExtraParams: Set<string>)

src/api/routes/v2-history/get_actions/functions.ts:137

↓ 1 callersMethodapplyUpdateScript

()

src/indexer/modules/master.ts:718

↓ 1 callersFunctionaskQuestion

(query: string)

src/cli/repair-cli/utils.ts:5

↓ 1 callersMethodassertQueues

()

src/indexer/workers/ws-router.ts:58

↓ 1 callersMethodattachActionExtras

(self: DSPoolWorker, action: ActionTrace)

src/indexer/workers/ds-pool.ts:183

↓ 1 callersFunctionbytesToString

(bytes: number)

src/indexer/workers/hyperionWorker.ts:68

↓ 1 callersMethodcalculateServerHash

()

src/indexer/connections/manager.class.ts:177

↓ 1 callersMethodcategorizeQueues

(queues: QueueInfo[])

src/cli/queue-manager/queue.manager.ts:218

↓ 1 callersMethodcheckAbiTracking

* 6. ABI tracking — verify ABIs were indexed for key contracts.

tests/e2e/lib/integrity-checker.ts:383

↓ 1 callersMethodcheckBigPayload

* 9. Big payload — verify bigpayload action was deserialized with correct content.

tests/e2e/lib/integrity-checker.ts:448

↓ 1 callersMethodcheckBlockContinuity

* 1. Block continuity — no gaps AND no duplicates. * Uses _count for exact total + cardinality agg for uniqueness check.

tests/e2e/lib/integrity-checker.ts:151

↓ 1 callersMethodcheckCustomActionCompleteness

* 4. Custom action completeness — all storedata, increment, nestaction, bigpayload indexed.

tests/e2e/lib/integrity-checker.ts:286

↓ 1 callersMethodcheckDeltaBlacklistForGenTrx

(gen_trx)

src/indexer/workers/deserializer.ts:1289

↓ 1 callersMethodcheckDeltaIndexing

* 5. Delta indexing — verify specific hyp.test table rows have correct field values.

tests/e2e/lib/integrity-checker.ts:333

↓ 1 callersMethodcheckDeltaWhitelistForGenTrx

(gen_trx)

src/indexer/workers/deserializer.ts:1295

↓ 1 callersFunctioncheckElastic

(fastify: FastifyInstance)

src/api/routes/v2/health/health.ts:148

↓ 1 callersMethodcheckElasticsearch

()

tests/e2e/lib/chain-manager.ts:168

↓ 1 callersFunctioncheckIndexerStatus

(chain: string)

src/cli/hyp-es-config.ts:537

↓ 1 callersMethodcheckInlineActions

* 8. Inline actions — verify nestaction produced inline action chain.

tests/e2e/lib/integrity-checker.ts:424

↓ 1 callersMethodcheckMemoSearch

* 7. Memo indexing — verify transfer memos are searchable.

tests/e2e/lib/integrity-checker.ts:399

↓ 1 callersMethodcheckMongoDbTools

()

src/cli/snapshot/snapshot.manager.ts:358

↓ 1 callersFunctioncheckNodeos

(fastify: FastifyInstance)

src/api/routes/v2/health/health.ts:126

↓ 1 callersMethodcheckNodeos

()

tests/e2e/lib/chain-manager.ts:159

↓ 1 callersMethodcheckPrivateKey

()

src/api/qry-hub/base-publisher.ts:38

↓ 1 callersFunctioncheckQueueSize

(q_name: string, config: AmqpConfig)

src/indexer/connections/amqp.ts:77

↓ 1 callersMethodcheckQueueSize

(queue: string)

src/indexer/connections/manager.class.ts:162

↓ 1 callersFunctioncheckRabbit

(fastify: FastifyInstance)

src/api/routes/v2/health/health.ts:103

↓ 1 callersMethodcheckRabbitMQ

()

tests/e2e/lib/chain-manager.ts:178

↓ 1 callersMethodcheckRedis

()

tests/e2e/lib/chain-manager.ts:193

↓ 1 callersFunctioncheckStateHistory

(fastify: FastifyInstance)

src/api/routes/v2/health/health.ts:60

↓ 1 callersMethodcheckTieredAllocation

()

src/indexer/modules/lifecycleManager.ts:173

↓ 1 callersMethodcheckTransactionIdIntegrity

* 10. Transaction ID integrity — verify exact trx_id matches for manifest entries. * Only runs when the manifest has real transaction IDs (not 'u

tests/e2e/lib/integrity-checker.ts:490

↓ 1 callersMethodcheckTransferCompleteness

* 2. Transfer completeness — all manifest transfers are indexed.

tests/e2e/lib/integrity-checker.ts:200

↓ 1 callersMethodcheckTransferDataIntegrity

* 3. Transfer data integrity — verify memo content matches expected values.

tests/e2e/lib/integrity-checker.ts:233

↓ 1 callersFunctioncleanActionTrace

(t: any)

src/indexer/workers/ds-pool.ts:23

↓ 1 callersMethodcleanReversibleBlocks

(lib: BlockInfo)

src/indexer/workers/state-reader.ts:601

↓ 1 callersFunctioncleanupIndices

(chain: string, partitionSizes: Record<string, number>, options: any)

src/cli/hyp-es-config.ts:784

↓ 1 callersFunctionclonePluginRepo

(pluginName: string, options: any)

src/cli/hpm.ts:203

↓ 1 callersMethodconfigureExplorer

()

src/api/server.ts:787

↓ 1 callersFunctioncountSpecs

(suites: any[])

tests/e2e/hyp-test.ts:157

↓ 1 callersMethodcreateAMQPChannels

(onReconnect: ([Channel, ConfirmChannel]) => void, onClose: () => void)

src/indexer/connections/manager.class.ts:158

↓ 1 callersFunctioncreateChannels

(connection: ChannelModel)

src/indexer/connections/amqp.ts:30

↓ 1 callersFunctioncreateConnection

(config: AmqpConfig)

src/indexer/connections/amqp.ts:5

↓ 1 callersMethodcreateLocalController

* Creates the local controller for managing Hyperion workers and handling requests. * @param controlPort The port on which the local controller w

src/indexer/modules/controller.ts:391

↓ 1 callersMethodcreateMongoClient

()

src/cli/sync-modules/sync-contract-state.ts:101

↓ 1 callersMethodcreateMongoSnapshot

(chain: string, lastBlock: number, options: SnapshotOptions)

src/cli/snapshot/snapshot.manager.ts:194

← previous next →201–300 of 838, ranked by callers