Versions in this module Expand all Collapse all v0 v0.0.1 Jun 20, 2016 Changes in this version + func NewClient() *client + func NewServer() *server + type Buffer struct + func NewBuffer() *Buffer + func (b *Buffer) Cap() int + func (b *Buffer) GetReadPos() int + func (b *Buffer) GetWritePos() int + func (b *Buffer) Index(sep []byte) int + func (b *Buffer) PutBytes(buffer []byte) + func (b *Buffer) PutBytesAt(pos int, buffer []byte) error + func (b *Buffer) PutInt(i int) + func (b *Buffer) PutString(s string) + func (b *Buffer) PutUint32(i uint32) + func (b *Buffer) ReadBytes(length int) ([]byte, error) + func (b *Buffer) ReadBytesAt(pos, length int) ([]byte, error) + func (b *Buffer) ReadInt() (int, error) + func (b *Buffer) ReadLength() int + func (b *Buffer) ReadString(length int) (string, error) + func (b *Buffer) ReadUint16() (uint16, error) + func (b *Buffer) ReadUint32() (uint32, error) + func (b *Buffer) ReadUint8() (uint8, error) + func (b *Buffer) ResetRead() + func (b *Buffer) ResetWrite() + func (b *Buffer) SetReadPos(pos int) error + type Codecer interface + Decode func(message interface{}) (interface{}, bool) + Encode func(message interface{}) (interface{}, bool) + type IoFilter interface + ErrorCaught func(sesion *Iosession, err error) bool + MsgReceived func(session *Iosession, message interface{}) bool + MsgSend func(session *Iosession, message interface{}) bool + SessionClosed func(session *Iosession) bool + SessionOpened func(session *Iosession) bool + type IoFilterAdapter struct + func (*IoFilterAdapter) ErrorCaught(session *Iosession, err error) bool + func (*IoFilterAdapter) MsgReceived(session *Iosession, message interface{}) bool + func (*IoFilterAdapter) MsgSend(session *Iosession, message interface{}) bool + func (*IoFilterAdapter) SessionClosed(session *Iosession) bool + func (*IoFilterAdapter) SessionOpened(session *Iosession) bool + type IoFilterChain struct + func (f *IoFilterChain) AddAfter(baseName, name string, filter IoFilter) *IoFilterChain + func (f *IoFilterChain) AddBefore(baseName, name string, filter IoFilter) *IoFilterChain + func (f *IoFilterChain) AddLast(name string, filter IoFilter) *IoFilterChain + type Iosession struct + Data interface{} + func (this *Iosession) Close() + func (this *Iosession) GetConn() net.Conn + func (this *Iosession) Write(message interface{}) error + type ProtocalCodec struct + func (*ProtocalCodec) Decode(message interface{}) (interface{}, bool) + func (*ProtocalCodec) Encode(message interface{}) (interface{}, bool)