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
Method
EnumDescriptor
()
pkg/adagio/adagio.pb.go:137
Method
EnumDescriptor
()
pkg/adagio/adagio.pb.go:165
Method
FinishNode
FinishNode records a result for a node identified by name for a specified run ID and given a unique and active claim
pkg/etcd/etcd.go:470
Method
FinishNode
FinishNode reports the result of a node run and readies any eligible outgoing nodes
pkg/memory/repository.go:284
Method
FinishNode
(_ context.Context, runID string, name string, result *adagio.Node_Result, claim *adagio.Claim)
pkg/agent/support_test.go:92
Function
ForList
ForList constructs a repository client for a specific list (other than the default one)
pkg/etcd/options.go:18
Function
Function
Function converts the provided ParseRunner into a agent.Function using the FunctionAdaptor wrapper type
pkg/runtimes/runtime.go:76
Method
GetAgents
()
pkg/rpc/controlplane/service.pb.go:381
Method
GetAttempts
()
pkg/adagio/adagio.pb.go:433
Method
GetClaim
()
pkg/adagio/adagio.pb.go:461
Method
GetCompletedCount
()
pkg/adagio/adagio.pb.go:963
Method
GetConclusion
()
pkg/adagio/adagio.pb.go:604
Method
GetConclusion
()
pkg/adagio/adagio.pb.go:706
Method
GetCreatedAt
()
pkg/adagio/adagio.pb.go:212
Method
GetDestination
()
pkg/adagio/adagio.pb.go:665
Method
GetEdges
()
pkg/adagio/adagio.pb.go:226
Method
GetEdges
()
pkg/adagio/adagio.pb.go:335
Method
GetFinishNs
()
pkg/rpc/controlplane/service.pb.go:296
Method
GetFinishedAt
()
pkg/adagio/adagio.pb.go:447
Method
GetId
()
pkg/adagio/adagio.pb.go:205
Method
GetId
()
pkg/adagio/adagio.pb.go:799
Method
GetId
()
pkg/adagio/adagio.pb.go:846
Method
GetId
()
pkg/rpc/controlplane/service.pb.go:209
Method
GetInputs
()
pkg/adagio/adagio.pb.go:454
Method
GetLimit
()
pkg/rpc/controlplane/service.pb.go:303
Method
GetMaxAttempts
()
pkg/adagio/adagio.pb.go:563
Method
GetMetadata
()
pkg/adagio/adagio.pb.go:517
Method
GetMetadata
()
pkg/adagio/adagio.pb.go:611
Method
GetMetadata
()
pkg/adagio/adagio.pb.go:713
Method
GetMetadata
()
pkg/adagio/adagio.pb.go:853
Method
GetName
()
pkg/adagio/adagio.pb.go:503
Method
GetName
()
pkg/adagio/adagio.pb.go:759
Method
GetNodeCounts
()
pkg/adagio/adagio.pb.go:900
Method
GetNodeSpec
()
pkg/adagio/adagio.pb.go:288
Method
GetNodes
()
pkg/adagio/adagio.pb.go:219
Method
GetNodes
()
pkg/adagio/adagio.pb.go:328
Method
GetOutput
()
pkg/adagio/adagio.pb.go:618
Method
GetOutput
()
pkg/adagio/adagio.pb.go:720
Method
GetReadyCount
()
pkg/adagio/adagio.pb.go:949
Method
GetRetry
()
pkg/adagio/adagio.pb.go:524
Method
GetRun
()
pkg/rpc/controlplane/service.pb.go:170
Method
GetRun
()
pkg/rpc/controlplane/service.pb.go:248
Method
GetRunCount
()
pkg/adagio/adagio.pb.go:893
Method
GetRunID
()
pkg/adagio/adagio.pb.go:281
Method
GetRunningCount
()
pkg/adagio/adagio.pb.go:956
Method
GetRuns
()
pkg/rpc/controlplane/service.pb.go:342
Method
GetRuntime
()
pkg/adagio/adagio.pb.go:510
Method
GetRuntimes
()
pkg/adagio/adagio.pb.go:806
Method
GetSource
()
pkg/adagio/adagio.pb.go:658
Method
GetSpec
()
pkg/adagio/adagio.pb.go:419
Method
GetSpec
()
pkg/rpc/controlplane/service.pb.go:131
Method
GetStartNs
()
pkg/rpc/controlplane/service.pb.go:289
Method
GetStartedAt
()
pkg/adagio/adagio.pb.go:440
Method
GetStats
()
pkg/rpc/controlplane/service.pb.go:92
Method
GetStatus
()
pkg/adagio/adagio.pb.go:233
Method
GetStatus
()
pkg/adagio/adagio.pb.go:426
Method
GetType
()
pkg/adagio/adagio.pb.go:274
Method
GetValues
()
pkg/adagio/adagio.pb.go:374
Method
GetWaitingCount
()
pkg/adagio/adagio.pb.go:942
Method
Inspect
Inspect adapts a control plane inspect request into a repository InspectRun call and returns the result
pkg/service/controlplane/server.go:69
Method
Inspect
(ctx context.Context, in *InspectRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:492
Method
Inspect
(context.Context, *InspectRequest)
pkg/rpc/controlplane/service.pb.go:515
Method
Inspect
(ctx context.Context, req *InspectRequest)
pkg/rpc/controlplane/service.pb.go:532
Method
InspectRun
InspectRun takes an ID and returns the associated Run if found within etcd
pkg/etcd/etcd.go:181
Method
InspectRun
InspectRun returns a run for the provided run ID
pkg/memory/repository.go:120
Method
ListAgents
ListAgents returns at agents recorded within etcd at the time of the call
pkg/etcd/etcd.go:186
Method
ListAgents
ListAgents returns a set of subscribed agents
pkg/memory/repository.go:154
Method
ListAgents
ListAgents adapts a control plane ListRequest into a repository ListAgents call and returns the result
pkg/service/controlplane/server.go:103
Method
ListAgents
(ctx context.Context, in *ListRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:501
Method
ListAgents
(context.Context, *ListRequest)
pkg/rpc/controlplane/service.pb.go:516
Method
ListAgents
(ctx context.Context, req *ListRequest)
pkg/rpc/controlplane/service.pb.go:535
Method
ListRuns
ListRuns returns a list of runs given a set of predicates Given no start time is provided now is assumed Given no finish time is provided epoch is ass
pkg/etcd/etcd.go:208
Method
ListRuns
ListRuns returns a list of runs in descending order based on a set of provided predicates
pkg/memory/repository.go:170
Method
ListRuns
ListRuns adapts a control plane list request into a ListRuns call and returns the result
pkg/service/controlplane/server.go:79
Method
ListRuns
(ctx context.Context, in *ListRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:483
Method
ListRuns
(context.Context, *ListRequest)
pkg/rpc/controlplane/service.pb.go:514
Method
ListRuns
(ctx context.Context, req *ListRequest)
pkg/rpc/controlplane/service.pb.go:529
Method
Name
Name returns the name of the runtime being built
pkg/runtimes/runtime.go:93
Method
Name
()
pkg/agent/support_test.go:15
Method
Name
Name returns the runtimes name
pkg/agent/agent.go:61
Function
New
New constructs and configures a new Service instance
pkg/service/controlplane/server.go:40
Method
NewClaim
NewClaim delegates to underlying ClaimerFunc
pkg/agent/agent.go:80
Function
NewFunction
NewFunction configures a new exec.Function pointer
pkg/runtimes/exec/exec.go:45
Function
NewFunction
NewFunction constructure and configures a new Function pointer The function will result in the provided conclusion unless one of zero or more chance c
pkg/runtimes/debug/debug.go:48
Method
NewFunction
()
pkg/agent/support_test.go:17
Method
NewFunction
NewFunction delegates to the anonymous function
pkg/agent/agent.go:64
Method
NewSpec
NewSpec constructs a Node_Spec based on the current state of the builders arguments
pkg/runtimes/runtime.go:112
Method
NewSpec
(name string)
pkg/workflow/support_test.go:20
Method
Orphan
Orphan delegates to the underlying OrphanFunc
pkg/repository/repository.go:86
Method
Parse
Parse parses the state from a node into the targets set on the builders arguments
pkg/runtimes/runtime.go:130
Method
ProtoMessage
()
pkg/adagio/adagio.pb.go:182
Method
ProtoMessage
()
pkg/adagio/adagio.pb.go:251
Method
ProtoMessage
()
pkg/adagio/adagio.pb.go:305
Method
ProtoMessage
()
pkg/adagio/adagio.pb.go:351
Method
ProtoMessage
()
pkg/adagio/adagio.pb.go:396
Method
ProtoMessage
()
pkg/adagio/adagio.pb.go:480
Method
ProtoMessage
()
pkg/adagio/adagio.pb.go:540
Method
ProtoMessage
()
pkg/adagio/adagio.pb.go:581
Method
ProtoMessage
()
pkg/adagio/adagio.pb.go:635
Method
ProtoMessage
()
pkg/adagio/adagio.pb.go:683
← previous
next →
201–300 of 551, ranked by callers