pbssinternal

package
v1.10.6 Latest Latest
Warning

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

 Go to latest Published: Sep 19, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Substreams_ProcessRange_FullMethodName = "/sf.substreams.internal.v2.Substreams/ProcessRange"
)

Variables

View Source 
var (
	Operation_Type_name = map[int32]string{
		0:  "SET",
		1:  "SET_BYTES",
		2:  "SET_IF_NOT_EXISTS",
		3:  "SET_BYTES_IF_NOT_EXISTS",
		4:  "APPEND",
		5:  "DELETE_PREFIX",
		6:  "SET_MAX_BIG_INT",
		7:  "SET_MAX_INT64",
		8:  "SET_MAX_FLOAT64",
		9:  "SET_MAX_BIG_DECIMAL",
		10: "SET_MIN_BIG_INT",
		11: "SET_MIN_INT64",
		12: "SET_MIN_FLOAT64",
		13: "SET_MIN_BIG_DECIMAL",
		14: "SUM_BIG_INT",
		15: "SUM_INT64",
		16: "SUM_FLOAT64",
		17: "SUM_BIG_DECIMAL",
		18: "SET_SUM_INT64",
		19: "SET_SUM_FLOAT64",
		20: "SET_SUM_BIG_INT",
		21: "SET_SUM_BIG_DECIMAL",
	}
	Operation_Type_value = map[string]int32{
		"SET":                     0,
		"SET_BYTES":               1,
		"SET_IF_NOT_EXISTS":       2,
		"SET_BYTES_IF_NOT_EXISTS": 3,
		"APPEND":                  4,
		"DELETE_PREFIX":           5,
		"SET_MAX_BIG_INT":         6,
		"SET_MAX_INT64":           7,
		"SET_MAX_FLOAT64":         8,
		"SET_MAX_BIG_DECIMAL":     9,
		"SET_MIN_BIG_INT":         10,
		"SET_MIN_INT64":           11,
		"SET_MIN_FLOAT64":         12,
		"SET_MIN_BIG_DECIMAL":     13,
		"SUM_BIG_INT":             14,
		"SUM_INT64":               15,
		"SUM_FLOAT64":             16,
		"SUM_BIG_DECIMAL":         17,
		"SET_SUM_INT64":           18,
		"SET_SUM_FLOAT64":         19,
		"SET_SUM_BIG_INT":         20,
		"SET_SUM_BIG_DECIMAL":     21,
	}
)

Enum value maps for Operation_Type.

View Source 
var (
	WASMModuleType_name = map[int32]string{
		0: "WASM_MODULE_TYPE_UNSPECIFIED",
		1: "WASM_MODULE_TYPE_RPC_CALL",
	}
	WASMModuleType_value = map[string]int32{
		"WASM_MODULE_TYPE_UNSPECIFIED": 0,
		"WASM_MODULE_TYPE_RPC_CALL":    1,
	}
)

Enum value maps for WASMModuleType.

View Source 
var File_sf_substreams_intern_v2_deltas_proto protoreflect.FileDescriptor
View Source 
var File_sf_substreams_intern_v2_service_proto protoreflect.FileDescriptor
View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Completed.ProtoReflect.Descriptor instead.

func (*Completed) GetAllProcessedRanges 

func (x *Completed) GetAllProcessedRanges() []*BlockRange

func (*Completed) GetTraceId added in v1.1.3 

func (x *Completed) GetTraceId() string

func (*Completed) ProtoMessage 

func (*Completed) ProtoMessage()

func (*Completed) ProtoReflect 

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

func (*Completed) Reset 

func (x *Completed) Reset()

func (*Completed) String 

func (x *Completed) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Failed.ProtoReflect.Descriptor instead.

func (*Failed) GetLogs 

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

func (*Failed) GetLogsTruncated 

func (x *Failed) GetLogsTruncated() bool

func (*Failed) GetReason 

func (x *Failed) GetReason() string

func (*Failed) ProtoMessage 

func (*Failed) ProtoMessage()

func (*Failed) ProtoReflect 

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

func (*Failed) Reset 

func (x *Failed) Reset()

func (*Failed) String 

func (x *Failed) String() string

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() *v1.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_MapOutput struct {
	MapOutput *anypb.Any `protobuf:"bytes,2,opt,name=map_output,json=mapOutput,proto3,oneof"`
}

type ModuleOutput_StoreDeltas 

type ModuleOutput_StoreDeltas struct {
	StoreDeltas *v1.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 Operation added in v1.4.0 

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

func (*Operation) Descriptor deprecated added in v1.4.0 

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

Deprecated: Use Operation.ProtoReflect.Descriptor instead.

func (*Operation) GetKey added in v1.4.0 

func (x *Operation) GetKey() string

func (*Operation) GetOrd added in v1.4.0 

func (x *Operation) GetOrd() uint64

func (*Operation) GetType added in v1.4.0 

func (x *Operation) GetType() Operation_Type

func (*Operation) GetValue added in v1.4.0 

func (x *Operation) GetValue() []byte

func (*Operation) ProtoMessage added in v1.4.0 

func (*Operation) ProtoMessage()

func (*Operation) ProtoReflect added in v1.4.0 

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

func (*Operation) Reset added in v1.4.0 

func (x *Operation) Reset()

func (*Operation) String added in v1.4.0 

func (x *Operation) String() string

type Operation_Type added in v1.4.0 

type Operation_Type int32
const (
	Operation_SET                     Operation_Type = 0
	Operation_SET_BYTES               Operation_Type = 1
	Operation_SET_IF_NOT_EXISTS       Operation_Type = 2
	Operation_SET_BYTES_IF_NOT_EXISTS Operation_Type = 3
	Operation_APPEND                  Operation_Type = 4
	Operation_DELETE_PREFIX           Operation_Type = 5
	Operation_SET_MAX_BIG_INT         Operation_Type = 6
	Operation_SET_MAX_INT64           Operation_Type = 7
	Operation_SET_MAX_FLOAT64         Operation_Type = 8
	Operation_SET_MAX_BIG_DECIMAL     Operation_Type = 9
	Operation_SET_MIN_BIG_INT         Operation_Type = 10
	Operation_SET_MIN_INT64           Operation_Type = 11
	Operation_SET_MIN_FLOAT64         Operation_Type = 12
	Operation_SET_MIN_BIG_DECIMAL     Operation_Type = 13
	Operation_SUM_BIG_INT             Operation_Type = 14
	Operation_SUM_INT64               Operation_Type = 15
	Operation_SUM_FLOAT64             Operation_Type = 16
	Operation_SUM_BIG_DECIMAL         Operation_Type = 17
	Operation_SET_SUM_INT64           Operation_Type = 18
	Operation_SET_SUM_FLOAT64         Operation_Type = 19
	Operation_SET_SUM_BIG_INT         Operation_Type = 20
	Operation_SET_SUM_BIG_DECIMAL     Operation_Type = 21
)

func (Operation_Type) Descriptor added in v1.4.0 

func (Operation_Type) Descriptor() protoreflect.EnumDescriptor

func (Operation_Type) Enum added in v1.4.0 

func (x Operation_Type) Enum() *Operation_Type

func (Operation_Type) EnumDescriptor deprecated added in v1.4.0 

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

Deprecated: Use Operation_Type.Descriptor instead.

func (Operation_Type) Number added in v1.4.0 

func (x Operation_Type) Number() protoreflect.EnumNumber

func (Operation_Type) String added in v1.4.0 

func (x Operation_Type) String() string

func (Operation_Type) Type added in v1.4.0 

func (Operation_Type) Type() protoreflect.EnumType

type Operations added in v1.4.0 

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

func (*Operations) Add added in v1.5.6 

func (o *Operations) Add(op *Operation)

func (*Operations) Descriptor deprecated added in v1.4.0 

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

Deprecated: Use Operations.ProtoReflect.Descriptor instead.

func (*Operations) GetOperations added in v1.4.0 

func (x *Operations) GetOperations() []*Operation

func (*Operations) ProtoMessage added in v1.4.0 

func (*Operations) ProtoMessage()

func (*Operations) ProtoReflect added in v1.4.0 

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

func (*Operations) Reset added in v1.4.0 

func (x *Operations) Reset()

func (*Operations) Sort added in v1.5.6 

func (o *Operations) Sort()

func (*Operations) String added in v1.4.0 

func (x *Operations) String() string

type ProcessRangeRequest 

type ProcessRangeRequest struct {

	// Deprecated: Marked as deprecated in sf/substreams/intern/v2/service.proto.
	StopBlockNum         uint64            `protobuf:"varint,2,opt,name=stop_block_num,json=stopBlockNum,proto3" json:"stop_block_num,omitempty"`
	OutputModule         string            `protobuf:"bytes,3,opt,name=output_module,json=outputModule,proto3" json:"output_module,omitempty"`
	Modules              *v1.Modules       `protobuf:"bytes,4,opt,name=modules,proto3" json:"modules,omitempty"`
	Stage                uint32            `protobuf:"varint,5,opt,name=stage,proto3" json:"stage,omitempty"` // 0-based index of stage to execute up to
	MeteringConfig       string            `protobuf:"bytes,6,opt,name=metering_config,json=meteringConfig,proto3" json:"metering_config,omitempty"`
	FirstStreamableBlock uint64            `protobuf:"varint,7,opt,name=first_streamable_block,json=firstStreamableBlock,proto3" json:"first_streamable_block,omitempty"` // first block that can be streamed on that chain
	WasmExtensionConfigs map[string]string ``                                                                                                                             // TODO: rename to `wasm_extension_configs`
	/* 211-byte string literal not displayed */
	MergedBlocksStore    string `protobuf:"bytes,10,opt,name=merged_blocks_store,json=mergedBlocksStore,proto3" json:"merged_blocks_store,omitempty"` // store to use for merged blocks
	StateStore           string `protobuf:"bytes,11,opt,name=state_store,json=stateStore,proto3" json:"state_store,omitempty"`                        // store to use for substreams state
	StateStoreDefaultTag string ``                                                                                                                    // default tag to use for state store
	/* 126-byte string literal not displayed */
	SegmentSize   uint64 `protobuf:"varint,13,opt,name=segment_size,json=segmentSize,proto3" json:"segment_size,omitempty"`       // number of blocks to process in a single batch
	BlockType     string `protobuf:"bytes,14,opt,name=block_type,json=blockType,proto3" json:"block_type,omitempty"`              // block type to process
	SegmentNumber uint64 `protobuf:"varint,15,opt,name=segment_number,json=segmentNumber,proto3" json:"segment_number,omitempty"` // segment_number * segment_size = start_block_num
	// contains filtered or unexported fields
}

func (*ProcessRangeRequest) Descriptor deprecated 

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

Deprecated: Use ProcessRangeRequest.ProtoReflect.Descriptor instead.

func (*ProcessRangeRequest) GetBlockType added in v1.5.0 

func (x *ProcessRangeRequest) GetBlockType() string

func (*ProcessRangeRequest) GetFirstStreamableBlock added in v1.5.0 

func (x *ProcessRangeRequest) GetFirstStreamableBlock() uint64

func (*ProcessRangeRequest) GetMergedBlocksStore added in v1.5.0 

func (x *ProcessRangeRequest) GetMergedBlocksStore() string

func (*ProcessRangeRequest) GetMeteringConfig added in v1.5.0 

func (x *ProcessRangeRequest) GetMeteringConfig() string

func (*ProcessRangeRequest) GetModules 

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

func (*ProcessRangeRequest) GetOutputModule 

func (x *ProcessRangeRequest) GetOutputModule() string

func (*ProcessRangeRequest) GetSegmentNumber added in v1.6.0 

func (x *ProcessRangeRequest) GetSegmentNumber() uint64

func (*ProcessRangeRequest) GetSegmentSize added in v1.6.0 

func (x *ProcessRangeRequest) GetSegmentSize() uint64

func (*ProcessRangeRequest) GetStage added in v1.1.9 

func (x *ProcessRangeRequest) GetStage() uint32

func (*ProcessRangeRequest) GetStateStore added in v1.5.0 

func (x *ProcessRangeRequest) GetStateStore() string

func (*ProcessRangeRequest) GetStateStoreDefaultTag added in v1.5.0 

func (x *ProcessRangeRequest) GetStateStoreDefaultTag() string

func (*ProcessRangeRequest) GetStopBlockNum deprecated 

func (x *ProcessRangeRequest) GetStopBlockNum() uint64

Deprecated: Marked as deprecated in sf/substreams/intern/v2/service.proto.

func (*ProcessRangeRequest) GetWasmExtensionConfigs added in v1.6.0 

func (x *ProcessRangeRequest) GetWasmExtensionConfigs() map[string]string

func (*ProcessRangeRequest) ProtoMessage 

func (*ProcessRangeRequest) ProtoMessage()

func (*ProcessRangeRequest) ProtoReflect 

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

func (*ProcessRangeRequest) Reset 

func (x *ProcessRangeRequest) Reset()

func (*ProcessRangeRequest) StartBlock added in v1.6.0 

func (r *ProcessRangeRequest) StartBlock() uint64

func (*ProcessRangeRequest) StopBlock added in v1.6.0 

func (r *ProcessRangeRequest) StopBlock() uint64

func (*ProcessRangeRequest) String 

func (x *ProcessRangeRequest) String() string

func (*ProcessRangeRequest) Validate 

func (r *ProcessRangeRequest) Validate() error

func (*ProcessRangeRequest) WasmConfig added in v1.5.0 

func (x *ProcessRangeRequest) WasmConfig(module string) string

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 RPCCallWasmModuleConfiguration added in v1.5.0 

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

func GetRPCCallWasmModuleConfiguration added in v1.5.0 

func GetRPCCallWasmModuleConfiguration(r *ProcessRangeRequest) (*RPCCallWasmModuleConfiguration, error)

type SubstreamsClient 

type SubstreamsClient interface {
	ProcessRange(ctx context.Context, in *ProcessRangeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ProcessRangeResponse], 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, grpc.ServerStreamingServer[ProcessRangeResponse]) error
}

SubstreamsServer is the server API for Substreams service. All implementations should embed UnimplementedSubstreamsServer for forward compatibility.

type Substreams_ProcessRangeClient 

type Substreams_ProcessRangeClient = grpc.ServerStreamingClient[ProcessRangeResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Substreams_ProcessRangeServer 

type Substreams_ProcessRangeServer = grpc.ServerStreamingServer[ProcessRangeResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedSubstreamsServer 

type UnimplementedSubstreamsServer struct{}

UnimplementedSubstreamsServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedSubstreamsServer) ProcessRange 

func (UnimplementedSubstreamsServer) ProcessRange(*ProcessRangeRequest, grpc.ServerStreamingServer[ProcessRangeResponse]) 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) Descriptor() ([]byte, []int)

Deprecated: Use Update.ProtoReflect.Descriptor instead.

func (*Update) GetDurationMs added in v1.1.12 

func (x *Update) GetDurationMs() uint64

func (*Update) GetModulesStats added in v1.1.12 

func (x *Update) GetModulesStats() []*ModuleStats

func (*Update) GetProcessedBlocks added in v1.1.12 

func (x *Update) GetProcessedBlocks() uint64

func (*Update) GetTotalBytesRead added in v1.1.12 

func (x *Update) GetTotalBytesRead() uint64

func (*Update) GetTotalBytesWritten added in v1.1.12 

func (x *Update) GetTotalBytesWritten() uint64

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

func (*Update) Reset added in v1.1.12 

func (x *Update) Reset()

func (*Update) String added in v1.1.12 

func (x *Update) String() string

type WASMModuleType added in v1.5.0 

type WASMModuleType int32

Possible types of WASM modules 

const (
	WASMModuleType_WASM_MODULE_TYPE_UNSPECIFIED WASMModuleType = 0
	WASMModuleType_WASM_MODULE_TYPE_RPC_CALL    WASMModuleType = 1
)

func ToWasmModuleTypeArray added in v1.5.0 

func ToWasmModuleTypeArray(s []string) []WASMModuleType

func (WASMModuleType) Descriptor added in v1.5.0 

func (WASMModuleType) Descriptor() protoreflect.EnumDescriptor

func (WASMModuleType) Enum added in v1.5.0 

func (x WASMModuleType) Enum() *WASMModuleType

func (WASMModuleType) EnumDescriptor deprecated added in v1.5.0 

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

Deprecated: Use WASMModuleType.Descriptor instead.

func (WASMModuleType) Number added in v1.5.0 

func (x WASMModuleType) Number() protoreflect.EnumNumber

func (WASMModuleType) String added in v1.5.0 

func (x WASMModuleType) String() string

func (WASMModuleType) Type added in v1.5.0 

func (WASMModuleType) Type() protoreflect.EnumType

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.