render

May 20, 2019

Changes in this version

+ var SelectJob = TopologySelector(report.Job)

Nov 22, 2018

Changes in this version

+ var ConnectedProcessRenderer = ColorConnected(ProcessRenderer)

+ var KubernetesVolumesRenderer = MakeReduce(VolumesRenderer, PodToVolumeRenderer, PVCToStorageClassRenderer, ...)

+ var PVCToStorageClassRenderer = pvcToStorageClassRenderer

+ var PVToSnapshotRenderer = pvToSnapshotRenderer

+ var PodToVolumeRenderer = podToVolumesRenderer

+ var SelectPersistentVolume = TopologySelector(report.PersistentVolume)

+ var SelectPersistentVolumeClaim = TopologySelector(report.PersistentVolumeClaim)

+ var SelectStorageClass = TopologySelector(report.StorageClass)

+ var SelectVolumeSnapshot = TopologySelector(report.VolumeSnapshot)

+ var SelectVolumeSnapshotData = TopologySelector(report.VolumeSnapshotData)

+ var VolumeSnapshotRenderer = volumeSnapshotRenderer

+ var VolumesRenderer = volumesRenderer

+ func IsNonSnapshotComponent(node report.Node) bool

+ func IsPodComponent(node report.Node) bool

Apr 16, 2018

Changes in this version

type Map2Parent

+ func (m Map2Parent) Render(rpt report.Report) Nodes

Jan 23, 2018

Changes in this version

+ func IsInternetNode(n report.Node) bool

+ func ParseGroupNodeTopology(topology string) (string, string, bool)

+ func ParsePseudoNodeID(nodeID string) (string, bool)

type Renderer

+ func MapEndpoints(f endpointMapFunc, topology string) Renderer

Dec 8, 2017

Changes in this version

+ const IsConnectedMark

+ func DNSFirstMatch(n report.Node, match func(name string) bool) (string, bool)

type FilterFunc

+ func (f FilterFunc) Transform(nodes Nodes) Nodes

+ type Nodes struct

+ Filtered int

+ func Render(rpt report.Report, renderer Renderer, transformer Transformer) Nodes

+ func (r Nodes) Merge(o Nodes) Nodes

+ type Transformer interface

+ Transform func(nodes Nodes) Nodes

+ type Transformers []Transformer

+ func (ts Transformers) Transform(nodes Nodes) Nodes

Jul 28, 2017

Changes in this version

+ var ColorConnectedProcessRenderer = ColorConnected(ProcessRenderer)

+ var KubeControllerRenderer = ConditionalRenderer(renderKubernetesTopologies, ...)

+ var SelectCronJob = TopologySelector(report.CronJob)

+ var SelectStatefulSet = TopologySelector(report.StatefulSet)

+ var UncontainedIDPrefix = MakePseudoNodeID(UncontainedID)

+ var UnmanagedIDPrefix = MakePseudoNodeID(UnmanagedID)

type FilterFunc

+ func IsTopology(topology string) FilterFunc

type Renderer

+ func ConnectionJoin(toIPs func(report.Node) []string, r Renderer) Renderer

+ func FilterUnconnectedPseudo(r Renderer) Renderer

May 22, 2017

Changes in this version

+ var DaemonSetRenderer = ConditionalRenderer(renderKubernetesTopologies, MakeMap(PropagateSingleMetrics(report.Pod), ...))

+ var SelectDaemonSet = TopologySelector(report.DaemonSet)

+ var SelectSwarmService = TopologySelector(report.SwarmService)

+ var SwarmServiceRenderer = ConditionalRenderer(renderSwarmTopologies, MakeMap(PropagateSingleMetrics(report.Container), ...))

+ func IsPseudoTopology(n report.Node) bool

Mar 27, 2017

Changes in this version

type FilterFunc

+ func AnyFilterFunc(fs ...FilterFunc) FilterFunc

type Renderer

+ func ApplyDecorator(renderer Renderer) Renderer

+ func FilterNonEBPF(r Renderer) Renderer

+ func FilterNonProcspiedNorEBPF(r Renderer) Renderer

Feb 8, 2017

Changes in this version

+ func NewDerivedExternalNode(n report.Node, addr string, local report.Networks) (report.Node, bool)

Nov 29, 2016

Changes in this version

+ var ECSServiceRenderer = ConditionalRenderer(renderECSTopologies, ...)

+ var ECSTaskRenderer = ConditionalRenderer(renderECSTopologies, ...)

+ var SelectECSService = TopologySelector(report.ECSService)

+ var SelectECSTask = TopologySelector(report.ECSTask)

+ var SelectOverlay = TopologySelector(report.Overlay)

+ var ServiceNodeIDPrefix = "service-"

+ var WeaveRenderer = MakeMap(MapWeaveIdentity, SelectOverlay)

+ func DNSNames(n report.Node) []string

+ func MapContainer2ECSTask(n report.Node, _ report.Networks) report.Nodes

+ func MapWeaveIdentity(m report.Node, _ report.Networks) report.Nodes

+ type ConstantRenderer report.Nodes

+ func (c ConstantRenderer) Render(_ report.Report, _ Decorator) report.Nodes

+ func (c ConstantRenderer) Stats(_ report.Report, _ Decorator) Stats

type FilterFunc

+ func DoesNotHaveLabel(labelKey string, labelValue string) FilterFunc

+ func HasLabel(labelKey string, labelValue string) FilterFunc

+ type PreciousNodeRenderer struct

+ PreciousNodeID string

+ func (p PreciousNodeRenderer) Render(rpt report.Report, dct Decorator) report.Nodes

+ func (p PreciousNodeRenderer) Stats(rpt report.Report, dct Decorator) Stats

Jun 17, 2016

Changes in this version

+ func IsNotPseudo(n report.Node) bool

+ func MapPod2IP(m report.Node) []string

type Decorator

+ func MakeFilterDecorator(f FilterFunc) Decorator

+ func MakeFilterPseudoDecorator(f FilterFunc) Decorator

type MapFunc

+ func PropagateSingleMetrics(topology string) MapFunc

type Renderer

+ func MakeFilterPseudo(f FilterFunc, r Renderer) Renderer

+ func ShortLivedConnectionJoin(r Renderer, toIPs func(report.Node) []string) Renderer

May 13, 2016

Changes in this version

+ const UnmanagedID

+ const UnmanagedMajor

+ var DeploymentRenderer = ConditionalRenderer(renderKubernetesTopologies, ...)

+ var IsStopped = Complement(IsRunning)

+ var Map2Deployment = Map2Parent(report.Deployment)

+ var Map2ReplicaSet = Map2Parent(report.ReplicaSet)

+ var Map2Service = Map2Parent(report.Service)

+ var ReplicaSetRenderer = ConditionalRenderer(renderKubernetesTopologies, ...)

+ var SelectDeployment = TopologySelector(report.Deployment)

+ var SelectReplicaSet = TopologySelector(report.ReplicaSet)

+ func IsApplication(n report.Node) bool

+ func MakeGroupNodeTopology(originalTopology, key string) string

+ func Map2Parent(topology string) func(n report.Node, _ report.Networks) report.Nodes

+ func MapToEmpty(n report.Node, _ report.Networks) report.Nodes

+ func Noop(_ report.Node) bool

+ type Condition func(report.Report) bool

+ type Decorator func(Renderer) Renderer

+ func ComposeDecorators(decorators ...Decorator) Decorator

+ type FilterFunc func(report.Node) bool

+ func ComposeFilterFuncs(fs ...FilterFunc) FilterFunc

+ func HasChildren(topology string) FilterFunc

+ func IsNamespace(namespace string) FilterFunc

type Renderer

+ func ApplyDecorators(renderer Renderer) Renderer

+ func ConditionalRenderer(c Condition, r Renderer) Renderer

+ func FilterEmpty(topology string, r Renderer) Renderer

Apr 19, 2016

Changes in this version

+ const IP

+ const InboundMajor

+ const InboundMinor

+ const IncomingInternetID

+ const OutboundMajor

+ const OutboundMinor

+ const OutgoingInternetID

+ const Pseudo

+ func Complement(f func(report.Node) bool) func(report.Node) bool

+ func IsRunning(n report.Node) bool

+ func IsSystem(n report.Node) bool

+ func MapEndpoint2Host(n report.Node, local report.Networks) report.Nodes

+ func MapEndpoint2Pseudo(n report.Node, local report.Networks) report.Nodes

+ func NewDerivedPseudoNode(id string, node report.Node) report.Node

type Filter

+ Silent bool

type Renderer

+ func FilterApplication(r Renderer) Renderer

+ func FilterNonProcspied(r Renderer) Renderer

+ func FilterRunning(r Renderer) Renderer

+ func MakeSilentFilter(f func(report.Node) bool, r Renderer) Renderer

+ func SilentFilterUnconnected(r Renderer) Renderer

Feb 29, 2016

Changes in this version

+ const Circle

+ const Cloud

+ const ContainersKey

+ const Heptagon

+ const Hexagon

+ const Square

+ var ContainerWithHostIPsRenderer = containerWithHostIPsRenderer

type RenderableNode

+ Shape string

+ Stack bool

Jan 29, 2016

Changes in this version

+ const KubernetesContainerNameLabel

+ func ImageNameWithoutVersion(name string) string

+ func MakeContainerID(containerID string) string

+ func MakeContainerImageID(imageID string) string

+ func MakePodID(podID string) string

+ func MakeServiceID(serviceID string) string

+ func ResetCache()

type RenderableNode

+ Children report.NodeSet

+ func (rn RenderableNode) WithParents(p report.Sets) RenderableNode

type RenderableNodes

+ func MapX2Host(n RenderableNode, _ report.Networks) RenderableNodes

type Renderer

+ func FilterPseudo(r Renderer) Renderer

+ func MakeFilter(f func(RenderableNode) bool, r Renderer) Renderer

+ func MakeMap(f MapFunc, r Renderer) Renderer

+ func Memoise(r Renderer) Renderer

Nov 16, 2015

Changes in this version

+ type ControlInstance struct

+ NodeID string

+ ProbeID string

type DetailedNode

+ Controls []ControlInstance

type RenderableNode

+ ControlNode string

type Renderer

+ func FilterNoop(in Renderer) Renderer

+ func FilterStopped(r Renderer) Renderer

type Row

+ Metric *report.Metric

+ ValueType string

Nov 2, 2015

Changes in this version

+ var ContainerHostnameRenderer = Map

+ var PodRenderer = Map

+ var PodServiceRenderer = Map

+ var SelectPod = TopologySelector(func(r report.Report) RenderableNodes { ... })

+ var SelectService = TopologySelector(func(r report.Report) RenderableNodes { ... })

type RenderableNodes

+ func MapContainer2Hostname(n RenderableNode, _ report.Networks) RenderableNodes

+ func MapContainer2Pod(n RenderableNode, _ report.Networks) RenderableNodes

+ func MapCountPods(n RenderableNode, _ report.Networks) RenderableNodes

+ func MapPod2Service(n RenderableNode, _ report.Networks) RenderableNodes

+ func MapPodIdentity(m RenderableNode, _ report.Networks) RenderableNodes

+ func MapServiceIdentity(m RenderableNode, _ report.Networks) RenderableNodes

Sep 30, 2015

Changes in this version

type Filter

+ func (f Filter) Stats(rpt report.Report) Stats

type Map

+ func (m Map) Stats(rpt report.Report) Stats

type Reduce

+ func (r Reduce) Stats(rpt report.Report) Stats

type Renderer

+ Stats func(report.Report) Stats

+ type Stats struct

+ FilteredNodes int

type TopologySelector

+ func (t TopologySelector) Stats(r report.Report) Stats

Sep 16, 2015

Changes in this version

+ const AmazonECSContainerNameLabel

+ const IsConnected

+ var SelectAddress = TopologySelector(func(r report.Report) RenderableNodes { ... })

+ var SelectContainer = TopologySelector(func(r report.Report) RenderableNodes { ... })

+ var SelectContainerImage = TopologySelector(func(r report.Report) RenderableNodes { ... })

+ var SelectEndpoint = TopologySelector(func(r report.Report) RenderableNodes { ... })

+ var SelectHost = TopologySelector(func(r report.Report) RenderableNodes { ... })

+ var SelectProcess = TopologySelector(func(r report.Report) RenderableNodes { ... })

+ func GetRenderableContainerName(nmd report.Node) (string, bool)

+ type ContainerWithImageNameRenderer struct

+ func (r ContainerWithImageNameRenderer) EdgeMetadata(rpt report.Report, localID, remoteID string) report.EdgeMetadata

+ func (r ContainerWithImageNameRenderer) Render(rpt report.Report) RenderableNodes

+ type CustomRenderer struct

+ RenderFunc func(RenderableNodes) RenderableNodes

+ func (c CustomRenderer) Render(rpt report.Report) RenderableNodes

+ type Filter struct

+ FilterFunc func(RenderableNode) bool

+ func (f Filter) Render(rpt report.Report) RenderableNodes

type Map

+ func (m Map) EdgeMetadata(rpt report.Report, srcRenderableID, dstRenderableID string) report.EdgeMetadata

+ type ProcessWithContainerNameRenderer struct

+ func (r ProcessWithContainerNameRenderer) EdgeMetadata(rpt report.Report, localID, remoteID string) report.EdgeMetadata

+ func (r ProcessWithContainerNameRenderer) Render(rpt report.Report) RenderableNodes

type Reduce

+ func (r Reduce) EdgeMetadata(rpt report.Report, localID, remoteID string) report.EdgeMetadata

type RenderableNode

+ func NewDerivedNode(id string, node RenderableNode) RenderableNode

+ func NewRenderableNodeWith(id, major, minor, rank string, rn RenderableNode) RenderableNode

+ func (rn RenderableNode) Copy() RenderableNode

+ func (rn RenderableNode) Prune() RenderableNode

+ func (rn RenderableNode) WithNode(n report.Node) RenderableNode

type RenderableNodes

+ func MakeRenderableNodes(t report.Topology) RenderableNodes

+ func MapContainer2IP(m RenderableNode, _ report.Networks) RenderableNodes

+ func MapCountContainers(n RenderableNode, _ report.Networks) RenderableNodes

+ func MapCountProcessName(n RenderableNode, _ report.Networks) RenderableNodes

+ func MapEndpoint2IP(m RenderableNode, local report.Networks) RenderableNodes

+ func MapIP2Container(n RenderableNode, _ report.Networks) RenderableNodes

+ func (rns RenderableNodes) Copy() RenderableNodes

+ func (rns RenderableNodes) Prune() RenderableNodes

type Renderer

+ func ColorConnected(r Renderer) Renderer

+ func FilterSystem(r Renderer) Renderer

+ EdgeMetadata func(rpt report.Report, localID, remoteID string) report.EdgeMetadata

type Row

+ Expandable bool

+ type TopologySelector func(r report.Report) RenderableNodes

+ func (t TopologySelector) EdgeMetadata(rpt report.Report, srcID, dstID string) report.EdgeMetadata

+ func (t TopologySelector) Render(r report.Report) RenderableNodes

Jul 16, 2015

Changes in this version

type RenderableNode

+ func MapContainerImage2Name(n RenderableNode) (RenderableNode, bool)

Jun 30, 2015

Changes in this version

+ const KeyBytesEgress

+ const KeyBytesIngress

+ const KeyMaxConnCountTCP

+ const TheInternetID

+ const TheInternetMajor

+ const UncontainedID

+ const UncontainedMajor

+ var AddressRenderer = LeafMap

+ var ContainerImageRenderer = MakeReduce(Map{ ... }, LeafMap{ ... })

+ var ContainerRenderer = MakeReduce(Map{ ... }, LeafMap{ ... })

+ var EndpointRenderer = LeafMap

+ var HostRenderer = MakeReduce(Map{ ... }, LeafMap{ ... })

+ var ProcessNameRenderer = Map

+ var ProcessRenderer = MakeReduce(Map{ ... }, LeafMap{ ... })

+ func LocalNetworks(r report.Report) report.Networks

+ func MakeAddressID(hostID, addr string) string

+ func MakeEndpointID(hostID, addr, port string) string

+ func MakeHostID(hostID string) string

+ func MakeProcessID(hostID, pid string) string

+ func MakePseudoNodeID(parts ...string) string

+ type AggregateMetadata map[string]int

+ func AggregateMetadataOf(md report.EdgeMetadata) AggregateMetadata

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

+ type DetailedNode struct

+ ID string

+ LabelMajor string

+ LabelMinor string

+ Pseudo bool

+ Tables []Table

+ func MakeDetailedNode(r report.Report, n RenderableNode) DetailedNode

+ type Diff struct

+ Add []RenderableNode

+ Remove []string

+ Update []RenderableNode

+ func TopoDiff(a, b RenderableNodes) Diff

+ type FilterUnconnected struct

+ func (f FilterUnconnected) Render(rpt report.Report) RenderableNodes

+ type LeafMap struct

+ Mapper LeafMapFunc

+ Pseudo PseudoFunc

+ Selector report.TopologySelector

+ func (m LeafMap) AggregateMetadata(rpt report.Report, srcRenderableID, dstRenderableID string) AggregateMetadata

+ func (m LeafMap) Render(rpt report.Report) RenderableNodes

+ type LeafMapFunc func(report.NodeMetadata) (RenderableNode, bool)

+ type Map struct

+ func (m Map) AggregateMetadata(rpt report.Report, srcRenderableID, dstRenderableID string) AggregateMetadata

+ func (m Map) Render(rpt report.Report) RenderableNodes

+ type MapFunc func(RenderableNode) (RenderableNode, bool)

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

+ func GenericPseudoNode(addresser func(id string) net.IP) PseudoFunc

+ type Reduce []Renderer

+ func (r Reduce) AggregateMetadata(rpt report.Report, localID, remoteID string) AggregateMetadata

+ func (r Reduce) Render(rpt report.Report) RenderableNodes

+ type RenderableNode struct

+ Adjacency report.IDList

+ ID string

+ LabelMajor string

+ LabelMinor string

+ Origins report.IDList

+ Pseudo bool

+ Rank string

+ func MapAddress2Host(n RenderableNode) (RenderableNode, bool)

+ func MapAddressIdentity(m report.NodeMetadata) (RenderableNode, bool)

+ func MapContainer2ContainerImage(n RenderableNode) (RenderableNode, bool)

+ func MapContainerIdentity(m report.NodeMetadata) (RenderableNode, bool)

+ func MapContainerImageIdentity(m report.NodeMetadata) (RenderableNode, bool)

+ func MapEndpoint2Process(n RenderableNode) (RenderableNode, bool)

+ func MapEndpointIdentity(m report.NodeMetadata) (RenderableNode, bool)

+ func MapHostIdentity(m report.NodeMetadata) (RenderableNode, bool)

+ func MapProcess2Container(n RenderableNode) (RenderableNode, bool)

+ func MapProcess2Name(n RenderableNode) (RenderableNode, bool)

+ func MapProcessIdentity(m report.NodeMetadata) (RenderableNode, bool)

+ func NewRenderableNode(id, major, minor, rank string, nmd report.NodeMetadata) RenderableNode

+ func PanicPseudoNode(src string, srcMapped RenderableNode, dst string, local report.Networks) (RenderableNode, bool)

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

+ type RenderableNodes map[string]RenderableNode

+ func OnlyConnected(input RenderableNodes) RenderableNodes

+ func (rns RenderableNodes) Merge(other RenderableNodes)

+ type Renderer interface

+ AggregateMetadata func(rpt report.Report, localID, remoteID string) AggregateMetadata

+ Render func(report.Report) RenderableNodes

+ func MakeReduce(renderers ...Renderer) Renderer

+ type Row struct

+ Key string

+ ValueMajor string

+ ValueMinor string

+ type Table struct

+ Numeric bool

+ Rank int

+ Rows []Row

+ Title string

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