rpc

Documentation

Index

• Constants
• Variables
• type AddTorrentRequest
  • func (atr *AddTorrentRequest) MarshalJSON() (data []byte, err error)
  • func (atr *AddTorrentRequest) ProcessRequest(sw *swarm.Swarm, w *ResponseWriter)
• type BaseRequest
• type ChangeTorrentRequest
  • func (r *ChangeTorrentRequest) MarshalJSON() (data []byte, err error)
  • func (r *ChangeTorrentRequest) ProcessRequest(sw *swarm.Swarm, w *ResponseWriter)
• type Client
  • func NewClient(url string, swarmno int) *Client
  • func (cl *Client) AddTorrent(url string) (err error)
  • func (cl *Client) DeleteTorrent(ih string) error
  • func (cl *Client) GetSwarmStatus() (status swarm.SwarmStatus, err error)
  • func (cl *Client) ListTorrents() (torrents swarm.TorrentsList, err error)
  • func (cl *Client) RemoveTorrent(ih string) error
  • func (cl *Client) SetPieceWindow(n int) (err error)
  • func (cl *Client) StartTorrent(ih string) error
  • func (cl *Client) StopTorrent(ih string) error
  • func (cl *Client) SwarmStatus(ih string) (st swarm.TorrentStatus, err error)
• type ListTorrentStatusRequest
  • func (req *ListTorrentStatusRequest) MarshalJSON() (data []byte, err error)
  • func (req *ListTorrentStatusRequest) ProcessRequest(sw *swarm.Swarm, w *ResponseWriter)
• type ListTorrentsRequest
  • func (ltr *ListTorrentsRequest) MarshalJSON() (data []byte, err error)
  • func (ltr *ListTorrentsRequest) ProcessRequest(sw *swarm.Swarm, w *ResponseWriter)
• type Request
• type ResponseWriter
  • func (rw *ResponseWriter) Return(obj interface{})
  • func (rw *ResponseWriter) SendError(msg string)
  • func (rw *ResponseWriter) SendJSON(obj interface{})
• type Server
  • func NewServer(sw []*swarm.Swarm, host string) *Server
  • func (r *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)
• type SetPieceWindowRequest
  • func (r *SetPieceWindowRequest) MarshalJSON() (data []byte, err error)
  • func (r *SetPieceWindowRequest) ProcessRequest(sw *swarm.Swarm, w *ResponseWriter)
• type SwarmCountRequest
  • func (scr *SwarmCountRequest) MarshalJSON() (data []byte, err error)
  • func (scr *SwarmCountRequest) ProcessRequest(_ *swarm.Swarm, w *ResponseWriter)
• type TorrentStatusRequest
  • func (r *TorrentStatusRequest) MarshalJSON() (data []byte, err error)
  • func (r *TorrentStatusRequest) ProcessRequest(sw *swarm.Swarm, w *ResponseWriter)

Constants

const ParamAction = "action"

const ParamInfohash = "infohash"

const ParamMethod = "method"

const ParamN = "n"

const ParamSwarm = "swarm"

const ParamSwarms = "swarms"

const ParamURL = "url"

const RPCAddTorrent = RPCName + ".AddTorrent"

const RPCChangeTorrent = RPCName + ".ChangeTorrent"

const RPCContentType = "text/json; encoding=UTF-8"

const RPCDelTorrent = RPCName + ".DelTorrent"

const RPCListTorrentStatus = RPCName + ".SwarmStatus"

const RPCListTorrents = RPCName + ".ListTorrents"

const RPCName = "XD"

const RPCPath = "/ecksdee/api"

const RPCSetPieceWindow = RPCName + ".SetPieceWindow"

const RPCSwarmCount = RPCName + ".SwarmCount"

const RPCTorrentStatus = RPCName + ".TorrentStatus"

const TorrentChangeDelete = "delete"

const TorrentChangeRemove = "remove"

const TorrentChangeStart = "start"

const TorrentChangeStop = "stop"

Variables

var ErrInvalidAction = errors.New("invalid torrent action")

var ErrNoTorrent = errors.New("no such torrent")

Types

type AddTorrentRequest

type AddTorrentRequest struct {
	BaseRequest
	URL string `json:"url"`
}

func (*AddTorrentRequest) MarshalJSON

func (atr *AddTorrentRequest) MarshalJSON() (data []byte, err error)

func (*AddTorrentRequest) ProcessRequest

func (atr *AddTorrentRequest) ProcessRequest(sw *swarm.Swarm, w *ResponseWriter)

type BaseRequest

type BaseRequest struct {
	Swarm string `json:"-"`
}

type ChangeTorrentRequest

type ChangeTorrentRequest struct {
	BaseRequest
	Infohash string `json:"infohash"`
	Action   string `json:"action"`
}

func (*ChangeTorrentRequest) MarshalJSON

func (r *ChangeTorrentRequest) MarshalJSON() (data []byte, err error)

func (*ChangeTorrentRequest) ProcessRequest

func (r *ChangeTorrentRequest) ProcessRequest(sw *swarm.Swarm, w *ResponseWriter)

type Client

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

func NewClient

func NewClient(url string, swarmno int) *Client

func (*Client) AddTorrent

func (cl *Client) AddTorrent(url string) (err error)

func (*Client) DeleteTorrent

func (cl *Client) DeleteTorrent(ih string) error

func (*Client) GetSwarmStatus

func (cl *Client) GetSwarmStatus() (status swarm.SwarmStatus, err error)

func (*Client) ListTorrents

func (cl *Client) ListTorrents() (torrents swarm.TorrentsList, err error)

func (*Client) RemoveTorrent

func (cl *Client) RemoveTorrent(ih string) error

func (*Client) SetPieceWindow

func (cl *Client) SetPieceWindow(n int) (err error)

func (*Client) StartTorrent

func (cl *Client) StartTorrent(ih string) error

func (*Client) StopTorrent

func (cl *Client) StopTorrent(ih string) error

func (*Client) SwarmStatus

func (cl *Client) SwarmStatus(ih string) (st swarm.TorrentStatus, err error)

type ListTorrentStatusRequest

type ListTorrentStatusRequest struct {
	BaseRequest
}

func (*ListTorrentStatusRequest) MarshalJSON

func (req *ListTorrentStatusRequest) MarshalJSON() (data []byte, err error)

func (*ListTorrentStatusRequest) ProcessRequest

func (req *ListTorrentStatusRequest) ProcessRequest(sw *swarm.Swarm, w *ResponseWriter)

type ListTorrentsRequest

type ListTorrentsRequest struct {
	BaseRequest
}

func (*ListTorrentsRequest) MarshalJSON

func (ltr *ListTorrentsRequest) MarshalJSON() (data []byte, err error)

func (*ListTorrentsRequest) ProcessRequest

func (ltr *ListTorrentsRequest) ProcessRequest(sw *swarm.Swarm, w *ResponseWriter)

type Request

type Request interface {
	// handle request on server
	ProcessRequest(sw *swarm.Swarm, w *ResponseWriter)
	// convert request to json
	MarshalJSON() ([]byte, error)
}

type ResponseWriter

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

func (*ResponseWriter) Return

func (rw *ResponseWriter) Return(obj interface{})

func (*ResponseWriter) SendError

func (rw *ResponseWriter) SendError(msg string)

func (*ResponseWriter) SendJSON

func (rw *ResponseWriter) SendJSON(obj interface{})

type Server

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

Bittorrent Swarm RPC Handler

func NewServer

func NewServer(sw []*swarm.Swarm, host string) *Server

func (*Server) ServeHTTP

func (r *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

type SetPieceWindowRequest

type SetPieceWindowRequest struct {
	BaseRequest
	N int `json:"n"`
}

func (*SetPieceWindowRequest) MarshalJSON

func (r *SetPieceWindowRequest) MarshalJSON() (data []byte, err error)

func (*SetPieceWindowRequest) ProcessRequest

func (r *SetPieceWindowRequest) ProcessRequest(sw *swarm.Swarm, w *ResponseWriter)

type SwarmCountRequest

type SwarmCountRequest struct {
	BaseRequest
	N int
}

func (*SwarmCountRequest) MarshalJSON

func (scr *SwarmCountRequest) MarshalJSON() (data []byte, err error)

func (*SwarmCountRequest) ProcessRequest

func (scr *SwarmCountRequest) ProcessRequest(_ *swarm.Swarm, w *ResponseWriter)

type TorrentStatusRequest

type TorrentStatusRequest struct {
	BaseRequest
	Infohash string `json:"infohash"`
}

func (*TorrentStatusRequest) MarshalJSON

func (r *TorrentStatusRequest) MarshalJSON() (data []byte, err error)

func (*TorrentStatusRequest) ProcessRequest

func (r *TorrentStatusRequest) ProcessRequest(sw *swarm.Swarm, w *ResponseWriter)