app

May 18, 2020

Changes in this version

type Collector

+ Close func()

type StaticCollector

+ func (c StaticCollector) Close()

Sep 19, 2019

Changes in this version

+ func RegisterAdminRoutes(router *mux.Router, reporter Reporter)

type Reporter

+ AdminSummary func(context.Context, time.Time) (string, error)

type StaticCollector

+ func (c StaticCollector) AdminSummary(ctx context.Context, timestamp time.Time) (string, error)

Jul 23, 2018

Changes in this version

type Merger

+ func NewFastMerger() Merger

Dec 15, 2017

Changes in this version

type Reporter

+ HasReports func(context.Context, time.Time) (bool, error)

type StaticCollector

+ func (c StaticCollector) HasReports(context.Context, time.Time) (bool, error)

Aug 24, 2017

Changes in this version

+ func RenderContextForReporter(rep Reporter, r report.Report) report.RenderContext

type Reporter

+ HasHistoricReports func() bool

type StaticCollector

+ func (c StaticCollector) HasHistoricReports() bool

+ type WebReporter struct

+ MetricsGraphURL string

May 22, 2017

Changes in this version

type APITopologyOptionGroup

+ NoneLabel string

+ SelectType string

Nov 29, 2016

Changes in this version

+ func AddContainerFilters(newFilters ...APITopologyOption)

type APITopologyOption

+ func MakeAPITopologyOption(value string, label string, filterFunc render.FilterFunc, pseudo bool) APITopologyOption

+ type Registry struct

+ func MakeRegistry() *Registry

+ func (r *Registry) Add(ts ...APITopologyDesc)

+ func (r *Registry) AddContainerFilters(newFilters ...APITopologyOption)

+ func (r *Registry) RendererForTopology(topologyID string, values url.Values, rpt report.Report) (render.Renderer, render.Decorator, error)

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)

+ type PipeRouter struct

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

+ func (pr *PipeRouter) Stop()

Nov 16, 2015

Changes in this version

+ type Adder interface

+ Add func(report.Report)

+ type Collector struct

+ func NewCollector(window time.Duration) *Collector

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

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

+ func (wc *Collector) Broadcast()

+ func (wc *Collector) UnWait(waiter chan struct{})

+ func (wc *Collector) WaitOn(waiter chan struct{})

type Reporter

+ UnWait func(chan struct{})

+ WaitOn func(chan struct{})

Sep 30, 2015

Changes in this version

type APIDetails

+ ID string

Sep 16, 2015

Changes in this version

+ func Dir(useLocal bool, name string) http.FileSystem

type APITopologyDesc

+ Options map[string][]APITopologyOption

+ type APITopologyOption struct

+ Default bool

+ Display string

+ Value string

Jul 16, 2015

Changes in this version

+ func URLMatcher(pattern string) mux.MatcherFunc

Jun 15, 2015

Changes in this version

+ type APIDetails struct

+ Version string

type APITopologyDesc

+ SubTopologies []APITopologyDesc

type OriginHost

+ Load string

+ Networks []string

May 29, 2015

Changes in this version

+ type OriginHost struct

+ Addresses []string

+ Hostname string

+ LoadFifteen float64

+ LoadFive float64

+ LoadOne float64

+ OS string

+ type OriginNode struct

+ Table report.Table

May 20, 2015

Changes in this version

+ func FS(useLocal bool) http.FileSystem

+ func FSByte(useLocal bool, name string) ([]byte, error)

+ func FSMustByte(useLocal bool, name string) []byte

+ func FSMustString(useLocal bool, name string) string

+ func FSString(useLocal bool, name string) (string, error)

+ func Router(c Reporter) *mux.Router

+ type APIEdge struct

+ Metadata report.AggregateMetadata

+ type APINode struct

+ Node report.DetailedNode

+ type APITopology struct

+ Nodes map[string]report.RenderableNode

+ type APITopologyDesc struct

+ GroupedURL string

+ Name string

+ Stats topologyStats

+ Type string

+ URL string

+ type Origin struct

+ Addresses []string

+ Hostname string

+ LoadFifteen float64

+ LoadFive float64

+ LoadOne float64

+ OS string

+ type ReportLIFO struct

+ func NewReportLIFO(r reporter, maxAge time.Duration) *ReportLIFO

+ func (r *ReportLIFO) Report() report.Report

+ func (r *ReportLIFO) Stop()

+ type Reporter interface

+ Report func() report.Report

+ type Resolver struct

+ func NewResolver(peers []string, add func(string)) Resolver

+ func (r Resolver) Stop()