pbsubstreams

package
v0.0.5-beta Latest Latest
Warning

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

 Go to latest Published: Apr 27, 2022 License: Apache-2.0 Imports: 15 Imported by: 28

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for TableChange_Operation.

View Source 
var (
	Module_KindStore_UpdatePolicy_name = map[int32]string{
		0: "UPDATE_POLICY_UNSET",
		1: "UPDATE_POLICY_REPLACE",
		2: "UPDATE_POLICY_IGNORE",
		3: "UPDATE_POLICY_SUM",
		4: "UPDATE_POLICY_MIN",
		5: "UPDATE_POLICY_MAX",
	}
	Module_KindStore_UpdatePolicy_value = map[string]int32{
		"UPDATE_POLICY_UNSET":   0,
		"UPDATE_POLICY_REPLACE": 1,
		"UPDATE_POLICY_IGNORE":  2,
		"UPDATE_POLICY_SUM":     3,
		"UPDATE_POLICY_MIN":     4,
		"UPDATE_POLICY_MAX":     5,
	}
)

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_database_proto protoreflect.FileDescriptor
View Source 
var File_sf_substreams_v1_manifest_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)

Types

type BlockRange 

type BlockRange struct {
	StartBlock uint64 `protobuf:"varint,1,opt,name=start_block,json=startBlock,proto3" json:"start_block,omitempty"`
	EndBlock   uint64 `protobuf:"varint,2,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 DatabaseChanges 

type DatabaseChanges struct {
	TableChanges []*TableChange `protobuf:"bytes,1,rep,name=tableChanges,proto3" json:"tableChanges,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseChanges) Descriptor deprecated 

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

Deprecated: Use DatabaseChanges.ProtoReflect.Descriptor instead.

func (*DatabaseChanges) GetTableChanges 

func (x *DatabaseChanges) GetTableChanges() []*TableChange

func (*DatabaseChanges) ProtoMessage 

func (*DatabaseChanges) ProtoMessage()

func (*DatabaseChanges) ProtoReflect 

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

func (*DatabaseChanges) Reset 

func (x *DatabaseChanges) Reset()

func (*DatabaseChanges) Squash 

func (x *DatabaseChanges) Squash() error

func (*DatabaseChanges) String 

func (x *DatabaseChanges) String() string

type Field 

type Field struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	NewValue string `protobuf:"bytes,2,opt,name=new_value,json=newValue,proto3" json:"new_value,omitempty"`
	OldValue string `protobuf:"bytes,3,opt,name=old_value,json=oldValue,proto3" json:"old_value,omitempty"`
	// contains filtered or unexported fields
}

func (*Field) Descriptor deprecated 

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

Deprecated: Use Field.ProtoReflect.Descriptor instead.

func (*Field) GetName 

func (x *Field) GetName() string

func (*Field) GetNewValue 

func (x *Field) GetNewValue() string

func (*Field) GetOldValue 

func (x *Field) GetOldValue() string

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) ProtoReflect 

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

func (*Field) Reset 

func (x *Field) Reset()

func (*Field) String 

func (x *Field) 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 (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 

func (ForkStep) Type() protoreflect.EnumType

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 Manifest 

type Manifest struct {
	SpecVersion string    `protobuf:"bytes,1,opt,name=spec_version,json=specVersion,proto3" json:"spec_version,omitempty"`
	Description string    `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Modules     []*Module `protobuf:"bytes,3,rep,name=modules,proto3" json:"modules,omitempty"`
	ModulesCode [][]byte  `protobuf:"bytes,4,rep,name=modules_code,json=modulesCode,proto3" json:"modules_code,omitempty"`
	// contains filtered or unexported fields
}

func (*Manifest) Descriptor deprecated 

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

Deprecated: Use Manifest.ProtoReflect.Descriptor instead.

func (*Manifest) GetDescription 

func (x *Manifest) GetDescription() string

func (*Manifest) GetModules 

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

func (*Manifest) GetModulesCode 

func (x *Manifest) GetModulesCode() [][]byte

func (*Manifest) GetSpecVersion 

func (x *Manifest) GetSpecVersion() string

func (*Manifest) ProtoMessage 

func (*Manifest) ProtoMessage()

func (*Manifest) ProtoReflect 

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

func (*Manifest) Reset 

func (x *Manifest) Reset()

func (*Manifest) String 

func (x *Manifest) 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"`
	// Types that are assignable to Code:
	//	*Module_WasmCode_
	//	*Module_NativeCode_
	Code       isModule_Code   `protobuf_oneof:"code"`
	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"`
	StartBlock uint64          `protobuf:"varint,8,opt,name=start_block,json=startBlock,proto3" json:"start_block,omitempty"`
	// contains filtered or unexported fields
}

func (*Module) Descriptor deprecated 

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

Deprecated: Use Module.ProtoReflect.Descriptor instead.

func (*Module) GetCode 

func (m *Module) GetCode() isModule_Code

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) GetNativeCode 

func (x *Module) GetNativeCode() *Module_NativeCode

func (*Module) GetOutput 

func (x *Module) GetOutput() *Module_Output

func (*Module) GetStartBlock 

func (x *Module) GetStartBlock() uint64

func (*Module) GetWasmCode 

func (x *Module) GetWasmCode() *Module_WasmCode

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 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"`
	// 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) 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 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"`
	ProcessedRanges   []*BlockRange `protobuf:"bytes,2,rep,name=processed_ranges,json=processedRanges,proto3" json:"processed_ranges,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"`
	Failed            bool          `protobuf:"varint,7,opt,name=failed,proto3" json:"failed,omitempty"`
	FailureReason     string        `protobuf:"bytes,8,opt,name=failure_reason,json=failureReason,proto3" json:"failure_reason,omitempty"`
	// 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() bool

func (*ModuleProgress) GetFailureReason 

func (x *ModuleProgress) GetFailureReason() string

func (*ModuleProgress) GetName 

func (x *ModuleProgress) GetName() string

func (*ModuleProgress) GetProcessedRanges 

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

func (*ModuleProgress) GetTotalBytesRead 

func (x *ModuleProgress) GetTotalBytesRead() uint64

func (*ModuleProgress) GetTotalBytesWritten 

func (x *ModuleProgress) GetTotalBytesWritten() uint64

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 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 (x *Module_Input_Store) GetMode() Module_Input_Store_Mode

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) Descriptor() protoreflect.EnumDescriptor

func (Module_Input_Store_Mode) Enum 

func (x Module_Input_Store_Mode) Enum() *Module_Input_Store_Mode

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 (x Module_Input_Store_Mode) Number() protoreflect.EnumNumber

func (Module_Input_Store_Mode) String 

func (x Module_Input_Store_Mode) String() string

func (Module_Input_Store_Mode) Type 

func (Module_Input_Store_Mode) Type() protoreflect.EnumType

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_REPLACE Module_KindStore_UpdatePolicy = 1
	// Provides a store where you can `set_if_not_exists()` keys, and the first key wins
	Module_KindStore_UPDATE_POLICY_IGNORE Module_KindStore_UpdatePolicy = 2
	// Provides a store where you can `sum_*()` keys, where two stores merge by summing its values.
	Module_KindStore_UPDATE_POLICY_SUM 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
)

func (Module_KindStore_UpdatePolicy) Descriptor 

func (Module_KindStore_UpdatePolicy) Descriptor() protoreflect.EnumDescriptor

func (Module_KindStore_UpdatePolicy) Enum 

func (x Module_KindStore_UpdatePolicy) Enum() *Module_KindStore_UpdatePolicy

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 (x Module_KindStore_UpdatePolicy) Number() protoreflect.EnumNumber

func (Module_KindStore_UpdatePolicy) String 

func (x Module_KindStore_UpdatePolicy) String() string

func (Module_KindStore_UpdatePolicy) Type 

func (Module_KindStore_UpdatePolicy) Type() protoreflect.EnumType

type Module_NativeCode 

type Module_NativeCode struct {
	Entrypoint string `protobuf:"bytes,5,opt,name=entrypoint,proto3" json:"entrypoint,omitempty"`
	// contains filtered or unexported fields
}

func (*Module_NativeCode) Descriptor deprecated 

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

Deprecated: Use Module_NativeCode.ProtoReflect.Descriptor instead.

func (*Module_NativeCode) GetEntrypoint 

func (x *Module_NativeCode) GetEntrypoint() string

func (*Module_NativeCode) ProtoMessage 

func (*Module_NativeCode) ProtoMessage()

func (*Module_NativeCode) ProtoReflect 

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

func (*Module_NativeCode) Reset 

func (x *Module_NativeCode) Reset()

func (*Module_NativeCode) String 

func (x *Module_NativeCode) String() string

type Module_NativeCode_ 

type Module_NativeCode_ struct {
	NativeCode *Module_NativeCode `protobuf:"bytes,5,opt,name=native_code,json=nativeCode,proto3,oneof"`
}

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 Module_WasmCode 

type Module_WasmCode struct {
	Type       string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Index      uint32 `protobuf:"varint,5,opt,name=index,proto3" json:"index,omitempty"`
	Entrypoint string `protobuf:"bytes,6,opt,name=entrypoint,proto3" json:"entrypoint,omitempty"`
	// contains filtered or unexported fields
}

func (*Module_WasmCode) Descriptor deprecated 

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

Deprecated: Use Module_WasmCode.ProtoReflect.Descriptor instead.

func (*Module_WasmCode) GetEntrypoint 

func (x *Module_WasmCode) GetEntrypoint() string

func (*Module_WasmCode) GetIndex 

func (x *Module_WasmCode) GetIndex() uint32

func (*Module_WasmCode) GetType 

func (x *Module_WasmCode) GetType() string

func (*Module_WasmCode) ProtoMessage 

func (*Module_WasmCode) ProtoMessage()

func (*Module_WasmCode) ProtoReflect 

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

func (*Module_WasmCode) Reset 

func (x *Module_WasmCode) Reset()

func (*Module_WasmCode) String 

func (x *Module_WasmCode) String() string

type Module_WasmCode_ 

type Module_WasmCode_ struct {
	WasmCode *Module_WasmCode `protobuf:"bytes,4,opt,name=wasm_code,json=wasmCode,proto3,oneof"`
}

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 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 */
	Manifest                       *Manifest  `protobuf:"bytes,6,opt,name=manifest,proto3" json:"manifest,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) GetManifest 

func (x *Request) GetManifest() *Manifest

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) 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 {
	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 TableChange 

type TableChange struct {
	Table     string                `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	Pk        string                `protobuf:"bytes,2,opt,name=pk,proto3" json:"pk,omitempty"`
	BlockNum  uint64                `protobuf:"varint,3,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"`
	Ordinal   uint64                `protobuf:"varint,4,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
	Operation TableChange_Operation `protobuf:"varint,5,opt,name=operation,proto3,enum=sf.substreams.v1.TableChange_Operation" json:"operation,omitempty"`
	Fields    []*Field              `protobuf:"bytes,6,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*TableChange) Descriptor deprecated 

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

Deprecated: Use TableChange.ProtoReflect.Descriptor instead.

func (*TableChange) GetBlockNum 

func (x *TableChange) GetBlockNum() uint64

func (*TableChange) GetFields 

func (x *TableChange) GetFields() []*Field

func (*TableChange) GetOperation 

func (x *TableChange) GetOperation() TableChange_Operation

func (*TableChange) GetOrdinal 

func (x *TableChange) GetOrdinal() uint64

func (*TableChange) GetPk 

func (x *TableChange) GetPk() string

func (*TableChange) GetTable 

func (x *TableChange) GetTable() string

func (*TableChange) Merge 

func (x *TableChange) Merge(next *TableChange) error

func (*TableChange) ProtoMessage 

func (*TableChange) ProtoMessage()

func (*TableChange) ProtoReflect 

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

func (*TableChange) Reset 

func (x *TableChange) Reset()

func (*TableChange) String 

func (x *TableChange) String() string

type TableChange_Operation 

type TableChange_Operation int32
const (
	TableChange_UNSET  TableChange_Operation = 0
	TableChange_CREATE TableChange_Operation = 1
	TableChange_UPDATE TableChange_Operation = 2
	TableChange_DELETE TableChange_Operation = 3
)

func (TableChange_Operation) Descriptor 

func (TableChange_Operation) Descriptor() protoreflect.EnumDescriptor

func (TableChange_Operation) Enum 

func (x TableChange_Operation) Enum() *TableChange_Operation

func (TableChange_Operation) EnumDescriptor deprecated 

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

Deprecated: Use TableChange_Operation.Descriptor instead.

func (TableChange_Operation) Number 

func (x TableChange_Operation) Number() protoreflect.EnumNumber

func (TableChange_Operation) String 

func (x TableChange_Operation) String() string

func (TableChange_Operation) Type 

func (TableChange_Operation) Type() protoreflect.EnumType

type TableChanges 

type TableChanges []*TableChange

func (TableChanges) Merge 

func (x TableChanges) Merge() ([]*TableChange, error)

type UnimplementedStreamServer 

type UnimplementedStreamServer struct {
}

UnimplementedStreamServer should be embedded to have forward compatible implementations.

func (UnimplementedStreamServer) Blocks 

func (UnimplementedStreamServer) Blocks(*Request, Stream_BlocksServer) error

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.

Source Files

View all Source files

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.