pbsubstreams

package
v1.7.0 Latest Latest
Warning

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

 Go to latest Published: May 21, 2024 License: Apache-2.0 Imports: 9 Imported by: 26

Documentation

Index

Constants

View Source 
const (
	ModuleKindStore = ModuleKind(iota)
	ModuleKindMap
	ModuleKindBlockIndex
)

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 (
	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",
		7: "UPDATE_POLICY_SET_SUM",
	}
	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,
		"UPDATE_POLICY_SET_SUM":           7,
	}
)

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 File_sf_substreams_v1_clock_proto protoreflect.FileDescriptor
View Source 
var File_sf_substreams_v1_deltas_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

Functions

This section is empty.

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 BlockRef added in v1.0.2 

type BlockRef 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"`
	// contains filtered or unexported fields
}

BlockRef is a pointer to a block to which we don't know the timestamp

func (*BlockRef) Descriptor deprecated added in v1.0.2 

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

Deprecated: Use BlockRef.ProtoReflect.Descriptor instead.

func (*BlockRef) GetId added in v1.0.2 

func (x *BlockRef) GetId() string

func (*BlockRef) GetNumber added in v1.0.2 

func (x *BlockRef) GetNumber() uint64

func (*BlockRef) ProtoMessage added in v1.0.2 

func (*BlockRef) ProtoMessage()

func (*BlockRef) ProtoReflect added in v1.0.2 

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

func (*BlockRef) Reset added in v1.0.2 

func (x *BlockRef) Reset()

func (*BlockRef) String added in v1.0.2 

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

Clock is a pointer to a block with added timestamp

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 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_
	//	*Module_KindBlockIndex_
	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"`
	BlockFilter      *Module_BlockFilter `protobuf:"bytes,9,opt,name=block_filter,json=blockFilter,proto3" json:"block_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*Module) BlockFilterQueryString added in v1.6.0 

func (m *Module) BlockFilterQueryString() (string, error)

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) GetBlockFilter added in v1.4.0 

func (x *Module) GetBlockFilter() *Module_BlockFilter

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) GetKindBlockIndex added in v1.4.0 

func (x *Module) GetKindBlockIndex() *Module_KindBlockIndex

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) ModuleKind added in v0.1.0 

func (x *Module) ModuleKind() ModuleKind

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 ModuleKind added in v0.1.0 

type ModuleKind int

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 Module_BlockFilter added in v1.4.0 

type Module_BlockFilter struct {
	Module string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	// Types that are assignable to Query:
	//
	//	*Module_BlockFilter_QueryString
	//	*Module_BlockFilter_QueryFromParams
	Query isModule_BlockFilter_Query `protobuf_oneof:"query"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Module_BlockFilter.ProtoReflect.Descriptor instead.

func (*Module_BlockFilter) GetModule added in v1.4.0 

func (x *Module_BlockFilter) GetModule() string

func (*Module_BlockFilter) GetQuery added in v1.4.0 

func (m *Module_BlockFilter) GetQuery() isModule_BlockFilter_Query

func (*Module_BlockFilter) GetQueryFromParams added in v1.6.0 

func (x *Module_BlockFilter) GetQueryFromParams() *Module_QueryFromParams

func (*Module_BlockFilter) GetQueryString added in v1.6.0 

func (x *Module_BlockFilter) GetQueryString() string

func (*Module_BlockFilter) ProtoMessage added in v1.4.0 

func (*Module_BlockFilter) ProtoMessage()

func (*Module_BlockFilter) ProtoReflect added in v1.4.0 

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

func (*Module_BlockFilter) Reset added in v1.4.0 

func (x *Module_BlockFilter) Reset()

func (*Module_BlockFilter) String added in v1.4.0 

func (x *Module_BlockFilter) String() string

type Module_BlockFilter_QueryFromParams added in v1.6.0 

type Module_BlockFilter_QueryFromParams struct {
	QueryFromParams *Module_QueryFromParams `protobuf:"bytes,3,opt,name=query_from_params,json=queryFromParams,proto3,oneof"` // QueryFromStore query_from_store_keys = 3;
}

type Module_BlockFilter_QueryString added in v1.6.0 

type Module_BlockFilter_QueryString struct {
	QueryString string `protobuf:"bytes,2,opt,name=query_string,json=queryString,proto3,oneof"`
}

type Module_Input 

type Module_Input struct {

	// Types that are assignable to Input:
	//
	//	*Module_Input_Source_
	//	*Module_Input_Map_
	//	*Module_Input_Store_
	//	*Module_Input_Params_
	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) GetParams added in v1.0.0 

func (x *Module_Input) GetParams() *Module_Input_Params

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) Pretty added in v1.1.1 

func (x *Module_Input) Pretty() string

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_Params added in v1.0.0 

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

func (*Module_Input_Params) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use Module_Input_Params.ProtoReflect.Descriptor instead.

func (*Module_Input_Params) GetValue added in v1.0.0 

func (x *Module_Input_Params) GetValue() string

func (*Module_Input_Params) ProtoMessage added in v1.0.0 

func (*Module_Input_Params) ProtoMessage()

func (*Module_Input_Params) ProtoReflect added in v1.0.0 

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

func (*Module_Input_Params) Reset added in v1.0.0 

func (x *Module_Input_Params) Reset()

func (*Module_Input_Params) String added in v1.0.0 

func (x *Module_Input_Params) String() string

type Module_Input_Params_ added in v1.0.0 

type Module_Input_Params_ struct {
	Params *Module_Input_Params `protobuf:"bytes,4,opt,name=params,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) Pretty added in v1.1.15 

func (x Module_Input_Store_Mode) Pretty() string

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_KindBlockIndex added in v1.4.0 

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

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

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

Deprecated: Use Module_KindBlockIndex.ProtoReflect.Descriptor instead.

func (*Module_KindBlockIndex) GetOutputType added in v1.4.0 

func (x *Module_KindBlockIndex) GetOutputType() string

func (*Module_KindBlockIndex) ProtoMessage added in v1.4.0 

func (*Module_KindBlockIndex) ProtoMessage()

func (*Module_KindBlockIndex) ProtoReflect added in v1.4.0 

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

func (*Module_KindBlockIndex) Reset added in v1.4.0 

func (x *Module_KindBlockIndex) Reset()

func (*Module_KindBlockIndex) String added in v1.4.0 

func (x *Module_KindBlockIndex) String() string

type Module_KindBlockIndex_ added in v1.4.0 

type Module_KindBlockIndex_ struct {
	KindBlockIndex *Module_KindBlockIndex `protobuf:"bytes,10,opt,name=kind_block_index,json=kindBlockIndex,proto3,oneof"`
}

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
	// Provides a store with both `set()` and `sum()` functions.
	Module_KindStore_UPDATE_POLICY_SET_SUM Module_KindStore_UpdatePolicy = 7
)

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) Pretty added in v1.1.15 

func (x Module_KindStore_UpdatePolicy) Pretty() string

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_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_QueryFromParams added in v1.6.0 

type Module_QueryFromParams struct {
	// contains filtered or unexported fields
}

func (*Module_QueryFromParams) Descriptor deprecated added in v1.6.0 

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

Deprecated: Use Module_QueryFromParams.ProtoReflect.Descriptor instead.

func (*Module_QueryFromParams) ProtoMessage added in v1.6.0 

func (*Module_QueryFromParams) ProtoMessage()

func (*Module_QueryFromParams) ProtoReflect added in v1.6.0 

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

func (*Module_QueryFromParams) Reset added in v1.6.0 

func (x *Module_QueryFromParams) Reset()

func (*Module_QueryFromParams) String added in v1.6.0 

func (x *Module_QueryFromParams) 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 NetworkParams added in v1.3.0 

type NetworkParams struct {
	InitialBlocks map[string]uint64 `` /* 168-byte string literal not displayed */
	Params        map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NetworkParams) Descriptor deprecated added in v1.3.0 

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

Deprecated: Use NetworkParams.ProtoReflect.Descriptor instead.

func (*NetworkParams) GetInitialBlocks added in v1.3.0 

func (x *NetworkParams) GetInitialBlocks() map[string]uint64

func (*NetworkParams) GetParams added in v1.3.0 

func (x *NetworkParams) GetParams() map[string]string

func (*NetworkParams) ProtoMessage added in v1.3.0 

func (*NetworkParams) ProtoMessage()

func (*NetworkParams) ProtoReflect added in v1.3.0 

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

func (*NetworkParams) Reset added in v1.3.0 

func (x *NetworkParams) Reset()

func (*NetworkParams) String added in v1.3.0 

func (x *NetworkParams) 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"`
	// Source network for Substreams to fetch its data from.
	Network    string     `protobuf:"bytes,9,opt,name=network,proto3" json:"network,omitempty"`
	SinkConfig *anypb.Any `protobuf:"bytes,10,opt,name=sink_config,json=sinkConfig,proto3" json:"sink_config,omitempty"`
	SinkModule string     `protobuf:"bytes,11,opt,name=sink_module,json=sinkModule,proto3" json:"sink_module,omitempty"`
	// image is the bytes to a JPEG, WebP or PNG file. Max size is 2 MiB
	Image        []byte                    `protobuf:"bytes,12,opt,name=image,proto3" json:"image,omitempty"`
	Networks     map[string]*NetworkParams `` /* 158-byte string literal not displayed */
	BlockFilters map[string]string         `` /* 186-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Package) Descriptor deprecated 

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

Deprecated: Use Package.ProtoReflect.Descriptor instead.

func (*Package) GetBlockFilters added in v1.4.0 

func (x *Package) GetBlockFilters() map[string]string

func (*Package) GetImage added in v1.1.18 

func (x *Package) GetImage() []byte

func (*Package) GetModuleMeta 

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

func (*Package) GetModules 

func (x *Package) GetModules() *Modules

func (*Package) GetNetwork added in v1.0.0 

func (x *Package) GetNetwork() string

func (*Package) GetNetworks added in v1.3.0 

func (x *Package) GetNetworks() map[string]*NetworkParams

func (*Package) GetPackageMeta 

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

func (*Package) GetProtoFiles 

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

func (*Package) GetSinkConfig added in v1.0.0 

func (x *Package) GetSinkConfig() *anypb.Any

func (*Package) GetSinkModule added in v1.0.0 

func (x *Package) GetSinkModule() string

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 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 {
	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 added in v1.4.0 

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

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.