rsyncwire

Documentation

Index

• Constants
• func CounterPair(r io.Reader, w io.Writer) (*CountingReader, *CountingWriter)
• type Buffer
  • func (b *Buffer) String() string
  • func (b *Buffer) WriteByte(data byte)
  • func (b *Buffer) WriteInt32(data int32)
  • func (b *Buffer) WriteInt64(data int64)
  • func (b *Buffer) WriteString(data string)
• type Conn
  • func (c *Conn) ReadByte() (byte, error)
  • func (c *Conn) ReadInt32() (int32, error)
  • func (c *Conn) ReadInt64() (int64, error)
  • func (c *Conn) WriteByte(data byte) error
  • func (c *Conn) WriteInt32(data int32) error
  • func (c *Conn) WriteInt64(data int64) error
  • func (c *Conn) WriteString(data string) error
• type CountingReader
  • func (r *CountingReader) Read(p []byte) (n int, err error)
• type CountingWriter
  • func (w *CountingWriter) Write(p []byte) (n int, err error)
• type MultiplexReader
  • func (w *MultiplexReader) Read(p []byte) (n int, err error)
  • func (w *MultiplexReader) ReadMsg() (tag uint8, p []byte, err error)
• type MultiplexWriter
  • func (w *MultiplexWriter) Write(p []byte) (n int, err error)
  • func (w *MultiplexWriter) WriteMsg(tag uint8, p []byte) (n int, err error)

Constants

const (
	MsgData  uint8 = 0
	MsgInfo  uint8 = 2
	MsgError uint8 = 1
)

Functions

func CounterPair

func CounterPair(r io.Reader, w io.Writer) (*CountingReader, *CountingWriter)

Types

type Buffer

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

func (*Buffer) String

func (b *Buffer) String() string

func (*Buffer) WriteByte

func (b *Buffer) WriteByte(data byte)

func (*Buffer) WriteInt32

func (b *Buffer) WriteInt32(data int32)

func (*Buffer) WriteInt64

func (b *Buffer) WriteInt64(data int64)

func (*Buffer) WriteString

func (b *Buffer) WriteString(data string)

type Conn

type Conn struct {
	Writer io.Writer
	Reader io.Reader
}

func (*Conn) ReadByte

func (c *Conn) ReadByte() (byte, error)

func (*Conn) ReadInt32

func (c *Conn) ReadInt32() (int32, error)

func (*Conn) ReadInt64

func (c *Conn) ReadInt64() (int64, error)

func (*Conn) WriteByte

func (c *Conn) WriteByte(data byte) error

func (*Conn) WriteInt32

func (c *Conn) WriteInt32(data int32) error

func (*Conn) WriteInt64

func (c *Conn) WriteInt64(data int64) error

func (*Conn) WriteString

func (c *Conn) WriteString(data string) error

type CountingReader

type CountingReader struct {
	R         io.Reader
	BytesRead int64
}

func (*CountingReader) Read

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

type CountingWriter

type CountingWriter struct {
	W            io.Writer
	BytesWritten int64
}

func (*CountingWriter) Write

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

type MultiplexReader

type MultiplexReader struct {
	Reader io.Reader
}

func (*MultiplexReader) Read

func (w *MultiplexReader) Read(p []byte) (n int, err error)

func (*MultiplexReader) ReadMsg

func (w *MultiplexReader) ReadMsg() (tag uint8, p []byte, err error)

type MultiplexWriter

type MultiplexWriter struct {
	Writer io.Writer
}

func (*MultiplexWriter) Write

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

func (*MultiplexWriter) WriteMsg

func (w *MultiplexWriter) WriteMsg(tag uint8, p []byte) (n int, err error)