Versions in this module Expand all Collapse all v0 v0.3.0 Aug 22, 2021 Changes in this version + const ARG_PERMS + const ARG_RECURSIVE + const ARG_SENDER + const ARG_SERVER + const ARG_SYMLINK + const DEFLATED_DATA + const END1 + const END2 + const END_FLAG + const EXCLUSION_END + const FLIST_END + const FLIST_GID_SAME + const FLIST_MODE_SAME + const FLIST_NAME_LONG + const FLIST_NAME_SAME + const FLIST_RDEV_SAME + const FLIST_TIME_SAME + const FLIST_TOP_LEVEL + const FLIST_UID_SAME + const G + const INDEX_END + const K + const M + const MAXPATHLEN + const MSG_DATA + const MSG_DELETED + const MSG_ERROR + const MSG_ERROR_XFER + const MSG_INFO + const MSG_IO_ERROR + const MSG_NOOP + const MSG_NO_SEND + const MSG_SUCCESS + const MSG_WARNING + const MUX_BASE + const PHASE_END + const RSYNCD_OK + const RSYNC_EXIT + const RSYNC_VERSION + const SAMPLE_ARGS + const SAMPLE_LIST_ARGS + const S_IFBLK + const S_IFCHR + const S_IFDIR + const S_IFIFO + const S_IFLNK + const S_IFMT + const S_IFREG + const S_IFSOCK + const TOKENRUN_LONG + const TOKENRUN_REL + const TOKEN_LONG + const TOKEN_REL + func NewflatedtokenReader(reader Conn) *flatedtokenReader + func SplitURI(uri string) (string, string, string, error) + func SplitURIS(uri string) (string, int, string, string, error) + func TrimPrepath(prepath string) string + type Attribs struct + DryRun bool + HasGID bool + HasLinks bool + HasModTime bool + HasPerms bool + HasUID bool + Recursive bool + Sender bool + Server bool + func (a *Attribs) Marshal() []byte + type Conn struct + func (conn *Conn) Close() error + func (conn *Conn) Read(p []byte) (n int, err error) + func (conn *Conn) ReadByte() (byte, error) + func (conn *Conn) ReadInt() (int32, error) + func (conn *Conn) ReadLong() (int64, error) + func (conn *Conn) ReadShort() (int16, error) + func (conn *Conn) ReadVarint() (int64, error) + func (conn *Conn) Write(p []byte) (n int, err error) + func (conn *Conn) WriteByte(data byte) error + func (conn *Conn) WriteInt(data int32) error + func (conn *Conn) WriteLong(data int64) error + func (conn *Conn) WriteShort(data int16) error + type Exclusion struct + func (e *Exclusion) Add(pattern string) + func (e *Exclusion) Match(name string) (matched bool, err error) + func (e *Exclusion) SendExlusion(conn Conn) error + type FS interface + Delete func(fileName string, mode FileMode) error + List func() (FileList, error) + Put func(fileName string, content io.Reader, fileSize int64, metadata FileMetadata) (written int64, err error) + type File interface + type FileInfo struct + Mode FileMode + Mtime int32 + Path []byte + Size int64 + type FileList []FileInfo + func (L FileList) Diff(R FileList) (newitems []int, olditems []int) + func (L FileList) Len() int + func (L FileList) Less(i, j int) bool + func (L FileList) Swap(i, j int) + type FileMetadata struct + Mode FileMode + Mtime int32 + type FileMode uint32 + func NewFileMode(mode os.FileMode) FileMode + func (m FileMode) Convert() os.FileMode + func (m FileMode) IsBLK() bool + func (m FileMode) IsDIR() bool + func (m FileMode) IsFIFO() bool + func (m FileMode) IsLNK() bool + func (m FileMode) IsREG() bool + func (m FileMode) IsSOCK() bool + func (m FileMode) Perm() FileMode + func (m FileMode) String() string + type MuxReader struct + func NewMuxReader(reader io.ReadCloser) *MuxReader + func (r *MuxReader) Close() error + func (r *MuxReader) Read(p []byte) (n int, err error) + type MuxReaderV0 struct + Data chan byte + func NewMuxReaderV0(reader io.ReadCloser) *MuxReaderV0 + func (r *MuxReaderV0) Close() error + func (r *MuxReaderV0) Read(p []byte) (n int, err error) + type Receiver struct + func (r *Receiver) BuildArgs() string + func (r *Receiver) FileCleaner(localList FileList, deleteList []int) error + func (r *Receiver) FileDownloader(localList FileList) error + func (r *Receiver) FinalPhase() error + func (r *Receiver) Generator(remoteList FileList, downloadList []int, symlinks map[string][]byte) error + func (r *Receiver) RecvFileList() (FileList, map[string][]byte, error) + func (r *Receiver) SendExclusions() error + func (r *Receiver) StartMuxIn() + func (r *Receiver) Sync() error + type SSH struct + func NewSSH(address string, username string, pwd string, cmd string) (*SSH, error) + func (s *SSH) Close() error + func (s *SSH) Read(p []byte) (n int, err error) + func (s *SSH) Write(p []byte) (n int, err error) + type SendReceiver interface + Sync func() error + func SocketClient(storage FS, address string, module string, path string, ...) (SendReceiver, error) + func SshClient(storage FS, address string, module string, path string, ...) (SendReceiver, error) + type Sender struct + func (s *Sender) FileUploader() error + func (s *Sender) FinalPhase() error + func (s *Sender) Generator(fileList FileList) error + func (s *Sender) SendFileList() error + func (s *Sender) Sync() error + type SumChunk struct + type SumStruct struct