Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/GeorgeMac/adagio
/ types & classes
Types & classes
104 in github.com/GeorgeMac/adagio
⨍
Functions
551
◇
Types & classes
104
↓ 5 callers
FuncType
ClaimerFunc
ClaimerFunc is a function which can be used as a Claimer
pkg/agent/agent.go:77
↓ 3 callers
TypeAlias
Node_Status
pkg/adagio/adagio.pb.go:76
↓ 2 callers
FuncType
FunctionFunc
func(string) (*adagio.Node_Spec, error)
pkg/workflow/support_test.go:18
↓ 2 callers
FuncType
OrphanFunc
OrphanFunc is a function which can be used as an Orphaner
pkg/repository/repository.go:83
↓ 2 callers
TypeAlias
Result_Conclusion
pkg/adagio/adagio.pb.go:141
↓ 2 callers
TypeAlias
types
pkg/etcd/etcd.go:1017
↓ 1 callers
FuncType
FormatterFunc
FormatterFunc is a function which implements the fmt.Formatter interface
pkg/printing/dot.go:17
↓ 1 callers
TypeAlias
NodeOptions
NodeOptions is a slice of NodeOption types
pkg/workflow/workflow.go:29
↓ 1 callers
TypeAlias
Node_Result_Conclusion
pkg/adagio/adagio.pb.go:110
↓ 1 callers
TypeAlias
Options
Options is a slice of Option types
pkg/runtimes/debug/debug.go:70
↓ 1 callers
TypeAlias
Options
Options is a slice of Option
pkg/etcd/options.go:7
↓ 1 callers
TypeAlias
Options
Options is a slice of Option types
pkg/agent/options.go:7
↓ 1 callers
TypeAlias
RuntimeMap
RuntimeMap is a set of runtimes identified by name
pkg/agent/agent.go:33
Struct
Agent
pkg/adagio/adagio.pb.go:766
Struct
Argument
Argument is a structure which contains the properties of a argument used to call a runtime
pkg/runtimes/runtime.go:293
TypeAlias
ArgumentType
ArgumentType is a type of argument
pkg/runtimes/runtime.go:18
Struct
Builder
Builder is a struct aids in both parsing and construction of runtimes and runtime request types
pkg/runtimes/runtime.go:82
Struct
Builder
Builder is a type used to compose calls to start runs on a client It can be used to convert runtime calls into workflow nodes configure connections be
pkg/workflow/workflow.go:54
Struct
ChanceCondition
ChanceCondition is a structure which contains a potential result for the debug function and a probability represented as a float64 in the range [0, 1)
pkg/runtimes/debug/debug.go:104
Struct
Claim
pkg/adagio/adagio.pb.go:813
Interface
Claimer
Claimer is used to generate claims
pkg/agent/agent.go:72
FuncType
Constructor
Constructor is a function which constructs a repository and orphaner when provded a function which returns a time (now)
pkg/repository/repository.go:90
Interface
ControlPlaneClient
ControlPlaneClient is the client API for ControlPlane service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https:
pkg/rpc/controlplane/service.pb.go:449
Interface
ControlPlaneServer
ControlPlaneServer is the server API for ControlPlane service.
pkg/rpc/controlplane/service.pb.go:511
FuncType
DependencyOption
DependencyOption is a function which manipulates a dependency between two nodes
pkg/workflow/workflow.go:126
Struct
Edge
pkg/adagio/adagio.pb.go:625
Struct
Event
pkg/adagio/adagio.pb.go:240
TypeAlias
Event_Type
pkg/adagio/adagio.pb.go:51
Interface
Function
Function is a type which can parse and execute a node
pkg/agent/agent.go:67
Interface
Function
Function is a type which can be composed into a workflow It represents itself as a node specifications and can be invoked in the graph as a node
pkg/workflow/workflow.go:14
Struct
Function
Function is a struct which implements the agent.Runtime It executes the work for a provided node on a function to Run and uses the os/exec package to
pkg/runtimes/exec/exec.go:38
Struct
Function
Function is a structure which contains the arguments for a debug package runtime function
pkg/runtimes/debug/debug.go:59
Struct
FunctionAdaptor
FunctionAdaptor is the type used to covert a ParseRunner into a agent.Function compatable type
pkg/runtimes/runtime.go:60
Struct
Graph
Graph is a graph datastructure which contains nodes with directed edges between them
pkg/graph/graph.go:25
Struct
GraphSpec
pkg/adagio/adagio.pb.go:295
Interface
InputMappableFunction
InputMappableFunction is a Function which allows for its arguments to be mapped from node inputs
pkg/workflow/workflow.go:20
Struct
InspectRequest
pkg/rpc/controlplane/service.pb.go:177
Struct
InspectResponse
pkg/rpc/controlplane/service.pb.go:216
Struct
ListAgentsResponse
pkg/rpc/controlplane/service.pb.go:349
Struct
ListRequest
ListRequest is a request structure with predicates used to retrieve a list of runs
pkg/service/controlplane/server.go:27
Struct
ListRequest
pkg/rpc/controlplane/service.pb.go:255
Struct
ListRunsResponse
pkg/rpc/controlplane/service.pb.go:310
Struct
MetadataValue
pkg/adagio/adagio.pb.go:342
Struct
NamedRuntimeFunc
NamedRuntimeFunc implements Runtime and aids in simplifying runtime generation
pkg/agent/agent.go:55
Interface
Node
Node is a vertex in a graph
pkg/graph/graph.go:18
Struct
Node
pkg/adagio/adagio.pb.go:381
Struct
Node
Node is a printing package simplified representation of an adagio node
pkg/printing/print.go:22
Struct
Node
Node is a builder wrapper type which can be used to further create connections between nodes in the originating builder
pkg/workflow/workflow.go:117
FuncType
NodeOption
NodeOption is a functional option for a node spec
pkg/workflow/workflow.go:26
Struct
Node_Result
pkg/adagio/adagio.pb.go:570
Struct
Node_Spec
pkg/adagio/adagio.pb.go:468
Struct
Node_Spec_Retry
pkg/adagio/adagio.pb.go:531
FuncType
Option
Option is a function option for the Function type
pkg/runtimes/debug/debug.go:67
FuncType
Option
Option is a functional option for repository
pkg/etcd/options.go:4
FuncType
Option
Option is a functional option for the Pool type
pkg/agent/options.go:4
Interface
Orphaner
Orphaner is a type which can trigger the orphaning of a node based on a claim
pkg/repository/repository.go:78
Interface
ParseRunner
ParseRunner is a type which has a separate function for parsing a node and then invoking the desired behavior via Run
pkg/runtimes/runtime.go:53
Struct
Pool
Pool spins up a number of agent goroutines which subscribe to nodes transitioning into the ready state and then attempts to claim and process them
pkg/agent/agent.go:85
Interface
Repository
Repository is an implementation of a backing repository which can report on the status of runs, list runs and agents and start new runs given a graph
pkg/service/controlplane/server.go:17
Interface
Repository
Repository is a combination of the controlplane and agent repository types
pkg/repository/repository.go:72
Interface
Repository
Repository is the minimal interface for a backing repository which can notify of node related events, issue node claims and finalize the result of exe
pkg/agent/agent.go:25
Interface
Repository
Repository is a type which is both a control plane and an agent repository implementation
cmd/adagiod/main.go:31
Struct
Repository
Repository is the etcd backed implementation of an adagio Repository type (control plane and agent) It facilitates a distributed set of agents and con
pkg/etcd/etcd.go:42
Struct
Repository
Repository is an in-memory implementation of the adagio Repository interfaces It adheres to the repository test harness
pkg/memory/repository.go:35
Struct
Result
pkg/adagio/adagio.pb.go:672
Struct
Result
Result is a printing package simplified representation of an adagio result
pkg/printing/print.go:16
TypeAlias
Result
Result is a string type which reprents the result of an operation ran by debug runtime function
pkg/runtimes/debug/debug.go:88
TypeAlias
RetryCondition
RetryCondition is a key used in the node spec retry map
pkg/adagio/node.go:6
Struct
Run
pkg/adagio/adagio.pb.go:169
Struct
Run
Run is a printing package simplified representation of an adagio run
pkg/printing/print.go:34
TypeAlias
Run_Status
please upgrade the proto package
pkg/adagio/adagio.pb.go:23
Interface
Runtime
Runtime is a type with a name which can generate new runtime calls
pkg/agent/agent.go:42
Struct
Runtime
pkg/adagio/adagio.pb.go:727
Struct
Service
Service is an adagio control plane server implementation which adapts call to a Repository implementation
pkg/service/controlplane/server.go:35
Struct
StartRequest
pkg/rpc/controlplane/service.pb.go:99
Struct
StartResponse
pkg/rpc/controlplane/service.pb.go:138
Struct
Stats
pkg/adagio/adagio.pb.go:860
Struct
StatsRequest
please upgrade the proto package
pkg/rpc/controlplane/service.pb.go:29
Struct
StatsResponse
pkg/rpc/controlplane/service.pb.go:60
Struct
Stats_NodeCounts
pkg/adagio/adagio.pb.go:907
Struct
TestLayer
TestLayer is used by the TestHarness to run a prebaked scenario of calls (claims and finishes) and expect a state of the world
pkg/repository/repository.go:819
Struct
UnimplementedControlPlaneServer
UnimplementedControlPlaneServer can be embedded to have forward compatible implementations.
pkg/rpc/controlplane/service.pb.go:520
FuncType
VisitFunc
VisitFunc is a function which takes a Node and returns an error
pkg/graph/graph.go:162
Struct
claimCall
pkg/agent/support_test.go:56
Struct
client
pkg/workflow/support_test.go:38
Struct
controlPlaneClient
pkg/rpc/controlplane/service.pb.go:457
TypeAlias
edgeSet
pkg/graph/graph.go:20
Struct
filter
pkg/etcd/etcd.go:739
Struct
finishCall
pkg/agent/support_test.go:86
Struct
function
pkg/agent/support_test.go:19
Struct
graph
pkg/graph/diff.go:12
Struct
keyEvent
pkg/etcd/etcd.go:726
TypeAlias
keyEventType
pkg/etcd/etcd.go:731
TypeAlias
listenerSet
pkg/memory/repository.go:24
Struct
mappable
pkg/workflow/support_test.go:24
Struct
node
pkg/graph/graph_test.go:13
TypeAlias
nodeSet
pkg/graph/graph.go:19
Struct
oneReader
pkg/etcd/etcd.go:1038
Struct
repository
pkg/agent/support_test.go:27
Struct
run
pkg/etcd/etcd.go:973
next →
1–100 of 104, ranked by callers