Documentation
¶
Index ¶
- func GetUniqueName(td *testdefinition.TestDefinition, step *tmv1beta1.DAGStep, flow string) string
- type Node
- func (n *Node) AddChildren(children ...*Node) *Node
- func (n *Node) AddParents(parents ...*Node)
- func (n *Node) ClearChildren() *Node
- func (n *Node) ClearParents() *Node
- func (n *Node) EnableOutput()
- func (n *Node) GetInputSource() *Node
- func (n *Node) GetOrDetermineArtifacts(trustedTokenMounts, untrustedTokenMounts []ProjectedTokenMount) []argov1.Artifact
- func (n *Node) HasOutput() bool
- func (n *Node) IsSerial() bool
- func (n *Node) Name() string
- func (n *Node) ParentNames() []string
- func (n *Node) RemoveChild(child *Node) *Node
- func (n *Node) RemoveChildren(children ...*Node) *Node
- func (n *Node) RemoveParent(parent *Node) *Node
- func (n *Node) SetInputSource(node *Node)
- func (n *Node) SetSerial()
- func (n *Node) SetStep(step *tmv1beta1.DAGStep)
- func (n *Node) Status() *tmv1beta1.StepStatus
- func (n *Node) Step() *tmv1beta1.DAGStep
- func (n *Node) Task(phase testmachinery.Phase, ...) []argov1.DAGTask
- type ProjectedTokenMount
- type Set
- func (s *Set) Add(nodes ...*Node) *Set
- func (s *Set) AddChildren(children ...*Node) *Set
- func (s *Set) AddParents(parents ...*Node) *Set
- func (s *Set) ClearChildren() *Set
- func (s *Set) ClearParents() *Set
- func (s *Set) Copy() *Set
- func (s *Set) GetChildren() *Set
- func (s *Set) GetParents() *Set
- func (s *Set) Has(n *Node) bool
- func (s *Set) Iterate() chan *Node
- func (s *Set) IterateInverse() chan *Node
- func (s *Set) Last() *Node
- func (s *Set) Len() int
- func (s Set) List() []*Node
- func (s *Set) Remove(nodes ...*Node) *Set
- func (s *Set) RemoveChildren(children ...*Node)
- func (s *Set) RemoveParents(parents ...*Node) *Set
- func (s Set) Set() map[*Node]sets.Empty
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetUniqueName ¶
func GetUniqueName(td *testdefinition.TestDefinition, step *tmv1beta1.DAGStep, flow string) string
Types ¶
type Node ¶
type Node struct {
Parents *Set
Children *Set
TestDefinition *testdefinition.TestDefinition
Template *argov1.Template
// contains filtered or unexported fields
}
Node is an object that represents a node of the internal DAG representation
func NewNode ¶
func NewNode(td *testdefinition.TestDefinition, step *tmv1beta1.DAGStep, flow string) *Node
NewNode creates a new TestflowNode for the internal DAG
func (*Node) AddChildren ¶
AddChildren adds Nodes as children
func (*Node) AddParents ¶
AddParents adds nodes as parents.
func (*Node) ClearChildren ¶
ClearChildren removes all children from the current node
func (*Node) ClearParents ¶
ClearParents removes all parents from the current node
func (*Node) EnableOutput ¶
func (n *Node) EnableOutput()
EnableOutput adds std output to the test and marks the node as node with output.
func (*Node) GetInputSource ¶
GetInputSource returns the input source node.
func (*Node) GetOrDetermineArtifacts ¶
func (n *Node) GetOrDetermineArtifacts(trustedTokenMounts, untrustedTokenMounts []ProjectedTokenMount) []argov1.Artifact
func (*Node) ParentNames ¶
ParentNames returns the names of all parent nodes
func (*Node) RemoveChild ¶
RemoveChild removes a node from the current node's children
func (*Node) RemoveChildren ¶
RemoveChildren removes all nodes from the current node's children
func (*Node) RemoveParent ¶
ClearParent removes a node from the current node's parents
func (*Node) SetInputSource ¶
SetInputSource sets the input source node for artifacts that are mounted to the test.
func (*Node) SetSerial ¶
func (n *Node) SetSerial()
SetSerial adds global std output to the test and marks the node as serial.
func (*Node) Status ¶
func (n *Node) Status() *tmv1beta1.StepStatus
Status returns the status for the test step based in the node.
func (*Node) Task ¶
func (n *Node) Task(phase testmachinery.Phase, trustedTokenMounts, untrustedTokenMounts []ProjectedTokenMount) []argov1.DAGTask
Task returns the argo task definition for the node.
type ProjectedTokenMount ¶
type ProjectedTokenMount struct {
Audience string
ExpirationSeconds int64
Name string
MountPath string
}
ProjectedTokenMount transports information how a projected service account token should be mounted
type Set ¶
type Set struct {
// contains filtered or unexported fields
}
func CreateNodesFromStep ¶
func CreateNodesFromStep(step *tmv1beta1.DAGStep, loc locations.Locations, globalConfig []*config.Element, flowID string) (*Set, error)
CreateNodesFromStep creates new nodes from a step and adds default configuration
func (*Set) AddChildren ¶
AddChildren adds nodes as children.
func (*Set) AddParents ¶
AddParents adds nodes as parents.
func (*Set) GetChildren ¶
GetChildren returns a set of all children
func (*Set) IterateInverse ¶
func (*Set) RemoveChildren ¶
RemoveChildren removes nodes from children
func (*Set) RemoveParents ¶
RemoveParents removes nodes from parents.
Source Files