fixture

package
v1.13.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 9, 2021 License: Apache-2.0 Imports: 7 Imported by: 21

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Now = time.Now()

	ClientHostID  = "client.hostname.com"
	ServerHostID  = "server.hostname.com"
	UnknownHostID = ""

	ClientIP         = "10.10.10.20"
	ServerIP         = "192.168.1.1"
	UnknownClient1IP = "10.10.10.10"
	UnknownClient2IP = "10.10.10.10"
	UnknownClient3IP = "10.10.10.11"
	RandomClientIP   = "51.52.53.54"
	GoogleIP         = "8.8.8.8"

	ClientPort54001        = "54001"
	ClientPort54002        = "54002"
	ServerPort             = "80"
	UnknownClient1Port     = "54010"
	UnknownClient2Port     = "54020"
	UnknownClient3Port     = "54020"
	RandomClientPort       = "12345"
	GooglePort             = "80"
	NonContainerClientPort = "46789"

	ClientHostName = ClientHostID
	ServerHostName = ServerHostID

	Client1PID      = "10001"
	Client2PID      = "30020"
	ServerPID       = "215"
	NonContainerPID = "1234"

	Client1Name      = "/usr/bin/curl"
	Client2Name      = "/usr/bin/curl"
	ServerName       = "apache"
	NonContainerName = "bash"

	True = "true"

	ClientHostNodeID = report.MakeHostNodeID(ClientHostID)
	ServerHostNodeID = report.MakeHostNodeID(ServerHostID)

	Client54001NodeID    = report.MakeEndpointNodeID(ClientHostID, "", ClientIP, ClientPort54001)            // curl (1)
	Client54002NodeID    = report.MakeEndpointNodeID(ClientHostID, "", ClientIP, ClientPort54002)            // curl (2)
	Server80NodeID       = report.MakeEndpointNodeID(ServerHostID, "", ServerIP, ServerPort)                 // apache
	UnknownClient1NodeID = report.MakeEndpointNodeID(ServerHostID, "", UnknownClient1IP, UnknownClient1Port) // we want to ensure two unknown clients, connnected
	UnknownClient2NodeID = report.MakeEndpointNodeID(ServerHostID, "", UnknownClient2IP, UnknownClient2Port) // to the same server, are deduped.
	UnknownClient3NodeID = report.MakeEndpointNodeID(ServerHostID, "", UnknownClient3IP, UnknownClient3Port) // Check this one isn't deduped
	RandomClientNodeID   = report.MakeEndpointNodeID(ServerHostID, "", RandomClientIP, RandomClientPort)     // this should become an internet node
	NonContainerNodeID   = report.MakeEndpointNodeID(ServerHostID, "", ServerIP, NonContainerClientPort)
	GoogleEndpointNodeID = report.MakeEndpointNodeID(ServerHostID, "", GoogleIP, GooglePort)

	ClientProcess1NodeID      = report.MakeProcessNodeID(ClientHostID, Client1PID)
	ClientProcess2NodeID      = report.MakeProcessNodeID(ClientHostID, Client2PID)
	ServerProcessNodeID       = report.MakeProcessNodeID(ServerHostID, ServerPID)
	NonContainerProcessNodeID = report.MakeProcessNodeID(ServerHostID, NonContainerPID)

	ClientContainerID      = "a1b2c3d4e5"
	ClientContainerName    = "client"
	ServerContainerID      = "5e4d3c2b1a"
	ServerContainerName    = "task-name-5-server-aceb93e2f2b797caba01"
	ServerContainer2ID     = "1a1d30201f"
	ServerContainer2Name   = "task-name-6-server-8213182737"
	ClientContainerNodeID  = report.MakeContainerNodeID(ClientContainerID)
	ServerContainerNodeID  = report.MakeContainerNodeID(ServerContainerID)
	ServerContainer2NodeID = report.MakeContainerNodeID(ServerContainer2ID)

	TestLabelKey1          = "myrole"
	ApplicationLabelValue1 = "customapplication1"
	TestLabelKey2          = "myrole2"
	ApplicationLabelValue2 = "customapplication2"

	ClientContainerHostname = ClientContainerName + ".hostname.com"
	ServerContainerHostname = ServerContainerName + ".hostname.com"

	ClientContainerImageID     = "imageid123"
	ServerContainerImageID     = "imageid456"
	ClientContainerImageNodeID = report.MakeContainerImageNodeID(ClientContainerImageID)
	ServerContainerImageNodeID = report.MakeContainerImageNodeID(ServerContainerImageID)
	ClientContainerImageName   = "image/client"
	ServerContainerImageName   = "image/server"

	KubernetesNamespace         = "ping"
	ClientPodUID                = "5d4c3b2a1"
	ServerPodUID                = "i9h8g7f6e"
	ClientPodNodeID             = report.MakePodNodeID(ClientPodUID)
	ServerPodNodeID             = report.MakePodNodeID(ServerPodUID)
	ServiceName                 = "pongservice"
	ServiceUID                  = "service1234"
	ServiceNodeID               = report.MakeServiceNodeID(ServiceUID)
	PersistentVolumeUID         = "pv1234"
	PersistentVolumeNodeID      = report.MakePersistentVolumeNodeID(PersistentVolumeUID)
	PersistentVolumeClaimUID    = "pvc1234"
	PersistentVolumeClaimNodeID = report.MakePersistentVolumeClaimNodeID(PersistentVolumeClaimUID)
	StorageClassUID             = "sc1234"
	StorageClassNodeID          = report.MakeStorageClassNodeID(StorageClassUID)
	VolumeSnapshotUID           = "vs1234"
	VolumeSnapshotNodeID        = report.MakeVolumeSnapshotNodeID(VolumeSnapshotUID)
	VolumeSnapshotDataUID       = "vsd1234"
	VolumeSnapshotDataNodeID    = report.MakeVolumeSnapshotDataNodeID(VolumeSnapshotDataUID)

	ClientProcess1CPUMetric    = report.MakeSingletonMetric(Now.Add(-1*time.Second), 0.01)
	ClientProcess1MemoryMetric = report.MakeSingletonMetric(Now.Add(-2*time.Second), 0.02)

	ClientContainerCPUMetric    = report.MakeSingletonMetric(Now.Add(-3*time.Second), 0.03)
	ClientContainerMemoryMetric = report.MakeSingletonMetric(Now.Add(-4*time.Second), 0.04)

	ServerContainerCPUMetric    = report.MakeSingletonMetric(Now.Add(-5*time.Second), 0.05)
	ServerContainerMemoryMetric = report.MakeSingletonMetric(Now.Add(-6*time.Second), 0.06)

	ClientHostCPUMetric    = report.MakeSingletonMetric(Now.Add(-7*time.Second), 0.07)
	ClientHostMemoryMetric = report.MakeSingletonMetric(Now.Add(-8*time.Second), 0.08)
	ClientHostLoad1Metric  = report.MakeSingletonMetric(Now.Add(-9*time.Second), 0.09)

	ServerHostCPUMetric    = report.MakeSingletonMetric(Now.Add(-12*time.Second), 0.12)
	ServerHostMemoryMetric = report.MakeSingletonMetric(Now.Add(-13*time.Second), 0.13)
	ServerHostLoad1Metric  = report.MakeSingletonMetric(Now.Add(-14*time.Second), 0.14)

	Report = report.Report{
		ID: "test-report",
		Endpoint: report.Topology{
			Nodes: report.Nodes{

				Client54001NodeID: report.MakeNode(Client54001NodeID).WithTopology(report.Endpoint).WithLatests(map[string]string{
					process.PID:       Client1PID,
					report.HostNodeID: ClientHostNodeID,
				}).WithAdjacent(Server80NodeID),

				Client54002NodeID: report.MakeNode(Client54002NodeID).WithTopology(report.Endpoint).WithLatests(map[string]string{
					process.PID:       Client2PID,
					report.HostNodeID: ClientHostNodeID,
				}).WithAdjacent(Server80NodeID),

				Server80NodeID: report.MakeNode(Server80NodeID).WithTopology(report.Endpoint).WithLatests(map[string]string{
					process.PID:       ServerPID,
					report.HostNodeID: ServerHostNodeID,
				}),

				NonContainerNodeID: report.MakeNode(NonContainerNodeID).WithTopology(report.Endpoint).WithLatests(map[string]string{
					process.PID:       NonContainerPID,
					report.HostNodeID: ServerHostNodeID,
				}).WithAdjacent(GoogleEndpointNodeID),

				UnknownClient1NodeID: report.MakeNode(UnknownClient1NodeID).WithTopology(report.Endpoint).WithAdjacent(Server80NodeID),
				UnknownClient2NodeID: report.MakeNode(UnknownClient2NodeID).WithTopology(report.Endpoint).WithAdjacent(Server80NodeID),
				UnknownClient3NodeID: report.MakeNode(UnknownClient3NodeID).WithTopology(report.Endpoint).WithAdjacent(Server80NodeID),
				RandomClientNodeID:   report.MakeNode(RandomClientNodeID).WithTopology(report.Endpoint).WithAdjacent(Server80NodeID),
				GoogleEndpointNodeID: report.MakeNode(GoogleEndpointNodeID).WithTopology(report.Endpoint),
			},
		},
		Process: report.Topology{
			Nodes: report.Nodes{
				ClientProcess1NodeID: report.MakeNodeWith(ClientProcess1NodeID, map[string]string{
					process.PID:        Client1PID,
					process.Name:       Client1Name,
					docker.ContainerID: ClientContainerID,
					report.HostNodeID:  ClientHostNodeID,
				}).
					WithTopology(report.Process).WithParents(report.MakeSets().
					Add("host", report.MakeStringSet(ClientHostNodeID)).
					Add("container", report.MakeStringSet(ClientContainerNodeID)),
				).WithMetrics(report.Metrics{
					process.CPUUsage:    ClientProcess1CPUMetric,
					process.MemoryUsage: ClientProcess1MemoryMetric,
				}),
				ClientProcess2NodeID: report.MakeNodeWith(ClientProcess2NodeID, map[string]string{
					process.PID:        Client2PID,
					process.Name:       Client2Name,
					docker.ContainerID: ClientContainerID,
					report.HostNodeID:  ClientHostNodeID,
				}).
					WithTopology(report.Process).WithParents(report.MakeSets().
					Add("host", report.MakeStringSet(ClientHostNodeID)).
					Add("container", report.MakeStringSet(ClientContainerNodeID)),
				),
				ServerProcessNodeID: report.MakeNodeWith(ServerProcessNodeID, map[string]string{
					process.PID:        ServerPID,
					process.Name:       ServerName,
					docker.ContainerID: ServerContainerID,
					report.HostNodeID:  ServerHostNodeID,
				}).
					WithTopology(report.Process).WithParents(report.MakeSets().
					Add("host", report.MakeStringSet(ServerHostNodeID)).
					Add("container", report.MakeStringSet(ServerContainerNodeID)),
				),
				NonContainerProcessNodeID: report.MakeNodeWith(NonContainerProcessNodeID, map[string]string{
					process.PID:       NonContainerPID,
					process.Name:      NonContainerName,
					report.HostNodeID: ServerHostNodeID,
				}).
					WithTopology(report.Process).WithParents(report.MakeSets().
					Add("host", report.MakeStringSet(ServerHostNodeID)),
				),
			},
			MetadataTemplates: process.MetadataTemplates,
			MetricTemplates:   process.MetricTemplates,
		}.WithShape(report.Square).WithLabel("process", "processes"),
		Container: report.Topology{
			Nodes: report.Nodes{
				ClientContainerNodeID: report.MakeNodeWith(

					ClientContainerNodeID, map[string]string{
						docker.ContainerID:                           ClientContainerID,
						docker.ContainerName:                         ClientContainerName,
						docker.ContainerHostname:                     ClientContainerHostname,
						docker.ImageID:                               ClientContainerImageID,
						report.HostNodeID:                            ClientHostNodeID,
						docker.LabelPrefix + "io.kubernetes.pod.uid": ClientPodUID,
						docker.LabelPrefix + TestLabelKey1:           ApplicationLabelValue1,
						kubernetes.Namespace:                         KubernetesNamespace,
						docker.ContainerState:                        report.StateRunning,
						docker.ContainerStateHuman:                   report.StateRunning,
					}).
					WithTopology(report.Container).WithParents(report.MakeSets().
					Add("host", report.MakeStringSet(ClientHostNodeID)).
					Add("container_image", report.MakeStringSet(ClientContainerImageNodeID)).
					Add("pod", report.MakeStringSet(ClientPodNodeID)),
				).WithMetrics(report.Metrics{
					docker.CPUTotalUsage: ClientContainerCPUMetric,
					docker.MemoryUsage:   ClientContainerMemoryMetric,
				}),
				ServerContainerNodeID: report.MakeNodeWith(

					ServerContainerNodeID, map[string]string{
						docker.ContainerID:         ServerContainerID,
						docker.ContainerName:       ServerContainerName,
						docker.ContainerHostname:   ServerContainerHostname,
						docker.ContainerState:      report.StateRunning,
						docker.ContainerStateHuman: report.StateRunning,
						docker.ImageID:             ServerContainerImageID,
						report.HostNodeID:          ServerHostNodeID,
						docker.LabelPrefix + detailed.AmazonECSContainerNameLabel: "server",
						docker.LabelPrefix + "foo1":                               "bar1",
						docker.LabelPrefix + "foo2":                               "bar2",
						docker.LabelPrefix + "io.kubernetes.pod.uid":              ServerPodUID,
						docker.LabelPrefix + TestLabelKey2:                        ApplicationLabelValue2,
						kubernetes.Namespace:                                      KubernetesNamespace,
					}).
					WithTopology(report.Container).WithParents(report.MakeSets().
					Add("host", report.MakeStringSet(ServerHostNodeID)).
					Add("container_image", report.MakeStringSet(ServerContainerImageNodeID)).
					Add("pod", report.MakeStringSet(ServerPodNodeID)),
				).WithMetrics(report.Metrics{
					docker.CPUTotalUsage: ServerContainerCPUMetric,
					docker.MemoryUsage:   ServerContainerMemoryMetric,
				}),

				ServerContainer2NodeID: report.MakeNodeWith(
					ServerContainer2NodeID, map[string]string{
						docker.ContainerID:         ServerContainer2ID,
						docker.ContainerName:       ServerContainer2Name,
						docker.ContainerHostname:   ServerContainerHostname,
						docker.ContainerState:      report.StateRunning,
						docker.ContainerStateHuman: report.StateRunning,
						docker.ImageID:             ServerContainerImageID,
						report.HostNodeID:          ServerHostNodeID,
					}).
					WithTopology(report.Container).WithParents(report.MakeSets().
					Add("host", report.MakeStringSet(ServerHostNodeID)).
					Add("container_image", report.MakeStringSet(ServerContainerImageNodeID))),
			},
			MetadataTemplates: docker.ContainerMetadataTemplates,
			MetricTemplates:   docker.ContainerMetricTemplates,
		}.WithShape(report.Hexagon).WithLabel("container", "containers"),
		ContainerImage: report.Topology{
			Nodes: report.Nodes{
				ClientContainerImageNodeID: report.MakeNodeWith(ClientContainerImageNodeID, map[string]string{
					docker.ImageID:    ClientContainerImageID,
					docker.ImageName:  ClientContainerImageName,
					report.HostNodeID: ClientHostNodeID,
				}).
					WithParents(report.MakeSets().
						Add("host", report.MakeStringSet(ClientHostNodeID)),
					).WithTopology(report.ContainerImage),
				ServerContainerImageNodeID: report.MakeNodeWith(ServerContainerImageNodeID, map[string]string{
					docker.ImageID:              ServerContainerImageID,
					docker.ImageName:            ServerContainerImageName,
					report.HostNodeID:           ServerHostNodeID,
					docker.LabelPrefix + "foo1": "bar1",
					docker.LabelPrefix + "foo2": "bar2",
				}).
					WithParents(report.MakeSets().
						Add("host", report.MakeStringSet(ServerHostNodeID)),
					).WithTopology(report.ContainerImage),
			},
			MetadataTemplates: docker.ContainerImageMetadataTemplates,
		}.WithShape(report.Hexagon).WithLabel("image", "images"),
		Host: report.Topology{
			Nodes: report.Nodes{
				ClientHostNodeID: report.MakeNodeWith(

					ClientHostNodeID, map[string]string{
						"host_name":       ClientHostName,
						"os":              "Linux",
						report.HostNodeID: ClientHostNodeID,
					}).
					WithTopology(report.Host).WithSets(report.MakeSets().
					Add(report.HostLocalNetworks, report.MakeStringSet("10.10.10.0/24")),
				).WithMetrics(report.Metrics{
					report.HostCPUUsage:    ClientHostCPUMetric,
					report.HostMemoryUsage: ClientHostMemoryMetric,
					report.Load1:           ClientHostLoad1Metric,
				}),
				ServerHostNodeID: report.MakeNodeWith(

					ServerHostNodeID, map[string]string{
						"host_name":       ServerHostName,
						"os":              "Linux",
						report.HostNodeID: ServerHostNodeID,
					}).
					WithTopology(report.Host).WithSets(report.MakeSets().
					Add(report.HostLocalNetworks, report.MakeStringSet("10.10.10.0/24")),
				).WithMetrics(report.Metrics{
					report.HostCPUUsage:    ServerHostCPUMetric,
					report.HostMemoryUsage: ServerHostMemoryMetric,
					report.Load1:           ServerHostLoad1Metric,
				}),
			},
			MetadataTemplates: host.MetadataTemplates,
			MetricTemplates:   host.MetricTemplates,
		}.WithShape(report.Circle).WithLabel("host", "hosts"),
		Pod: report.Topology{
			Nodes: report.Nodes{
				ClientPodNodeID: report.MakeNodeWith(
					ClientPodNodeID, map[string]string{
						kubernetes.Name:      "pong-a",
						kubernetes.Namespace: KubernetesNamespace,
						report.HostNodeID:    ClientHostNodeID,
					}).
					WithTopology(report.Pod).WithParents(report.MakeSets().
					Add("host", report.MakeStringSet(ClientHostNodeID)).
					Add("service", report.MakeStringSet(ServiceNodeID)),
				),
				ServerPodNodeID: report.MakeNodeWith(
					ServerPodNodeID, map[string]string{
						kubernetes.Name:      "pong-b",
						kubernetes.Namespace: KubernetesNamespace,
						kubernetes.State:     "running",
						report.HostNodeID:    ServerHostNodeID,
					}).
					WithTopology(report.Pod).WithParents(report.MakeSets().
					Add("host", report.MakeStringSet(ServerHostNodeID)).
					Add("service", report.MakeStringSet(ServiceNodeID)),
				),
			},
			MetadataTemplates: kubernetes.PodMetadataTemplates,
		}.WithShape(report.Heptagon).WithLabel("pod", "pods"),
		Service: report.Topology{
			Nodes: report.Nodes{
				ServiceNodeID: report.MakeNodeWith(

					ServiceNodeID, map[string]string{
						kubernetes.Name:      "pongservice",
						kubernetes.Namespace: "ping",
					}).
					WithTopology(report.Service),
			},
		}.WithShape(report.Heptagon).WithLabel("service", "services"),
		PersistentVolumeClaim: report.Topology{
			Nodes: report.Nodes{
				PersistentVolumeClaimNodeID: report.MakeNodeWith(

					PersistentVolumeClaimNodeID, map[string]string{
						kubernetes.Name:             "pvc-6124",
						kubernetes.Namespace:        "ping",
						kubernetes.Status:           "bound",
						kubernetes.VolumeName:       "pongvolume",
						kubernetes.AccessModes:      "ReadWriteOnce",
						kubernetes.StorageClassName: "standard",
					}).
					WithTopology(report.PersistentVolumeClaim),
			},
		}.WithShape(report.DottedCylinder).WithLabel("persistent volume claim", "persistent volume claims"),
		PersistentVolume: report.Topology{
			Nodes: report.Nodes{
				PersistentVolumeNodeID: report.MakeNodeWith(

					PersistentVolumeNodeID, map[string]string{
						kubernetes.Name:             "pongvolume",
						kubernetes.Namespace:        "ping",
						kubernetes.Status:           "bound",
						kubernetes.VolumeClaim:      "pvc-6124",
						kubernetes.AccessModes:      "ReadWriteOnce",
						kubernetes.StorageClassName: "standard",
						kubernetes.StorageDriver:    "iSCSI",
					}).
					WithTopology(report.PersistentVolume),
			},
		}.WithShape(report.Cylinder).WithLabel("persistent volume", "persistent volumes"),
		StorageClass: report.Topology{
			Nodes: report.Nodes{
				StorageClassNodeID: report.MakeNodeWith(

					StorageClassNodeID, map[string]string{
						kubernetes.Name:        "standard",
						kubernetes.Provisioner: "pong",
					}).
					WithTopology(report.StorageClass),
			},
		}.WithShape(report.StorageSheet).WithLabel("storage class", "storage classes"),
		VolumeSnapshot: report.Topology{
			Nodes: report.Nodes{
				VolumeSnapshotNodeID: report.MakeNodeWith(

					VolumeSnapshotNodeID, map[string]string{
						kubernetes.Name:         "vs-1234",
						kubernetes.Namespace:    "ping",
						kubernetes.VolumeClaim:  "pvc-6124",
						kubernetes.SnapshotData: "vsd-1234",
						kubernetes.VolumeName:   "pongvolume",
					}).
					WithTopology(report.VolumeSnapshot),
			},
		}.WithShape(report.DottedCylinder).WithLabel("volume snapshot", "volume snapshots").
			WithTag(report.Camera),
		VolumeSnapshotData: report.Topology{
			Nodes: report.Nodes{
				VolumeSnapshotDataNodeID: report.MakeNodeWith(

					VolumeSnapshotDataNodeID, map[string]string{
						kubernetes.Name:               "vsd-1234",
						kubernetes.VolumeName:         "pongvolume",
						kubernetes.VolumeSnapshotName: "vs-1234",
					}).
					WithTopology(report.VolumeSnapshotData),
			},
		}.WithShape(report.Cylinder).WithLabel("volume snapshot data", "volume snapshot data").
			WithTag(report.Camera),
		Sampling: report.Sampling{
			Count: 1024,
			Total: 4096,
		},
		Window: 2 * time.Second,
	}
)

This is an example Report: 

2 hosts with probes installed - client & server.

Functions

This section is empty.

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.