conn

Dec 3, 2020

Changes in this version

type Event

+ func (e *Event) Push(data interface{})

Dec 3, 2020

Changes in this version

type EventQueue

+ func (eq *EventQueue) Post(e *Event)

Dec 3, 2020

Changes in this version

+ type Event struct

+ Eg *Engine

+ Handle func(event *Event)

+ func (e *Event) Rsp() interface{}

Dec 3, 2020

Changes in this version

+ func NewEvent(s func(event *event)) *event

+ type EventQueue struct

+ Queue chan *event

+ func NewEventQueue(l int) *EventQueue

Nov 9, 2020

Changes in this version

type Engine

+ func (e *Engine) ExecByPsql(sql string, val []interface{}) error

Nov 9, 2020

Changes in this version

type Engine

+ func (e *Engine) BuildDataMode(mode interface{}, data []map[string]interface{}) (list []interface{})

Nov 9, 2020

Changes in this version

type Engine

+ func (e *Engine) Out(mode interface{}, data []map[string]interface{}) (list []interface{})

Nov 9, 2020

Changes in this version

type Engine

+ func (e *Engine) QueryByPsql(sm *base.SqlModify) (list []map[string]interface{}, total int, err error)

Nov 3, 2020

Changes in this version

type Engine

+ func (e *Engine) GetParam(def interface{}) error

Oct 24, 2020

Changes in this version

type Engine

+ func (e *Engine) OutErr(data interface{})

+ func (e *Engine) OutList(data interface{})

+ func (e *Engine) OutSuccess()

Oct 24, 2020

Changes in this version

+ type Engine struct

+ Data map[string]string

+ Log *base.Logger

+ Req *http.Request

+ Res http.ResponseWriter

+ type Handle func(*Engine)

+ type Tcp struct

+ Conns map[string]TcpEngine

+ Method map[int]TcpHandle

+ Protocol TcpHandle

+ func NewTcp() *Tcp

+ func (t *Tcp) AddProtocol(f TcpHandle)

+ func (t *Tcp) AddRoute(cmd int, f TcpHandle)

+ func (t *Tcp) Start(host string, port int)

+ type TcpEngine struct

+ Cache []byte

+ Handel net.Conn

+ Log *base.Logger

+ Owner *Tcp

+ Pack interface{}

+ WC chan []byte

+ func (t *TcpEngine) Listen()

+ type TcpHandle func(*TcpEngine)

+ type Web struct

+ Process chan struct{}

+ Run bool

+ func NewWeb() *Web

+ func (web *Web) AddRoute(path string, r Handle)

+ func (web *Web) AddService(i interface{})

+ func (web *Web) GetParam(req *http.Request) (map[string]interface{}, error)

+ func (web *Web) Listen(port int)

+ func (web *Web) ServeHTTP(rw http.ResponseWriter, req *http.Request)

+ func (web *Web) Wait() chan struct{}