Documentation ¶
Index ¶
- Variables
- func RegisterSubstreamsServer(s grpc.ServiceRegistrar, srv SubstreamsServer)
- 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 Completed
- func (*Completed) Descriptor() ([]byte, []int)deprecated
- func (x *Completed) GetAllProcessedRanges() []*BlockRange
- func (x *Completed) GetTraceId() string
- func (*Completed) ProtoMessage()
- func (x *Completed) ProtoReflect() protoreflect.Message
- func (x *Completed) Reset()
- func (x *Completed) String() string
- type ExternalCallMetric
- func (*ExternalCallMetric) Descriptor() ([]byte, []int)deprecated
- func (x *ExternalCallMetric) GetCount() uint64
- func (x *ExternalCallMetric) GetName() string
- func (x *ExternalCallMetric) GetTimeMs() uint64
- func (*ExternalCallMetric) ProtoMessage()
- func (x *ExternalCallMetric) ProtoReflect() protoreflect.Message
- func (x *ExternalCallMetric) Reset()
- func (x *ExternalCallMetric) String() string
- type Failed
- func (*Failed) Descriptor() ([]byte, []int)deprecated
- func (x *Failed) GetLogs() []string
- func (x *Failed) GetLogsTruncated() bool
- func (x *Failed) GetReason() string
- func (*Failed) ProtoMessage()
- func (x *Failed) ProtoReflect() protoreflect.Message
- func (x *Failed) Reset()
- func (x *Failed) String() string
- type ModuleOutput
- func (*ModuleOutput) Descriptor() ([]byte, []int)deprecated
- func (x *ModuleOutput) GetCached() bool
- func (m *ModuleOutput) GetData() isModuleOutput_Data
- func (x *ModuleOutput) GetDebugLogsTruncated() bool
- func (x *ModuleOutput) GetLogs() []string
- func (x *ModuleOutput) GetMapOutput() *anypb.Any
- func (x *ModuleOutput) GetModuleName() 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 ModuleOutput_MapOutput
- type ModuleOutput_StoreDeltas
- type ModuleStats
- func (*ModuleStats) Descriptor() ([]byte, []int)deprecated
- func (x *ModuleStats) GetExternalCallMetrics() []*ExternalCallMetric
- func (x *ModuleStats) GetName() string
- func (x *ModuleStats) GetProcessingTimeMs() uint64
- func (x *ModuleStats) GetStoreDeleteprefixCount() uint64
- func (x *ModuleStats) GetStoreOperationTimeMs() uint64
- func (x *ModuleStats) GetStoreReadCount() uint64
- func (x *ModuleStats) GetStoreSizeBytes() uint64
- func (x *ModuleStats) GetStoreWriteCount() uint64
- func (*ModuleStats) ProtoMessage()
- func (x *ModuleStats) ProtoReflect() protoreflect.Message
- func (x *ModuleStats) Reset()
- func (x *ModuleStats) String() string
- type ProcessRangeRequest
- func (*ProcessRangeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessRangeRequest) GetModules() *v1.Modules
- func (x *ProcessRangeRequest) GetOutputModule() string
- func (x *ProcessRangeRequest) GetStage() uint32
- func (x *ProcessRangeRequest) GetStartBlockNum() uint64
- func (x *ProcessRangeRequest) GetStopBlockNum() uint64
- func (*ProcessRangeRequest) ProtoMessage()
- func (x *ProcessRangeRequest) ProtoReflect() protoreflect.Message
- func (x *ProcessRangeRequest) Reset()
- func (x *ProcessRangeRequest) String() string
- func (r *ProcessRangeRequest) Validate() error
- type ProcessRangeResponse
- func (*ProcessRangeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessRangeResponse) GetCompleted() *Completed
- func (x *ProcessRangeResponse) GetFailed() *Failed
- func (m *ProcessRangeResponse) GetType() isProcessRangeResponse_Type
- func (x *ProcessRangeResponse) GetUpdate() *Update
- func (*ProcessRangeResponse) ProtoMessage()
- func (x *ProcessRangeResponse) ProtoReflect() protoreflect.Message
- func (x *ProcessRangeResponse) Reset()
- func (x *ProcessRangeResponse) String() string
- type ProcessRangeResponse_Completed
- type ProcessRangeResponse_Failed
- type ProcessRangeResponse_Update
- 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 SubstreamsClient
- type SubstreamsServer
- type Substreams_ProcessRangeClient
- type Substreams_ProcessRangeServer
- type UnimplementedSubstreamsServer
- type UnsafeSubstreamsServer
- type Update
- func (*Update) Descriptor() ([]byte, []int)deprecated
- func (x *Update) GetDurationMs() uint64
- func (x *Update) GetModulesStats() []*ModuleStats
- func (x *Update) GetProcessedBlocks() uint64
- func (x *Update) GetTotalBytesRead() uint64
- func (x *Update) GetTotalBytesWritten() uint64
- func (*Update) ProtoMessage()
- func (x *Update) ProtoReflect() protoreflect.Message
- func (x *Update) Reset()
- func (x *Update) String() string
Constants ¶
This section is empty.
Variables ¶
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_intern_v2_deltas_proto protoreflect.FileDescriptor
var File_sf_substreams_intern_v2_service_proto protoreflect.FileDescriptor
var Substreams_ServiceDesc = grpc.ServiceDesc{ ServiceName: "sf.substreams.internal.v2.Substreams", HandlerType: (*SubstreamsServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "ProcessRange", Handler: _Substreams_ProcessRange_Handler, ServerStreams: true, }, }, Metadata: "sf/substreams/intern/v2/service.proto", }
Substreams_ServiceDesc is the grpc.ServiceDesc for Substreams service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSubstreamsServer ¶
func RegisterSubstreamsServer(s grpc.ServiceRegistrar, srv SubstreamsServer)
Types ¶
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 Completed ¶
type Completed struct { AllProcessedRanges []*BlockRange `protobuf:"bytes,1,rep,name=all_processed_ranges,json=allProcessedRanges,proto3" json:"all_processed_ranges,omitempty"` // TraceId represents the producer's trace id that produced the partial files. // This is present here so that the consumer can use it to identify the // right partial files that needs to be squashed together. // // The TraceId can be empty in which case it should be assumed by the tier1 // consuming this message that the tier2 that produced those partial files // is not yet updated to produce a trace id and a such, the tier1 should // generate a legacy partial file name. TraceId string `protobuf:"bytes,2,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // contains filtered or unexported fields }
func (*Completed) Descriptor
deprecated
func (*Completed) GetAllProcessedRanges ¶
func (x *Completed) GetAllProcessedRanges() []*BlockRange
func (*Completed) GetTraceId ¶ added in v1.1.3
func (*Completed) ProtoMessage ¶
func (*Completed) ProtoMessage()
func (*Completed) ProtoReflect ¶
func (x *Completed) ProtoReflect() protoreflect.Message
type ExternalCallMetric ¶ added in v1.1.12
type ExternalCallMetric struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Count uint64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` TimeMs uint64 `protobuf:"varint,3,opt,name=time_ms,json=timeMs,proto3" json:"time_ms,omitempty"` // contains filtered or unexported fields }
func (*ExternalCallMetric) Descriptor
deprecated
added in
v1.1.12
func (*ExternalCallMetric) Descriptor() ([]byte, []int)
Deprecated: Use ExternalCallMetric.ProtoReflect.Descriptor instead.
func (*ExternalCallMetric) GetCount ¶ added in v1.1.12
func (x *ExternalCallMetric) GetCount() uint64
func (*ExternalCallMetric) GetName ¶ added in v1.1.12
func (x *ExternalCallMetric) GetName() string
func (*ExternalCallMetric) GetTimeMs ¶ added in v1.1.12
func (x *ExternalCallMetric) GetTimeMs() uint64
func (*ExternalCallMetric) ProtoMessage ¶ added in v1.1.12
func (*ExternalCallMetric) ProtoMessage()
func (*ExternalCallMetric) ProtoReflect ¶ added in v1.1.12
func (x *ExternalCallMetric) ProtoReflect() protoreflect.Message
func (*ExternalCallMetric) Reset ¶ added in v1.1.12
func (x *ExternalCallMetric) Reset()
func (*ExternalCallMetric) String ¶ added in v1.1.12
func (x *ExternalCallMetric) String() string
type Failed ¶
type Failed struct { Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"` Logs []string `protobuf:"bytes,2,rep,name=logs,proto3" json:"logs,omitempty"` // FailureLogsTruncated is a flag that tells you if you received all the logs or if they // were truncated because you logged too much (fixed limit currently is set to 128 KiB). LogsTruncated bool `protobuf:"varint,3,opt,name=logs_truncated,json=logsTruncated,proto3" json:"logs_truncated,omitempty"` // contains filtered or unexported fields }
func (*Failed) Descriptor
deprecated
func (*Failed) GetLogsTruncated ¶
func (*Failed) ProtoMessage ¶
func (*Failed) ProtoMessage()
func (*Failed) ProtoReflect ¶
func (x *Failed) ProtoReflect() protoreflect.Message
type ModuleOutput ¶
type ModuleOutput struct { ModuleName string `protobuf:"bytes,1,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"` // Types that are assignable to Data: // // *ModuleOutput_MapOutput // *ModuleOutput_StoreDeltas Data isModuleOutput_Data `protobuf_oneof:"data"` Logs []string `protobuf:"bytes,4,rep,name=logs,proto3" json:"logs,omitempty"` DebugLogsTruncated bool `protobuf:"varint,5,opt,name=debug_logs_truncated,json=debugLogsTruncated,proto3" json:"debug_logs_truncated,omitempty"` Cached bool `protobuf:"varint,6,opt,name=cached,proto3" json:"cached,omitempty"` // contains filtered or unexported fields }
func (*ModuleOutput) Descriptor
deprecated
func (*ModuleOutput) Descriptor() ([]byte, []int)
Deprecated: Use ModuleOutput.ProtoReflect.Descriptor instead.
func (*ModuleOutput) GetCached ¶
func (x *ModuleOutput) GetCached() bool
func (*ModuleOutput) GetData ¶
func (m *ModuleOutput) GetData() isModuleOutput_Data
func (*ModuleOutput) GetDebugLogsTruncated ¶
func (x *ModuleOutput) GetDebugLogsTruncated() bool
func (*ModuleOutput) GetLogs ¶
func (x *ModuleOutput) GetLogs() []string
func (*ModuleOutput) GetMapOutput ¶
func (x *ModuleOutput) GetMapOutput() *anypb.Any
func (*ModuleOutput) GetModuleName ¶
func (x *ModuleOutput) GetModuleName() 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 ModuleOutput_MapOutput ¶
type ModuleOutput_StoreDeltas ¶
type ModuleOutput_StoreDeltas struct {
StoreDeltas *StoreDeltas `protobuf:"bytes,3,opt,name=store_deltas,json=storeDeltas,proto3,oneof"`
}
type ModuleStats ¶ added in v1.1.12
type ModuleStats struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` ProcessingTimeMs uint64 `protobuf:"varint,2,opt,name=processing_time_ms,json=processingTimeMs,proto3" json:"processing_time_ms,omitempty"` StoreOperationTimeMs uint64 `` /* 126-byte string literal not displayed */ StoreReadCount uint64 `protobuf:"varint,4,opt,name=store_read_count,json=storeReadCount,proto3" json:"store_read_count,omitempty"` ExternalCallMetrics []*ExternalCallMetric `protobuf:"bytes,5,rep,name=external_call_metrics,json=externalCallMetrics,proto3" json:"external_call_metrics,omitempty"` // store-specific (will be 0 on mappers) StoreWriteCount uint64 `protobuf:"varint,10,opt,name=store_write_count,json=storeWriteCount,proto3" json:"store_write_count,omitempty"` StoreDeleteprefixCount uint64 `` /* 131-byte string literal not displayed */ StoreSizeBytes uint64 `protobuf:"varint,12,opt,name=store_size_bytes,json=storeSizeBytes,proto3" json:"store_size_bytes,omitempty"` // contains filtered or unexported fields }
func (*ModuleStats) Descriptor
deprecated
added in
v1.1.12
func (*ModuleStats) Descriptor() ([]byte, []int)
Deprecated: Use ModuleStats.ProtoReflect.Descriptor instead.
func (*ModuleStats) GetExternalCallMetrics ¶ added in v1.1.12
func (x *ModuleStats) GetExternalCallMetrics() []*ExternalCallMetric
func (*ModuleStats) GetName ¶ added in v1.1.12
func (x *ModuleStats) GetName() string
func (*ModuleStats) GetProcessingTimeMs ¶ added in v1.1.12
func (x *ModuleStats) GetProcessingTimeMs() uint64
func (*ModuleStats) GetStoreDeleteprefixCount ¶ added in v1.1.12
func (x *ModuleStats) GetStoreDeleteprefixCount() uint64
func (*ModuleStats) GetStoreOperationTimeMs ¶ added in v1.1.12
func (x *ModuleStats) GetStoreOperationTimeMs() uint64
func (*ModuleStats) GetStoreReadCount ¶ added in v1.1.12
func (x *ModuleStats) GetStoreReadCount() uint64
func (*ModuleStats) GetStoreSizeBytes ¶ added in v1.1.12
func (x *ModuleStats) GetStoreSizeBytes() uint64
func (*ModuleStats) GetStoreWriteCount ¶ added in v1.1.12
func (x *ModuleStats) GetStoreWriteCount() uint64
func (*ModuleStats) ProtoMessage ¶ added in v1.1.12
func (*ModuleStats) ProtoMessage()
func (*ModuleStats) ProtoReflect ¶ added in v1.1.12
func (x *ModuleStats) ProtoReflect() protoreflect.Message
func (*ModuleStats) Reset ¶ added in v1.1.12
func (x *ModuleStats) Reset()
func (*ModuleStats) String ¶ added in v1.1.12
func (x *ModuleStats) String() string
type ProcessRangeRequest ¶
type ProcessRangeRequest struct { StartBlockNum uint64 `protobuf:"varint,1,opt,name=start_block_num,json=startBlockNum,proto3" json:"start_block_num,omitempty"` StopBlockNum uint64 `protobuf:"varint,2,opt,name=stop_block_num,json=stopBlockNum,proto3" json:"stop_block_num,omitempty"` OutputModule string `protobuf:"bytes,3,opt,name=output_module,json=outputModule,proto3" json:"output_module,omitempty"` Modules *v1.Modules `protobuf:"bytes,4,opt,name=modules,proto3" json:"modules,omitempty"` Stage uint32 `protobuf:"varint,5,opt,name=stage,proto3" json:"stage,omitempty"` // 0-based index of stage to execute up to // contains filtered or unexported fields }
func (*ProcessRangeRequest) Descriptor
deprecated
func (*ProcessRangeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProcessRangeRequest.ProtoReflect.Descriptor instead.
func (*ProcessRangeRequest) GetModules ¶
func (x *ProcessRangeRequest) GetModules() *v1.Modules
func (*ProcessRangeRequest) GetOutputModule ¶
func (x *ProcessRangeRequest) GetOutputModule() string
func (*ProcessRangeRequest) GetStage ¶ added in v1.1.9
func (x *ProcessRangeRequest) GetStage() uint32
func (*ProcessRangeRequest) GetStartBlockNum ¶
func (x *ProcessRangeRequest) GetStartBlockNum() uint64
func (*ProcessRangeRequest) GetStopBlockNum ¶
func (x *ProcessRangeRequest) GetStopBlockNum() uint64
func (*ProcessRangeRequest) ProtoMessage ¶
func (*ProcessRangeRequest) ProtoMessage()
func (*ProcessRangeRequest) ProtoReflect ¶
func (x *ProcessRangeRequest) ProtoReflect() protoreflect.Message
func (*ProcessRangeRequest) Reset ¶
func (x *ProcessRangeRequest) Reset()
func (*ProcessRangeRequest) String ¶
func (x *ProcessRangeRequest) String() string
func (*ProcessRangeRequest) Validate ¶
func (r *ProcessRangeRequest) Validate() error
type ProcessRangeResponse ¶
type ProcessRangeResponse struct { // Types that are assignable to Type: // // *ProcessRangeResponse_Failed // *ProcessRangeResponse_Completed // *ProcessRangeResponse_Update Type isProcessRangeResponse_Type `protobuf_oneof:"type"` // contains filtered or unexported fields }
func (*ProcessRangeResponse) Descriptor
deprecated
func (*ProcessRangeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProcessRangeResponse.ProtoReflect.Descriptor instead.
func (*ProcessRangeResponse) GetCompleted ¶
func (x *ProcessRangeResponse) GetCompleted() *Completed
func (*ProcessRangeResponse) GetFailed ¶
func (x *ProcessRangeResponse) GetFailed() *Failed
func (*ProcessRangeResponse) GetType ¶
func (m *ProcessRangeResponse) GetType() isProcessRangeResponse_Type
func (*ProcessRangeResponse) GetUpdate ¶ added in v1.1.12
func (x *ProcessRangeResponse) GetUpdate() *Update
func (*ProcessRangeResponse) ProtoMessage ¶
func (*ProcessRangeResponse) ProtoMessage()
func (*ProcessRangeResponse) ProtoReflect ¶
func (x *ProcessRangeResponse) ProtoReflect() protoreflect.Message
func (*ProcessRangeResponse) Reset ¶
func (x *ProcessRangeResponse) Reset()
func (*ProcessRangeResponse) String ¶
func (x *ProcessRangeResponse) String() string
type ProcessRangeResponse_Completed ¶
type ProcessRangeResponse_Completed struct {
Completed *Completed `protobuf:"bytes,5,opt,name=completed,proto3,oneof"`
}
type ProcessRangeResponse_Failed ¶
type ProcessRangeResponse_Failed struct {
Failed *Failed `protobuf:"bytes,4,opt,name=failed,proto3,oneof"`
}
type ProcessRangeResponse_Update ¶ added in v1.1.12
type ProcessRangeResponse_Update struct {
Update *Update `protobuf:"bytes,6,opt,name=update,proto3,oneof"`
}
type StoreDelta ¶
type StoreDelta struct { Operation StoreDelta_Operation `protobuf:"varint,1,opt,name=operation,proto3,enum=sf.substreams.internal.v2.StoreDelta_Operation" json:"operation,omitempty"` Ordinal uint64 `protobuf:"varint,2,opt,name=ordinal,proto3" json:"ordinal,omitempty"` Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` OldValue []byte `protobuf:"bytes,4,opt,name=old_value,json=oldValue,proto3" json:"old_value,omitempty"` NewValue []byte `protobuf:"bytes,5,opt,name=new_value,json=newValue,proto3" json:"new_value,omitempty"` // contains filtered or unexported fields }
func (*StoreDelta) Descriptor
deprecated
func (*StoreDelta) Descriptor() ([]byte, []int)
Deprecated: Use StoreDelta.ProtoReflect.Descriptor instead.
func (*StoreDelta) GetKey ¶
func (x *StoreDelta) GetKey() string
func (*StoreDelta) GetNewValue ¶
func (x *StoreDelta) GetNewValue() []byte
func (*StoreDelta) GetOldValue ¶
func (x *StoreDelta) GetOldValue() []byte
func (*StoreDelta) GetOperation ¶
func (x *StoreDelta) GetOperation() StoreDelta_Operation
func (*StoreDelta) GetOrdinal ¶
func (x *StoreDelta) GetOrdinal() uint64
func (*StoreDelta) ProtoMessage ¶
func (*StoreDelta) ProtoMessage()
func (*StoreDelta) ProtoReflect ¶
func (x *StoreDelta) ProtoReflect() protoreflect.Message
func (*StoreDelta) Reset ¶
func (x *StoreDelta) Reset()
func (*StoreDelta) String ¶
func (x *StoreDelta) String() string
type StoreDelta_Operation ¶
type StoreDelta_Operation int32
const ( StoreDelta_UNSET StoreDelta_Operation = 0 StoreDelta_CREATE StoreDelta_Operation = 1 StoreDelta_UPDATE StoreDelta_Operation = 2 StoreDelta_DELETE StoreDelta_Operation = 3 )
func (StoreDelta_Operation) Descriptor ¶
func (StoreDelta_Operation) Descriptor() protoreflect.EnumDescriptor
func (StoreDelta_Operation) Enum ¶
func (x StoreDelta_Operation) Enum() *StoreDelta_Operation
func (StoreDelta_Operation) EnumDescriptor
deprecated
func (StoreDelta_Operation) EnumDescriptor() ([]byte, []int)
Deprecated: Use StoreDelta_Operation.Descriptor instead.
func (StoreDelta_Operation) Number ¶
func (x StoreDelta_Operation) Number() protoreflect.EnumNumber
func (StoreDelta_Operation) String ¶
func (x StoreDelta_Operation) String() string
func (StoreDelta_Operation) Type ¶
func (StoreDelta_Operation) Type() protoreflect.EnumType
type StoreDeltas ¶
type StoreDeltas struct { StoreDeltas []*StoreDelta `protobuf:"bytes,1,rep,name=store_deltas,json=storeDeltas,proto3" json:"store_deltas,omitempty"` // contains filtered or unexported fields }
func (*StoreDeltas) Descriptor
deprecated
func (*StoreDeltas) Descriptor() ([]byte, []int)
Deprecated: Use StoreDeltas.ProtoReflect.Descriptor instead.
func (*StoreDeltas) GetStoreDeltas ¶
func (x *StoreDeltas) GetStoreDeltas() []*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 SubstreamsClient ¶
type SubstreamsClient interface {
ProcessRange(ctx context.Context, in *ProcessRangeRequest, opts ...grpc.CallOption) (Substreams_ProcessRangeClient, error)
}
SubstreamsClient is the client API for Substreams 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 NewSubstreamsClient ¶
func NewSubstreamsClient(cc grpc.ClientConnInterface) SubstreamsClient
type SubstreamsServer ¶
type SubstreamsServer interface {
ProcessRange(*ProcessRangeRequest, Substreams_ProcessRangeServer) error
}
SubstreamsServer is the server API for Substreams service. All implementations should embed UnimplementedSubstreamsServer for forward compatibility
type Substreams_ProcessRangeClient ¶
type Substreams_ProcessRangeClient interface { Recv() (*ProcessRangeResponse, error) grpc.ClientStream }
type Substreams_ProcessRangeServer ¶
type Substreams_ProcessRangeServer interface { Send(*ProcessRangeResponse) error grpc.ServerStream }
type UnimplementedSubstreamsServer ¶
type UnimplementedSubstreamsServer struct { }
UnimplementedSubstreamsServer should be embedded to have forward compatible implementations.
func (UnimplementedSubstreamsServer) ProcessRange ¶
func (UnimplementedSubstreamsServer) ProcessRange(*ProcessRangeRequest, Substreams_ProcessRangeServer) error
type UnsafeSubstreamsServer ¶
type UnsafeSubstreamsServer interface {
// contains filtered or unexported methods
}
UnsafeSubstreamsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SubstreamsServer will result in compilation errors.
type Update ¶ added in v1.1.12
type Update struct { DurationMs uint64 `protobuf:"varint,1,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"` ProcessedBlocks uint64 `protobuf:"varint,2,opt,name=processed_blocks,json=processedBlocks,proto3" json:"processed_blocks,omitempty"` TotalBytesRead uint64 `protobuf:"varint,3,opt,name=total_bytes_read,json=totalBytesRead,proto3" json:"total_bytes_read,omitempty"` TotalBytesWritten uint64 `protobuf:"varint,4,opt,name=total_bytes_written,json=totalBytesWritten,proto3" json:"total_bytes_written,omitempty"` ModulesStats []*ModuleStats `protobuf:"bytes,5,rep,name=modules_stats,json=modulesStats,proto3" json:"modules_stats,omitempty"` // contains filtered or unexported fields }
func (*Update) Descriptor
deprecated
added in
v1.1.12
func (*Update) GetDurationMs ¶ added in v1.1.12
func (*Update) GetModulesStats ¶ added in v1.1.12
func (x *Update) GetModulesStats() []*ModuleStats
func (*Update) GetProcessedBlocks ¶ added in v1.1.12
func (*Update) GetTotalBytesRead ¶ added in v1.1.12
func (*Update) GetTotalBytesWritten ¶ added in v1.1.12
func (*Update) ProtoMessage ¶ added in v1.1.12
func (*Update) ProtoMessage()
func (*Update) ProtoReflect ¶ added in v1.1.12
func (x *Update) ProtoReflect() protoreflect.Message