MCPcopy Create free account

hub / github.com/GeorgeMac/adagio / types & classes

Types & classes104 in github.com/GeorgeMac/adagio

↓ 5 callersFuncTypeClaimerFunc
ClaimerFunc is a function which can be used as a Claimer
pkg/agent/agent.go:77
↓ 3 callersTypeAliasNode_Status
pkg/adagio/adagio.pb.go:76
↓ 2 callersFuncTypeFunctionFunc
func(string) (*adagio.Node_Spec, error)
pkg/workflow/support_test.go:18
↓ 2 callersFuncTypeOrphanFunc
OrphanFunc is a function which can be used as an Orphaner
pkg/repository/repository.go:83
↓ 2 callersTypeAliasResult_Conclusion
pkg/adagio/adagio.pb.go:141
↓ 2 callersTypeAliastypes
pkg/etcd/etcd.go:1017
↓ 1 callersFuncTypeFormatterFunc
FormatterFunc is a function which implements the fmt.Formatter interface
pkg/printing/dot.go:17
↓ 1 callersTypeAliasNodeOptions
NodeOptions is a slice of NodeOption types
pkg/workflow/workflow.go:29
↓ 1 callersTypeAliasNode_Result_Conclusion
pkg/adagio/adagio.pb.go:110
↓ 1 callersTypeAliasOptions
Options is a slice of Option types
pkg/runtimes/debug/debug.go:70
↓ 1 callersTypeAliasOptions
Options is a slice of Option
pkg/etcd/options.go:7
↓ 1 callersTypeAliasOptions
Options is a slice of Option types
pkg/agent/options.go:7
↓ 1 callersTypeAliasRuntimeMap
RuntimeMap is a set of runtimes identified by name
pkg/agent/agent.go:33
StructAgent
pkg/adagio/adagio.pb.go:766
StructArgument
Argument is a structure which contains the properties of a argument used to call a runtime
pkg/runtimes/runtime.go:293
TypeAliasArgumentType
ArgumentType is a type of argument
pkg/runtimes/runtime.go:18
StructBuilder
Builder is a struct aids in both parsing and construction of runtimes and runtime request types
pkg/runtimes/runtime.go:82
StructBuilder
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
StructChanceCondition
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
StructClaim
pkg/adagio/adagio.pb.go:813
InterfaceClaimer
Claimer is used to generate claims
pkg/agent/agent.go:72
FuncTypeConstructor
Constructor is a function which constructs a repository and orphaner when provded a function which returns a time (now)
pkg/repository/repository.go:90
InterfaceControlPlaneClient
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
InterfaceControlPlaneServer
ControlPlaneServer is the server API for ControlPlane service.
pkg/rpc/controlplane/service.pb.go:511
FuncTypeDependencyOption
DependencyOption is a function which manipulates a dependency between two nodes
pkg/workflow/workflow.go:126
StructEdge
pkg/adagio/adagio.pb.go:625
StructEvent
pkg/adagio/adagio.pb.go:240
TypeAliasEvent_Type
pkg/adagio/adagio.pb.go:51
InterfaceFunction
Function is a type which can parse and execute a node
pkg/agent/agent.go:67
InterfaceFunction
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
StructFunction
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
StructFunction
Function is a structure which contains the arguments for a debug package runtime function
pkg/runtimes/debug/debug.go:59
StructFunctionAdaptor
FunctionAdaptor is the type used to covert a ParseRunner into a agent.Function compatable type
pkg/runtimes/runtime.go:60
StructGraph
Graph is a graph datastructure which contains nodes with directed edges between them
pkg/graph/graph.go:25
StructGraphSpec
pkg/adagio/adagio.pb.go:295
InterfaceInputMappableFunction
InputMappableFunction is a Function which allows for its arguments to be mapped from node inputs
pkg/workflow/workflow.go:20
StructInspectRequest
pkg/rpc/controlplane/service.pb.go:177
StructInspectResponse
pkg/rpc/controlplane/service.pb.go:216
StructListAgentsResponse
pkg/rpc/controlplane/service.pb.go:349
StructListRequest
ListRequest is a request structure with predicates used to retrieve a list of runs
pkg/service/controlplane/server.go:27
StructListRequest
pkg/rpc/controlplane/service.pb.go:255
StructListRunsResponse
pkg/rpc/controlplane/service.pb.go:310
StructMetadataValue
pkg/adagio/adagio.pb.go:342
StructNamedRuntimeFunc
NamedRuntimeFunc implements Runtime and aids in simplifying runtime generation
pkg/agent/agent.go:55
InterfaceNode
Node is a vertex in a graph
pkg/graph/graph.go:18
StructNode
pkg/adagio/adagio.pb.go:381
StructNode
Node is a printing package simplified representation of an adagio node
pkg/printing/print.go:22
StructNode
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
FuncTypeNodeOption
NodeOption is a functional option for a node spec
pkg/workflow/workflow.go:26
StructNode_Result
pkg/adagio/adagio.pb.go:570
StructNode_Spec
pkg/adagio/adagio.pb.go:468
StructNode_Spec_Retry
pkg/adagio/adagio.pb.go:531
FuncTypeOption
Option is a function option for the Function type
pkg/runtimes/debug/debug.go:67
FuncTypeOption
Option is a functional option for repository
pkg/etcd/options.go:4
FuncTypeOption
Option is a functional option for the Pool type
pkg/agent/options.go:4
InterfaceOrphaner
Orphaner is a type which can trigger the orphaning of a node based on a claim
pkg/repository/repository.go:78
InterfaceParseRunner
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
StructPool
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
InterfaceRepository
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
InterfaceRepository
Repository is a combination of the controlplane and agent repository types
pkg/repository/repository.go:72
InterfaceRepository
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
InterfaceRepository
Repository is a type which is both a control plane and an agent repository implementation
cmd/adagiod/main.go:31
StructRepository
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
StructRepository
Repository is an in-memory implementation of the adagio Repository interfaces It adheres to the repository test harness
pkg/memory/repository.go:35
StructResult
pkg/adagio/adagio.pb.go:672
StructResult
Result is a printing package simplified representation of an adagio result
pkg/printing/print.go:16
TypeAliasResult
Result is a string type which reprents the result of an operation ran by debug runtime function
pkg/runtimes/debug/debug.go:88
TypeAliasRetryCondition
RetryCondition is a key used in the node spec retry map
pkg/adagio/node.go:6
StructRun
pkg/adagio/adagio.pb.go:169
StructRun
Run is a printing package simplified representation of an adagio run
pkg/printing/print.go:34
TypeAliasRun_Status
please upgrade the proto package
pkg/adagio/adagio.pb.go:23
InterfaceRuntime
Runtime is a type with a name which can generate new runtime calls
pkg/agent/agent.go:42
StructRuntime
pkg/adagio/adagio.pb.go:727
StructService
Service is an adagio control plane server implementation which adapts call to a Repository implementation
pkg/service/controlplane/server.go:35
StructStartRequest
pkg/rpc/controlplane/service.pb.go:99
StructStartResponse
pkg/rpc/controlplane/service.pb.go:138
StructStats
pkg/adagio/adagio.pb.go:860
StructStatsRequest
please upgrade the proto package
pkg/rpc/controlplane/service.pb.go:29
StructStatsResponse
pkg/rpc/controlplane/service.pb.go:60
StructStats_NodeCounts
pkg/adagio/adagio.pb.go:907
StructTestLayer
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
StructUnimplementedControlPlaneServer
UnimplementedControlPlaneServer can be embedded to have forward compatible implementations.
pkg/rpc/controlplane/service.pb.go:520
FuncTypeVisitFunc
VisitFunc is a function which takes a Node and returns an error
pkg/graph/graph.go:162
StructclaimCall
pkg/agent/support_test.go:56
Structclient
pkg/workflow/support_test.go:38
StructcontrolPlaneClient
pkg/rpc/controlplane/service.pb.go:457
TypeAliasedgeSet
pkg/graph/graph.go:20
Structfilter
pkg/etcd/etcd.go:739
StructfinishCall
pkg/agent/support_test.go:86
Structfunction
pkg/agent/support_test.go:19
Structgraph
pkg/graph/diff.go:12
StructkeyEvent
pkg/etcd/etcd.go:726
TypeAliaskeyEventType
pkg/etcd/etcd.go:731
TypeAliaslistenerSet
pkg/memory/repository.go:24
Structmappable
pkg/workflow/support_test.go:24
Structnode
pkg/graph/graph_test.go:13
TypeAliasnodeSet
pkg/graph/graph.go:19
StructoneReader
pkg/etcd/etcd.go:1038
Structrepository
pkg/agent/support_test.go:27
Structrun
pkg/etcd/etcd.go:973
next →1–100 of 104, ranked by callers