protocol

Documentation

Index

• Variables
• type DownloadMsg
• type InitMsg
• type Session
  • func NewSession(stdin io.Reader, stdout io.Writer) *Session
  • func (s *Session) Init() (msg *InitMsg, err error)
  • func (s *Session) Ready() (err error)
  • func (s *Session) ReportCompletedDownload(oid, path string) (err error)
  • func (s *Session) ReportCompletedUpload(oid string) (err error)
  • func (s *Session) ReportFailedDownload(oid, msg string) (err error)
  • func (s *Session) ReportFailedUpload(oid, msg string) (err error)
  • func (s *Session) ReportProgress(oid string, change, total int64) (err error)
  • func (s *Session) StartDownload() (msg *DownloadMsg, err error)
  • func (s *Session) StartUpload() (msg *UploadMsg, err error)
• type UploadMsg

Variables

var (
	Terminate = errors.New("terminate")
)

Types

type DownloadMsg

type DownloadMsg struct {
	Event string `json:"event"`
	Oid   string `json:"oid"`
	Size  int64  `json:"size"`
}

type InitMsg

type InitMsg struct {
	Event               string `json:"event"`
	Operation           string `json:"operation"`
	Concurrent          bool   `json:"concurrent"`
	ConcurrentTransfers int    `json:"concurrenttransfers"`
}

type Session

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

func NewSession

func NewSession(stdin io.Reader, stdout io.Writer) *Session

func (*Session) Init

func (s *Session) Init() (msg *InitMsg, err error)

func (*Session) Ready

func (s *Session) Ready() (err error)

func (*Session) ReportCompletedDownload

func (s *Session) ReportCompletedDownload(oid, path string) (err error)

func (*Session) ReportCompletedUpload

func (s *Session) ReportCompletedUpload(oid string) (err error)

func (*Session) ReportFailedDownload

func (s *Session) ReportFailedDownload(oid, msg string) (err error)

func (*Session) ReportFailedUpload

func (s *Session) ReportFailedUpload(oid, msg string) (err error)

func (*Session) ReportProgress

func (s *Session) ReportProgress(oid string, change, total int64) (err error)

func (*Session) StartDownload

func (s *Session) StartDownload() (msg *DownloadMsg, err error)

func (*Session) StartUpload

func (s *Session) StartUpload() (msg *UploadMsg, err error)

type UploadMsg

type UploadMsg struct {
	Event string `json:"event"`
	Oid   string `json:"oid"`
	Size  int64  `json:"size"`
	Path  string `json:"path"`
}