qdrmanagement

Documentation

Index

• func InterconnectHasExpectedInterRouterConnections(c framework.ContextData, interconnect *v1alpha1.Interconnect) (bool, error)
• func InterconnectHasExpectedNodes(c framework.ContextData, interconnect *v1alpha1.Interconnect) (bool, error)
• func QdmanageQuery(c framework.ContextData, pod string, entity entities.Entity, ...) ([]entities.Entity, error)
• func QdmanageQueryWithRetries(c framework.ContextData, pod string, entity entities.Entity, delaySecs int, ...) (es []entities.Entity, err error)
• func WaitForQdrNodesInPod(ctxData framework.ContextData, pod v1.Pod, expected int, ...) error
• func WaitUntilFullInterconnectWithQdrEntities(ctx context.Context, c framework.ContextData, ...) error

Functions

func InterconnectHasExpectedInterRouterConnections

func InterconnectHasExpectedInterRouterConnections(c framework.ContextData, interconnect *v1alpha1.Interconnect) (bool, error)

func InterconnectHasExpectedNodes

func InterconnectHasExpectedNodes(c framework.ContextData, interconnect *v1alpha1.Interconnect) (bool, error)

func QdmanageQuery

func QdmanageQuery(c framework.ContextData, 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 QdmanageQueryWithRetries

func QdmanageQueryWithRetries(c framework.ContextData, pod string, entity entities.Entity,
	delaySecs int, timeoutSecs int, filter func(entities.Entity) bool,
	done func(es []entities.Entity, err error) bool) (es []entities.Entity, err error)

QdmanageQueryWithRetries calls QdmanageQuery based on given delay and timeout, till the done function returns true (or if done function is nil).

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.

func WaitUntilFullInterconnectWithQdrEntities

func WaitUntilFullInterconnectWithQdrEntities(ctx context.Context, c framework.ContextData, interconnect *v1alpha1.Interconnect) error

Wait until all the pods belonging to the Interconnect deployment report expected node counts, irc's, etc.