void

type CloseReason int32

type Codec interface {
	Marshal(v interface{}) ([]byte, error)
	Unmarshal(data []byte, v interface{}) error
	Name() string
	MimeType() string
}

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

type Event interface {
	Session() Session
	Message() interface{}
}

type EventHandler func(e Event)

type EventHooker interface {
	OnInboundEvent(input Event) (output Event)
	OnOutboundEvent(input Event) (output Event)
}

type EventQueue interface {
	StartLoop() EventQueue
	StopLoop() EventQueue
	Wait()
	Post(callback func())
}

type MessageTransmitter interface {
	OnRecvMessage(s Session) (msg interface{}, err error)
	OnSendMessage(s Session, msg interface{}) error
}

type Meta interface {
	TypeName() string
	GetType() reflect.Type
	GetID() int
	NewType() interface{}
	GetCodec() Codec
}

type Peer interface {
	PeerProperty
	Start() Peer
	Stop()
	TypeName() string
}

type PeerListener interface {
	Port() int
}

type PeerProperty interface {
	Name() string
	Address() string
	Queue() EventQueue
	SetName(string)
	SetAddress(string)
	SetQueue(EventQueue)
}

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

type Processor interface {
	SetHooker(h EventHooker)
	SetTransmitter(t MessageTransmitter)
	SetHandler(handler EventHandler)
	ReadMessage(s Session) (msg interface{}, err error)
	SendMessage(e Event)
	ProcessEvent(e Event)
}

type Session interface {
	Raw() interface{}
	Peer() Peer
	Send(msg interface{})
	Close()
	ID() int64
	SetID(int64)
}

type SessionAccepted struct{}

type SessionAccessor interface {
	GetSession(int64) Session
	VisitSession(func(Session) bool)
	SessionCount() int
	CloseAllSession()
}

type SessionCloseNotify struct{}

type SessionClosed struct {
	Reason CloseReason // 断开原因
}

type SessionConnectError struct{}

type SessionConnected struct{}

type SessionInit struct{}

type SessionManager interface {
	SessionAccessor
	Add(s Session)
	Remove(s Session)
	Count() int
	SetIDBase(base int64)
}

type TCPAcceptor interface {
	Peer
	PeerListener
	SessionAccessor
	TCPSocketOption
}

type TCPConnector interface {
	Peer
	PeerListener
	TCPSocketOption

	SetReconnectDuration(time.Duration)
	ReconnectDuration() time.Duration
	Session() Session
	SetSessionManager(raw interface{})
}

type TCPSocketOption interface {
	// 收发缓冲大小，默认-1
	SetSocketBuffer(readBufferSize, writeBufferSize int, noDelay bool)

	// 设置最大的封包大小
	SetMaxPacketSize(maxSize int)

	// 设置读写超时，默认0，不超时
	SetSocketDeadline(read, write time.Duration)

	ApplySocketOption(conn net.Conn)

	MaxPacketSize() int
	ApplySocketReadTimeout(conn net.Conn, callback func())
	ApplySocketWriteTimeout(conn net.Conn, callback func())

	Init()
}