xfer

Jun 17, 2016

Changes in this version

+ const ScopeProbeVersionHeader

May 13, 2016

Changes in this version

type Details

+ NewVersion *NewVersionInfo

+ type NewVersionInfo struct

+ DownloadURL string

+ Version string

type Response

+ RemovedNode string

Apr 19, 2016

Changes in this version

+ var EmptyPluginSpecs = PluginSpecs

type Details

+ Plugins PluginSpecs

type Pipe

+ func NewPipeFromEnds(local io.ReadWriter, remote io.ReadWriter) Pipe

+ type PluginSpec struct

+ APIVersion string

+ Description string

+ ID string

+ Interfaces []string

+ Label string

+ Status string

+ type PluginSpecs struct

+ func MakePluginSpecs(specs ...PluginSpec) PluginSpecs

+ func (*PluginSpecs) UnmarshalJSON(b []byte) error

+ func (PluginSpecs) MarshalJSON() ([]byte, error)

+ func (n *PluginSpecs) CodecDecodeSelf(decoder *codec.Decoder)

+ func (n *PluginSpecs) CodecEncodeSelf(encoder *codec.Encoder)

+ func (n *PluginSpecs) GobDecode(input []byte) error

+ func (n PluginSpecs) Add(specs ...PluginSpec) PluginSpecs

+ func (n PluginSpecs) Copy() PluginSpecs

+ func (n PluginSpecs) DeepEqual(i interface{}) bool

+ func (n PluginSpecs) ForEach(f func(PluginSpec))

+ func (n PluginSpecs) GobEncode() ([]byte, error)

+ func (n PluginSpecs) Keys() []string

+ func (n PluginSpecs) Lookup(key string) (PluginSpec, bool)

+ func (n PluginSpecs) Merge(other PluginSpecs) PluginSpecs

+ func (n PluginSpecs) Size() int

+ func (n PluginSpecs) String() string

+ type PluginSpecsByID []PluginSpec

+ func (p PluginSpecsByID) Len() int

+ func (p PluginSpecsByID) Less(i, j int) bool

+ func (p PluginSpecsByID) Swap(i, j int)

Feb 29, 2016

Changes in this version

+ func IsExpectedWSCloseError(err error) bool

+ type WSDialer interface

+ Dial func(urlStr string, requestHeader http.Header) (*websocket.Conn, *http.Response, error)

+ type Websocket interface

+ Close func() error

+ ReadJSON func(v interface{}) error

+ ReadMessage func() (messageType int, p []byte, err error)

+ WriteJSON func(v interface{}) error

+ WriteMessage func(messageType int, data []byte) error

+ func DialWS(d WSDialer, urlStr string, requestHeader http.Header) (Websocket, *http.Response, error)

+ func Ping(c *websocket.Conn) Websocket

+ func Upgrade(w http.ResponseWriter, r *http.Request, responseHeader http.Header) (Websocket, error)

Jan 29, 2016

Changes in this version

+ const AppPort

+ const ScopeProbeIDHeader

+ var ErrInvalidMessage = fmt.Errorf("Invalid Message")

+ type ControlHandler interface

+ Handle func(req Request, res *Response) error

+ type ControlHandlerFunc func(Request) Response

+ func (c ControlHandlerFunc) Handle(req Request, res *Response) error

+ type Details struct

+ Hostname string

+ ID string

+ Version string

+ type JSONWebsocketCodec struct

+ func NewJSONWebsocketCodec(conn *websocket.Conn) *JSONWebsocketCodec

+ func (j *JSONWebsocketCodec) Close() error

+ func (j *JSONWebsocketCodec) ReadRequestBody(v interface{}) error

+ func (j *JSONWebsocketCodec) ReadRequestHeader(r *rpc.Request) error

+ func (j *JSONWebsocketCodec) ReadResponseBody(v interface{}) error

+ func (j *JSONWebsocketCodec) ReadResponseHeader(r *rpc.Response) error

+ func (j *JSONWebsocketCodec) WaitForReadError()

+ func (j *JSONWebsocketCodec) WriteRequest(r *rpc.Request, v interface{}) error

+ func (j *JSONWebsocketCodec) WriteResponse(r *rpc.Response, v interface{}) error

+ type Message struct

+ Request *rpc.Request

+ Response *rpc.Response

+ Value interface{}

+ type Pipe interface

+ Close func() error

+ Closed func() bool

+ CopyToWebsocket func(io.ReadWriter, *websocket.Conn) error

+ Ends func() (io.ReadWriter, io.ReadWriter)

+ OnClose func(func())

+ func NewPipe() Pipe

+ type Request struct

+ AppID string

+ Control string

+ NodeID string

+ type Response struct

+ Error string

+ Pipe string

+ RawTTY bool

+ Value interface{}

+ func ResponseError(err error) Response

+ func ResponseErrorf(format string, a ...interface{}) Response