Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

protocol

package

Go to main page

Versions in this module

v0

v0.10.23

Feb 15, 2015

Changes in this version

+ const FlagsAll

v0.10.22

Feb 9, 2015

v0.10.21

Jan 19, 2015

v0.10.20

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