msg

Documentation

Index

• Constants
• func ReadMsgInto(c io.Reader, msg Message) (err error)
• func WriteMsg(c io.Writer, msg interface{}) (err error)
• type Message
  • func ReadMsg(c io.Reader) (msg Message, err error)
• type NewReceiveFileStream
• type NewReceiveFileStreamResp
• type NewSendFileStream
• type NewSendFileStreamResp
• type Ping
• type Pong
• type ReceiveFile
• type ReceiveFileResp
• type RegisterWorker
• type RegisterWorkerResp
• type SendFile
• type SendFileResp

Constants

const (
	TypeRegisterWorker           = 'a'
	TypeRegisterWorkerResp       = 'b'
	TypeSendFile                 = 'c'
	TypeSendFileResp             = 'd'
	TypeReceiveFile              = 'e'
	TypeReceiveFileResp          = 'f'
	TypeNewSendFileStream        = 'g'
	TypeNewSendFileStreamResp    = 'h'
	TypeNewReceiveFileStream     = 'i'
	TypeNewReceiveFileStreamResp = 'j'

	TypePing = 'y'
	TypePong = 'z'
)

Functions

func ReadMsgInto

func ReadMsgInto(c io.Reader, msg Message) (err error)

func WriteMsg

func WriteMsg(c io.Writer, msg interface{}) (err error)

Types

type Message

type Message = jsonMsg.Message

func ReadMsg

func ReadMsg(c io.Reader) (msg Message, err error)

type NewReceiveFileStream

type NewReceiveFileStream struct {
	ID string `json:"id"`
}

type NewReceiveFileStreamResp

type NewReceiveFileStreamResp struct {
	Error string `json:"error"`
}

type NewSendFileStream

type NewSendFileStream struct {
	ID string `json:"id"`
}

type NewSendFileStreamResp

type NewSendFileStreamResp struct {
	Error string `json:"error"`
}

type Ping

type Ping struct {
}

type Pong

type Pong struct {
}

type ReceiveFile

type ReceiveFile struct {
	ID         string `json:"id"`
	CacheCount int64  `json:"cache_count"`
}

type ReceiveFileResp

type ReceiveFileResp struct {
	Name       string   `json:"name"`
	Fsize      int64    `json:"fsize"`
	Workers    []string `json:"workers"`
	CacheCount int64    `json:"cache_count"`
	Error      string   `json:"error"`
}

type RegisterWorker

type RegisterWorker struct {
	Version  string `json:"version"`
	BindPort int64  `json:"bind_port"`
	PublicIP string `json:"public_ip"`
}

type RegisterWorkerResp

type RegisterWorkerResp struct {
	Error string `json:"error"`
}

type SendFile

type SendFile struct {
	ID         string `json:"id"`
	Fsize      int64  `json:"fsize"`
	Name       string `json:"name"`
	CacheCount int64  `json:"cache_count"`
}

type SendFileResp

type SendFileResp struct {
	ID         string   `json:"id"`
	Workers    []string `json:"workers"`
	CacheCount int64    `json:"cache_count"`
	Error      string   `json:"error"`
}