GoSend asynchronous message send, parks it on a new goroutine until it completes

Close implements Collector.

All routes that match a package

Splitter for a component of a name

Filter a name to take out components. "a.b.c" filter "*.*" returns "a"

Len of routing table

Named entry find and return that channel from the routing table

NewParent sets up the parent by promoting incoming span id, and get a new spanid

pretty printer for Values

Add an entry to the routing table

AnnotateReceive service activity when receiving a message

AnnotateSend service sends on a flow

Random channel from the routing table

Write a string to the file

AddSpan updates to get a new span for an existing request and parent

FilterNode to simplify its name

Names return all

Pick a random matching package and return that channel from the routing table

Find the node in the ring for a token

Route string formatter for routing part of context

StartNode starts a node using the named package, and connect it to any dependencies

Write an entry to the database

decide whether to write a comma before the newline or not

hash a string into the ring

AsJson returns current config as json

DebugContext turns on debug context logging for eureka and edda messages

Lookup a name and return the IP address for that name

NewTrace using atomic increment

ThroughputMax throughput for a given contention and crosstalk

AMI from a name

Container from a name

FromJson imports a config from json

MakeRouter with maps initialized

NameChan find the name corresponding to a channel

Package (same as AMI) from a name

Region extract from a name

Remove an entry from the routing table

ResponseRN time as a function of capacity

RingConfig gets the tokens for a ring

ThroughputXN as a function of capacity

WriteDone records that a node has gone away normally func WriteDone(name string, t time.Time) { if Enabled == false { return } } WriteEdge writes

WriteZip stores zipkin as json

Zone extract from a name

Common Annotation code

return uniquely incremented TraceContextType

all configuration and state is sent via messages

Shutdown fsm and pirates

verify the sizes of arrays above are equal at runtime

Arch extract from a name

WriteForget writes the forgotten edge to a file given a space separated edge id, from and to node names func WriteForget(fromTo string, t time.Time) {

Collect implements Collector.

ComposeArch makes an architecture from a compose V2 yaml format

Connect tells a source node how to connect to a target node directly by name, only used when Eureka can't be used

Create a tier and specify any dependencies, return the full name of the last node created

CreateChannels makes the maps of channels

CreateEureka service registries in each zone

Distribute tokens to one zone of a cassandra cluster, this doesn't yet allow for clusters to grow or replace nodes

FilterEdge - two space separated nodes

Flush the spans for a request in zipkin format

Instance from a name

Key finds a value given a key

Extract dependencies from an architecture

Machine from a name

Make a service name from components and an index

MakeContainer name from components and an index

NewKafkaCollector returns a new Kafka-backed Collector. addrs should be a slice of TCP endpoints of the form "host:port".

OtherRegions given one

OtherZones given one

Process from a name

ReadArch parses archjson

ReadCompose unmarshalls services from a yaml file

ReadComposeV2 unmarshalls services from a compose V2 yaml file

ResponseRX time as a function of throughput

Send a synchronous message

SendToName sends a message directly to a name via asgard, only used during setup

Service from a name

Setup by opening a connection to neo4j then removing stuff that's going to be updated

Shutdown the flow mapping system and flush remaining flows

ShutdownEureka shuts down the Eureka service registries and wait for them to go away

ShutdownNodes - shut down the nodes and wait for them to go away

Start eureka discovery service and set name directly

Start architecture

ThroughputXR as a function of response time

WriteFlow records messages in neo4j as well as zipkin

WriteNode writes the node to a file given a space separated name and service type