MCPcopy Create free account

hub / github.com/subquery/subql / functions

Functions2,116 in github.com/subquery/subql

↓ 2 callersMethodrewind
(targetBlockHeight: number, transaction: Transaction)
packages/node-core/src/indexer/poi/poi.service.ts:167
↓ 2 callersMethodrewindableCheck
(projects: Map<number, P>)
packages/node-core/src/configure/ProjectUpgrade.service.ts:379
↓ 2 callersMethodrunFlush
(tx: Transaction, blockHeight?: number)
packages/node-core/src/indexer/storeModelProvider/poi/cachePoi.ts:44
↓ 2 callersFunctionsafeClamp
(x: number)
packages/query/src/graphql/plugins/PgConnectionArgFirstLastBeforeAfter.ts:27
↓ 2 callersFunctionsanitizeArgField
(input: string)
packages/node-core/src/indexer/dictionary/v1/utils.ts:61
↓ 2 callersFunctionsanitizeDbName
(dbName: string)
packages/node-core/src/indexer/monitor.service.ts:43
↓ 2 callersMethodsearchWaitRewindHeader
(rewindTimestamp: Date)
packages/node-core/src/indexer/multiChainRewind.service.ts:181
↓ 2 callersFunctionset
()
packages/node-core/src/configure/ProjectUpgrade.service.ts:74
↓ 2 callersMethodset
(id: string, data: T, blockHeight: number)
packages/node-core/src/indexer/storeModelProvider/model/cacheModel.ts:174
↓ 2 callersMethodsetBypassBlocks
(blocks: BypassBlocks)
packages/node-core/src/indexer/fetch.service.spec.ts:33
↓ 2 callersMethodsetConcurrency
(newConcurrency: number)
packages/node-core/src/utils/queues/rampQueue.ts:52
↓ 2 callersMethodsetFieldValue
( endpoint: string, field: K, value: ConnectionPoolItem<T>[K] )
packages/node-core/src/indexer/connectionPoolState.manager.ts:41
↓ 2 callersFunctionsetJsonObjectType
( jsonObject: GraphQLObjectType<unknown, unknown>, jsonObjects: GraphQLObjectType<unknown, unknown>[] )
packages/utils/src/graphql/entities.ts:388
↓ 2 callersMethodsetLatestProcessedHeight
(height: number)
packages/node-core/src/indexer/blockDispatcher/base-block-dispatcher.ts:39
↓ 2 callersMethodsetLevel
(level: LevelWithSilent)
packages/utils/src/logger/logger.ts:139
↓ 2 callersFunctionsetMonitorService
(service: MonitorServiceInterface)
packages/node-core/src/process.ts:9
↓ 2 callersFunctionsplitEndpoints
(endpointStr: string)
packages/cli/src/controller/deploy-controller.ts:192
↓ 2 callersFunctionstopFlexPlanAdapter
( args: CreateApiKeyInputs, logger: Logger )
packages/cli/src/commands/network/stop-flex-plan.ts:29
↓ 2 callersFunctionstoreHostFunctions
(store: Store)
packages/node-core/src/indexer/worker/worker.store.service.ts:57
↓ 2 callersFunctionsubgraphTemplateToSubqlTemplate
( convertFunction: TemplateConvertFunction, subgraphTemplates: SubgraphTemplate[] )
packages/cli/src/controller/migrate/manifest/migrate-manifest.controller.ts:142
↓ 2 callersFunctionsubstrateBlockToHeader
(block: SignedBlock)
packages/node/src/utils/substrate.ts:52
↓ 2 callersFunctionsubstrateHeaderToHeader
(header: SubstrateHeader)
packages/node/src/utils/substrate.ts:44
↓ 2 callersFunctionswapDeploymentBoostAdapter
( args: BoostProjectInputs, logger: Logger, prompt?: Prompt )
packages/cli/src/commands/network/swap-deployment-boost.ts:45
↓ 2 callersMethodswitchToFile
(file: keyof typeof FileLocation)
packages/node-core/src/indexer/monitor.service.ts:449
↓ 2 callersMethodsyncRuntimeService
( specVersions: SpecVersion[], latestFinalizedHeight?: number, )
packages/node/src/indexer/worker/worker.service.ts:92
↓ 2 callersMethodsyncedPoiQueueAppend
* Append syncPoi to syncedPoiQueue, check flush If queue is full or overtime, then put input block. * @param syncedPoiBlock * @private
packages/node-core/src/indexer/poi/poiSync.service.ts:432
↓ 2 callersFunctiontestSubqueryProject
()
packages/node/src/indexer/project.service.spec.ts:25
↓ 2 callersMethodtoDeployment
()
packages/types-core/src/project/types.ts:128
↓ 2 callersFunctiontoString
(value: any)
packages/cli/src/utils/jsonToTable.ts:12
↓ 2 callersFunctiontsExtractor
(dataSources, casedInputAddress)
packages/cli/src/controller/generate-controller.ts:363
↓ 2 callersFunctiontsStringify
( obj: SubqlRuntimeHandler | SubqlRuntimeHandler[] | string, indent = 2, currentIndent = 0 )
packages/cli/src/controller/generate-controller.ts:481
↓ 2 callersFunctiontsVectorIndexName
(schema: string, table: string)
packages/node-core/src/db/sync-helper.ts:734
↓ 2 callersFunctionunwrap
( def: ZodTypeAny, unwrapInfo: UnwrapInfo = {type: def, default: undefined, array: false, optional: false}
packages/cli/src/adapters/utils.ts:74
↓ 2 callersFunctionupdateChainTypesHasher
( chainTypes: any, )
packages/node/src/indexer/api.service.ts:88
↓ 2 callersFunctionupdateDataSourcesV1_0_0
( _dataSources: (DS | CDS)[], reader: Reader, root: string, isCustomDs: IsCustomDs<DS, CDS> )
packages/node-core/src/utils/project.ts:121
↓ 2 callersFunctionupdateDeployment
( org: string, projectName: string, deployID: number, authToken: string, ipfsCID: string, queryVer
packages/cli/src/controller/deploy-controller.ts:136
↓ 2 callersMethodupdateDictionary
()
packages/node-core/src/indexer/fetch.service.ts:114
↓ 2 callersMethodupdateModels
(changes: ModifiedDbModels)
packages/node-core/src/indexer/storeModelProvider/types.ts:26
↓ 2 callersFunctionvalidate
(x: any)
packages/query/src/main.ts:27
↓ 2 callersMethodvalidate
()
packages/common-substrate/src/project/versioned/ProjectManifestVersioned.ts:50
↓ 2 callersFunctionvalidateEthereumProjectManifest
(projectPath: string)
packages/cli/src/controller/init-controller.ts:401
↓ 2 callersFunctionvalidateObject
(object: any, errorMessage = 'failed to validate object.')
packages/common/src/project/utils.ts:202
↓ 2 callersMethodvalidateSchemaChanges
(currentSchema: GraphQLSchema, nextSchema: GraphQLSchema)
packages/node-core/src/db/migration-service/SchemaMigration.service.ts:35
↓ 2 callersMethodvalidateSyncedPoi
(poi: ProofOfIndex, assertLocation: string)
packages/node-core/src/indexer/poi/poiSync.service.ts:200
↓ 2 callersMethodwrite
* Write block record data to file * @param blockData string or function that returns a string, this allows lazy interpolation for any heavy stringi
packages/node-core/src/indexer/monitor.service.ts:217
↓ 1 callersFunctionDEFAULT_OPTION
(unsafe = false)
packages/node-core/src/indexer/sandbox.ts:27
↓ 1 callersFunctionGlobalDataFactory
(sequelize: Sequelize, schema: string)
packages/node-core/src/indexer/entities/GlobalData.entity.ts:28
↓ 1 callersFunctionI
(e)
packages/node-core/test/sandbox/sourcemap-test-webpack.js:388
↓ 1 callersFunctionIsGreaterThan
(property: string, validationOptions?: ValidationOptions)
packages/node-core/src/admin/blockRange.ts:16
↓ 1 callersFunctionIsNetworkEndpoint
(cls: ClassConstructor<T>, validationOptions?: ValidationOptions)
packages/common/src/project/utils.ts:243
↓ 1 callersMethod_flushCache
()
packages/node-core/src/indexer/storeModelProvider/storeCache.service.ts:95
↓ 1 callersMethod_resetCache
()
packages/node-core/src/indexer/storeModelProvider/storeCache.service.ts:121
↓ 1 callersMethod_send
(body: string)
packages/node/src/indexer/x-provider/http.ts:191
↓ 1 callersFunctiona
(o,r)
packages/node-core/test/sandbox/sourcemap-test-esbuild.js:1
↓ 1 callersMethodaddArrayQueryParam
(query: QueryParamsType, key: string)
packages/cli/src/controller/network/consumer-host/consumer-host-service-api.ts:311
↓ 1 callersFunctionaddChain
(multichain: string, chainManifestPath: string)
packages/cli/src/controller/add-chain-controller.ts:47
↓ 1 callersMethodaddDefaultPoiBlocks
* Add default poi from latestSyncedPoi height to endHeight * @param endHeight * @private
packages/node-core/src/indexer/poi/poiSync.service.ts:391
↓ 1 callersFunctionaddDotEnvConfigCode
(manifestData: string)
packages/cli/src/controller/init-controller.ts:268
↓ 1 callersMethodaddExporter
(cachedModel: CachedModel, exporter: Exporter)
packages/node-core/src/indexer/storeModelProvider/storeCache.service.ts:68
↓ 1 callersMethodaddExporter
(model: PlainModel, exporter: Exporter)
packages/node-core/src/indexer/storeModelProvider/storeModel.service.ts:65
↓ 1 callersFunctionaddIdAndBlockRangeAttributes
(attributes: ModelAttributes<Model<any, any>, any>)
packages/node-core/src/db/sync-helper.ts:434
↓ 1 callersMethodaddQueryParam
(query: QueryParamsType, key: string)
packages/cli/src/controller/network/consumer-host/consumer-host-service-api.ts:307
↓ 1 callersMethodaddRelationComments
()
packages/node-core/src/db/migration-service/migration.ts:322
↓ 1 callersMethodaddSize
(size: number)
packages/node-core/src/utils/queues/rampQueue.ts:87
↓ 1 callersMethodaddToConnections
(api: T, endpoint: string)
packages/node-core/src/indexer/connectionPool.service.ts:54
↓ 1 callersMethodadjustConcurrency
(data: T)
packages/node-core/src/utils/queues/rampQueue.ts:62
↓ 1 callersMethodallCachedIds
()
packages/node-core/src/indexer/storeModelProvider/model/cacheModel.ts:53
↓ 1 callersMethodapiDisconnect
()
packages/node-core/src/api.service.ts:28
↓ 1 callersMethodapplyCronTimestamps
(getTimestamp: (height: number) => Promise<Date>)
packages/node-core/src/configure/SubqueryProject.ts:126
↓ 1 callersFunctionasTxExporter
(exporter: Exporter<T>)
packages/node-core/src/indexer/storeModelProvider/exporters/exporter.ts:33
↓ 1 callersMethodassertChainId
( network: { chainId: string }, connection: ApiPromiseConnection, )
packages/node/src/indexer/api.service.ts:402
↓ 1 callersFunctionb
(e)
packages/node-core/test/sandbox/sourcemap-test-webpack.js:252
↓ 1 callersMethodbackfillBlocks
* Backfills missing blocks between the last unfinalized block and a new block. * Validates parentHash chain during backfill to detect forks. *
packages/node-core/src/indexer/unfinalizedBlocks.service.ts:214
↓ 1 callersFunctionbackoffRetryInternal
(fn: () => Promise<T>, maxAttempts: number, currentAttempt = 0)
packages/node-core/src/utils/promise.ts:45
↓ 1 callersFunctionbatchDeleteAndThenUpdate
( sequelize: Sequelize, model: ModelStatic<any>, transaction: Transaction, targetBlockUnit: number, //
packages/node-core/src/indexer/store.service.ts:479
↓ 1 callersFunctionbatchDeletePoi
( model: PoiRepo, transaction: Transaction, targetBlockHeight: number, batchSize = 10000 )
packages/node-core/src/indexer/poi/poi.service.ts:189
↓ 1 callersFunctionbindProjections
(node: GqlNode)
packages/utils/src/graphql/builder.ts:50
↓ 1 callersFunctionblockDispatcherFactory
( workerPath: string, workerFns: Parameters<typeof createIndexerWorker<Worker, ApiConn, Block, DS>>[1]
packages/node-core/src/indexer/blockDispatcher/factory.ts:26
↓ 1 callersMethodblockRangeToBlockNumber
(input: T['__block_range'])
packages/node-core/src/indexer/storeModelProvider/exporters/csvStore.ts:56
↓ 1 callersMethodblockToHeader
(block: IBlock<B>)
packages/node-core/src/indexer/unfinalizedBlocks.service.ts:52
↓ 1 callersFunctionbootstrap
()
packages/node/src/init.ts:29
↓ 1 callersFunctionbuildArgs
(args: Record<string, unknown>)
packages/utils/src/graphql/builder.ts:22
↓ 1 callersMethodbuildDictionaryQueryEntries
(dataSources: any[])
packages/node-core/src/indexer/dictionary/dictionary.fixtures.ts:24
↓ 1 callersFunctionbuildDictionaryV2QueryEntry
( dataSources: SubstrateDataSource[], )
packages/node/src/indexer/dictionary/v2/substrateDictionaryV2.ts:20
↓ 1 callersMethodbulkRemove
(entity: string, ids: string[])
packages/node-core/src/indexer/store/store.ts:159
↓ 1 callersFunctionc
(o,r,e,s)
packages/node-core/test/sandbox/sourcemap-test-esbuild.js:1
↓ 1 callersFunctioncacheHostFunctions
(cache: Cache)
packages/node-core/src/indexer/worker/worker.cache.service.ts:23
↓ 1 callersFunctioncachedMethodHandler
( fn: ProviderInterface['send'], args: Parameters<ProviderInterface['send']>, )
packages/node/src/indexer/x-provider/cachedProvider.ts:18
↓ 1 callersFunctioncalcInterval
(api: ApiPromise)
packages/node/src/utils/substrate.ts:486
↓ 1 callersMethodcalculateNextDelay
(poolItem: ConnectionPoolItem<T>)
packages/node-core/src/indexer/connectionPoolState.manager.ts:283
↓ 1 callersFunctioncallFilterToQueryEntry
( filter: SubstrateCallFilter, )
packages/node/src/indexer/dictionary/v1/substrateDictionaryV1.ts:53
↓ 1 callersFunctioncamelCaseObjectKey
(object: Record<string, any>)
packages/node-core/src/utils/object.ts:14
↓ 1 callersMethodcheckAndSwitchFile
()
packages/node-core/src/indexer/monitor.service.ts:439
↓ 1 callersFunctioncheckCondition
()
packages/node-core/src/indexer/connectionPool.service.spec.ts:11
↓ 1 callersFunctioncheckLimit
(document: DocumentNode, limit: number)
packages/query/src/graphql/plugins/QueryAliasLimitPlugin.ts:7
↓ 1 callersFunctioncheckSchemaMetadata
(sequelize: Sequelize, schema: string, chainId: string)
packages/node-core/src/indexer/entities/Metadata.entity.ts:50
↓ 1 callersFunctioncheckYarnExists
()
packages/cli/src/controller/init-controller.ts:357
↓ 1 callersMethodcloseConnection
()
packages/cli/src/controller/network/walletconnect-signer.ts:47
↓ 1 callersFunctioncommentOnFunction
(schema: string, functionName: string, comment: string)
packages/node-core/src/db/sync-helper.ts:110
↓ 1 callersFunctioncompareModels
( currentModels: GraphQLModelsType[], nextModels: GraphQLModelsType[], changes: SchemaChangesType )
packages/node-core/src/db/migration-service/migration-helpers.ts:135
← previousnext →701–800 of 2,116, ranked by callers