daemon

type Config struct {
	Listen        string
	ManageListen  string
	WorkerLimit   int
	WorkerDefault int
	LoadDir       string
	ListenLimit   int
	LogLevel      int
}

type Daemon struct {
	Config

	Queue       chan Request
	PoolCounter chan bool
	MaxWorker   chan int
	MngQ        []chan ManageRequest
}

type ManageCmd uint

type ManageRequest struct {
	Cmd   ManageCmd
	Name  string
	Path  string
	Node  *core.Node
	ResCh chan ManageResponse
	From  string
	To    string
}

type ManageResponse struct {
	Body interface{}
	Err  error
}

type Options struct {
	core.PhpOptions
	OrderDesc  bool   `json:"order_by,omitempty"`
	OrderBy    string `json:"order_desc,omitempty"`
	QueryCache bool   `json:"query_cache,omitempty"`
}

type Query struct {
	Options     `json:"options"`
	core.Stream `json:"stream"`
}

type Querys []Query

type Request struct {
	Query core.Stream
	Name  string
	ResCh chan Response
	EndCh chan bool
}

type Response struct {
	Result *core.Relation
	Err    error
}

type Worker struct {
	*Daemon
	DataBuf [][]core.Value
}