ltvsocket

Documentation

Overview

ltvsocket包使用cell框架封装socket层, 同时使用length-type-value格式的私有协议 进行收发封包处理

使用本包可以迅速建立socket互联及统一的开发框架

Index

• Constants
• func NewPacketStream(conn net.Conn) cellnet.IPacketStream
• func SpawnAcceptor(address string, callback func(cellnet.CellID, interface{})) cellnet.CellID
• func SpawnConnector(address string, callback func(cellnet.CellID, interface{})) cellnet.CellID
• func SpawnSession(stream cellnet.IPacketStream, callback func(cellnet.CellID, interface{})) cellnet.CellID
• type EventAccepted
  • func (self EventAccepted) Stream() cellnet.IPacketStream
• type EventClose
• type EventConnectError
• type EventConnected
  • func (self EventConnected) Stream() cellnet.IPacketStream
• type EventListenError
• type EventNewSession
• type PacketStream
  • func (self *PacketStream) Close() error
  • func (self *PacketStream) Read() (p *cellnet.Packet, err error)
  • func (self *PacketStream) Write(pkt *cellnet.Packet) (err error)

Constants

const (
	PackageHeaderSize = 8
	MaxPacketSize     = 1024 * 8
)

Functions

func NewPacketStream

func NewPacketStream(conn net.Conn) cellnet.IPacketStream

func SpawnAcceptor

func SpawnAcceptor(address string, callback func(cellnet.CellID, interface{})) cellnet.CellID

func SpawnConnector

func SpawnConnector(address string, callback func(cellnet.CellID, interface{})) cellnet.CellID

func SpawnSession

func SpawnSession(stream cellnet.IPacketStream, callback func(cellnet.CellID, interface{})) cellnet.CellID

Types

type EventAccepted

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

func (EventAccepted) Stream

func (self EventAccepted) Stream() cellnet.IPacketStream

type EventClose

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

type EventConnectError

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

type EventConnected

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

func (EventConnected) Stream

func (self EventConnected) Stream() cellnet.IPacketStream

type EventListenError

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

type EventNewSession

type EventNewSession interface {
	Stream() cellnet.IPacketStream
}

type PacketStream

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

func (*PacketStream) Close

func (self *PacketStream) Close() error

func (*PacketStream) Read

func (self *PacketStream) Read() (p *cellnet.Packet, err error)

参考hub_client.go Read a packet from a datastream interface , return packet struct

func (*PacketStream) Write

func (self *PacketStream) Write(pkt *cellnet.Packet) (err error)

Write a packet to datastream interface