udpx

Documentation

Index

• func Init(ctx contextx.Context, ops ...func(opt *Option)) error
• func PutPackage(pkg *Package)
• func SendBinaryMsg(rAddr *net.UDPAddr, data []byte)
• func SendTextMsg(rAddr *net.UDPAddr, data []byte)
• type MsgType
• type Option
• type Package
  • func GetPackage() *Package
  • func (p *Package) Marshal() []byte
  • func (p *Package) Unmarshal(body []byte)

Functions

func Init

func Init(ctx contextx.Context, ops ...func(opt *Option)) error

func PutPackage

func PutPackage(pkg *Package)

func SendBinaryMsg

func SendBinaryMsg(rAddr *net.UDPAddr, data []byte)

func SendTextMsg

func SendTextMsg(rAddr *net.UDPAddr, data []byte)

Types

type MsgType

type MsgType int8

const (
	TextMessage   MsgType = 1
	BinaryMessage MsgType = 2
)

type Option

type Option struct {
	//ListenIp       string // 监听IP
	//Port           int    // 监听端口
	LAddr          *net.UDPAddr
	WriteTimeout   time.Duration
	MaxPkgSize     int32
	OnMsgHandle    func(addr *net.UDPAddr, data []byte)
	OnBinaryHandle func(addr *net.UDPAddr, data []byte)
}

type Package

type Package struct {
	Type    MsgType
	Payload []byte
}

func GetPackage

func GetPackage() *Package

func (*Package) Marshal

func (p *Package) Marshal() []byte

func (*Package) Unmarshal

func (p *Package) Unmarshal(body []byte)