controller

Documentation

Index

• Constants
• Variables
• func Add(mgr manager.Manager) error
• func DefaultPredicates() []predicate.Predicate
• func GenerationChangedPredicate() predicate.Predicate
• type QperfOutput
  • func Qperf(ctx context.Context, config *rest.Config, ...) (*QperfOutput, error)
• type ReconcileNetworkDelayTest
  • func (r *ReconcileNetworkDelayTest) InjectClient(client client.Client) error
  • func (r *ReconcileNetworkDelayTest) InjectConfig(config *rest.Config) error
  • func (r *ReconcileNetworkDelayTest) InjectStopChannel(stopCh <-chan struct{}) error
  • func (r *ReconcileNetworkDelayTest) NodeQperf(ctx context.Context, status *v1alpha1.QperfStatus, ...) error
  • func (r *ReconcileNetworkDelayTest) PodQperf(ctx context.Context, status *v1alpha1.QperfStatus, ...) error
  • func (r *ReconcileNetworkDelayTest) Reconcile(request reconcile.Request) (reconcile.Result, error)

Constants

const (
	LogKey = "NetworkDelayTest"
	// FinalizerName is the controlplane controller finalizer.
	FinalizerName = "networkmachinery.io/networkdelay"
)

const Name = "networkdelay-test-controller"

Variables

var (
	QperfStatusTypeMeta = metav1.TypeMeta{
		APIVersion: v1alpha1.SchemeGroupVersion.String(),
		Kind:       "QperfStatus",
	}
)

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new NetworkMonitor Controller and adds it to the Manager

func DefaultPredicates

func DefaultPredicates() []predicate.Predicate

DefaultPredicates returns the default predicates for an infrastructure reconciler.

func GenerationChangedPredicate

func GenerationChangedPredicate() predicate.Predicate

GenerationChangedPredicate is a predicate for generation changes.

Types

type QperfOutput

type QperfOutput struct {
	// contains filtered or unexported fields
}

func Qperf

func Qperf(ctx context.Context, config *rest.Config, source networkmachineryv1alpha1.NetworkSourceEndpoint, destination networkmachineryv1alpha1.NetworkDestinationEndpoint, protocol, podIP string) (*QperfOutput, error)

type ReconcileNetworkDelayTest

type ReconcileNetworkDelayTest struct {
	// contains filtered or unexported fields
}

ReconcileMachineDeployment reconciles a MachineDeployment object.

func (*ReconcileNetworkDelayTest) InjectClient

func (r *ReconcileNetworkDelayTest) InjectClient(client client.Client) error

func (*ReconcileNetworkDelayTest) InjectConfig

func (r *ReconcileNetworkDelayTest) InjectConfig(config *rest.Config) error

InjectConfig implements inject.Config.

func (*ReconcileNetworkDelayTest) InjectStopChannel

func (r *ReconcileNetworkDelayTest) InjectStopChannel(stopCh <-chan struct{}) error

func (*ReconcileNetworkDelayTest) NodeQperf

func (r *ReconcileNetworkDelayTest) NodeQperf(ctx context.Context, status *v1alpha1.QperfStatus, source *v1alpha1.NetworkSourceEndpoint, destination *v1alpha1.NetworkDestinationEndpoint, protocol string) error

func (*ReconcileNetworkDelayTest) PodQperf

func (r *ReconcileNetworkDelayTest) PodQperf(ctx context.Context, status *v1alpha1.QperfStatus, source *v1alpha1.NetworkSourceEndpoint, destination *v1alpha1.NetworkDestinationEndpoint, protocol string) error

func (*ReconcileNetworkDelayTest) Reconcile

func (r *ReconcileNetworkDelayTest) Reconcile(request reconcile.Request) (reconcile.Result, error)