Interface ProcessorClient<CallOptionsExt>
interface ProcessorClient<CallOptionsExt = {}> { getConfig( request: {}, options?: CallOptions & CallOptionsExt, ): Promise<ProcessConfigResponse>; preprocessBindingsStream( request: AsyncIterable< { bindings?: { bindings?: { 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?: { fields?: { [key: ...
]: ...
} }[] }; entityList?: { entities?: { data?: { fields?: ...
}; entity?: string; genBlockChain?: string; genBlockNumber?: bigint; genBlockTime?: Date; }[]; }; error?: string; list?: any[]; nextCursor?: string; opId?: bigint; }; processId?: number; }, >, options?: CallOptions & CallOptionsExt, ): AsyncIterable<PreprocessStreamResponse>; processBindings( request: { bindings?: { data?: { aptCall?: { rawTransaction?: string; transaction?: { [key: string]: any }; }; aptEvent?: { rawTransaction?: string; transaction?: { [key: string]: any }; }; aptResource?: { rawResources?: string[]; resources?: { [key: ...
]: ...
}[]; timestampMicros?: bigint; version?: bigint; }; btcBlock?: { block?: { [key: string]: any }; timestamp?: Date }; btcTransaction?: { timestamp?: Date; transaction?: { [key: string]: any }; }; cosmosCall?: { timestamp?: Date; transaction?: { [key: string]: any } }; ethBlock?: { block?: { [key: string]: any } }; ethLog?: { block?: { [key: string]: any }; log?: { [key: string]: any }; timestamp?: Date; transaction?: { [key: string]: any }; transactionReceipt?: { [key: string]: any }; }; ethTrace?: { block?: { [key: string]: any }; timestamp?: Date; trace?: { [key: string]: any }; transaction?: { [key: string]: any }; transactionReceipt?: { [key: string]: any }; }; ethTransaction?: { block?: { [key: string]: any }; timestamp?: Date; trace?: { [key: string]: any }; transaction?: { [key: string]: any }; transactionReceipt?: { [key: string]: any }; }; fuelBlock?: { block?: { [key: string]: any }; timestamp?: Date }; fuelCall?: { timestamp?: Date; transaction?: { [key: string]: any } }; solInstruction?: { accounts?: string[]; instructionData?: string; parsed?: { [key: string]: any }; programAccountId?: string; slot?: bigint; }; starknetEvents?: { result?: { [key: string]: any }; timestamp?: Date }; suiCall?: { slot?: bigint; timestamp?: Date; transaction?: { [key: string]: any }; }; suiEvent?: { slot?: bigint; timestamp?: Date; transaction?: { [key: string]: any }; }; suiObject?: { objectDigest?: string; objectId?: string; objects?: { [key: ...
]: ...
}[]; objectVersion?: bigint; self?: { [key: string]: any }; slot?: bigint; timestamp?: Date; }; suiObjectChange?: { changes?: { [key: ...
]: ...
}[]; slot?: bigint; timestamp?: Date; txDigest?: string; }; }; handlerIds?: number[]; handlerType?: HandlerType; }[]; }, options?: CallOptions & CallOptionsExt, ): Promise<ProcessBindingResponse>; processBindingsStream( request: AsyncIterable< { binding?: { data?: { aptCall?: { rawTransaction?: string; transaction?: { [key: string]: any }; }; aptEvent?: { rawTransaction?: string; transaction?: { [key: string]: any }; }; aptResource?: { rawResources?: string[]; resources?: { [key: ...
]: ...
}[]; timestampMicros?: bigint; version?: bigint; }; btcBlock?: { block?: { [key: string]: any }; timestamp?: Date }; btcTransaction?: { timestamp?: Date; transaction?: { [key: string]: any }; }; cosmosCall?: { timestamp?: Date; transaction?: { [key: string]: any }; }; ethBlock?: { block?: { [key: string]: any } }; ethLog?: { block?: { [key: string]: any }; log?: { [key: string]: any }; timestamp?: Date; transaction?: { [key: string]: any }; transactionReceipt?: { [key: string]: any }; }; ethTrace?: { block?: { [key: string]: any }; timestamp?: Date; trace?: { [key: string]: any }; transaction?: { [key: string]: any }; transactionReceipt?: { [key: string]: any }; }; ethTransaction?: { block?: { [key: string]: any }; timestamp?: Date; trace?: { [key: string]: any }; transaction?: { [key: string]: any }; transactionReceipt?: { [key: string]: any }; }; fuelBlock?: { block?: { [key: string]: any }; timestamp?: Date }; fuelCall?: { timestamp?: Date; transaction?: { [key: string]: any } }; solInstruction?: { accounts?: string[]; instructionData?: string; parsed?: { [key: string]: any }; programAccountId?: string; slot?: bigint; }; starknetEvents?: { result?: { [key: string]: any }; timestamp?: Date }; suiCall?: { slot?: bigint; timestamp?: Date; transaction?: { [key: string]: any }; }; suiEvent?: { slot?: bigint; timestamp?: Date; transaction?: { [key: string]: any }; }; suiObject?: { objectDigest?: string; objectId?: string; objects?: { [key: ...
]: ...
}[]; objectVersion?: bigint; self?: { [key: string]: any }; slot?: bigint; timestamp?: Date; }; suiObjectChange?: { changes?: { [key: ...
]: ...
}[]; slot?: bigint; timestamp?: Date; txDigest?: string; }; }; handlerIds?: number[]; handlerType?: HandlerType; }; dbResult?: { data?: { [key: string]: any }; entities?: { entities?: { fields?: { [key: ...
]: ...
} }[] }; entityList?: { entities?: { data?: { fields?: ...
}; entity?: string; genBlockChain?: string; genBlockNumber?: bigint; genBlockTime?: Date; }[]; }; error?: string; list?: any[]; nextCursor?: string; opId?: bigint; }; processId?: number; }, >, options?: CallOptions & CallOptionsExt, ): AsyncIterable<ProcessStreamResponse>; start( request: { templateInstances?: { baseLabels?: { [key: string]: any }; contract?: { abi?: string; address?: string; chainId?: string; name?: string; }; endBlock?: bigint; startBlock?: bigint; templateId?: number; }[]; }, options?: CallOptions & CallOptionsExt, ): Promise<Empty>; stop(request: {}, options?: CallOptions & CallOptionsExt): Promise<Empty>;} Methods
preprocessBindingsStream
- preprocessBindingsStream(
request: AsyncIterable<
{
bindings?: {
bindings?: {
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?: { fields?: { [key: ...]: ... } }[] };
entityList?: {
entities?: {
data?: { fields?: ... };
entity?: string;
genBlockChain?: string;
genBlockNumber?: bigint;
genBlockTime?: Date;
}[];
};
error?: string;
list?: any[];
nextCursor?: string;
opId?: bigint;
};
processId?: number;
},
>,
options?: CallOptions & CallOptionsExt,
): AsyncIterable<PreprocessStreamResponse> Parameters
- request: AsyncIterable<
{
bindings?: {
bindings?: {
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?: { fields?: { [key: ...]: ... } }[] };
entityList?: {
entities?: {
data?: { fields?: ... };
entity?: string;
genBlockChain?: string;
genBlockNumber?: bigint;
genBlockTime?: Date;
}[];
};
error?: string;
list?: any[];
nextCursor?: string;
opId?: bigint;
};
processId?: number;
},
> Optional
options: CallOptions & CallOptionsExt
processBindings
- processBindings(
request: {
bindings?: {
data?: {
aptCall?: {
rawTransaction?: string;
transaction?: { [key: string]: any };
};
aptEvent?: {
rawTransaction?: string;
transaction?: { [key: string]: any };
};
aptResource?: {
rawResources?: string[];
resources?: { [key: ...]: ... }[];
timestampMicros?: bigint;
version?: bigint;
};
btcBlock?: { block?: { [key: string]: any }; timestamp?: Date };
btcTransaction?: {
timestamp?: Date;
transaction?: { [key: string]: any };
};
cosmosCall?: { timestamp?: Date; transaction?: { [key: string]: any } };
ethBlock?: { block?: { [key: string]: any } };
ethLog?: {
block?: { [key: string]: any };
log?: { [key: string]: any };
timestamp?: Date;
transaction?: { [key: string]: any };
transactionReceipt?: { [key: string]: any };
};
ethTrace?: {
block?: { [key: string]: any };
timestamp?: Date;
trace?: { [key: string]: any };
transaction?: { [key: string]: any };
transactionReceipt?: { [key: string]: any };
};
ethTransaction?: {
block?: { [key: string]: any };
timestamp?: Date;
trace?: { [key: string]: any };
transaction?: { [key: string]: any };
transactionReceipt?: { [key: string]: any };
};
fuelBlock?: { block?: { [key: string]: any }; timestamp?: Date };
fuelCall?: { timestamp?: Date; transaction?: { [key: string]: any } };
solInstruction?: {
accounts?: string[];
instructionData?: string;
parsed?: { [key: string]: any };
programAccountId?: string;
slot?: bigint;
};
starknetEvents?: { result?: { [key: string]: any }; timestamp?: Date };
suiCall?: {
slot?: bigint;
timestamp?: Date;
transaction?: { [key: string]: any };
};
suiEvent?: {
slot?: bigint;
timestamp?: Date;
transaction?: { [key: string]: any };
};
suiObject?: {
objectDigest?: string;
objectId?: string;
objects?: { [key: ...]: ... }[];
objectVersion?: bigint;
self?: { [key: string]: any };
slot?: bigint;
timestamp?: Date;
};
suiObjectChange?: {
changes?: { [key: ...]: ... }[];
slot?: bigint;
timestamp?: Date;
txDigest?: string;
};
};
handlerIds?: number[];
handlerType?: HandlerType;
}[];
},
options?: CallOptions & CallOptionsExt,
): Promise<ProcessBindingResponse> Parameters
- request: {
bindings?: {
data?: {
aptCall?: {
rawTransaction?: string;
transaction?: { [key: string]: any };
};
aptEvent?: {
rawTransaction?: string;
transaction?: { [key: string]: any };
};
aptResource?: {
rawResources?: string[];
resources?: { [key: ...]: ... }[];
timestampMicros?: bigint;
version?: bigint;
};
btcBlock?: { block?: { [key: string]: any }; timestamp?: Date };
btcTransaction?: {
timestamp?: Date;
transaction?: { [key: string]: any };
};
cosmosCall?: { timestamp?: Date; transaction?: { [key: string]: any } };
ethBlock?: { block?: { [key: string]: any } };
ethLog?: {
block?: { [key: string]: any };
log?: { [key: string]: any };
timestamp?: Date;
transaction?: { [key: string]: any };
transactionReceipt?: { [key: string]: any };
};
ethTrace?: {
block?: { [key: string]: any };
timestamp?: Date;
trace?: { [key: string]: any };
transaction?: { [key: string]: any };
transactionReceipt?: { [key: string]: any };
};
ethTransaction?: {
block?: { [key: string]: any };
timestamp?: Date;
trace?: { [key: string]: any };
transaction?: { [key: string]: any };
transactionReceipt?: { [key: string]: any };
};
fuelBlock?: { block?: { [key: string]: any }; timestamp?: Date };
fuelCall?: { timestamp?: Date; transaction?: { [key: string]: any } };
solInstruction?: {
accounts?: string[];
instructionData?: string;
parsed?: { [key: string]: any };
programAccountId?: string;
slot?: bigint;
};
starknetEvents?: { result?: { [key: string]: any }; timestamp?: Date };
suiCall?: {
slot?: bigint;
timestamp?: Date;
transaction?: { [key: string]: any };
};
suiEvent?: {
slot?: bigint;
timestamp?: Date;
transaction?: { [key: string]: any };
};
suiObject?: {
objectDigest?: string;
objectId?: string;
objects?: { [key: ...]: ... }[];
objectVersion?: bigint;
self?: { [key: string]: any };
slot?: bigint;
timestamp?: Date;
};
suiObjectChange?: {
changes?: { [key: ...]: ... }[];
slot?: bigint;
timestamp?: Date;
txDigest?: string;
};
};
handlerIds?: number[];
handlerType?: HandlerType;
}[];
} Optional
options: CallOptions & CallOptionsExt
processBindingsStream
- processBindingsStream(
request: AsyncIterable<
{
binding?: {
data?: {
aptCall?: {
rawTransaction?: string;
transaction?: { [key: string]: any };
};
aptEvent?: {
rawTransaction?: string;
transaction?: { [key: string]: any };
};
aptResource?: {
rawResources?: string[];
resources?: { [key: ...]: ... }[];
timestampMicros?: bigint;
version?: bigint;
};
btcBlock?: { block?: { [key: string]: any }; timestamp?: Date };
btcTransaction?: {
timestamp?: Date;
transaction?: { [key: string]: any };
};
cosmosCall?: { timestamp?: Date; transaction?: { [key: string]: any } };
ethBlock?: { block?: { [key: string]: any } };
ethLog?: {
block?: { [key: string]: any };
log?: { [key: string]: any };
timestamp?: Date;
transaction?: { [key: string]: any };
transactionReceipt?: { [key: string]: any };
};
ethTrace?: {
block?: { [key: string]: any };
timestamp?: Date;
trace?: { [key: string]: any };
transaction?: { [key: string]: any };
transactionReceipt?: { [key: string]: any };
};
ethTransaction?: {
block?: { [key: string]: any };
timestamp?: Date;
trace?: { [key: string]: any };
transaction?: { [key: string]: any };
transactionReceipt?: { [key: string]: any };
};
fuelBlock?: { block?: { [key: string]: any }; timestamp?: Date };
fuelCall?: { timestamp?: Date; transaction?: { [key: string]: any } };
solInstruction?: {
accounts?: string[];
instructionData?: string;
parsed?: { [key: string]: any };
programAccountId?: string;
slot?: bigint;
};
starknetEvents?: { result?: { [key: string]: any }; timestamp?: Date };
suiCall?: {
slot?: bigint;
timestamp?: Date;
transaction?: { [key: string]: any };
};
suiEvent?: {
slot?: bigint;
timestamp?: Date;
transaction?: { [key: string]: any };
};
suiObject?: {
objectDigest?: string;
objectId?: string;
objects?: { [key: ...]: ... }[];
objectVersion?: bigint;
self?: { [key: string]: any };
slot?: bigint;
timestamp?: Date;
};
suiObjectChange?: {
changes?: { [key: ...]: ... }[];
slot?: bigint;
timestamp?: Date;
txDigest?: string;
};
};
handlerIds?: number[];
handlerType?: HandlerType;
};
dbResult?: {
data?: { [key: string]: any };
entities?: { entities?: { fields?: { [key: ...]: ... } }[] };
entityList?: {
entities?: {
data?: { fields?: ... };
entity?: string;
genBlockChain?: string;
genBlockNumber?: bigint;
genBlockTime?: Date;
}[];
};
error?: string;
list?: any[];
nextCursor?: string;
opId?: bigint;
};
processId?: number;
},
>,
options?: CallOptions & CallOptionsExt,
): AsyncIterable<ProcessStreamResponse> Parameters
- request: AsyncIterable<
{
binding?: {
data?: {
aptCall?: {
rawTransaction?: string;
transaction?: { [key: string]: any };
};
aptEvent?: {
rawTransaction?: string;
transaction?: { [key: string]: any };
};
aptResource?: {
rawResources?: string[];
resources?: { [key: ...]: ... }[];
timestampMicros?: bigint;
version?: bigint;
};
btcBlock?: { block?: { [key: string]: any }; timestamp?: Date };
btcTransaction?: {
timestamp?: Date;
transaction?: { [key: string]: any };
};
cosmosCall?: { timestamp?: Date; transaction?: { [key: string]: any } };
ethBlock?: { block?: { [key: string]: any } };
ethLog?: {
block?: { [key: string]: any };
log?: { [key: string]: any };
timestamp?: Date;
transaction?: { [key: string]: any };
transactionReceipt?: { [key: string]: any };
};
ethTrace?: {
block?: { [key: string]: any };
timestamp?: Date;
trace?: { [key: string]: any };
transaction?: { [key: string]: any };
transactionReceipt?: { [key: string]: any };
};
ethTransaction?: {
block?: { [key: string]: any };
timestamp?: Date;
trace?: { [key: string]: any };
transaction?: { [key: string]: any };
transactionReceipt?: { [key: string]: any };
};
fuelBlock?: { block?: { [key: string]: any }; timestamp?: Date };
fuelCall?: { timestamp?: Date; transaction?: { [key: string]: any } };
solInstruction?: {
accounts?: string[];
instructionData?: string;
parsed?: { [key: string]: any };
programAccountId?: string;
slot?: bigint;
};
starknetEvents?: { result?: { [key: string]: any }; timestamp?: Date };
suiCall?: {
slot?: bigint;
timestamp?: Date;
transaction?: { [key: string]: any };
};
suiEvent?: {
slot?: bigint;
timestamp?: Date;
transaction?: { [key: string]: any };
};
suiObject?: {
objectDigest?: string;
objectId?: string;
objects?: { [key: ...]: ... }[];
objectVersion?: bigint;
self?: { [key: string]: any };
slot?: bigint;
timestamp?: Date;
};
suiObjectChange?: {
changes?: { [key: ...]: ... }[];
slot?: bigint;
timestamp?: Date;
txDigest?: string;
};
};
handlerIds?: number[];
handlerType?: HandlerType;
};
dbResult?: {
data?: { [key: string]: any };
entities?: { entities?: { fields?: { [key: ...]: ... } }[] };
entityList?: {
entities?: {
data?: { fields?: ... };
entity?: string;
genBlockChain?: string;
genBlockNumber?: bigint;
genBlockTime?: Date;
}[];
};
error?: string;
list?: any[];
nextCursor?: string;
opId?: bigint;
};
processId?: number;
},
> Optional
options: CallOptions & CallOptionsExt
start
- start(
request: {
templateInstances?: {
baseLabels?: { [key: string]: any };
contract?: {
abi?: string;
address?: string;
chainId?: string;
name?: string;
};
endBlock?: bigint;
startBlock?: bigint;
templateId?: number;
}[];
},
options?: CallOptions & CallOptionsExt,
): Promise<Empty> Parameters
- request: {
templateInstances?: {
baseLabels?: { [key: string]: any };
contract?: {
abi?: string;
address?: string;
chainId?: string;
name?: string;
};
endBlock?: bigint;
startBlock?: bigint;
templateId?: number;
}[];
} Optional
options: CallOptions & CallOptionsExt
Returns Promise<Empty>
stop
- stop(request: {}, options?: CallOptions & CallOptionsExt): Promise<Empty>
Returns Promise<Empty>