protocol

Sep 24, 2014

Changes in this version

+ const FlagIntroducer

Sep 5, 2014

Changes in this version

type FileInfo

+ func (f FileInfo) IsInvalid() bool

type FileInfoTruncated

+ func (f FileInfoTruncated) IsInvalid() bool

type FileIntf

+ IsInvalid func() bool

Aug 16, 2014

Changes in this version

type ClusterConfigMessage

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

Aug 12, 2014

Changes in this version

type FileInfo

+ func (f FileInfo) IsDeleted() bool

+ type FileInfoTruncated struct

+ Flags uint32

+ LocalVersion uint64

+ Modified int64

+ Name string

+ NumBlocks uint32

+ Version uint64

+ func (f FileInfoTruncated) IsDeleted() 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

+ Size func() int64

Aug 2, 2014

Changes in this version

+ var LocalNodeID = NodeID

type BlockInfo

+ Offset int64

+ func (b BlockInfo) String() string

+ func (o BlockInfo) AppendXDR(bs []byte) []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

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

type Connection

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

+ Name func() 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

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

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

type FileInfo

+ LocalVersion uint64

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

+ func (f FileInfo) String() string

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

type IndexMessage

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

type Node

+ MaxLocalVersion uint64

+ func (o Node) AppendXDR(bs []byte) []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

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

type Repository

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

type RequestMessage

+ func (o RequestMessage) AppendXDR(bs []byte) []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

May 25, 2014

Changes in this version

+ const FlagNoPermBits

+ func HasPermissionBits(bits uint32) bool

+ func IsDeleted(bits uint32) bool

+ func IsDirectory(bits uint32) bool

+ func IsInvalid(bits uint32) bool

+ func TotalInOut() (uint64, uint64)

Apr 14, 2014

Changes in this version

+ const FlagShareBits

+ const FlagShareReadOnly

+ const FlagShareTrusted

+ type ClusterConfigMessage struct

+ ClientName string

+ ClientVersion string

+ Options []Option

+ Repositories []Repository

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

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

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

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

type Connection

+ ClusterConfig func(config ClusterConfigMessage)

type Model

+ ClusterConfig func(nodeID string, config ClusterConfigMessage)

+ type Node struct

+ Flags uint32

+ ID string

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

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

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

+ func (o Node) 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) EncodeXDR(w io.Writer) (int, error)

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

Apr 4, 2014

Changes in this version

+ const FlagDirectory

Feb 23, 2014

Changes in this version

+ const BlockSize

type BlockInfo

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

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

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

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

type FileInfo

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

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

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

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

+ 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) EncodeXDR(w io.Writer) (int, error)

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

+ 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) EncodeXDR(w io.Writer) (int, error)

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

+ type OptionsMessage struct

+ Options []Option

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

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

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

+ func (o OptionsMessage) 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) EncodeXDR(w io.Writer) (int, error)

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

Feb 16, 2014

Changes in this version

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

Jan 26, 2014

Changes in this version

type Connection

+ func (c *Connection) Option(key string) string

Jan 13, 2014

Changes in this version

type BlockInfo

+ Size uint32

Jan 9, 2014

Changes in this version

+ const FlagDeleted

+ const FlagInvalid

type FileInfo

+ Version uint32

Jan 1, 2014

Changes in this version

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

+ var ErrFieldLengthExceeded = errors.New("Raw bytes field size exceeds limit")

+ func WriteIndex(w io.Writer, idx []FileInfo) (int, error)

+ type BlockInfo struct

+ Hash []byte

+ Length uint32

+ type Connection struct

+ ID string

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

+ func (c *Connection) Close(err error)

+ func (c *Connection) Index(idx []FileInfo)

+ func (c *Connection) Ping() bool

+ func (c *Connection) Request(name string, offset uint64, size uint32, hash []byte) ([]byte, error)

+ func (c *Connection) Statistics() Statistics

+ func (c *Connection) Stop()

+ type FileInfo struct

+ Blocks []BlockInfo

+ Flags uint32

+ Modified int64

+ Name string

+ func ReadIndex(r io.Reader) ([]FileInfo, error)

+ type Model interface

+ Close func(nodeID string, err error)

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

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

+ Request func(nodeID, name string, offset uint64, size uint32, hash []byte) ([]byte, error)

+ type Statistics struct

+ At time.Time

+ InBytesPerSec int

+ InBytesTotal int

+ OutBytesPerSec int

+ OutBytesTotal int