script

Documentation

Index

• Constants
• Variables
• func RegisterMessageType(L *lua.LState)
• type Base64Module
  • func (b *Base64Module) Decode(l *lua.LState) int
  • func (b *Base64Module) Encode(l *lua.LState) int
  • func (b *Base64Module) Loader(l *lua.LState) int
• type HttpModule
  • func NewHttpModule() *HttpModule
  • func NewHttpModuleWithDo(client *http.Client) *HttpModule
  • func (h *HttpModule) GetReport() []Report
  • func (h *HttpModule) Loader(L *lua.LState) int
• type MD5Module
  • func (m *MD5Module) Loader(l *lua.LState) int
  • func (m *MD5Module) Sum(l *lua.LState) int
• type Message
• type MgoModule
  • func NewMgoModule() *MgoModule
  • func (m *MgoModule) Loader(L *lua.LState) int
• type ProtoModule
  • func (p *ProtoModule) Loader(l *lua.LState) int
  • func (p *ProtoModule) Marshal(L *lua.LState) int
  • func (p *ProtoModule) Unmarshal(L *lua.LState) int
• type Report
• type TCPModule
  • func NewTCPModule() *TCPModule
  • func (t *TCPModule) Close(L *lua.LState) int
  • func (t *TCPModule) GetReport() []Report
  • func (t *TCPModule) Loader(L *lua.LState) int
• type UtilsModule
  • func (u *UtilsModule) Loader(l *lua.LState) int
  • func (u *UtilsModule) Random(l *lua.LState) int
  • func (u *UtilsModule) UUID(l *lua.LState) int
• type WebsocketModule
  • func NewWebsocketModule() *WebsocketModule
  • func (ws *WebsocketModule) Close(L *lua.LState) int
  • func (ws *WebsocketModule) GetReport() []Report
  • func (ws *WebsocketModule) Loader(L *lua.LState) int

Constants

const (
	Little = "LittleEndian"
	Big    = "BigEndian"
)

Variables

var (
	ErrNil = lua.LString("nil")
)

Functions

func RegisterMessageType

func RegisterMessageType(L *lua.LState)

Registers type to given L.

Types

type Base64Module

type Base64Module struct {
}

func (*Base64Module) Decode

func (b *Base64Module) Decode(l *lua.LState) int

func (*Base64Module) Encode

func (b *Base64Module) Encode(l *lua.LState) int

func (*Base64Module) Loader

func (b *Base64Module) Loader(l *lua.LState) int

type HttpModule

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

func NewHttpModule

func NewHttpModule() *HttpModule

func NewHttpModuleWithDo

func NewHttpModuleWithDo(client *http.Client) *HttpModule

func (*HttpModule) GetReport

func (h *HttpModule) GetReport() []Report

func (*HttpModule) Loader

func (h *HttpModule) Loader(L *lua.LState) int

type MD5Module

type MD5Module struct {
}

func (*MD5Module) Loader

func (m *MD5Module) Loader(l *lua.LState) int

func (*MD5Module) Sum

func (m *MD5Module) Sum(l *lua.LState) int

type Message

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

type MgoModule

type MgoModule struct {
	Url    string
	DBName string
	// contains filtered or unexported fields
}

func NewMgoModule

func NewMgoModule() *MgoModule

func (*MgoModule) Loader

func (m *MgoModule) Loader(L *lua.LState) int

type ProtoModule

type ProtoModule struct {
}

func (*ProtoModule) Loader

func (p *ProtoModule) Loader(l *lua.LState) int

func (*ProtoModule) Marshal

func (p *ProtoModule) Marshal(L *lua.LState) int

func (*ProtoModule) Unmarshal

func (p *ProtoModule) Unmarshal(L *lua.LState) int

type Report

type Report struct {
	MsgID string
	Err   string
}

Report 网络层在处理消息时的信息

因为流式消息无法保证 req/res 配对，因此不再记录消费时间

type TCPModule

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

func NewTCPModule

func NewTCPModule() *TCPModule

func (*TCPModule) Close

func (t *TCPModule) Close(L *lua.LState) int

func (*TCPModule) GetReport

func (t *TCPModule) GetReport() []Report

func (*TCPModule) Loader

func (t *TCPModule) Loader(L *lua.LState) int

type UtilsModule

type UtilsModule struct {
}

func (*UtilsModule) Loader

func (u *UtilsModule) Loader(l *lua.LState) int

func (*UtilsModule) Random

func (u *UtilsModule) Random(l *lua.LState) int

func (*UtilsModule) UUID

func (u *UtilsModule) UUID(l *lua.LState) int

type WebsocketModule

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

func NewWebsocketModule

func NewWebsocketModule() *WebsocketModule

func (*WebsocketModule) Close

func (ws *WebsocketModule) Close(L *lua.LState) int

func (*WebsocketModule) GetReport

func (ws *WebsocketModule) GetReport() []Report

func (*WebsocketModule) Loader

func (ws *WebsocketModule) Loader(L *lua.LState) int