Interface ProcessorServiceImplementation<CallContextExt>
interface ProcessorServiceImplementation<CallContextExt = {}> { getConfig( request: ProcessConfigRequest, context: CallContext & CallContextExt, ): Promise< { accountConfigs?: { address?: string; chainId?: string; intervalConfigs?: { fetchConfig?: { block?: (...)
| (...)
| (...)
; trace?: (...)
| (...)
| (...)
; transaction?: (...)
| (...)
| (...)
; transactionReceipt?: (...)
| (...)
| (...)
; transactionReceiptLogs?: (...)
| (...)
| (...)
; }; handlerId?: number; minutes?: number; minutesInterval?: { backfillInterval?: (...)
| (...)
; recentInterval?: (...)
| (...)
; }; slot?: number; slotInterval?: { backfillInterval?: (...)
| (...)
; recentInterval?: (...)
| (...)
; }; }[]; logConfigs?: { fetchConfig?: { block?: (...)
| (...)
| (...)
; trace?: (...)
| (...)
| (...)
; transaction?: (...)
| (...)
| (...)
; transactionReceipt?: (...)
| (...)
| (...)
; transactionReceiptLogs?: (...)
| (...)
| (...)
; }; filters?: { address?: ...
; addressType?: ...
; topics?: ...
}[]; handlerId?: number; handlerName?: string; }[]; moveCallConfigs?: { fetchConfig?: { allEvents?: (...)
| (...)
| (...)
; includeFailedTransaction?: (...)
| (...)
| (...)
; inputs?: (...)
| (...)
| (...)
; resourceChanges?: (...)
| (...)
| (...)
; resourceConfig?: (...)
| (...)
; supportMultisigFunc?: (...)
| (...)
| (...)
; }; filters?: { fromAndToAddress?: ...
; function?: ...
; includeFailed?: ...
; publicKeyPrefix?: ...
; typeArguments?: ...
; withTypeArguments?: ...
; }[]; handlerId?: number; }[]; moveIntervalConfigs?: { fetchConfig?: { allEvents?: (...)
| (...)
| (...)
; includeFailedTransaction?: (...)
| (...)
| (...)
; inputs?: (...)
| (...)
| (...)
; resourceChanges?: (...)
| (...)
| (...)
; resourceConfig?: (...)
| (...)
; supportMultisigFunc?: (...)
| (...)
| (...)
; }; intervalConfig?: { fetchConfig?: (...)
| (...)
; handlerId?: (...)
| (...)
; minutes?: (...)
| (...)
; minutesInterval?: (...)
| (...)
; slot?: (...)
| (...)
; slotInterval?: (...)
| (...)
; }; ownerType?: MoveOwnerType; resourceFetchConfig?: { owned?: (...)
| (...)
| (...)
}; type?: string; }[]; moveResourceChangeConfigs?: { handlerId?: number; type?: string }[]; startBlock?: bigint; }[]; config?: { name?: string; version?: string }; contractConfigs?: { assetConfigs?: { filters?: { assetId?: ...
; fromAddress?: ...
; toAddress?: ...
}[]; handlerId?: number; }[]; btcTransactionConfigs?: { filters?: { filter?: ...
; inputFilter?: ...
; outputFilter?: ...
}[]; handlerId?: number; }[]; contract?: { abi?: string; address?: string; chainId?: string; name?: string; }; cosmosLogConfigs?: { handlerId?: number; logFilters?: string[] }[]; endBlock?: bigint; fuelCallConfigs?: { filters?: { function?: ...
; includeFailed?: ...
}[]; handlerId?: number; }[]; fuelLogConfigs?: { handlerId?: number; logIds?: string[] }[]; instructionConfig?: { innerInstruction?: boolean; parsedInstruction?: boolean; rawDataInstruction?: boolean; }; intervalConfigs?: { fetchConfig?: { block?: (...)
| (...)
| (...)
; trace?: (...)
| (...)
| (...)
; transaction?: (...)
| (...)
| (...)
; transactionReceipt?: (...)
| (...)
| (...)
; transactionReceiptLogs?: (...)
| (...)
| (...)
; }; handlerId?: number; minutes?: number; minutesInterval?: { backfillInterval?: (...)
| (...)
; recentInterval?: (...)
| (...)
; }; slot?: number; slotInterval?: { backfillInterval?: (...)
| (...)
; recentInterval?: (...)
| (...)
; }; }[]; logConfigs?: { fetchConfig?: { block?: (...)
| (...)
| (...)
; trace?: (...)
| (...)
| (...)
; transaction?: (...)
| (...)
| (...)
; transactionReceipt?: (...)
| (...)
| (...)
; transactionReceiptLogs?: (...)
| (...)
| (...)
; }; filters?: { address?: ...
; addressType?: ...
; topics?: ...
}[]; handlerId?: number; handlerName?: string; }[]; moveCallConfigs?: { fetchConfig?: { allEvents?: (...)
| (...)
| (...)
; includeFailedTransaction?: (...)
| (...)
| (...)
; inputs?: (...)
| (...)
| (...)
; resourceChanges?: (...)
| (...)
| (...)
; resourceConfig?: (...)
| (...)
; supportMultisigFunc?: (...)
| (...)
| (...)
; }; filters?: { fromAndToAddress?: ...
; function?: ...
; includeFailed?: ...
; publicKeyPrefix?: ...
; typeArguments?: ...
; withTypeArguments?: ...
; }[]; handlerId?: number; }[]; moveEventConfigs?: { fetchConfig?: { allEvents?: (...)
| (...)
| (...)
; includeFailedTransaction?: (...)
| (...)
| (...)
; inputs?: (...)
| (...)
| (...)
; resourceChanges?: (...)
| (...)
| (...)
; resourceConfig?: (...)
| (...)
; supportMultisigFunc?: (...)
| (...)
| (...)
; }; filters?: { account?: ...
; type?: ...
}[]; handlerId?: number; }[]; moveIntervalConfigs?: { fetchConfig?: { allEvents?: (...)
| (...)
| (...)
; includeFailedTransaction?: (...)
| (...)
| (...)
; inputs?: (...)
| (...)
| (...)
; resourceChanges?: (...)
| (...)
| (...)
; resourceConfig?: (...)
| (...)
; supportMultisigFunc?: (...)
| (...)
| (...)
; }; intervalConfig?: { fetchConfig?: (...)
| (...)
; handlerId?: (...)
| (...)
; minutes?: (...)
| (...)
; minutesInterval?: (...)
| (...)
; slot?: (...)
| (...)
; slotInterval?: (...)
| (...)
; }; ownerType?: MoveOwnerType; resourceFetchConfig?: { owned?: (...)
| (...)
| (...)
}; type?: string; }[]; moveResourceChangeConfigs?: { handlerId?: number; type?: string }[]; processorType?: string; starknetEventConfigs?: { filters?: { address?: ...
; keys?: ...
}[]; handlerId?: number; }[]; startBlock?: bigint; traceConfigs?: { fetchConfig?: { block?: (...)
| (...)
| (...)
; trace?: (...)
| (...)
| (...)
; transaction?: (...)
| (...)
| (...)
; transactionReceipt?: (...)
| (...)
| (...)
; transactionReceiptLogs?: (...)
| (...)
| (...)
; }; handlerId?: number; handlerName?: string; signature?: string; }[]; transactionConfig?: { fetchConfig?: { block?: (...)
| (...)
| (...)
; trace?: (...)
| (...)
| (...)
; transaction?: (...)
| (...)
| (...)
; transactionReceipt?: (...)
| (...)
| (...)
; transactionReceiptLogs?: (...)
| (...)
| (...)
; }; handlerId?: number; }[]; }[]; dbSchema?: { gqlSchema?: string }; eventLogConfigs?: { fields?: { basicType?: EventLogConfig_BasicFieldType; coinType?: { address?: (...)
| (...)
; symbol?: (...)
| (...)
}; name?: string; structType?: { fields?: { name?: string | undefined; basicType?: EventLogConfig_BasicFieldType | undefined; coinType?: { symbol?: string | undefined; address?: { address?: string | undefined; chain?: string | undefined; } | undefined; } | undefined; structType?: { ...; } | undefined; }[] | undefined
; }; }[]; name?: string; }[]; eventTrackingConfigs?: { distinctAggregationByDays?: number[]; eventName?: string; retentionConfig?: { days?: number; retentionEventName?: string }; totalByDay?: boolean; totalPerEntity?: {}; unique?: boolean; }[]; executionConfig?: { forceExactBlockTime?: boolean; processBindingTimeout?: number; rpcRetryTimes?: number; sequential?: boolean; skipStartBlockValidation?: boolean; }; exportConfigs?: { channel?: string; name?: string }[]; metricConfigs?: { aggregationConfig?: { discardOrigin?: boolean; intervalInMinutes?: number[]; types?: AggregationType[]; }; description?: string; name?: string; persistentBetweenVersion?: boolean; sparse?: boolean; type?: MetricType; unit?: string; }[]; templateInstances?: { baseLabels?: { [key: string]: any }; contract?: { abi?: string; address?: string; chainId?: string; name?: string; }; endBlock?: bigint; startBlock?: bigint; templateId?: number; }[]; }, >; preprocessBindingsStream( request: AsyncIterable<PreprocessStreamRequest>, context: CallContext & CallContextExt, ): ServerStreamingMethodResult< { dbRequest?: { delete?: { entity?: string[]; id?: string[] }; get?: { entity?: string; id?: string }; list?: { cursor?: string; entity?: string; filters?: { field?: string; op?: DBRequest_DBOperator; value?: { values?: ...
}; }[]; pageSize?: number; }; opId?: bigint; upsert?: { data?: { [key: string]: any }[]; entity?: string[]; entityData?: { fields?: { [key: ...
]: ...
} }[]; id?: string[]; }; }; processId?: number; }, >; processBindings( request: ProcessBindingsRequest, context: CallContext & CallContextExt, ): Promise< { result?: { counters?: { add?: boolean; metadata?: { address?: string; blockNumber?: bigint; chainId?: string; contractName?: string; labels?: { [key: ...
]: ...
}; logIndex?: number; name?: string; transactionHash?: string; transactionIndex?: number; }; metricValue?: { bigDecimal?: string; bigInteger?: { data?: ...
; negative?: ...
}; doubleValue?: number; }; runtimeInfo?: { from?: HandlerType }; }[]; events?: { attributes?: { [key: string]: any }; attributes2?: { fields?: { [key: ...
]: ...
} }; distinctEntityId?: string; message?: string; metadata?: { address?: string; blockNumber?: bigint; chainId?: string; contractName?: string; labels?: { [key: ...
]: ...
}; logIndex?: number; name?: string; transactionHash?: string; transactionIndex?: number; }; noMetric?: boolean; runtimeInfo?: { from?: HandlerType }; severity?: LogLevel; }[]; exports?: { metadata?: { address?: string; blockNumber?: bigint; chainId?: string; contractName?: string; labels?: { [key: ...
]: ...
}; logIndex?: number; name?: string; transactionHash?: string; transactionIndex?: number; }; payload?: string; runtimeInfo?: { from?: HandlerType }; }[]; gauges?: { metadata?: { address?: string; blockNumber?: bigint; chainId?: string; contractName?: string; labels?: { [key: ...
]: ...
}; logIndex?: number; name?: string; transactionHash?: string; transactionIndex?: number; }; metricValue?: { bigDecimal?: string; bigInteger?: { data?: ...
; negative?: ...
}; doubleValue?: number; }; runtimeInfo?: { from?: HandlerType }; }[]; states?: { configUpdated?: boolean; error?: string }; }; }, >; processBindingsStream( request: AsyncIterable<ProcessStreamRequest>, context: CallContext & CallContextExt, ): ServerStreamingMethodResult< { dbRequest?: { delete?: { entity?: string[]; id?: string[] }; get?: { entity?: string; id?: string }; list?: { cursor?: string; entity?: string; filters?: { field?: string; op?: DBRequest_DBOperator; value?: { values?: ...
}; }[]; pageSize?: number; }; opId?: bigint; upsert?: { data?: { [key: string]: any }[]; entity?: string[]; entityData?: { fields?: { [key: ...
]: ...
} }[]; id?: string[]; }; }; processId?: number; result?: { counters?: { add?: boolean; metadata?: { address?: string; blockNumber?: bigint; chainId?: string; contractName?: string; labels?: { [key: ...
]: ...
}; logIndex?: number; name?: string; transactionHash?: string; transactionIndex?: number; }; metricValue?: { bigDecimal?: string; bigInteger?: { data?: ...
; negative?: ...
}; doubleValue?: number; }; runtimeInfo?: { from?: HandlerType }; }[]; events?: { attributes?: { [key: string]: any }; attributes2?: { fields?: { [key: ...
]: ...
} }; distinctEntityId?: string; message?: string; metadata?: { address?: string; blockNumber?: bigint; chainId?: string; contractName?: string; labels?: { [key: ...
]: ...
}; logIndex?: number; name?: string; transactionHash?: string; transactionIndex?: number; }; noMetric?: boolean; runtimeInfo?: { from?: HandlerType }; severity?: LogLevel; }[]; exports?: { metadata?: { address?: string; blockNumber?: bigint; chainId?: string; contractName?: string; labels?: { [key: ...
]: ...
}; logIndex?: number; name?: string; transactionHash?: string; transactionIndex?: number; }; payload?: string; runtimeInfo?: { from?: HandlerType }; }[]; gauges?: { metadata?: { address?: string; blockNumber?: bigint; chainId?: string; contractName?: string; labels?: { [key: ...
]: ...
}; logIndex?: number; name?: string; transactionHash?: string; transactionIndex?: number; }; metricValue?: { bigDecimal?: string; bigInteger?: { data?: ...
; negative?: ...
}; doubleValue?: number; }; runtimeInfo?: { from?: HandlerType }; }[]; states?: { configUpdated?: boolean; error?: string }; }; }, >; start( request: StartRequest, context: CallContext & CallContextExt, ): Promise<{}>; stop(request: Empty, context: CallContext & CallContextExt): Promise<{}>;} Methods
getConfig
- getConfig(
request: ProcessConfigRequest,
context: CallContext & CallContextExt,
): Promise<
{
accountConfigs?: {
address?: string;
chainId?: string;
intervalConfigs?: {
fetchConfig?: {
block?: (...)
| (...)
| (...);
trace?: (...) | (...) | (...);
transaction?: (...) | (...) | (...);
transactionReceipt?: (...) | (...) | (...);
transactionReceiptLogs?: (...) | (...) | (...);
};
handlerId?: number;
minutes?: number;
minutesInterval?: {
backfillInterval?: (...)
| (...);
recentInterval?: (...) | (...);
};
slot?: number;
slotInterval?: {
backfillInterval?: (...)
| (...);
recentInterval?: (...) | (...);
};
}[];
logConfigs?: {
fetchConfig?: {
block?: (...)
| (...)
| (...);
trace?: (...) | (...) | (...);
transaction?: (...) | (...) | (...);
transactionReceipt?: (...) | (...) | (...);
transactionReceiptLogs?: (...) | (...) | (...);
};
filters?: { address?: ...; addressType?: ...; topics?: ... }[];
handlerId?: number;
handlerName?: string;
}[];
moveCallConfigs?: {
fetchConfig?: {
allEvents?: (...)
| (...)
| (...);
includeFailedTransaction?: (...) | (...) | (...);
inputs?: (...) | (...) | (...);
resourceChanges?: (...) | (...) | (...);
resourceConfig?: (...) | (...);
supportMultisigFunc?: (...) | (...) | (...);
};
filters?: {
fromAndToAddress?: ...;
function?: ...;
includeFailed?: ...;
publicKeyPrefix?: ...;
typeArguments?: ...;
withTypeArguments?: ...;
}[];
handlerId?: number;
}[];
moveIntervalConfigs?: {
fetchConfig?: {
allEvents?: (...)
| (...)
| (...);
includeFailedTransaction?: (...) | (...) | (...);
inputs?: (...) | (...) | (...);
resourceChanges?: (...) | (...) | (...);
resourceConfig?: (...) | (...);
supportMultisigFunc?: (...) | (...) | (...);
};
intervalConfig?: {
fetchConfig?: (...)
| (...);
handlerId?: (...) | (...);
minutes?: (...) | (...);
minutesInterval?: (...) | (...);
slot?: (...) | (...);
slotInterval?: (...) | (...);
};
ownerType?: MoveOwnerType;
resourceFetchConfig?: { owned?: (...)
| (...)
| (...) };
type?: string;
}[];
moveResourceChangeConfigs?: { handlerId?: number; type?: string }[];
startBlock?: bigint;
}[];
config?: { name?: string; version?: string };
contractConfigs?: {
assetConfigs?: {
filters?: { assetId?: ...; fromAddress?: ...; toAddress?: ... }[];
handlerId?: number;
}[];
btcTransactionConfigs?: {
filters?: { filter?: ...; inputFilter?: ...; outputFilter?: ... }[];
handlerId?: number;
}[];
contract?: {
abi?: string;
address?: string;
chainId?: string;
name?: string;
};
cosmosLogConfigs?: { handlerId?: number; logFilters?: string[] }[];
endBlock?: bigint;
fuelCallConfigs?: {
filters?: { function?: ...; includeFailed?: ... }[];
handlerId?: number;
}[];
fuelLogConfigs?: { handlerId?: number; logIds?: string[] }[];
instructionConfig?: {
innerInstruction?: boolean;
parsedInstruction?: boolean;
rawDataInstruction?: boolean;
};
intervalConfigs?: {
fetchConfig?: {
block?: (...)
| (...)
| (...);
trace?: (...) | (...) | (...);
transaction?: (...) | (...) | (...);
transactionReceipt?: (...) | (...) | (...);
transactionReceiptLogs?: (...) | (...) | (...);
};
handlerId?: number;
minutes?: number;
minutesInterval?: {
backfillInterval?: (...)
| (...);
recentInterval?: (...) | (...);
};
slot?: number;
slotInterval?: {
backfillInterval?: (...)
| (...);
recentInterval?: (...) | (...);
};
}[];
logConfigs?: {
fetchConfig?: {
block?: (...)
| (...)
| (...);
trace?: (...) | (...) | (...);
transaction?: (...) | (...) | (...);
transactionReceipt?: (...) | (...) | (...);
transactionReceiptLogs?: (...) | (...) | (...);
};
filters?: { address?: ...; addressType?: ...; topics?: ... }[];
handlerId?: number;
handlerName?: string;
}[];
moveCallConfigs?: {
fetchConfig?: {
allEvents?: (...)
| (...)
| (...);
includeFailedTransaction?: (...) | (...) | (...);
inputs?: (...) | (...) | (...);
resourceChanges?: (...) | (...) | (...);
resourceConfig?: (...) | (...);
supportMultisigFunc?: (...) | (...) | (...);
};
filters?: {
fromAndToAddress?: ...;
function?: ...;
includeFailed?: ...;
publicKeyPrefix?: ...;
typeArguments?: ...;
withTypeArguments?: ...;
}[];
handlerId?: number;
}[];
moveEventConfigs?: {
fetchConfig?: {
allEvents?: (...)
| (...)
| (...);
includeFailedTransaction?: (...) | (...) | (...);
inputs?: (...) | (...) | (...);
resourceChanges?: (...) | (...) | (...);
resourceConfig?: (...) | (...);
supportMultisigFunc?: (...) | (...) | (...);
};
filters?: { account?: ...; type?: ... }[];
handlerId?: number;
}[];
moveIntervalConfigs?: {
fetchConfig?: {
allEvents?: (...)
| (...)
| (...);
includeFailedTransaction?: (...) | (...) | (...);
inputs?: (...) | (...) | (...);
resourceChanges?: (...) | (...) | (...);
resourceConfig?: (...) | (...);
supportMultisigFunc?: (...) | (...) | (...);
};
intervalConfig?: {
fetchConfig?: (...)
| (...);
handlerId?: (...) | (...);
minutes?: (...) | (...);
minutesInterval?: (...) | (...);
slot?: (...) | (...);
slotInterval?: (...) | (...);
};
ownerType?: MoveOwnerType;
resourceFetchConfig?: { owned?: (...)
| (...)
| (...) };
type?: string;
}[];
moveResourceChangeConfigs?: { handlerId?: number; type?: string }[];
processorType?: string;
starknetEventConfigs?: {
filters?: { address?: ...; keys?: ... }[];
handlerId?: number;
}[];
startBlock?: bigint;
traceConfigs?: {
fetchConfig?: {
block?: (...)
| (...)
| (...);
trace?: (...) | (...) | (...);
transaction?: (...) | (...) | (...);
transactionReceipt?: (...) | (...) | (...);
transactionReceiptLogs?: (...) | (...) | (...);
};
handlerId?: number;
handlerName?: string;
signature?: string;
}[];
transactionConfig?: {
fetchConfig?: {
block?: (...)
| (...)
| (...);
trace?: (...) | (...) | (...);
transaction?: (...) | (...) | (...);
transactionReceipt?: (...) | (...) | (...);
transactionReceiptLogs?: (...) | (...) | (...);
};
handlerId?: number;
}[];
}[];
dbSchema?: { gqlSchema?: string };
eventLogConfigs?: {
fields?: {
basicType?: EventLogConfig_BasicFieldType;
coinType?: { address?: (...) | (...); symbol?: (...) | (...) };
name?: string;
structType?: {
fields?: { name?: string | undefined; basicType?: EventLogConfig_BasicFieldType | undefined; coinType?: { symbol?: string | undefined; address?: { address?: string | undefined; chain?: string | undefined; } | undefined; } | undefined; structType?: { ...; } | undefined; }[] | undefined;
};
}[];
name?: string;
}[];
eventTrackingConfigs?: {
distinctAggregationByDays?: number[];
eventName?: string;
retentionConfig?: { days?: number; retentionEventName?: string };
totalByDay?: boolean;
totalPerEntity?: {};
unique?: boolean;
}[];
executionConfig?: {
forceExactBlockTime?: boolean;
processBindingTimeout?: number;
rpcRetryTimes?: number;
sequential?: boolean;
skipStartBlockValidation?: boolean;
};
exportConfigs?: { channel?: string; name?: string }[];
metricConfigs?: {
aggregationConfig?: {
discardOrigin?: boolean;
intervalInMinutes?: number[];
types?: AggregationType[];
};
description?: string;
name?: string;
persistentBetweenVersion?: boolean;
sparse?: boolean;
type?: MetricType;
unit?: string;
}[];
templateInstances?: {
baseLabels?: { [key: string]: any };
contract?: {
abi?: string;
address?: string;
chainId?: string;
name?: string;
};
endBlock?: bigint;
startBlock?: bigint;
templateId?: number;
}[];
},
> Returns Promise<
{
accountConfigs?: {
address?: string;
chainId?: string;
intervalConfigs?: {
fetchConfig?: {
block?: (...)
| (...)
| (...);
trace?: (...) | (...) | (...);
transaction?: (...) | (...) | (...);
transactionReceipt?: (...) | (...) | (...);
transactionReceiptLogs?: (...) | (...) | (...);
};
handlerId?: number;
minutes?: number;
minutesInterval?: {
backfillInterval?: (...)
| (...);
recentInterval?: (...) | (...);
};
slot?: number;
slotInterval?: {
backfillInterval?: (...)
| (...);
recentInterval?: (...) | (...);
};
}[];
logConfigs?: {
fetchConfig?: {
block?: (...)
| (...)
| (...);
trace?: (...) | (...) | (...);
transaction?: (...) | (...) | (...);
transactionReceipt?: (...) | (...) | (...);
transactionReceiptLogs?: (...) | (...) | (...);
};
filters?: { address?: ...; addressType?: ...; topics?: ... }[];
handlerId?: number;
handlerName?: string;
}[];
moveCallConfigs?: {
fetchConfig?: {
allEvents?: (...)
| (...)
| (...);
includeFailedTransaction?: (...) | (...) | (...);
inputs?: (...) | (...) | (...);
resourceChanges?: (...) | (...) | (...);
resourceConfig?: (...) | (...);
supportMultisigFunc?: (...) | (...) | (...);
};
filters?: {
fromAndToAddress?: ...;
function?: ...;
includeFailed?: ...;
publicKeyPrefix?: ...;
typeArguments?: ...;
withTypeArguments?: ...;
}[];
handlerId?: number;
}[];
moveIntervalConfigs?: {
fetchConfig?: {
allEvents?: (...)
| (...)
| (...);
includeFailedTransaction?: (...) | (...) | (...);
inputs?: (...) | (...) | (...);
resourceChanges?: (...) | (...) | (...);
resourceConfig?: (...) | (...);
supportMultisigFunc?: (...) | (...) | (...);
};
intervalConfig?: {
fetchConfig?: (...)
| (...);
handlerId?: (...) | (...);
minutes?: (...) | (...);
minutesInterval?: (...) | (...);
slot?: (...) | (...);
slotInterval?: (...) | (...);
};
ownerType?: MoveOwnerType;
resourceFetchConfig?: { owned?: (...)
| (...)
| (...) };
type?: string;
}[];
moveResourceChangeConfigs?: { handlerId?: number; type?: string }[];
startBlock?: bigint;
}[];
config?: { name?: string; version?: string };
contractConfigs?: {
assetConfigs?: {
filters?: { assetId?: ...; fromAddress?: ...; toAddress?: ... }[];
handlerId?: number;
}[];
btcTransactionConfigs?: {
filters?: { filter?: ...; inputFilter?: ...; outputFilter?: ... }[];
handlerId?: number;
}[];
contract?: {
abi?: string;
address?: string;
chainId?: string;
name?: string;
};
cosmosLogConfigs?: { handlerId?: number; logFilters?: string[] }[];
endBlock?: bigint;
fuelCallConfigs?: {
filters?: { function?: ...; includeFailed?: ... }[];
handlerId?: number;
}[];
fuelLogConfigs?: { handlerId?: number; logIds?: string[] }[];
instructionConfig?: {
innerInstruction?: boolean;
parsedInstruction?: boolean;
rawDataInstruction?: boolean;
};
intervalConfigs?: {
fetchConfig?: {
block?: (...)
| (...)
| (...);
trace?: (...) | (...) | (...);
transaction?: (...) | (...) | (...);
transactionReceipt?: (...) | (...) | (...);
transactionReceiptLogs?: (...) | (...) | (...);
};
handlerId?: number;
minutes?: number;
minutesInterval?: {
backfillInterval?: (...)
| (...);
recentInterval?: (...) | (...);
};
slot?: number;
slotInterval?: {
backfillInterval?: (...)
| (...);
recentInterval?: (...) | (...);
};
}[];
logConfigs?: {
fetchConfig?: {
block?: (...)
| (...)
| (...);
trace?: (...) | (...) | (...);
transaction?: (...) | (...) | (...);
transactionReceipt?: (...) | (...) | (...);
transactionReceiptLogs?: (...) | (...) | (...);
};
filters?: { address?: ...; addressType?: ...; topics?: ... }[];
handlerId?: number;
handlerName?: string;
}[];
moveCallConfigs?: {
fetchConfig?: {
allEvents?: (...)
| (...)
| (...);
includeFailedTransaction?: (...) | (...) | (...);
inputs?: (...) | (...) | (...);
resourceChanges?: (...) | (...) | (...);
resourceConfig?: (...) | (...);
supportMultisigFunc?: (...) | (...) | (...);
};
filters?: {
fromAndToAddress?: ...;
function?: ...;
includeFailed?: ...;
publicKeyPrefix?: ...;
typeArguments?: ...;
withTypeArguments?: ...;
}[];
handlerId?: number;
}[];
moveEventConfigs?: {
fetchConfig?: {
allEvents?: (...)
| (...)
| (...);
includeFailedTransaction?: (...) | (...) | (...);
inputs?: (...) | (...) | (...);
resourceChanges?: (...) | (...) | (...);
resourceConfig?: (...) | (...);
supportMultisigFunc?: (...) | (...) | (...);
};
filters?: { account?: ...; type?: ... }[];
handlerId?: number;
}[];
moveIntervalConfigs?: {
fetchConfig?: {
allEvents?: (...)
| (...)
| (...);
includeFailedTransaction?: (...) | (...) | (...);
inputs?: (...) | (...) | (...);
resourceChanges?: (...) | (...) | (...);
resourceConfig?: (...) | (...);
supportMultisigFunc?: (...) | (...) | (...);
};
intervalConfig?: {
fetchConfig?: (...)
| (...);
handlerId?: (...) | (...);
minutes?: (...) | (...);
minutesInterval?: (...) | (...);
slot?: (...) | (...);
slotInterval?: (...) | (...);
};
ownerType?: MoveOwnerType;
resourceFetchConfig?: { owned?: (...)
| (...)
| (...) };
type?: string;
}[];
moveResourceChangeConfigs?: { handlerId?: number; type?: string }[];
processorType?: string;
starknetEventConfigs?: {
filters?: { address?: ...; keys?: ... }[];
handlerId?: number;
}[];
startBlock?: bigint;
traceConfigs?: {
fetchConfig?: {
block?: (...)
| (...)
| (...);
trace?: (...) | (...) | (...);
transaction?: (...) | (...) | (...);
transactionReceipt?: (...) | (...) | (...);
transactionReceiptLogs?: (...) | (...) | (...);
};
handlerId?: number;
handlerName?: string;
signature?: string;
}[];
transactionConfig?: {
fetchConfig?: {
block?: (...)
| (...)
| (...);
trace?: (...) | (...) | (...);
transaction?: (...) | (...) | (...);
transactionReceipt?: (...) | (...) | (...);
transactionReceiptLogs?: (...) | (...) | (...);
};
handlerId?: number;
}[];
}[];
dbSchema?: { gqlSchema?: string };
eventLogConfigs?: {
fields?: {
basicType?: EventLogConfig_BasicFieldType;
coinType?: { address?: (...) | (...); symbol?: (...) | (...) };
name?: string;
structType?: {
fields?: { name?: string | undefined; basicType?: EventLogConfig_BasicFieldType | undefined; coinType?: { symbol?: string | undefined; address?: { address?: string | undefined; chain?: string | undefined; } | undefined; } | undefined; structType?: { ...; } | undefined; }[] | undefined;
};
}[];
name?: string;
}[];
eventTrackingConfigs?: {
distinctAggregationByDays?: number[];
eventName?: string;
retentionConfig?: { days?: number; retentionEventName?: string };
totalByDay?: boolean;
totalPerEntity?: {};
unique?: boolean;
}[];
executionConfig?: {
forceExactBlockTime?: boolean;
processBindingTimeout?: number;
rpcRetryTimes?: number;
sequential?: boolean;
skipStartBlockValidation?: boolean;
};
exportConfigs?: { channel?: string; name?: string }[];
metricConfigs?: {
aggregationConfig?: {
discardOrigin?: boolean;
intervalInMinutes?: number[];
types?: AggregationType[];
};
description?: string;
name?: string;
persistentBetweenVersion?: boolean;
sparse?: boolean;
type?: MetricType;
unit?: string;
}[];
templateInstances?: {
baseLabels?: { [key: string]: any };
contract?: {
abi?: string;
address?: string;
chainId?: string;
name?: string;
};
endBlock?: bigint;
startBlock?: bigint;
templateId?: number;
}[];
},
>
preprocessBindingsStream
- preprocessBindingsStream(
request: AsyncIterable<PreprocessStreamRequest>,
context: CallContext & CallContextExt,
): ServerStreamingMethodResult<
{
dbRequest?: {
delete?: { entity?: string[]; id?: string[] };
get?: { entity?: string; id?: string };
list?: {
cursor?: string;
entity?: string;
filters?: {
field?: string;
op?: DBRequest_DBOperator;
value?: { values?: ... };
}[];
pageSize?: number;
};
opId?: bigint;
upsert?: {
data?: { [key: string]: any }[];
entity?: string[];
entityData?: { fields?: { [key: ...]: ... } }[];
id?: string[];
};
};
processId?: number;
},
> Returns ServerStreamingMethodResult<
{
dbRequest?: {
delete?: { entity?: string[]; id?: string[] };
get?: { entity?: string; id?: string };
list?: {
cursor?: string;
entity?: string;
filters?: {
field?: string;
op?: DBRequest_DBOperator;
value?: { values?: ... };
}[];
pageSize?: number;
};
opId?: bigint;
upsert?: {
data?: { [key: string]: any }[];
entity?: string[];
entityData?: { fields?: { [key: ...]: ... } }[];
id?: string[];
};
};
processId?: number;
},
>
processBindings
- processBindings(
request: ProcessBindingsRequest,
context: CallContext & CallContextExt,
): Promise<
{
result?: {
counters?: {
add?: boolean;
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
metricValue?: {
bigDecimal?: string;
bigInteger?: { data?: ...; negative?: ... };
doubleValue?: number;
};
runtimeInfo?: { from?: HandlerType };
}[];
events?: {
attributes?: { [key: string]: any };
attributes2?: { fields?: { [key: ...]: ... } };
distinctEntityId?: string;
message?: string;
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
noMetric?: boolean;
runtimeInfo?: { from?: HandlerType };
severity?: LogLevel;
}[];
exports?: {
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
payload?: string;
runtimeInfo?: { from?: HandlerType };
}[];
gauges?: {
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
metricValue?: {
bigDecimal?: string;
bigInteger?: { data?: ...; negative?: ... };
doubleValue?: number;
};
runtimeInfo?: { from?: HandlerType };
}[];
states?: { configUpdated?: boolean; error?: string };
};
},
> Returns Promise<
{
result?: {
counters?: {
add?: boolean;
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
metricValue?: {
bigDecimal?: string;
bigInteger?: { data?: ...; negative?: ... };
doubleValue?: number;
};
runtimeInfo?: { from?: HandlerType };
}[];
events?: {
attributes?: { [key: string]: any };
attributes2?: { fields?: { [key: ...]: ... } };
distinctEntityId?: string;
message?: string;
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
noMetric?: boolean;
runtimeInfo?: { from?: HandlerType };
severity?: LogLevel;
}[];
exports?: {
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
payload?: string;
runtimeInfo?: { from?: HandlerType };
}[];
gauges?: {
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
metricValue?: {
bigDecimal?: string;
bigInteger?: { data?: ...; negative?: ... };
doubleValue?: number;
};
runtimeInfo?: { from?: HandlerType };
}[];
states?: { configUpdated?: boolean; error?: string };
};
},
>
processBindingsStream
- processBindingsStream(
request: AsyncIterable<ProcessStreamRequest>,
context: CallContext & CallContextExt,
): ServerStreamingMethodResult<
{
dbRequest?: {
delete?: { entity?: string[]; id?: string[] };
get?: { entity?: string; id?: string };
list?: {
cursor?: string;
entity?: string;
filters?: {
field?: string;
op?: DBRequest_DBOperator;
value?: { values?: ... };
}[];
pageSize?: number;
};
opId?: bigint;
upsert?: {
data?: { [key: string]: any }[];
entity?: string[];
entityData?: { fields?: { [key: ...]: ... } }[];
id?: string[];
};
};
processId?: number;
result?: {
counters?: {
add?: boolean;
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
metricValue?: {
bigDecimal?: string;
bigInteger?: { data?: ...; negative?: ... };
doubleValue?: number;
};
runtimeInfo?: { from?: HandlerType };
}[];
events?: {
attributes?: { [key: string]: any };
attributes2?: { fields?: { [key: ...]: ... } };
distinctEntityId?: string;
message?: string;
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
noMetric?: boolean;
runtimeInfo?: { from?: HandlerType };
severity?: LogLevel;
}[];
exports?: {
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
payload?: string;
runtimeInfo?: { from?: HandlerType };
}[];
gauges?: {
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
metricValue?: {
bigDecimal?: string;
bigInteger?: { data?: ...; negative?: ... };
doubleValue?: number;
};
runtimeInfo?: { from?: HandlerType };
}[];
states?: { configUpdated?: boolean; error?: string };
};
},
> Returns ServerStreamingMethodResult<
{
dbRequest?: {
delete?: { entity?: string[]; id?: string[] };
get?: { entity?: string; id?: string };
list?: {
cursor?: string;
entity?: string;
filters?: {
field?: string;
op?: DBRequest_DBOperator;
value?: { values?: ... };
}[];
pageSize?: number;
};
opId?: bigint;
upsert?: {
data?: { [key: string]: any }[];
entity?: string[];
entityData?: { fields?: { [key: ...]: ... } }[];
id?: string[];
};
};
processId?: number;
result?: {
counters?: {
add?: boolean;
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
metricValue?: {
bigDecimal?: string;
bigInteger?: { data?: ...; negative?: ... };
doubleValue?: number;
};
runtimeInfo?: { from?: HandlerType };
}[];
events?: {
attributes?: { [key: string]: any };
attributes2?: { fields?: { [key: ...]: ... } };
distinctEntityId?: string;
message?: string;
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
noMetric?: boolean;
runtimeInfo?: { from?: HandlerType };
severity?: LogLevel;
}[];
exports?: {
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
payload?: string;
runtimeInfo?: { from?: HandlerType };
}[];
gauges?: {
metadata?: {
address?: string;
blockNumber?: bigint;
chainId?: string;
contractName?: string;
labels?: { [key: ...]: ... };
logIndex?: number;
name?: string;
transactionHash?: string;
transactionIndex?: number;
};
metricValue?: {
bigDecimal?: string;
bigInteger?: { data?: ...; negative?: ... };
doubleValue?: number;
};
runtimeInfo?: { from?: HandlerType };
}[];
states?: { configUpdated?: boolean; error?: string };
};
},
>
start
- start(request: StartRequest, context: CallContext & CallContextExt): Promise<{}>
Returns Promise<{}>
stop
- stop(request: Empty, context: CallContext & CallContextExt): Promise<{}>
Returns Promise<{}>