codegen

Documentation

Index

• Variables
• type Argument
  • func NewArgument(name string, argType string, moduleInput *manifest.Input) *Argument
• type Arguments
• type Engine
  • func (e *Engine) FunctionSignature(module *manifest.Module) (*FunctionSignature, error)
  • func (e *Engine) GetEngine() *Engine
  • func (e *Engine) ModuleArgument(inputs []*manifest.Input) (Arguments, error)
  • func (e *Engine) MustModule(moduleName string) *manifest.Module
  • func (e *Engine) ReadableStoreDeclaration(name string, store *manifest.Module, input *manifest.Input) string
  • func (e *Engine) ReadableStoreType(store *manifest.Module, input *manifest.Input) string
  • func (e *Engine) WritableStoreDeclaration(store *manifest.Module) string
  • func (e *Engine) WritableStoreType(store *manifest.Module) string
• type FunctionSignature
  • func NewFunctionSignature(name string, t string, outType string, storePolicy string, arguments Arguments) *FunctionSignature
• type GenerationOptions
  • func WithTestWriter(w io.Writer) GenerationOptions
• type Generator
  • func NewGenerator(pkg *pbsubstreams.Package, manifest *manifest.Manifest, ...) *Generator
  • func (g *Generator) Generate() (err error)
• type ProjectGenerator
  • func NewProjectGenerator(srcPath, projectName string, opts ...ProjectGeneratorOption) *ProjectGenerator
  • func (g *ProjectGenerator) GenerateProject() error
• type ProjectGeneratorOption
  • func WithProjectVersion(version string) ProjectGeneratorOption
  • func WithRustVersion(version string) ProjectGeneratorOption
• type ProtoGenerator
  • func NewProtoGenerator(outputPath string, excludedPaths []string) *ProtoGenerator
  • func (g *ProtoGenerator) GenerateProto(pkg *pbsubstreams.Package) error

Variables

var DefaultProjectVersion = "0.0.0"

var DefaultRustVersion = "1.60.0"

var DefaultSubstreamsVersion = "0.4.0"

var E_RUST_MODULE = &protoimpl.ExtensionInfo{
	ExtendedType:  (*descriptorpb.FileOptions)(nil),
	ExtensionType: (*string)(nil),
	Field:         56781,
	Name:          "rust_module",
	Tag:           "bytes",
}

var StoreType = map[string]string{
	"bytes":      "Raw",
	"string":     "String",
	"bigint":     "BigInt",
	"bigdecimal": "BigDecimal",
	"bigfloat":   "BigDecimal",
	"int64":      "Int64",
	"i64":        "Int64",
	"float64":    "Float64",
	"boolean":    "bool",
}

var UpdatePoliciesMap = map[string]string{
	"":                                  "Unset",
	manifest.UpdatePolicySet:            "Set",
	manifest.UpdatePolicySetIfNotExists: "SetIfNotExists",
	manifest.UpdatePolicyAdd:            "Add",
	manifest.UpdatePolicyMin:            "Min",
	manifest.UpdatePolicyMax:            "Max",
	manifest.UpdatePolicyAppend:         "Append",
}

Types

type Argument

type Argument struct {
	Name        string
	Type        string
	ModuleInput *manifest.Input
}

func NewArgument

func NewArgument(name string, argType string, moduleInput *manifest.Input) *Argument

type Arguments

type Arguments []*Argument

type Engine

type Engine struct {
	Manifest *manifest.Manifest
}

func (*Engine) FunctionSignature

func (e *Engine) FunctionSignature(module *manifest.Module) (*FunctionSignature, error)

func (*Engine) GetEngine

func (e *Engine) GetEngine() *Engine

func (*Engine) ModuleArgument

func (e *Engine) ModuleArgument(inputs []*manifest.Input) (Arguments, error)

func (*Engine) MustModule

func (e *Engine) MustModule(moduleName string) *manifest.Module

func (*Engine) ReadableStoreDeclaration

func (e *Engine) ReadableStoreDeclaration(name string, store *manifest.Module, input *manifest.Input) string

func (*Engine) ReadableStoreType

func (e *Engine) ReadableStoreType(store *manifest.Module, input *manifest.Input) string

func (*Engine) WritableStoreDeclaration

func (e *Engine) WritableStoreDeclaration(store *manifest.Module) string

func (*Engine) WritableStoreType

func (e *Engine) WritableStoreType(store *manifest.Module) string

type FunctionSignature

type FunctionSignature struct {
	Name        string
	Type        string
	OutputType  string
	StorePolicy string
	Arguments   Arguments
}

func NewFunctionSignature

func NewFunctionSignature(name string, t string, outType string, storePolicy string, arguments Arguments) *FunctionSignature

type GenerationOptions

type GenerationOptions func(options *generateOptions)

func WithTestWriter

func WithTestWriter(w io.Writer) GenerationOptions

type Generator

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

func NewGenerator

func NewGenerator(pkg *pbsubstreams.Package, manifest *manifest.Manifest, protoDefinitions []*desc.FileDescriptor, srcPath string) *Generator

func (*Generator) Generate

func (g *Generator) Generate() (err error)

type ProjectGenerator

type ProjectGenerator struct {
	ProjectName       string
	ProjectVersion    string
	RustVersion       string
	SubstreamsVersion string
	// contains filtered or unexported fields
}

func NewProjectGenerator

func NewProjectGenerator(srcPath, projectName string, opts ...ProjectGeneratorOption) *ProjectGenerator

func (*ProjectGenerator) GenerateProject

func (g *ProjectGenerator) GenerateProject() error

type ProjectGeneratorOption

type ProjectGeneratorOption func(*ProjectGenerator)

func WithProjectVersion

func WithProjectVersion(version string) ProjectGeneratorOption

func WithRustVersion

func WithRustVersion(version string) ProjectGeneratorOption

type ProtoGenerator

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

func NewProtoGenerator

func NewProtoGenerator(outputPath string, excludedPaths []string) *ProtoGenerator

func (*ProtoGenerator) GenerateProto

func (g *ProtoGenerator) GenerateProto(pkg *pbsubstreams.Package) error