ans

Documentation

Index

• type Anser
  • func (a *Anser) Handler()
  • func (a *Anser) Listen()
  • func (a *Anser) Write(cid int32, data *[]byte, length int32) error
• type HandlerChain
• type HandlerFunc
• type HttpAnser
  • func (a *HttpAnser) Finish(c *ghttp.Context)
  • func (a *HttpAnser) GetContext(cid int32) *ghttp.Context
  • func (a *HttpAnser) Listen()
  • func (a *HttpAnser) Send(c *ghttp.Context)
  • func (a *HttpAnser) SetWorkHandler()
• type IAnswer
  • func NewAnser(socketType define.SocketType, laddr *net.TCPAddr, nConnect int32, nWork int32) (IAnswer, error)
  • func NewHttpAnser(laddr *net.TCPAddr, nConnect int32, nWork int32) (IAnswer, error)
  • func NewTcp0Anser(laddr *net.TCPAddr, nConnect int32, nWork int32) (IAnswer, error)
• type Router
  • func (r *Router) GET(path string, handlers ...HandlerFunc)
  • func (r *Router) NewRouter(relativePath string, handlers ...HandlerFunc) *Router
  • func (r *Router) POST(path string, handlers ...HandlerFunc)
• type Tcp0Anser
  • func (a *Tcp0Anser) Listen()
  • func (a *Tcp0Anser) SetWorkHandler(handler func(*base.Work))

Types

type Anser

type Anser struct {

	// 讀取超時
	ReadTimeout time.Duration
	// contains filtered or unexported fields
}

func (*Anser) Handler

func (a *Anser) Handler()

持續檢查是否有未完成的工作，若有，則呼叫外部定義的 workHandler 函式

func (*Anser) Listen

func (a *Anser) Listen()

監聽連線並註冊

func (*Anser) Write

func (a *Anser) Write(cid int32, data *[]byte, length int32) error

type HandlerChain

type HandlerChain []HandlerFunc

type HandlerFunc

type HandlerFunc func(c *ghttp.Context)

type HttpAnser

type HttpAnser struct {
	*Anser
	*Router

	// key1: Method(Get/Post); key2: path; value: []HandlerFunc
	Handlers map[string]map[string]HandlerChain
	// contains filtered or unexported fields
}

func (*HttpAnser) Finish

func (a *HttpAnser) Finish(c *ghttp.Context)

func (*HttpAnser) GetContext

func (a *HttpAnser) GetContext(cid int32) *ghttp.Context

func (*HttpAnser) Listen

func (a *HttpAnser) Listen()

監聽連線並註冊

func (*HttpAnser) Send

func (a *HttpAnser) Send(c *ghttp.Context)

func (*HttpAnser) SetWorkHandler

func (a *HttpAnser) SetWorkHandler()

由外部定義 workHandler，定義如何處理工作

type IAnswer

type IAnswer interface {
	// 開始監聽
	Listen()
	// 執行一次主迴圈
	Handler()
	// 數據寫出(寫到寫出緩存中)
	Write(int32, *[]byte, int32) error
}

func NewAnser

func NewAnser(socketType define.SocketType, laddr *net.TCPAddr, nConnect int32, nWork int32) (IAnswer, error)

func NewHttpAnser

func NewHttpAnser(laddr *net.TCPAddr, nConnect int32, nWork int32) (IAnswer, error)

func NewTcp0Anser

func NewTcp0Anser(laddr *net.TCPAddr, nConnect int32, nWork int32) (IAnswer, error)

type Router

type Router struct {
	*HttpAnser

	Handlers HandlerChain
	// contains filtered or unexported fields
}

==================================================================================================== Router ====================================================================================================

func (*Router) GET

func (r *Router) GET(path string, handlers ...HandlerFunc)

func (*Router) NewRouter

func (r *Router) NewRouter(relativePath string, handlers ...HandlerFunc) *Router

func (*Router) POST

func (r *Router) POST(path string, handlers ...HandlerFunc)

type Tcp0Anser

type Tcp0Anser struct {
	*Anser
	// contains filtered or unexported fields
}

func (*Tcp0Anser) Listen

func (a *Tcp0Anser) Listen()

監聽連線並註冊

func (*Tcp0Anser) SetWorkHandler

func (a *Tcp0Anser) SetWorkHandler(handler func(*base.Work))

由外部定義 workHandler，定義如何處理工作