protocol

package
v0.6.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 4, 2014 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	FlagDeleted = 1 << 12
	FlagInvalid = 1 << 13
)
View Source 
const BlockSize = 128 * 1024

Variables

View Source 
var (
	ErrClusterHash = fmt.Errorf("configuration error: mismatched cluster hash")
	ErrClosed      = errors.New("connection closed")
)

Functions

This section is empty.

Types

type BlockInfo 

type BlockInfo struct {
	Size uint32
	Hash []byte // max:64
}

func (*BlockInfo) DecodeXDR added in v0.6.0 

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

func (BlockInfo) EncodeXDR added in v0.6.0 

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

func (BlockInfo) MarshalXDR added in v0.6.0 

func (o BlockInfo) MarshalXDR() []byte

func (*BlockInfo) UnmarshalXDR added in v0.6.0 

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

type Connection 

type Connection struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewConnection 

func NewConnection(nodeID string, reader io.Reader, writer io.Writer, receiver Model, options map[string]string) *Connection

func (*Connection) ID 

func (c *Connection) ID() string

func (*Connection) Index 

func (c *Connection) Index(repo string, idx []FileInfo)

Index writes the list of file information to the connected peer node

func (*Connection) Option added in v0.5.0 

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

func (*Connection) Request 

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

Request returns the bytes for the specified block after fetching them from the connected peer.

func (*Connection) Statistics 

func (c *Connection) Statistics() Statistics

type FileInfo 

type FileInfo struct {
	Name     string // max:1024
	Flags    uint32
	Modified int64
	Version  uint32
	Blocks   []BlockInfo // max:100000
}

func (*FileInfo) DecodeXDR added in v0.6.0 

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

func (FileInfo) EncodeXDR added in v0.6.0 

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

func (FileInfo) MarshalXDR added in v0.6.0 

func (o FileInfo) MarshalXDR() []byte

func (*FileInfo) UnmarshalXDR added in v0.6.0 

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

type IndexMessage added in v0.6.0 

type IndexMessage struct {
	Repository string     // max:64
	Files      []FileInfo // max:100000
}

func (*IndexMessage) DecodeXDR added in v0.6.0 

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

func (IndexMessage) EncodeXDR added in v0.6.0 

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

func (IndexMessage) MarshalXDR added in v0.6.0 

func (o IndexMessage) MarshalXDR() []byte

func (*IndexMessage) UnmarshalXDR added in v0.6.0 

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

type Model 

type Model interface {
	// An index was received from the peer node
	Index(nodeID string, files []FileInfo)
	// An index update was received from the peer node
	IndexUpdate(nodeID string, files []FileInfo)
	// A request was made by the peer node
	Request(nodeID, repo string, name string, offset int64, size int) ([]byte, error)
	// The peer node closed the connection
	Close(nodeID string, err error)
}

type Option added in v0.6.0 

type Option struct {
	Key   string // max:64
	Value string // max:1024
}

func (*Option) DecodeXDR added in v0.6.0 

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

func (Option) EncodeXDR added in v0.6.0 

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

func (Option) MarshalXDR added in v0.6.0 

func (o Option) MarshalXDR() []byte

func (*Option) UnmarshalXDR added in v0.6.0 

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

type OptionsMessage added in v0.6.0 

type OptionsMessage struct {
	Options []Option // max:64
}

func (*OptionsMessage) DecodeXDR added in v0.6.0 

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

func (OptionsMessage) EncodeXDR added in v0.6.0 

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

func (OptionsMessage) MarshalXDR added in v0.6.0 

func (o OptionsMessage) MarshalXDR() []byte

func (*OptionsMessage) UnmarshalXDR added in v0.6.0 

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

type RequestMessage added in v0.6.0 

type RequestMessage struct {
	Repository string // max:64
	Name       string // max:1024
	Offset     uint64
	Size       uint32
}

func (*RequestMessage) DecodeXDR added in v0.6.0 

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

func (RequestMessage) EncodeXDR added in v0.6.0 

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

func (RequestMessage) MarshalXDR added in v0.6.0 

func (o RequestMessage) MarshalXDR() []byte

func (*RequestMessage) UnmarshalXDR added in v0.6.0 

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

type Statistics 

type Statistics struct {
	At            time.Time
	InBytesTotal  int
	OutBytesTotal int
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.