protocol

Jul 26, 2015

Changes in this version

type FileInfo

+ func (f FileInfo) WinsConflict(other FileInfo) bool

Jul 13, 2015

Changes in this version

type Connection

+ Start func()

Jun 28, 2015

Changes in this version

+ var PingIdleTime = 60 * time.Second

+ var PingTimeout = 30 * time.Second

Apr 22, 2015

Changes in this version

+ const FlagIndexTemporary

+ const FlagRequestTemporary

+ var ErrGeneric = errors.New("generic error")

+ var ErrInvalid = errors.New("file is invalid")

+ var ErrNoError error = nil

+ var ErrNoSuchFile = errors.New("no such file")

type BlockInfo

+ func (o *BlockInfo) DecodeXDRFrom(xr *xdr.Reader) error

+ func (o BlockInfo) EncodeXDRInto(xw *xdr.Writer) (int, error)

type CloseMessage

+ func (o *CloseMessage) DecodeXDRFrom(xr *xdr.Reader) error

+ func (o CloseMessage) EncodeXDRInto(xw *xdr.Writer) (int, error)

type ClusterConfigMessage

+ func (o *ClusterConfigMessage) DecodeXDRFrom(xr *xdr.Reader) error

+ func (o ClusterConfigMessage) EncodeXDRInto(xw *xdr.Writer) (int, error)

+ type Counter struct

+ ID uint64

+ Value uint64

type Device

+ Options []Option

+ func (o *Device) DecodeXDRFrom(xr *xdr.Reader) error

+ func (o Device) EncodeXDRInto(xw *xdr.Writer) (int, error)

type DeviceID

+ func (n DeviceID) Short() uint64

type EmptyMessage

+ func (o *EmptyMessage) DecodeXDRFrom(xr *xdr.Reader) error

+ func (o EmptyMessage) EncodeXDRInto(xw *xdr.Writer) (int, error)

type FileInfo

+ func (o *FileInfo) DecodeXDRFrom(xr *xdr.Reader) error

+ func (o FileInfo) EncodeXDRInto(xw *xdr.Writer) (int, error)

type Folder

+ Flags uint32

+ Options []Option

+ func (o *Folder) DecodeXDRFrom(xr *xdr.Reader) error

+ func (o Folder) EncodeXDRInto(xw *xdr.Writer) (int, error)

type IndexMessage

+ func (o *IndexMessage) DecodeXDRFrom(xr *xdr.Reader) error

+ func (o IndexMessage) EncodeXDRInto(xw *xdr.Writer) (int, error)

type Option

+ func (o *Option) DecodeXDRFrom(xr *xdr.Reader) error

+ func (o Option) EncodeXDRInto(xw *xdr.Writer) (int, error)

+ type Ordering int

+ const ConcurrentGreater

+ const ConcurrentLesser

+ const Equal

+ const Greater

+ const Lesser

type RequestMessage

+ func (o *RequestMessage) DecodeXDRFrom(xr *xdr.Reader) error

+ func (o RequestMessage) EncodeXDRInto(xw *xdr.Writer) (int, error)

type ResponseMessage

+ Code int32

+ func (o *ResponseMessage) DecodeXDRFrom(xr *xdr.Reader) error

+ func (o ResponseMessage) EncodeXDRInto(xw *xdr.Writer) (int, error)

+ type Vector []Counter

+ func (a Vector) Compare(b Vector) Ordering

+ func (a Vector) Concurrent(b Vector) bool

+ func (a Vector) Equal(b Vector) bool

+ func (a Vector) GreaterEqual(b Vector) bool

+ func (a Vector) LesserEqual(b Vector) bool

+ func (a Vector) Merge(b Vector) Vector

+ func (v *Vector) DecodeXDRFrom(r xdrReader) error

+ func (v Vector) Copy() Vector

+ func (v Vector) Counter(id uint64) uint64

+ func (v Vector) EncodeXDRInto(w xdrWriter) (int, error)

+ func (v Vector) Update(ID uint64) Vector

Mar 11, 2015

Changes in this version

+ type Compression int

+ const CompressAlways

+ const CompressMetadata

+ const CompressNever

+ func (c *Compression) UnmarshalText(bs []byte) error

+ func (c Compression) GoString() string

+ func (c Compression) MarshalText() ([]byte, error)

+ func (c Compression) String() string

Feb 15, 2015

Changes in this version

+ const FlagsAll

Jan 13, 2015

Changes in this version

+ const BlockSize

+ const FlagDeleted

+ const FlagDirectory

+ const FlagIntroducer

+ const FlagInvalid

+ const FlagNoPermBits

+ const FlagShareBits

+ const FlagShareReadOnly

+ const FlagShareTrusted

+ const FlagSymlink

+ const FlagSymlinkMissingTarget

+ const SymlinkTypeMask

+ var ErrClosed = errors.New("connection closed")

+ var ErrClusterHash = fmt.Errorf("configuration error: mismatched cluster hash")

+ var LocalDeviceID = DeviceID

+ func TotalInOut() (uint64, uint64)

+ type BlockInfo struct

+ Hash []byte

+ Offset int64

+ Size uint32

+ func (b BlockInfo) String() string

+ func (o *BlockInfo) DecodeXDR(r io.Reader) error

+ func (o *BlockInfo) UnmarshalXDR(bs []byte) error

+ func (o BlockInfo) AppendXDR(bs []byte) ([]byte, error)

+ func (o BlockInfo) EncodeXDR(w io.Writer) (int, error)

+ func (o BlockInfo) MarshalXDR() ([]byte, error)

+ func (o BlockInfo) MustMarshalXDR() []byte

+ type CloseMessage struct

+ Code uint32

+ Reason string

+ func (o *CloseMessage) DecodeXDR(r io.Reader) error

+ func (o *CloseMessage) UnmarshalXDR(bs []byte) error

+ func (o CloseMessage) AppendXDR(bs []byte) ([]byte, error)

+ func (o CloseMessage) EncodeXDR(w io.Writer) (int, error)

+ func (o CloseMessage) MarshalXDR() ([]byte, error)

+ func (o CloseMessage) MustMarshalXDR() []byte

+ type ClusterConfigMessage struct

+ ClientName string

+ ClientVersion string

+ Folders []Folder

+ Options []Option

+ func (o *ClusterConfigMessage) DecodeXDR(r io.Reader) error

+ func (o *ClusterConfigMessage) GetOption(key string) string

+ func (o *ClusterConfigMessage) UnmarshalXDR(bs []byte) error

+ func (o ClusterConfigMessage) AppendXDR(bs []byte) ([]byte, error)

+ func (o ClusterConfigMessage) EncodeXDR(w io.Writer) (int, error)

+ func (o ClusterConfigMessage) MarshalXDR() ([]byte, error)

+ func (o ClusterConfigMessage) MustMarshalXDR() []byte

+ type Connection interface

+ ClusterConfig func(config ClusterConfigMessage)

+ ID func() DeviceID

+ Index func(folder string, files []FileInfo) error

+ IndexUpdate func(folder string, files []FileInfo) error

+ Name func() string

+ Request func(folder string, name string, offset int64, size int) ([]byte, error)

+ Statistics func() Statistics

+ func NewConnection(deviceID DeviceID, reader io.Reader, writer io.Writer, receiver Model, ...) Connection

+ type Device struct

+ Flags uint32

+ ID []byte

+ MaxLocalVersion uint64

+ func (o *Device) DecodeXDR(r io.Reader) error

+ func (o *Device) UnmarshalXDR(bs []byte) error

+ func (o Device) AppendXDR(bs []byte) ([]byte, error)

+ func (o Device) EncodeXDR(w io.Writer) (int, error)

+ func (o Device) MarshalXDR() ([]byte, error)

+ func (o Device) MustMarshalXDR() []byte

+ type DeviceID [32]byte

+ func DeviceIDFromBytes(bs []byte) DeviceID

+ func DeviceIDFromString(s string) (DeviceID, error)

+ func NewDeviceID(rawCert []byte) DeviceID

+ func (n *DeviceID) MarshalText() ([]byte, error)

+ func (n *DeviceID) UnmarshalText(bs []byte) error

+ func (n DeviceID) Compare(other DeviceID) int

+ func (n DeviceID) Equals(other DeviceID) bool

+ func (n DeviceID) GoString() string

+ func (n DeviceID) String() string

+ type EmptyMessage struct

+ func (o *EmptyMessage) DecodeXDR(r io.Reader) error

+ func (o *EmptyMessage) UnmarshalXDR(bs []byte) error

+ func (o EmptyMessage) AppendXDR(bs []byte) ([]byte, error)

+ func (o EmptyMessage) EncodeXDR(w io.Writer) (int, error)

+ func (o EmptyMessage) MarshalXDR() ([]byte, error)

+ func (o EmptyMessage) MustMarshalXDR() []byte

+ type FileInfo struct

+ Blocks []BlockInfo

+ Flags uint32

+ LocalVersion uint64

+ Modified int64

+ Name string

+ Version uint64

+ func (f FileInfo) HasPermissionBits() bool

+ func (f FileInfo) IsDeleted() bool

+ func (f FileInfo) IsDirectory() bool

+ func (f FileInfo) IsInvalid() bool

+ func (f FileInfo) IsSymlink() bool

+ func (f FileInfo) Size() (bytes int64)

+ func (f FileInfo) String() string

+ func (o *FileInfo) DecodeXDR(r io.Reader) error

+ func (o *FileInfo) UnmarshalXDR(bs []byte) error

+ func (o FileInfo) AppendXDR(bs []byte) ([]byte, error)

+ func (o FileInfo) EncodeXDR(w io.Writer) (int, error)

+ func (o FileInfo) MarshalXDR() ([]byte, error)

+ func (o FileInfo) MustMarshalXDR() []byte

+ type Folder struct

+ Devices []Device

+ ID string

+ func (o *Folder) DecodeXDR(r io.Reader) error

+ func (o *Folder) UnmarshalXDR(bs []byte) error

+ func (o Folder) AppendXDR(bs []byte) ([]byte, error)

+ func (o Folder) EncodeXDR(w io.Writer) (int, error)

+ func (o Folder) MarshalXDR() ([]byte, error)

+ func (o Folder) MustMarshalXDR() []byte

+ type IndexMessage struct

+ Files []FileInfo

+ Flags uint32

+ Folder string

+ Options []Option

+ func (o *IndexMessage) DecodeXDR(r io.Reader) error

+ func (o *IndexMessage) UnmarshalXDR(bs []byte) error

+ func (o IndexMessage) AppendXDR(bs []byte) ([]byte, error)

+ func (o IndexMessage) EncodeXDR(w io.Writer) (int, error)

+ func (o IndexMessage) MarshalXDR() ([]byte, error)

+ func (o IndexMessage) MustMarshalXDR() []byte

+ type Model interface

+ Close func(deviceID DeviceID, err error)

+ ClusterConfig func(deviceID DeviceID, config ClusterConfigMessage)

+ Index func(deviceID DeviceID, folder string, files []FileInfo)

+ IndexUpdate func(deviceID DeviceID, folder string, files []FileInfo)

+ Request func(deviceID DeviceID, folder string, name string, offset int64, size int) ([]byte, error)

+ type Option struct

+ Key string

+ Value string

+ func (o *Option) DecodeXDR(r io.Reader) error

+ func (o *Option) UnmarshalXDR(bs []byte) error

+ func (o Option) AppendXDR(bs []byte) ([]byte, error)

+ func (o Option) EncodeXDR(w io.Writer) (int, error)

+ func (o Option) MarshalXDR() ([]byte, error)

+ func (o Option) MustMarshalXDR() []byte

+ type RequestMessage struct

+ Flags uint32

+ Folder string

+ Hash []byte

+ Name string

+ Offset uint64

+ Options []Option

+ Size uint32

+ func (o *RequestMessage) DecodeXDR(r io.Reader) error

+ func (o *RequestMessage) UnmarshalXDR(bs []byte) error

+ func (o RequestMessage) AppendXDR(bs []byte) ([]byte, error)

+ func (o RequestMessage) EncodeXDR(w io.Writer) (int, error)

+ func (o RequestMessage) MarshalXDR() ([]byte, error)

+ func (o RequestMessage) MustMarshalXDR() []byte

+ type ResponseMessage struct

+ Data []byte

+ Error uint32

+ func (o *ResponseMessage) DecodeXDR(r io.Reader) error

+ func (o *ResponseMessage) UnmarshalXDR(bs []byte) error

+ func (o ResponseMessage) AppendXDR(bs []byte) ([]byte, error)

+ func (o ResponseMessage) EncodeXDR(w io.Writer) (int, error)

+ func (o ResponseMessage) MarshalXDR() ([]byte, error)

+ func (o ResponseMessage) MustMarshalXDR() []byte

+ type Statistics struct

+ At time.Time

+ InBytesTotal uint64

+ OutBytesTotal uint64