message

Documentation

Index

• func NewMessage(messageType proto.MessageType, payload []byte) *proto.Message
• type FileDataPayload
  • func (f *FileDataPayload) Bytes(protocol Protocol) ([]byte, error)
• type FileInfoPayload
  • func (f *FileInfoPayload) Bytes(protocol Protocol) ([]byte, error)
• type FileStatPayload
  • func (f *FileStatPayload) Bytes(protocol Protocol) ([]byte, error)
• type Message
  • func ParseMessagePayload(msg *proto.Message) (Message, error)
• type Protocol
• type ShareCodePayload
  • func (c *ShareCodePayload) Bytes(protocol Protocol) ([]byte, error)

Functions

func NewMessage

func NewMessage(messageType proto.MessageType, payload []byte) *proto.Message

Types

type FileDataPayload

type FileDataPayload struct {
	Data     []byte
	Position int64
	EOF      bool
}

func (*FileDataPayload) Bytes

func (f *FileDataPayload) Bytes(protocol Protocol) ([]byte, error)

type FileInfoPayload

type FileInfoPayload struct {
	FileInfo *files.FileInfo
}

func (*FileInfoPayload) Bytes

func (f *FileInfoPayload) Bytes(protocol Protocol) ([]byte, error)

type FileStatPayload

type FileStatPayload struct {
	FilesSize    int64 `json:"FilesSize,omitempty"`
	FilesNumber  int64 `json:"FilesNumber,omitempty"`
	FolderNumber int64 `json:"FolderNumber,omitempty"`
}

func (*FileStatPayload) Bytes

func (f *FileStatPayload) Bytes(protocol Protocol) ([]byte, error)

type Message

type Message interface {
	Bytes(protocol Protocol) ([]byte, error)
}

Message is the interface of a message to send over the wire

func ParseMessagePayload

func ParseMessagePayload(msg *proto.Message) (Message, error)

type Protocol

type Protocol string

Protocol used to transport messages

const (
	// RawProtocol is raw messages
	RawProtocol Protocol = "raw"
	// JSONProtocol is used for JSON encoded messages
	JSONProtocol Protocol = "json"
)

type ShareCodePayload

type ShareCodePayload struct {
	ShareCode string
}

func (*ShareCodePayload) Bytes

func (c *ShareCodePayload) Bytes(protocol Protocol) ([]byte, error)