mfile

Documentation

Index

• type File
  • func Parse(lines []string, model string) (*File, error)
  • func (f *File) GetConfig(key string) string
  • func (f *File) NewRunner(externalStr string) (*Runner, error)
• type Instance
• type Runner
  • func (r *Runner) RunSql(prepare bool) ([]sqlutil.BuildResult, error)
• type SqlEpochHandler
• type Variable

Types

type File

type File struct {
	Source  string
	RunType string

	Vars []Variable

	Conn db.Config

	Instances []Instance

	Idxes map[string]int
	// contains filtered or unexported fields
}

func Parse

func Parse(lines []string, model string) (*File, error)

func (*File) GetConfig

func (f *File) GetConfig(key string) string

func (*File) NewRunner

func (f *File) NewRunner(externalStr string) (*Runner, error)

type Instance

type Instance struct {
	Name       string
	Num        *mrule.Iterator
	FieldNames []string
	FieldIters []*mrule.Iterator
}

type Runner

type Runner struct {
	Vars      map[string]interface{}
	Externals map[string]string
	Idxes     map[string]int

	Instances []Instance
}

func (*Runner) RunSql

func (r *Runner) RunSql(prepare bool) ([]sqlutil.BuildResult, error)

type SqlEpochHandler

type SqlEpochHandler func(epoch []sqlutil.BuildResult, meta *mrule.EpochMeta) error

type Variable

type Variable struct {
	Name string
	Iter *mrule.Iterator
}