@sentio/sdk
Preparing search index...
.
ProcessorDefinition
Variable ProcessorDefinition
ProcessorDefinition
:
{
fullName
:
"processor.Processor"
;
methods
:
{
getConfig
:
{
name
:
"GetConfig"
;
options
:
{}
;
requestStream
:
false
;
requestType
:
{
create
(
base
?:
{}
)
:
ProcessConfigRequest
;
decode
(
input
:
Uint8Array
<
ArrayBufferLike
>
|
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
;
endBlock
?:
bigint
;
intervalConfigs
?:
(...)
[]
;
logConfigs
?:
(...)
[]
;
moveCallConfigs
?:
(...)
[]
;
moveIntervalConfigs
?:
(...)
[]
;
moveResourceChangeConfigs
?:
(...)
[]
;
startBlock
?:
bigint
;
}
[]
;
config
?:
{
name
?:
string
;
version
?:
string
}
;
contractConfigs
?:
{
assetConfigs
?:
(...)
[]
;
contract
?:
{
abi
?:
...
;
address
?:
...
;
chainId
?:
...
;
name
?:
...
}
;
cosmosLogConfigs
?:
(...)
[]
;
endBlock
?:
bigint
;
fuelReceiptConfigs
?:
(...)
[]
;
fuelTransactionConfigs
?:
(...)
[]
;
instructionConfig
?:
{
innerInstruction
?:
...
;
parsedInstruction
?:
...
;
rawDataInstruction
?:
...
;
}
;
intervalConfigs
?:
(...)
[]
;
logConfigs
?:
(...)
[]
;
moveCallConfigs
?:
(...)
[]
;
moveEventConfigs
?:
(...)
[]
;
moveIntervalConfigs
?:
(...)
[]
;
moveResourceChangeConfigs
?:
(...)
[]
;
processorType
?:
string
;
starknetEventConfigs
?:
(...)
[]
;
startBlock
?:
bigint
;
traceConfigs
?:
(...)
[]
;
transactionConfig
?:
(...)
[]
;
}
[]
;
dbSchema
?:
{
gqlSchema
?:
string
}
;
eventLogConfigs
?:
{
fields
?:
(...)
[]
;
name
?:
string
}
[]
;
executionConfig
?:
{
ethAbiDecoderConfig
?:
{
enabled
?:
(...)
|
(...)
|
(...)
;
skipWhenDecodeFailed
?:
(...)
|
(...)
|
(...)
;
workerCount
?:
(...)
|
(...)
;
}
;
forceExactBlockTime
?:
boolean
;
handlerOrderInsideTransaction
?:
ExecutionConfig_HandlerOrderInsideTransaction
;
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
<
ArrayBufferLike
>
|
Reader
,
length
?:
number
,
)
:
ProcessConfigResponse
;
encode
(
message
:
ProcessConfigResponse
,
writer
?:
Writer
)
:
Writer
;
fromJSON
(
object
:
any
)
:
ProcessConfigResponse
;
fromPartial
(
object
:
{
accountConfigs
?:
{
address
?:
string
;
chainId
?:
string
;
endBlock
?:
bigint
;
intervalConfigs
?:
{
fetchConfig
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
minutes
?:
...
;
minutesInterval
?:
...
;
slot
?:
...
;
slotInterval
?:
...
;
}
[]
;
logConfigs
?:
{
fetchConfig
?:
...
;
filters
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
moveCallConfigs
?:
{
fetchConfig
?:
...
;
filters
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
moveIntervalConfigs
?:
{
fetchConfig
?:
...
;
intervalConfig
?:
...
;
ownerType
?:
...
;
resourceFetchConfig
?:
...
;
type
?:
...
;
}
[]
;
moveResourceChangeConfigs
?:
{
handlerId
?:
...
;
handlerName
?:
...
;
includeDeleted
?:
...
;
type
?:
...
;
}
[]
;
startBlock
?:
bigint
;
}
[]
;
config
?:
{
name
?:
string
;
version
?:
string
}
;
contractConfigs
?:
{
assetConfigs
?:
{
filters
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
contract
?:
{
abi
?:
(...)
|
(...)
;
address
?:
(...)
|
(...)
;
chainId
?:
(...)
|
(...)
;
name
?:
(...)
|
(...)
;
}
;
cosmosLogConfigs
?:
{
handlerId
?:
...
;
handlerName
?:
...
;
logFilters
?:
...
;
}
[]
;
endBlock
?:
bigint
;
fuelReceiptConfigs
?:
{
handlerId
?:
...
;
handlerName
?:
...
;
log
?:
...
;
transfer
?:
...
;
}
[]
;
fuelTransactionConfigs
?:
{
handlerId
?:
...
;
handlerName
?:
...
}
[]
;
instructionConfig
?:
{
innerInstruction
?:
(...)
|
(...)
|
(...)
;
parsedInstruction
?:
(...)
|
(...)
|
(...)
;
rawDataInstruction
?:
(...)
|
(...)
|
(...)
;
}
;
intervalConfigs
?:
{
fetchConfig
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
minutes
?:
...
;
minutesInterval
?:
...
;
slot
?:
...
;
slotInterval
?:
...
;
}
[]
;
logConfigs
?:
{
fetchConfig
?:
...
;
filters
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
moveCallConfigs
?:
{
fetchConfig
?:
...
;
filters
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
moveEventConfigs
?:
{
fetchConfig
?:
...
;
filters
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
moveIntervalConfigs
?:
{
fetchConfig
?:
...
;
intervalConfig
?:
...
;
ownerType
?:
...
;
resourceFetchConfig
?:
...
;
type
?:
...
;
}
[]
;
moveResourceChangeConfigs
?:
{
handlerId
?:
...
;
handlerName
?:
...
;
includeDeleted
?:
...
;
type
?:
...
;
}
[]
;
processorType
?:
string
;
starknetEventConfigs
?:
{
filters
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
startBlock
?:
bigint
;
traceConfigs
?:
{
fetchConfig
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
signature
?:
...
;
}
[]
;
transactionConfig
?:
{
fetchConfig
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
}
[]
;
dbSchema
?:
{
gqlSchema
?:
string
}
;
eventLogConfigs
?:
{
fields
?:
{
basicType
?:
...
;
coinType
?:
...
;
name
?:
...
;
structType
?:
...
;
}
[]
;
name
?:
string
;
}
[]
;
executionConfig
?:
{
ethAbiDecoderConfig
?:
{
enabled
?:
boolean
;
skipWhenDecodeFailed
?:
boolean
;
workerCount
?:
number
;
}
;
forceExactBlockTime
?:
boolean
;
handlerOrderInsideTransaction
?:
ExecutionConfig_HandlerOrderInsideTransaction
;
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
?:
{
chainId
?:
...
;
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
<
ArrayBufferLike
>
|
Reader
,
length
?:
number
,
)
:
PreprocessStreamRequest
;
encode
(
message
:
PreprocessStreamRequest
,
writer
?:
Writer
)
:
Writer
;
fromJSON
(
object
:
any
)
:
PreprocessStreamRequest
;
fromPartial
(
object
:
{
bindings
?:
{
bindings
?:
{
chainId
?:
(...)
|
(...)
;
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
;
update
?:
{
entity
?:
(...)
|
(...)
;
entityData
?:
(...)
|
(...)
;
id
?:
(...)
|
(...)
;
}
;
upsert
?:
{
data
?:
(...)
|
(...)
;
entity
?:
(...)
|
(...)
;
entityData
?:
(...)
|
(...)
;
id
?:
(...)
|
(...)
;
}
;
}
;
processId
?:
number
;
}
,
)
:
PreprocessStreamResponse
;
decode
(
input
:
Uint8Array
<
ArrayBufferLike
>
|
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
;
update
?:
{
entity
?:
(...)
[]
;
entityData
?:
(...)
[]
;
id
?:
(...)
[]
}
;
upsert
?:
{
data
?:
(...)
[]
;
entity
?:
(...)
[]
;
entityData
?:
(...)
[]
;
id
?:
(...)
[]
;
}
;
}
;
processId
?:
number
;
}
,
)
:
PreprocessStreamResponse
;
toJSON
(
message
:
PreprocessStreamResponse
)
:
unknown
;
}
;
}
;
processBindings
:
{
name
:
"ProcessBindings"
;
options
:
{}
;
requestStream
:
false
;
requestType
:
{
create
(
base
?:
{
bindings
?:
{
chainId
?:
string
;
data
?:
{
aptCall
?:
...
;
aptEvent
?:
...
;
aptResource
?:
...
;
cosmosCall
?:
...
;
ethBlock
?:
...
;
ethLog
?:
...
;
ethTrace
?:
...
;
ethTransaction
?:
...
;
fuelBlock
?:
...
;
fuelLog
?:
...
;
fuelTransaction
?:
...
;
solInstruction
?:
...
;
starknetEvents
?:
...
;
suiCall
?:
...
;
suiEvent
?:
...
;
suiObject
?:
...
;
suiObjectChange
?:
...
;
}
;
handlerIds
?:
(...)
[]
;
handlerType
?:
HandlerType
;
}
[]
;
}
,
)
:
ProcessBindingsRequest
;
decode
(
input
:
Uint8Array
<
ArrayBufferLike
>
|
Reader
,
length
?:
number
,
)
:
ProcessBindingsRequest
;
encode
(
message
:
ProcessBindingsRequest
,
writer
?:
Writer
)
:
Writer
;
fromJSON
(
object
:
any
)
:
ProcessBindingsRequest
;
fromPartial
(
object
:
{
bindings
?:
{
chainId
?:
string
;
data
?:
{
aptCall
?:
(...)
|
(...)
;
aptEvent
?:
(...)
|
(...)
;
aptResource
?:
(...)
|
(...)
;
cosmosCall
?:
(...)
|
(...)
;
ethBlock
?:
(...)
|
(...)
;
ethLog
?:
(...)
|
(...)
;
ethTrace
?:
(...)
|
(...)
;
ethTransaction
?:
(...)
|
(...)
;
fuelBlock
?:
(...)
|
(...)
;
fuelLog
?:
(...)
|
(...)
;
fuelTransaction
?:
(...)
|
(...)
;
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
?:
(...)
|
(...)
;
}
;
timeseriesResult
?:
{
data
?:
...
;
metadata
?:
...
;
runtimeInfo
?:
...
;
type
?:
...
;
}
[]
;
}
;
}
,
)
:
ProcessBindingResponse
;
decode
(
input
:
Uint8Array
<
ArrayBufferLike
>
|
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
}
;
timeseriesResult
?:
{
data
?:
(...)
|
(...)
;
metadata
?:
(...)
|
(...)
;
runtimeInfo
?:
(...)
|
(...)
;
type
?:
(...)
|
(...)
;
}
[]
;
}
;
}
,
)
:
ProcessBindingResponse
;
toJSON
(
message
:
ProcessBindingResponse
)
:
unknown
;
}
;
}
;
processBindingsStream
:
{
name
:
"ProcessBindingsStream"
;
options
:
{}
;
requestStream
:
true
;
requestType
:
{
create
(
base
?:
{
binding
?:
{
chainId
?:
string
;
data
?:
{
aptCall
?:
(...)
|
(...)
;
aptEvent
?:
(...)
|
(...)
;
aptResource
?:
(...)
|
(...)
;
cosmosCall
?:
(...)
|
(...)
;
ethBlock
?:
(...)
|
(...)
;
ethLog
?:
(...)
|
(...)
;
ethTrace
?:
(...)
|
(...)
;
ethTransaction
?:
(...)
|
(...)
;
fuelBlock
?:
(...)
|
(...)
;
fuelLog
?:
(...)
|
(...)
;
fuelTransaction
?:
(...)
|
(...)
;
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
;
start
?:
boolean
;
}
,
)
:
ProcessStreamRequest
;
decode
(
input
:
Uint8Array
<
ArrayBufferLike
>
|
Reader
,
length
?:
number
,
)
:
ProcessStreamRequest
;
encode
(
message
:
ProcessStreamRequest
,
writer
?:
Writer
)
:
Writer
;
fromJSON
(
object
:
any
)
:
ProcessStreamRequest
;
fromPartial
(
object
:
{
binding
?:
{
chainId
?:
string
;
data
?:
{
aptCall
?:
{
rawTransaction
?:
...
}
;
aptEvent
?:
{
eventIndex
?:
...
;
rawEvent
?:
...
;
rawTransaction
?:
...
;
}
;
aptResource
?:
{
rawResources
?:
...
;
timestampMicros
?:
...
;
version
?:
...
;
}
;
cosmosCall
?:
{
timestamp
?:
...
;
transaction
?:
...
}
;
ethBlock
?:
{
block
?:
...
}
;
ethLog
?:
{
block
?:
...
;
log
?:
...
;
rawBlock
?:
...
;
rawLog
?:
...
;
rawTransaction
?:
...
;
rawTransactionReceipt
?:
...
;
timestamp
?:
...
;
transaction
?:
...
;
transactionReceipt
?:
...
;
}
;
ethTrace
?:
{
block
?:
...
;
timestamp
?:
...
;
trace
?:
...
;
transaction
?:
...
;
transactionReceipt
?:
...
;
}
;
ethTransaction
?:
{
block
?:
...
;
rawBlock
?:
...
;
rawTrace
?:
...
;
rawTransaction
?:
...
;
rawTransactionReceipt
?:
...
;
timestamp
?:
...
;
trace
?:
...
;
transaction
?:
...
;
transactionReceipt
?:
...
;
}
;
fuelBlock
?:
{
block
?:
...
;
timestamp
?:
...
}
;
fuelLog
?:
{
receiptIndex
?:
...
;
timestamp
?:
...
;
transaction
?:
...
}
;
fuelTransaction
?:
{
timestamp
?:
...
;
transaction
?:
...
}
;
solInstruction
?:
{
accounts
?:
...
;
instructionData
?:
...
;
parsed
?:
...
;
programAccountId
?:
...
;
slot
?:
...
;
}
;
starknetEvents
?:
{
result
?:
...
;
timestamp
?:
...
}
;
suiCall
?:
{
rawTransaction
?:
...
;
slot
?:
...
;
timestamp
?:
...
}
;
suiEvent
?:
{
rawEvent
?:
...
;
rawTransaction
?:
...
;
slot
?:
...
;
timestamp
?:
...
;
}
;
suiObject
?:
{
objectDigest
?:
...
;
objectId
?:
...
;
objectVersion
?:
...
;
rawObjects
?:
...
;
rawSelf
?:
...
;
slot
?:
...
;
timestamp
?:
...
;
}
;
suiObjectChange
?:
{
rawChanges
?:
...
;
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
;
start
?:
boolean
;
}
,
)
:
ProcessStreamRequest
;
toJSON
(
message
:
ProcessStreamRequest
)
:
unknown
;
}
;
responseStream
:
true
;
responseType
:
{
create
(
base
?:
{
dbRequest
?:
{
delete
?:
{
entity
?:
(...)
|
(...)
;
id
?:
(...)
|
(...)
}
;
get
?:
{
entity
?:
(...)
|
(...)
;
id
?:
(...)
|
(...)
}
;
list
?:
{
cursor
?:
(...)
|
(...)
;
entity
?:
(...)
|
(...)
;
filters
?:
(...)
|
(...)
;
pageSize
?:
(...)
|
(...)
;
}
;
opId
?:
bigint
;
update
?:
{
entity
?:
(...)
|
(...)
;
entityData
?:
(...)
|
(...)
;
id
?:
(...)
|
(...)
;
}
;
upsert
?:
{
data
?:
(...)
|
(...)
;
entity
?:
(...)
|
(...)
;
entityData
?:
(...)
|
(...)
;
id
?:
(...)
|
(...)
;
}
;
}
;
partitions
?:
{
partitions
?:
{
[
key
:
number
]:
(...)
|
(...)
}
}
;
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
?:
(...)
|
(...)
;
}
;
timeseriesResult
?:
{
data
?:
...
;
metadata
?:
...
;
runtimeInfo
?:
...
;
type
?:
...
;
}
[]
;
}
;
}
,
)
:
ProcessStreamResponse
;
decode
(
input
:
Uint8Array
<
ArrayBufferLike
>
|
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
;
update
?:
{
entity
?:
(...)
[]
;
entityData
?:
(...)
[]
;
id
?:
(...)
[]
}
;
upsert
?:
{
data
?:
(...)
[]
;
entity
?:
(...)
[]
;
entityData
?:
(...)
[]
;
id
?:
(...)
[]
;
}
;
}
;
partitions
?:
{
partitions
?:
{
[
key
:
number
]:
undefined
|
{
sysValue
?:
...
;
userValue
?:
...
}
;
}
;
}
;
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
}
;
timeseriesResult
?:
{
data
?:
(...)
|
(...)
;
metadata
?:
(...)
|
(...)
;
runtimeInfo
?:
(...)
|
(...)
;
type
?:
(...)
|
(...)
;
}
[]
;
}
;
}
,
)
:
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
<
ArrayBufferLike
>
|
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
<
ArrayBufferLike
>
|
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
<
ArrayBufferLike
>
|
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
<
ArrayBufferLike
>
|
Reader
,
length
?:
number
,
)
:
Empty
;
encode
(
_
:
Empty
,
writer
?:
Writer
)
:
Writer
;
fromJSON
(
_
:
any
)
:
Empty
;
fromPartial
(
_
:
{}
)
:
Empty
;
toJSON
(
_
:
Empty
)
:
unknown
;
}
;
}
;
}
;
name
:
"Processor"
;
}
Type Declaration
Readonly
fullName
:
"processor.Processor"
Readonly
methods
:
{
getConfig
:
{
name
:
"GetConfig"
;
options
:
{}
;
requestStream
:
false
;
requestType
:
{
create
(
base
?:
{}
)
:
ProcessConfigRequest
;
decode
(
input
:
Uint8Array
<
ArrayBufferLike
>
|
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
;
endBlock
?:
bigint
;
intervalConfigs
?:
(...)
[]
;
logConfigs
?:
(...)
[]
;
moveCallConfigs
?:
(...)
[]
;
moveIntervalConfigs
?:
(...)
[]
;
moveResourceChangeConfigs
?:
(...)
[]
;
startBlock
?:
bigint
;
}
[]
;
config
?:
{
name
?:
string
;
version
?:
string
}
;
contractConfigs
?:
{
assetConfigs
?:
(...)
[]
;
contract
?:
{
abi
?:
...
;
address
?:
...
;
chainId
?:
...
;
name
?:
...
}
;
cosmosLogConfigs
?:
(...)
[]
;
endBlock
?:
bigint
;
fuelReceiptConfigs
?:
(...)
[]
;
fuelTransactionConfigs
?:
(...)
[]
;
instructionConfig
?:
{
innerInstruction
?:
...
;
parsedInstruction
?:
...
;
rawDataInstruction
?:
...
;
}
;
intervalConfigs
?:
(...)
[]
;
logConfigs
?:
(...)
[]
;
moveCallConfigs
?:
(...)
[]
;
moveEventConfigs
?:
(...)
[]
;
moveIntervalConfigs
?:
(...)
[]
;
moveResourceChangeConfigs
?:
(...)
[]
;
processorType
?:
string
;
starknetEventConfigs
?:
(...)
[]
;
startBlock
?:
bigint
;
traceConfigs
?:
(...)
[]
;
transactionConfig
?:
(...)
[]
;
}
[]
;
dbSchema
?:
{
gqlSchema
?:
string
}
;
eventLogConfigs
?:
{
fields
?:
(...)
[]
;
name
?:
string
}
[]
;
executionConfig
?:
{
ethAbiDecoderConfig
?:
{
enabled
?:
(...)
|
(...)
|
(...)
;
skipWhenDecodeFailed
?:
(...)
|
(...)
|
(...)
;
workerCount
?:
(...)
|
(...)
;
}
;
forceExactBlockTime
?:
boolean
;
handlerOrderInsideTransaction
?:
ExecutionConfig_HandlerOrderInsideTransaction
;
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
<
ArrayBufferLike
>
|
Reader
,
length
?:
number
,
)
:
ProcessConfigResponse
;
encode
(
message
:
ProcessConfigResponse
,
writer
?:
Writer
)
:
Writer
;
fromJSON
(
object
:
any
)
:
ProcessConfigResponse
;
fromPartial
(
object
:
{
accountConfigs
?:
{
address
?:
string
;
chainId
?:
string
;
endBlock
?:
bigint
;
intervalConfigs
?:
{
fetchConfig
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
minutes
?:
...
;
minutesInterval
?:
...
;
slot
?:
...
;
slotInterval
?:
...
;
}
[]
;
logConfigs
?:
{
fetchConfig
?:
...
;
filters
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
moveCallConfigs
?:
{
fetchConfig
?:
...
;
filters
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
moveIntervalConfigs
?:
{
fetchConfig
?:
...
;
intervalConfig
?:
...
;
ownerType
?:
...
;
resourceFetchConfig
?:
...
;
type
?:
...
;
}
[]
;
moveResourceChangeConfigs
?:
{
handlerId
?:
...
;
handlerName
?:
...
;
includeDeleted
?:
...
;
type
?:
...
;
}
[]
;
startBlock
?:
bigint
;
}
[]
;
config
?:
{
name
?:
string
;
version
?:
string
}
;
contractConfigs
?:
{
assetConfigs
?:
{
filters
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
contract
?:
{
abi
?:
(...)
|
(...)
;
address
?:
(...)
|
(...)
;
chainId
?:
(...)
|
(...)
;
name
?:
(...)
|
(...)
;
}
;
cosmosLogConfigs
?:
{
handlerId
?:
...
;
handlerName
?:
...
;
logFilters
?:
...
;
}
[]
;
endBlock
?:
bigint
;
fuelReceiptConfigs
?:
{
handlerId
?:
...
;
handlerName
?:
...
;
log
?:
...
;
transfer
?:
...
;
}
[]
;
fuelTransactionConfigs
?:
{
handlerId
?:
...
;
handlerName
?:
...
}
[]
;
instructionConfig
?:
{
innerInstruction
?:
(...)
|
(...)
|
(...)
;
parsedInstruction
?:
(...)
|
(...)
|
(...)
;
rawDataInstruction
?:
(...)
|
(...)
|
(...)
;
}
;
intervalConfigs
?:
{
fetchConfig
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
minutes
?:
...
;
minutesInterval
?:
...
;
slot
?:
...
;
slotInterval
?:
...
;
}
[]
;
logConfigs
?:
{
fetchConfig
?:
...
;
filters
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
moveCallConfigs
?:
{
fetchConfig
?:
...
;
filters
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
moveEventConfigs
?:
{
fetchConfig
?:
...
;
filters
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
moveIntervalConfigs
?:
{
fetchConfig
?:
...
;
intervalConfig
?:
...
;
ownerType
?:
...
;
resourceFetchConfig
?:
...
;
type
?:
...
;
}
[]
;
moveResourceChangeConfigs
?:
{
handlerId
?:
...
;
handlerName
?:
...
;
includeDeleted
?:
...
;
type
?:
...
;
}
[]
;
processorType
?:
string
;
starknetEventConfigs
?:
{
filters
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
startBlock
?:
bigint
;
traceConfigs
?:
{
fetchConfig
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
signature
?:
...
;
}
[]
;
transactionConfig
?:
{
fetchConfig
?:
...
;
handlerId
?:
...
;
handlerName
?:
...
;
}
[]
;
}
[]
;
dbSchema
?:
{
gqlSchema
?:
string
}
;
eventLogConfigs
?:
{
fields
?:
{
basicType
?:
...
;
coinType
?:
...
;
name
?:
...
;
structType
?:
...
;
}
[]
;
name
?:
string
;
}
[]
;
executionConfig
?:
{
ethAbiDecoderConfig
?:
{
enabled
?:
boolean
;
skipWhenDecodeFailed
?:
boolean
;
workerCount
?:
number
;
}
;
forceExactBlockTime
?:
boolean
;
handlerOrderInsideTransaction
?:
ExecutionConfig_HandlerOrderInsideTransaction
;
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
?:
{
chainId
?:
...
;
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
<
ArrayBufferLike
>
|
Reader
,
length
?:
number
,
)
:
PreprocessStreamRequest
;
encode
(
message
:
PreprocessStreamRequest
,
writer
?:
Writer
)
:
Writer
;
fromJSON
(
object
:
any
)
:
PreprocessStreamRequest
;
fromPartial
(
object
:
{
bindings
?:
{
bindings
?:
{
chainId
?:
(...)
|
(...)
;
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
;
update
?:
{
entity
?:
(...)
|
(...)
;
entityData
?:
(...)
|
(...)
;
id
?:
(...)
|
(...)
;
}
;
upsert
?:
{
data
?:
(...)
|
(...)
;
entity
?:
(...)
|
(...)
;
entityData
?:
(...)
|
(...)
;
id
?:
(...)
|
(...)
;
}
;
}
;
processId
?:
number
;
}
,
)
:
PreprocessStreamResponse
;
decode
(
input
:
Uint8Array
<
ArrayBufferLike
>
|
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
;
update
?:
{
entity
?:
(...)
[]
;
entityData
?:
(...)
[]
;
id
?:
(...)
[]
}
;
upsert
?:
{
data
?:
(...)
[]
;
entity
?:
(...)
[]
;
entityData
?:
(...)
[]
;
id
?:
(...)
[]
;
}
;
}
;
processId
?:
number
;
}
,
)
:
PreprocessStreamResponse
;
toJSON
(
message
:
PreprocessStreamResponse
)
:
unknown
;
}
;
}
;
processBindings
:
{
name
:
"ProcessBindings"
;
options
:
{}
;
requestStream
:
false
;
requestType
:
{
create
(
base
?:
{
bindings
?:
{
chainId
?:
string
;
data
?:
{
aptCall
?:
...
;
aptEvent
?:
...
;
aptResource
?:
...
;
cosmosCall
?:
...
;
ethBlock
?:
...
;
ethLog
?:
...
;
ethTrace
?:
...
;
ethTransaction
?:
...
;
fuelBlock
?:
...
;
fuelLog
?:
...
;
fuelTransaction
?:
...
;
solInstruction
?:
...
;
starknetEvents
?:
...
;
suiCall
?:
...
;
suiEvent
?:
...
;
suiObject
?:
...
;
suiObjectChange
?:
...
;
}
;
handlerIds
?:
(...)
[]
;
handlerType
?:
HandlerType
;
}
[]
;
}
,
)
:
ProcessBindingsRequest
;
decode
(
input
:
Uint8Array
<
ArrayBufferLike
>
|
Reader
,
length
?:
number
,
)
:
ProcessBindingsRequest
;
encode
(
message
:
ProcessBindingsRequest
,
writer
?:
Writer
)
:
Writer
;
fromJSON
(
object
:
any
)
:
ProcessBindingsRequest
;
fromPartial
(
object
:
{
bindings
?:
{
chainId
?:
string
;
data
?:
{
aptCall
?:
(...)
|
(...)
;
aptEvent
?:
(...)
|
(...)
;
aptResource
?:
(...)
|
(...)
;
cosmosCall
?:
(...)
|
(...)
;
ethBlock
?:
(...)
|
(...)
;
ethLog
?:
(...)
|
(...)
;
ethTrace
?:
(...)
|
(...)
;
ethTransaction
?:
(...)
|
(...)
;
fuelBlock
?:
(...)
|
(...)
;
fuelLog
?:
(...)
|
(...)
;
fuelTransaction
?:
(...)
|
(...)
;
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
?:
(...)
|
(...)
;
}
;
timeseriesResult
?:
{
data
?:
...
;
metadata
?:
...
;
runtimeInfo
?:
...
;
type
?:
...
;
}
[]
;
}
;
}
,
)
:
ProcessBindingResponse
;
decode
(
input
:
Uint8Array
<
ArrayBufferLike
>
|
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
}
;
timeseriesResult
?:
{
data
?:
(...)
|
(...)
;
metadata
?:
(...)
|
(...)
;
runtimeInfo
?:
(...)
|
(...)
;
type
?:
(...)
|
(...)
;
}
[]
;
}
;
}
,
)
:
ProcessBindingResponse
;
toJSON
(
message
:
ProcessBindingResponse
)
:
unknown
;
}
;
}
;
processBindingsStream
:
{
name
:
"ProcessBindingsStream"
;
options
:
{}
;
requestStream
:
true
;
requestType
:
{
create
(
base
?:
{
binding
?:
{
chainId
?:
string
;
data
?:
{
aptCall
?:
(...)
|
(...)
;
aptEvent
?:
(...)
|
(...)
;
aptResource
?:
(...)
|
(...)
;
cosmosCall
?:
(...)
|
(...)
;
ethBlock
?:
(...)
|
(...)
;
ethLog
?:
(...)
|
(...)
;
ethTrace
?:
(...)
|
(...)
;
ethTransaction
?:
(...)
|
(...)
;
fuelBlock
?:
(...)
|
(...)
;
fuelLog
?:
(...)
|
(...)
;
fuelTransaction
?:
(...)
|
(...)
;
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
;
start
?:
boolean
;
}
,
)
:
ProcessStreamRequest
;
decode
(
input
:
Uint8Array
<
ArrayBufferLike
>
|
Reader
,
length
?:
number
,
)
:
ProcessStreamRequest
;
encode
(
message
:
ProcessStreamRequest
,
writer
?:
Writer
)
:
Writer
;
fromJSON
(
object
:
any
)
:
ProcessStreamRequest
;
fromPartial
(
object
:
{
binding
?:
{
chainId
?:
string
;
data
?:
{
aptCall
?:
{
rawTransaction
?:
...
}
;
aptEvent
?:
{
eventIndex
?:
...
;
rawEvent
?:
...
;
rawTransaction
?:
...
}
;
aptResource
?:
{
rawResources
?:
...
;
timestampMicros
?:
...
;
version
?:
...
;
}
;
cosmosCall
?:
{
timestamp
?:
...
;
transaction
?:
...
}
;
ethBlock
?:
{
block
?:
...
}
;
ethLog
?:
{
block
?:
...
;
log
?:
...
;
rawBlock
?:
...
;
rawLog
?:
...
;
rawTransaction
?:
...
;
rawTransactionReceipt
?:
...
;
timestamp
?:
...
;
transaction
?:
...
;
transactionReceipt
?:
...
;
}
;
ethTrace
?:
{
block
?:
...
;
timestamp
?:
...
;
trace
?:
...
;
transaction
?:
...
;
transactionReceipt
?:
...
;
}
;
ethTransaction
?:
{
block
?:
...
;
rawBlock
?:
...
;
rawTrace
?:
...
;
rawTransaction
?:
...
;
rawTransactionReceipt
?:
...
;
timestamp
?:
...
;
trace
?:
...
;
transaction
?:
...
;
transactionReceipt
?:
...
;
}
;
fuelBlock
?:
{
block
?:
...
;
timestamp
?:
...
}
;
fuelLog
?:
{
receiptIndex
?:
...
;
timestamp
?:
...
;
transaction
?:
...
}
;
fuelTransaction
?:
{
timestamp
?:
...
;
transaction
?:
...
}
;
solInstruction
?:
{
accounts
?:
...
;
instructionData
?:
...
;
parsed
?:
...
;
programAccountId
?:
...
;
slot
?:
...
;
}
;
starknetEvents
?:
{
result
?:
...
;
timestamp
?:
...
}
;
suiCall
?:
{
rawTransaction
?:
...
;
slot
?:
...
;
timestamp
?:
...
}
;
suiEvent
?:
{
rawEvent
?:
...
;
rawTransaction
?:
...
;
slot
?:
...
;
timestamp
?:
...
;
}
;
suiObject
?:
{
objectDigest
?:
...
;
objectId
?:
...
;
objectVersion
?:
...
;
rawObjects
?:
...
;
rawSelf
?:
...
;
slot
?:
...
;
timestamp
?:
...
;
}
;
suiObjectChange
?:
{
rawChanges
?:
...
;
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
;
start
?:
boolean
;
}
,
)
:
ProcessStreamRequest
;
toJSON
(
message
:
ProcessStreamRequest
)
:
unknown
;
}
;
responseStream
:
true
;
responseType
:
{
create
(
base
?:
{
dbRequest
?:
{
delete
?:
{
entity
?:
(...)
|
(...)
;
id
?:
(...)
|
(...)
}
;
get
?:
{
entity
?:
(...)
|
(...)
;
id
?:
(...)
|
(...)
}
;
list
?:
{
cursor
?:
(...)
|
(...)
;
entity
?:
(...)
|
(...)
;
filters
?:
(...)
|
(...)
;
pageSize
?:
(...)
|
(...)
;
}
;
opId
?:
bigint
;
update
?:
{
entity
?:
(...)
|
(...)
;
entityData
?:
(...)
|
(...)
;
id
?:
(...)
|
(...)
;
}
;
upsert
?:
{
data
?:
(...)
|
(...)
;
entity
?:
(...)
|
(...)
;
entityData
?:
(...)
|
(...)
;
id
?:
(...)
|
(...)
;
}
;
}
;
partitions
?:
{
partitions
?:
{
[
key
:
number
]:
(...)
|
(...)
}
}
;
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
?:
(...)
|
(...)
;
}
;
timeseriesResult
?:
{
data
?:
...
;
metadata
?:
...
;
runtimeInfo
?:
...
;
type
?:
...
;
}
[]
;
}
;
}
,
)
:
ProcessStreamResponse
;
decode
(
input
:
Uint8Array
<
ArrayBufferLike
>
|
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
;
update
?:
{
entity
?:
(...)
[]
;
entityData
?:
(...)
[]
;
id
?:
(...)
[]
}
;
upsert
?:
{
data
?:
(...)
[]
;
entity
?:
(...)
[]
;
entityData
?:
(...)
[]
;
id
?:
(...)
[]
;
}
;
}
;
partitions
?:
{
partitions
?:
{
[
key
:
number
]:
undefined
|
{
sysValue
?:
...
;
userValue
?:
...
}
;
}
;
}
;
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
}
;
timeseriesResult
?:
{
data
?:
(...)
|
(...)
;
metadata
?:
(...)
|
(...)
;
runtimeInfo
?:
(...)
|
(...)
;
type
?:
(...)
|
(...)
;
}
[]
;
}
;
}
,
)
:
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
<
ArrayBufferLike
>
|
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
<
ArrayBufferLike
>
|
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
<
ArrayBufferLike
>
|
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
<
ArrayBufferLike
>
|
Reader
,
length
?:
number
,
)
:
Empty
;
encode
(
_
:
Empty
,
writer
?:
Writer
)
:
Writer
;
fromJSON
(
_
:
any
)
:
Empty
;
fromPartial
(
_
:
{}
)
:
Empty
;
toJSON
(
_
:
Empty
)
:
unknown
;
}
;
}
;
}
Readonly
name
:
"Processor"
Settings
Member Visibility
Protected
Inherited
External
Theme
OS
Light
Dark
@sentio/sdk
Loading...