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
↓ 1 callers
Method
Apply
Apply calls each option in turn on the provided Node_Spec
pkg/workflow/workflow.go:32
↓ 1 callers
Method
Build
Build constructs a graph specification from the builders state
pkg/workflow/workflow.go:76
↓ 1 callers
Function
Dot
Dot takes an adagio Run proto struct and returns a formatter
pkg/printing/dot.go:25
↓ 1 callers
Method
IsLeaf
IsLeaf returns true if the node has no outgoing edges within the graph
pkg/graph/graph.go:87
↓ 1 callers
Method
IsRoot
IsRoot returns true if the node has no incoming edges within the graph
pkg/graph/graph.go:77
↓ 1 callers
Method
ListAgents
(context.Context)
pkg/service/controlplane/server.go:22
↓ 1 callers
Function
MapOutputTo
MapOutputTo maps the output of the dependency onto the argument name of the callee
pkg/workflow/workflow.go:130
↓ 1 callers
Function
Mappable
(fn FunctionFunc)
pkg/workflow/support_test.go:29
↓ 1 callers
Method
Name
()
pkg/agent/agent.go:43
↓ 1 callers
Function
NewBuilder
NewBuilder creates and configures a new Builder
pkg/workflow/workflow.go:61
↓ 1 callers
Method
NewClaim
()
pkg/agent/agent.go:73
↓ 1 callers
Method
NewFunction
()
pkg/agent/agent.go:44
↓ 1 callers
Method
Orphan
(claim *adagio.Claim)
pkg/repository/repository.go:79
↓ 1 callers
Function
Pretty
Pretty is a formatter which used pretty to format the run
pkg/printing/print.go:112
↓ 1 callers
Function
RegisterControlPlaneHandler
RegisterControlPlaneHandler registers the http handlers for service ControlPlane to "mux". The handlers forward requests to the grpc endpoint over "co
pkg/rpc/controlplane/service.pb.gw.go:338
↓ 1 callers
Function
RegisterControlPlaneHandlerClient
RegisterControlPlaneHandlerClient registers the http handlers for service ControlPlane to "mux". The handlers forward requests to the grpc endpoint ov
pkg/rpc/controlplane/service.pb.gw.go:347
↓ 1 callers
Function
RegisterControlPlaneHandlerFromEndpoint
RegisterControlPlaneHandlerFromEndpoint is same as RegisterControlPlaneHandler but automatically dials to "endpoint" and closes the connection when "c
pkg/rpc/controlplane/service.pb.gw.go:313
↓ 1 callers
Function
Runtime
Runtime returns the exec package agent.Runtime
pkg/runtimes/exec/exec.go:20
↓ 1 callers
Function
Runtime
Runtime returns the debub packages runtime
pkg/runtimes/debug/debug.go:24
↓ 1 callers
Method
SetToDefault
SetToDefault applies the default values to the argument
pkg/runtimes/runtime.go:370
↓ 1 callers
Function
Spew
Spew is a formatter which uses gospew to format the run
pkg/printing/print.go:102
↓ 1 callers
Method
StronglyConnectedComponents
StronglyConnectedComponents returns the set of strongly connected components within the graph
pkg/graph/graph.go:140
↓ 1 callers
Method
TopologicalSort
TopologicalSort returns the set of nodes within the graph topologically sorted
pkg/graph/graph.go:157
↓ 1 callers
Method
UnsubscribeAll
(context.Context, *adagio.Agent, chan<- *adagio.Event)
pkg/agent/agent.go:29
↓ 1 callers
Method
WalkFrom
WalkFrom traverses the outgoing nodes to the leaves of the graph from the provided node
pkg/graph/graph.go:173
↓ 1 callers
Function
WithNamespace
WithNamespace configures the etcd client to use a particular top-level prefix
pkg/etcd/options.go:26
↓ 1 callers
Function
WithRetry
WithRetry configures a retry for a specified condition up to maxAttempts times on a Node_Spec
pkg/workflow/workflow.go:40
↓ 1 callers
Method
addTo
(runtime string, spec *adagio.Node_Spec)
pkg/runtimes/runtime.go:312
↓ 1 callers
Function
allNodesKey
(run *adagio.Run)
pkg/etcd/etcd.go:957
↓ 1 callers
Function
attemptNClaims
(ctx context.Context, t *testing.T, repo Repository, run *adagio.Run, name string, n int)
pkg/repository/repository.go:967
↓ 1 callers
Function
buildNodes
(specs []*Node_Spec)
pkg/adagio/run.go:58
↓ 1 callers
Function
canNotClaim
(ctx context.Context, t *testing.T, repo Repository, run *adagio.Run, names ...string)
pkg/repository/repository.go:894
↓ 1 callers
Function
conclusionToString
(conclusion adagio.Node_Result_Conclusion)
pkg/printing/print.go:138
↓ 1 callers
Method
handleEvent
(ctx context.Context, claimer Claimer, event *adagio.Event)
pkg/agent/agent.go:172
↓ 1 callers
Method
handleFailure
(ctx context.Context, run *adagio.Run, node *adagio.Node, result *adagio.Node_Result)
pkg/etcd/etcd.go:592
↓ 1 callers
Method
handleFailure
(state runState, node *adagio.Node, src map[graph.Node]struct{}, result *adagio.Node_Result)
pkg/memory/repository.go:354
↓ 1 callers
Method
handleSuccess
(ctx context.Context, run *adagio.Run, node *adagio.Node, result *adagio.Node_Result)
pkg/etcd/etcd.go:530
↓ 1 callers
Method
handleSuccess
(state runState, node *adagio.Node, outgoing map[graph.Node]struct{}, result *adagio.Node_Result)
pkg/memory/repository.go:316
↓ 1 callers
Function
inspect
(ctxt context.Context, client controlplane.ControlPlaneClient, args ...string)
cmd/adagio/runs.go:105
↓ 1 callers
Function
list
(ctxt context.Context, client controlplane.ControlPlaneClient)
cmd/adagio/runs.go:206
↓ 1 callers
Function
local_request_ControlPlane_Inspect_0
(ctx context.Context, marshaler runtime.Marshaler, server ControlPlaneServer, req *http.Request, pathParams ma
pkg/rpc/controlplane/service.pb.gw.go:143
↓ 1 callers
Function
local_request_ControlPlane_ListAgents_0
(ctx context.Context, marshaler runtime.Marshaler, server ControlPlaneServer, req *http.Request, pathParams ma
pkg/rpc/controlplane/service.pb.gw.go:190
↓ 1 callers
Function
local_request_ControlPlane_ListRuns_0
(ctx context.Context, marshaler runtime.Marshaler, server ControlPlaneServer, req *http.Request, pathParams ma
pkg/rpc/controlplane/service.pb.gw.go:103
↓ 1 callers
Function
local_request_ControlPlane_Start_0
(ctx context.Context, marshaler runtime.Marshaler, server ControlPlaneServer, req *http.Request, pathParams ma
pkg/rpc/controlplane/service.pb.gw.go:66
↓ 1 callers
Function
local_request_ControlPlane_Stats_0
(ctx context.Context, marshaler runtime.Marshaler, server ControlPlaneServer, req *http.Request, pathParams ma
pkg/rpc/controlplane/service.pb.gw.go:40
↓ 1 callers
Function
marshalRun
(createdAt string, spec []*adagio.Node_Spec, edges []*adagio.Edge)
pkg/etcd/etcd.go:997
↓ 1 callers
Function
node
(state runState, name string)
pkg/memory/repository.go:443
↓ 1 callers
Method
nodesForRun
(ctx context.Context, run *adagio.Run, ops ...clientv3.OpOption)
pkg/etcd/etcd.go:840
↓ 1 callers
Method
parseNode
Parse sets the values of the argument using the provided slice of strings
pkg/runtimes/runtime.go:334
↓ 1 callers
Function
request_ControlPlane_Inspect_0
(ctx context.Context, marshaler runtime.Marshaler, client ControlPlaneClient, req *http.Request, pathParams ma
pkg/rpc/controlplane/service.pb.gw.go:116
↓ 1 callers
Function
request_ControlPlane_ListAgents_0
(ctx context.Context, marshaler runtime.Marshaler, client ControlPlaneClient, req *http.Request, pathParams ma
pkg/rpc/controlplane/service.pb.gw.go:174
↓ 1 callers
Function
request_ControlPlane_ListRuns_0
(ctx context.Context, marshaler runtime.Marshaler, client ControlPlaneClient, req *http.Request, pathParams ma
pkg/rpc/controlplane/service.pb.gw.go:87
↓ 1 callers
Function
request_ControlPlane_Start_0
(ctx context.Context, marshaler runtime.Marshaler, client ControlPlaneClient, req *http.Request, pathParams ma
pkg/rpc/controlplane/service.pb.gw.go:49
↓ 1 callers
Function
request_ControlPlane_Stats_0
(ctx context.Context, marshaler runtime.Marshaler, client ControlPlaneClient, req *http.Request, pathParams ma
pkg/rpc/controlplane/service.pb.gw.go:31
↓ 1 callers
Function
reverse
(nodes []Node)
pkg/graph/graph.go:224
↓ 1 callers
Function
run
()
cmd/adagiogw/main.go:18
↓ 1 callers
Function
runs
(ctxt context.Context, client controlplane.ControlPlaneClient, args []string)
cmd/adagio/runs.go:20
↓ 1 callers
Function
setInitialNodeStates
(graph *graph.Graph, nodes []*Node)
pkg/adagio/run.go:76
↓ 1 callers
Method
setInputs
(run *adagio.Run, node *adagio.Node)
pkg/etcd/etcd.go:900
↓ 1 callers
Function
start
(ctxt context.Context, client controlplane.ControlPlaneClient, args ...string)
cmd/adagio/runs.go:55
↓ 1 callers
Function
startAPI
(ctxt context.Context, repo controlservice.Repository)
cmd/adagiod/main.go:124
↓ 1 callers
Function
startAgents
(ctxt context.Context, repo agent.Repository)
cmd/adagiod/main.go:151
↓ 1 callers
Function
stats
(ctxt context.Context, client controlplane.ControlPlaneClient, args []string)
cmd/adagio/main.go:52
↓ 1 callers
Function
statusToString
(state adagio.Node_Status)
pkg/printing/print.go:121
↓ 1 callers
Function
stringToStatus
(status string)
pkg/etcd/etcd.go:1013
↓ 1 callers
Function
unmarshalRun
(data []byte, dst *adagio.Run)
pkg/etcd/etcd.go:979
↓ 1 callers
Function
validateGraph
(graph *graph.Graph)
pkg/adagio/run.go:68
↓ 1 callers
Function
walkFrom
(set edgeSet, node Node, fn VisitFunc)
pkg/graph/graph.go:192
Function
Chance
Chance configures a new ChanceCondition
pkg/runtimes/debug/debug.go:110
Method
ClaimNode
ClaimNode attempts to claim a node identified by name for a specified run ID and providing a unique claim Given the node is found and the claim is suc
pkg/etcd/etcd.go:271
Method
ClaimNode
ClaimNode attempts to make a claim for a node
pkg/memory/repository.go:237
Method
ClaimNode
(_ context.Context, runID string, name string, claim *adagio.Claim)
pkg/agent/support_test.go:70
Method
Descriptor
()
pkg/adagio/adagio.pb.go:183
Method
Descriptor
()
pkg/adagio/adagio.pb.go:252
Method
Descriptor
()
pkg/adagio/adagio.pb.go:306
Method
Descriptor
()
pkg/adagio/adagio.pb.go:352
Method
Descriptor
()
pkg/adagio/adagio.pb.go:397
Method
Descriptor
()
pkg/adagio/adagio.pb.go:481
Method
Descriptor
()
pkg/adagio/adagio.pb.go:541
Method
Descriptor
()
pkg/adagio/adagio.pb.go:582
Method
Descriptor
()
pkg/adagio/adagio.pb.go:636
Method
Descriptor
()
pkg/adagio/adagio.pb.go:684
Method
Descriptor
()
pkg/adagio/adagio.pb.go:737
Method
Descriptor
()
pkg/adagio/adagio.pb.go:777
Method
Descriptor
()
pkg/adagio/adagio.pb.go:824
Method
Descriptor
()
pkg/adagio/adagio.pb.go:871
Method
Descriptor
()
pkg/adagio/adagio.pb.go:920
Method
Descriptor
()
pkg/rpc/controlplane/service.pb.go:38
Method
Descriptor
()
pkg/rpc/controlplane/service.pb.go:70
Method
Descriptor
()
pkg/rpc/controlplane/service.pb.go:109
Method
Descriptor
()
pkg/rpc/controlplane/service.pb.go:148
Method
Descriptor
()
pkg/rpc/controlplane/service.pb.go:187
Method
Descriptor
()
pkg/rpc/controlplane/service.pb.go:226
Method
Descriptor
()
pkg/rpc/controlplane/service.pb.go:267
Method
Descriptor
()
pkg/rpc/controlplane/service.pb.go:320
Method
Descriptor
()
pkg/rpc/controlplane/service.pb.go:359
Function
Diff
Diff returns a string slice of differences between graphs a and b
pkg/graph/diff.go:11
Method
EnumDescriptor
()
pkg/adagio/adagio.pb.go:47
Method
EnumDescriptor
()
pkg/adagio/adagio.pb.go:72
Method
EnumDescriptor
()
pkg/adagio/adagio.pb.go:106
← previous
next →
101–200 of 551, ranked by callers