Documentation
¶
Index ¶
- func FilterEntities(i interface{}, fn func(i interface{}) bool) []interface{}
- func ListInterRouterConnectionsForPod(ctxData framework.ContextData, pod v1.Pod) ([]entities2.Connection, error)
- func QdmanageQuery(ctxData framework.ContextData, pod string, entity string) (string, error)
- func QdmanageQueryConnections(ctxData framework.ContextData, pod string) ([]entities2.Connection, error)
- func QdmanageQueryConnectionsFilter(ctxData framework.ContextData, pod string, ...) ([]entities2.Connection, error)
- func QdmanageQueryNodes(ctxData framework.ContextData, pod string) ([]entities2.Node, error)
- func QdmanageQueryNodesFilter(ctxData framework.ContextData, pod string, ...) ([]entities2.Node, error)
- func WaitForQdrNodesInPod(ctxData framework.ContextData, pod v1.Pod, expected int, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FilterEntities ¶
func FilterEntities(i interface{}, fn func(i interface{}) bool) []interface{}
filter is an internal method to be invoked by specific Query<Entity> methods so all methods can reuse the same code for filtering entities
func ListInterRouterConnectionsForPod ¶
func ListInterRouterConnectionsForPod(ctxData framework.ContextData, pod v1.Pod) ([]entities2.Connection, error)
ListInterRouterConnectionsForPod will get all opened inter-router connections
func QdmanageQuery ¶
QdmanageQuery executes a "qdmanage query" command on the given pod to retrieve all entities for the given <entity> type.
func QdmanageQueryConnections ¶
func QdmanageQueryConnections(ctxData framework.ContextData, pod string) ([]entities2.Connection, error)
QdmanageQueryConnections use qdmanage to query existing connections on the given pod
func QdmanageQueryConnectionsFilter ¶
func QdmanageQueryConnectionsFilter(ctxData framework.ContextData, pod string, filter func(entity interface{}) bool) ([]entities2.Connection, error)
QdmanageQueryConnectionsFilter use qdmanage to query existing connections on the given pod filtering entities using the provided filter function (if one is given)
func QdmanageQueryNodes ¶
QdmanageQueryNodes use qdmanage to query existing nodes on the given pod
func QdmanageQueryNodesFilter ¶
func QdmanageQueryNodesFilter(ctxData framework.ContextData, pod string, filter func(entity interface{}) bool) ([]entities2.Node, error)
QdmanageQueryNodesFilter use qdmanage to query existing nodes on the given pod filtering entities using the provided filter function (if one given)
func WaitForQdrNodesInPod ¶
func WaitForQdrNodesInPod(ctxData framework.ContextData, 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.
Types ¶
This section is empty.
Source Files
Directories