Documentation ¶
Index ¶
- func InterRouterConnectionsForPod(f *framework.Framework, pod v1.Pod) ([]entities.Connection, error)
- func InterconnectHasExpectedInterRouterConnections(f *framework.Framework, interconnect *v1alpha1.Interconnect) (bool, error)
- func InterconnectHasExpectedNodes(f *framework.Framework, interconnect *v1alpha1.Interconnect) (bool, error)
- func QdmanageQuery(f *framework.Framework, pod string, entity entities.Entity, ...) ([]entities.Entity, error)
- func WaitForQdrNodesInPod(f *framework.Framework, pod v1.Pod, expected int, ...) error
- func WaitUntilFullInterconnectWithQdrEntities(ctx context.Context, f *framework.Framework, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InterRouterConnectionsForPod ¶
func InterRouterConnectionsForPod(f *framework.Framework, pod v1.Pod) ([]entities.Connection, error)
InterRouterConnectionsForPod will get all opened inter-router connections
func QdmanageQuery ¶
func QdmanageQuery(f *framework.Framework, pod string, entity entities.Entity, fn func(entities.Entity) bool) ([]entities.Entity, error)
QdmanageQuery executes a "qdmanager query" command on the provided pod, returning a slice of entities of the provided "entity" type.
func WaitForQdrNodesInPod ¶
func WaitForQdrNodesInPod(f *framework.Framework, pod v1.Pod, expected int, retryInterval, timeout time.Duration) error
WaitForQdrNodesInPod attempts to retrieve the list of Node Entities present on the given pod till the expected amount of nodes are present or an error or timeout occurs.
func WaitUntilFullInterconnectWithQdrEntities ¶
func WaitUntilFullInterconnectWithQdrEntities(ctx context.Context, f *framework.Framework, interconnect *v1alpha1.Interconnect) error
Wait until all the pods belonging to the Interconnect deployment report expected node counts, irc's, etc.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.