RegisterControlPlaneHandlerServer registers the http handlers for service ControlPlane to "mux". UnaryRPC :call ControlPlaneServer directly. Strea

Run calls Parse on the provided node and then invokes Run on the underlying ParseRunner

Run spawns a subprocess for the desired command and returns the combined output writer as an adagio Result output slice of bytes

Run invokes the desired debug operations. It first sleeps the configured amount and then loops over any provided chance conditions. Given no chance co

Run begins the configured number of agents and responds to cancelation of the supplied context

SetArgumentFromInput configures the argument to derives its value from the input paramertes of the node

Start adapts a control plane start request into a repository Start Run call and returns the result

Start invokes the built graph specification onto the provided client It returns the run responded by the controlplane API

StartRun takes a graph specification and instantiates it within etcd an returns the resulting Run representation

StartRun instantiates a run from a provided graph specification

Stats returns the state of world represented as counts within the etcd database

Stats returns counts of runs and nodes in their respective states

Stats adapts a controle plane stats request into a repository Stats call and returns the result

String prints a string representation of the argument type

Subscribe registers the agent as a subscriber and sends events regarding node readiness and orphanage on the provided events channel

Subscribe registers the provided channel to listen for the defined event types