Documentation ¶
Index ¶
- Variables
- func RegisterStreamServer(s grpc.ServiceRegistrar, srv StreamServer)
- func ValidateRequest(req *Request) error
- type Binary
- type BlockRange
- func (*BlockRange) Descriptor() ([]byte, []int)deprecated
- func (x *BlockRange) GetEndBlock() uint64
- func (x *BlockRange) GetStartBlock() uint64
- func (*BlockRange) ProtoMessage()
- func (x *BlockRange) ProtoReflect() protoreflect.Message
- func (x *BlockRange) Reset()
- func (x *BlockRange) String() string
- type BlockScopedData
- func (*BlockScopedData) Descriptor() ([]byte, []int)deprecated
- func (x *BlockScopedData) GetClock() *Clock
- func (x *BlockScopedData) GetCursor() string
- func (x *BlockScopedData) GetOutputs() []*ModuleOutput
- func (x *BlockScopedData) GetStep() ForkStep
- func (*BlockScopedData) ProtoMessage()
- func (x *BlockScopedData) ProtoReflect() protoreflect.Message
- func (x *BlockScopedData) Reset()
- func (x *BlockScopedData) String() string
- type Clock
- func (*Clock) Descriptor() ([]byte, []int)deprecated
- func (x *Clock) GetId() string
- func (x *Clock) GetNumber() uint64
- func (x *Clock) GetTimestamp() *timestamppb.Timestamp
- func (*Clock) ProtoMessage()
- func (x *Clock) ProtoReflect() protoreflect.Message
- func (x *Clock) Reset()
- func (x *Clock) String() string
- type ForkStep
- type InitialSnapshotComplete
- func (*InitialSnapshotComplete) Descriptor() ([]byte, []int)deprecated
- func (x *InitialSnapshotComplete) GetCursor() string
- func (*InitialSnapshotComplete) ProtoMessage()
- func (x *InitialSnapshotComplete) ProtoReflect() protoreflect.Message
- func (x *InitialSnapshotComplete) Reset()
- func (x *InitialSnapshotComplete) String() string
- type InitialSnapshotData
- func (*InitialSnapshotData) Descriptor() ([]byte, []int)deprecated
- func (x *InitialSnapshotData) GetDeltas() *StoreDeltas
- func (x *InitialSnapshotData) GetModuleName() string
- func (x *InitialSnapshotData) GetSentKeys() uint64
- func (x *InitialSnapshotData) GetTotalKeys() uint64
- func (*InitialSnapshotData) ProtoMessage()
- func (x *InitialSnapshotData) ProtoReflect() protoreflect.Message
- func (x *InitialSnapshotData) Reset()
- func (x *InitialSnapshotData) String() string
- type Module
- func (*Module) Descriptor() ([]byte, []int)deprecated
- func (x *Module) GetBinaryEntrypoint() string
- func (x *Module) GetBinaryIndex() uint32
- func (x *Module) GetInitialBlock() uint64
- func (x *Module) GetInputs() []*Module_Input
- func (m *Module) GetKind() isModule_Kind
- func (x *Module) GetKindMap() *Module_KindMap
- func (x *Module) GetKindStore() *Module_KindStore
- func (x *Module) GetName() string
- func (x *Module) GetOutput() *Module_Output
- func (*Module) ProtoMessage()
- func (x *Module) ProtoReflect() protoreflect.Message
- func (x *Module) Reset()
- func (x *Module) String() string
- type ModuleMetadata
- func (*ModuleMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *ModuleMetadata) GetDoc() string
- func (x *ModuleMetadata) GetPackageIndex() uint64
- func (*ModuleMetadata) ProtoMessage()
- func (x *ModuleMetadata) ProtoReflect() protoreflect.Message
- func (x *ModuleMetadata) Reset()
- func (x *ModuleMetadata) String() string
- type ModuleOutput
- func (*ModuleOutput) Descriptor() ([]byte, []int)deprecated
- func (m *ModuleOutput) GetData() isModuleOutput_Data
- func (x *ModuleOutput) GetLogs() []string
- func (x *ModuleOutput) GetLogsTruncated() bool
- func (x *ModuleOutput) GetMapOutput() *anypb.Any
- func (x *ModuleOutput) GetName() string
- func (x *ModuleOutput) GetStoreDeltas() *StoreDeltas
- func (*ModuleOutput) ProtoMessage()
- func (x *ModuleOutput) ProtoReflect() protoreflect.Message
- func (x *ModuleOutput) Reset()
- func (x *ModuleOutput) String() string
- type ModuleOutputData
- type ModuleOutput_MapOutput
- type ModuleOutput_StoreDeltas
- type ModuleProgress
- func (*ModuleProgress) Descriptor() ([]byte, []int)deprecated
- func (x *ModuleProgress) GetFailed() *ModuleProgress_Failed
- func (x *ModuleProgress) GetInitialState() *ModuleProgress_InitialState
- func (x *ModuleProgress) GetName() string
- func (x *ModuleProgress) GetProcessedBytes() *ModuleProgress_ProcessedBytes
- func (x *ModuleProgress) GetProcessedRanges() *ModuleProgress_ProcessedRange
- func (m *ModuleProgress) GetType() isModuleProgress_Type
- func (*ModuleProgress) ProtoMessage()
- func (x *ModuleProgress) ProtoReflect() protoreflect.Message
- func (x *ModuleProgress) Reset()
- func (x *ModuleProgress) String() string
- type ModuleProgress_Failed
- func (*ModuleProgress_Failed) Descriptor() ([]byte, []int)deprecated
- func (x *ModuleProgress_Failed) GetLogs() []string
- func (x *ModuleProgress_Failed) GetLogsTruncated() bool
- func (x *ModuleProgress_Failed) GetReason() string
- func (*ModuleProgress_Failed) ProtoMessage()
- func (x *ModuleProgress_Failed) ProtoReflect() protoreflect.Message
- func (x *ModuleProgress_Failed) Reset()
- func (x *ModuleProgress_Failed) String() string
- type ModuleProgress_Failed_
- type ModuleProgress_InitialState
- func (*ModuleProgress_InitialState) Descriptor() ([]byte, []int)deprecated
- func (x *ModuleProgress_InitialState) GetAvailableUpToBlock() uint64
- func (*ModuleProgress_InitialState) ProtoMessage()
- func (x *ModuleProgress_InitialState) ProtoReflect() protoreflect.Message
- func (x *ModuleProgress_InitialState) Reset()
- func (x *ModuleProgress_InitialState) String() string
- type ModuleProgress_InitialState_
- type ModuleProgress_ProcessedBytes
- func (*ModuleProgress_ProcessedBytes) Descriptor() ([]byte, []int)deprecated
- func (x *ModuleProgress_ProcessedBytes) GetTotalBytesRead() uint64
- func (x *ModuleProgress_ProcessedBytes) GetTotalBytesWritten() uint64
- func (*ModuleProgress_ProcessedBytes) ProtoMessage()
- func (x *ModuleProgress_ProcessedBytes) ProtoReflect() protoreflect.Message
- func (x *ModuleProgress_ProcessedBytes) Reset()
- func (x *ModuleProgress_ProcessedBytes) String() string
- type ModuleProgress_ProcessedBytes_
- type ModuleProgress_ProcessedRange
- func (*ModuleProgress_ProcessedRange) Descriptor() ([]byte, []int)deprecated
- func (x *ModuleProgress_ProcessedRange) GetProcessedRanges() []*BlockRange
- func (*ModuleProgress_ProcessedRange) ProtoMessage()
- func (x *ModuleProgress_ProcessedRange) ProtoReflect() protoreflect.Message
- func (x *ModuleProgress_ProcessedRange) Reset()
- func (x *ModuleProgress_ProcessedRange) String() string
- type ModuleProgress_ProcessedRanges
- type Module_Input
- func (*Module_Input) Descriptor() ([]byte, []int)deprecated
- func (m *Module_Input) GetInput() isModule_Input_Input
- func (x *Module_Input) GetMap() *Module_Input_Map
- func (x *Module_Input) GetSource() *Module_Input_Source
- func (x *Module_Input) GetStore() *Module_Input_Store
- func (*Module_Input) ProtoMessage()
- func (x *Module_Input) ProtoReflect() protoreflect.Message
- func (x *Module_Input) Reset()
- func (x *Module_Input) String() string
- type Module_Input_Map
- type Module_Input_Map_
- type Module_Input_Source
- func (*Module_Input_Source) Descriptor() ([]byte, []int)deprecated
- func (x *Module_Input_Source) GetType() string
- func (*Module_Input_Source) ProtoMessage()
- func (x *Module_Input_Source) ProtoReflect() protoreflect.Message
- func (x *Module_Input_Source) Reset()
- func (x *Module_Input_Source) String() string
- type Module_Input_Source_
- type Module_Input_Store
- func (*Module_Input_Store) Descriptor() ([]byte, []int)deprecated
- func (x *Module_Input_Store) GetMode() Module_Input_Store_Mode
- func (x *Module_Input_Store) GetModuleName() string
- func (*Module_Input_Store) ProtoMessage()
- func (x *Module_Input_Store) ProtoReflect() protoreflect.Message
- func (x *Module_Input_Store) Reset()
- func (x *Module_Input_Store) String() string
- type Module_Input_Store_
- type Module_Input_Store_Mode
- func (Module_Input_Store_Mode) Descriptor() protoreflect.EnumDescriptor
- func (x Module_Input_Store_Mode) Enum() *Module_Input_Store_Mode
- func (Module_Input_Store_Mode) EnumDescriptor() ([]byte, []int)deprecated
- func (x Module_Input_Store_Mode) Number() protoreflect.EnumNumber
- func (x Module_Input_Store_Mode) String() string
- func (Module_Input_Store_Mode) Type() protoreflect.EnumType
- type Module_KindMap
- type Module_KindMap_
- type Module_KindStore
- func (*Module_KindStore) Descriptor() ([]byte, []int)deprecated
- func (x *Module_KindStore) GetUpdatePolicy() Module_KindStore_UpdatePolicy
- func (x *Module_KindStore) GetValueType() string
- func (*Module_KindStore) ProtoMessage()
- func (x *Module_KindStore) ProtoReflect() protoreflect.Message
- func (x *Module_KindStore) Reset()
- func (x *Module_KindStore) String() string
- type Module_KindStore_
- type Module_KindStore_UpdatePolicy
- func (Module_KindStore_UpdatePolicy) Descriptor() protoreflect.EnumDescriptor
- func (x Module_KindStore_UpdatePolicy) Enum() *Module_KindStore_UpdatePolicy
- func (Module_KindStore_UpdatePolicy) EnumDescriptor() ([]byte, []int)deprecated
- func (x Module_KindStore_UpdatePolicy) Number() protoreflect.EnumNumber
- func (x Module_KindStore_UpdatePolicy) String() string
- func (Module_KindStore_UpdatePolicy) Type() protoreflect.EnumType
- type Module_Output
- type Modules
- type ModulesProgress
- type Output
- func (*Output) Descriptor() ([]byte, []int)deprecated
- func (x *Output) GetBlockId() string
- func (x *Output) GetBlockNum() uint64
- func (x *Output) GetTimestamp() *timestamppb.Timestamp
- func (x *Output) GetValue() *anypb.Any
- func (*Output) ProtoMessage()
- func (x *Output) ProtoReflect() protoreflect.Message
- func (x *Output) Reset()
- func (x *Output) String() string
- type Package
- func (*Package) Descriptor() ([]byte, []int)deprecated
- func (x *Package) GetModuleMeta() []*ModuleMetadata
- func (x *Package) GetModules() *Modules
- func (x *Package) GetPackageMeta() []*PackageMetadata
- func (x *Package) GetProtoFiles() []*descriptorpb.FileDescriptorProto
- func (x *Package) GetVersion() uint64
- func (*Package) ProtoMessage()
- func (x *Package) ProtoReflect() protoreflect.Message
- func (x *Package) Reset()
- func (x *Package) String() string
- type PackageMetadata
- func (*PackageMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *PackageMetadata) GetDoc() string
- func (x *PackageMetadata) GetName() string
- func (x *PackageMetadata) GetUrl() string
- func (x *PackageMetadata) GetVersion() string
- func (*PackageMetadata) ProtoMessage()
- func (x *PackageMetadata) ProtoReflect() protoreflect.Message
- func (x *PackageMetadata) Reset()
- func (x *PackageMetadata) String() string
- type Request
- func (*Request) Descriptor() ([]byte, []int)deprecated
- func (x *Request) GetForkSteps() []ForkStep
- func (x *Request) GetInitialStoreSnapshotForModules() []string
- func (x *Request) GetIrreversibilityCondition() string
- func (x *Request) GetModules() *Modules
- func (x *Request) GetOutputModules() []string
- func (x *Request) GetStartBlockNum() int64
- func (x *Request) GetStartCursor() string
- func (x *Request) GetStopBlockNum() uint64
- func (*Request) ProtoMessage()
- func (x *Request) ProtoReflect() protoreflect.Message
- func (x *Request) Reset()
- func (x *Request) String() string
- type Response
- func (*Response) Descriptor() ([]byte, []int)deprecated
- func (x *Response) GetData() *BlockScopedData
- func (m *Response) GetMessage() isResponse_Message
- func (x *Response) GetProgress() *ModulesProgress
- func (x *Response) GetSnapshotComplete() *InitialSnapshotComplete
- func (x *Response) GetSnapshotData() *InitialSnapshotData
- func (*Response) ProtoMessage()
- func (x *Response) ProtoReflect() protoreflect.Message
- func (x *Response) Reset()
- func (x *Response) String() string
- type Response_Data
- type Response_Progress
- type Response_SnapshotComplete
- type Response_SnapshotData
- type StoreDelta
- func (*StoreDelta) Descriptor() ([]byte, []int)deprecated
- func (x *StoreDelta) GetKey() string
- func (x *StoreDelta) GetNewValue() []byte
- func (x *StoreDelta) GetOldValue() []byte
- func (x *StoreDelta) GetOperation() StoreDelta_Operation
- func (x *StoreDelta) GetOrdinal() uint64
- func (*StoreDelta) ProtoMessage()
- func (x *StoreDelta) ProtoReflect() protoreflect.Message
- func (x *StoreDelta) Reset()
- func (x *StoreDelta) String() string
- type StoreDelta_Operation
- func (StoreDelta_Operation) Descriptor() protoreflect.EnumDescriptor
- func (x StoreDelta_Operation) Enum() *StoreDelta_Operation
- func (StoreDelta_Operation) EnumDescriptor() ([]byte, []int)deprecated
- func (x StoreDelta_Operation) Number() protoreflect.EnumNumber
- func (x StoreDelta_Operation) String() string
- func (StoreDelta_Operation) Type() protoreflect.EnumType
- type StoreDeltas
- type StreamClient
- type StreamServer
- type Stream_BlocksClient
- type Stream_BlocksServer
- type UnimplementedStreamServer
- type UnsafeStreamServer
Constants ¶
This section is empty.
Variables ¶
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.
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.
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.
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.
var File_sf_substreams_v1_clock_proto protoreflect.FileDescriptor
var File_sf_substreams_v1_modules_proto protoreflect.FileDescriptor
var File_sf_substreams_v1_package_proto protoreflect.FileDescriptor
var File_sf_substreams_v1_substreams_proto protoreflect.FileDescriptor
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
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) GetContent ¶
func (*Binary) ProtoMessage ¶
func (*Binary) ProtoMessage()
func (*Binary) ProtoReflect ¶
func (x *Binary) ProtoReflect() protoreflect.Message
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"` // 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) 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) GetTimestamp ¶
func (x *Clock) GetTimestamp() *timestamppb.Timestamp
func (*Clock) ProtoMessage ¶
func (*Clock) ProtoMessage()
func (*Clock) ProtoReflect ¶
func (x *Clock) ProtoReflect() protoreflect.Message
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 (ForkStep) Descriptor ¶
func (ForkStep) Descriptor() protoreflect.EnumDescriptor
func (ForkStep) EnumDescriptor
deprecated
func (ForkStep) Number ¶
func (x ForkStep) Number() protoreflect.EnumNumber
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 (*Module) Descriptor
deprecated
func (*Module) GetBinaryEntrypoint ¶
func (*Module) GetBinaryIndex ¶
func (*Module) GetInitialBlock ¶
func (*Module) GetInputs ¶
func (x *Module) GetInputs() []*Module_Input
func (*Module) GetKindMap ¶
func (x *Module) GetKindMap() *Module_KindMap
func (*Module) GetKindStore ¶
func (x *Module) GetKindStore() *Module_KindStore
func (*Module) GetOutput ¶
func (x *Module) GetOutput() *Module_Output
func (*Module) ProtoMessage ¶
func (*Module) ProtoMessage()
func (*Module) ProtoReflect ¶
func (x *Module) ProtoReflect() protoreflect.Message
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_StoreDeltas Data isModuleOutput_Data `protobuf_oneof:"data"` Logs []string `protobuf:"bytes,4,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,5,opt,name=logs_truncated,json=logsTruncated,proto3" json:"logs_truncated,omitempty"` // contains filtered or unexported fields }
func (*ModuleOutput) Descriptor
deprecated
func (*ModuleOutput) Descriptor() ([]byte, []int)
Deprecated: Use ModuleOutput.ProtoReflect.Descriptor instead.
func (*ModuleOutput) GetData ¶
func (m *ModuleOutput) GetData() isModuleOutput_Data
func (*ModuleOutput) GetLogs ¶
func (x *ModuleOutput) GetLogs() []string
func (*ModuleOutput) GetLogsTruncated ¶
func (x *ModuleOutput) GetLogsTruncated() bool
func (*ModuleOutput) GetMapOutput ¶
func (x *ModuleOutput) GetMapOutput() *anypb.Any
func (*ModuleOutput) GetName ¶
func (x *ModuleOutput) GetName() string
func (*ModuleOutput) GetStoreDeltas ¶
func (x *ModuleOutput) GetStoreDeltas() *StoreDeltas
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_MapOutput ¶
type ModuleOutput_StoreDeltas ¶
type ModuleOutput_StoreDeltas struct {
StoreDeltas *StoreDeltas `protobuf:"bytes,3,opt,name=store_deltas,json=storeDeltas,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"` // 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) 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_ 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) 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_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) GetBinaries ¶
func (*Modules) GetModules ¶
func (*Modules) ProtoMessage ¶
func (*Modules) ProtoMessage()
func (*Modules) ProtoReflect ¶
func (x *Modules) ProtoReflect() protoreflect.Message
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) GetBlockId ¶
func (*Output) GetBlockNum ¶
func (*Output) GetTimestamp ¶
func (x *Output) GetTimestamp() *timestamppb.Timestamp
func (*Output) ProtoMessage ¶
func (*Output) ProtoMessage()
func (*Output) ProtoReflect ¶
func (x *Output) ProtoReflect() protoreflect.Message
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"` // contains filtered or unexported fields }
func (*Package) Descriptor
deprecated
func (*Package) GetModuleMeta ¶
func (x *Package) GetModuleMeta() []*ModuleMetadata
func (*Package) GetModules ¶
func (*Package) GetPackageMeta ¶
func (x *Package) GetPackageMeta() []*PackageMetadata
func (*Package) GetProtoFiles ¶
func (x *Package) GetProtoFiles() []*descriptorpb.FileDescriptorProto
func (*Package) GetVersion ¶
func (*Package) ProtoMessage ¶
func (*Package) ProtoMessage()
func (*Package) ProtoReflect ¶
func (x *Package) ProtoReflect() protoreflect.Message
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 */ 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"` InitialStoreSnapshotForModules []string `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Request) Descriptor
deprecated
func (*Request) GetForkSteps ¶
func (*Request) GetInitialStoreSnapshotForModules ¶
func (*Request) GetIrreversibilityCondition ¶
func (*Request) GetModules ¶
func (*Request) GetOutputModules ¶
func (*Request) GetStartBlockNum ¶
func (*Request) GetStartCursor ¶
func (*Request) GetStopBlockNum ¶
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) ProtoReflect ¶
func (x *Request) ProtoReflect() protoreflect.Message
type Response ¶
type Response struct { // Types that are assignable to Message: // *Response_Progress // *Response_SnapshotData // *Response_SnapshotComplete // *Response_Data Message isResponse_Message `protobuf_oneof:"message"` // contains filtered or unexported fields }
func (*Response) Descriptor
deprecated
func (*Response) GetData ¶
func (x *Response) GetData() *BlockScopedData
func (*Response) GetMessage ¶
func (m *Response) GetMessage() isResponse_Message
func (*Response) GetProgress ¶
func (x *Response) GetProgress() *ModulesProgress
func (*Response) GetSnapshotComplete ¶
func (x *Response) GetSnapshotComplete() *InitialSnapshotComplete
func (*Response) GetSnapshotData ¶
func (x *Response) GetSnapshotData() *InitialSnapshotData
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type Response_Data ¶
type Response_Data struct {
Data *BlockScopedData `protobuf:"bytes,4,opt,name=data,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_SnapshotComplete ¶
type Response_SnapshotComplete struct {
SnapshotComplete *InitialSnapshotComplete `protobuf:"bytes,3,opt,name=snapshot_complete,json=snapshotComplete,proto3,oneof"`
}
type Response_SnapshotData ¶
type Response_SnapshotData struct {
SnapshotData *InitialSnapshotData `protobuf:"bytes,2,opt,name=snapshot_data,json=snapshotData,proto3,oneof"`
}
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.