pbssinternal

package
v1.1.19 Latest Latest
Warning

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

Go to latest
Published: Oct 25, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for StoreDelta_Operation.

View Source
var File_sf_substreams_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() *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 *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) Enum

func (StoreDelta_Operation) EnumDescriptor deprecated

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

Deprecated: Use StoreDelta_Operation.Descriptor instead.

func (StoreDelta_Operation) Number

func (StoreDelta_Operation) String

func (x StoreDelta_Operation) String() string

func (StoreDelta_Operation) Type

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

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL