MCPcopy Create free account

hub / github.com/GeorgeMac/adagio / functions

Functions551 in github.com/GeorgeMac/adagio

MethodEnumDescriptor
()
pkg/adagio/adagio.pb.go:137
MethodEnumDescriptor
()
pkg/adagio/adagio.pb.go:165
MethodFinishNode
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
MethodFinishNode
FinishNode reports the result of a node run and readies any eligible outgoing nodes
pkg/memory/repository.go:284
MethodFinishNode
(_ context.Context, runID string, name string, result *adagio.Node_Result, claim *adagio.Claim)
pkg/agent/support_test.go:92
FunctionForList
ForList constructs a repository client for a specific list (other than the default one)
pkg/etcd/options.go:18
FunctionFunction
Function converts the provided ParseRunner into a agent.Function using the FunctionAdaptor wrapper type
pkg/runtimes/runtime.go:76
MethodGetAgents
()
pkg/rpc/controlplane/service.pb.go:381
MethodGetAttempts
()
pkg/adagio/adagio.pb.go:433
MethodGetClaim
()
pkg/adagio/adagio.pb.go:461
MethodGetCompletedCount
()
pkg/adagio/adagio.pb.go:963
MethodGetConclusion
()
pkg/adagio/adagio.pb.go:604
MethodGetConclusion
()
pkg/adagio/adagio.pb.go:706
MethodGetCreatedAt
()
pkg/adagio/adagio.pb.go:212
MethodGetDestination
()
pkg/adagio/adagio.pb.go:665
MethodGetEdges
()
pkg/adagio/adagio.pb.go:226
MethodGetEdges
()
pkg/adagio/adagio.pb.go:335
MethodGetFinishNs
()
pkg/rpc/controlplane/service.pb.go:296
MethodGetFinishedAt
()
pkg/adagio/adagio.pb.go:447
MethodGetId
()
pkg/adagio/adagio.pb.go:205
MethodGetId
()
pkg/adagio/adagio.pb.go:799
MethodGetId
()
pkg/adagio/adagio.pb.go:846
MethodGetId
()
pkg/rpc/controlplane/service.pb.go:209
MethodGetInputs
()
pkg/adagio/adagio.pb.go:454
MethodGetLimit
()
pkg/rpc/controlplane/service.pb.go:303
MethodGetMaxAttempts
()
pkg/adagio/adagio.pb.go:563
MethodGetMetadata
()
pkg/adagio/adagio.pb.go:517
MethodGetMetadata
()
pkg/adagio/adagio.pb.go:611
MethodGetMetadata
()
pkg/adagio/adagio.pb.go:713
MethodGetMetadata
()
pkg/adagio/adagio.pb.go:853
MethodGetName
()
pkg/adagio/adagio.pb.go:503
MethodGetName
()
pkg/adagio/adagio.pb.go:759
MethodGetNodeCounts
()
pkg/adagio/adagio.pb.go:900
MethodGetNodeSpec
()
pkg/adagio/adagio.pb.go:288
MethodGetNodes
()
pkg/adagio/adagio.pb.go:219
MethodGetNodes
()
pkg/adagio/adagio.pb.go:328
MethodGetOutput
()
pkg/adagio/adagio.pb.go:618
MethodGetOutput
()
pkg/adagio/adagio.pb.go:720
MethodGetReadyCount
()
pkg/adagio/adagio.pb.go:949
MethodGetRetry
()
pkg/adagio/adagio.pb.go:524
MethodGetRun
()
pkg/rpc/controlplane/service.pb.go:170
MethodGetRun
()
pkg/rpc/controlplane/service.pb.go:248
MethodGetRunCount
()
pkg/adagio/adagio.pb.go:893
MethodGetRunID
()
pkg/adagio/adagio.pb.go:281
MethodGetRunningCount
()
pkg/adagio/adagio.pb.go:956
MethodGetRuns
()
pkg/rpc/controlplane/service.pb.go:342
MethodGetRuntime
()
pkg/adagio/adagio.pb.go:510
MethodGetRuntimes
()
pkg/adagio/adagio.pb.go:806
MethodGetSource
()
pkg/adagio/adagio.pb.go:658
MethodGetSpec
()
pkg/adagio/adagio.pb.go:419
MethodGetSpec
()
pkg/rpc/controlplane/service.pb.go:131
MethodGetStartNs
()
pkg/rpc/controlplane/service.pb.go:289
MethodGetStartedAt
()
pkg/adagio/adagio.pb.go:440
MethodGetStats
()
pkg/rpc/controlplane/service.pb.go:92
MethodGetStatus
()
pkg/adagio/adagio.pb.go:233
MethodGetStatus
()
pkg/adagio/adagio.pb.go:426
MethodGetType
()
pkg/adagio/adagio.pb.go:274
MethodGetValues
()
pkg/adagio/adagio.pb.go:374
MethodGetWaitingCount
()
pkg/adagio/adagio.pb.go:942
MethodInspect
Inspect adapts a control plane inspect request into a repository InspectRun call and returns the result
pkg/service/controlplane/server.go:69
MethodInspect
(ctx context.Context, in *InspectRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:492
MethodInspect
(context.Context, *InspectRequest)
pkg/rpc/controlplane/service.pb.go:515
MethodInspect
(ctx context.Context, req *InspectRequest)
pkg/rpc/controlplane/service.pb.go:532
MethodInspectRun
InspectRun takes an ID and returns the associated Run if found within etcd
pkg/etcd/etcd.go:181
MethodInspectRun
InspectRun returns a run for the provided run ID
pkg/memory/repository.go:120
MethodListAgents
ListAgents returns at agents recorded within etcd at the time of the call
pkg/etcd/etcd.go:186
MethodListAgents
ListAgents returns a set of subscribed agents
pkg/memory/repository.go:154
MethodListAgents
ListAgents adapts a control plane ListRequest into a repository ListAgents call and returns the result
pkg/service/controlplane/server.go:103
MethodListAgents
(ctx context.Context, in *ListRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:501
MethodListAgents
(context.Context, *ListRequest)
pkg/rpc/controlplane/service.pb.go:516
MethodListAgents
(ctx context.Context, req *ListRequest)
pkg/rpc/controlplane/service.pb.go:535
MethodListRuns
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
MethodListRuns
ListRuns returns a list of runs in descending order based on a set of provided predicates
pkg/memory/repository.go:170
MethodListRuns
ListRuns adapts a control plane list request into a ListRuns call and returns the result
pkg/service/controlplane/server.go:79
MethodListRuns
(ctx context.Context, in *ListRequest, opts ...grpc.CallOption)
pkg/rpc/controlplane/service.pb.go:483
MethodListRuns
(context.Context, *ListRequest)
pkg/rpc/controlplane/service.pb.go:514
MethodListRuns
(ctx context.Context, req *ListRequest)
pkg/rpc/controlplane/service.pb.go:529
MethodName
Name returns the name of the runtime being built
pkg/runtimes/runtime.go:93
MethodName
()
pkg/agent/support_test.go:15
MethodName
Name returns the runtimes name
pkg/agent/agent.go:61
FunctionNew
New constructs and configures a new Service instance
pkg/service/controlplane/server.go:40
MethodNewClaim
NewClaim delegates to underlying ClaimerFunc
pkg/agent/agent.go:80
FunctionNewFunction
NewFunction configures a new exec.Function pointer
pkg/runtimes/exec/exec.go:45
FunctionNewFunction
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
MethodNewFunction
()
pkg/agent/support_test.go:17
MethodNewFunction
NewFunction delegates to the anonymous function
pkg/agent/agent.go:64
MethodNewSpec
NewSpec constructs a Node_Spec based on the current state of the builders arguments
pkg/runtimes/runtime.go:112
MethodNewSpec
(name string)
pkg/workflow/support_test.go:20
MethodOrphan
Orphan delegates to the underlying OrphanFunc
pkg/repository/repository.go:86
MethodParse
Parse parses the state from a node into the targets set on the builders arguments
pkg/runtimes/runtime.go:130
MethodProtoMessage
()
pkg/adagio/adagio.pb.go:182
MethodProtoMessage
()
pkg/adagio/adagio.pb.go:251
MethodProtoMessage
()
pkg/adagio/adagio.pb.go:305
MethodProtoMessage
()
pkg/adagio/adagio.pb.go:351
MethodProtoMessage
()
pkg/adagio/adagio.pb.go:396
MethodProtoMessage
()
pkg/adagio/adagio.pb.go:480
MethodProtoMessage
()
pkg/adagio/adagio.pb.go:540
MethodProtoMessage
()
pkg/adagio/adagio.pb.go:581
MethodProtoMessage
()
pkg/adagio/adagio.pb.go:635
MethodProtoMessage
()
pkg/adagio/adagio.pb.go:683
← previousnext →201–300 of 551, ranked by callers