MCPcopy Create free account

hub / github.com/GeorgeMac/adagio / functions

Functions551 in github.com/GeorgeMac/adagio

↓ 29 callersMethodRun
(ctx context.Context)
pkg/runtimes/runtime.go:55
↓ 23 callersFunctioncompleted
(spec *adagio.Node_Spec, inputs map[string][]byte, attempts ...*adagio.Node_Result)
pkg/repository/repository.go:1024
↓ 23 callersFunctionrunning
(spec *adagio.Node_Spec, inputs map[string][]byte, attempts ...*adagio.Node_Result)
pkg/repository/repository.go:1017
↓ 20 callersMethodParse
(n *adagio.Node)
pkg/runtimes/runtime.go:54
↓ 17 callersFunctionsuccess
(output string)
pkg/repository/repository.go:1037
↓ 16 callersMethodConnect
Connect constructs and edge from one node to another
pkg/graph/graph.go:116
↓ 15 callersMethodString
()
pkg/adagio/adagio.pb.go:181
↓ 14 callersMethodFormat
Format delegates to the underlying FormatterFunc
pkg/printing/dot.go:20
↓ 11 callersMethodListRuns
(ctx context.Context, in *ListRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:452
↓ 9 callersMethodRun
(context.Context, *adagio.Node)
pkg/agent/agent.go:68
↓ 9 callersMethodString
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 callersMethodStrings
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 callersFunctionexitIfError
(err error)
cmd/adagio/main.go:83
↓ 7 callersMethodStart
(ctx context.Context, in *StartRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:451
↓ 7 callersMethodcancelLease
(claimID string)
pkg/etcd/etcd.go:459
↓ 7 callersMethodpresent
(n Node)
pkg/graph/graph.go:246
↓ 7 callersFunctionstatusToString
(status adagio.Node_Status)
pkg/etcd/etcd.go:1009
↓ 7 callersFunctionwrapMissingErr
(n Node)
pkg/graph/graph.go:302
↓ 6 callersMethodIncoming
Incoming returns a set of nodes which are directed from the provided node
pkg/graph/graph.go:107
↓ 6 callersMethodInt64
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 callersMethodStartRun
(context.Context, *adagio.GraphSpec)
pkg/service/controlplane/server.go:19
↓ 6 callersFunctionexit
(v interface{}, code int)
cmd/adagio/main.go:91
↓ 6 callersFunctionnodeInStateKey
(runID, state, name string)
pkg/etcd/etcd.go:969
↓ 5 callersFunctionGraphFrom
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 callersMethodInspect
(ctx context.Context, in *InspectRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:453
↓ 5 callersMethodListAgents
(ctx context.Context, in *ListRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:454
↓ 5 callersFunctionNewBuilder
NewBuilder constructs and configures a new runtime builder
pkg/runtimes/runtime.go:88
↓ 5 callersFunctionNewPool
NewPool constructs and configures a new node pool for execution
pkg/agent/agent.go:95
↓ 5 callersMethodOutgoing
Outgoing returns a set of nodes which are directed to from the provided node
pkg/graph/graph.go:97
↓ 5 callersMethodStats
(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:450
↓ 5 callersFunctionWithAgentCount
WithAgentCount configures the number of agents to be run
pkg/agent/options.go:17
↓ 5 callersMethodclone
()
pkg/graph/graph.go:41
↓ 5 callersMethodgetRun
(ctx context.Context, id string, ops ...clientv3.OpOption)
pkg/etcd/etcd.go:796
↓ 5 callersFunctionnewArgument
(name string, argumentType ArgumentType, required bool, defaultValues []string)
pkg/runtimes/runtime.go:374
↓ 5 callersFunctionstripClaims
(nodes []*adagio.Node)
pkg/repository/repository.go:1070
↓ 4 callersMethodExec
Exec executes the test layer against the provided testing T given a context
pkg/repository/repository.go:831
↓ 4 callersFunctionNew
New constructs a new graph from a set of Nodes
pkg/graph/graph.go:30
↓ 4 callersMethodNode
Node creates a node from a provided name and SpecBuilder type it also applies any provided options
pkg/workflow/workflow.go:67
↓ 4 callersMethodTime
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 callersFunctionWithClaimerFunc
WithClaimerFunc overrides the claimer which generates a unique claim per node claim attempt
pkg/agent/options.go:25
↓ 4 callersFunctionfail
(output string)
pkg/repository/repository.go:1041
↓ 4 callersFunctionnewRepository
(subscriptionCount int, nodes ...*adagio.Node)
pkg/agent/support_test.go:40
↓ 4 callersFunctionnode
(spec *adagio.Node_Spec, status adagio.Node_Status, inputs map[string][]byte)
pkg/repository/repository.go:1033
↓ 4 callersFunctionresult
(output string, conclusion adagio.Node_Result_Conclusion)
pkg/repository/repository.go:1051
↓ 4 callersMethodstatusDoesNotExist
(runID string, node *adagio.Node, status adagio.Node_Status)
pkg/etcd/etcd.go:411
↓ 4 callersMethodtransition
(runID string, node *adagio.Node, toStatus adagio.Node_Status, cmps []clientv3.Cmp, ops []clientv3.Op, putOpts
pkg/etcd/etcd.go:345
↓ 3 callersMethodAddNodes
AddNodes adds the provided nodes to the graph
pkg/graph/graph.go:59
↓ 3 callersMethodClaimNode
(ctx context.Context, runID, name string, claim *adagio.Claim)
pkg/agent/agent.go:26
↓ 3 callersMethodCycles
Cycles detects and returns any cycles found within the graph
pkg/graph/graph.go:128
↓ 3 callersMethodDependsOn
DependsOn creates a connection from the provided nodes (sources) to the callee node (destination) on the original builder
pkg/workflow/workflow.go:143
↓ 3 callersMethodGetNodeByName
GetNodeByName fetches a Node from the Run by name
pkg/adagio/run.go:48
↓ 3 callersMethodJSON
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 callersFunctionNewControlPlaneClient
(cc *grpc.ClientConn)
pkg/rpc/controlplane/service.pb.go:461
↓ 3 callersFunctionPBRunToRun
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 callersMethodSubscribe
(ctx context.Context, agent *adagio.Agent, events chan<- *adagio.Event, types ...adagio.Event_Type)
pkg/agent/agent.go:28
↓ 3 callersFunctionVisitLatestAttempt
VisitLatestAttempt calls the supplied function with the latest attempt result if any attempts have been made
pkg/adagio/node.go:41
↓ 3 callersFunctioncanClaim
(ctx context.Context, t *testing.T, repo Repository, run *adagio.Run, nodes map[string]*adagio.Node)
pkg/repository/repository.go:913
↓ 3 callersFunctionclaims
(count int, runID, name string, claim *adagio.Claim)
pkg/agent/support_test.go:61
↓ 3 callersMethodcomplete
(runID string, node *adagio.Node, cmps []clientv3.Cmp, ops []clientv3.Op)
pkg/etcd/etcd.go:332
↓ 3 callersFunctionerrorResult
(output string)
pkg/repository/repository.go:1047
↓ 3 callersMethodnotifyReady
(run *adagio.Run, node *adagio.Node)
pkg/memory/repository.go:273
↓ 3 callersMethodremove
(n Node)
pkg/graph/graph.go:275
↓ 3 callersMethodstate
(runID string)
pkg/memory/repository.go:434
↓ 2 callersFunctionCanRetry
CanRetry returns true if the node can be retried
pkg/adagio/node.go:18
↓ 2 callersMethodFinishNode
(ctx context.Context, runID, name string, result *adagio.Node_Result, claim *adagio.Claim)
pkg/agent/agent.go:27
↓ 2 callersMethodInspectRun
(ctx context.Context, id string)
pkg/service/controlplane/server.go:20
↓ 2 callersMethodListRuns
(context.Context, ListRequest)
pkg/service/controlplane/server.go:21
↓ 2 callersFunctionNew
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 callersFunctionNew
New constructs and configures a new in memory repository
pkg/memory/repository.go:50
↓ 2 callersFunctionNewRun
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 callersMethodNewSpec
(name string)
pkg/workflow/workflow.go:15
↓ 2 callersMethodRegister
Register adds the runtime to the RuntimeMap
pkg/agent/agent.go:36
↓ 2 callersFunctionRuntimeFunc
RuntimeFunc converts a name and an anonymous call generating function into a Runtime
pkg/agent/agent.go:49
↓ 2 callersMethodSetArgumentFromInput
(argument, input string)
pkg/workflow/workflow.go:22
↓ 2 callersMethodStats
(context.Context)
pkg/service/controlplane/server.go:18
↓ 2 callersMethodString
()
pkg/rpc/controlplane/service.pb.go:265
↓ 2 callersFunctionTestHarness
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 callersMethodaddNode
(n Node)
pkg/graph/graph.go:265
↓ 2 callersFunctionagentKey
(agent *adagio.Agent)
pkg/etcd/etcd.go:949
↓ 2 callersFunctionblankFunction
()
pkg/runtimes/exec/exec.go:26
↓ 2 callersFunctionblankFunction
()
pkg/runtimes/debug/debug.go:30
↓ 2 callersFunctioncanFinish
(ctx context.Context, t *testing.T, repo Repository, run *adagio.Run, names map[string]adagio.Node_Result_Conc
pkg/repository/repository.go:945
↓ 2 callersMethodconnect
(from, to Node)
pkg/graph/graph.go:251
↓ 2 callersMethodcontains
(typ adagio.Event_Type)
pkg/etcd/etcd.go:1019
↓ 2 callersFunctiondfs
(all edgeSet, from Node, dest []Node)
pkg/graph/graph.go:233
↓ 2 callersMethoddfsForward
()
pkg/graph/graph.go:211
↓ 2 callersMethodhandleKeyEvent
(ctx context.Context, dest chan<- *adagio.Event, ev keyEvent, filter filter, opts ...clientv3.OpOption)
pkg/etcd/etcd.go:744
↓ 2 callersMethodinitializeIfEmpty
()
pkg/graph/graph.go:48
↓ 2 callersFunctioninputArgument
(runtime string, argument *Argument)
pkg/runtimes/runtime.go:308
↓ 2 callersMethodlease
(claimID string)
pkg/etcd/etcd.go:416
↓ 2 callersFunctionmetadataArgument
(runtime string, argument *Argument)
pkg/runtimes/runtime.go:304
↓ 2 callersMethodmissing
()
pkg/runtimes/runtime.go:361
↓ 2 callersFunctionnewClaim
()
pkg/repository/repository.go:1063
↓ 2 callersMethodnodeIsOrphaned
(runID string, node *adagio.Node)
pkg/etcd/etcd.go:401
↓ 2 callersFunctionnodeKey
(runID, name string)
pkg/etcd/etcd.go:961
↓ 2 callersFunctionnodesInStateKey
(status adagio.Node_Status)
pkg/etcd/etcd.go:965
↓ 2 callersFunctionrunKey
(run *adagio.Run)
pkg/etcd/etcd.go:953
↓ 1 callersMethodApply
Apply functions each option in order on the provided Function
pkg/runtimes/debug/debug.go:73
↓ 1 callersMethodApply
Apply calls each option on r in turn
pkg/etcd/options.go:10
↓ 1 callersMethodApply
Apply calls each option in turn on the provided Pool
pkg/agent/options.go:10
next →1–100 of 551, ranked by callers