app

Jul 14, 2016

Changes in this version

type Collector

+ func NewFileCollector(path string) (Collector, error)

+ type StaticCollector report.Report

+ func (c StaticCollector) Add(context.Context, report.Report) error

+ func (c StaticCollector) Report(context.Context) (report.Report, error)

+ func (c StaticCollector) UnWait(context.Context, chan struct{})

+ func (c StaticCollector) WaitOn(context.Context, chan struct{})

May 13, 2016

Changes in this version

+ func NewVersion(version, downloadURL string)

+ type Merger interface

+ Merge func([]report.Report) report.Report

+ func MakeDumbMerger() Merger

+ func NewSmartMerger() Merger

Apr 19, 2016

Changes in this version

type APITopologyDesc

+ HideIfEmpty bool

type APITopologyOption

+ Label string

+ type APITopologyOptionGroup struct

+ Default string

+ ID string

+ Options []APITopologyOption

type End

+ func (e End) String() string

type PipeRouter

+ Exists func(context.Context, string) (bool, error)

Feb 29, 2016

Changes in this version

+ const DefaultContainerName

+ const DefaultDockerEndpoint

+ const DefaultHostname

+ const DefaultWeaveURL

+ const ProbeEnd

+ const RequestCtxKey

+ const UIEnd

type APITopologyDesc

+ Rank int

+ type ControlRouter interface

+ Deregister func(ctx context.Context, probeID string, id int64) error

+ Handle func(ctx context.Context, probeID string, req xfer.Request) (xfer.Response, error)

+ Register func(ctx context.Context, probeID string, handler xfer.ControlHandlerFunc) (int64, error)

+ func NewLocalControlRouter() ControlRouter

+ type CtxHandlerFunc func(context.Context, http.ResponseWriter, *http.Request)

+ type DockerClient interface

+ ListContainers func(fsouza.ListContainersOptions) ([]fsouza.APIContainers, error)

+ type End int

+ type Interface struct

+ Addrs []net.Addr

+ Name string

+ func Interfaces() ([]Interface, error)

+ type InterfaceFunc func() ([]Interface, error)

type PipeRouter

+ func NewLocalPipeRouter() PipeRouter

+ Delete func(context.Context, string)

+ Get func(context.Context, string, End) (xfer.Pipe, io.ReadWriter, bool)

+ Release func(context.Context, string, End)

+ type WeaveClient interface

+ AddDNSEntry func(hostname, containerid string, ip net.IP) error

+ Expose func() error

+ type WeavePublisher struct

+ func NewWeavePublisher(weaveClient WeaveClient, dockerClient DockerClient, interfaces InterfaceFunc, ...) *WeavePublisher

+ func (w *WeavePublisher) Stop()

Jan 29, 2016

Changes in this version

+ func TopologyHandler(c Reporter, preRoutes *mux.Router, postRoutes http.Handler) http.Handler

Dec 15, 2015

Changes in this version

+ var UniqueID = "0"

+ var Version = "dev"

+ func RegisterControlRoutes(router *mux.Router)

+ func RegisterReportPostHandler(a Adder, router *mux.Router)

+ func RegisterTopologyRoutes(c Reporter, router *mux.Router)

+ func URLMatcher(pattern string) mux.MatcherFunc

+ type APINode struct

+ Node render.DetailedNode

+ type APITopology struct

+ Nodes render.RenderableNodes

+ type APITopologyDesc struct

+ Name string

+ Options map[string][]APITopologyOption

+ Stats topologyStats

+ SubTopologies []APITopologyDesc

+ URL string

+ type APITopologyOption struct

+ Default bool

+ Display string

+ Value string

+ type Adder interface

+ Add func(report.Report)

+ type Collector interface

+ func NewCollector(window time.Duration) Collector

+ type PipeRouter struct

+ func RegisterPipeRoutes(router *mux.Router) *PipeRouter

+ func (pr *PipeRouter) Stop()

+ type Reporter interface

+ Report func() report.Report

+ UnWait func(chan struct{})

+ WaitOn func(chan struct{})