protocol

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