MCPcopy Create free account

hub / github.com/GeorgeMac/adagio / functions

Functions551 in github.com/GeorgeMac/adagio

↓ 1 callersMethodApply
Apply calls each option in turn on the provided Node_Spec
pkg/workflow/workflow.go:32
↓ 1 callersMethodBuild
Build constructs a graph specification from the builders state
pkg/workflow/workflow.go:76
↓ 1 callersFunctionDot
Dot takes an adagio Run proto struct and returns a formatter
pkg/printing/dot.go:25
↓ 1 callersMethodIsLeaf
IsLeaf returns true if the node has no outgoing edges within the graph
pkg/graph/graph.go:87
↓ 1 callersMethodIsRoot
IsRoot returns true if the node has no incoming edges within the graph
pkg/graph/graph.go:77
↓ 1 callersMethodListAgents
(context.Context)
pkg/service/controlplane/server.go:22
↓ 1 callersFunctionMapOutputTo
MapOutputTo maps the output of the dependency onto the argument name of the callee
pkg/workflow/workflow.go:130
↓ 1 callersFunctionMappable
(fn FunctionFunc)
pkg/workflow/support_test.go:29
↓ 1 callersMethodName
()
pkg/agent/agent.go:43
↓ 1 callersFunctionNewBuilder
NewBuilder creates and configures a new Builder
pkg/workflow/workflow.go:61
↓ 1 callersMethodNewClaim
()
pkg/agent/agent.go:73
↓ 1 callersMethodNewFunction
()
pkg/agent/agent.go:44
↓ 1 callersMethodOrphan
(claim *adagio.Claim)
pkg/repository/repository.go:79
↓ 1 callersFunctionPretty
Pretty is a formatter which used pretty to format the run
pkg/printing/print.go:112
↓ 1 callersFunctionRegisterControlPlaneHandler
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 callersFunctionRegisterControlPlaneHandlerClient
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 callersFunctionRegisterControlPlaneHandlerFromEndpoint
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 callersFunctionRuntime
Runtime returns the exec package agent.Runtime
pkg/runtimes/exec/exec.go:20
↓ 1 callersFunctionRuntime
Runtime returns the debub packages runtime
pkg/runtimes/debug/debug.go:24
↓ 1 callersMethodSetToDefault
SetToDefault applies the default values to the argument
pkg/runtimes/runtime.go:370
↓ 1 callersFunctionSpew
Spew is a formatter which uses gospew to format the run
pkg/printing/print.go:102
↓ 1 callersMethodStronglyConnectedComponents
StronglyConnectedComponents returns the set of strongly connected components within the graph
pkg/graph/graph.go:140
↓ 1 callersMethodTopologicalSort
TopologicalSort returns the set of nodes within the graph topologically sorted
pkg/graph/graph.go:157
↓ 1 callersMethodUnsubscribeAll
(context.Context, *adagio.Agent, chan<- *adagio.Event)
pkg/agent/agent.go:29
↓ 1 callersMethodWalkFrom
WalkFrom traverses the outgoing nodes to the leaves of the graph from the provided node
pkg/graph/graph.go:173
↓ 1 callersFunctionWithNamespace
WithNamespace configures the etcd client to use a particular top-level prefix
pkg/etcd/options.go:26
↓ 1 callersFunctionWithRetry
WithRetry configures a retry for a specified condition up to maxAttempts times on a Node_Spec
pkg/workflow/workflow.go:40
↓ 1 callersMethodaddTo
(runtime string, spec *adagio.Node_Spec)
pkg/runtimes/runtime.go:312
↓ 1 callersFunctionallNodesKey
(run *adagio.Run)
pkg/etcd/etcd.go:957
↓ 1 callersFunctionattemptNClaims
(ctx context.Context, t *testing.T, repo Repository, run *adagio.Run, name string, n int)
pkg/repository/repository.go:967
↓ 1 callersFunctionbuildNodes
(specs []*Node_Spec)
pkg/adagio/run.go:58
↓ 1 callersFunctioncanNotClaim
(ctx context.Context, t *testing.T, repo Repository, run *adagio.Run, names ...string)
pkg/repository/repository.go:894
↓ 1 callersFunctionconclusionToString
(conclusion adagio.Node_Result_Conclusion)
pkg/printing/print.go:138
↓ 1 callersMethodhandleEvent
(ctx context.Context, claimer Claimer, event *adagio.Event)
pkg/agent/agent.go:172
↓ 1 callersMethodhandleFailure
(ctx context.Context, run *adagio.Run, node *adagio.Node, result *adagio.Node_Result)
pkg/etcd/etcd.go:592
↓ 1 callersMethodhandleFailure
(state runState, node *adagio.Node, src map[graph.Node]struct{}, result *adagio.Node_Result)
pkg/memory/repository.go:354
↓ 1 callersMethodhandleSuccess
(ctx context.Context, run *adagio.Run, node *adagio.Node, result *adagio.Node_Result)
pkg/etcd/etcd.go:530
↓ 1 callersMethodhandleSuccess
(state runState, node *adagio.Node, outgoing map[graph.Node]struct{}, result *adagio.Node_Result)
pkg/memory/repository.go:316
↓ 1 callersFunctioninspect
(ctxt context.Context, client controlplane.ControlPlaneClient, args ...string)
cmd/adagio/runs.go:105
↓ 1 callersFunctionlist
(ctxt context.Context, client controlplane.ControlPlaneClient)
cmd/adagio/runs.go:206
↓ 1 callersFunctionlocal_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 callersFunctionlocal_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 callersFunctionlocal_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 callersFunctionlocal_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 callersFunctionlocal_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 callersFunctionmarshalRun
(createdAt string, spec []*adagio.Node_Spec, edges []*adagio.Edge)
pkg/etcd/etcd.go:997
↓ 1 callersFunctionnode
(state runState, name string)
pkg/memory/repository.go:443
↓ 1 callersMethodnodesForRun
(ctx context.Context, run *adagio.Run, ops ...clientv3.OpOption)
pkg/etcd/etcd.go:840
↓ 1 callersMethodparseNode
Parse sets the values of the argument using the provided slice of strings
pkg/runtimes/runtime.go:334
↓ 1 callersFunctionrequest_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 callersFunctionrequest_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 callersFunctionrequest_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 callersFunctionrequest_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 callersFunctionrequest_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 callersFunctionreverse
(nodes []Node)
pkg/graph/graph.go:224
↓ 1 callersFunctionrun
()
cmd/adagiogw/main.go:18
↓ 1 callersFunctionruns
(ctxt context.Context, client controlplane.ControlPlaneClient, args []string)
cmd/adagio/runs.go:20
↓ 1 callersFunctionsetInitialNodeStates
(graph *graph.Graph, nodes []*Node)
pkg/adagio/run.go:76
↓ 1 callersMethodsetInputs
(run *adagio.Run, node *adagio.Node)
pkg/etcd/etcd.go:900
↓ 1 callersFunctionstart
(ctxt context.Context, client controlplane.ControlPlaneClient, args ...string)
cmd/adagio/runs.go:55
↓ 1 callersFunctionstartAPI
(ctxt context.Context, repo controlservice.Repository)
cmd/adagiod/main.go:124
↓ 1 callersFunctionstartAgents
(ctxt context.Context, repo agent.Repository)
cmd/adagiod/main.go:151
↓ 1 callersFunctionstats
(ctxt context.Context, client controlplane.ControlPlaneClient, args []string)
cmd/adagio/main.go:52
↓ 1 callersFunctionstatusToString
(state adagio.Node_Status)
pkg/printing/print.go:121
↓ 1 callersFunctionstringToStatus
(status string)
pkg/etcd/etcd.go:1013
↓ 1 callersFunctionunmarshalRun
(data []byte, dst *adagio.Run)
pkg/etcd/etcd.go:979
↓ 1 callersFunctionvalidateGraph
(graph *graph.Graph)
pkg/adagio/run.go:68
↓ 1 callersFunctionwalkFrom
(set edgeSet, node Node, fn VisitFunc)
pkg/graph/graph.go:192
FunctionChance
Chance configures a new ChanceCondition
pkg/runtimes/debug/debug.go:110
MethodClaimNode
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
MethodClaimNode
ClaimNode attempts to make a claim for a node
pkg/memory/repository.go:237
MethodClaimNode
(_ context.Context, runID string, name string, claim *adagio.Claim)
pkg/agent/support_test.go:70
MethodDescriptor
()
pkg/adagio/adagio.pb.go:183
MethodDescriptor
()
pkg/adagio/adagio.pb.go:252
MethodDescriptor
()
pkg/adagio/adagio.pb.go:306
MethodDescriptor
()
pkg/adagio/adagio.pb.go:352
MethodDescriptor
()
pkg/adagio/adagio.pb.go:397
MethodDescriptor
()
pkg/adagio/adagio.pb.go:481
MethodDescriptor
()
pkg/adagio/adagio.pb.go:541
MethodDescriptor
()
pkg/adagio/adagio.pb.go:582
MethodDescriptor
()
pkg/adagio/adagio.pb.go:636
MethodDescriptor
()
pkg/adagio/adagio.pb.go:684
MethodDescriptor
()
pkg/adagio/adagio.pb.go:737
MethodDescriptor
()
pkg/adagio/adagio.pb.go:777
MethodDescriptor
()
pkg/adagio/adagio.pb.go:824
MethodDescriptor
()
pkg/adagio/adagio.pb.go:871
MethodDescriptor
()
pkg/adagio/adagio.pb.go:920
MethodDescriptor
()
pkg/rpc/controlplane/service.pb.go:38
MethodDescriptor
()
pkg/rpc/controlplane/service.pb.go:70
MethodDescriptor
()
pkg/rpc/controlplane/service.pb.go:109
MethodDescriptor
()
pkg/rpc/controlplane/service.pb.go:148
MethodDescriptor
()
pkg/rpc/controlplane/service.pb.go:187
MethodDescriptor
()
pkg/rpc/controlplane/service.pb.go:226
MethodDescriptor
()
pkg/rpc/controlplane/service.pb.go:267
MethodDescriptor
()
pkg/rpc/controlplane/service.pb.go:320
MethodDescriptor
()
pkg/rpc/controlplane/service.pb.go:359
FunctionDiff
Diff returns a string slice of differences between graphs a and b
pkg/graph/diff.go:11
MethodEnumDescriptor
()
pkg/adagio/adagio.pb.go:47
MethodEnumDescriptor
()
pkg/adagio/adagio.pb.go:72
MethodEnumDescriptor
()
pkg/adagio/adagio.pb.go:106
← previousnext →101–200 of 551, ranked by callers