transfer

Documentation

Index

• func ReadFile(r io.Reader, destDir string, progress func(int64, int64)) (string, error)
• func ReadFrame(r io.Reader) (proto.Frame, error)
• func WriteFile(srcPath, from, transferID string, w io.Writer, progress func(int64, int64)) error
• func WriteFileWithChunkSize(srcPath, from, transferID string, w io.Writer, chunkSize int, ...) error
• func WriteFrame(w io.Writer, f proto.Frame) error

Functions

func ReadFile

func ReadFile(r io.Reader, destDir string, progress func(int64, int64)) (string, error)

ReadFile reads FILE_START, FILE_CHUNK..., FILE_END frames from r into destDir. progress is called after each chunk. Returns the path of the written file.

func ReadFrame

func ReadFrame(r io.Reader) (proto.Frame, error)

ReadFrame reads one Frame from r.

func WriteFile

func WriteFile(srcPath, from, transferID string, w io.Writer, progress func(int64, int64)) error

WriteFile sends FILE_START, FILE_CHUNK..., FILE_END frames to w. progress, if non-nil, is invoked after each chunk with (sentBytes, totalBytes). transferID is echoed in FILE_START so the receiver can ACK against the same id.

func WriteFileWithChunkSize

func WriteFileWithChunkSize(srcPath, from, transferID string, w io.Writer, chunkSize int, progress func(int64, int64)) error

func WriteFrame

func WriteFrame(w io.Writer, f proto.Frame) error

WriteFrame encodes a Frame as: [4-byte big-endian length][JSON payload]