pbsubstreamsrpc

type AnyModuleOutput struct {
	MapOutput   *MapModuleOutput
	StoreOutput *StoreModuleOutput
}

type BlockRange struct {
	StartBlock uint64 `protobuf:"varint,2,opt,name=start_block,json=startBlock,proto3" json:"start_block,omitempty"`
	EndBlock   uint64 `protobuf:"varint,3,opt,name=end_block,json=endBlock,proto3" json:"end_block,omitempty"`
	// contains filtered or unexported fields
}

type BlockScopedData struct {
	Output *MapModuleOutput `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Clock  *v1.Clock        `protobuf:"bytes,2,opt,name=clock,proto3" json:"clock,omitempty"`
	Cursor string           `protobuf:"bytes,3,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// Non-deterministic, allows substreams-sink to let go of their undo data.
	FinalBlockHeight  uint64               `protobuf:"varint,4,opt,name=final_block_height,json=finalBlockHeight,proto3" json:"final_block_height,omitempty"`
	DebugMapOutputs   []*MapModuleOutput   `protobuf:"bytes,10,rep,name=debug_map_outputs,json=debugMapOutputs,proto3" json:"debug_map_outputs,omitempty"`
	DebugStoreOutputs []*StoreModuleOutput `protobuf:"bytes,11,rep,name=debug_store_outputs,json=debugStoreOutputs,proto3" json:"debug_store_outputs,omitempty"`
	// contains filtered or unexported fields
}

type BlockUndoSignal struct {
	LastValidBlock  *v1.BlockRef `protobuf:"bytes,1,opt,name=last_valid_block,json=lastValidBlock,proto3" json:"last_valid_block,omitempty"`
	LastValidCursor string       `protobuf:"bytes,2,opt,name=last_valid_cursor,json=lastValidCursor,proto3" json:"last_valid_cursor,omitempty"`
	// contains filtered or unexported fields
}

type Error struct {
	Module string   `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	Reason string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Logs   []string `protobuf:"bytes,3,rep,name=logs,proto3" json:"logs,omitempty"`
	// FailureLogsTruncated is a flag that tells you if you received all the logs or if they
	// were truncated because you logged too much (fixed limit currently is set to 128 KiB).
	LogsTruncated bool `protobuf:"varint,4,opt,name=logs_truncated,json=logsTruncated,proto3" json:"logs_truncated,omitempty"`
	// contains filtered or unexported fields
}

type ExternalCallMetric struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Count  uint64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	TimeMs uint64 `protobuf:"varint,3,opt,name=time_ms,json=timeMs,proto3" json:"time_ms,omitempty"`
	// contains filtered or unexported fields
}

type InitialSnapshotComplete struct {
	Cursor string `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

type InitialSnapshotData struct {
	ModuleName string        `protobuf:"bytes,1,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
	Deltas     []*StoreDelta `protobuf:"bytes,2,rep,name=deltas,proto3" json:"deltas,omitempty"`
	SentKeys   uint64        `protobuf:"varint,4,opt,name=sent_keys,json=sentKeys,proto3" json:"sent_keys,omitempty"`
	TotalKeys  uint64        `protobuf:"varint,3,opt,name=total_keys,json=totalKeys,proto3" json:"total_keys,omitempty"`
	// contains filtered or unexported fields
}

type Job struct {
	Stage           uint32 `protobuf:"varint,1,opt,name=stage,proto3" json:"stage,omitempty"`
	StartBlock      uint64 `protobuf:"varint,2,opt,name=start_block,json=startBlock,proto3" json:"start_block,omitempty"`
	StopBlock       uint64 `protobuf:"varint,3,opt,name=stop_block,json=stopBlock,proto3" json:"stop_block,omitempty"`
	ProcessedBlocks uint64 `protobuf:"varint,4,opt,name=processed_blocks,json=processedBlocks,proto3" json:"processed_blocks,omitempty"`
	DurationMs      uint64 `protobuf:"varint,5,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
	// contains filtered or unexported fields
}

type MapModuleOutput struct {
	Name      string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	MapOutput *anypb.Any `protobuf:"bytes,2,opt,name=map_output,json=mapOutput,proto3" json:"map_output,omitempty"`
	// DebugOutputInfo is available in non-production mode only
	DebugInfo *OutputDebugInfo `protobuf:"bytes,10,opt,name=debug_info,json=debugInfo,proto3" json:"debug_info,omitempty"`
	// contains filtered or unexported fields
}

type ModuleStats struct {

	// name of the module
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// total_processed_blocks is the sum of blocks sent to that module code
	TotalProcessedBlockCount uint64 `` /* 138-byte string literal not displayed */
	// total_processing_time_ms is the sum of all time spent running that module code
	TotalProcessingTimeMs uint64 `` /* 129-byte string literal not displayed */
	// // external_calls are chain-specific intrinsics, like "Ethereum RPC calls".
	ExternalCallMetrics []*ExternalCallMetric `protobuf:"bytes,4,rep,name=external_call_metrics,json=externalCallMetrics,proto3" json:"external_call_metrics,omitempty"`
	// total_store_operation_time_ms is the sum of all time spent running that module code waiting for a store operation (ex: read, write, delete...)
	TotalStoreOperationTimeMs uint64 `` /* 143-byte string literal not displayed */
	// total_store_read_count is the sum of all the store Read operations called from that module code
	TotalStoreReadCount uint64 `protobuf:"varint,6,opt,name=total_store_read_count,json=totalStoreReadCount,proto3" json:"total_store_read_count,omitempty"`
	// total_store_write_count is the sum of all store Write operations called from that module code (store-only)
	TotalStoreWriteCount uint64 `` /* 127-byte string literal not displayed */
	// total_store_deleteprefix_count is the sum of all store DeletePrefix operations called from that module code (store-only)
	// note that DeletePrefix can be a costly operation on large stores
	TotalStoreDeleteprefixCount uint64 `` /* 148-byte string literal not displayed */
	// store_size_bytes is the uncompressed size of the full KV store for that module, from the last 'merge' operation (store-only)
	StoreSizeBytes uint64 `protobuf:"varint,12,opt,name=store_size_bytes,json=storeSizeBytes,proto3" json:"store_size_bytes,omitempty"`
	// total_store_merging_time_ms is the time spent merging partial stores into a full KV store for that module (store-only)
	TotalStoreMergingTimeMs uint64 `` /* 138-byte string literal not displayed */
	// store_currently_merging is true if there is a merging operation (partial store to full KV store) on the way.
	StoreCurrentlyMerging bool `` /* 128-byte string literal not displayed */
	// highest_contiguous_block is the highest block in the highest merged full KV store of that module (store-only)
	HighestContiguousBlock uint64 `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ModulesProgress struct {

	// List of jobs running on tier2 servers
	RunningJobs []*Job `protobuf:"bytes,2,rep,name=running_jobs,json=runningJobs,proto3" json:"running_jobs,omitempty"`
	// Execution statistics for each module
	ModulesStats []*ModuleStats `protobuf:"bytes,3,rep,name=modules_stats,json=modulesStats,proto3" json:"modules_stats,omitempty"`
	// Stages definition and completed block ranges
	Stages         []*Stage        `protobuf:"bytes,4,rep,name=stages,proto3" json:"stages,omitempty"`
	ProcessedBytes *ProcessedBytes `protobuf:"bytes,5,opt,name=processed_bytes,json=processedBytes,proto3" json:"processed_bytes,omitempty"`
	// contains filtered or unexported fields
}

type OutputDebugInfo struct {
	Logs []string `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// LogsTruncated is a flag that tells you if you received all the logs or if they
	// were truncated because you logged too much (fixed limit currently is set to 128 KiB).
	LogsTruncated bool `protobuf:"varint,2,opt,name=logs_truncated,json=logsTruncated,proto3" json:"logs_truncated,omitempty"`
	Cached        bool `protobuf:"varint,3,opt,name=cached,proto3" json:"cached,omitempty"`
	// contains filtered or unexported fields
}

type ProcessedBytes struct {
	TotalBytesRead    uint64 `protobuf:"varint,1,opt,name=total_bytes_read,json=totalBytesRead,proto3" json:"total_bytes_read,omitempty"`
	TotalBytesWritten uint64 `protobuf:"varint,2,opt,name=total_bytes_written,json=totalBytesWritten,proto3" json:"total_bytes_written,omitempty"`
	// contains filtered or unexported fields
}

type Request struct {
	StartBlockNum int64  `protobuf:"varint,1,opt,name=start_block_num,json=startBlockNum,proto3" json:"start_block_num,omitempty"`
	StartCursor   string `protobuf:"bytes,2,opt,name=start_cursor,json=startCursor,proto3" json:"start_cursor,omitempty"`
	StopBlockNum  uint64 `protobuf:"varint,3,opt,name=stop_block_num,json=stopBlockNum,proto3" json:"stop_block_num,omitempty"`
	// With final_block_only, you only receive blocks that are irreversible:
	// 'final_block_height' will be equal to current block and no 'undo_signal' will ever be sent
	FinalBlocksOnly bool `protobuf:"varint,4,opt,name=final_blocks_only,json=finalBlocksOnly,proto3" json:"final_blocks_only,omitempty"`
	// Substreams has two mode when executing your module(s) either development mode or production
	// mode. Development and production modes impact the execution of Substreams, important aspects
	// of execution include:
	// * The time required to reach the first byte.
	// * The speed that large ranges get executed.
	// * The module logs and outputs sent back to the client.
	//
	// By default, the engine runs in developer mode, with richer and deeper output. Differences
	// between production and development modes include:
	// * Forward parallel execution is enabled in production mode and disabled in development mode
	// * The time required to reach the first byte in development mode is faster than in production mode.
	//
	// Specific attributes of development mode include:
	// * The client will receive all of the executed module's logs.
	// * It's possible to request specific store snapshots in the execution tree (via `debug_initial_store_snapshot_for_modules`).
	// * Multiple module's output is possible.
	//
	// With production mode`, however, you trade off functionality for high speed enabling forward
	// parallel execution of module ahead of time.
	ProductionMode bool        `protobuf:"varint,5,opt,name=production_mode,json=productionMode,proto3" json:"production_mode,omitempty"`
	OutputModule   string      `protobuf:"bytes,6,opt,name=output_module,json=outputModule,proto3" json:"output_module,omitempty"`
	Modules        *v1.Modules `protobuf:"bytes,7,opt,name=modules,proto3" json:"modules,omitempty"`
	// Available only in developer mode
	DebugInitialStoreSnapshotForModules []string `` /* 175-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Response struct {

	// Types that are assignable to Message:
	//
	//	*Response_Session
	//	*Response_Progress
	//	*Response_BlockScopedData
	//	*Response_BlockUndoSignal
	//	*Response_FatalError
	//	*Response_DebugSnapshotData
	//	*Response_DebugSnapshotComplete
	Message isResponse_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type Response_BlockScopedData struct {
	BlockScopedData *BlockScopedData `protobuf:"bytes,3,opt,name=block_scoped_data,json=blockScopedData,proto3,oneof"`
}

type Response_BlockUndoSignal struct {
	BlockUndoSignal *BlockUndoSignal `protobuf:"bytes,4,opt,name=block_undo_signal,json=blockUndoSignal,proto3,oneof"`
}

type Response_DebugSnapshotComplete struct {
	// Available only in developer mode, and only if `debug_initial_store_snapshot_for_modules` is set.
	DebugSnapshotComplete *InitialSnapshotComplete `protobuf:"bytes,11,opt,name=debug_snapshot_complete,json=debugSnapshotComplete,proto3,oneof"`
}

type Response_DebugSnapshotData struct {
	// Available only in developer mode, and only if `debug_initial_store_snapshot_for_modules` is set.
	DebugSnapshotData *InitialSnapshotData `protobuf:"bytes,10,opt,name=debug_snapshot_data,json=debugSnapshotData,proto3,oneof"`
}

type Response_FatalError struct {
	FatalError *Error `protobuf:"bytes,5,opt,name=fatal_error,json=fatalError,proto3,oneof"`
}

type Response_Progress struct {
	Progress *ModulesProgress `protobuf:"bytes,2,opt,name=progress,proto3,oneof"` // Progress of data preparation, before sending in the stream of `data` events.
}

type Response_Session struct {
	Session *SessionInit `protobuf:"bytes,1,opt,name=session,proto3,oneof"` // Always sent first
}

type SessionInit struct {
	TraceId            string `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	ResolvedStartBlock uint64 `protobuf:"varint,2,opt,name=resolved_start_block,json=resolvedStartBlock,proto3" json:"resolved_start_block,omitempty"`
	LinearHandoffBlock uint64 `protobuf:"varint,3,opt,name=linear_handoff_block,json=linearHandoffBlock,proto3" json:"linear_handoff_block,omitempty"`
	MaxParallelWorkers uint64 `protobuf:"varint,4,opt,name=max_parallel_workers,json=maxParallelWorkers,proto3" json:"max_parallel_workers,omitempty"`
	// contains filtered or unexported fields
}

type Stage struct {
	Modules         []string      `protobuf:"bytes,1,rep,name=modules,proto3" json:"modules,omitempty"`
	CompletedRanges []*BlockRange `protobuf:"bytes,2,rep,name=completed_ranges,json=completedRanges,proto3" json:"completed_ranges,omitempty"`
	// contains filtered or unexported fields
}

type StoreDelta struct {
	Operation StoreDelta_Operation `protobuf:"varint,1,opt,name=operation,proto3,enum=sf.substreams.rpc.v2.StoreDelta_Operation" json:"operation,omitempty"`
	Ordinal   uint64               `protobuf:"varint,2,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
	Key       string               `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	OldValue  []byte               `protobuf:"bytes,4,opt,name=old_value,json=oldValue,proto3" json:"old_value,omitempty"`
	NewValue  []byte               `protobuf:"bytes,5,opt,name=new_value,json=newValue,proto3" json:"new_value,omitempty"`
	// contains filtered or unexported fields
}

type StoreDelta_Operation int32

type StoreModuleOutput struct {
	Name             string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	DebugStoreDeltas []*StoreDelta    `protobuf:"bytes,2,rep,name=debug_store_deltas,json=debugStoreDeltas,proto3" json:"debug_store_deltas,omitempty"`
	DebugInfo        *OutputDebugInfo `protobuf:"bytes,10,opt,name=debug_info,json=debugInfo,proto3" json:"debug_info,omitempty"`
	// contains filtered or unexported fields
}

type StreamClient interface {
	Blocks(ctx context.Context, in *Request, opts ...grpc.CallOption) (Stream_BlocksClient, error)
}

type StreamServer interface {
	Blocks(*Request, Stream_BlocksServer) error
}

type Stream_BlocksClient interface {
	Recv() (*Response, error)
	grpc.ClientStream
}

type Stream_BlocksServer interface {
	Send(*Response) error
	grpc.ServerStream
}

type UnimplementedStreamServer struct {
}

type UnsafeStreamServer interface {
	// contains filtered or unexported methods
}