lib

type Configure struct {
	HttpHandleUrl       string `json:"HttpHandleUrl"`
	WebsocketHandlerUrl string `json:"WebsocketHandlerUrl"`
	DataVerify          DataVerifyType
	NadoDefaultHandle   Header

	MessageTimeout time.Duration `json:"MessageTimeout,timeunit:s"`
	AppKey         string        `json:"AppKey"`
	AppSecret      string        `json:"AppSecret"`

	NsqConsumerTopic  string `json:"NsqConsumerTopic"`
	NsqProducterTopic string `json:"NsqProducterTopic"`
	NsqChannel        string `json:"NsqChannel"`
	NsqDefaultHandle  Header
	NsqMaxConsumer    int      `json:"NsqMaxConsumer"`
	NsqdLookupds      []string `json:"NsqdLookupds"`
	NsqdAddress       string   `json:"NsqdAddress"`
	NsqConfig         *nsq.Config

	OnServeStop   func()
	OnServeStart  func()
	OnConnectStop func(w ResponseWrite, r Request) //当链接中断时的回调函数
}

type DataVerifyType func([]byte) error

type Header func(w ResponseWrite, r Request)

type Headers map[uint16]Header

type Message interface {
	ByteBody() []byte
}

type Request interface {
	Reset()
	Type() uint16
	Unmarshal(interface{}) error
	Marshal(interface{}) error
	Byte() []byte
	BaseByte() []byte
	GetId() uint64
	SetType(uint16)
}

type RequestByNsq interface {
	Reset()
	Type() uint16
	Unmarshal(interface{}) error
	Marshal(interface{}) error
	Byte() []byte
	BaseByte() []byte
	GetId() uint64
	GetRoute() string
	SetRoute(string)
	SetId(uint64)
	Copy() RequestByNsq
}

type RequestResponse struct {
	Res ResponseWrite
	Req Request
}

type ResponseWrite interface {
	Write([]byte) error
	Close() error
}

type ResponseWriteByNsq interface {
	Write([]byte) error
	Close() error
	Copy() ResponseWriteByNsq
}

type ServeHandle interface {
	Run(conf *Configure) error
	Stop()
}

type TestRequest struct {
	TypeId uint16
	Id     uint64
	// contains filtered or unexported fields
}

type TestResponseWrite struct {
	// contains filtered or unexported fields
}