iokit

Documentation

Index

• Variables
• func Close(conn ...io.Closer)
• func CloseAll(connSlice ...net.Conn)
• func CopyBuffer(dst io.Writer, src io.Reader, bufLength int, block bool, monitor bool) (int64, error)
• func CopyBufferBlock(dst io.Writer, src io.Reader, monitor bool) (int64, error)
• func CopyBufferCallBack(dst io.Writer, src io.Reader, bufLength int, block bool, ...) (total []byte, err error)
• func CopyDuplex(src io.ReadWriteCloser, dst io.ReadWriteCloser, thenClose bool) chan Direction
• func DirectCopy(dst io.Writer, src io.Reader) (int64, error)
• func ForceClose(conn ...io.Closer)
• func IsConnect(conn net.Conn) bool
• func NewConn(connFactory ConnFactoryFunc) (net.Conn, error)
• func Read(rd io.Reader, b []byte) (int, error)
• func ReadAllBytes(rd io.Reader) ([]byte, error)
• func ReadAllBytesBuffer(rd io.Reader, bufLength int, block bool) ([]byte, error)
• func ReadAllBytesNonBlocking(rd io.Reader) ([]byte, error)
• func ReadAllString(rd io.Reader) (string, error)
• func ReadCurrentFile(relative string) ([]byte, error)
• func ReadFile(path string) ([]byte, error)
• func ReadFileToBuf(filePath string, bufSize int, receive func([]byte)) error
• func ReadFirstLine(file string) (string, error)
• func ReadLine(rd io.Reader) (line []byte, err error)
• func ReadLines(rd io.Reader) ([][]byte, error)
• func ReadToByte(rd io.Reader, delim byte) ([]byte, error)
• func ReadToBytes(rd io.Reader, delim []byte) ([]byte, error)
• func ScanLine(filePath string, handle func(string)) error
• func SetDeadLine(conn net.Conn, d time.Duration)
• func Write(wr io.Writer, b []byte) (int, error)
• func WriteString(wr io.Writer, s string) (int, error)
• func WriteToCurrentFile(relative string, bytes []byte) error
• func WriteToFile(bytes []byte, path string) error
• type BinaryInterceptor
• type ConnFactoryFunc
• type Direction

Variables

var Monitor = false

Functions

func Close

func Close(conn ...io.Closer)

func CloseAll

func CloseAll(connSlice ...net.Conn)

func CopyBuffer

func CopyBuffer(dst io.Writer, src io.Reader, bufLength int, block bool, monitor bool) (int64, error)

func CopyBufferBlock

func CopyBufferBlock(dst io.Writer, src io.Reader, monitor bool) (int64, error)

func CopyBufferCallBack

func CopyBufferCallBack(dst io.Writer, src io.Reader, bufLength int, block bool, intercept BinaryInterceptor) (total []byte, err error)

func CopyDuplex

func CopyDuplex(src io.ReadWriteCloser, dst io.ReadWriteCloser, thenClose bool) chan Direction

func DirectCopy

func DirectCopy(dst io.Writer, src io.Reader) (int64, error)

func ForceClose

func ForceClose(conn ...io.Closer)

func IsConnect

func IsConnect(conn net.Conn) bool

func NewConn

func NewConn(connFactory ConnFactoryFunc) (net.Conn, error)

func Read

func Read(rd io.Reader, b []byte) (int, error)

func ReadAllBytes

func ReadAllBytes(rd io.Reader) ([]byte, error)

func ReadAllBytesBuffer

func ReadAllBytesBuffer(rd io.Reader, bufLength int, block bool) ([]byte, error)

func ReadAllBytesNonBlocking

func ReadAllBytesNonBlocking(rd io.Reader) ([]byte, error)

func ReadAllString

func ReadAllString(rd io.Reader) (string, error)

func ReadCurrentFile

func ReadCurrentFile(relative string) ([]byte, error)

func ReadFile

func ReadFile(path string) ([]byte, error)

func ReadFileToBuf

func ReadFileToBuf(filePath string, bufSize int, receive func([]byte)) error

func ReadFirstLine

func ReadFirstLine(file string) (string, error)

func ReadLine

func ReadLine(rd io.Reader) (line []byte, err error)

func ReadLines

func ReadLines(rd io.Reader) ([][]byte, error)

func ReadToByte

func ReadToByte(rd io.Reader, delim byte) ([]byte, error)

func ReadToBytes

func ReadToBytes(rd io.Reader, delim []byte) ([]byte, error)

func ScanLine

func ScanLine(filePath string, handle func(string)) error

func SetDeadLine

func SetDeadLine(conn net.Conn, d time.Duration)

func Write

func Write(wr io.Writer, b []byte) (int, error)

func WriteString

func WriteString(wr io.Writer, s string) (int, error)

func WriteToCurrentFile

func WriteToCurrentFile(relative string, bytes []byte) error

func WriteToFile

func WriteToFile(bytes []byte, path string) error

Types

type BinaryInterceptor

type BinaryInterceptor func(...[]byte)

type ConnFactoryFunc

type ConnFactoryFunc func() (net.Conn, error)

type Direction

type Direction int

const (
	Upload   Direction = 0
	Download Direction = 1
)