common

type AggType int

type BlockingPlanNode interface {
	Execute(ctx context.Context) (queryCom.AQLQueryResult, error)
	Children() []BlockingPlanNode
	Add(...BlockingPlanNode)
}

type MergeNode interface {
	BlockingPlanNode
	AggType() AggType
}

type QueryExecutor interface {
	// Execute executes query and flush result to connection
	Execute(ctx context.Context, requestID string, aql *queryCom.AQLQuery, returnHLLBinary bool, w http.ResponseWriter) (err error)
}

type QueryPlan interface {
	Execute(ctx context.Context, w http.ResponseWriter) (err error)
}

type SchemaManager interface {
	// Run initializes all schema and starts jobs to sync from controller
	Run()
	// GetTable gets schema by namespace and table name
	GetTableSchemaReader(namespace string) (memCom.TableSchemaReader, error)
}