engine

Documentation

Index

• func GetRegisterFunc() map[string]interface{}
• type ComputeUnit
  • func NewComputeUnit(hd *proto.HandleData) *ComputeUnit
  • func (u *ComputeUnit) Compute() (map[string]interface{}, error)
  • func (u *ComputeUnit) GetDataSet() *proto.HandleData
  • func (u *ComputeUnit) MockEmptyResult() map[string]interface{}
  • func (u *ComputeUnit) Register(dataContext *genginecontext.DataContext)
  • func (u *ComputeUnit) RuleSplicing() string
• type Wrapper
  • func NewWrapper(sd *proto.SourceDataV2, rs map[string]*proto.Rule, rd *render.ResultWrapper) *Wrapper
  • func (w *Wrapper) CrossData(oriData [][]proto.Data) [][]proto.Data
  • func (w *Wrapper) Exec() error
  • func (w *Wrapper) FindData(namestruct string) ([]proto.Data, error)
  • func (w *Wrapper) GenHandleData(ds [][]proto.Data) []*proto.HandleData
  • func (w *Wrapper) GetDataSet(namestructs string) ([]*proto.HandleData, error)
  • func (w *Wrapper) PackageResult(hd *proto.HandleData, resultset map[string]interface{}) error
  • func (w *Wrapper) SplitNamestruct(namestructs string) []string
  • func (w *Wrapper) Start(ctx context.Context) error

Functions

func GetRegisterFunc

func GetRegisterFunc() map[string]interface{}

Types

type ComputeUnit

type ComputeUnit struct {
	Rules      []*proto.Rule
	HandleData *proto.HandleData
}

unique {data1, data2}

func NewComputeUnit

func NewComputeUnit(hd *proto.HandleData) *ComputeUnit

func (*ComputeUnit) Compute

func (u *ComputeUnit) Compute() (map[string]interface{}, error)

func (*ComputeUnit) GetDataSet

func (u *ComputeUnit) GetDataSet() *proto.HandleData

func (*ComputeUnit) MockEmptyResult

func (u *ComputeUnit) MockEmptyResult() map[string]interface{}

func (*ComputeUnit) Register

func (u *ComputeUnit) Register(dataContext *genginecontext.DataContext)

func (*ComputeUnit) RuleSplicing

func (u *ComputeUnit) RuleSplicing() string

type Wrapper

type Wrapper struct {
	SourceData *proto.SourceDataV2
	Render     *render.ResultWrapper
	RuleResult map[string]proto.PrintTemplate
	RuleSet    map[string]*proto.Rule
	// contains filtered or unexported fields
}

func NewWrapper

func NewWrapper(sd *proto.SourceDataV2, rs map[string]*proto.Rule, rd *render.ResultWrapper) *Wrapper

func (*Wrapper) CrossData

func (w *Wrapper) CrossData(oriData [][]proto.Data) [][]proto.Data

func (*Wrapper) Exec

func (w *Wrapper) Exec() error

func (*Wrapper) FindData

func (w *Wrapper) FindData(namestruct string) ([]proto.Data, error)

func (*Wrapper) GenHandleData

func (w *Wrapper) GenHandleData(ds [][]proto.Data) []*proto.HandleData

func (*Wrapper) GetDataSet

func (w *Wrapper) GetDataSet(namestructs string) ([]*proto.HandleData, error)

func (*Wrapper) PackageResult

func (w *Wrapper) PackageResult(hd *proto.HandleData, resultset map[string]interface{}) error

func (*Wrapper) SplitNamestruct

func (w *Wrapper) SplitNamestruct(namestructs string) []string

func (*Wrapper) Start

func (w *Wrapper) Start(ctx context.Context) error