controller

package

v0.0.0-...-300c491 Latest Latest Go to latest Published: Jan 10, 2022 License: Apache-2.0, BSD-2-Clause, MIT, + 1 more Imports: 28 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/networkmachinery/networkmachinery-operators

Links

Open Source Insights

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

Constants ¶

View Source

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

View Source

const Name = "networkdelay-test-controller"

Variables ¶

View Source

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL