protocol

type DataExchange ¶

type DataExchange struct {
	File   storage.FileHash
	Chunks []storage.Chunk
}

type Datagram ¶

type Datagram struct {
	Msgs []Msg
}

Datagram holds a protocol datagram

func NewDataGram(m ...Msg) *Datagram

type HaveMsg ¶

type HaveMsg struct {
	File     storage.FileHash
	Type     int
	FileSize int
	Chunks   []storage.ChunkID
}

HaveMsg holds a have message storage payload

type Msg ¶

type Msg struct {
	Op   Opcode
	Data MsgData
}

Msg holds a protocol message

func (m *Msg) HandleDataExchange(pStorage storage.LocalStorage) error

func (m *Msg) HandleHave(pid PeerID, lStorage storage.LocalStorage, pStorage storage.PeerStorage) (*Datagram, error)

func (m *Msg) HandleRequest(pStorage storage.LocalStorage) (*Datagram, error)

func (m *Msg) MarshalJSON() ([]byte, error)

func (m *Msg) UnmarshalJSON(b []byte) error

type MsgData ¶

type MsgData interface{}

MsgData holds the storage payload of a message

type MsgError ¶

type MsgError struct {
	// contains filtered or unexported fields
}

MsgError is an error that happens while handling an incoming message

func (e MsgError) Error() string

type Opcode ¶

type Opcode uint8

Opcode identifies the type of message

const (
	Handshake Opcode = 0
	Data      Opcode = 1
	Have      Opcode = 3
	Request   Opcode = 8
	Error     Opcode = 255
)

type PeerID ¶

type PeerID interface {
	String() string
}

PeerID identifies a peer To avoid cycle Import

type Protocol ¶

type Protocol interface {
	HandleDatagram(d *Datagram, id PeerID)
	SetDatagramSender(f func(Datagram, PeerID) error)
}

type RequestChunks ¶

type RequestChunks struct {
	File storage.FileHash
	IDs  []storage.ChunkID
}

RequestChunks holds a have message storage payload

func (c RequestChunks) String() string