socket

package

v0.0.0-...-cd87c42 Latest Latest Go to latest Published: Mar 28, 2016 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/dgkang/cellnet

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func NewAcceptor(pipe cellnet.EventPipe) cellnet.Peer
func NewConnector(pipe cellnet.EventPipe) cellnet.Peer
func RegisterPeerMessage(eq cellnet.EventQueue, msgName string, ...) *cellnet.MessageMeta
func RegisterSessionMessage(eq cellnet.EventQueue, msgName string, ...) *cellnet.MessageMeta
func SetMessageLogHook(hook func(*MessageLogInfo) bool)
type MessageLogInfo
type PacketStream
- func NewPacketStream(conn net.Conn) PacketStream
type PeerEvent
- func NewPeerEvent(msgid uint32, p cellnet.Peer) *PeerEvent
- func (self PeerEvent) ContextID() uint32
- func (self PeerEvent) String() string
type SessionEvent
- func NewSessionEvent(msgid uint32, s cellnet.Session, data []byte) *SessionEvent
- func (self SessionEvent) String() string

Constants ¶

View Source

const (
	PackageHeaderSize = 8 // MsgID(uint32) + Ser(uint16) + Size(uint16)
	MaxPacketSize     = 1024 * 8
)

Variables ¶

View Source

var (
	Event_SessionConnected = uint32(cellnet.MessageMetaByName("coredef.SessionConnected").ID)
	Event_SessionClosed    = uint32(cellnet.MessageMetaByName("coredef.SessionClosed").ID)
	Event_SessionAccepted  = uint32(cellnet.MessageMetaByName("coredef.SessionAccepted").ID)
	Event_PeerInit         = uint32(cellnet.MessageMetaByName("coredef.PeerInit").ID)
	Event_PeerStart        = uint32(cellnet.MessageMetaByName("coredef.PeerStart").ID)
	Event_PeerStop         = uint32(cellnet.MessageMetaByName("coredef.PeerStop").ID)
)

View Source

var EnableMessageLog bool = true

是否启用消息日志

Functions ¶

func NewAcceptor ¶

func NewAcceptor(pipe cellnet.EventPipe) cellnet.Peer

func NewConnector ¶

func NewConnector(pipe cellnet.EventPipe) cellnet.Peer

func RegisterPeerMessage ¶

func RegisterPeerMessage(eq cellnet.EventQueue, msgName string, userHandler func(interface{}, cellnet.Peer)) *cellnet.MessageMeta

注册连接消息

func RegisterSessionMessage ¶

func RegisterSessionMessage(eq cellnet.EventQueue, msgName string, userHandler func(interface{}, cellnet.Session)) *cellnet.MessageMeta

注册连接消息

func SetMessageLogHook ¶

func SetMessageLogHook(hook func(*MessageLogInfo) bool)

Types ¶

type MessageLogInfo ¶

type MessageLogInfo struct {
	Dir       string
	PeerName  string
	SessionID int64
	Name      string
	Size      int32
	Data      string
}

type PacketStream ¶

type PacketStream interface {
	Read() (*cellnet.Packet, error)
	Write(pkt *cellnet.Packet) error
	Close() error
	Raw() net.Conn
}

封包流

func NewPacketStream ¶

func NewPacketStream(conn net.Conn) PacketStream

封包流 relay模式: 在封包头有clientid信息

type PeerEvent ¶

type PeerEvent struct {
	MsgID uint32
	P     cellnet.Peer
}

端事件

func NewPeerEvent ¶

func NewPeerEvent(msgid uint32, p cellnet.Peer) *PeerEvent

func (PeerEvent) ContextID ¶

func (self PeerEvent) ContextID() uint32

func (PeerEvent) String ¶

func (self PeerEvent) String() string

type SessionEvent ¶

type SessionEvent struct {
	*cellnet.Packet
	Ses cellnet.Session
}

会话事件

func NewSessionEvent ¶

func NewSessionEvent(msgid uint32, s cellnet.Session, data []byte) *SessionEvent

func (SessionEvent) String ¶

func (self SessionEvent) String() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL