net

package
v0.0.0-...-b1bf5db Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 18, 2017 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultWriteSize = 4096
)

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

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