pbssinternal

package
v1.1.4 Latest Latest
Warning

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

 Go to latest Published: May 26, 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 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 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"`
	// 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) 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 {
	ModuleName string `protobuf:"bytes,1,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
	// Types that are assignable to Type:
	//	*ProcessRangeResponse_ProcessedRange
	//	*ProcessRangeResponse_ProcessedBytes
	//	*ProcessRangeResponse_Failed
	//	*ProcessRangeResponse_Completed
	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) GetModuleName 

func (x *ProcessRangeResponse) GetModuleName() string

func (*ProcessRangeResponse) GetProcessedBytes 

func (x *ProcessRangeResponse) GetProcessedBytes() *ProcessedBytes

func (*ProcessRangeResponse) GetProcessedRange 

func (x *ProcessRangeResponse) GetProcessedRange() *BlockRange

func (*ProcessRangeResponse) GetType 

func (m *ProcessRangeResponse) GetType() isProcessRangeResponse_Type

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_ProcessedBytes 

type ProcessRangeResponse_ProcessedBytes struct {
	ProcessedBytes *ProcessedBytes `protobuf:"bytes,3,opt,name=processed_bytes,json=processedBytes,proto3,oneof"`
}

type ProcessRangeResponse_ProcessedRange 

type ProcessRangeResponse_ProcessedRange struct {
	ProcessedRange *BlockRange `protobuf:"bytes,2,opt,name=processed_range,json=processedRange,proto3,oneof"`
}

type ProcessedBytes 

type ProcessedBytes struct {
	TotalBytesRead    uint64 `protobuf:"varint,1,opt,name=total_bytes_read,json=totalBytesRead,proto3" json:"total_bytes_read,omitempty"`
	TotalBytesWritten uint64 `protobuf:"varint,2,opt,name=total_bytes_written,json=totalBytesWritten,proto3" json:"total_bytes_written,omitempty"`
	BytesReadDelta    uint64 `protobuf:"varint,3,opt,name=bytes_read_delta,json=bytesReadDelta,proto3" json:"bytes_read_delta,omitempty"`
	BytesWrittenDelta uint64 `protobuf:"varint,4,opt,name=bytes_written_delta,json=bytesWrittenDelta,proto3" json:"bytes_written_delta,omitempty"`
	NanoSecondsDelta  uint64 `protobuf:"varint,5,opt,name=nano_seconds_delta,json=nanoSecondsDelta,proto3" json:"nano_seconds_delta,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessedBytes) Descriptor deprecated 

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

Deprecated: Use ProcessedBytes.ProtoReflect.Descriptor instead.

func (*ProcessedBytes) GetBytesReadDelta 

func (x *ProcessedBytes) GetBytesReadDelta() uint64

func (*ProcessedBytes) GetBytesWrittenDelta 

func (x *ProcessedBytes) GetBytesWrittenDelta() uint64

func (*ProcessedBytes) GetNanoSecondsDelta 

func (x *ProcessedBytes) GetNanoSecondsDelta() uint64

func (*ProcessedBytes) GetTotalBytesRead 

func (x *ProcessedBytes) GetTotalBytesRead() uint64

func (*ProcessedBytes) GetTotalBytesWritten 

func (x *ProcessedBytes) GetTotalBytesWritten() uint64

func (*ProcessedBytes) ProtoMessage 

func (*ProcessedBytes) ProtoMessage()

func (*ProcessedBytes) ProtoReflect 

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

func (*ProcessedBytes) Reset 

func (x *ProcessedBytes) Reset()

func (*ProcessedBytes) String 

func (x *ProcessedBytes) String() string

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.

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.