test

Documentation

Index

• type Result
• type Runner
  • func NewRunner(path string, descs map[string]*manifest.ModuleDescriptor, verbose bool, ...) (*Runner, error)
  • func (r *Runner) LogResults()
  • func (r *Runner) Test(ctx context.Context, output *pbsubstreamsrpc.MapModuleOutput, ...) error
• type Spec
• type StorageDelta
• type Test
• type TestConfig
  • func (t *TestConfig) Test(idx int) (*Test, error)

Types

type Result

type Result struct {
	Valid bool
	Msg   string
	// contains filtered or unexported fields
}

type Runner

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

func NewRunner

func NewRunner(path string, descs map[string]*manifest.ModuleDescriptor, verbose bool, logger *zap.Logger) (*Runner, error)

func (*Runner) LogResults

func (r *Runner) LogResults()

func (*Runner) Test

func (r *Runner) Test(
	ctx context.Context,
	output *pbsubstreamsrpc.MapModuleOutput,
	debugMapOutputs []*pbsubstreamsrpc.MapModuleOutput,
	debugStoreOutputs []*pbsubstreamsrpc.StoreModuleOutput,
	clock *pbsubstreams.Clock,
) error

type Spec

type Spec struct {
	Tests []*TestConfig `json:"tests"`
}

type StorageDelta

type StorageDelta struct {
	Operation string           `json:"op"`
	Ordinal   uint64           `json:"ordinal"`
	Key       string           `json:"key"`
	OldValue  *json.RawMessage `json:"old,omitempty"`
	NewValue  *json.RawMessage `json:"new,omitempty"`
}

type Test

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

type TestConfig

type TestConfig struct {
	Module string `json:"module" yaml:"module"`
	Block  uint64 `json:"block" yaml:"block"`
	Path   string `json:"path" yaml:"path"`
	Expect string `json:"expect" yaml:"expect"`
	Op     string `json:"op,omitempty" yaml:"op"`
	Args   string `json:"args,omitempty" yaml:"args"`
}

func (*TestConfig) Test

func (t *TestConfig) Test(idx int) (*Test, error)