primitivegraph

type PrimitiveGraph interface {
	AddTxnControlCounters(t internaldto.TxnControlCounters)
	ContainsIndirect() bool
	CreatePrimitiveNode(pr primitive.IPrimitive) PrimitiveNode
	Execute(ctx primitive.IPrimitiveCtx) internaldto.ExecutorOutput
	GetInputFromAlias(string) (internaldto.ExecutorOutput, bool)
	IncidentData(fromId int64, input internaldto.ExecutorOutput) error
	GetTxnControlCounterSlice() []internaldto.TxnControlCounters
	NewDependency(from PrimitiveNode, to PrimitiveNode, weight float64)
	Optimise() error
	SetContainsIndirect(containsView bool)
	SetExecutor(func(pc primitive.IPrimitiveCtx) internaldto.ExecutorOutput) error
	SetInputAlias(alias string, id int64) error
	SetTxnId(id int)
	Sort() (sorted []graph.Node, err error)
}

type PrimitiveNode interface {
	GetPrimitive() primitive.IPrimitive
	ID() int64
	SetInputAlias(alias string, id int64) error
}