report

Mar 27, 2017

Changes in this version

type EdgeMetadata

+ func (s *EdgeMetadata) CodecDecodeSelf(decoder *codec.Decoder)

type Report

+ func MakeFromBytes(buf []byte) (*Report, error)

+ func (rep *Report) ReadBytes(buf []byte, codecHandle codec.Handle) error

type WireMetrics

+ func (s *WireMetrics) CodecDecodeSelf(decoder *codec.Decoder)

Feb 8, 2017

Changes in this version

+ const MulticolumnTableType

+ const PropertyListType

+ const TableEntryKeySeparator

+ func WithoutPrefix(s string, prefix string) (string, bool)

+ type Column struct

+ DataType string

+ ID string

+ Label string

type Node

+ func (node Node) AddPrefixMulticolumnTable(prefix string, rows []Row) Node

+ func (node Node) AddPrefixPropertyList(prefix string, propertyList map[string]string) Node

+ func (node Node) ExtractMulticolumnTable(template TableTemplate) (rows []Row)

+ func (node Node) ExtractPropertyList(template TableTemplate) (rows []Row)

+ func (node Node) WithTableTruncationInformation(prefix string, totalRowsCount int) Node

type Row

+ Entries map[string]string

+ ID string

+ func (r Row) Copy() Row

type Table

+ Columns []Column

+ Type string

type TableTemplate

+ Columns []Column

+ Type string

Nov 29, 2016

Changes in this version

+ const ECSService

+ const ECSTask

+ var MakeECSServiceNodeID = makeSingleComponentID("ecs_service")

+ var MakeECSTaskNodeID = makeSingleComponentID("ecs_task")

+ var ParseECSServiceNodeID = parseSingleComponentID("ecs_service")

+ var ParseECSTaskNodeID = parseSingleComponentID("ecs_task")

type Report

+ ECSService Topology

+ ECSTask Topology

Nov 7, 2016

Changes in this version

+ const DockerOverlayPeerPrefix

+ const WeaveOverlayPeerPrefix

+ var EmptyNodeControlDataLatestMap = (NodeControlDataLatestMap)(MakeLatestMapWithDecoder(NodeControlDataLatestEntryDecoder))

+ var EmptyStringLatestMap = (StringLatestMap)(MakeLatestMapWithDecoder(StringLatestEntryDecoder))

+ func ParseOverlayNodeID(id string) (overlayPrefix string, peerName string)

+ type FixedRow struct

+ Key string

+ Label string

+ type LatestEntryDecoder interface

+ Decode func(decoder *codec.Decoder, entry *LatestEntry)

+ var NodeControlDataLatestEntryDecoder LatestEntryDecoder = &nodeControlDataLatestEntryDecoder{}

+ var StringLatestEntryDecoder LatestEntryDecoder = &stringLatestEntryDecoder{}

type LatestMap

+ func MakeLatestMapWithDecoder(decoder LatestEntryDecoder) LatestMap

type MetadataRow

+ Truncate int

type Node

+ LatestControls NodeControlDataLatestMap

+ func (n Node) WithLatestActiveControls(cs ...string) Node

+ func (n Node) WithLatestControl(control string, ts time.Time, data NodeControlData) Node

+ func (n Node) WithLatestControls(lcs map[string]NodeControlData) Node

+ func (node Node) AddPrefixTable(prefix string, labels map[string]string) Node

+ type NodeControlData struct

+ Dead bool

+ type NodeControlDataLatestMap LatestMap

+ func MakeNodeControlDataLatestMap() NodeControlDataLatestMap

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

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

+ func (m *NodeControlDataLatestMap) CodecDecodeSelf(decoder *codec.Decoder)

+ func (m *NodeControlDataLatestMap) CodecEncodeSelf(encoder *codec.Encoder)

+ func (m NodeControlDataLatestMap) Copy() NodeControlDataLatestMap

+ func (m NodeControlDataLatestMap) DeepEqual(n NodeControlDataLatestMap) bool

+ func (m NodeControlDataLatestMap) Delete(key string) NodeControlDataLatestMap

+ func (m NodeControlDataLatestMap) ForEach(fn func(k string, timestamp time.Time, v NodeControlData))

+ func (m NodeControlDataLatestMap) Lookup(key string) (NodeControlData, bool)

+ func (m NodeControlDataLatestMap) LookupEntry(key string) (NodeControlData, time.Time, bool)

+ func (m NodeControlDataLatestMap) Merge(other NodeControlDataLatestMap) NodeControlDataLatestMap

+ func (m NodeControlDataLatestMap) Set(key string, timestamp time.Time, value NodeControlData) NodeControlDataLatestMap

+ func (m NodeControlDataLatestMap) Size() int

+ func (m NodeControlDataLatestMap) String() string

type Report

+ func (r Report) BackwardCompatible() Report

+ func (r Report) Upgrade() Report

+ type StringLatestMap LatestMap

+ func MakeStringLatestMap() StringLatestMap

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

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

+ func (m *StringLatestMap) CodecDecodeSelf(decoder *codec.Decoder)

+ func (m *StringLatestMap) CodecEncodeSelf(encoder *codec.Encoder)

+ func (m StringLatestMap) Copy() StringLatestMap

+ func (m StringLatestMap) DeepEqual(n StringLatestMap) bool

+ func (m StringLatestMap) Delete(key string) StringLatestMap

+ func (m StringLatestMap) ForEach(fn func(k string, timestamp time.Time, v string))

+ func (m StringLatestMap) Lookup(key string) (string, bool)

+ func (m StringLatestMap) LookupEntry(key string) (string, time.Time, bool)

+ func (m StringLatestMap) Merge(other StringLatestMap) StringLatestMap

+ func (m StringLatestMap) Set(key string, timestamp time.Time, value string) StringLatestMap

+ func (m StringLatestMap) Size() int

+ func (m StringLatestMap) String() string

type TableTemplate

+ FixedRows map[string]string

Aug 16, 2016

Changes in this version

+ func IsLoopback(address string) bool

type Metric

+ func MakeSingletonMetric(t time.Time, v float64) Metric

Jul 14, 2016

Changes in this version

type Report

+ func MakeFromBinary(r io.Reader) (*Report, error)

+ func (r *Report) WalkTopologies(f func(*Topology))

+ func (rep *Report) ReadBinary(r io.Reader, gzipped bool, codecHandle codec.Handle) error

+ func (rep Report) WriteBinary(w io.Writer) error

Jun 17, 2016

Changes in this version

type Sets

+ func (s Sets) Delete(key string) Sets

May 13, 2016

Changes in this version

+ const Circle

+ const Cloud

+ const Deployment

+ const DoesNotMakeConnections

+ const Heptagon

+ const Hexagon

+ const MaxTableRows

+ const ReplicaSet

+ const Square

+ const TruncationCountPrefix

+ var MakeDeploymentNodeID = makeSingleComponentID("deployment")

+ var MakeReplicaSetNodeID = makeSingleComponentID("replica_set")

+ var ParseContainerImageNodeID = parseSingleComponentID("container_image")

+ var ParseDeploymentNodeID = parseSingleComponentID("deployment")

+ var ParseHostNodeID = parseSingleComponentID("host")

+ var ParsePodNodeID = parseSingleComponentID("pod")

+ var ParseReplicaSetNodeID = parseSingleComponentID("replica_set")

+ var ParseServiceNodeID = parseSingleComponentID("service")

type Control

+ Rank int

type Controls

+ func (cs Controls) AddControls(controls []Control)

type Node

+ func (node Node) AddTable(prefix string, labels map[string]string) Node

+ func (node Node) ExtractTable(prefix string) (rows map[string]string, truncationCount int)

type NodeSet

+ func (n NodeSet) Delete(ids ...string) NodeSet

type Report

+ Deployment Topology

+ ReplicaSet Topology

type Table

+ ID string

+ Label string

+ TruncationCount int

+ func (t Table) Copy() Table

+ type TableTemplate struct

+ ID string

+ Label string

+ Prefix string

+ func (t TableTemplate) Copy() TableTemplate

+ func (t TableTemplate) Merge(other TableTemplate) TableTemplate

+ type TableTemplates map[string]TableTemplate

+ func (t TableTemplates) Copy() TableTemplates

+ func (t TableTemplates) Merge(other TableTemplates) TableTemplates

+ func (t TableTemplates) Tables(node Node) []Table

type Topology

+ Label string

+ LabelPlural string

+ Shape string

+ func (t Topology) GetShape() string

+ func (t Topology) WithLabel(label, labelPlural string) Topology

+ func (t Topology) WithShape(shape string) Topology

+ func (t Topology) WithTableTemplates(other TableTemplates) Topology

Apr 19, 2016

Changes in this version

+ const ContainersKey

+ const DefaultFormat

+ const FilesizeFormat

+ const FromCounters

+ const FromLatest

+ const FromSets

+ const IntegerFormat

+ const PercentFormat

type Counters

+ func (c Counters) ForEach(f func(key string, val int))

type EdgeMetadata

+ func (e EdgeMetadata) String() string

type IDList

+ func (a IDList) Intersection(b IDList) IDList

type LatestMap

+ func (m LatestMap) LookupEntry(key string) (string, time.Time, bool)

+ type MetadataRow struct

+ Datatype string

+ ID string

+ Label string

+ Priority float64

+ Value string

+ func (m MetadataRow) Copy() MetadataRow

+ type MetadataRowsByPriority []MetadataRow

+ func (m MetadataRowsByPriority) Len() int

+ func (m MetadataRowsByPriority) Less(i, j int) bool

+ func (m MetadataRowsByPriority) Swap(i, j int)

+ type MetadataTemplate struct

+ Datatype string

+ From string

+ ID string

+ Label string

+ Priority float64

+ Truncate int

+ func (t MetadataTemplate) Copy() MetadataTemplate

+ func (t MetadataTemplate) MetadataRows(n Node) []MetadataRow

+ type MetadataTemplates map[string]MetadataTemplate

+ func (e MetadataTemplates) Copy() MetadataTemplates

+ func (e MetadataTemplates) Merge(other MetadataTemplates) MetadataTemplates

+ func (e MetadataTemplates) MetadataRows(n Node) []MetadataRow

+ type MetricRow struct

+ Format string

+ Group string

+ ID string

+ Label string

+ Metric *Metric

+ Priority float64

+ Value float64

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

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

+ func (m *MetricRow) CodecDecodeSelf(decoder *codec.Decoder)

+ func (m *MetricRow) CodecEncodeSelf(encoder *codec.Encoder)

+ func (m MetricRow) Copy() MetricRow

+ func (m MetricRow) Summary() MetricRow

+ type MetricRowsByPriority []MetricRow

+ func (m MetricRowsByPriority) Len() int

+ func (m MetricRowsByPriority) Less(i, j int) bool

+ func (m MetricRowsByPriority) Swap(i, j int)

+ type MetricTemplate struct

+ Format string

+ Group string

+ ID string

+ Label string

+ Priority float64

+ func (t MetricTemplate) Copy() MetricTemplate

+ func (t MetricTemplate) MetricRows(n Node) []MetricRow

+ type MetricTemplates map[string]MetricTemplate

+ func (e MetricTemplates) Copy() MetricTemplates

+ func (e MetricTemplates) Merge(other MetricTemplates) MetricTemplates

+ func (e MetricTemplates) MetricRows(n Node) []MetricRow

type Metrics

+ func (m Metrics) Lookup(key string) (Metric, bool)

type Node

+ Children NodeSet

+ func (n Node) Prune() Node

+ func (n Node) PruneParents() Node

+ func (n Node) WithChild(child Node) Node

+ func (n Node) WithChildren(children NodeSet) Node

type Nodes

+ func (n Nodes) Prune() Nodes

+ type Probe struct

+ ID string

+ LastSeen time.Time

+ func (p Probe) Copy() Probe

+ type Probes map[string]Probe

+ func (ps Probes) Copy() Probes

+ func (ps Probes) Merge(other Probes) Probes

type Report

+ Plugins xfer.PluginSpecs

+ Probes Probes

+ func (r Report) Topology(name string) (Topology, bool)

type StringSet

+ func (s StringSet) Intersection(b StringSet) StringSet

type Topology

+ func (t Topology) WithMetadataTemplates(other MetadataTemplates) Topology

+ func (t Topology) WithMetricTemplates(other MetricTemplates) Topology

Feb 29, 2016

Changes in this version

+ const ControlProbeID

type Counters

+ func (c *Counters) CodecDecodeSelf(decoder *codec.Decoder)

+ func (c *Counters) CodecEncodeSelf(encoder *codec.Encoder)

type EdgeMetadatas

+ func (c *EdgeMetadatas) CodecDecodeSelf(decoder *codec.Decoder)

+ func (c *EdgeMetadatas) CodecEncodeSelf(encoder *codec.Encoder)

type LatestMap

+ func (m *LatestMap) CodecDecodeSelf(decoder *codec.Decoder)

+ func (m *LatestMap) CodecEncodeSelf(encoder *codec.Encoder)

type Metric

+ func (m *Metric) CodecDecodeSelf(decoder *codec.Decoder)

+ func (m *Metric) CodecEncodeSelf(encoder *codec.Encoder)

type NodeControls

+ func (nc *NodeControls) CodecDecodeSelf(decoder *codec.Decoder)

+ func (nc *NodeControls) CodecEncodeSelf(encoder *codec.Encoder)

type NodeSet

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

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

type Sets

+ func (s *Sets) CodecDecodeSelf(decoder *codec.Decoder)

+ func (s *Sets) CodecEncodeSelf(encoder *codec.Encoder)

type WireMetrics

+ func (m WireMetrics) FromIntermediate() Metric

Jan 29, 2016

Changes in this version

+ const Address

+ const Container

+ const ContainerImage

+ const Endpoint

+ const Host

+ const Overlay

+ const Pod

+ const Process

+ const Service

+ var EmptyCounters = Counters

+ var EmptyEdgeMetadatas = EdgeMetadatas

+ var EmptyIDList = IDList(EmptyStringSet)

+ var EmptyLatestMap = LatestMap

+ var EmptyNodeSet = NodeSet

+ var EmptySets = Sets

+ func MakeContainerImageNodeID(containerImageID string) string

type Counters

+ func MakeCounters() Counters

+ func (c *Counters) GobDecode(input []byte) error

+ func (c *Counters) UnmarshalJSON(input []byte) error

+ func (c Counters) Add(key string, value int) Counters

+ func (c Counters) DeepEqual(i interface{}) bool

+ func (c Counters) GobEncode() ([]byte, error)

+ func (c Counters) Lookup(key string) (int, bool)

+ func (c Counters) MarshalJSON() ([]byte, error)

+ func (c Counters) Size() int

+ func (c Counters) String() string

type EdgeMetadatas

+ func MakeEdgeMetadatas() EdgeMetadatas

+ func (c *EdgeMetadatas) GobDecode(input []byte) error

+ func (c *EdgeMetadatas) UnmarshalJSON(input []byte) error

+ func (c EdgeMetadatas) Add(key string, value EdgeMetadata) EdgeMetadatas

+ func (c EdgeMetadatas) DeepEqual(i interface{}) bool

+ func (c EdgeMetadatas) ForEach(fn func(k string, v EdgeMetadata))

+ func (c EdgeMetadatas) GobEncode() ([]byte, error)

+ func (c EdgeMetadatas) Lookup(key string) (EdgeMetadata, bool)

+ func (c EdgeMetadatas) MarshalJSON() ([]byte, error)

+ func (c EdgeMetadatas) Size() int

+ func (c EdgeMetadatas) String() string

type IDList

+ func (a IDList) Remove(ids ...string) IDList

type LatestEntry

+ func (e LatestEntry) Equal(e2 LatestEntry) bool

type LatestMap

+ func (m LatestMap) DeepEqual(i interface{}) bool

+ func (m LatestMap) Delete(key string) LatestMap

+ func (m LatestMap) ForEach(fn func(k, v string))

+ func (m LatestMap) Size() int

+ func (m LatestMap) String() string

type Metric

+ func (m Metric) ToIntermediate() WireMetrics

type Node

+ ID string

+ Parents Sets

+ Topology string

+ func (n Node) After(other Node) bool

+ func (n Node) Before(other Node) bool

+ func (n Node) Equal(other Node) bool

+ func (n Node) WithID(id string) Node

+ func (n Node) WithLatests(m map[string]string) Node

+ func (n Node) WithParents(parents Sets) Node

+ func (n Node) WithTopology(topology string) Node

+ type NodeSet struct

+ func MakeNodeSet(nodes ...Node) NodeSet

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

+ func (n *NodeSet) UnmarshalJSON(input []byte) error

+ func (n NodeSet) Add(nodes ...Node) NodeSet

+ func (n NodeSet) Copy() NodeSet

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

+ func (n NodeSet) ForEach(f func(Node))

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

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

+ func (n NodeSet) Lookup(key string) (Node, bool)

+ func (n NodeSet) MarshalJSON() ([]byte, error)

+ func (n NodeSet) Merge(other NodeSet) NodeSet

+ func (n NodeSet) Size() int

+ func (n NodeSet) String() string

type Report

+ ID string

type Sets

+ func MakeSets() Sets

+ func (s *Sets) GobDecode(input []byte) error

+ func (s *Sets) UnmarshalJSON(input []byte) error

+ func (s Sets) Add(key string, value StringSet) Sets

+ func (s Sets) DeepEqual(i interface{}) bool

+ func (s Sets) GobEncode() ([]byte, error)

+ func (s Sets) Keys() []string

+ func (s Sets) Lookup(key string) (StringSet, bool)

+ func (s Sets) MarshalJSON() ([]byte, error)

+ func (s Sets) Size() int

+ func (s Sets) String() string

type StringSet

+ var EmptyStringSet StringSet

+ func (s StringSet) Contains(str string) bool

+ func (s StringSet) Remove(strs ...string) StringSet

Dec 15, 2015

Changes in this version

type Metric

+ func (m Metric) WithMax(max float64) Metric

type NodeControls

+ func (nc *NodeControls) UnmarshalJSON(input []byte) error

+ func (nc NodeControls) MarshalJSON() ([]byte, error)

+ type WireNodeControls struct

+ Controls StringSet

+ Timestamp string

Nov 16, 2015

Changes in this version

+ const ProbeID

+ type Control struct

+ Human string

+ ID string

+ Icon string

+ type Controls map[string]Control

+ func (cs Controls) AddControl(c Control)

+ func (cs Controls) Copy() Controls

+ func (cs Controls) Merge(other Controls) Controls

+ type LatestEntry struct

+ Timestamp time.Time

+ Value string

+ func (e LatestEntry) String() string

+ type LatestMap struct

+ func MakeLatestMap() LatestMap

+ func (m *LatestMap) GobDecode(input []byte) error

+ func (m *LatestMap) UnmarshalJSON(input []byte) error

+ func (m LatestMap) Copy() LatestMap

+ func (m LatestMap) GobEncode() ([]byte, error)

+ func (m LatestMap) Lookup(key string) (string, bool)

+ func (m LatestMap) MarshalJSON() ([]byte, error)

+ func (m LatestMap) Merge(newer LatestMap) LatestMap

+ func (m LatestMap) Set(key string, timestamp time.Time, value string) LatestMap

+ type Metric struct

+ First time.Time

+ Last time.Time

+ Max float64

+ Min float64

+ Samples ps.List

+ func MakeMetric() Metric

+ func (m *Metric) GobDecode(input []byte) error

+ func (m *Metric) UnmarshalJSON(input []byte) error

+ func (m Metric) Add(t time.Time, v float64) Metric

+ func (m Metric) Copy() Metric

+ func (m Metric) Div(n float64) Metric

+ func (m Metric) GobEncode() ([]byte, error)

+ func (m Metric) LastSample() *Sample

+ func (m Metric) Len() int

+ func (m Metric) MarshalJSON() ([]byte, error)

+ func (m Metric) Merge(other Metric) Metric

+ func (m Metric) WithFirst(t time.Time) Metric

+ type Metrics map[string]Metric

+ func (m Metrics) Copy() Metrics

+ func (m Metrics) Merge(other Metrics) Metrics

type Node

+ Controls NodeControls

+ Counters Counters

+ Latest LatestMap

+ Metadata Metadata

+ Metrics Metrics

+ Sets Sets

+ func (n Node) WithControls(cs ...string) Node

+ func (n Node) WithLatest(k string, ts time.Time, v string) Node

+ func (n Node) WithMetric(key string, metric Metric) Node

+ func (n Node) WithMetrics(metrics Metrics) Node

+ func (n Node) WithSet(key string, set StringSet) Node

+ func (n Node) WithSets(sets Sets) Node

+ type NodeControls struct

+ Controls StringSet

+ Timestamp time.Time

+ func MakeNodeControls() NodeControls

+ func (nc NodeControls) Add(ids ...string) NodeControls

+ func (nc NodeControls) Copy() NodeControls

+ func (nc NodeControls) Merge(other NodeControls) NodeControls

type Report

+ Shortcut bool

+ type Sample struct

+ Timestamp time.Time

+ Value float64

+ type Sets map[string]StringSet

+ func (s Sets) Copy() Sets

+ func (s Sets) Merge(other Sets) Sets

+ type StringSet []string

+ func MakeStringSet(strs ...string) StringSet

+ func (s StringSet) Add(strs ...string) StringSet

+ func (s StringSet) Copy() StringSet

+ func (s StringSet) Merge(other StringSet) StringSet

+ type WireMetrics struct

+ First string

+ Last string

+ Max float64

+ Min float64

+ Samples []Sample

Nov 2, 2015

Changes in this version

+ func LocalAddresses() ([]net.IP, error)

+ func MakePodNodeID(hostID, podID string) string

+ func MakeScopedAddressNodeID(hostID, address string) string

+ func MakeScopedEndpointNodeID(hostID, address, port string) string

+ func MakeServiceNodeID(namespaceID, serviceID string) string

type Report

+ Pod Topology

+ Service Topology

Sep 30, 2015

Changes in this version

type EdgeMetadata

+ func (e EdgeMetadata) Reversed() EdgeMetadata

Sep 16, 2015

Changes in this version

+ func ParseAddressNodeID(addressNodeID string) (hostID, address string, ok bool)

+ func ParseContainerNodeID(containerNodeID string) (hostID, containerID string, ok bool)

+ type Counters map[string]int

+ func (c Counters) Copy() Counters

+ func (c Counters) Merge(other Counters) Counters

type EdgeMetadata

+ func (e EdgeMetadata) Copy() EdgeMetadata

type EdgeMetadatas

+ func (e EdgeMetadatas) Copy() EdgeMetadatas

+ func (e EdgeMetadatas) Flatten() EdgeMetadata

type IDList

+ func (a IDList) Copy() IDList

+ type Metadata map[string]string

+ func (m Metadata) Copy() Metadata

+ func (m Metadata) Merge(other Metadata) Metadata

+ type Node struct

+ Adjacency IDList

+ Edges EdgeMetadatas

+ func MakeNode() Node

+ func MakeNodeWith(m map[string]string) Node

+ func (n Node) AddMetadata(m map[string]string) Node

+ func (n Node) Copy() Node

+ func (n Node) Merge(other Node) Node

+ func (n Node) WithAdjacency(a IDList) Node

+ func (n Node) WithAdjacent(a string) Node

+ func (n Node) WithCounters(c map[string]int) Node

+ func (n Node) WithEdge(dst string, md EdgeMetadata) Node

+ func (n Node) WithMetadata(m map[string]string) Node

+ type Nodes map[string]Node

+ func (n Nodes) Copy() Nodes

+ func (n Nodes) Merge(other Nodes) Nodes

type Report

+ func (r Report) Copy() Report

type Topology

+ func MakeTopology() Topology

+ func (t Topology) AddNode(nodeID string, nmd Node) Topology

+ func (t Topology) Copy() Topology

Aug 19, 2015

Changes in this version

type EdgeMetadata

+ EgressByteCount *uint64

+ EgressPacketCount *uint64

+ IngressByteCount *uint64

+ IngressPacketCount *uint64

type NodeMetadata

+ Metadata map[string]string

+ func MakeNodeMetadata() NodeMetadata

+ func MakeNodeMetadataWith(m map[string]string) NodeMetadata

type Report

+ Sampling Sampling

+ Window time.Duration

+ type Sampling struct

+ Count uint64

+ Total uint64

+ func (s *Sampling) Merge(other Sampling)

+ func (s Sampling) Rate() float64

Jul 16, 2015

Changes in this version

+ func ParseEndpointNodeID(endpointNodeID string) (hostID, address, port string, ok bool)

type IDList

+ func (a IDList) Merge(b IDList) IDList

Jun 30, 2015

Changes in this version

+ var InterfaceByNameStub = func(name string) (Interface, error)

+ var LocalNetworks = Networks

+ func AddLocalBridge(name string) error

+ func ExtractHostID(m NodeMetadata) string

+ func MakeOverlayNodeID(peerName string) string

+ type Interface interface

+ Addrs func() ([]net.Addr, error)

+ type Networks []*net.IPNet

+ func (n Networks) Contains(ip net.IP) bool

type Report

+ ContainerImage Topology

+ Overlay Topology

type Topology

+ func SelectContainerImage(r Report) Topology

+ func SelectHost(r Report) Topology

+ func SelectProcess(r Report) Topology

Jun 15, 2015

Changes in this version

+ const EdgeDelim

+ const HostNodeID

+ func AddressIDAddresser(id string) net.IP

+ func EndpointIDAddresser(id string) net.IP

+ func MakeAddressNodeID(hostID, address string) string

+ func MakeAdjacencyID(srcNodeID string) string

+ func MakeContainerNodeID(hostID, containerID string) string

+ func MakeEdgeID(srcNodeID, dstNodeID string) string

+ func MakeEndpointNodeID(hostID, address, port string) string

+ func MakeHostNodeID(hostID string) string

+ func MakeProcessNodeID(hostID, pid string) string

+ func MakePseudoNodeID(parts ...string) string

+ func PanicIDAddresser(id string) net.IP

+ func ParseAdjacencyID(adjacencyID string) (string, bool)

+ func ParseEdgeID(edgeID string) (srcNodeID, dstNodeID string, ok bool)

+ func ParseNodeID(nodeID string) (hostID string, remainder string, ok bool)

type DetailedNode

+ func MakeDetailedNode(r Report, n RenderableNode) DetailedNode

type IDList

+ func MakeIDList(ids ...string) IDList

+ func (a IDList) Contains(id string) bool

type MappedNode

+ func MapContainerIdentity(_ string, m NodeMetadata) (MappedNode, bool)

+ func MapEndpoint2Container(_ string, m NodeMetadata) (MappedNode, bool)

type NodeMetadata

+ func (nm NodeMetadata) Copy() NodeMetadata

+ func (nm NodeMetadata) Merge(other NodeMetadata) NodeMetadata

type RenderableNode

+ Origins IDList

+ func (rn *RenderableNode) Merge(other RenderableNode)

+ type RenderableNodes map[string]RenderableNode

+ func (rns RenderableNodes) Merge(other RenderableNodes)

type Report

+ Address Topology

+ Container Topology

+ Endpoint Topology

+ Host Topology

+ func MakeReport() Report

+ func (r Report) LocalNetworks() []*net.IPNet

+ func (r Report) Squash() Report

+ func (r Report) Topologies() []Topology

+ func (r Report) Validate() error

type Table

+ func OriginTable(r Report, originID string) (Table, bool)

type Topology

+ func SelectAddress(r Report) Topology

+ func SelectContainer(r Report) Topology

+ func SelectEndpoint(r Report) Topology

+ func (t Topology) Squash(f IDAddresser, localNets []*net.IPNet) Topology

+ func (t Topology) Validate() error

+ type TopologySelector func(r Report) Topology

May 29, 2015

Changes in this version

type MappedNode

+ func GenericGroupedPseudoNode(src string, srcMapped RenderableNode, dst string) (MappedNode, bool)

+ func GenericPseudoNode(src string, srcMapped RenderableNode, dst string) (MappedNode, bool)

+ func InternetOnlyPseudoNode(_ string, _ RenderableNode, dst string) (MappedNode, bool)

+ func ProcessContainer(_ string, m NodeMetadata) (MappedNode, bool)

+ func ProcessContainerImage(_ string, m NodeMetadata) (MappedNode, bool)

+ type PseudoFunc func(srcNodeID string, srcNode RenderableNode, dstNodeID string) (MappedNode, bool)

type RenderableNode

+ OriginHosts IDList

+ OriginNodes IDList

May 20, 2015

Changes in this version

+ const IDDelim

+ const KeyBytesEgress

+ const KeyBytesIngress

+ const KeyMaxConnCountTCP

+ const ScopeDelim

+ const TheInternet

+ var MapFuncRegistry = map[string]MapFunc

+ func AddressIP(id string) net.IP

+ func AddressIPPort(id string) net.IP

+ type Adjacency map[string]IDList

+ func (a *Adjacency) Merge(other Adjacency)

+ type AggregateMetadata map[string]int

+ func (r *AggregateMetadata) Merge(other AggregateMetadata)

+ type ByID []RenderableNode

+ func (r ByID) Len() int

+ func (r ByID) Less(i, j int) bool

+ func (r ByID) Swap(i, j int)

+ type DetailedNode struct

+ ID string

+ LabelMajor string

+ LabelMinor string

+ Pseudo bool

+ Tables []Table

+ type Diff struct

+ Add []RenderableNode

+ Remove []string

+ Update []RenderableNode

+ func TopoDiff(a, b map[string]RenderableNode) Diff

+ type EdgeMetadata struct

+ BytesEgress uint

+ BytesIngress uint

+ MaxConnCountTCP uint

+ WithBytes bool

+ WithConnCountTCP bool

+ func (m *EdgeMetadata) Flatten(other EdgeMetadata)

+ func (m *EdgeMetadata) Merge(other EdgeMetadata)

+ func (md EdgeMetadata) Transform() AggregateMetadata

+ type EdgeMetadatas map[string]EdgeMetadata

+ func (e *EdgeMetadatas) Merge(other EdgeMetadatas)

+ type HostMetadata struct

+ Hostname string

+ LoadFifteen float64

+ LoadFive float64

+ LoadOne float64

+ LocalNets []*net.IPNet

+ OS string

+ Timestamp time.Time

+ func (m *HostMetadata) UnmarshalJSON(data []byte) error

+ type HostMetadatas map[string]HostMetadata

+ func (e *HostMetadatas) Merge(other HostMetadatas)

+ func (m HostMetadatas) LocalNets() []*net.IPNet

+ type IDAddresser func(string) net.IP

+ type IDList []string

+ func NewIDList(ids ...string) IDList

+ func (a IDList) Add(ids ...string) IDList

+ type MapFunc func(string, NodeMetadata, bool) (MappedNode, bool)

+ type MappedNode struct

+ ID string

+ Major string

+ Minor string

+ Rank string

+ func NetworkHostname(id string, m NodeMetadata, _ bool) (MappedNode, bool)

+ func NetworkIP(id string, m NodeMetadata, _ bool) (MappedNode, bool)

+ func ProcessCgroup(id string, m NodeMetadata, grouped bool) (MappedNode, bool)

+ func ProcessName(id string, m NodeMetadata, grouped bool) (MappedNode, bool)

+ func ProcessPID(id string, m NodeMetadata, grouped bool) (MappedNode, bool)

+ type NodeMetadata map[string]string

+ type NodeMetadatas map[string]NodeMetadata

+ func (m *NodeMetadatas) Merge(other NodeMetadatas)

+ type RenderableNode struct

+ Adjacency IDList

+ ID string

+ LabelMajor string

+ LabelMinor string

+ Metadata AggregateMetadata

+ Origin IDList

+ Pseudo bool

+ Rank string

+ type Report struct

+ Network Topology

+ Process Topology

+ func NewReport() Report

+ func (r *Report) Merge(other Report)

+ func (r Report) SquashRemote() Report

+ type Row struct

+ Key string

+ ValueMajor string

+ ValueMinor string

+ type Table struct

+ Numeric bool

+ Rows []Row

+ Title string

+ type Topology struct

+ func NewTopology() Topology

+ func Squash(t Topology, f IDAddresser, localNets []*net.IPNet) Topology

+ func (t *Topology) Merge(other Topology)

+ func (t Topology) EdgeMetadata(f MapFunc, grouped bool, srcRenderableID, dstRenderableID string) EdgeMetadata

+ func (t Topology) RenderBy(f MapFunc, grouped bool) map[string]RenderableNode