engine

package

v1.4.2 Latest Latest Go to latest Published: Aug 14, 2023 License: Apache-2.0, MIT, MPL-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/pingcap/diag

Links

Open Source Insights

Documentation ¶

Index ¶

func GetRegisterFunc() map[string]interface{}
type ComputeUnit
- func NewComputeUnit(hd *proto.HandleData) *ComputeUnit
type Wrapper
- func NewWrapper(sd *proto.SourceDataV2, rs map[string]*proto.Rule, rd *render.ResultWrapper) *Wrapper

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL