commpipe

package

v0.0.0-...-5c775dd Latest Latest Go to latest Published: Jun 24, 2024 License: MIT Imports: 4 Imported by: 0

Details

View Source

const MaxFrameSize = 1<<16 - 1

This section is empty.

func Handshake(p *Pipe) error

Handshake initiates a handshake request and waits for a response.

func ShakeHand(p *Pipe) error

ShakeHand is the inverse of Handshake and shakes the reaching hand.

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

Pipe is a bi-directional communication channel.

func NewPipe(inp io.Reader, out io.Writer) *Pipe

func (p *Pipe) Read(out *TLVFrame) (err error)

func (p *Pipe) Write(f *TLVFrame) error

type TLVFrame struct {
	Type TLVType
	Size uint64
	Data []byte
}

func (f *TLVFrame) ReadFrom(r io.Reader) (n int64, err error)

func (f *TLVFrame) WriteTo(w io.Writer) (n int64, err error)

type TLVType uint64

const (
	TLVTypeHandshake TLVType = iota + 1
	TLVTypePing
	TLVTypePong
	TLVTypeQuit
	TLVTypeUser
)

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

func NewTrackingReader(rd io.Reader, offset *int64) *TrackingReader

func (r *TrackingReader) Offset() int64

func (r *TrackingReader) Read(p []byte) (n int, err error)

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

func NewTrackingWriter(wr io.Writer, offset *int64) *TrackingWriter

func (w *TrackingWriter) Offset() int64

func (w *TrackingWriter) Write(p []byte) (n int, err error)