pbssinternal

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 Completed struct {
	AllProcessedRanges []*BlockRange `protobuf:"bytes,1,rep,name=all_processed_ranges,json=allProcessedRanges,proto3" json:"all_processed_ranges,omitempty"`
	// TraceId represents the producer's trace id that produced the partial files.
	// This is present here so that the consumer can use it to identify the
	// right partial files that needs to be squashed together.
	//
	// The TraceId can be empty in which case it should be assumed by the tier1
	// consuming this message that the tier2 that produced those partial files
	// is not yet updated to produce a trace id and a such, the tier1 should
	// generate a legacy partial file name.
	TraceId string `protobuf:"bytes,2,opt,name=trace_id,json=traceId,proto3" json:"trace_id,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 Failed struct {
	Reason string   `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	Logs   []string `protobuf:"bytes,2,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,3,opt,name=logs_truncated,json=logsTruncated,proto3" json:"logs_truncated,omitempty"`
	// contains filtered or unexported fields
}

type ModuleOutput struct {
	ModuleName string `protobuf:"bytes,1,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
	// Types that are assignable to Data:
	//
	//	*ModuleOutput_MapOutput
	//	*ModuleOutput_StoreDeltas
	Data               isModuleOutput_Data `protobuf_oneof:"data"`
	Logs               []string            `protobuf:"bytes,4,rep,name=logs,proto3" json:"logs,omitempty"`
	DebugLogsTruncated bool                `protobuf:"varint,5,opt,name=debug_logs_truncated,json=debugLogsTruncated,proto3" json:"debug_logs_truncated,omitempty"`
	Cached             bool                `protobuf:"varint,6,opt,name=cached,proto3" json:"cached,omitempty"`
	// contains filtered or unexported fields
}

type ModuleOutput_MapOutput struct {
	MapOutput *anypb.Any `protobuf:"bytes,2,opt,name=map_output,json=mapOutput,proto3,oneof"`
}

type ModuleOutput_StoreDeltas struct {
	StoreDeltas *v1.StoreDeltas `protobuf:"bytes,3,opt,name=store_deltas,json=storeDeltas,proto3,oneof"`
}

type ModuleStats struct {
	Name                 string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ProcessingTimeMs     uint64                `protobuf:"varint,2,opt,name=processing_time_ms,json=processingTimeMs,proto3" json:"processing_time_ms,omitempty"`
	StoreOperationTimeMs uint64                `` /* 126-byte string literal not displayed */
	StoreReadCount       uint64                `protobuf:"varint,4,opt,name=store_read_count,json=storeReadCount,proto3" json:"store_read_count,omitempty"`
	ExternalCallMetrics  []*ExternalCallMetric `protobuf:"bytes,5,rep,name=external_call_metrics,json=externalCallMetrics,proto3" json:"external_call_metrics,omitempty"`
	// store-specific (will be 0 on mappers)
	StoreWriteCount        uint64 `protobuf:"varint,10,opt,name=store_write_count,json=storeWriteCount,proto3" json:"store_write_count,omitempty"`
	StoreDeleteprefixCount uint64 `` /* 131-byte string literal not displayed */
	StoreSizeBytes         uint64 `protobuf:"varint,12,opt,name=store_size_bytes,json=storeSizeBytes,proto3" json:"store_size_bytes,omitempty"`
	// contains filtered or unexported fields
}

type Operation struct {
	Type  Operation_Type `protobuf:"varint,1,opt,name=type,proto3,enum=sf.substreams.internal.v2.Operation_Type" json:"type,omitempty"`
	Ord   uint64         `protobuf:"varint,2,opt,name=ord,proto3" json:"ord,omitempty"`
	Key   string         `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte         `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Operation_Type int32

type Operations struct {
	Operations []*Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

type ProcessRangeRequest struct {
	StartBlockNum        uint64            `protobuf:"varint,1,opt,name=start_block_num,json=startBlockNum,proto3" json:"start_block_num,omitempty"`
	StopBlockNum         uint64            `protobuf:"varint,2,opt,name=stop_block_num,json=stopBlockNum,proto3" json:"stop_block_num,omitempty"`
	OutputModule         string            `protobuf:"bytes,3,opt,name=output_module,json=outputModule,proto3" json:"output_module,omitempty"`
	Modules              *v1.Modules       `protobuf:"bytes,4,opt,name=modules,proto3" json:"modules,omitempty"`
	Stage                uint32            `protobuf:"varint,5,opt,name=stage,proto3" json:"stage,omitempty"` // 0-based index of stage to execute up to
	MeteringConfig       string            `protobuf:"bytes,6,opt,name=metering_config,json=meteringConfig,proto3" json:"metering_config,omitempty"`
	FirstStreamableBlock uint64            `protobuf:"varint,7,opt,name=first_streamable_block,json=firstStreamableBlock,proto3" json:"first_streamable_block,omitempty"` // first block that can be streamed
	LastStreamableBlock  uint64            `protobuf:"varint,8,opt,name=last_streamable_block,json=lastStreamableBlock,proto3" json:"last_streamable_block,omitempty"`    // last block that can be streamed
	WasmModules          map[string]string ``                                                                                                                             // TODO: rename to `wasm_extension_configs`
	/* 182-byte string literal not displayed */
	MergedBlocksStore    string `protobuf:"bytes,10,opt,name=merged_blocks_store,json=mergedBlocksStore,proto3" json:"merged_blocks_store,omitempty"` // store to use for merged blocks
	StateStore           string `protobuf:"bytes,11,opt,name=state_store,json=stateStore,proto3" json:"state_store,omitempty"`                        // store to use for substreams state
	StateStoreDefaultTag string ``                                                                                                                    // default tag to use for state store
	/* 126-byte string literal not displayed */
	StateBundleSize uint64 `protobuf:"varint,13,opt,name=state_bundle_size,json=stateBundleSize,proto3" json:"state_bundle_size,omitempty"` // number of blocks to process in a single batch
	BlockType       string `protobuf:"bytes,14,opt,name=block_type,json=blockType,proto3" json:"block_type,omitempty"`                      // block type to process
	// contains filtered or unexported fields
}

type ProcessRangeResponse struct {

	// Types that are assignable to Type:
	//
	//	*ProcessRangeResponse_Failed
	//	*ProcessRangeResponse_Completed
	//	*ProcessRangeResponse_Update
	Type isProcessRangeResponse_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type ProcessRangeResponse_Completed struct {
	Completed *Completed `protobuf:"bytes,5,opt,name=completed,proto3,oneof"`
}

type ProcessRangeResponse_Failed struct {
	Failed *Failed `protobuf:"bytes,4,opt,name=failed,proto3,oneof"`
}

type ProcessRangeResponse_Update struct {
	Update *Update `protobuf:"bytes,6,opt,name=update,proto3,oneof"`
}

type RPCCallWasmModuleConfiguration struct {
	Endpoint string `json:"endpoint"`
}

type SubstreamsClient interface {
	ProcessRange(ctx context.Context, in *ProcessRangeRequest, opts ...grpc.CallOption) (Substreams_ProcessRangeClient, error)
}

type SubstreamsServer interface {
	ProcessRange(*ProcessRangeRequest, Substreams_ProcessRangeServer) error
}

type Substreams_ProcessRangeClient interface {
	Recv() (*ProcessRangeResponse, error)
	grpc.ClientStream
}

type Substreams_ProcessRangeServer interface {
	Send(*ProcessRangeResponse) error
	grpc.ServerStream
}

type UnimplementedSubstreamsServer struct {
}

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

type Update struct {
	DurationMs        uint64         `protobuf:"varint,1,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
	ProcessedBlocks   uint64         `protobuf:"varint,2,opt,name=processed_blocks,json=processedBlocks,proto3" json:"processed_blocks,omitempty"`
	TotalBytesRead    uint64         `protobuf:"varint,3,opt,name=total_bytes_read,json=totalBytesRead,proto3" json:"total_bytes_read,omitempty"`
	TotalBytesWritten uint64         `protobuf:"varint,4,opt,name=total_bytes_written,json=totalBytesWritten,proto3" json:"total_bytes_written,omitempty"`
	ModulesStats      []*ModuleStats `protobuf:"bytes,5,rep,name=modules_stats,json=modulesStats,proto3" json:"modules_stats,omitempty"`
	// contains filtered or unexported fields
}

type WASMModuleType int32