Documentation ¶
Index ¶
- type Config
- type Daemon
- func (d *Daemon) BroadcastManageReq(req ManageRequest) error
- func (d *Daemon) JsonHandler(w http.ResponseWriter, r *http.Request)
- func (d *Daemon) ManageHandler(w http.ResponseWriter, r *http.Request)
- func (d *Daemon) QueryHandleWorker(ctx context.Context)
- func (d *Daemon) QueryStreams(name string, querys Querys) (endCh chan bool, err error)
- func (d *Daemon) Serve(ctx context.Context) error
- func (d *Daemon) UtilServe()
- func (d *Daemon) Worker(ctx context.Context, ManageCh chan ManageRequest)
- type ManageCmd
- type ManageRequest
- type ManageResponse
- type Options
- type Query
- type Querys
- type QuerysRequest
- type Request
- type Response
- type Worker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { Listen string ManageListen string WorkerLimit int WorkerDefault int LoadDir string ListenLimit int LogLevel int }
func LoadConfig ¶
type Daemon ¶
type Daemon struct { Config QuerysQ chan QuerysRequest Queue chan Request PoolCounter chan bool MaxWorker chan int MngQ []chan ManageRequest WorkCount chan bool }
func (*Daemon) BroadcastManageReq ¶
func (d *Daemon) BroadcastManageReq(req ManageRequest) error
func (*Daemon) JsonHandler ¶
func (d *Daemon) JsonHandler(w http.ResponseWriter, r *http.Request)
func (*Daemon) ManageHandler ¶
func (d *Daemon) ManageHandler(w http.ResponseWriter, r *http.Request)
func (*Daemon) QueryHandleWorker ¶
func (*Daemon) QueryStreams ¶
type ManageRequest ¶
type ManageResponse ¶
type ManageResponse struct { Body interface{} Err error }
type QuerysRequest ¶
Click to show internal directories.
Click to hide internal directories.