pbsubstreamsrpc

package
v1.1.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 6, 2023 License: Apache-2.0 Imports: 11 Imported by: 14

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	StoreDelta_Operation_name = map[int32]string{
		0: "UNSET",
		1: "CREATE",
		2: "UPDATE",
		3: "DELETE",
	}
	StoreDelta_Operation_value = map[string]int32{
		"UNSET":  0,
		"CREATE": 1,
		"UPDATE": 2,
		"DELETE": 3,
	}
)

Enum value maps for StoreDelta_Operation.

View Source 
var File_sf_substreams_rpc_v2_service_proto protoreflect.FileDescriptor
View Source 
var Stream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sf.substreams.rpc.v2.Stream",
	HandlerType: (*StreamServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Blocks",
			Handler:       _Stream_Blocks_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "sf/substreams/rpc/v2/service.proto",
}

Stream_ServiceDesc is the grpc.ServiceDesc for Stream service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterStreamServer 

func RegisterStreamServer(s grpc.ServiceRegistrar, srv StreamServer)

func TestNewMapModule 

func TestNewMapModule(name string) *pbsubstreams.Module

func TestNewStoreModule 

func TestNewStoreModule(name string) *pbsubstreams.Module

Types

type AnyModuleOutput 

type AnyModuleOutput struct {
	MapOutput   *MapModuleOutput
	StoreOutput *StoreModuleOutput
}

func (*AnyModuleOutput) DebugInfo 

func (a *AnyModuleOutput) DebugInfo() *OutputDebugInfo

func (*AnyModuleOutput) IsEmpty 

func (a *AnyModuleOutput) IsEmpty() bool

func (*AnyModuleOutput) IsMap 

func (a *AnyModuleOutput) IsMap() bool

func (*AnyModuleOutput) IsStore 

func (a *AnyModuleOutput) IsStore() bool

func (*AnyModuleOutput) Name 

func (a *AnyModuleOutput) Name() string

type BlockRange 

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
}

func (*BlockRange) Descriptor deprecated 

func (*BlockRange) Descriptor() ([]byte, []int)

Deprecated: Use BlockRange.ProtoReflect.Descriptor instead.

func (*BlockRange) GetEndBlock 

func (x *BlockRange) GetEndBlock() uint64

func (*BlockRange) GetStartBlock 

func (x *BlockRange) GetStartBlock() uint64

func (*BlockRange) ProtoMessage 

func (*BlockRange) ProtoMessage()

func (*BlockRange) ProtoReflect 

func (x *BlockRange) ProtoReflect() protoreflect.Message

func (*BlockRange) Reset 

func (x *BlockRange) Reset()

func (*BlockRange) String 

func (x *BlockRange) String() string

type BlockScopedData 

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
}

func (*BlockScopedData) AllModuleOutputs 

func (bd *BlockScopedData) AllModuleOutputs() (out []*AnyModuleOutput)

func (*BlockScopedData) Descriptor deprecated 

func (*BlockScopedData) Descriptor() ([]byte, []int)

Deprecated: Use BlockScopedData.ProtoReflect.Descriptor instead.

func (*BlockScopedData) GetClock 

func (x *BlockScopedData) GetClock() *v1.Clock

func (*BlockScopedData) GetCursor 

func (x *BlockScopedData) GetCursor() string

func (*BlockScopedData) GetDebugMapOutputs 

func (x *BlockScopedData) GetDebugMapOutputs() []*MapModuleOutput

func (*BlockScopedData) GetDebugStoreOutputs 

func (x *BlockScopedData) GetDebugStoreOutputs() []*StoreModuleOutput

func (*BlockScopedData) GetFinalBlockHeight 

func (x *BlockScopedData) GetFinalBlockHeight() uint64

func (*BlockScopedData) GetOutput 

func (x *BlockScopedData) GetOutput() *MapModuleOutput

func (*BlockScopedData) ProtoMessage 

func (*BlockScopedData) ProtoMessage()

func (*BlockScopedData) ProtoReflect 

func (x *BlockScopedData) ProtoReflect() protoreflect.Message

func (*BlockScopedData) Reset 

func (x *BlockScopedData) Reset()

func (*BlockScopedData) String 

func (x *BlockScopedData) String() string

type BlockUndoSignal 

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
}

BlockUndoSignal informs you that every bit of data with a block number above 'last_valid_block' has been reverted on-chain. Delete that data and restart from 'last_valid_cursor'

func (*BlockUndoSignal) Descriptor deprecated 

func (*BlockUndoSignal) Descriptor() ([]byte, []int)

Deprecated: Use BlockUndoSignal.ProtoReflect.Descriptor instead.

func (*BlockUndoSignal) GetLastValidBlock 

func (x *BlockUndoSignal) GetLastValidBlock() *v1.BlockRef

func (*BlockUndoSignal) GetLastValidCursor 

func (x *BlockUndoSignal) GetLastValidCursor() string

func (*BlockUndoSignal) ProtoMessage 

func (*BlockUndoSignal) ProtoMessage()

func (*BlockUndoSignal) ProtoReflect 

func (x *BlockUndoSignal) ProtoReflect() protoreflect.Message

func (*BlockUndoSignal) Reset 

func (x *BlockUndoSignal) Reset()

func (*BlockUndoSignal) String 

func (x *BlockUndoSignal) String() string

type InitialSnapshotComplete 

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

func (*InitialSnapshotComplete) Descriptor deprecated 

func (*InitialSnapshotComplete) Descriptor() ([]byte, []int)

Deprecated: Use InitialSnapshotComplete.ProtoReflect.Descriptor instead.

func (*InitialSnapshotComplete) GetCursor 

func (x *InitialSnapshotComplete) GetCursor() string

func (*InitialSnapshotComplete) ProtoMessage 

func (*InitialSnapshotComplete) ProtoMessage()

func (*InitialSnapshotComplete) ProtoReflect 

func (x *InitialSnapshotComplete) ProtoReflect() protoreflect.Message

func (*InitialSnapshotComplete) Reset 

func (x *InitialSnapshotComplete) Reset()

func (*InitialSnapshotComplete) String 

func (x *InitialSnapshotComplete) String() string

type InitialSnapshotData 

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
}

func (*InitialSnapshotData) Descriptor deprecated 

func (*InitialSnapshotData) Descriptor() ([]byte, []int)

Deprecated: Use InitialSnapshotData.ProtoReflect.Descriptor instead.

func (*InitialSnapshotData) GetDeltas 

func (x *InitialSnapshotData) GetDeltas() []*StoreDelta

func (*InitialSnapshotData) GetModuleName 

func (x *InitialSnapshotData) GetModuleName() string

func (*InitialSnapshotData) GetSentKeys 

func (x *InitialSnapshotData) GetSentKeys() uint64

func (*InitialSnapshotData) GetTotalKeys 

func (x *InitialSnapshotData) GetTotalKeys() uint64

func (*InitialSnapshotData) ProtoMessage 

func (*InitialSnapshotData) ProtoMessage()

func (*InitialSnapshotData) ProtoReflect 

func (x *InitialSnapshotData) ProtoReflect() protoreflect.Message

func (*InitialSnapshotData) Reset 

func (x *InitialSnapshotData) Reset()

func (*InitialSnapshotData) String 

func (x *InitialSnapshotData) String() string

type MapModuleOutput 

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
}

func (*MapModuleOutput) Descriptor deprecated 

func (*MapModuleOutput) Descriptor() ([]byte, []int)

Deprecated: Use MapModuleOutput.ProtoReflect.Descriptor instead.

func (*MapModuleOutput) GetDebugInfo 

func (x *MapModuleOutput) GetDebugInfo() *OutputDebugInfo

func (*MapModuleOutput) GetMapOutput 

func (x *MapModuleOutput) GetMapOutput() *anypb.Any

func (*MapModuleOutput) GetName 

func (x *MapModuleOutput) GetName() string

func (*MapModuleOutput) ProtoMessage 

func (*MapModuleOutput) ProtoMessage()

func (*MapModuleOutput) ProtoReflect 

func (x *MapModuleOutput) ProtoReflect() protoreflect.Message

func (*MapModuleOutput) Reset 

func (x *MapModuleOutput) Reset()

func (*MapModuleOutput) String 

func (x *MapModuleOutput) String() string

func (*MapModuleOutput) ToAny 

func (m *MapModuleOutput) ToAny() *AnyModuleOutput

type ModuleProgress 

type ModuleProgress struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to Type:
	//	*ModuleProgress_ProcessedRanges_
	//	*ModuleProgress_InitialState_
	//	*ModuleProgress_ProcessedBytes_
	//	*ModuleProgress_Failed_
	Type isModuleProgress_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*ModuleProgress) Descriptor deprecated 

func (*ModuleProgress) Descriptor() ([]byte, []int)

Deprecated: Use ModuleProgress.ProtoReflect.Descriptor instead.

func (*ModuleProgress) GetFailed 

func (x *ModuleProgress) GetFailed() *ModuleProgress_Failed

func (*ModuleProgress) GetInitialState 

func (x *ModuleProgress) GetInitialState() *ModuleProgress_InitialState

func (*ModuleProgress) GetName 

func (x *ModuleProgress) GetName() string

func (*ModuleProgress) GetProcessedBytes 

func (x *ModuleProgress) GetProcessedBytes() *ModuleProgress_ProcessedBytes

func (*ModuleProgress) GetProcessedRanges 

func (x *ModuleProgress) GetProcessedRanges() *ModuleProgress_ProcessedRanges

func (*ModuleProgress) GetType 

func (m *ModuleProgress) GetType() isModuleProgress_Type

func (*ModuleProgress) ProtoMessage 

func (*ModuleProgress) ProtoMessage()

func (*ModuleProgress) ProtoReflect 

func (x *ModuleProgress) ProtoReflect() protoreflect.Message

func (*ModuleProgress) Reset 

func (x *ModuleProgress) Reset()

func (*ModuleProgress) String 

func (x *ModuleProgress) String() string

type ModuleProgress_Failed 

type ModuleProgress_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
}

func (*ModuleProgress_Failed) Descriptor deprecated 

func (*ModuleProgress_Failed) Descriptor() ([]byte, []int)

Deprecated: Use ModuleProgress_Failed.ProtoReflect.Descriptor instead.

func (*ModuleProgress_Failed) GetLogs 

func (x *ModuleProgress_Failed) GetLogs() []string

func (*ModuleProgress_Failed) GetLogsTruncated 

func (x *ModuleProgress_Failed) GetLogsTruncated() bool

func (*ModuleProgress_Failed) GetReason 

func (x *ModuleProgress_Failed) GetReason() string

func (*ModuleProgress_Failed) ProtoMessage 

func (*ModuleProgress_Failed) ProtoMessage()

func (*ModuleProgress_Failed) ProtoReflect 

func (x *ModuleProgress_Failed) ProtoReflect() protoreflect.Message

func (*ModuleProgress_Failed) Reset 

func (x *ModuleProgress_Failed) Reset()

func (*ModuleProgress_Failed) String 

func (x *ModuleProgress_Failed) String() string

type ModuleProgress_Failed_ 

type ModuleProgress_Failed_ struct {
	Failed *ModuleProgress_Failed `protobuf:"bytes,5,opt,name=failed,proto3,oneof"`
}

type ModuleProgress_InitialState 

type ModuleProgress_InitialState struct {
	AvailableUpToBlock uint64 `protobuf:"varint,2,opt,name=available_up_to_block,json=availableUpToBlock,proto3" json:"available_up_to_block,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleProgress_InitialState) Descriptor deprecated 

func (*ModuleProgress_InitialState) Descriptor() ([]byte, []int)

Deprecated: Use ModuleProgress_InitialState.ProtoReflect.Descriptor instead.

func (*ModuleProgress_InitialState) GetAvailableUpToBlock 

func (x *ModuleProgress_InitialState) GetAvailableUpToBlock() uint64

func (*ModuleProgress_InitialState) ProtoMessage 

func (*ModuleProgress_InitialState) ProtoMessage()

func (*ModuleProgress_InitialState) ProtoReflect 

func (x *ModuleProgress_InitialState) ProtoReflect() protoreflect.Message

func (*ModuleProgress_InitialState) Reset 

func (x *ModuleProgress_InitialState) Reset()

func (*ModuleProgress_InitialState) String 

func (x *ModuleProgress_InitialState) String() string

type ModuleProgress_InitialState_ 

type ModuleProgress_InitialState_ struct {
	InitialState *ModuleProgress_InitialState `protobuf:"bytes,3,opt,name=initial_state,json=initialState,proto3,oneof"`
}

type ModuleProgress_ProcessedBytes 

type ModuleProgress_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"`
	BytesReadDelta    uint64 `protobuf:"varint,3,opt,name=bytes_read_delta,json=bytesReadDelta,proto3" json:"bytes_read_delta,omitempty"`
	BytesWrittenDelta uint64 `protobuf:"varint,4,opt,name=bytes_written_delta,json=bytesWrittenDelta,proto3" json:"bytes_written_delta,omitempty"`
	NanoSecondsDelta  uint64 `protobuf:"varint,5,opt,name=nano_seconds_delta,json=nanoSecondsDelta,proto3" json:"nano_seconds_delta,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleProgress_ProcessedBytes) Descriptor deprecated 

func (*ModuleProgress_ProcessedBytes) Descriptor() ([]byte, []int)

Deprecated: Use ModuleProgress_ProcessedBytes.ProtoReflect.Descriptor instead.

func (*ModuleProgress_ProcessedBytes) GetBytesReadDelta 

func (x *ModuleProgress_ProcessedBytes) GetBytesReadDelta() uint64

func (*ModuleProgress_ProcessedBytes) GetBytesWrittenDelta 

func (x *ModuleProgress_ProcessedBytes) GetBytesWrittenDelta() uint64

func (*ModuleProgress_ProcessedBytes) GetNanoSecondsDelta 

func (x *ModuleProgress_ProcessedBytes) GetNanoSecondsDelta() uint64

func (*ModuleProgress_ProcessedBytes) GetTotalBytesRead 

func (x *ModuleProgress_ProcessedBytes) GetTotalBytesRead() uint64

func (*ModuleProgress_ProcessedBytes) GetTotalBytesWritten 

func (x *ModuleProgress_ProcessedBytes) GetTotalBytesWritten() uint64

func (*ModuleProgress_ProcessedBytes) ProtoMessage 

func (*ModuleProgress_ProcessedBytes) ProtoMessage()

func (*ModuleProgress_ProcessedBytes) ProtoReflect 

func (x *ModuleProgress_ProcessedBytes) ProtoReflect() protoreflect.Message

func (*ModuleProgress_ProcessedBytes) Reset 

func (x *ModuleProgress_ProcessedBytes) Reset()

func (*ModuleProgress_ProcessedBytes) String 

func (x *ModuleProgress_ProcessedBytes) String() string

type ModuleProgress_ProcessedBytes_ 

type ModuleProgress_ProcessedBytes_ struct {
	ProcessedBytes *ModuleProgress_ProcessedBytes `protobuf:"bytes,4,opt,name=processed_bytes,json=processedBytes,proto3,oneof"`
}

type ModuleProgress_ProcessedRanges 

type ModuleProgress_ProcessedRanges struct {
	ProcessedRanges []*BlockRange `protobuf:"bytes,1,rep,name=processed_ranges,json=processedRanges,proto3" json:"processed_ranges,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleProgress_ProcessedRanges) Descriptor deprecated 

func (*ModuleProgress_ProcessedRanges) Descriptor() ([]byte, []int)

Deprecated: Use ModuleProgress_ProcessedRanges.ProtoReflect.Descriptor instead.

func (*ModuleProgress_ProcessedRanges) GetProcessedRanges 

func (x *ModuleProgress_ProcessedRanges) GetProcessedRanges() []*BlockRange

func (*ModuleProgress_ProcessedRanges) ProtoMessage 

func (*ModuleProgress_ProcessedRanges) ProtoMessage()

func (*ModuleProgress_ProcessedRanges) ProtoReflect 

func (x *ModuleProgress_ProcessedRanges) ProtoReflect() protoreflect.Message

func (*ModuleProgress_ProcessedRanges) Reset 

func (x *ModuleProgress_ProcessedRanges) Reset()

func (*ModuleProgress_ProcessedRanges) String 

func (x *ModuleProgress_ProcessedRanges) String() string

type ModuleProgress_ProcessedRanges_ 

type ModuleProgress_ProcessedRanges_ struct {
	ProcessedRanges *ModuleProgress_ProcessedRanges `protobuf:"bytes,2,opt,name=processed_ranges,json=processedRanges,proto3,oneof"`
}

type ModulesProgress 

type ModulesProgress struct {
	Modules []*ModuleProgress `protobuf:"bytes,1,rep,name=modules,proto3" json:"modules,omitempty"`
	// contains filtered or unexported fields
}

func (*ModulesProgress) Descriptor deprecated 

func (*ModulesProgress) Descriptor() ([]byte, []int)

Deprecated: Use ModulesProgress.ProtoReflect.Descriptor instead.

func (*ModulesProgress) GetModules 

func (x *ModulesProgress) GetModules() []*ModuleProgress

func (*ModulesProgress) ProtoMessage 

func (*ModulesProgress) ProtoMessage()

func (*ModulesProgress) ProtoReflect 

func (x *ModulesProgress) ProtoReflect() protoreflect.Message

func (*ModulesProgress) Reset 

func (x *ModulesProgress) Reset()

func (*ModulesProgress) String 

func (x *ModulesProgress) String() string

type OutputDebugInfo 

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
}

func (*OutputDebugInfo) Descriptor deprecated 

func (*OutputDebugInfo) Descriptor() ([]byte, []int)

Deprecated: Use OutputDebugInfo.ProtoReflect.Descriptor instead.

func (*OutputDebugInfo) GetCached 

func (x *OutputDebugInfo) GetCached() bool

func (*OutputDebugInfo) GetLogs 

func (x *OutputDebugInfo) GetLogs() []string

func (*OutputDebugInfo) GetLogsTruncated 

func (x *OutputDebugInfo) GetLogsTruncated() bool

func (*OutputDebugInfo) ProtoMessage 

func (*OutputDebugInfo) ProtoMessage()

func (*OutputDebugInfo) ProtoReflect 

func (x *OutputDebugInfo) ProtoReflect() protoreflect.Message

func (*OutputDebugInfo) Reset 

func (x *OutputDebugInfo) Reset()

func (*OutputDebugInfo) String 

func (x *OutputDebugInfo) String() string

type Request 

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
}

func TestNewRequest 

func TestNewRequest(startBlockNum int64, opts ...testNewRequestOption) *Request

func (*Request) Descriptor deprecated 

func (*Request) Descriptor() ([]byte, []int)

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetDebugInitialStoreSnapshotForModules 

func (x *Request) GetDebugInitialStoreSnapshotForModules() []string

func (*Request) GetFinalBlocksOnly 

func (x *Request) GetFinalBlocksOnly() bool

func (*Request) GetModules 

func (x *Request) GetModules() *v1.Modules

func (*Request) GetOutputModule 

func (x *Request) GetOutputModule() string

func (*Request) GetProductionMode 

func (x *Request) GetProductionMode() bool

func (*Request) GetStartBlockNum 

func (x *Request) GetStartBlockNum() int64

func (*Request) GetStartCursor 

func (x *Request) GetStartCursor() string

func (*Request) GetStopBlockNum 

func (x *Request) GetStopBlockNum() uint64

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

func (x *Request) ProtoReflect() protoreflect.Message

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

func (*Request) Validate 

func (req *Request) Validate() error

type Response 

type Response struct {

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

func (*Response) Descriptor deprecated 

func (*Response) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetBlockScopedData 

func (x *Response) GetBlockScopedData() *BlockScopedData

func (*Response) GetBlockUndoSignal 

func (x *Response) GetBlockUndoSignal() *BlockUndoSignal

func (*Response) GetDebugSnapshotComplete 

func (x *Response) GetDebugSnapshotComplete() *InitialSnapshotComplete

func (*Response) GetDebugSnapshotData 

func (x *Response) GetDebugSnapshotData() *InitialSnapshotData

func (*Response) GetMessage 

func (m *Response) GetMessage() isResponse_Message

func (*Response) GetProgress 

func (x *Response) GetProgress() *ModulesProgress

func (*Response) GetSession 

func (x *Response) GetSession() *SessionInit

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type Response_BlockScopedData 

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

type Response_BlockUndoSignal 

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

type Response_DebugSnapshotComplete 

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 

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_Progress 

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 

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

type SessionInit 

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
}

func (*SessionInit) Descriptor deprecated 

func (*SessionInit) Descriptor() ([]byte, []int)

Deprecated: Use SessionInit.ProtoReflect.Descriptor instead.

func (*SessionInit) GetLinearHandoffBlock added in v1.1.5 

func (x *SessionInit) GetLinearHandoffBlock() uint64

func (*SessionInit) GetMaxParallelWorkers added in v1.1.5 

func (x *SessionInit) GetMaxParallelWorkers() uint64

func (*SessionInit) GetResolvedStartBlock added in v1.1.5 

func (x *SessionInit) GetResolvedStartBlock() uint64

func (*SessionInit) GetTraceId 

func (x *SessionInit) GetTraceId() string

func (*SessionInit) ProtoMessage 

func (*SessionInit) ProtoMessage()

func (*SessionInit) ProtoReflect 

func (x *SessionInit) ProtoReflect() protoreflect.Message

func (*SessionInit) Reset 

func (x *SessionInit) Reset()

func (*SessionInit) String 

func (x *SessionInit) String() string

type StoreDelta 

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
}

func (*StoreDelta) Descriptor deprecated 

func (*StoreDelta) Descriptor() ([]byte, []int)

Deprecated: Use StoreDelta.ProtoReflect.Descriptor instead.

func (*StoreDelta) GetKey 

func (x *StoreDelta) GetKey() string

func (*StoreDelta) GetNewValue 

func (x *StoreDelta) GetNewValue() []byte

func (*StoreDelta) GetOldValue 

func (x *StoreDelta) GetOldValue() []byte

func (*StoreDelta) GetOperation 

func (x *StoreDelta) GetOperation() StoreDelta_Operation

func (*StoreDelta) GetOrdinal 

func (x *StoreDelta) GetOrdinal() uint64

func (*StoreDelta) ProtoMessage 

func (*StoreDelta) ProtoMessage()

func (*StoreDelta) ProtoReflect 

func (x *StoreDelta) ProtoReflect() protoreflect.Message

func (*StoreDelta) Reset 

func (x *StoreDelta) Reset()

func (*StoreDelta) String 

func (x *StoreDelta) String() string

type StoreDelta_Operation 

type StoreDelta_Operation int32
const (
	StoreDelta_UNSET  StoreDelta_Operation = 0
	StoreDelta_CREATE StoreDelta_Operation = 1
	StoreDelta_UPDATE StoreDelta_Operation = 2
	StoreDelta_DELETE StoreDelta_Operation = 3
)

func (StoreDelta_Operation) Descriptor 

func (StoreDelta_Operation) Descriptor() protoreflect.EnumDescriptor

func (StoreDelta_Operation) Enum 

func (x StoreDelta_Operation) Enum() *StoreDelta_Operation

func (StoreDelta_Operation) EnumDescriptor deprecated 

func (StoreDelta_Operation) EnumDescriptor() ([]byte, []int)

Deprecated: Use StoreDelta_Operation.Descriptor instead.

func (StoreDelta_Operation) Number 

func (x StoreDelta_Operation) Number() protoreflect.EnumNumber

func (StoreDelta_Operation) String 

func (x StoreDelta_Operation) String() string

func (StoreDelta_Operation) Type 

func (StoreDelta_Operation) Type() protoreflect.EnumType

type StoreModuleOutput 

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
}

StoreModuleOutput are produced for store modules in development mode. It is not possible to retrieve store models in production, with parallelization enabled. If you need the deltas directly, write a pass through mapper module that will get them down to you.

func (*StoreModuleOutput) Descriptor deprecated 

func (*StoreModuleOutput) Descriptor() ([]byte, []int)

Deprecated: Use StoreModuleOutput.ProtoReflect.Descriptor instead.

func (*StoreModuleOutput) GetDebugInfo 

func (x *StoreModuleOutput) GetDebugInfo() *OutputDebugInfo

func (*StoreModuleOutput) GetDebugStoreDeltas 

func (x *StoreModuleOutput) GetDebugStoreDeltas() []*StoreDelta

func (*StoreModuleOutput) GetName 

func (x *StoreModuleOutput) GetName() string

func (*StoreModuleOutput) ProtoMessage 

func (*StoreModuleOutput) ProtoMessage()

func (*StoreModuleOutput) ProtoReflect 

func (x *StoreModuleOutput) ProtoReflect() protoreflect.Message

func (*StoreModuleOutput) Reset 

func (x *StoreModuleOutput) Reset()

func (*StoreModuleOutput) String 

func (x *StoreModuleOutput) String() string

func (*StoreModuleOutput) ToAny 

func (s *StoreModuleOutput) ToAny() *AnyModuleOutput

type StreamClient 

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

StreamClient is the client API for Stream service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStreamClient 

func NewStreamClient(cc grpc.ClientConnInterface) StreamClient

type StreamServer 

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

StreamServer is the server API for Stream service. All implementations should embed UnimplementedStreamServer for forward compatibility

type Stream_BlocksClient 

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

type Stream_BlocksServer 

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

type UnimplementedStreamServer 

type UnimplementedStreamServer struct {
}

UnimplementedStreamServer should be embedded to have forward compatible implementations.

func (UnimplementedStreamServer) Blocks 

func (UnimplementedStreamServer) Blocks(*Request, Stream_BlocksServer) error

type UnsafeStreamServer 

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

UnsafeStreamServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamServer will result in compilation errors.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.