pbsubstreams

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Mar 7, 2023 License: Apache-2.0 Imports: 13 Imported by: 26

Documentation

Index

Constants

View Source 
const (
	ModuleKindStore = ModuleKind(iota)
	ModuleKindMap
)

Variables

View Source 
var (
	Module_KindStore_UpdatePolicy_name = map[int32]string{
		0: "UPDATE_POLICY_UNSET",
		1: "UPDATE_POLICY_SET",
		2: "UPDATE_POLICY_SET_IF_NOT_EXISTS",
		3: "UPDATE_POLICY_ADD",
		4: "UPDATE_POLICY_MIN",
		5: "UPDATE_POLICY_MAX",
		6: "UPDATE_POLICY_APPEND",
	}
	Module_KindStore_UpdatePolicy_value = map[string]int32{
		"UPDATE_POLICY_UNSET":             0,
		"UPDATE_POLICY_SET":               1,
		"UPDATE_POLICY_SET_IF_NOT_EXISTS": 2,
		"UPDATE_POLICY_ADD":               3,
		"UPDATE_POLICY_MIN":               4,
		"UPDATE_POLICY_MAX":               5,
		"UPDATE_POLICY_APPEND":            6,
	}
)

Enum value maps for Module_KindStore_UpdatePolicy.

View Source 
var (
	Module_Input_Store_Mode_name = map[int32]string{
		0: "UNSET",
		1: "GET",
		2: "DELTAS",
	}
	Module_Input_Store_Mode_value = map[string]int32{
		"UNSET":  0,
		"GET":    1,
		"DELTAS": 2,
	}
)

Enum value maps for Module_Input_Store_Mode.

View Source 
var (
	ForkStep_name = map[int32]string{
		0: "STEP_UNKNOWN",
		1: "STEP_NEW",
		2: "STEP_UNDO",
		4: "STEP_IRREVERSIBLE",
	}
	ForkStep_value = map[string]int32{
		"STEP_UNKNOWN":      0,
		"STEP_NEW":          1,
		"STEP_UNDO":         2,
		"STEP_IRREVERSIBLE": 4,
	}
)

Enum value maps for ForkStep.

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_v1_clock_proto protoreflect.FileDescriptor
View Source 
var File_sf_substreams_v1_modules_proto protoreflect.FileDescriptor
View Source 
var File_sf_substreams_v1_package_proto protoreflect.FileDescriptor
View Source 
var File_sf_substreams_v1_substreams_proto protoreflect.FileDescriptor
View Source 
var Stream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sf.substreams.v1.Stream",
	HandlerType: (*StreamServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Blocks",
			Handler:       _Stream_Blocks_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "sf/substreams/v1/substreams.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 ValidateRequest added in v0.0.14 

func ValidateRequest(req *Request, isSubRequest bool) error

Types

type Binary 

type Binary struct {
	Type    string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

Binary represents some code compiled to its binary form.

func (*Binary) Descriptor deprecated 

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

Deprecated: Use Binary.ProtoReflect.Descriptor instead.

func (*Binary) GetContent 

func (x *Binary) GetContent() []byte

func (*Binary) GetType 

func (x *Binary) GetType() string

func (*Binary) ProtoMessage 

func (*Binary) ProtoMessage()

func (*Binary) ProtoReflect 

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

func (*Binary) Reset 

func (x *Binary) Reset()

func (*Binary) String 

func (x *Binary) String() 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 {
	Outputs []*ModuleOutput `protobuf:"bytes,1,rep,name=outputs,proto3" json:"outputs,omitempty"`
	Clock   *Clock          `protobuf:"bytes,3,opt,name=clock,proto3" json:"clock,omitempty"`
	Step    ForkStep        `protobuf:"varint,6,opt,name=step,proto3,enum=sf.substreams.v1.ForkStep" json:"step,omitempty"`
	Cursor  string          `protobuf:"bytes,10,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// Potentially non-deterministic. Reserved for future use.
	FinalBlockHeight uint64 `protobuf:"varint,11,opt,name=final_block_height,json=finalBlockHeight,proto3" json:"final_block_height,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockScopedData) Descriptor deprecated 

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

Deprecated: Use BlockScopedData.ProtoReflect.Descriptor instead.

func (*BlockScopedData) GetClock 

func (x *BlockScopedData) GetClock() *Clock

func (*BlockScopedData) GetCursor 

func (x *BlockScopedData) GetCursor() string

func (*BlockScopedData) GetFinalBlockHeight added in v1.0.0 

func (x *BlockScopedData) GetFinalBlockHeight() uint64

func (*BlockScopedData) GetOutputs 

func (x *BlockScopedData) GetOutputs() []*ModuleOutput

func (*BlockScopedData) GetStep 

func (x *BlockScopedData) GetStep() ForkStep

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 Clock 

type Clock struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Number    uint64                 `protobuf:"varint,2,opt,name=number,proto3" json:"number,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Clock) Descriptor deprecated 

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

Deprecated: Use Clock.ProtoReflect.Descriptor instead.

func (*Clock) GetId 

func (x *Clock) GetId() string

func (*Clock) GetNumber 

func (x *Clock) GetNumber() uint64

func (*Clock) GetTimestamp 

func (x *Clock) GetTimestamp() *timestamppb.Timestamp

func (*Clock) ProtoMessage 

func (*Clock) ProtoMessage()

func (*Clock) ProtoReflect 

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

func (*Clock) Reset 

func (x *Clock) Reset()

func (*Clock) String 

func (x *Clock) String() string

type ForkStep 

type ForkStep int32
const (
	ForkStep_STEP_UNKNOWN ForkStep = 0
	// Block is new head block of the chain, that is linear with the previous block
	ForkStep_STEP_NEW ForkStep = 1
	// Block is now forked and should be undone, it's not the head block of the chain anymore
	ForkStep_STEP_UNDO ForkStep = 2
	// Block is now irreversible and can be committed to (finality is chain specific, see chain documentation for more details)
	ForkStep_STEP_IRREVERSIBLE ForkStep = 4
)

func StepToProto 

func StepToProto(step bstream.StepType, finalBlocksOnly bool) (out ForkStep, skip bool)

func (ForkStep) Descriptor 

func (ForkStep) Descriptor() protoreflect.EnumDescriptor

func (ForkStep) Enum 

func (x ForkStep) Enum() *ForkStep

func (ForkStep) EnumDescriptor deprecated 

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

Deprecated: Use ForkStep.Descriptor instead.

func (ForkStep) Number 

func (x ForkStep) Number() protoreflect.EnumNumber

func (ForkStep) String 

func (x ForkStep) String() string

func (ForkStep) Type 

func (ForkStep) Type() protoreflect.EnumType

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     *StoreDeltas `protobuf:"bytes,2,opt,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() *StoreDeltas

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 Module 

type Module struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to Kind:
	//
	//	*Module_KindMap_
	//	*Module_KindStore_
	Kind             isModule_Kind   `protobuf_oneof:"kind"`
	BinaryIndex      uint32          `protobuf:"varint,4,opt,name=binary_index,json=binaryIndex,proto3" json:"binary_index,omitempty"`
	BinaryEntrypoint string          `protobuf:"bytes,5,opt,name=binary_entrypoint,json=binaryEntrypoint,proto3" json:"binary_entrypoint,omitempty"`
	Inputs           []*Module_Input `protobuf:"bytes,6,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Output           *Module_Output  `protobuf:"bytes,7,opt,name=output,proto3" json:"output,omitempty"`
	InitialBlock     uint64          `protobuf:"varint,8,opt,name=initial_block,json=initialBlock,proto3" json:"initial_block,omitempty"`
	// contains filtered or unexported fields
}

func TestNewMapModule added in v0.1.0 

func TestNewMapModule(name string) *Module

func TestNewStoreModule added in v0.1.0 

func TestNewStoreModule(name string) *Module

func (*Module) Descriptor deprecated 

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

Deprecated: Use Module.ProtoReflect.Descriptor instead.

func (*Module) GetBinaryEntrypoint 

func (x *Module) GetBinaryEntrypoint() string

func (*Module) GetBinaryIndex 

func (x *Module) GetBinaryIndex() uint32

func (*Module) GetInitialBlock 

func (x *Module) GetInitialBlock() uint64

func (*Module) GetInputs 

func (x *Module) GetInputs() []*Module_Input

func (*Module) GetKind 

func (m *Module) GetKind() isModule_Kind

func (*Module) GetKindMap 

func (x *Module) GetKindMap() *Module_KindMap

func (*Module) GetKindStore 

func (x *Module) GetKindStore() *Module_KindStore

func (*Module) GetName 

func (x *Module) GetName() string

func (*Module) GetOutput 

func (x *Module) GetOutput() *Module_Output

func (*Module) ModuleKind added in v0.1.0 

func (x *Module) ModuleKind() ModuleKind

func (*Module) ProtoMessage 

func (*Module) ProtoMessage()

func (*Module) ProtoReflect 

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

func (*Module) Reset 

func (x *Module) Reset()

func (*Module) String 

func (x *Module) String() string

type ModuleKind added in v0.1.0 

type ModuleKind int

type ModuleMetadata 

type ModuleMetadata struct {

	// Corresponds to the index in `Package.metadata.package_meta`
	PackageIndex uint64 `protobuf:"varint,1,opt,name=package_index,json=packageIndex,proto3" json:"package_index,omitempty"`
	Doc          string `protobuf:"bytes,2,opt,name=doc,proto3" json:"doc,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleMetadata) Descriptor deprecated 

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

Deprecated: Use ModuleMetadata.ProtoReflect.Descriptor instead.

func (*ModuleMetadata) GetDoc 

func (x *ModuleMetadata) GetDoc() string

func (*ModuleMetadata) GetPackageIndex 

func (x *ModuleMetadata) GetPackageIndex() uint64

func (*ModuleMetadata) ProtoMessage 

func (*ModuleMetadata) ProtoMessage()

func (*ModuleMetadata) ProtoReflect 

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

func (*ModuleMetadata) Reset 

func (x *ModuleMetadata) Reset()

func (*ModuleMetadata) String 

func (x *ModuleMetadata) String() string

type ModuleOutput 

type ModuleOutput struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to Data:
	//
	//	*ModuleOutput_MapOutput
	//	*ModuleOutput_DebugStoreDeltas
	Data      isModuleOutput_Data `protobuf_oneof:"data"`
	DebugLogs []string            `protobuf:"bytes,4,rep,name=debug_logs,json=debugLogs,proto3" json:"debug_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).
	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
}

func (*ModuleOutput) Descriptor deprecated 

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

Deprecated: Use ModuleOutput.ProtoReflect.Descriptor instead.

func (*ModuleOutput) GetCached added in v0.1.0 

func (x *ModuleOutput) GetCached() bool

func (*ModuleOutput) GetData 

func (m *ModuleOutput) GetData() isModuleOutput_Data

func (*ModuleOutput) GetDebugLogs added in v0.1.0 

func (x *ModuleOutput) GetDebugLogs() []string

func (*ModuleOutput) GetDebugLogsTruncated added in v0.1.0 

func (x *ModuleOutput) GetDebugLogsTruncated() bool

func (*ModuleOutput) GetDebugStoreDeltas added in v0.1.0 

func (x *ModuleOutput) GetDebugStoreDeltas() *StoreDeltas

func (*ModuleOutput) GetMapOutput 

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

func (*ModuleOutput) GetName 

func (x *ModuleOutput) GetName() string

func (*ModuleOutput) ProtoMessage 

func (*ModuleOutput) ProtoMessage()

func (*ModuleOutput) ProtoReflect 

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

func (*ModuleOutput) Reset 

func (x *ModuleOutput) Reset()

func (*ModuleOutput) String 

func (x *ModuleOutput) String() string

type ModuleOutputData 

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

type ModuleOutput_DebugStoreDeltas added in v0.1.0 

type ModuleOutput_DebugStoreDeltas struct {
	// StoreDeltas 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.
	DebugStoreDeltas *StoreDeltas `protobuf:"bytes,3,opt,name=debug_store_deltas,json=debugStoreDeltas,proto3,oneof"`
}

type ModuleOutput_MapOutput 

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

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_ProcessedRange

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 added in v0.1.0 

func (x *ModuleProgress_ProcessedBytes) GetBytesReadDelta() uint64

func (*ModuleProgress_ProcessedBytes) GetBytesWrittenDelta added in v0.1.0 

func (x *ModuleProgress_ProcessedBytes) GetBytesWrittenDelta() uint64

func (*ModuleProgress_ProcessedBytes) GetNanoSecondsDelta added in v0.1.0 

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_ProcessedRange 

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

func (*ModuleProgress_ProcessedRange) Descriptor deprecated 

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

Deprecated: Use ModuleProgress_ProcessedRange.ProtoReflect.Descriptor instead.

func (*ModuleProgress_ProcessedRange) GetProcessedRanges 

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

func (*ModuleProgress_ProcessedRange) ProtoMessage 

func (*ModuleProgress_ProcessedRange) ProtoMessage()

func (*ModuleProgress_ProcessedRange) ProtoReflect 

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

func (*ModuleProgress_ProcessedRange) Reset 

func (x *ModuleProgress_ProcessedRange) Reset()

func (*ModuleProgress_ProcessedRange) String 

func (x *ModuleProgress_ProcessedRange) String() string

type ModuleProgress_ProcessedRanges 

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

type Module_Input 

type Module_Input struct {

	// Types that are assignable to Input:
	//
	//	*Module_Input_Source_
	//	*Module_Input_Map_
	//	*Module_Input_Store_
	//	*Module_Input_Params_
	Input isModule_Input_Input `protobuf_oneof:"input"`
	// contains filtered or unexported fields
}

func (*Module_Input) Descriptor deprecated 

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

Deprecated: Use Module_Input.ProtoReflect.Descriptor instead.

func (*Module_Input) GetInput 

func (m *Module_Input) GetInput() isModule_Input_Input

func (*Module_Input) GetMap 

func (x *Module_Input) GetMap() *Module_Input_Map

func (*Module_Input) GetParams added in v1.0.0 

func (x *Module_Input) GetParams() *Module_Input_Params

func (*Module_Input) GetSource 

func (x *Module_Input) GetSource() *Module_Input_Source

func (*Module_Input) GetStore 

func (x *Module_Input) GetStore() *Module_Input_Store

func (*Module_Input) ProtoMessage 

func (*Module_Input) ProtoMessage()

func (*Module_Input) ProtoReflect 

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

func (*Module_Input) Reset 

func (x *Module_Input) Reset()

func (*Module_Input) String 

func (x *Module_Input) String() string

type Module_Input_Map 

type Module_Input_Map struct {
	ModuleName string `protobuf:"bytes,1,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"` // ex: "block_to_pairs"
	// contains filtered or unexported fields
}

func (*Module_Input_Map) Descriptor deprecated 

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

Deprecated: Use Module_Input_Map.ProtoReflect.Descriptor instead.

func (*Module_Input_Map) GetModuleName 

func (x *Module_Input_Map) GetModuleName() string

func (*Module_Input_Map) ProtoMessage 

func (*Module_Input_Map) ProtoMessage()

func (*Module_Input_Map) ProtoReflect 

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

func (*Module_Input_Map) Reset 

func (x *Module_Input_Map) Reset()

func (*Module_Input_Map) String 

func (x *Module_Input_Map) String() string

type Module_Input_Map_ 

type Module_Input_Map_ struct {
	Map *Module_Input_Map `protobuf:"bytes,2,opt,name=map,proto3,oneof"`
}

type Module_Input_Params added in v1.0.0 

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

func (*Module_Input_Params) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use Module_Input_Params.ProtoReflect.Descriptor instead.

func (*Module_Input_Params) GetValue added in v1.0.0 

func (x *Module_Input_Params) GetValue() string

func (*Module_Input_Params) ProtoMessage added in v1.0.0 

func (*Module_Input_Params) ProtoMessage()

func (*Module_Input_Params) ProtoReflect added in v1.0.0 

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

func (*Module_Input_Params) Reset added in v1.0.0 

func (x *Module_Input_Params) Reset()

func (*Module_Input_Params) String added in v1.0.0 

func (x *Module_Input_Params) String() string

type Module_Input_Params_ added in v1.0.0 

type Module_Input_Params_ struct {
	Params *Module_Input_Params `protobuf:"bytes,4,opt,name=params,proto3,oneof"`
}

type Module_Input_Source 

type Module_Input_Source struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` // ex: "sf.ethereum.type.v1.Block"
	// contains filtered or unexported fields
}

func (*Module_Input_Source) Descriptor deprecated 

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

Deprecated: Use Module_Input_Source.ProtoReflect.Descriptor instead.

func (*Module_Input_Source) GetType 

func (x *Module_Input_Source) GetType() string

func (*Module_Input_Source) ProtoMessage 

func (*Module_Input_Source) ProtoMessage()

func (*Module_Input_Source) ProtoReflect 

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

func (*Module_Input_Source) Reset 

func (x *Module_Input_Source) Reset()

func (*Module_Input_Source) String 

func (x *Module_Input_Source) String() string

type Module_Input_Source_ 

type Module_Input_Source_ struct {
	Source *Module_Input_Source `protobuf:"bytes,1,opt,name=source,proto3,oneof"`
}

type Module_Input_Store 

type Module_Input_Store struct {
	ModuleName string                  `protobuf:"bytes,1,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
	Mode       Module_Input_Store_Mode `protobuf:"varint,2,opt,name=mode,proto3,enum=sf.substreams.v1.Module_Input_Store_Mode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*Module_Input_Store) Descriptor deprecated 

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

Deprecated: Use Module_Input_Store.ProtoReflect.Descriptor instead.

func (*Module_Input_Store) GetMode 

func (x *Module_Input_Store) GetMode() Module_Input_Store_Mode

func (*Module_Input_Store) GetModuleName 

func (x *Module_Input_Store) GetModuleName() string

func (*Module_Input_Store) ProtoMessage 

func (*Module_Input_Store) ProtoMessage()

func (*Module_Input_Store) ProtoReflect 

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

func (*Module_Input_Store) Reset 

func (x *Module_Input_Store) Reset()

func (*Module_Input_Store) String 

func (x *Module_Input_Store) String() string

type Module_Input_Store_ 

type Module_Input_Store_ struct {
	Store *Module_Input_Store `protobuf:"bytes,3,opt,name=store,proto3,oneof"`
}

type Module_Input_Store_Mode 

type Module_Input_Store_Mode int32
const (
	Module_Input_Store_UNSET  Module_Input_Store_Mode = 0
	Module_Input_Store_GET    Module_Input_Store_Mode = 1
	Module_Input_Store_DELTAS Module_Input_Store_Mode = 2
)

func (Module_Input_Store_Mode) Descriptor 

func (Module_Input_Store_Mode) Descriptor() protoreflect.EnumDescriptor

func (Module_Input_Store_Mode) Enum 

func (x Module_Input_Store_Mode) Enum() *Module_Input_Store_Mode

func (Module_Input_Store_Mode) EnumDescriptor deprecated 

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

Deprecated: Use Module_Input_Store_Mode.Descriptor instead.

func (Module_Input_Store_Mode) Number 

func (x Module_Input_Store_Mode) Number() protoreflect.EnumNumber

func (Module_Input_Store_Mode) String 

func (x Module_Input_Store_Mode) String() string

func (Module_Input_Store_Mode) Type 

func (Module_Input_Store_Mode) Type() protoreflect.EnumType

type Module_KindMap 

type Module_KindMap struct {
	OutputType string `protobuf:"bytes,1,opt,name=output_type,json=outputType,proto3" json:"output_type,omitempty"`
	// contains filtered or unexported fields
}

func (*Module_KindMap) Descriptor deprecated 

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

Deprecated: Use Module_KindMap.ProtoReflect.Descriptor instead.

func (*Module_KindMap) GetOutputType 

func (x *Module_KindMap) GetOutputType() string

func (*Module_KindMap) ProtoMessage 

func (*Module_KindMap) ProtoMessage()

func (*Module_KindMap) ProtoReflect 

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

func (*Module_KindMap) Reset 

func (x *Module_KindMap) Reset()

func (*Module_KindMap) String 

func (x *Module_KindMap) String() string

type Module_KindMap_ 

type Module_KindMap_ struct {
	KindMap *Module_KindMap `protobuf:"bytes,2,opt,name=kind_map,json=kindMap,proto3,oneof"`
}

type Module_KindStore 

type Module_KindStore struct {

	// The `update_policy` determines the functions available to mutate the store
	// (like `set()`, `set_if_not_exists()` or `sum()`, etc..) in
	// order to ensure that parallel operations are possible and deterministic
	//
	// Say a store cumulates keys from block 0 to 1M, and a second store
	// cumulates keys from block 1M to 2M. When we want to use this
	// store as a dependency for a downstream module, we will merge the
	// two stores according to this policy.
	UpdatePolicy Module_KindStore_UpdatePolicy `` /* 150-byte string literal not displayed */
	ValueType    string                        `protobuf:"bytes,2,opt,name=value_type,json=valueType,proto3" json:"value_type,omitempty"`
	// contains filtered or unexported fields
}

func (*Module_KindStore) Descriptor deprecated 

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

Deprecated: Use Module_KindStore.ProtoReflect.Descriptor instead.

func (*Module_KindStore) GetUpdatePolicy 

func (x *Module_KindStore) GetUpdatePolicy() Module_KindStore_UpdatePolicy

func (*Module_KindStore) GetValueType 

func (x *Module_KindStore) GetValueType() string

func (*Module_KindStore) ProtoMessage 

func (*Module_KindStore) ProtoMessage()

func (*Module_KindStore) ProtoReflect 

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

func (*Module_KindStore) Reset 

func (x *Module_KindStore) Reset()

func (*Module_KindStore) String 

func (x *Module_KindStore) String() string

type Module_KindStore_ 

type Module_KindStore_ struct {
	KindStore *Module_KindStore `protobuf:"bytes,3,opt,name=kind_store,json=kindStore,proto3,oneof"`
}

type Module_KindStore_UpdatePolicy 

type Module_KindStore_UpdatePolicy int32
const (
	Module_KindStore_UPDATE_POLICY_UNSET Module_KindStore_UpdatePolicy = 0
	// Provides a store where you can `set()` keys, and the latest key wins
	Module_KindStore_UPDATE_POLICY_SET Module_KindStore_UpdatePolicy = 1
	// Provides a store where you can `set_if_not_exists()` keys, and the first key wins
	Module_KindStore_UPDATE_POLICY_SET_IF_NOT_EXISTS Module_KindStore_UpdatePolicy = 2
	// Provides a store where you can `add_*()` keys, where two stores merge by summing its values.
	Module_KindStore_UPDATE_POLICY_ADD Module_KindStore_UpdatePolicy = 3
	// Provides a store where you can `min_*()` keys, where two stores merge by leaving the minimum value.
	Module_KindStore_UPDATE_POLICY_MIN Module_KindStore_UpdatePolicy = 4
	// Provides a store where you can `max_*()` keys, where two stores merge by leaving the maximum value.
	Module_KindStore_UPDATE_POLICY_MAX Module_KindStore_UpdatePolicy = 5
	// Provides a store where you can `append()` keys, where two stores merge by concatenating the bytes in order.
	Module_KindStore_UPDATE_POLICY_APPEND Module_KindStore_UpdatePolicy = 6
)

func (Module_KindStore_UpdatePolicy) Descriptor 

func (Module_KindStore_UpdatePolicy) Descriptor() protoreflect.EnumDescriptor

func (Module_KindStore_UpdatePolicy) Enum 

func (x Module_KindStore_UpdatePolicy) Enum() *Module_KindStore_UpdatePolicy

func (Module_KindStore_UpdatePolicy) EnumDescriptor deprecated 

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

Deprecated: Use Module_KindStore_UpdatePolicy.Descriptor instead.

func (Module_KindStore_UpdatePolicy) Number 

func (x Module_KindStore_UpdatePolicy) Number() protoreflect.EnumNumber

func (Module_KindStore_UpdatePolicy) String 

func (x Module_KindStore_UpdatePolicy) String() string

func (Module_KindStore_UpdatePolicy) Type 

func (Module_KindStore_UpdatePolicy) Type() protoreflect.EnumType

type Module_Output 

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

func (*Module_Output) Descriptor deprecated 

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

Deprecated: Use Module_Output.ProtoReflect.Descriptor instead.

func (*Module_Output) GetType 

func (x *Module_Output) GetType() string

func (*Module_Output) ProtoMessage 

func (*Module_Output) ProtoMessage()

func (*Module_Output) ProtoReflect 

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

func (*Module_Output) Reset 

func (x *Module_Output) Reset()

func (*Module_Output) String 

func (x *Module_Output) String() string

type Modules 

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

func (*Modules) Descriptor deprecated 

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

Deprecated: Use Modules.ProtoReflect.Descriptor instead.

func (*Modules) GetBinaries 

func (x *Modules) GetBinaries() []*Binary

func (*Modules) GetModules 

func (x *Modules) GetModules() []*Module

func (*Modules) ProtoMessage 

func (*Modules) ProtoMessage()

func (*Modules) ProtoReflect 

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

func (*Modules) Reset 

func (x *Modules) Reset()

func (*Modules) String 

func (x *Modules) String() string

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 Output 

type Output struct {
	BlockNum  uint64                 `protobuf:"varint,1,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"`
	BlockId   string                 `protobuf:"bytes,2,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     *anypb.Any             `protobuf:"bytes,10,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Output) Descriptor deprecated 

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

Deprecated: Use Output.ProtoReflect.Descriptor instead.

func (*Output) GetBlockId 

func (x *Output) GetBlockId() string

func (*Output) GetBlockNum 

func (x *Output) GetBlockNum() uint64

func (*Output) GetTimestamp 

func (x *Output) GetTimestamp() *timestamppb.Timestamp

func (*Output) GetValue 

func (x *Output) GetValue() *anypb.Any

func (*Output) ProtoMessage 

func (*Output) ProtoMessage()

func (*Output) ProtoReflect 

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

func (*Output) Reset 

func (x *Output) Reset()

func (*Output) String 

func (x *Output) String() string

type Package 

type Package struct {

	// Needs to be one so this file can be used _directly_ as a
	// buf `Image` andor a ProtoSet for grpcurl and other tools
	ProtoFiles  []*descriptorpb.FileDescriptorProto `protobuf:"bytes,1,rep,name=proto_files,json=protoFiles,proto3" json:"proto_files,omitempty"`
	Version     uint64                              `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	Modules     *Modules                            `protobuf:"bytes,6,opt,name=modules,proto3" json:"modules,omitempty"`
	ModuleMeta  []*ModuleMetadata                   `protobuf:"bytes,7,rep,name=module_meta,json=moduleMeta,proto3" json:"module_meta,omitempty"`
	PackageMeta []*PackageMetadata                  `protobuf:"bytes,8,rep,name=package_meta,json=packageMeta,proto3" json:"package_meta,omitempty"`
	// Source network for Substreams to fetch its data from.
	Network    string     `protobuf:"bytes,9,opt,name=network,proto3" json:"network,omitempty"`
	SinkConfig *anypb.Any `protobuf:"bytes,10,opt,name=sink_config,json=sinkConfig,proto3" json:"sink_config,omitempty"`
	SinkModule string     `protobuf:"bytes,11,opt,name=sink_module,json=sinkModule,proto3" json:"sink_module,omitempty"`
	// contains filtered or unexported fields
}

func (*Package) Descriptor deprecated 

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

Deprecated: Use Package.ProtoReflect.Descriptor instead.

func (*Package) GetModuleMeta 

func (x *Package) GetModuleMeta() []*ModuleMetadata

func (*Package) GetModules 

func (x *Package) GetModules() *Modules

func (*Package) GetNetwork added in v1.0.0 

func (x *Package) GetNetwork() string

func (*Package) GetPackageMeta 

func (x *Package) GetPackageMeta() []*PackageMetadata

func (*Package) GetProtoFiles 

func (x *Package) GetProtoFiles() []*descriptorpb.FileDescriptorProto

func (*Package) GetSinkConfig added in v1.0.0 

func (x *Package) GetSinkConfig() *anypb.Any

func (*Package) GetSinkModule added in v1.0.0 

func (x *Package) GetSinkModule() string

func (*Package) GetVersion 

func (x *Package) GetVersion() uint64

func (*Package) ProtoMessage 

func (*Package) ProtoMessage()

func (*Package) ProtoReflect 

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

func (*Package) Reset 

func (x *Package) Reset()

func (*Package) String 

func (x *Package) String() string

type PackageMetadata 

type PackageMetadata struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Url     string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Name    string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Doc     string `protobuf:"bytes,4,opt,name=doc,proto3" json:"doc,omitempty"`
	// contains filtered or unexported fields
}

func (*PackageMetadata) Descriptor deprecated 

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

Deprecated: Use PackageMetadata.ProtoReflect.Descriptor instead.

func (*PackageMetadata) GetDoc 

func (x *PackageMetadata) GetDoc() string

func (*PackageMetadata) GetName 

func (x *PackageMetadata) GetName() string

func (*PackageMetadata) GetUrl 

func (x *PackageMetadata) GetUrl() string

func (*PackageMetadata) GetVersion 

func (x *PackageMetadata) GetVersion() string

func (*PackageMetadata) ProtoMessage 

func (*PackageMetadata) ProtoMessage()

func (*PackageMetadata) ProtoReflect 

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

func (*PackageMetadata) Reset 

func (x *PackageMetadata) Reset()

func (*PackageMetadata) String 

func (x *PackageMetadata) 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"`
	ForkSteps                []ForkStep `` /* 127-byte string literal not displayed */
	IrreversibilityCondition string     `` /* 133-byte string literal not displayed */
	// 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,9,opt,name=production_mode,json=productionMode,proto3" json:"production_mode,omitempty"`
	Modules        *Modules `protobuf:"bytes,6,opt,name=modules,proto3" json:"modules,omitempty"`
	OutputModules  []string `protobuf:"bytes,7,rep,name=output_modules,json=outputModules,proto3" json:"output_modules,omitempty"`
	// Available only in developer mode
	DebugInitialStoreSnapshotForModules []string `` /* 174-byte string literal not displayed */
	OutputModule                        string   `protobuf:"bytes,10,opt,name=output_module,json=outputModule,proto3" json:"output_module,omitempty"`
	// contains filtered or unexported fields
}

func TestNewRequest added in v0.1.0 

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 added in v0.1.0 

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

func (*Request) GetForkSteps 

func (x *Request) GetForkSteps() []ForkStep

func (*Request) GetIrreversibilityCondition 

func (x *Request) GetIrreversibilityCondition() string

func (*Request) GetModules 

func (x *Request) GetModules() *Modules

func (*Request) GetOutputModule added in v0.1.0 

func (x *Request) GetOutputModule() string

func (*Request) GetOutputModuleName added in v0.1.0 

func (x *Request) GetOutputModuleName() (string, bool)

GetOutputModuleName is a helper to retrieve the output module name as we transition to a single output from either `OutputModule` (priority if non-empty) or `OutputModules`. If an output module was found, return `<name>, true` otherwise returns `"", false`.

func (*Request) GetOutputModules 

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

func (*Request) GetProductionMode added in v0.1.0 

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) MustGetOutputModuleName added in v0.2.0 

func (x *Request) MustGetOutputModuleName() string

MustGetOutputModuleName is like #GetOutputModuleName but panics if no output module is found.

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

type Response 

type Response struct {

	// Types that are assignable to Message:
	//
	//	*Response_Session
	//	*Response_Progress
	//	*Response_DebugSnapshotData
	//	*Response_DebugSnapshotComplete
	//	*Response_Data
	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) GetData 

func (x *Response) GetData() *BlockScopedData

func (*Response) GetDebugSnapshotComplete added in v0.1.0 

func (x *Response) GetDebugSnapshotComplete() *InitialSnapshotComplete

func (*Response) GetDebugSnapshotData added in v0.1.0 

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 added in v0.0.21 

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_Data 

type Response_Data struct {
	Data *BlockScopedData `protobuf:"bytes,4,opt,name=data,proto3,oneof"`
}

type Response_DebugSnapshotComplete added in v0.1.0 

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

type Response_DebugSnapshotData added in v0.1.0 

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

type Response_Progress 

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

type Response_Session added in v0.0.21 

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

type SessionInit added in v0.0.21 

type SessionInit struct {
	TraceId string `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionInit) Descriptor deprecated added in v0.0.21 

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

Deprecated: Use SessionInit.ProtoReflect.Descriptor instead.

func (*SessionInit) GetTraceId added in v0.0.21 

func (x *SessionInit) GetTraceId() string

func (*SessionInit) ProtoMessage added in v0.0.21 

func (*SessionInit) ProtoMessage()

func (*SessionInit) ProtoReflect added in v0.0.21 

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

func (*SessionInit) Reset added in v0.0.21 

func (x *SessionInit) Reset()

func (*SessionInit) String added in v0.0.21 

func (x *SessionInit) String() string

type StoreDelta 

type StoreDelta struct {
	Operation StoreDelta_Operation `protobuf:"varint,1,opt,name=operation,proto3,enum=sf.substreams.v1.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 StoreDeltas 

type StoreDeltas struct {
	Deltas []*StoreDelta `protobuf:"bytes,1,rep,name=deltas,proto3" json:"deltas,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreDeltas) Descriptor deprecated 

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

Deprecated: Use StoreDeltas.ProtoReflect.Descriptor instead.

func (*StoreDeltas) GetDeltas 

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

func (*StoreDeltas) ProtoMessage 

func (*StoreDeltas) ProtoMessage()

func (*StoreDeltas) ProtoReflect 

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

func (*StoreDeltas) Reset 

func (x *StoreDeltas) Reset()

func (*StoreDeltas) String 

func (x *StoreDeltas) String() string

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.