protocol

Jan 3, 2015

Changes in this version

type FileInfo

+ func (f FileInfo) ToTruncated() FileInfoTruncated

Nov 24, 2014

Changes in this version

+ const FlagSymlink

+ const FlagSymlinkMissingTarget

+ const SymlinkTypeMask

+ func BlocksToSize(num uint32) int64

type FileInfo

+ func (f FileInfo) HasPermissionBits() bool

+ func (f FileInfo) IsSymlink() bool

type FileInfoTruncated

+ func (f FileInfoTruncated) HasPermissionBits() bool

+ func (f FileInfoTruncated) IsDirectory() bool

+ func (f FileInfoTruncated) IsSymlink() bool

type FileIntf

+ HasPermissionBits func() bool

+ IsDirectory func() bool

+ IsSymlink func() bool

Oct 24, 2014

Changes in this version

type BlockInfo

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

type CloseMessage

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

type ClusterConfigMessage

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

type Device

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

type EmptyMessage

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

type FileInfo

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

type FileInfoTruncated

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

type Folder

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

type IndexMessage

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

type Option

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

type RequestMessage

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

type ResponseMessage

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

Oct 18, 2014

Changes in this version

type FileInfo

+ func (f FileInfo) IsDirectory() bool

type FileInfoTruncated

+ func (f FileInfoTruncated) String() string

Oct 8, 2014

Changes in this version

+ var LocalDeviceID = DeviceID

type ClusterConfigMessage

+ Folders []Folder

+ 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

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

+ func (o Device) MarshalXDR() []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 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

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

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

type IndexMessage

+ Folder string

type RequestMessage

+ Folder string

Sep 28, 2014

Changes in this version

+ const BlockSize

+ const FlagDeleted

+ const FlagDirectory

+ const FlagIntroducer

+ const FlagInvalid

+ const FlagNoPermBits

+ const FlagShareBits

+ const FlagShareReadOnly

+ const FlagShareTrusted

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

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

+ var LocalNodeID = NodeID

+ func HasPermissionBits(bits uint32) bool

+ func IsDeleted(bits uint32) bool

+ func IsDirectory(bits uint32) bool

+ func IsInvalid(bits uint32) bool

+ 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

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

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

+ type CloseMessage struct

+ Reason string

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

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

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

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

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

+ type ClusterConfigMessage struct

+ ClientName string

+ ClientVersion string

+ Options []Option

+ Repositories []Repository

+ 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

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

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

+ type Connection interface

+ ClusterConfig func(config ClusterConfigMessage)

+ ID func() NodeID

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

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

+ Name func() string

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

+ Statistics func() Statistics

+ func NewConnection(nodeID NodeID, reader io.Reader, writer io.Writer, receiver Model, name string, ...) Connection

+ 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

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

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

+ type FileInfo struct

+ Blocks []BlockInfo

+ Flags uint32

+ LocalVersion uint64

+ Modified int64

+ Name string

+ Version uint64

+ func (f FileInfo) IsDeleted() bool

+ func (f FileInfo) IsInvalid() 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

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

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

+ type FileInfoTruncated struct

+ Flags uint32

+ LocalVersion uint64

+ Modified int64

+ Name string

+ NumBlocks uint32

+ Version uint64

+ func (f FileInfoTruncated) IsDeleted() bool

+ func (f FileInfoTruncated) IsInvalid() bool

+ func (f FileInfoTruncated) Size() int64

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

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

+ func (o FileInfoTruncated) AppendXDR(bs []byte) []byte

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

+ func (o FileInfoTruncated) MarshalXDR() []byte

+ type FileIntf interface

+ IsDeleted func() bool

+ IsInvalid func() bool

+ Size func() int64

+ type IndexMessage struct

+ Files []FileInfo

+ Repository string

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

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

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

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

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

+ type Model interface

+ Close func(nodeID NodeID, err error)

+ ClusterConfig func(nodeID NodeID, config ClusterConfigMessage)

+ Index func(nodeID NodeID, repo string, files []FileInfo)

+ IndexUpdate func(nodeID NodeID, repo string, files []FileInfo)

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

+ type Node struct

+ Flags uint32

+ ID []byte

+ MaxLocalVersion uint64

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

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

+ func (o Node) AppendXDR(bs []byte) []byte

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

+ func (o Node) MarshalXDR() []byte

+ type NodeID [32]byte

+ func NewNodeID(rawCert []byte) NodeID

+ func NodeIDFromBytes(bs []byte) NodeID

+ func NodeIDFromString(s string) (NodeID, error)

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

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

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

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

+ func (n NodeID) GoString() string

+ func (n NodeID) String() string

+ 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

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

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

+ type Repository struct

+ ID string

+ Nodes []Node

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

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

+ func (o Repository) AppendXDR(bs []byte) []byte

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

+ func (o Repository) MarshalXDR() []byte

+ type RequestMessage struct

+ Name string

+ Offset uint64

+ Repository string

+ Size uint32

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

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

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

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

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

+ type ResponseMessage struct

+ Data []byte

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

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

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

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

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

+ type Statistics struct

+ At time.Time

+ InBytesTotal uint64

+ OutBytesTotal uint64