xfer

Dec 15, 2015

Changes in this version

type AppClient

+ PipeClose func(string) error

+ PipeConnection func(string, Pipe)

+ Publish func(r io.Reader) error

type Details

+ Hostname string

+ type Message struct

+ Request *rpc.Request

+ Response *rpc.Response

+ Value interface{}

type MultiAppClient

+ PipeClose func(appID, pipeID string) error

+ PipeConnection func(appID, pipeID string, pipe Pipe) error

+ Publish func(io.Reader) error

+ 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

+ AppID string

type Response

+ Pipe string

+ RawTTY bool

Nov 16, 2015

Changes in this version

+ type AppClient interface

+ ControlConnection func(handler ControlHandler)

+ Details func() (Details, error)

+ Stop func()

+ func NewAppClient(pc ProbeConfig, hostname, target string) (AppClient, error)

+ type ClientFactory func(ProbeConfig, string, string) (AppClient, error)

+ 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

+ 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 MultiAppClient interface

+ Set func(hostname string, endpoints []string)

+ Stop func()

+ func NewMultiAppClient(pc ProbeConfig, handler ControlHandler, clientFactory ClientFactory) MultiAppClient

+ type ProbeConfig struct

+ Insecure bool

+ ProbeID string

+ Token string

+ type Request struct

+ Control string

+ ID int64

+ NodeID string

+ type Resolver interface

+ Stop func()

+ func NewStaticResolver(targets []string, setters ...setter) Resolver

+ type Response struct

+ Error string

+ ID int64

+ Value interface{}

+ func ResponseError(err error) Response

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

Sep 30, 2015

Changes in this version

type MultiPublisher

+ func (p *MultiPublisher) Delete(target string)

+ func (p *MultiPublisher) Set(target string, endpoints []string)

Sep 16, 2015

Changes in this version

+ type BackgroundPublisher struct

+ func NewBackgroundPublisher(p Publisher) *BackgroundPublisher

+ func (b *BackgroundPublisher) Publish(buf *bytes.Buffer) error

+ func (b *BackgroundPublisher) Stop()

type HTTPPublisher

+ func (p HTTPPublisher) Stop()

+ func (p HTTPPublisher) String() string

type MultiPublisher

+ func (p *MultiPublisher) Stop()

type Publisher

+ Stop func()

+ type ReportPublisher struct

+ func NewReportPublisher(publisher Publisher) *ReportPublisher

+ func (p *ReportPublisher) Publish(r report.Report) error

Aug 19, 2015

Changes in this version

+ const ScopeProbeIDHeader

+ func AuthorizationHeader(token string) string

+ type Adder interface

+ Add func(report.Report)

type Collector

+ func (c *Collector) Report() report.Report

+ type HTTPPublisher struct

+ func NewHTTPPublisher(target, token, id string) (*HTTPPublisher, error)

+ func (p HTTPPublisher) Publish(rpt report.Report) error

+ type MultiPublisher struct

+ func NewMultiPublisher(factory func(string) (Publisher, error)) *MultiPublisher

+ func (p *MultiPublisher) Add(target string)

+ func (p *MultiPublisher) Publish(rpt report.Report) error

+ type Reporter interface

+ Report func() report.Report

Jun 15, 2015

Changes in this version

type Collector

+ Add func(string)

+ Remove func(string)

+ type HandshakeRequest struct

+ ID string

May 20, 2015

Changes in this version

+ var AppPort = 4040

+ var MaxBackoff = 2 * time.Minute

+ var ProbePort = 4030

+ type Collector struct

+ func NewCollector(batchTime time.Duration) *Collector

+ func (c *Collector) AddAddress(ip string)

+ func (c *Collector) AddAddresses(ips []string)

+ func (c *Collector) RemoveAddress(ip string)

+ func (c *Collector) Reports() <-chan report.Report

+ func (c *Collector) Stop()

+ type Publisher interface

+ Close func()

+ Publish func(report.Report)

+ type TCPPublisher struct

+ func NewTCPPublisher(listenAddress string) (*TCPPublisher, error)

+ func (p *TCPPublisher) Close()

+ func (p *TCPPublisher) Publish(msg report.Report)