Variable ProcessorDefinition
ProcessorDefinition: { fullName: "processor.Processor"; methods: { getConfig: { name: "GetConfig"; options: {}; requestStream: false; requestType: { create(base?: {}): ProcessConfigRequest; decode( input: Uint8Array | Reader, length?: number, ): ProcessConfigRequest; encode(_: ProcessConfigRequest, writer?: Writer): Writer; fromJSON(_: any): ProcessConfigRequest; fromPartial(_: {}): ProcessConfigRequest; toJSON(_: ProcessConfigRequest): unknown; }; responseStream: false; responseType: { create( base?: { accountConfigs?: { address?: string; chainId?: string; intervalConfigs?: (...)
[]; logConfigs?: (...)
[]; moveCallConfigs?: (...)
[]; moveIntervalConfigs?: (...)
[]; moveResourceChangeConfigs?: (...)
[]; startBlock?: bigint; }[]; config?: { name?: string; version?: string }; contractConfigs?: { assetConfigs?: (...)
[]; btcTransactionConfigs?: (...)
[]; contract?: { abi?: ...
; address?: ...
; chainId?: ...
; name?: ...
}; cosmosLogConfigs?: (...)
[]; endBlock?: bigint; fuelCallConfigs?: (...)
[]; fuelLogConfigs?: (...)
[]; instructionConfig?: { innerInstruction?: ...
; parsedInstruction?: ...
; rawDataInstruction?: ...
; }; intervalConfigs?: (...)
[]; logConfigs?: (...)
[]; moveCallConfigs?: (...)
[]; moveEventConfigs?: (...)
[]; moveIntervalConfigs?: (...)
[]; moveResourceChangeConfigs?: (...)
[]; processorType?: string; starknetEventConfigs?: (...)
[]; startBlock?: bigint; traceConfigs?: (...)
[]; transactionConfig?: (...)
[]; }[]; dbSchema?: { gqlSchema?: string }; eventLogConfigs?: { fields?: (...)
[]; name?: string }[]; eventTrackingConfigs?: { distinctAggregationByDays?: (...)
[]; eventName?: string; retentionConfig?: { days?: ...
; retentionEventName?: ...
}; totalByDay?: boolean; totalPerEntity?: {}; unique?: boolean; }[]; executionConfig?: { forceExactBlockTime?: boolean; processBindingTimeout?: number; rpcRetryTimes?: number; sequential?: boolean; skipStartBlockValidation?: boolean; }; exportConfigs?: { channel?: string; name?: string }[]; metricConfigs?: { aggregationConfig?: { discardOrigin?: ...
; intervalInMinutes?: ...
; types?: ...
; }; description?: string; name?: string; persistentBetweenVersion?: boolean; sparse?: boolean; type?: MetricType; unit?: string; }[]; templateInstances?: { baseLabels?: { [key: ...
]: ...
}; contract?: { abi?: ...
; address?: ...
; chainId?: ...
; name?: ...
}; endBlock?: bigint; startBlock?: bigint; templateId?: number; }[]; }, ): ProcessConfigResponse; decode( input: Uint8Array | Reader, length?: number, ): ProcessConfigResponse; encode(message: ProcessConfigResponse, writer?: Writer): Writer; fromJSON(object: any): ProcessConfigResponse; fromPartial( object: { accountConfigs?: { address?: string; chainId?: string; intervalConfigs?: { fetchConfig?: ...
; handlerId?: ...
; minutes?: ...
; minutesInterval?: ...
; slot?: ...
; slotInterval?: ...
; }[]; logConfigs?: { fetchConfig?: ...
; filters?: ...
; handlerId?: ...
; handlerName?: ...
; }[]; moveCallConfigs?: { fetchConfig?: ...
; filters?: ...
; handlerId?: ...
; }[]; moveIntervalConfigs?: { fetchConfig?: ...
; intervalConfig?: ...
; ownerType?: ...
; resourceFetchConfig?: ...
; type?: ...
; }[]; moveResourceChangeConfigs?: { handlerId?: ...
; type?: ...
}[]; startBlock?: bigint; }[]; config?: { name?: string; version?: string }; contractConfigs?: { assetConfigs?: { filters?: ...
; handlerId?: ...
}[]; btcTransactionConfigs?: { filters?: ...
; handlerId?: ...
}[]; contract?: { abi?: (...)
| (...)
; address?: (...)
| (...)
; chainId?: (...)
| (...)
; name?: (...)
| (...)
; }; cosmosLogConfigs?: { handlerId?: ...
; logFilters?: ...
}[]; endBlock?: bigint; fuelCallConfigs?: { filters?: ...
; handlerId?: ...
}[]; fuelLogConfigs?: { handlerId?: ...
; logIds?: ...
}[]; instructionConfig?: { innerInstruction?: (...)
| (...)
| (...)
; parsedInstruction?: (...)
| (...)
| (...)
; rawDataInstruction?: (...)
| (...)
| (...)
; }; intervalConfigs?: { fetchConfig?: ...
; handlerId?: ...
; minutes?: ...
; minutesInterval?: ...
; slot?: ...
; slotInterval?: ...
; }[]; logConfigs?: { fetchConfig?: ...
; filters?: ...
; handlerId?: ...
; handlerName?: ...
; }[]; moveCallConfigs?: { fetchConfig?: ...
; filters?: ...
; handlerId?: ...
; }[]; moveEventConfigs?: { fetchConfig?: ...
; filters?: ...
; handlerId?: ...
; }[]; moveIntervalConfigs?: { fetchConfig?: ...
; intervalConfig?: ...
; ownerType?: ...
; resourceFetchConfig?: ...
; type?: ...
; }[]; moveResourceChangeConfigs?: { handlerId?: ...
; type?: ...
}[]; processorType?: string; starknetEventConfigs?: { filters?: ...
; handlerId?: ...
}[]; startBlock?: bigint; traceConfigs?: { fetchConfig?: ...
; handlerId?: ...
; handlerName?: ...
; signature?: ...
; }[]; transactionConfig?: { fetchConfig?: ...
; handlerId?: ...
}[]; }[]; dbSchema?: { gqlSchema?: string }; eventLogConfigs?: { fields?: { basicType?: ...
; coinType?: ...
; name?: ...
; structType?: ...
; }[]; name?: string; }[]; eventTrackingConfigs?: { distinctAggregationByDays?: number[]; eventName?: string; retentionConfig?: { days?: (...)
| (...)
; retentionEventName?: (...)
| (...)
; }; totalByDay?: boolean; totalPerEntity?: {}; unique?: boolean; }[]; executionConfig?: { forceExactBlockTime?: boolean; processBindingTimeout?: number; rpcRetryTimes?: number; sequential?: boolean; skipStartBlockValidation?: boolean; }; exportConfigs?: { channel?: string; name?: string }[]; metricConfigs?: { aggregationConfig?: { discardOrigin?: (...)
| (...)
| (...)
; intervalInMinutes?: (...)
| (...)
; types?: (...)
| (...)
; }; description?: string; name?: string; persistentBetweenVersion?: boolean; sparse?: boolean; type?: MetricType; unit?: string; }[]; templateInstances?: { baseLabels?: { [key: string]: any }; contract?: { abi?: (...)
| (...)
; address?: (...)
| (...)
; chainId?: (...)
| (...)
; name?: (...)
| (...)
; }; endBlock?: bigint; startBlock?: bigint; templateId?: number; }[]; }, ): ProcessConfigResponse; toJSON(message: ProcessConfigResponse): unknown; }; }; preprocessBindingsStream: { name: "PreprocessBindingsStream"; options: {}; requestStream: true; requestType: { create( base?: { bindings?: { bindings?: { data?: ...
; handlerIds?: ...
; handlerType?: ...
}[]; }; dbResult?: { data?: { [key: string]: any }; entities?: { entities?: (...)
| (...)
}; entityList?: { entities?: (...)
| (...)
}; error?: string; list?: any[]; nextCursor?: string; opId?: bigint; }; processId?: number; }, ): PreprocessStreamRequest; decode( input: Uint8Array | Reader, length?: number, ): PreprocessStreamRequest; encode(message: PreprocessStreamRequest, writer?: Writer): Writer; fromJSON(object: any): PreprocessStreamRequest; fromPartial( object: { bindings?: { bindings?: { data?: (...)
| (...)
; handlerIds?: (...)
| (...)
; handlerType?: (...)
| (...)
; }[]; }; dbResult?: { data?: { [key: string]: any }; entities?: { entities?: (...)
[] }; entityList?: { entities?: (...)
[] }; error?: string; list?: any[]; nextCursor?: string; opId?: bigint; }; processId?: number; }, ): PreprocessStreamRequest; toJSON(message: PreprocessStreamRequest): unknown; }; responseStream: true; responseType: { create( base?: { dbRequest?: { delete?: { entity?: (...)
| (...)
; id?: (...)
| (...)
}; get?: { entity?: (...)
| (...)
; id?: (...)
| (...)
}; list?: { cursor?: (...)
| (...)
; entity?: (...)
| (...)
; filters?: (...)
| (...)
; pageSize?: (...)
| (...)
; }; opId?: bigint; upsert?: { data?: (...)
| (...)
; entity?: (...)
| (...)
; entityData?: (...)
| (...)
; id?: (...)
| (...)
; }; }; processId?: number; }, ): PreprocessStreamResponse; decode( input: Uint8Array | Reader, length?: number, ): PreprocessStreamResponse; encode(message: PreprocessStreamResponse, writer?: Writer): Writer; fromJSON(object: any): PreprocessStreamResponse; fromPartial( object: { dbRequest?: { delete?: { entity?: (...)
[]; id?: (...)
[] }; get?: { entity?: string; id?: string }; list?: { cursor?: string; entity?: string; filters?: (...)
[]; pageSize?: number; }; opId?: bigint; upsert?: { data?: (...)
[]; entity?: (...)
[]; entityData?: (...)
[]; id?: (...)
[]; }; }; processId?: number; }, ): PreprocessStreamResponse; toJSON(message: PreprocessStreamResponse): unknown; }; }; processBindings: { name: "ProcessBindings"; options: {}; requestStream: false; requestType: { create( base?: { bindings?: { data?: { aptCall?: ...
; aptEvent?: ...
; aptResource?: ...
; btcBlock?: ...
; btcTransaction?: ...
; cosmosCall?: ...
; ethBlock?: ...
; ethLog?: ...
; ethTrace?: ...
; ethTransaction?: ...
; fuelBlock?: ...
; fuelCall?: ...
; solInstruction?: ...
; starknetEvents?: ...
; suiCall?: ...
; suiEvent?: ...
; suiObject?: ...
; suiObjectChange?: ...
; }; handlerIds?: (...)
[]; handlerType?: HandlerType; }[]; }, ): ProcessBindingsRequest; decode( input: Uint8Array | Reader, length?: number, ): ProcessBindingsRequest; encode(message: ProcessBindingsRequest, writer?: Writer): Writer; fromJSON(object: any): ProcessBindingsRequest; fromPartial( object: { bindings?: { data?: { aptCall?: (...)
| (...)
; aptEvent?: (...)
| (...)
; aptResource?: (...)
| (...)
; btcBlock?: (...)
| (...)
; btcTransaction?: (...)
| (...)
; cosmosCall?: (...)
| (...)
; ethBlock?: (...)
| (...)
; ethLog?: (...)
| (...)
; ethTrace?: (...)
| (...)
; ethTransaction?: (...)
| (...)
; fuelBlock?: (...)
| (...)
; fuelCall?: (...)
| (...)
; solInstruction?: (...)
| (...)
; starknetEvents?: (...)
| (...)
; suiCall?: (...)
| (...)
; suiEvent?: (...)
| (...)
; suiObject?: (...)
| (...)
; suiObjectChange?: (...)
| (...)
; }; handlerIds?: number[]; handlerType?: HandlerType; }[]; }, ): ProcessBindingsRequest; toJSON(message: ProcessBindingsRequest): unknown; }; responseStream: false; responseType: { create( base?: { result?: { counters?: { add?: ...
; metadata?: ...
; metricValue?: ...
; runtimeInfo?: ...
; }[]; events?: { attributes?: ...
; attributes2?: ...
; distinctEntityId?: ...
; message?: ...
; metadata?: ...
; noMetric?: ...
; runtimeInfo?: ...
; severity?: ...
; }[]; exports?: { metadata?: ...
; payload?: ...
; runtimeInfo?: ...
}[]; gauges?: { metadata?: ...
; metricValue?: ...
; runtimeInfo?: ...
}[]; states?: { configUpdated?: (...)
| (...)
| (...)
; error?: (...)
| (...)
; }; }; }, ): ProcessBindingResponse; decode( input: Uint8Array | Reader, length?: number, ): ProcessBindingResponse; encode(message: ProcessBindingResponse, writer?: Writer): Writer; fromJSON(object: any): ProcessBindingResponse; fromPartial( object: { result?: { counters?: { add?: (...)
| (...)
| (...)
; metadata?: (...)
| (...)
; metricValue?: (...)
| (...)
; runtimeInfo?: (...)
| (...)
; }[]; events?: { attributes?: (...)
| (...)
; attributes2?: (...)
| (...)
; distinctEntityId?: (...)
| (...)
; message?: (...)
| (...)
; metadata?: (...)
| (...)
; noMetric?: (...)
| (...)
| (...)
; runtimeInfo?: (...)
| (...)
; severity?: (...)
| (...)
; }[]; exports?: { metadata?: (...)
| (...)
; payload?: (...)
| (...)
; runtimeInfo?: (...)
| (...)
; }[]; gauges?: { metadata?: (...)
| (...)
; metricValue?: (...)
| (...)
; runtimeInfo?: (...)
| (...)
; }[]; states?: { configUpdated?: boolean; error?: string }; }; }, ): ProcessBindingResponse; toJSON(message: ProcessBindingResponse): unknown; }; }; processBindingsStream: { name: "ProcessBindingsStream"; options: {}; requestStream: true; requestType: { create( base?: { binding?: { data?: { aptCall?: (...)
| (...)
; aptEvent?: (...)
| (...)
; aptResource?: (...)
| (...)
; btcBlock?: (...)
| (...)
; btcTransaction?: (...)
| (...)
; cosmosCall?: (...)
| (...)
; ethBlock?: (...)
| (...)
; ethLog?: (...)
| (...)
; ethTrace?: (...)
| (...)
; ethTransaction?: (...)
| (...)
; fuelBlock?: (...)
| (...)
; fuelCall?: (...)
| (...)
; solInstruction?: (...)
| (...)
; starknetEvents?: (...)
| (...)
; suiCall?: (...)
| (...)
; suiEvent?: (...)
| (...)
; suiObject?: (...)
| (...)
; suiObjectChange?: (...)
| (...)
; }; handlerIds?: number[]; handlerType?: HandlerType; }; dbResult?: { data?: { [key: string]: any }; entities?: { entities?: (...)
| (...)
}; entityList?: { entities?: (...)
| (...)
}; error?: string; list?: any[]; nextCursor?: string; opId?: bigint; }; processId?: number; }, ): ProcessStreamRequest; decode( input: Uint8Array | Reader, length?: number, ): ProcessStreamRequest; encode(message: ProcessStreamRequest, writer?: Writer): Writer; fromJSON(object: any): ProcessStreamRequest; fromPartial( object: { binding?: { data?: { aptCall?: { rawTransaction?: ...
; transaction?: ...
}; aptEvent?: { rawTransaction?: ...
; transaction?: ...
}; aptResource?: { rawResources?: ...
; resources?: ...
; timestampMicros?: ...
; version?: ...
; }; btcBlock?: { block?: ...
; timestamp?: ...
}; btcTransaction?: { timestamp?: ...
; transaction?: ...
}; cosmosCall?: { timestamp?: ...
; transaction?: ...
}; ethBlock?: { block?: ...
}; ethLog?: { block?: ...
; log?: ...
; timestamp?: ...
; transaction?: ...
; transactionReceipt?: ...
; }; ethTrace?: { block?: ...
; timestamp?: ...
; trace?: ...
; transaction?: ...
; transactionReceipt?: ...
; }; ethTransaction?: { block?: ...
; timestamp?: ...
; trace?: ...
; transaction?: ...
; transactionReceipt?: ...
; }; fuelBlock?: { block?: ...
; timestamp?: ...
}; fuelCall?: { timestamp?: ...
; transaction?: ...
}; solInstruction?: { accounts?: ...
; instructionData?: ...
; parsed?: ...
; programAccountId?: ...
; slot?: ...
; }; starknetEvents?: { result?: ...
; timestamp?: ...
}; suiCall?: { slot?: ...
; timestamp?: ...
; transaction?: ...
}; suiEvent?: { slot?: ...
; timestamp?: ...
; transaction?: ...
}; suiObject?: { objectDigest?: ...
; objectId?: ...
; objects?: ...
; objectVersion?: ...
; self?: ...
; slot?: ...
; timestamp?: ...
; }; suiObjectChange?: { changes?: ...
; slot?: ...
; timestamp?: ...
; txDigest?: ...
; }; }; handlerIds?: number[]; handlerType?: HandlerType; }; dbResult?: { data?: { [key: string]: any }; entities?: { entities?: (...)
[] }; entityList?: { entities?: (...)
[] }; error?: string; list?: any[]; nextCursor?: string; opId?: bigint; }; processId?: number; }, ): ProcessStreamRequest; toJSON(message: ProcessStreamRequest): unknown; }; responseStream: true; responseType: { create( base?: { dbRequest?: { delete?: { entity?: (...)
| (...)
; id?: (...)
| (...)
}; get?: { entity?: (...)
| (...)
; id?: (...)
| (...)
}; list?: { cursor?: (...)
| (...)
; entity?: (...)
| (...)
; filters?: (...)
| (...)
; pageSize?: (...)
| (...)
; }; opId?: bigint; upsert?: { data?: (...)
| (...)
; entity?: (...)
| (...)
; entityData?: (...)
| (...)
; id?: (...)
| (...)
; }; }; processId?: number; result?: { counters?: { add?: ...
; metadata?: ...
; metricValue?: ...
; runtimeInfo?: ...
; }[]; events?: { attributes?: ...
; attributes2?: ...
; distinctEntityId?: ...
; message?: ...
; metadata?: ...
; noMetric?: ...
; runtimeInfo?: ...
; severity?: ...
; }[]; exports?: { metadata?: ...
; payload?: ...
; runtimeInfo?: ...
}[]; gauges?: { metadata?: ...
; metricValue?: ...
; runtimeInfo?: ...
}[]; states?: { configUpdated?: (...)
| (...)
| (...)
; error?: (...)
| (...)
; }; }; }, ): ProcessStreamResponse; decode( input: Uint8Array | Reader, length?: number, ): ProcessStreamResponse; encode(message: ProcessStreamResponse, writer?: Writer): Writer; fromJSON(object: any): ProcessStreamResponse; fromPartial( object: { dbRequest?: { delete?: { entity?: (...)
[]; id?: (...)
[] }; get?: { entity?: string; id?: string }; list?: { cursor?: string; entity?: string; filters?: (...)
[]; pageSize?: number; }; opId?: bigint; upsert?: { data?: (...)
[]; entity?: (...)
[]; entityData?: (...)
[]; id?: (...)
[]; }; }; processId?: number; result?: { counters?: { add?: (...)
| (...)
| (...)
; metadata?: (...)
| (...)
; metricValue?: (...)
| (...)
; runtimeInfo?: (...)
| (...)
; }[]; events?: { attributes?: (...)
| (...)
; attributes2?: (...)
| (...)
; distinctEntityId?: (...)
| (...)
; message?: (...)
| (...)
; metadata?: (...)
| (...)
; noMetric?: (...)
| (...)
| (...)
; runtimeInfo?: (...)
| (...)
; severity?: (...)
| (...)
; }[]; exports?: { metadata?: (...)
| (...)
; payload?: (...)
| (...)
; runtimeInfo?: (...)
| (...)
; }[]; gauges?: { metadata?: (...)
| (...)
; metricValue?: (...)
| (...)
; runtimeInfo?: (...)
| (...)
; }[]; states?: { configUpdated?: boolean; error?: string }; }; }, ): ProcessStreamResponse; toJSON(message: ProcessStreamResponse): unknown; }; }; start: { name: "Start"; options: {}; requestStream: false; requestType: { create( base?: { templateInstances?: { baseLabels?: { [key: ...
]: ...
}; contract?: { abi?: ...
; address?: ...
; chainId?: ...
; name?: ...
}; endBlock?: bigint; startBlock?: bigint; templateId?: number; }[]; }, ): StartRequest; decode(input: Uint8Array | Reader, length?: number): StartRequest; encode(message: StartRequest, writer?: Writer): Writer; fromJSON(object: any): StartRequest; fromPartial( object: { templateInstances?: { baseLabels?: { [key: string]: any }; contract?: { abi?: (...)
| (...)
; address?: (...)
| (...)
; chainId?: (...)
| (...)
; name?: (...)
| (...)
; }; endBlock?: bigint; startBlock?: bigint; templateId?: number; }[]; }, ): StartRequest; toJSON(message: StartRequest): unknown; }; responseStream: false; responseType: { create(base?: {}): Empty; decode(input: Uint8Array | Reader, length?: number): Empty; encode(_: Empty, writer?: Writer): Writer; fromJSON(_: any): Empty; fromPartial(_: {}): Empty; toJSON(_: Empty): unknown; }; }; stop: { name: "Stop"; options: {}; requestStream: false; requestType: { create(base?: {}): Empty; decode(input: Uint8Array | Reader, length?: number): Empty; encode(_: Empty, writer?: Writer): Writer; fromJSON(_: any): Empty; fromPartial(_: {}): Empty; toJSON(_: Empty): unknown; }; responseStream: false; responseType: { create(base?: {}): Empty; decode(input: Uint8Array | Reader, length?: number): Empty; encode(_: Empty, writer?: Writer): Writer; fromJSON(_: any): Empty; fromPartial(_: {}): Empty; toJSON(_: Empty): unknown; }; }; }; name: "Processor";}