types

Documentation

Index

• type Callbacks
• type ClientSession
• type Options
• type Packet
  • func (p *Packet) Address() (string, int)
  • func (p *Packet) Crc64() uint64
• type ServerConnection
• type ServerSession
• type Session
• type Stream

Types

type Callbacks

type Callbacks struct {
	OnConnectionOpen  func(connection Session)
	OnConnectionClose func(connection Session)

	OnStreamOpenCallback  func(stream Stream)
	OnStreamCloseCallback func(stream Stream, error int)
}

type ClientSession

type ClientSession interface {
	OpenStream() Stream

	Session
}

type Options

type Options interface {
	Get() (bool, string, string, string, string, string, uint64, bool)
}

type Packet

type Packet struct {
	Streamid   uint64
	Data       []byte
	DataLen    int
	RetAddress *net.UDPAddr
}

func (*Packet) Address

func (p *Packet) Address() (string, int)

func (*Packet) Crc64

func (p *Packet) Crc64() uint64

type ServerConnection

type ServerConnection interface {
	// Accept waits for and returns the next connection to the listener.
	Accept() (Stream, error)

	Session
}

type ServerSession

type ServerSession interface {
	// Accept waits for and returns the next connection to the listener.
	Accept() (ServerConnection, error)

	Session
}

type Session

type Session interface {
	ID() uint64

	OnStreamOpen(uint64)
	OnStreamClose(uint64, int)

	GetStream(uint64) Stream

	StreamPacket(*Packet)

	// Addr returns the listener's network address.
	Addr() net.Addr

	// Close closes the listener.
	// Any blocked Accept operations will be unblocked and return errors.
	Close() error
	IsClosed() bool
}

type Stream

type Stream interface {
	net.Conn

	ID() uint64

	Sync() bool
	OnOpened()
	OnReceived([]byte, int)
	OnSentBytes(uint64)
	OnAckedSentBytes(uint64)
	OnClosed() error

	IsClosed() bool
}