Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/GeorgeMac/adagio
/ functions
Functions
551 in github.com/GeorgeMac/adagio
⨍
Functions
551
◇
Types & classes
104
↓ 29 callers
Method
Run
(ctx context.Context)
pkg/runtimes/runtime.go:55
↓ 23 callers
Function
completed
(spec *adagio.Node_Spec, inputs map[string][]byte, attempts ...*adagio.Node_Result)
pkg/repository/repository.go:1024
↓ 23 callers
Function
running
(spec *adagio.Node_Spec, inputs map[string][]byte, attempts ...*adagio.Node_Result)
pkg/repository/repository.go:1017
↓ 20 callers
Method
Parse
(n *adagio.Node)
pkg/runtimes/runtime.go:54
↓ 17 callers
Function
success
(output string)
pkg/repository/repository.go:1037
↓ 16 callers
Method
Connect
Connect constructs and edge from one node to another
pkg/graph/graph.go:116
↓ 15 callers
Method
String
()
pkg/adagio/adagio.pb.go:181
↓ 14 callers
Method
Format
Format delegates to the underlying FormatterFunc
pkg/printing/dot.go:20
↓ 11 callers
Method
ListRuns
(ctx context.Context, in *ListRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:452
↓ 9 callers
Method
Run
(context.Context, *adagio.Node)
pkg/agent/agent.go:68
↓ 9 callers
Method
String
String configures a string argument which when call with a string pointer will set the pointer on calls to builder.Parse() and read the value at the e
pkg/runtimes/runtime.go:143
↓ 9 callers
Method
Strings
Strings configures a string slice argument which when call with a string slice pointer will set the pointer on calls to builder.Parse() and read the v
pkg/runtimes/runtime.go:173
↓ 9 callers
Function
exitIfError
(err error)
cmd/adagio/main.go:83
↓ 7 callers
Method
Start
(ctx context.Context, in *StartRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:451
↓ 7 callers
Method
cancelLease
(claimID string)
pkg/etcd/etcd.go:459
↓ 7 callers
Method
present
(n Node)
pkg/graph/graph.go:246
↓ 7 callers
Function
statusToString
(status adagio.Node_Status)
pkg/etcd/etcd.go:1009
↓ 7 callers
Function
wrapMissingErr
(n Node)
pkg/graph/graph.go:302
↓ 6 callers
Method
Incoming
Incoming returns a set of nodes which are directed from the provided node
pkg/graph/graph.go:107
↓ 6 callers
Method
Int64
Int64 configures an int64 argument which will set the pointer on calls to builder.Parse() and read the value at the end of the pointer on calls to bui
pkg/runtimes/runtime.go:199
↓ 6 callers
Method
StartRun
(context.Context, *adagio.GraphSpec)
pkg/service/controlplane/server.go:19
↓ 6 callers
Function
exit
(v interface{}, code int)
cmd/adagio/main.go:91
↓ 6 callers
Function
nodeInStateKey
(runID, state, name string)
pkg/etcd/etcd.go:969
↓ 5 callers
Function
GraphFrom
GraphFrom takes a run and builds a *graph.Graph from it which contains helpful functions to traversing the runs graph structure
pkg/adagio/run.go:96
↓ 5 callers
Method
Inspect
(ctx context.Context, in *InspectRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:453
↓ 5 callers
Method
ListAgents
(ctx context.Context, in *ListRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:454
↓ 5 callers
Function
NewBuilder
NewBuilder constructs and configures a new runtime builder
pkg/runtimes/runtime.go:88
↓ 5 callers
Function
NewPool
NewPool constructs and configures a new node pool for execution
pkg/agent/agent.go:95
↓ 5 callers
Method
Outgoing
Outgoing returns a set of nodes which are directed to from the provided node
pkg/graph/graph.go:97
↓ 5 callers
Method
Stats
(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:450
↓ 5 callers
Function
WithAgentCount
WithAgentCount configures the number of agents to be run
pkg/agent/options.go:17
↓ 5 callers
Method
clone
()
pkg/graph/graph.go:41
↓ 5 callers
Method
getRun
(ctx context.Context, id string, ops ...clientv3.OpOption)
pkg/etcd/etcd.go:796
↓ 5 callers
Function
newArgument
(name string, argumentType ArgumentType, required bool, defaultValues []string)
pkg/runtimes/runtime.go:374
↓ 5 callers
Function
stripClaims
(nodes []*adagio.Node)
pkg/repository/repository.go:1070
↓ 4 callers
Method
Exec
Exec executes the test layer against the provided testing T given a context
pkg/repository/repository.go:831
↓ 4 callers
Function
New
New constructs a new graph from a set of Nodes
pkg/graph/graph.go:30
↓ 4 callers
Method
Node
Node creates a node from a provided name and SpecBuilder type it also applies any provided options
pkg/workflow/workflow.go:67
↓ 4 callers
Method
Time
Time configures a time argument which when call with a int64 pointer will set the pointer on calls to builder.Parse() and read the value at the end of
pkg/runtimes/runtime.go:229
↓ 4 callers
Function
WithClaimerFunc
WithClaimerFunc overrides the claimer which generates a unique claim per node claim attempt
pkg/agent/options.go:25
↓ 4 callers
Function
fail
(output string)
pkg/repository/repository.go:1041
↓ 4 callers
Function
newRepository
(subscriptionCount int, nodes ...*adagio.Node)
pkg/agent/support_test.go:40
↓ 4 callers
Function
node
(spec *adagio.Node_Spec, status adagio.Node_Status, inputs map[string][]byte)
pkg/repository/repository.go:1033
↓ 4 callers
Function
result
(output string, conclusion adagio.Node_Result_Conclusion)
pkg/repository/repository.go:1051
↓ 4 callers
Method
statusDoesNotExist
(runID string, node *adagio.Node, status adagio.Node_Status)
pkg/etcd/etcd.go:411
↓ 4 callers
Method
transition
(runID string, node *adagio.Node, toStatus adagio.Node_Status, cmps []clientv3.Cmp, ops []clientv3.Op, putOpts
pkg/etcd/etcd.go:345
↓ 3 callers
Method
AddNodes
AddNodes adds the provided nodes to the graph
pkg/graph/graph.go:59
↓ 3 callers
Method
ClaimNode
(ctx context.Context, runID, name string, claim *adagio.Claim)
pkg/agent/agent.go:26
↓ 3 callers
Method
Cycles
Cycles detects and returns any cycles found within the graph
pkg/graph/graph.go:128
↓ 3 callers
Method
DependsOn
DependsOn creates a connection from the provided nodes (sources) to the callee node (destination) on the original builder
pkg/workflow/workflow.go:143
↓ 3 callers
Method
GetNodeByName
GetNodeByName fetches a Node from the Run by name
pkg/adagio/run.go:48
↓ 3 callers
Method
JSON
JSON configures an argument which should be called with a pointer to any json marshallable type It will set the pointer on calls to builder.Parse() by
pkg/runtimes/runtime.go:261
↓ 3 callers
Function
NewControlPlaneClient
(cc *grpc.ClientConn)
pkg/rpc/controlplane/service.pb.go:461
↓ 3 callers
Function
PBRunToRun
PBRunToRun takes a protobuf run and adapts it to the printer.Run type which is used to produce a friendlier printing output
pkg/printing/print.go:43
↓ 3 callers
Method
Subscribe
(ctx context.Context, agent *adagio.Agent, events chan<- *adagio.Event, types ...adagio.Event_Type)
pkg/agent/agent.go:28
↓ 3 callers
Function
VisitLatestAttempt
VisitLatestAttempt calls the supplied function with the latest attempt result if any attempts have been made
pkg/adagio/node.go:41
↓ 3 callers
Function
canClaim
(ctx context.Context, t *testing.T, repo Repository, run *adagio.Run, nodes map[string]*adagio.Node)
pkg/repository/repository.go:913
↓ 3 callers
Function
claims
(count int, runID, name string, claim *adagio.Claim)
pkg/agent/support_test.go:61
↓ 3 callers
Method
complete
(runID string, node *adagio.Node, cmps []clientv3.Cmp, ops []clientv3.Op)
pkg/etcd/etcd.go:332
↓ 3 callers
Function
errorResult
(output string)
pkg/repository/repository.go:1047
↓ 3 callers
Method
notifyReady
(run *adagio.Run, node *adagio.Node)
pkg/memory/repository.go:273
↓ 3 callers
Method
remove
(n Node)
pkg/graph/graph.go:275
↓ 3 callers
Method
state
(runID string)
pkg/memory/repository.go:434
↓ 2 callers
Function
CanRetry
CanRetry returns true if the node can be retried
pkg/adagio/node.go:18
↓ 2 callers
Method
FinishNode
(ctx context.Context, runID, name string, result *adagio.Node_Result, claim *adagio.Claim)
pkg/agent/agent.go:27
↓ 2 callers
Method
InspectRun
(ctx context.Context, id string)
pkg/service/controlplane/server.go:20
↓ 2 callers
Method
ListRuns
(context.Context, ListRequest)
pkg/service/controlplane/server.go:21
↓ 2 callers
Function
New
New constructs and configure a new repository service from the provided etcd client and a set of function options
pkg/etcd/etcd.go:61
↓ 2 callers
Function
New
New constructs and configures a new in memory repository
pkg/memory/repository.go:50
↓ 2 callers
Function
NewRun
NewRun converts a graph specification into a new run instance This is a convention and helper function for repository implementations to use to correc
pkg/adagio/run.go:22
↓ 2 callers
Method
NewSpec
(name string)
pkg/workflow/workflow.go:15
↓ 2 callers
Method
Register
Register adds the runtime to the RuntimeMap
pkg/agent/agent.go:36
↓ 2 callers
Function
RuntimeFunc
RuntimeFunc converts a name and an anonymous call generating function into a Runtime
pkg/agent/agent.go:49
↓ 2 callers
Method
SetArgumentFromInput
(argument, input string)
pkg/workflow/workflow.go:22
↓ 2 callers
Method
Stats
(context.Context)
pkg/service/controlplane/server.go:18
↓ 2 callers
Method
String
()
pkg/rpc/controlplane/service.pb.go:265
↓ 2 callers
Function
TestHarness
TestHarness is a test suite which a repository must pass in order to be deemed appropriate as an adagio repository. It runs a number of import scenar
pkg/repository/repository.go:98
↓ 2 callers
Method
addNode
(n Node)
pkg/graph/graph.go:265
↓ 2 callers
Function
agentKey
(agent *adagio.Agent)
pkg/etcd/etcd.go:949
↓ 2 callers
Function
blankFunction
()
pkg/runtimes/exec/exec.go:26
↓ 2 callers
Function
blankFunction
()
pkg/runtimes/debug/debug.go:30
↓ 2 callers
Function
canFinish
(ctx context.Context, t *testing.T, repo Repository, run *adagio.Run, names map[string]adagio.Node_Result_Conc
pkg/repository/repository.go:945
↓ 2 callers
Method
connect
(from, to Node)
pkg/graph/graph.go:251
↓ 2 callers
Method
contains
(typ adagio.Event_Type)
pkg/etcd/etcd.go:1019
↓ 2 callers
Function
dfs
(all edgeSet, from Node, dest []Node)
pkg/graph/graph.go:233
↓ 2 callers
Method
dfsForward
()
pkg/graph/graph.go:211
↓ 2 callers
Method
handleKeyEvent
(ctx context.Context, dest chan<- *adagio.Event, ev keyEvent, filter filter, opts ...clientv3.OpOption)
pkg/etcd/etcd.go:744
↓ 2 callers
Method
initializeIfEmpty
()
pkg/graph/graph.go:48
↓ 2 callers
Function
inputArgument
(runtime string, argument *Argument)
pkg/runtimes/runtime.go:308
↓ 2 callers
Method
lease
(claimID string)
pkg/etcd/etcd.go:416
↓ 2 callers
Function
metadataArgument
(runtime string, argument *Argument)
pkg/runtimes/runtime.go:304
↓ 2 callers
Method
missing
()
pkg/runtimes/runtime.go:361
↓ 2 callers
Function
newClaim
()
pkg/repository/repository.go:1063
↓ 2 callers
Method
nodeIsOrphaned
(runID string, node *adagio.Node)
pkg/etcd/etcd.go:401
↓ 2 callers
Function
nodeKey
(runID, name string)
pkg/etcd/etcd.go:961
↓ 2 callers
Function
nodesInStateKey
(status adagio.Node_Status)
pkg/etcd/etcd.go:965
↓ 2 callers
Function
runKey
(run *adagio.Run)
pkg/etcd/etcd.go:953
↓ 1 callers
Method
Apply
Apply functions each option in order on the provided Function
pkg/runtimes/debug/debug.go:73
↓ 1 callers
Method
Apply
Apply calls each option on r in turn
pkg/etcd/options.go:10
↓ 1 callers
Method
Apply
Apply calls each option in turn on the provided Pool
pkg/agent/options.go:10
next →
1–100 of 551, ranked by callers