pbsubstreams

package
v0.0.15 Latest Latest
Warning

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

Go to latest
Published: Jul 29, 2022 License: Apache-2.0 Imports: 13 Imported by: 26

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Module_KindStore_UpdatePolicy_name = map[int32]string{
		0: "UPDATE_POLICY_UNSET",
		1: "UPDATE_POLICY_SET",
		2: "UPDATE_POLICY_SET_IF_NOT_EXISTS",
		3: "UPDATE_POLICY_ADD",
		4: "UPDATE_POLICY_MIN",
		5: "UPDATE_POLICY_MAX",
		6: "UPDATE_POLICY_APPEND",
	}
	Module_KindStore_UpdatePolicy_value = map[string]int32{
		"UPDATE_POLICY_UNSET":             0,
		"UPDATE_POLICY_SET":               1,
		"UPDATE_POLICY_SET_IF_NOT_EXISTS": 2,
		"UPDATE_POLICY_ADD":               3,
		"UPDATE_POLICY_MIN":               4,
		"UPDATE_POLICY_MAX":               5,
		"UPDATE_POLICY_APPEND":            6,
	}
)

Enum value maps for Module_KindStore_UpdatePolicy.

View Source
var (
	Module_Input_Store_Mode_name = map[int32]string{
		0: "UNSET",
		1: "GET",
		2: "DELTAS",
	}
	Module_Input_Store_Mode_value = map[string]int32{
		"UNSET":  0,
		"GET":    1,
		"DELTAS": 2,
	}
)

Enum value maps for Module_Input_Store_Mode.

View Source
var (
	ForkStep_name = map[int32]string{
		0: "STEP_UNKNOWN",
		1: "STEP_NEW",
		2: "STEP_UNDO",
		4: "STEP_IRREVERSIBLE",
	}
	ForkStep_value = map[string]int32{
		"STEP_UNKNOWN":      0,
		"STEP_NEW":          1,
		"STEP_UNDO":         2,
		"STEP_IRREVERSIBLE": 4,
	}
)

Enum value maps for ForkStep.

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_v1_clock_proto protoreflect.FileDescriptor
View Source
var File_sf_substreams_v1_modules_proto protoreflect.FileDescriptor
View Source
var File_sf_substreams_v1_package_proto protoreflect.FileDescriptor
View Source
var File_sf_substreams_v1_substreams_proto protoreflect.FileDescriptor
View Source
var Stream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sf.substreams.v1.Stream",
	HandlerType: (*StreamServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Blocks",
			Handler:       _Stream_Blocks_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "sf/substreams/v1/substreams.proto",
}

Stream_ServiceDesc is the grpc.ServiceDesc for Stream service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterStreamServer

func RegisterStreamServer(s grpc.ServiceRegistrar, srv StreamServer)

func ValidateRequest added in v0.0.14

func ValidateRequest(req *Request) error

Types

type Binary

type Binary struct {
	Type    string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

Binary represents some code compiled to its binary form.

func (*Binary) Descriptor deprecated

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

Deprecated: Use Binary.ProtoReflect.Descriptor instead.

func (*Binary) GetContent

func (x *Binary) GetContent() []byte

func (*Binary) GetType

func (x *Binary) GetType() string

func (*Binary) ProtoMessage

func (*Binary) ProtoMessage()

func (*Binary) ProtoReflect

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

func (*Binary) Reset

func (x *Binary) Reset()

func (*Binary) String

func (x *Binary) String() string

type BlockRange

type BlockRange struct {
	StartBlock uint64 `protobuf:"varint,2,opt,name=start_block,json=startBlock,proto3" json:"start_block,omitempty"`
	EndBlock   uint64 `protobuf:"varint,3,opt,name=end_block,json=endBlock,proto3" json:"end_block,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockRange) Descriptor deprecated

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

Deprecated: Use BlockRange.ProtoReflect.Descriptor instead.

func (*BlockRange) GetEndBlock

func (x *BlockRange) GetEndBlock() uint64

func (*BlockRange) GetStartBlock

func (x *BlockRange) GetStartBlock() uint64

func (*BlockRange) ProtoMessage

func (*BlockRange) ProtoMessage()

func (*BlockRange) ProtoReflect

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

func (*BlockRange) Reset

func (x *BlockRange) Reset()

func (*BlockRange) String

func (x *BlockRange) String() string

type BlockScopedData

type BlockScopedData struct {
	Outputs []*ModuleOutput `protobuf:"bytes,1,rep,name=outputs,proto3" json:"outputs,omitempty"`
	Clock   *Clock          `protobuf:"bytes,3,opt,name=clock,proto3" json:"clock,omitempty"`
	Step    ForkStep        `protobuf:"varint,6,opt,name=step,proto3,enum=sf.substreams.v1.ForkStep" json:"step,omitempty"`
	Cursor  string          `protobuf:"bytes,10,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockScopedData) Descriptor deprecated

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

Deprecated: Use BlockScopedData.ProtoReflect.Descriptor instead.

func (*BlockScopedData) GetClock

func (x *BlockScopedData) GetClock() *Clock

func (*BlockScopedData) GetCursor

func (x *BlockScopedData) GetCursor() string

func (*BlockScopedData) GetOutputs

func (x *BlockScopedData) GetOutputs() []*ModuleOutput

func (*BlockScopedData) GetStep

func (x *BlockScopedData) GetStep() ForkStep

func (*BlockScopedData) ProtoMessage

func (*BlockScopedData) ProtoMessage()

func (*BlockScopedData) ProtoReflect

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

func (*BlockScopedData) Reset

func (x *BlockScopedData) Reset()

func (*BlockScopedData) String

func (x *BlockScopedData) String() string

type Clock

type Clock struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Number    uint64                 `protobuf:"varint,2,opt,name=number,proto3" json:"number,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Clock) Descriptor deprecated

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

Deprecated: Use Clock.ProtoReflect.Descriptor instead.

func (*Clock) GetId

func (x *Clock) GetId() string

func (*Clock) GetNumber

func (x *Clock) GetNumber() uint64

func (*Clock) GetTimestamp

func (x *Clock) GetTimestamp() *timestamppb.Timestamp

func (*Clock) ProtoMessage

func (*Clock) ProtoMessage()

func (*Clock) ProtoReflect

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

func (*Clock) Reset

func (x *Clock) Reset()

func (*Clock) String

func (x *Clock) String() string

type ForkStep

type ForkStep int32
const (
	ForkStep_STEP_UNKNOWN ForkStep = 0
	// Block is new head block of the chain, that is linear with the previous block
	ForkStep_STEP_NEW ForkStep = 1
	// Block is now forked and should be undone, it's not the head block of the chain anymore
	ForkStep_STEP_UNDO ForkStep = 2
	// Block is now irreversible and can be committed to (finality is chain specific, see chain documentation for more details)
	ForkStep_STEP_IRREVERSIBLE ForkStep = 4
)

func StepToProto

func StepToProto(step bstream.StepType) ForkStep

func (ForkStep) Descriptor

func (ForkStep) Descriptor() protoreflect.EnumDescriptor

func (ForkStep) Enum

func (x ForkStep) Enum() *ForkStep

func (ForkStep) EnumDescriptor deprecated

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

Deprecated: Use ForkStep.Descriptor instead.

func (ForkStep) Number

func (x ForkStep) Number() protoreflect.EnumNumber

func (ForkStep) String

func (x ForkStep) String() string

func (ForkStep) Type

type InitialSnapshotComplete

type InitialSnapshotComplete struct {
	Cursor string `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*InitialSnapshotComplete) Descriptor deprecated

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

Deprecated: Use InitialSnapshotComplete.ProtoReflect.Descriptor instead.

func (*InitialSnapshotComplete) GetCursor

func (x *InitialSnapshotComplete) GetCursor() string

func (*InitialSnapshotComplete) ProtoMessage

func (*InitialSnapshotComplete) ProtoMessage()

func (*InitialSnapshotComplete) ProtoReflect

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

func (*InitialSnapshotComplete) Reset

func (x *InitialSnapshotComplete) Reset()

func (*InitialSnapshotComplete) String

func (x *InitialSnapshotComplete) String() string

type InitialSnapshotData

type InitialSnapshotData struct {
	ModuleName string       `protobuf:"bytes,1,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
	Deltas     *StoreDeltas `protobuf:"bytes,2,opt,name=deltas,proto3" json:"deltas,omitempty"`
	SentKeys   uint64       `protobuf:"varint,4,opt,name=sent_keys,json=sentKeys,proto3" json:"sent_keys,omitempty"`
	TotalKeys  uint64       `protobuf:"varint,3,opt,name=total_keys,json=totalKeys,proto3" json:"total_keys,omitempty"`
	// contains filtered or unexported fields
}

func (*InitialSnapshotData) Descriptor deprecated

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

Deprecated: Use InitialSnapshotData.ProtoReflect.Descriptor instead.

func (*InitialSnapshotData) GetDeltas

func (x *InitialSnapshotData) GetDeltas() *StoreDeltas

func (*InitialSnapshotData) GetModuleName

func (x *InitialSnapshotData) GetModuleName() string

func (*InitialSnapshotData) GetSentKeys

func (x *InitialSnapshotData) GetSentKeys() uint64

func (*InitialSnapshotData) GetTotalKeys

func (x *InitialSnapshotData) GetTotalKeys() uint64

func (*InitialSnapshotData) ProtoMessage

func (*InitialSnapshotData) ProtoMessage()

func (*InitialSnapshotData) ProtoReflect

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

func (*InitialSnapshotData) Reset

func (x *InitialSnapshotData) Reset()

func (*InitialSnapshotData) String

func (x *InitialSnapshotData) String() string

type Module

type Module struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to Kind:
	//	*Module_KindMap_
	//	*Module_KindStore_
	Kind             isModule_Kind   `protobuf_oneof:"kind"`
	BinaryIndex      uint32          `protobuf:"varint,4,opt,name=binary_index,json=binaryIndex,proto3" json:"binary_index,omitempty"`
	BinaryEntrypoint string          `protobuf:"bytes,5,opt,name=binary_entrypoint,json=binaryEntrypoint,proto3" json:"binary_entrypoint,omitempty"`
	Inputs           []*Module_Input `protobuf:"bytes,6,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Output           *Module_Output  `protobuf:"bytes,7,opt,name=output,proto3" json:"output,omitempty"`
	InitialBlock     uint64          `protobuf:"varint,8,opt,name=initial_block,json=initialBlock,proto3" json:"initial_block,omitempty"`
	// contains filtered or unexported fields
}

func (*Module) Descriptor deprecated

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

Deprecated: Use Module.ProtoReflect.Descriptor instead.

func (*Module) GetBinaryEntrypoint

func (x *Module) GetBinaryEntrypoint() string

func (*Module) GetBinaryIndex

func (x *Module) GetBinaryIndex() uint32

func (*Module) GetInitialBlock

func (x *Module) GetInitialBlock() uint64

func (*Module) GetInputs

func (x *Module) GetInputs() []*Module_Input

func (*Module) GetKind

func (m *Module) GetKind() isModule_Kind

func (*Module) GetKindMap

func (x *Module) GetKindMap() *Module_KindMap

func (*Module) GetKindStore

func (x *Module) GetKindStore() *Module_KindStore

func (*Module) GetName

func (x *Module) GetName() string

func (*Module) GetOutput

func (x *Module) GetOutput() *Module_Output

func (*Module) ProtoMessage

func (*Module) ProtoMessage()

func (*Module) ProtoReflect

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

func (*Module) Reset

func (x *Module) Reset()

func (*Module) String

func (x *Module) String() string

type ModuleMetadata

type ModuleMetadata struct {

	// Corresponds to the index in `Package.metadata.package_meta`
	PackageIndex uint64 `protobuf:"varint,1,opt,name=package_index,json=packageIndex,proto3" json:"package_index,omitempty"`
	Doc          string `protobuf:"bytes,2,opt,name=doc,proto3" json:"doc,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleMetadata) Descriptor deprecated

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

Deprecated: Use ModuleMetadata.ProtoReflect.Descriptor instead.

func (*ModuleMetadata) GetDoc

func (x *ModuleMetadata) GetDoc() string

func (*ModuleMetadata) GetPackageIndex

func (x *ModuleMetadata) GetPackageIndex() uint64

func (*ModuleMetadata) ProtoMessage

func (*ModuleMetadata) ProtoMessage()

func (*ModuleMetadata) ProtoReflect

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

func (*ModuleMetadata) Reset

func (x *ModuleMetadata) Reset()

func (*ModuleMetadata) String

func (x *ModuleMetadata) String() string

type ModuleOutput

type ModuleOutput struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to Data:
	//	*ModuleOutput_MapOutput
	//	*ModuleOutput_StoreDeltas
	Data isModuleOutput_Data `protobuf_oneof:"data"`
	Logs []string            `protobuf:"bytes,4,rep,name=logs,proto3" json:"logs,omitempty"`
	// LogsTruncated is a flag that tells you if you received all the logs or if they
	// were truncated because you logged too much (fixed limit currently is set to 128 KiB).
	LogsTruncated bool `protobuf:"varint,5,opt,name=logs_truncated,json=logsTruncated,proto3" json:"logs_truncated,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleOutput) Descriptor deprecated

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

Deprecated: Use ModuleOutput.ProtoReflect.Descriptor instead.

func (*ModuleOutput) GetData

func (m *ModuleOutput) GetData() isModuleOutput_Data

func (*ModuleOutput) GetLogs

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

func (*ModuleOutput) GetLogsTruncated

func (x *ModuleOutput) GetLogsTruncated() bool

func (*ModuleOutput) GetMapOutput

func (x *ModuleOutput) GetMapOutput() *anypb.Any

func (*ModuleOutput) GetName

func (x *ModuleOutput) GetName() string

func (*ModuleOutput) GetStoreDeltas

func (x *ModuleOutput) GetStoreDeltas() *StoreDeltas

func (*ModuleOutput) ProtoMessage

func (*ModuleOutput) ProtoMessage()

func (*ModuleOutput) ProtoReflect

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

func (*ModuleOutput) Reset

func (x *ModuleOutput) Reset()

func (*ModuleOutput) String

func (x *ModuleOutput) String() string

type ModuleOutputData

type ModuleOutputData interface {
	// contains filtered or unexported methods
}

type ModuleOutput_MapOutput

type ModuleOutput_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 ModuleProgress

type ModuleProgress struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to Type:
	//	*ModuleProgress_ProcessedRanges
	//	*ModuleProgress_InitialState_
	//	*ModuleProgress_ProcessedBytes_
	//	*ModuleProgress_Failed_
	Type isModuleProgress_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*ModuleProgress) Descriptor deprecated

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

Deprecated: Use ModuleProgress.ProtoReflect.Descriptor instead.

func (*ModuleProgress) GetFailed

func (x *ModuleProgress) GetFailed() *ModuleProgress_Failed

func (*ModuleProgress) GetInitialState

func (x *ModuleProgress) GetInitialState() *ModuleProgress_InitialState

func (*ModuleProgress) GetName

func (x *ModuleProgress) GetName() string

func (*ModuleProgress) GetProcessedBytes

func (x *ModuleProgress) GetProcessedBytes() *ModuleProgress_ProcessedBytes

func (*ModuleProgress) GetProcessedRanges

func (x *ModuleProgress) GetProcessedRanges() *ModuleProgress_ProcessedRange

func (*ModuleProgress) GetType

func (m *ModuleProgress) GetType() isModuleProgress_Type

func (*ModuleProgress) ProtoMessage

func (*ModuleProgress) ProtoMessage()

func (*ModuleProgress) ProtoReflect

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

func (*ModuleProgress) Reset

func (x *ModuleProgress) Reset()

func (*ModuleProgress) String

func (x *ModuleProgress) String() string

type ModuleProgress_Failed

type ModuleProgress_Failed struct {
	Reason string   `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	Logs   []string `protobuf:"bytes,2,rep,name=logs,proto3" json:"logs,omitempty"`
	// FailureLogsTruncated is a flag that tells you if you received all the logs or if they
	// were truncated because you logged too much (fixed limit currently is set to 128 KiB).
	LogsTruncated bool `protobuf:"varint,3,opt,name=logs_truncated,json=logsTruncated,proto3" json:"logs_truncated,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleProgress_Failed) Descriptor deprecated

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

Deprecated: Use ModuleProgress_Failed.ProtoReflect.Descriptor instead.

func (*ModuleProgress_Failed) GetLogs

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

func (*ModuleProgress_Failed) GetLogsTruncated

func (x *ModuleProgress_Failed) GetLogsTruncated() bool

func (*ModuleProgress_Failed) GetReason

func (x *ModuleProgress_Failed) GetReason() string

func (*ModuleProgress_Failed) ProtoMessage

func (*ModuleProgress_Failed) ProtoMessage()

func (*ModuleProgress_Failed) ProtoReflect

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

func (*ModuleProgress_Failed) Reset

func (x *ModuleProgress_Failed) Reset()

func (*ModuleProgress_Failed) String

func (x *ModuleProgress_Failed) String() string

type ModuleProgress_Failed_

type ModuleProgress_Failed_ struct {
	Failed *ModuleProgress_Failed `protobuf:"bytes,5,opt,name=failed,proto3,oneof"`
}

type ModuleProgress_InitialState

type ModuleProgress_InitialState struct {
	AvailableUpToBlock uint64 `protobuf:"varint,2,opt,name=available_up_to_block,json=availableUpToBlock,proto3" json:"available_up_to_block,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleProgress_InitialState) Descriptor deprecated

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

Deprecated: Use ModuleProgress_InitialState.ProtoReflect.Descriptor instead.

func (*ModuleProgress_InitialState) GetAvailableUpToBlock

func (x *ModuleProgress_InitialState) GetAvailableUpToBlock() uint64

func (*ModuleProgress_InitialState) ProtoMessage

func (*ModuleProgress_InitialState) ProtoMessage()

func (*ModuleProgress_InitialState) ProtoReflect

func (*ModuleProgress_InitialState) Reset

func (x *ModuleProgress_InitialState) Reset()

func (*ModuleProgress_InitialState) String

func (x *ModuleProgress_InitialState) String() string

type ModuleProgress_InitialState_

type ModuleProgress_InitialState_ struct {
	InitialState *ModuleProgress_InitialState `protobuf:"bytes,3,opt,name=initial_state,json=initialState,proto3,oneof"`
}

type ModuleProgress_ProcessedBytes

type ModuleProgress_ProcessedBytes struct {
	TotalBytesRead    uint64 `protobuf:"varint,1,opt,name=total_bytes_read,json=totalBytesRead,proto3" json:"total_bytes_read,omitempty"`
	TotalBytesWritten uint64 `protobuf:"varint,2,opt,name=total_bytes_written,json=totalBytesWritten,proto3" json:"total_bytes_written,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleProgress_ProcessedBytes) Descriptor deprecated

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

Deprecated: Use ModuleProgress_ProcessedBytes.ProtoReflect.Descriptor instead.

func (*ModuleProgress_ProcessedBytes) GetTotalBytesRead

func (x *ModuleProgress_ProcessedBytes) GetTotalBytesRead() uint64

func (*ModuleProgress_ProcessedBytes) GetTotalBytesWritten

func (x *ModuleProgress_ProcessedBytes) GetTotalBytesWritten() uint64

func (*ModuleProgress_ProcessedBytes) ProtoMessage

func (*ModuleProgress_ProcessedBytes) ProtoMessage()

func (*ModuleProgress_ProcessedBytes) ProtoReflect

func (*ModuleProgress_ProcessedBytes) Reset

func (x *ModuleProgress_ProcessedBytes) Reset()

func (*ModuleProgress_ProcessedBytes) String

type ModuleProgress_ProcessedBytes_

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

type ModuleProgress_ProcessedRange

type ModuleProgress_ProcessedRange struct {
	ProcessedRanges []*BlockRange `protobuf:"bytes,1,rep,name=processed_ranges,json=processedRanges,proto3" json:"processed_ranges,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleProgress_ProcessedRange) Descriptor deprecated

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

Deprecated: Use ModuleProgress_ProcessedRange.ProtoReflect.Descriptor instead.

func (*ModuleProgress_ProcessedRange) GetProcessedRanges

func (x *ModuleProgress_ProcessedRange) GetProcessedRanges() []*BlockRange

func (*ModuleProgress_ProcessedRange) ProtoMessage

func (*ModuleProgress_ProcessedRange) ProtoMessage()

func (*ModuleProgress_ProcessedRange) ProtoReflect

func (*ModuleProgress_ProcessedRange) Reset

func (x *ModuleProgress_ProcessedRange) Reset()

func (*ModuleProgress_ProcessedRange) String

type ModuleProgress_ProcessedRanges

type ModuleProgress_ProcessedRanges struct {
	ProcessedRanges *ModuleProgress_ProcessedRange `protobuf:"bytes,2,opt,name=processed_ranges,json=processedRanges,proto3,oneof"`
}

type Module_Input

type Module_Input struct {

	// Types that are assignable to Input:
	//	*Module_Input_Source_
	//	*Module_Input_Map_
	//	*Module_Input_Store_
	Input isModule_Input_Input `protobuf_oneof:"input"`
	// contains filtered or unexported fields
}

func (*Module_Input) Descriptor deprecated

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

Deprecated: Use Module_Input.ProtoReflect.Descriptor instead.

func (*Module_Input) GetInput

func (m *Module_Input) GetInput() isModule_Input_Input

func (*Module_Input) GetMap

func (x *Module_Input) GetMap() *Module_Input_Map

func (*Module_Input) GetSource

func (x *Module_Input) GetSource() *Module_Input_Source

func (*Module_Input) GetStore

func (x *Module_Input) GetStore() *Module_Input_Store

func (*Module_Input) ProtoMessage

func (*Module_Input) ProtoMessage()

func (*Module_Input) ProtoReflect

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

func (*Module_Input) Reset

func (x *Module_Input) Reset()

func (*Module_Input) String

func (x *Module_Input) String() string

type Module_Input_Map

type Module_Input_Map struct {
	ModuleName string `protobuf:"bytes,1,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"` // ex: "block_to_pairs"
	// contains filtered or unexported fields
}

func (*Module_Input_Map) Descriptor deprecated

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

Deprecated: Use Module_Input_Map.ProtoReflect.Descriptor instead.

func (*Module_Input_Map) GetModuleName

func (x *Module_Input_Map) GetModuleName() string

func (*Module_Input_Map) ProtoMessage

func (*Module_Input_Map) ProtoMessage()

func (*Module_Input_Map) ProtoReflect

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

func (*Module_Input_Map) Reset

func (x *Module_Input_Map) Reset()

func (*Module_Input_Map) String

func (x *Module_Input_Map) String() string

type Module_Input_Map_

type Module_Input_Map_ struct {
	Map *Module_Input_Map `protobuf:"bytes,2,opt,name=map,proto3,oneof"`
}

type Module_Input_Source

type Module_Input_Source struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` // ex: "sf.ethereum.type.v1.Block"
	// contains filtered or unexported fields
}

func (*Module_Input_Source) Descriptor deprecated

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

Deprecated: Use Module_Input_Source.ProtoReflect.Descriptor instead.

func (*Module_Input_Source) GetType

func (x *Module_Input_Source) GetType() string

func (*Module_Input_Source) ProtoMessage

func (*Module_Input_Source) ProtoMessage()

func (*Module_Input_Source) ProtoReflect

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

func (*Module_Input_Source) Reset

func (x *Module_Input_Source) Reset()

func (*Module_Input_Source) String

func (x *Module_Input_Source) String() string

type Module_Input_Source_

type Module_Input_Source_ struct {
	Source *Module_Input_Source `protobuf:"bytes,1,opt,name=source,proto3,oneof"`
}

type Module_Input_Store

type Module_Input_Store struct {
	ModuleName string                  `protobuf:"bytes,1,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
	Mode       Module_Input_Store_Mode `protobuf:"varint,2,opt,name=mode,proto3,enum=sf.substreams.v1.Module_Input_Store_Mode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*Module_Input_Store) Descriptor deprecated

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

Deprecated: Use Module_Input_Store.ProtoReflect.Descriptor instead.

func (*Module_Input_Store) GetMode

func (*Module_Input_Store) GetModuleName

func (x *Module_Input_Store) GetModuleName() string

func (*Module_Input_Store) ProtoMessage

func (*Module_Input_Store) ProtoMessage()

func (*Module_Input_Store) ProtoReflect

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

func (*Module_Input_Store) Reset

func (x *Module_Input_Store) Reset()

func (*Module_Input_Store) String

func (x *Module_Input_Store) String() string

type Module_Input_Store_

type Module_Input_Store_ struct {
	Store *Module_Input_Store `protobuf:"bytes,3,opt,name=store,proto3,oneof"`
}

type Module_Input_Store_Mode

type Module_Input_Store_Mode int32
const (
	Module_Input_Store_UNSET  Module_Input_Store_Mode = 0
	Module_Input_Store_GET    Module_Input_Store_Mode = 1
	Module_Input_Store_DELTAS Module_Input_Store_Mode = 2
)

func (Module_Input_Store_Mode) Descriptor

func (Module_Input_Store_Mode) Enum

func (Module_Input_Store_Mode) EnumDescriptor deprecated

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

Deprecated: Use Module_Input_Store_Mode.Descriptor instead.

func (Module_Input_Store_Mode) Number

func (Module_Input_Store_Mode) String

func (x Module_Input_Store_Mode) String() string

func (Module_Input_Store_Mode) Type

type Module_KindMap

type Module_KindMap struct {
	OutputType string `protobuf:"bytes,1,opt,name=output_type,json=outputType,proto3" json:"output_type,omitempty"`
	// contains filtered or unexported fields
}

func (*Module_KindMap) Descriptor deprecated

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

Deprecated: Use Module_KindMap.ProtoReflect.Descriptor instead.

func (*Module_KindMap) GetOutputType

func (x *Module_KindMap) GetOutputType() string

func (*Module_KindMap) ProtoMessage

func (*Module_KindMap) ProtoMessage()

func (*Module_KindMap) ProtoReflect

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

func (*Module_KindMap) Reset

func (x *Module_KindMap) Reset()

func (*Module_KindMap) String

func (x *Module_KindMap) String() string

type Module_KindMap_

type Module_KindMap_ struct {
	KindMap *Module_KindMap `protobuf:"bytes,2,opt,name=kind_map,json=kindMap,proto3,oneof"`
}

type Module_KindStore

type Module_KindStore struct {

	// The `update_policy` determines the functions available to mutate the store
	// (like `set()`, `set_if_not_exists()` or `sum()`, etc..) in
	// order to ensure that parallel operations are possible and deterministic
	//
	// Say a store cumulates keys from block 0 to 1M, and a second store
	// cumulates keys from block 1M to 2M. When we want to use this
	// store as a dependency for a downstream module, we will merge the
	// two stores according to this policy.
	UpdatePolicy Module_KindStore_UpdatePolicy `` /* 150-byte string literal not displayed */
	ValueType    string                        `protobuf:"bytes,2,opt,name=value_type,json=valueType,proto3" json:"value_type,omitempty"`
	// contains filtered or unexported fields
}

func (*Module_KindStore) Descriptor deprecated

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

Deprecated: Use Module_KindStore.ProtoReflect.Descriptor instead.

func (*Module_KindStore) GetUpdatePolicy

func (x *Module_KindStore) GetUpdatePolicy() Module_KindStore_UpdatePolicy

func (*Module_KindStore) GetValueType

func (x *Module_KindStore) GetValueType() string

func (*Module_KindStore) ProtoMessage

func (*Module_KindStore) ProtoMessage()

func (*Module_KindStore) ProtoReflect

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

func (*Module_KindStore) Reset

func (x *Module_KindStore) Reset()

func (*Module_KindStore) String

func (x *Module_KindStore) String() string

type Module_KindStore_

type Module_KindStore_ struct {
	KindStore *Module_KindStore `protobuf:"bytes,3,opt,name=kind_store,json=kindStore,proto3,oneof"`
}

type Module_KindStore_UpdatePolicy

type Module_KindStore_UpdatePolicy int32
const (
	Module_KindStore_UPDATE_POLICY_UNSET Module_KindStore_UpdatePolicy = 0
	// Provides a store where you can `set()` keys, and the latest key wins
	Module_KindStore_UPDATE_POLICY_SET Module_KindStore_UpdatePolicy = 1
	// Provides a store where you can `set_if_not_exists()` keys, and the first key wins
	Module_KindStore_UPDATE_POLICY_SET_IF_NOT_EXISTS Module_KindStore_UpdatePolicy = 2
	// Provides a store where you can `add_*()` keys, where two stores merge by summing its values.
	Module_KindStore_UPDATE_POLICY_ADD Module_KindStore_UpdatePolicy = 3
	// Provides a store where you can `min_*()` keys, where two stores merge by leaving the minimum value.
	Module_KindStore_UPDATE_POLICY_MIN Module_KindStore_UpdatePolicy = 4
	// Provides a store where you can `max_*()` keys, where two stores merge by leaving the maximum value.
	Module_KindStore_UPDATE_POLICY_MAX Module_KindStore_UpdatePolicy = 5
	// Provides a store where you can `append()` keys, where two stores merge by concatenating the bytes in order.
	Module_KindStore_UPDATE_POLICY_APPEND Module_KindStore_UpdatePolicy = 6
)

func (Module_KindStore_UpdatePolicy) Descriptor

func (Module_KindStore_UpdatePolicy) Enum

func (Module_KindStore_UpdatePolicy) EnumDescriptor deprecated

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

Deprecated: Use Module_KindStore_UpdatePolicy.Descriptor instead.

func (Module_KindStore_UpdatePolicy) Number

func (Module_KindStore_UpdatePolicy) String

func (Module_KindStore_UpdatePolicy) Type

type Module_Output

type Module_Output struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Module_Output) Descriptor deprecated

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

Deprecated: Use Module_Output.ProtoReflect.Descriptor instead.

func (*Module_Output) GetType

func (x *Module_Output) GetType() string

func (*Module_Output) ProtoMessage

func (*Module_Output) ProtoMessage()

func (*Module_Output) ProtoReflect

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

func (*Module_Output) Reset

func (x *Module_Output) Reset()

func (*Module_Output) String

func (x *Module_Output) String() string

type Modules

type Modules struct {
	Modules  []*Module `protobuf:"bytes,1,rep,name=modules,proto3" json:"modules,omitempty"`
	Binaries []*Binary `protobuf:"bytes,2,rep,name=binaries,proto3" json:"binaries,omitempty"`
	// contains filtered or unexported fields
}

func (*Modules) Descriptor deprecated

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

Deprecated: Use Modules.ProtoReflect.Descriptor instead.

func (*Modules) GetBinaries

func (x *Modules) GetBinaries() []*Binary

func (*Modules) GetModules

func (x *Modules) GetModules() []*Module

func (*Modules) ProtoMessage

func (*Modules) ProtoMessage()

func (*Modules) ProtoReflect

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

func (*Modules) Reset

func (x *Modules) Reset()

func (*Modules) String

func (x *Modules) String() string

type ModulesProgress

type ModulesProgress struct {
	Modules []*ModuleProgress `protobuf:"bytes,1,rep,name=modules,proto3" json:"modules,omitempty"`
	// contains filtered or unexported fields
}

func (*ModulesProgress) Descriptor deprecated

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

Deprecated: Use ModulesProgress.ProtoReflect.Descriptor instead.

func (*ModulesProgress) GetModules

func (x *ModulesProgress) GetModules() []*ModuleProgress

func (*ModulesProgress) ProtoMessage

func (*ModulesProgress) ProtoMessage()

func (*ModulesProgress) ProtoReflect

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

func (*ModulesProgress) Reset

func (x *ModulesProgress) Reset()

func (*ModulesProgress) String

func (x *ModulesProgress) String() string

type Output

type Output struct {
	BlockNum  uint64                 `protobuf:"varint,1,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"`
	BlockId   string                 `protobuf:"bytes,2,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     *anypb.Any             `protobuf:"bytes,10,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Output) Descriptor deprecated

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

Deprecated: Use Output.ProtoReflect.Descriptor instead.

func (*Output) GetBlockId

func (x *Output) GetBlockId() string

func (*Output) GetBlockNum

func (x *Output) GetBlockNum() uint64

func (*Output) GetTimestamp

func (x *Output) GetTimestamp() *timestamppb.Timestamp

func (*Output) GetValue

func (x *Output) GetValue() *anypb.Any

func (*Output) ProtoMessage

func (*Output) ProtoMessage()

func (*Output) ProtoReflect

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

func (*Output) Reset

func (x *Output) Reset()

func (*Output) String

func (x *Output) String() string

type Package

type Package struct {

	// Needs to be one so this file can be used _directly_ as a
	// buf `Image` andor a ProtoSet for grpcurl and other tools
	ProtoFiles  []*descriptorpb.FileDescriptorProto `protobuf:"bytes,1,rep,name=proto_files,json=protoFiles,proto3" json:"proto_files,omitempty"`
	Version     uint64                              `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	Modules     *Modules                            `protobuf:"bytes,6,opt,name=modules,proto3" json:"modules,omitempty"`
	ModuleMeta  []*ModuleMetadata                   `protobuf:"bytes,7,rep,name=module_meta,json=moduleMeta,proto3" json:"module_meta,omitempty"`
	PackageMeta []*PackageMetadata                  `protobuf:"bytes,8,rep,name=package_meta,json=packageMeta,proto3" json:"package_meta,omitempty"`
	// contains filtered or unexported fields
}

func (*Package) Descriptor deprecated

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

Deprecated: Use Package.ProtoReflect.Descriptor instead.

func (*Package) GetModuleMeta

func (x *Package) GetModuleMeta() []*ModuleMetadata

func (*Package) GetModules

func (x *Package) GetModules() *Modules

func (*Package) GetPackageMeta

func (x *Package) GetPackageMeta() []*PackageMetadata

func (*Package) GetProtoFiles

func (x *Package) GetProtoFiles() []*descriptorpb.FileDescriptorProto

func (*Package) GetVersion

func (x *Package) GetVersion() uint64

func (*Package) ProtoMessage

func (*Package) ProtoMessage()

func (*Package) ProtoReflect

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

func (*Package) Reset

func (x *Package) Reset()

func (*Package) String

func (x *Package) String() string

type PackageMetadata

type PackageMetadata struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Url     string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Name    string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Doc     string `protobuf:"bytes,4,opt,name=doc,proto3" json:"doc,omitempty"`
	// contains filtered or unexported fields
}

func (*PackageMetadata) Descriptor deprecated

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

Deprecated: Use PackageMetadata.ProtoReflect.Descriptor instead.

func (*PackageMetadata) GetDoc

func (x *PackageMetadata) GetDoc() string

func (*PackageMetadata) GetName

func (x *PackageMetadata) GetName() string

func (*PackageMetadata) GetUrl

func (x *PackageMetadata) GetUrl() string

func (*PackageMetadata) GetVersion

func (x *PackageMetadata) GetVersion() string

func (*PackageMetadata) ProtoMessage

func (*PackageMetadata) ProtoMessage()

func (*PackageMetadata) ProtoReflect

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

func (*PackageMetadata) Reset

func (x *PackageMetadata) Reset()

func (*PackageMetadata) String

func (x *PackageMetadata) String() string

type Request

type Request struct {
	StartBlockNum                  int64      `protobuf:"varint,1,opt,name=start_block_num,json=startBlockNum,proto3" json:"start_block_num,omitempty"`
	StartCursor                    string     `protobuf:"bytes,2,opt,name=start_cursor,json=startCursor,proto3" json:"start_cursor,omitempty"`
	StopBlockNum                   uint64     `protobuf:"varint,3,opt,name=stop_block_num,json=stopBlockNum,proto3" json:"stop_block_num,omitempty"`
	ForkSteps                      []ForkStep `` /* 127-byte string literal not displayed */
	IrreversibilityCondition       string     `` /* 133-byte string literal not displayed */
	Modules                        *Modules   `protobuf:"bytes,6,opt,name=modules,proto3" json:"modules,omitempty"`
	OutputModules                  []string   `protobuf:"bytes,7,rep,name=output_modules,json=outputModules,proto3" json:"output_modules,omitempty"`
	InitialStoreSnapshotForModules []string   `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetForkSteps

func (x *Request) GetForkSteps() []ForkStep

func (*Request) GetInitialStoreSnapshotForModules

func (x *Request) GetInitialStoreSnapshotForModules() []string

func (*Request) GetIrreversibilityCondition

func (x *Request) GetIrreversibilityCondition() string

func (*Request) GetModules

func (x *Request) GetModules() *Modules

func (*Request) GetOutputModules

func (x *Request) GetOutputModules() []string

func (*Request) GetStartBlockNum

func (x *Request) GetStartBlockNum() int64

func (*Request) GetStartCursor

func (x *Request) GetStartCursor() string

func (*Request) GetStopBlockNum

func (x *Request) GetStopBlockNum() uint64

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) ProtoReflect

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

func (*Request) Reset

func (x *Request) Reset()

func (*Request) String

func (x *Request) String() string

type Response

type Response struct {

	// Types that are assignable to Message:
	//	*Response_Progress
	//	*Response_SnapshotData
	//	*Response_SnapshotComplete
	//	*Response_Data
	Message isResponse_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetData

func (x *Response) GetData() *BlockScopedData

func (*Response) GetMessage

func (m *Response) GetMessage() isResponse_Message

func (*Response) GetProgress

func (x *Response) GetProgress() *ModulesProgress

func (*Response) GetSnapshotComplete

func (x *Response) GetSnapshotComplete() *InitialSnapshotComplete

func (*Response) GetSnapshotData

func (x *Response) GetSnapshotData() *InitialSnapshotData

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) ProtoReflect

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

func (*Response) Reset

func (x *Response) Reset()

func (*Response) String

func (x *Response) String() string

type Response_Data

type Response_Data struct {
	Data *BlockScopedData `protobuf:"bytes,4,opt,name=data,proto3,oneof"`
}

type Response_Progress

type Response_Progress struct {
	Progress *ModulesProgress `protobuf:"bytes,1,opt,name=progress,proto3,oneof"` // Progress of data preparation, before sending in the stream of `data` events.
}

type Response_SnapshotComplete

type Response_SnapshotComplete struct {
	SnapshotComplete *InitialSnapshotComplete `protobuf:"bytes,3,opt,name=snapshot_complete,json=snapshotComplete,proto3,oneof"`
}

type Response_SnapshotData

type Response_SnapshotData struct {
	SnapshotData *InitialSnapshotData `protobuf:"bytes,2,opt,name=snapshot_data,json=snapshotData,proto3,oneof"`
}

type StoreDelta

type StoreDelta struct {
	Operation StoreDelta_Operation `protobuf:"varint,1,opt,name=operation,proto3,enum=sf.substreams.v1.StoreDelta_Operation" json:"operation,omitempty"`
	Ordinal   uint64               `protobuf:"varint,2,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
	Key       string               `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	OldValue  []byte               `protobuf:"bytes,4,opt,name=old_value,json=oldValue,proto3" json:"old_value,omitempty"`
	NewValue  []byte               `protobuf:"bytes,5,opt,name=new_value,json=newValue,proto3" json:"new_value,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreDelta) Descriptor deprecated

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

Deprecated: Use StoreDelta.ProtoReflect.Descriptor instead.

func (*StoreDelta) GetKey

func (x *StoreDelta) GetKey() string

func (*StoreDelta) GetNewValue

func (x *StoreDelta) GetNewValue() []byte

func (*StoreDelta) GetOldValue

func (x *StoreDelta) GetOldValue() []byte

func (*StoreDelta) GetOperation

func (x *StoreDelta) GetOperation() StoreDelta_Operation

func (*StoreDelta) GetOrdinal

func (x *StoreDelta) GetOrdinal() uint64

func (*StoreDelta) ProtoMessage

func (*StoreDelta) ProtoMessage()

func (*StoreDelta) ProtoReflect

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

func (*StoreDelta) Reset

func (x *StoreDelta) Reset()

func (*StoreDelta) String

func (x *StoreDelta) String() string

type StoreDelta_Operation

type StoreDelta_Operation int32
const (
	StoreDelta_UNSET  StoreDelta_Operation = 0
	StoreDelta_CREATE StoreDelta_Operation = 1
	StoreDelta_UPDATE StoreDelta_Operation = 2
	StoreDelta_DELETE StoreDelta_Operation = 3
)

func (StoreDelta_Operation) Descriptor

func (StoreDelta_Operation) 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 {
	Deltas []*StoreDelta `protobuf:"bytes,1,rep,name=deltas,proto3" json:"deltas,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreDeltas) Descriptor deprecated

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

Deprecated: Use StoreDeltas.ProtoReflect.Descriptor instead.

func (*StoreDeltas) GetDeltas

func (x *StoreDeltas) GetDeltas() []*StoreDelta

func (*StoreDeltas) ProtoMessage

func (*StoreDeltas) ProtoMessage()

func (*StoreDeltas) ProtoReflect

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

func (*StoreDeltas) Reset

func (x *StoreDeltas) Reset()

func (*StoreDeltas) String

func (x *StoreDeltas) String() string

type StreamClient

type StreamClient interface {
	Blocks(ctx context.Context, in *Request, opts ...grpc.CallOption) (Stream_BlocksClient, error)
}

StreamClient is the client API for Stream service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStreamClient

func NewStreamClient(cc grpc.ClientConnInterface) StreamClient

type StreamServer

type StreamServer interface {
	Blocks(*Request, Stream_BlocksServer) error
}

StreamServer is the server API for Stream service. All implementations should embed UnimplementedStreamServer for forward compatibility

type Stream_BlocksClient

type Stream_BlocksClient interface {
	Recv() (*Response, error)
	grpc.ClientStream
}

type Stream_BlocksServer

type Stream_BlocksServer interface {
	Send(*Response) error
	grpc.ServerStream
}

type UnimplementedStreamServer

type UnimplementedStreamServer struct {
}

UnimplementedStreamServer should be embedded to have forward compatible implementations.

func (UnimplementedStreamServer) Blocks

type UnsafeStreamServer

type UnsafeStreamServer interface {
	// contains filtered or unexported methods
}

UnsafeStreamServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamServer will result in compilation errors.

Jump to

Keyboard shortcuts

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