didagle

type CondParams struct {
	Match string                 `toml:"match"`
	Args  map[string]interface{} `toml:"args"`
}

type ConfigSetting struct {
	Name      string `toml:"name"`
	Cond      string `toml:"cond"`
	Processor string `toml:"processor"`
}

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

type FieldFlags struct {
	Extern    int `json:"is_extern"`
	InOut     int `json:"is_in_out"`
	Agrregate int `json:"is_aggregate"`
}

type FieldMeta struct {
	Name  string     `json:"name"`
	ID    int64      `json:"id"`
	Type  string     `json:"type"`
	Flags FieldFlags `json:"flags"`
}

type Graph struct {
	Name   string   `toml:"name"`
	Vertex []Vertex `toml:"vertex"`
	// contains filtered or unexported fields
}

type GraphCluster struct {
	Desc                   string          `toml:"desc"`
	StrictDsl              bool            `toml:"strict_dsl"`
	DefaultExprProcessor   string          `toml:"default_expr_processor"`
	DefaultDefaultPoolSize string          `toml:"default_context_pool_size"`
	Graph                  []Graph         `toml:"graph"`
	ConfigSetting          []ConfigSetting `toml:"config_setting"`
	// contains filtered or unexported fields
}

type GraphData struct {
	ID         string   `toml:"id"`
	Field      string   `toml:"field"`
	Aggregate  []string `toml:"aggregate"`
	Cond       string   `toml:"cond"`
	Required   bool     `toml:"required"`
	Move       bool     `toml:"move"`
	IsExtern   bool     `toml:"extern"`
	IsInOut    bool
	IsMapInput bool
}

type OperatorMeta struct {
	Name   string      `json:"name"`
	Input  []FieldMeta `json:"input"`
	Output []FieldMeta `json:"output"`
}

type Vertex struct {
	ID           string       `toml:"id"`
	Processor    string       `toml:"processor"`
	Cond         string       `toml:"cond"`
	Expect       string       `toml:"expect"`
	ExpectConfig string       `toml:"expect_config"`
	SelectArgs   []CondParams `toml:"select_args"`

	Cluster        string   `toml:"cluster"`
	Graph          string   `toml:"graph"`
	Successor      []string `toml:"successor"`
	SuccessorOnOk  []string `toml:"if"`
	SuccessorOnErr []string `toml:"else"`
	Deps           []string `toml:"deps"`
	DepsOnOk       []string `toml:"deps_on_ok"`
	DepsOnErr      []string `toml:"deps_on_err"`

	Input  []GraphData `toml:"input"`
	Output []GraphData `toml:"output"`
	Start  bool        `toml:"start"`
	// contains filtered or unexported fields
}