net

Documentation

Index

• Constants
• type DecryptFunc
• type EncryptFunc
• type PacketHandler
• type ReadStream
  • func (rs *ReadStream) Read() (n int, err error)
  • func (rs *ReadStream) SetDecrypt(dec DecryptFunc)
  • func (rs *ReadStream) SetPacketHandler(handle PacketHandler)
  • func (rs *ReadStream) SetTimeout(t time.Duration)
• type ReadWriteStream
  • func NewRWStream(conn net.Conn, writeSize int, handle PacketHandler) (rws *ReadWriteStream)
  • func (rws *ReadWriteStream) Send(buf *buffer.Buffer)
  • func (rws *ReadWriteStream) Start(onStarted, onEnd func())
  • func (rws *ReadWriteStream) Stop()
• type Stream
• type StreamReadWriter
• type StreamReader
• type StreamWriter
• type WriteStream
  • func (ws *WriteStream) Send(buf *buffer.Buffer)
  • func (ws *WriteStream) SetEncrypt(enc EncryptFunc)

Constants

const (
	DefaultWriteSize = 4096
)

Types

type DecryptFunc

type DecryptFunc func(dst, src []byte)

type EncryptFunc

type EncryptFunc func(dst, src []byte)

type PacketHandler

type PacketHandler func(packet []byte)

type ReadStream

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

ReadStream

func (*ReadStream) Read

func (rs *ReadStream) Read() (n int, err error)

func (*ReadStream) SetDecrypt

func (rs *ReadStream) SetDecrypt(dec DecryptFunc)

func (*ReadStream) SetPacketHandler

func (rs *ReadStream) SetPacketHandler(handle PacketHandler)

func (*ReadStream) SetTimeout

func (rs *ReadStream) SetTimeout(t time.Duration)

type ReadWriteStream

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

ReadWriteStream

func NewRWStream

func NewRWStream(conn net.Conn, writeSize int, handle PacketHandler) (rws *ReadWriteStream)

new read write stream

func (*ReadWriteStream) Send

func (rws *ReadWriteStream) Send(buf *buffer.Buffer)

func (*ReadWriteStream) Start

func (rws *ReadWriteStream) Start(onStarted, onEnd func())

func (*ReadWriteStream) Stop

func (rws *ReadWriteStream) Stop()

type Stream

type Stream interface {
	Conn() net.Conn
}

type StreamReadWriter

type StreamReadWriter interface {
	StreamReader
	StreamWriter
}

type StreamReader

type StreamReader interface {
	Read() (int, error)
	SetDecrypt(DecryptFunc)
	SetTimeout(time.Duration)
}

type StreamWriter

type StreamWriter interface {
	Write() (int, error)
	SetEncrypt(EncryptFunc)
}

type WriteStream

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

WriteStream

func (*WriteStream) Send

func (ws *WriteStream) Send(buf *buffer.Buffer)

func (*WriteStream) SetEncrypt

func (ws *WriteStream) SetEncrypt(enc EncryptFunc)